wsub

Documentation

Index

• func NewSubscriber(config *Config, topic string, consumeFunc subscriber.ConsumeFunc) (subscriber.Subscriber, error)
• type Config
  • func NewConfig() (*Config, error)
• type MultiSubscriber
  • func NewMultiSubscriber(config *Config) *MultiSubscriber
  • func (s *MultiSubscriber) Close() error
  • func (s *MultiSubscriber) Subscribe(topic string, consumeFunc subscriber.ConsumeFunc) error

Functions

func NewSubscriber

func NewSubscriber(config *Config, topic string, consumeFunc subscriber.ConsumeFunc) (subscriber.Subscriber, error)

Types

type Config

type Config struct {
	LoggerDebug   bool   `env:"REDIS_SUB_LOGGER_DEBUG,notEmpty" envdefault:"false"`
	LoggerTrace   bool   `env:"REDIS_SUB_LOGGER_TRACE,notEmpty" envdefault:"false"`
	ConsumerGroup string `env:"REDIS_SUB_CONSUMER_GROUP_ID,required"`
}

func NewConfig

func NewConfig() (*Config, error)

type MultiSubscriber

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

Subscriber to manage multiple subscribers

func NewMultiSubscriber

func NewMultiSubscriber(config *Config) *MultiSubscriber

func (*MultiSubscriber) Close

func (s *MultiSubscriber) Close() error

func (*MultiSubscriber) Subscribe

func (s *MultiSubscriber) Subscribe(topic string, consumeFunc subscriber.ConsumeFunc) error