msgqueue

May 29, 2017

Changes in this version

type Options

+ MaxBackoff time.Duration

May 1, 2017

Changes in this version

type Options

+ WorkerLimit int

Apr 12, 2017

Changes in this version

type Redis

+ Subscribe func(channels ...string) *redis.PubSub

Apr 10, 2017

Changes in this version

type Options

+ MaxWorkers int

type Redis

+ Eval func(script string, keys []string, args ...interface{}) *redis.Cmd

Apr 5, 2017

Changes in this version

type Options

+ GroupName string

Apr 4, 2017

Changes in this version

+ var ErrDuplicate = errors.New("queue: message with such name already exists")

+ type Handler interface

+ HandleMessage func(msg *Message) error

+ func NewHandler(fn interface{}) Handler

+ type HandlerFunc func(*Message) error

+ func (fn HandlerFunc) HandleMessage(msg *Message) error

+ type Message struct

+ Args []interface{}

+ Body string

+ Delay time.Duration

+ Id string

+ Name string

+ ReservationId string

+ ReservedCount int

+ func NewMessage(args ...interface{}) *Message

+ func (m *Message) MarshalArgs() (string, error)

+ func (m *Message) SetDelayName(delay time.Duration, args ...interface{})

+ func (m *Message) String() string

+ type Options struct

+ BufferSize int

+ FallbackHandler interface{}

+ Handler interface{}

+ MinBackoff time.Duration

+ Name string

+ RateLimit timerate.Limit

+ RateLimiter RateLimiter

+ Redis Redis

+ ReservationTimeout time.Duration

+ RetryLimit int

+ ScavengerNumber int

+ Storage Storage

+ WorkerNumber int

+ func (opt *Options) Init()

+ type RateLimiter interface

+ AllowRate func(name string, limit timerate.Limit) (delay time.Duration, allow bool)

+ type Redis interface

+ Del func(...string) *redis.IntCmd

+ Pipelined func(func(pipe *redis.Pipeline) error) ([]redis.Cmder, error)

+ Publish func(channel, message string) *redis.IntCmd

+ SAdd func(key string, members ...interface{}) *redis.IntCmd

+ SMembers func(key string) *redis.StringSliceCmd

+ SetNX func(string, interface{}, time.Duration) *redis.BoolCmd

+ type Storage interface

+ Exists func(key string) bool