yyc
diff --git a/‎README.rst
Lines changed: 4 additions & 7 deletions b/‎README.rst
Lines changed: 4 additions & 7 deletions
diff --git a/‎fluent/sender.py
Lines changed: 2 additions & 0 deletions b/‎fluent/sender.py
Lines changed: 2 additions & 0 deletions
diff --git a/‎tests/test_sender.py
Lines changed: 16 additions & 0 deletions b/‎tests/test_sender.py
Lines changed: 16 additions & 0 deletions
@@ -90,18 +90,15 @@ fluentd, with tag 'app.follow' and the attributes 'from' and 'to'.
     cur_time = int(time.time())
     logger.emit_with_time('follow', cur_time, {'from': 'userA', 'to':'userB'})
 
-To sending events with nanosecond-precision timestamps (Fluent 0.14 and up),
-specify `nanosecond_precision` on `FluentSender` or use `sender.EventTime`.
+To send events with nanosecond-precision timestamps (Fluent 0.14 and up),
+specify `nanosecond_precision` on `FluentSender`.
 
 .. code:: python
 
-    # Use current time
+    # Use nanosecond
     logger = sender.FluentSender('app', nanosecond_precision=True)
     logger.emit('follow', {'from': 'userA', 'to': 'userB'})
-
-    # Specify optional time
-    cur_time = sender.EventTime(time.time())
-    logger.emit_with_time('follow', cur_time, {'from': 'userA', 'to':'userB'})
+    logger.emit_with_time('follow', time.time(), {'from': 'userA', 'to': 'userB'})
 
 You can detect an error via return value of `emit`. If an error happens in `emit`, `emit` returns `False` and get an error object using `last_error` method.
 
 
@@ -83,6 +83,8 @@ def emit(self, label, data):
         return self.emit_with_time(label, cur_time, data)
 
     def emit_with_time(self, label, timestamp, data):
+        if self.nanosecond_precision and isinstance(timestamp, float):
+            timestamp = EventTime(timestamp)
         try:
             bytes_ = self._make_packet(label, timestamp, data)
         except Exception as e:
 
@@ -79,6 +79,22 @@ def test_nanosecond(self):
         self.assertTrue(isinstance(data[0][1], msgpack.ExtType))
         eq(data[0][1].code, 0)
 
+    def test_nanosecond_coerce_float(self):
+        time = 1490061367.8616468906402588
+        sender = self._sender
+        sender.nanosecond_precision = True
+        sender.emit_with_time('foo', time, {'bar': 'baz'})
+        sender._close()
+        data = self.get_data()
+        eq = self.assertEqual
+        eq(1, len(data))
+        eq(3, len(data[0]))
+        eq('test.foo', data[0][0])
+        eq({'bar': 'baz'}, data[0][2])
+        self.assertTrue(isinstance(data[0][1], msgpack.ExtType))
+        eq(data[0][1].code, 0)
+        eq(data[0][1].data, b'X\xd0\x8873[\xb0*')
+
     def test_no_last_error_on_successful_emit(self):
         sender = self._sender
         sender.emit('foo', {'bar': 'baz'})