rmq

package module

Go to main page

Versions in this module

v1

v1.0.4

Sep 15, 2019

Changes in this version

type Queue

+ ReturnAllUnacked func() int

type TestQueue

+ func (queue *TestQueue) ReturnAllUnacked() int

v1.0.3

Sep 15, 2019

v1.0.2

Sep 15, 2019

v1.0.1

Sep 15, 2019

Changes in this version

+ func CleanConnection(connection *redisConnection) error

+ func CleanQueue(queue *redisQueue)

+ func OpenConnectionWithTestRedisClient(tag string) *redisConnection

+ type ConsumerFunc func(Delivery)

+ func (consumerFunc ConsumerFunc) Consume(delivery Delivery)

type Deliveries

+ func (deliveries Deliveries) Push() int

type Queue

+ AddConsumerFunc func(tag string, consumerFunc ConsumerFunc) string

+ type RedisClient interface

+ Del func(key string) (affected int, ok bool)

+ FlushDb func()

+ LLen func(key string) (affected int, ok bool)

+ LPush func(key, value string) bool

+ LRem func(key string, count int, value string) (affected int, ok bool)

+ LTrim func(key string, start, stop int)

+ RPopLPush func(source, destination string) (value string, ok bool)

+ SAdd func(key, value string) bool

+ SMembers func(key string) (members []string)

+ SRem func(key, value string) (affected int, ok bool)

+ Set func(key string, value string, expiration time.Duration) bool

+ TTL func(key string) (ttl time.Duration, ok bool)

+ type RedisWrapper struct

+ func (wrapper RedisWrapper) Del(key string) (affected int, ok bool)

+ func (wrapper RedisWrapper) FlushDb()

+ func (wrapper RedisWrapper) LLen(key string) (affected int, ok bool)

+ func (wrapper RedisWrapper) LPush(key, value string) bool

+ func (wrapper RedisWrapper) LRem(key string, count int, value string) (affected int, ok bool)

+ func (wrapper RedisWrapper) LTrim(key string, start, stop int)

+ func (wrapper RedisWrapper) RPopLPush(source, destination string) (value string, ok bool)

+ func (wrapper RedisWrapper) SAdd(key, value string) bool

+ func (wrapper RedisWrapper) SMembers(key string) []string

+ func (wrapper RedisWrapper) SRem(key, value string) (affected int, ok bool)

+ func (wrapper RedisWrapper) Set(key string, value string, expiration time.Duration) bool

+ func (wrapper RedisWrapper) TTL(key string) (ttl time.Duration, ok bool)

type TestBatchConsumer

+ AutoFinish bool

+ ConsumedCount int

type TestQueue

+ func (queue *TestQueue) AddConsumerFunc(tag string, consumerFunc ConsumerFunc) string

+ type TestRedisClient struct

+ func NewTestRedisClient() *TestRedisClient

+ func (client *TestRedisClient) Del(key string) (affected int, ok bool)

+ func (client *TestRedisClient) FlushDb()

+ func (client *TestRedisClient) Get(key string) string

+ func (client *TestRedisClient) LLen(key string) (affected int, ok bool)

+ func (client *TestRedisClient) LPush(key, value string) bool

+ func (client *TestRedisClient) LRange(key string, start, end int) []string

+ func (client *TestRedisClient) LRem(key string, count int, value string) (affected int, ok bool)

+ func (client *TestRedisClient) LTrim(key string, start, stop int)

+ func (client *TestRedisClient) RPopLPush(source, destination string) (value string, ok bool)

+ func (client *TestRedisClient) SAdd(key, value string) bool

+ func (client *TestRedisClient) SMembers(key string) (members []string)

+ func (client *TestRedisClient) SRem(key, value string) (affected int, ok bool)

+ func (client *TestRedisClient) Set(key string, value string, expiration time.Duration) bool

+ func (client *TestRedisClient) TTL(key string) (ttl time.Duration, ok bool)

v1.0.0

Jul 6, 2017

Changes in this version

+ func ActiveSign(active bool) string

+ func OpenConnection(tag, network, address string, db int) *redisConnection

+ func OpenConnectionWithRedisClient(tag string, redisClient *redis.Client) *redisConnection

+ type BatchConsumer interface

+ Consume func(batch Deliveries)

+ type Cleaner struct

+ func NewCleaner(connection *redisConnection) *Cleaner

+ func (cleaner *Cleaner) Clean() error

+ func (cleaner *Cleaner) CleanConnection(connection *redisConnection) error

+ func (cleaner *Cleaner) CleanQueue(queue *redisQueue)

+ type Connection interface

+ CollectStats func(queueList []string) Stats

+ GetOpenQueues func() []string

+ OpenQueue func(name string) Queue

