Method publishEvent

internal/dmap/service.go:115–129

(e events.Event)

}

func (s *Service) publishEvent(e events.Event) {
	defer s.wg.Done()

	rc := s.client.Get(s.rt.This().String())
	data, err := e.Encode()
	if err != nil {
		s.log.V(3).Printf("[ERROR] Failed to encode %s: %v", getType(e), err)
		return
	}
	err = rc.Publish(s.ctx, events.ClusterEventsChannel, data).Err()
	if err != nil {
		s.log.V(3).Printf("[ERROR] Failed to publish %s to %s: %v",
			getType(e), events.ClusterEventsChannel, err)
	}
}

// Start starts the distributed map service.
func (s *Service) Start() error {