Versions in this module Expand all Collapse all v1 v1.2.0 Aug 5, 2021 v1.1.0 Aug 5, 2021 v1.0.0 Aug 5, 2021 Changes in this version + type Subscriber struct + CMQ *cmq.CMQ + Logger *zap.Logger + Tracer trace.Tracer + func New(c *cmq.CMQ, logger *zap.Logger, tracer trace.Tracer) *Subscriber + func (s *Subscriber) RegisterHandler(c chan<- model.ChanneledEvent) + func (s *Subscriber) Subcribe() error
Go to main page