Versions in this module Expand all Collapse all v1 v1.1.0 Jul 29, 2021 Changes in this version + func Assign(queueName string, prefetchLimit int64, duration time.Duration, f Func, ...) + func AssignBatch(queueName string, prefetchLimit int64, duration time.Duration, batchSize int64, ...) + func Bind(conf ...Conf) + func Publish(name string, payload interface{}) error + func Purge(queueName string, qt KeyFlag) error + func Return(queueName string, qt KeyFlag, max int64) error + func StopAllConsuming() error + func StopConsuming(queueName string) error + type AssignFunc func() error + type BatchConsumerFunc func(deliveries rmq.Deliveries) + func (batchConsumerFunc BatchConsumerFunc) Consume(delivery rmq.Deliveries) + type Conf func(*RedisMessageConn) + func CleanerTick(duration time.Duration) Conf + func Custom(custom interface{}) Conf + func Mongo(mg *mongo.MgoClient) Conf + func Name(name string) Conf + func Redis(rd *redis.RdClient) Conf + func Repo(rp *repo.Repository) Conf + type Configuration struct + func (c *Configuration) CleanerTick() time.Duration + func (c *Configuration) Custom() interface{} + func (c *Configuration) Mongo() *mongo.MgoClient + func (c *Configuration) Redis() *redis.RdClient + func (c *Configuration) Repo() *repo.Repository + type Deliveries = rmq.Deliveries + type Delivery = rmq.Delivery + type Func func(Delivery, *Configuration) + type FuncBatch func(Deliveries, *Configuration) + type KeyFlag int + const Ready + const Rejected + const Unacked + type RedisMessageConn struct
Go to main page