sub

Documentation

Index

• type Subscriber
  • func GetSubscriberByConfig(ctx context.Context, cfg *config.Config, wmLogger watermill.LoggerAdapter, ...) (*Subscriber, error)
  • func NewSubscriber(c context.Context, sub message.Subscriber, logger *zap.Logger) *Subscriber
  • func (s *Subscriber) Close() error
  • func (s *Subscriber) Handler(msg *message.Message) error
  • func (s *Subscriber) Subscribe(ctx context.Context, topic string) (<-chan *message.Message, error)

Types

type Subscriber

type Subscriber struct {
	// contains filtered or unexported fields
}

func GetSubscriberByConfig

func GetSubscriberByConfig(
	ctx context.Context,
	cfg *config.Config,
	wmLogger watermill.LoggerAdapter,
	logger *zap.Logger,
) (*Subscriber, error)

func NewSubscriber

func NewSubscriber(c context.Context, sub message.Subscriber, logger *zap.Logger) *Subscriber

func (*Subscriber) Close

func (s *Subscriber) Close() error

func (*Subscriber) Handler

func (s *Subscriber) Handler(msg *message.Message) error

func (*Subscriber) Subscribe

func (s *Subscriber) Subscribe(ctx context.Context, topic string) (<-chan *message.Message, error)