Versions in this module Expand all Collapse all v1 v1.0.0 Sep 19, 2023 Changes in this version + const AttemptName + const DeadLetterExchange + const DeadLetterRoutingKey + const DefaultAttempt + const DefaultExchange + const DelayKey + const ErrDelay + const NotFoundIndex + const TtrKey + const VERSION + var Config *config + var Consumer = consumer + var Producer = producer + var RabbitmqConfig = rabbitmqConfig + var Util = util + func HeartBeater(interval time.Duration, job func()) + type ConsumerHandler func(ctx context.Context, data *QueueData) error + type ExpireFunc func(interface{}) + type NewFunc func() (interface{}, error) + type Pool struct + ExpireFunc func(interface{}) + NewFunc func() (interface{}, error) + TTL time.Duration + func NewPool(ttl time.Duration, newFunc NewFunc, expireFunc ...ExpireFunc) *Pool + func (p *Pool) Clear() + func (p *Pool) Close() + func (p *Pool) Get() (interface{}, error) + func (p *Pool) Put(value interface{}) error + func (p *Pool) Size() int + func (p *Pool) TimestampMilli() int64 + type Queue struct + Data interface{} + Delay int + QueueName string + Ttr int + Type string + type QueueData struct + Data interface{} + Headers amqp.Table + MessageId string + QueueName string + Ttr int + Type string
Go to main page