/
bas
/
rmq
Обзор
Документация
Войти
/
bas
/
rmq
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
rmq
Следить
1
Форк
0
Избранное
0
GigaIDE Cloud
SB
Sergey Butenin
Bugfix with stop consuming
3 года назад
fa724eb
Описание
Fork
В избранном
0
Следят
1
Языки
Go
Сообщить о нарушении
master
Ветки:
8
Коммиты:
289
Теги:
10
Код
example
All examples now use v4 imports instead of v3
4 года назад
.gitignore
Updates go-redis version
5 лет назад
.travis.yml
Adding go versions 1.15 and 1.16 to test
4 года назад
LICENSE
Initial commit
10 лет назад
README.md
v3 -> v4 in README.md
4 года назад
batch_consumer.go
Change package name to rmq
10 лет назад
cleaner.go
Rename hijacked connections
5 лет назад
cleaner_test.go
Fixed problem where slow redis causes test failure
4 года назад
connection.go
🎨 feat: change `*redis.Client` to `redis.Cmable` interface to support redis cluster client
4 года назад
consumer.go
Use ConsumerFunc as parater type in AddConsumerFunc
7 лет назад
deliveries.go
Inject context into OpenConnection() functions
5 лет назад
delivery.go
Check context in redisDelivery.move()
5 лет назад
errors.go
Add Unwrap() methods to error types
5 лет назад
go.mod
Setting version to V4
5 лет назад
go.sum
Bugfix with stop consuming
3 года назад
queue.go
Bugfix with stop consuming
3 года назад
queue_test.go
refactor jitter method
3 года назад
rand.go
Remove dependency on uniuri
5 лет назад
redis_client.go
Check affected count in some more places
5 лет назад
redis_keys.go
Reorder functions
5 лет назад
redis_wrapper.go
🎨 feat: change `*redis.Client` to `redis.Cmable` interface to support redis cluster client
4 года назад
state.go
make state in test_delivery public
9 лет назад
state_string.go
make state in test_delivery public
9 лет назад
stats.go
Rename hijacked connections
5 лет назад
stats_test.go
Handle contexts internally
5 лет назад
test_batch_consumer.go
Inject context into OpenConnection() functions
5 лет назад
test_connection.go
Connection remember open queues
5 лет назад
test_connection_test.go
Switch from gocheck to testify
5 лет назад
test_consumer.go
Ensure StopConsuming has completed for all calls
4 года назад
test_delivery.go
Update README
5 лет назад
test_delivery_test.go
Inject context into OpenConnection() functions
5 лет назад
test_queue.go
Reuse error channel passed into OpenConnection()
5 лет назад
test_redis_client.go
Rename CloseAllQueues() -> unlistAllQueues()
5 лет назад
test_redis_client_test.go
SAdd() return number of elements
5 лет назад
test_util.go
Fixed problem where slow redis causes test failure
4 года назад
Readme
Overview
Basic Usage
Background Errors
Advanced Usage
Testing Included
Statistics
Overview
Basic Usage
Import
Connection
Queues
Producers
Consumers
Consumer Lifecycle
Background Errors
Advanced Usage
Batch Consumers
Push Queues
Stop Consuming
Return Rejected Deliveries
Purge Rejected Deliveries
Cleaner
Testing Included
Test Connection
Producer Tests
Consumer Tests
Integration Tests
Statistics
Prometheus
README.md
Описание
Fork
В избранном
0
Следят
1
Языки
Go
Сообщить о нарушении