Add event id to router events

router/service/proto/router.proto

@@ -93,12 +93,14 @@ enum EventType {
 
 // Event is routing table event
 message Event {
+	// the unique event id
+	string id = 1;
         // type of event
-        EventType type = 1;
+        EventType type = 2;
         // unix timestamp of event
-        int64 timestamp = 2;
+        int64 timestamp = 3;
         // service route
-	Route route = 3;
+	Route route = 4;
 }
 
 // Query is passed in a LookupRequest

router/service/service.go

@@ -121,6 +121,7 @@ func (s *svc) advertiseEvents(advertChan chan *router.Advert, stream pb.Router_A
 			}
 
 			events[i] = &router.Event{
+				Id:        event.Id,
 				Type:      router.EventType(event.Type),
 				Timestamp: time.Unix(0, event.Timestamp),
 				Route:     route,
@@ -179,6 +180,7 @@ func (s *svc) Process(advert *router.Advert) error {
 			Metric:  event.Route.Metric,
 		}
 		e := &pb.Event{
+			Id:        event.Id,
 			Type:      pb.EventType(event.Type),
 			Timestamp: event.Timestamp.UnixNano(),
 			Route:     route,

router/service/watcher.go

@@ -65,6 +65,7 @@ func (w *watcher) watch(stream pb.Router_WatchService) error {
 		}
 
 		event := &router.Event{
+			Id:        resp.Id,
 			Type:      router.EventType(resp.Type),
 			Timestamp: time.Unix(0, resp.Timestamp),
 			Route:     route,

router/table.go

@@ -38,6 +38,10 @@ func (t *table) sendEvent(e *Event) {
 	t.RLock()
 	defer t.RUnlock()
 
+	if len(e.Id) == 0 {
+		e.Id = uuid.New().String()
+	}
+
 	for _, w := range t.watchers {
 		select {
 		case w.resChan <- e:

router/watcher.go

@@ -39,6 +39,8 @@ func (t EventType) String() string {
 
 // Event is returned by a call to Next on the watcher.
 type Event struct {
+	// Unique id of the event
+	Id string
 	// Type defines type of event
 	Type EventType
 	// Timestamp is event timestamp