Versions in this module Expand all Collapse all v1 v1.0.0 Nov 9, 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()
Go to main page