Include timestamp in eliot:destination_failure.

eliot/_output.py

@@ -5,6 +5,7 @@
 from __future__ import unicode_literals, absolute_import
 
 import sys
+import time
 import json as pyjson
 
 from characteristic import attributes
@@ -143,6 +144,7 @@ class Logger(object):
     can then replace a specific L{Logger} with a L{MemoryLogger}.
     """
     _destinations = Destinations()
+    _time = time.time
 
     def _safeUnicodeDictionary(self, dictionary):
         """
@@ -191,6 +193,7 @@ def write(self, dictionary, serializer=None):
                     self._destinations.send({
                         "message_type": "eliot:destination_failure",
                         "reason": safeunicode(exception),
+                        "timestamp": self._time(),
                         "exception":
                         exc_type.__module__ + "." + exc_type.__name__,
                         "message": self._safeUnicodeDictionary(dictionary)})

eliot/tests/test_output.py

@@ -505,7 +505,8 @@ def raiser(i):
         # Calling _safeUnicodeDictionary multiple times leads to
         # inconsistent results due to hash ordering, so compare contents:
         assertContainsFields(self, written[1],
-                             {"message_type": "eliot:serialization_failure"})
+                             {"message_type": "eliot:serialization_failure",
+                              })
         self.assertEqual(eval(written[1]["message"]),
                          dict((repr(key), repr(value)) for
                               (key, value) in message.items()))
@@ -517,6 +518,7 @@ def test_destinationExceptionCaught(self):
         logged.
         """
         logger = Logger()
+        logger._time = lambda: 1234.5
         logger._destinations = Destinations()
         dest = BadDestination()
         logger._destinations.add(dest)
@@ -527,6 +529,7 @@ def test_destinationExceptionCaught(self):
             self, dest[0],
             {"message_type": "eliot:destination_failure",
              "message": logger._safeUnicodeDictionary(message),
+             "timestamp": 1234.5,
              "reason": "ono",
              "exception": "eliot.tests.test_output.MyException"})
 
@@ -537,6 +540,7 @@ def test_destinationMultipleExceptionsCaught(self):
         logged for each.
         """
         logger = Logger()
+        logger._time = lambda: 1234.5
         logger._destinations = Destinations()
         logger._destinations.add(BadDestination())
         logger._destinations.add(lambda msg: 1/0)
@@ -557,10 +561,12 @@ def test_destinationMultipleExceptionsCaught(self):
              {"message_type": "eliot:destination_failure",
               "message": logger._safeUnicodeDictionary(message),
               "reason": "ono",
+              "timestamp": 1234.5,
               "exception": "eliot.tests.test_output.MyException"},
              {"message_type": "eliot:destination_failure",
               "message": logger._safeUnicodeDictionary(message),
               "reason": zero_divide,
+              "timestamp": 1234.5,
               "exception": zero_type}])