/

/

rmq

Обзор ДокументацияВойти

/

/

rmq

Аналитика

Безопасность

rmq

Публичный

Описание

Fork

1.76 MiB

Лицензия

В избранном0

Языки

Go100%

Сообщить о нарушении

Коммиты:

Sergey Butenin

Bugfix with stop consuming

20 май 2022, 17:02

20 май 2022, 17:02fa724eb

All examples now use v4 imports instead of v3

5 лет назад

Updates go-redis version

6 лет назад

Adding go versions 1.15 and 1.16 to test

5 лет назад

11 лет назад

v3 -> v4 in README.md

5 лет назад

batch_consumer.go

Change package name to rmq

11 лет назад

Rename hijacked connections

6 лет назад

cleaner_test.go

Fixed problem where slow redis causes test failure

5 лет назад

🎨 feat: change `*redis.Client` to `redis.Cmable` interface to support redis cluster client

5 лет назад

Use ConsumerFunc as parater type in AddConsumerFunc

8 лет назад

Inject context into OpenConnection() functions

6 лет назад

Check context in redisDelivery.move()

6 лет назад

Add Unwrap() methods to error types

6 лет назад

Setting version to V4

6 лет назад

Bugfix with stop consuming

4 года назад

Bugfix with stop consuming

4 года назад

refactor jitter method

5 лет назад

Remove dependency on uniuri

6 лет назад

redis_client.go

Check affected count in some more places

6 лет назад

Reorder functions

6 лет назад

redis_wrapper.go

🎨 feat: change `*redis.Client` to `redis.Cmable` interface to support redis cluster client

5 лет назад

make state in test_delivery public

11 лет назад

state_string.go

make state in test_delivery public

11 лет назад

Rename hijacked connections

6 лет назад

Handle contexts internally

6 лет назад

test_batch_consumer.go

Inject context into OpenConnection() functions

6 лет назад

test_connection.go

Connection remember open queues

6 лет назад

test_connection_test.go

Switch from gocheck to testify

6 лет назад

test_consumer.go

Ensure StopConsuming has completed for all calls

5 лет назад

test_delivery.go

6 лет назад

test_delivery_test.go

Inject context into OpenConnection() functions

6 лет назад

Reuse error channel passed into OpenConnection()

6 лет назад

test_redis_client.go

Rename CloseAllQueues() -> unlistAllQueues()

6 лет назад

test_redis_client_test.go

SAdd() return number of elements

6 лет назад

Fixed problem where slow redis causes test failure

5 лет назад

README.md