subscriber

Documentation

Index

• type Subscriber
  • 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

Types

type Subscriber

type Subscriber struct {
	CMQ    *cmq.CMQ
	Tracer trace.Tracer
	Logger *zap.Logger
	// contains filtered or unexported fields
}

func New

func New(c *cmq.CMQ, logger *zap.Logger, tracer trace.Tracer) *Subscriber

func (*Subscriber) RegisterHandler

func (s *Subscriber) RegisterHandler(c chan<- model.ChanneledEvent)

func (*Subscriber) Subcribe

func (s *Subscriber) Subcribe() error