queue

Aug 22, 2023

Changes in this version

+ type Memory struct

+ PoolNum uint

+ func NewMemory(poolNum uint) *Memory

+ func (*Memory) String() string

+ func (m *Memory) Append(message storage.Messager) error

+ func (m *Memory) Register(name string, f storage.ConsumerFunc)

+ func (m *Memory) Run()

+ func (m *Memory) Shutdown()

+ type Message struct

+ ErrorCount int

+ func (m *Message) GetErrorCount() int

+ func (m *Message) GetID() string

+ func (m *Message) GetPrefix() (prefix string)

+ func (m *Message) GetStream() string

+ func (m *Message) GetValues() map[string]interface{}

+ func (m *Message) SetErrorCount(count int)

+ func (m *Message) SetID(id string)

+ func (m *Message) SetPrefix(prefix string)

+ func (m *Message) SetStream(stream string)

+ func (m *Message) SetValues(values map[string]interface{})

+ type NSQ struct

+ func NewNSQ(addresses []string, cfg *nsq.Config, channelPrefix string) (*NSQ, error)

+ func (NSQ) String() string

+ func (e *NSQ) Append(message storage.Messager) error

+ func (e *NSQ) Register(name string, f storage.ConsumerFunc)

+ func (e *NSQ) Run()

+ func (e *NSQ) Shutdown()

+ type Redis struct

+ func NewRedis(producerOptions *redisqueue.ProducerOptions, ...) (*Redis, error)

+ func (Redis) String() string

+ func (r *Redis) Append(message storage.Messager) error

+ func (r *Redis) Register(name string, f storage.ConsumerFunc)

+ func (r *Redis) Run()

+ func (r *Redis) Shutdown()