+ type ConnectionStat struct

+ func (stat ConnectionStat) String() string

+ type ConnectionStats map[string]ConnectionStat

+ type Consumer interface

+ Consume func(delivery Delivery)

+ type Deliveries []Delivery

+ func (deliveries Deliveries) Ack() int

+ func (deliveries Deliveries) Reject() int

+ type Delivery interface

+ Ack func() bool

+ Payload func() string

+ Push func() bool

+ Reject func() bool

+ type Queue interface

+ AddBatchConsumer func(tag string, batchSize int, consumer BatchConsumer) string

+ AddBatchConsumerWithTimeout func(tag string, batchSize int, timeout time.Duration, consumer BatchConsumer) string

+ AddConsumer func(tag string, consumer Consumer) string

+ Close func() bool

+ Publish func(payload string) bool

+ PublishBytes func(payload []byte) bool

+ PurgeReady func() int

+ PurgeRejected func() int

+ ReturnAllRejected func() int

+ ReturnRejected func(count int) int

+ SetPushQueue func(pushQueue Queue)

+ StartConsuming func(prefetchLimit int, pollDuration time.Duration) bool

+ StopConsuming func() bool

+ type QueueStat struct

+ ReadyCount int

+ RejectedCount int

+ func NewQueueStat(readyCount, rejectedCount int) QueueStat

+ func (stat QueueStat) ConnectionCount() int

+ func (stat QueueStat) ConsumerCount() int

+ func (stat QueueStat) String() string

+ func (stat QueueStat) UnackedCount() int

+ type QueueStats map[string]QueueStat

+ type State int

+ const Acked

+ const Pushed

+ const Rejected

+ const Unacked

+ func (i State) String() string

+ type Stats struct

+ QueueStats QueueStats

+ func CollectStats(queueList []string, mainConnection *redisConnection) Stats

+ func NewStats() Stats

+ func (stats Stats) GetHtml(layout, refresh string) string

+ func (stats Stats) String() string

+ type TestBatchConsumer struct

+ LastBatch Deliveries

+ func NewTestBatchConsumer() *TestBatchConsumer

+ func (consumer *TestBatchConsumer) Consume(batch Deliveries)

+ func (consumer *TestBatchConsumer) Finish()

+ type TestConnection struct

+ func NewTestConnection() TestConnection

+ func (connection TestConnection) CollectStats(queueList []string) Stats

+ func (connection TestConnection) GetDeliveries(queueName string) []string

+ func (connection TestConnection) GetDelivery(queueName string, index int) string

+ func (connection TestConnection) GetOpenQueues() []string

+ func (connection TestConnection) OpenQueue(name string) Queue

+ func (connection TestConnection) Reset()

+ type TestConsumer struct

+ AutoAck bool

+ AutoFinish bool

+ LastDeliveries []Delivery

+ LastDelivery Delivery

+ SleepDuration time.Duration

+ func NewTestConsumer(name string) *TestConsumer

+ func (consumer *TestConsumer) Consume(delivery Delivery)

+ func (consumer *TestConsumer) Finish()

+ func (consumer *TestConsumer) String() string

+ type TestDelivery struct

+ State State

+ func NewTestDelivery(content interface{}) *TestDelivery

+ func NewTestDeliveryString(payload string) *TestDelivery

+ func (delivery *TestDelivery) Ack() bool

+ func (delivery *TestDelivery) Payload() string

+ func (delivery *TestDelivery) Push() bool

+ func (delivery *TestDelivery) Reject() bool

+ type TestQueue struct

+ LastDeliveries []string

+ func NewTestQueue(name string) *TestQueue

+ func (queue *TestQueue) AddBatchConsumer(tag string, batchSize int, consumer BatchConsumer) string

+ func (queue *TestQueue) AddBatchConsumerWithTimeout(tag string, batchSize int, timeout time.Duration, consumer BatchConsumer) string

+ func (queue *TestQueue) AddConsumer(tag string, consumer Consumer) string

+ func (queue *TestQueue) Close() bool

+ func (queue *TestQueue) Publish(payload string) bool

+ func (queue *TestQueue) PublishBytes(payload []byte) bool

+ func (queue *TestQueue) PurgeReady() int

+ func (queue *TestQueue) PurgeRejected() int

+ func (queue *TestQueue) Reset()

+ func (queue *TestQueue) ReturnAllRejected() int

+ func (queue *TestQueue) ReturnRejected(count int) int

+ func (queue *TestQueue) SetPushQueue(pushQueue Queue)

+ func (queue *TestQueue) StartConsuming(prefetchLimit int, pollDuration time.Duration) bool

+ func (queue *TestQueue) StopConsuming() bool

+ func (queue *TestQueue) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL