Commit Graph

49 Commits

Author SHA1 Message Date
monkey92t 8e8510431d
Improve pubsub (#1764)
* Improve pubsub

Signed-off-by: monkey92t <golang@88.com>

* Extract code to channel struct and tweak API

* Move chanSendTimeout to channel

* Cleanup health check

* Add WithChannelSendTimeout and tweak comments

* clear notes

Signed-off-by: monkey92t <golang@88.com>

Co-authored-by: Vladimir Mihailenco <vladimir.webdev@gmail.com>
2021-05-26 11:25:18 +08:00
Rueian f5f73f8033
Support string array in pubsub message payload 2020-08-21 17:29:37 +08:00
Vladimir Mihailenco 3dcb844106 Bump major version 2020-05-19 08:52:38 +03:00
Vladimir Mihailenco f5593121e0 Add ctx as first arg 2020-05-19 08:52:38 +03:00
Vladimir Mihailenco 7779accbea Use semantic import versioning 2019-08-08 14:29:44 +03:00
Vladimir Mihailenco 6c72dc807e internal/pool: replace atomic.Value with int64 2019-06-01 11:32:05 +03:00
Vladimir Mihailenco 21913a8304 pubsub: drop a message when the channel is full 2019-03-12 12:40:08 +02:00
Vladimir Mihailenco 651e9fef1d Add MaxConnAge 2018-08-12 10:25:16 +03:00
Vladimir Mihailenco b576fe91a1 Use single read and write buffer where possible 2018-08-04 13:09:22 +03:00
Vladimir Mihailenco ea9da7c2e8 Rework ReceiveMessage 2018-07-23 17:10:58 +03:00
Vladimir Mihailenco 742a58164c Add test for receive big message payload 2017-09-30 09:21:59 +03:00
Vladimir Mihailenco bc5f9a6878 Replace PoolStats.Requests with PoolStats.Misses 2017-09-22 12:28:08 +03:00
Vladimir Mihailenco 8ff417ca18 Fix flaky tests 2017-08-15 10:49:45 +03:00
Vladimir Mihailenco dbcf95c85e Fix PubSub.Subscribe deadlock 2017-08-01 14:21:26 +03:00
Vladimir Mihailenco 6060f097e1 Add PubSub support to Cluster client 2017-07-09 10:07:20 +03:00
Vladimir Mihailenco 55da68487f Fix PubSub example. Fixes #575 2017-07-01 13:42:26 +03:00
Vladimir Mihailenco f1ed2ad288 Add FlushDBAsync and FlushAllAsync 2017-06-17 12:53:16 +03:00
Vladimir Mihailenco 6499563e07 PubSub conns don't share connection pool limit 2017-04-17 16:59:56 +03:00
Vladimir Mihailenco 8d52a95269 Simplify PubSub API 2017-04-11 16:53:55 +03:00
Vladimir Mihailenco 8040d63c4f Remove gopkg.in 2017-02-19 09:49:21 +02:00
Vladimir Mihailenco c2156b59f3 Fix Go 1.4 build. 2017-02-18 12:28:01 +02:00
eyalpost 5de14cbf58 ensure wait.done to avoid deadlock in test 2017-02-15 17:15:24 +02:00
Vladimir Mihailenco ce4fd8b677 Fix ReceiveMessage to work without any subscriptions. 2017-02-08 14:15:32 +02:00
Vladimir Mihailenco b4efc45f1c Set read/write timeouts more consistently. 2016-12-03 17:30:13 +02:00
Vladimir Mihailenco f5245efa73 Prepare v5 release. 2016-10-09 10:56:53 +00:00
Vladimir Mihailenco e57ac63b6e Simplify resubscribing in PubSub. 2016-09-29 12:33:47 +00:00
Vladimir Mihailenco 31abb18d9a Move logger to internal package. 2016-04-09 14:52:01 +03:00
Vladimir Mihailenco 38d30a4bab Use redis.v4 that is in alpha/beta state. 2016-04-09 13:27:16 +03:00
Vladimir Mihailenco d79074eadb Remove PMessage. 2016-04-09 11:51:13 +03:00
Vladimir Mihailenco 6e1aef39ea Faster and simpler pool. 2016-03-19 11:49:13 +02:00
Vladimir Mihailenco f47fb47df0 Extract race tests to separate file. Add more race tests. 2016-03-16 19:45:35 +02:00
Vladimir Mihailenco 707472c09b Fix connection initialization. 2016-03-15 14:21:53 +02:00
Vladimir Mihailenco 46790aa060 Add race test for big vals. Copy connection to avoid race with PubSub. 2016-03-14 16:34:15 +02:00
Vladimir Mihailenco fdd0fdf678 Optimize pool.Remove. 2016-03-12 12:41:02 +02:00
Vladimir Mihailenco ad0739be99 Extract pool package. Add pool benchmark. 2016-03-12 10:52:13 +02:00
Vladimir Mihailenco 0db1d730c8 Improve pool tests by verifying number of created connections. 2016-03-09 14:36:14 +02:00
Vladimir Mihailenco 110e93a8e4 Simplify connection management with sticky connection pool. Fixes #260. 2016-03-01 14:12:25 +02:00
Vladimir Mihailenco 1739cd9380 pubsub: add PSubscribe test. Updates #233. 2015-12-31 11:27:28 +02:00
Vladimir Mihailenco 42141f11d1 Improve ReceiveMessage. 2015-12-02 15:40:44 +02:00
Leonid Shagabutdinov 62ce552959 Fix PubSub panic on concurrent Close. 2015-11-26 17:09:09 +02:00
Vladimir Mihailenco b6b689904a Fix test. 2015-11-22 17:53:44 +02:00
Vladimir Mihailenco ade3425870 multi: fix recovering from bad connection. 2015-11-14 14:44:16 +02:00
Vladimir Mihailenco 9987f2abaa Add PubSub.ReceiveMessage. 2015-09-06 13:54:04 +03:00
Vladimir Mihailenco d7edae84cf pubsub: improve API and docs. 2015-07-11 13:42:44 +03:00
Vladimir Mihailenco f901321d84 pubsub: add PING support. 2015-07-11 13:12:47 +03:00
Vladimir Mihailenco 18ea75d2ad Release redis.v3 beta. 2015-05-14 16:24:19 +03:00
Vladimir Mihailenco 121cfc5792 Remove deprecated funcs. 2015-05-02 16:22:06 +03:00
Dimitrij Denissenko 34855172f2 Fix/normalise pubsubnumsub response 2015-01-30 17:09:57 +02:00
Dimitrij Denissenko f6bca78168 Migrates tests to ginkgo/gomega 2015-01-25 11:56:03 +00:00