f7b3619c8b
hotfix/v8_conn_pool_check_fd ( #2431 )
2023-02-09 23:01:02 +08:00
3961b9577f
fix: use redis over ssh channel( #2057 ) ( #2060 )
2022-03-26 18:11:44 +08:00
9b6ee9c3cc
chore: gofmt all code
2021-09-08 16:52:29 +03:00
afafeda8a3
after the connection pool is closed, no new connections should be added ( #1863 )
...
* after the connection pool is closed, no new connections should be added
Signed-off-by: monkey92t <golang@88.com >
* remove runGoroutine
Signed-off-by: monkey92t <golang@88.com >
* pool.popIdle add p.closed check
Signed-off-by: monkey92t <golang@88.com >
* upgrade golangci-lint v1.42.0
Signed-off-by: monkey92t <golang@88.com >
2021-08-19 16:56:23 +08:00
fd3025bfed
Revert "ConnPool check fd for bad conns ( #1824 )" ( #1849 )
...
This reverts commit 346bfafddd
2021-08-06 17:16:22 +08:00
346bfafddd
ConnPool check fd for bad conns ( #1824 )
...
* conncheck for badconn (#1821 )
* format imports
* fix ut: pool with badconn
* fix unstable ut: should facilitate failover
* Revert "fix unstable ut: should facilitate failover"
This reverts commit c7eeca2a5cgolang@88.com >
Co-authored-by: hidu <duv123+github@gmail.com >
Co-authored-by: monkey92t <golang@88.com >
2021-07-20 17:23:48 +08:00
ce40cd942a
Allow FIFO pool in redis client ( #1820 )
...
* Initial commit for FIFO pool
* Change PoolType string to PoolFIFO bool
* Remove redundant type
* add PoolFIFO option to all clients
Signed-off-by: monkey92t <golang@88.com >
Co-authored-by: Kim Tae Kwon <taekwon.kim@shopee.com >
Co-authored-by: monkey92t <golang@88.com >
2021-07-16 11:58:01 +08:00
27e2efb0af
Remove OpenTelemetry metrics for now ( #1805 )
2021-06-30 18:40:23 +08:00
6e4eb2e3ac
Remove OpenTelemetry from the code (but leave redisotel as is) ( #1782 )
2021-06-03 19:01:51 +08:00
26373ef2f1
follow to golang-lint 1.40
...
Signed-off-by: monkey <golang@88.com >
2021-05-13 10:33:38 +08:00
a2410beb43
upgrade golangci-lint to v1.39.0
...
Signed-off-by: monkey <golang@88.com >
2021-04-08 14:44:31 +08:00
02a9c81ef1
Fix golangci-lint check
2021-03-23 11:02:29 +02:00
1b77706c0c
Optimize Otel instrumentation
2021-03-20 10:01:48 +02:00
76fd0eac61
Fix Tx pipeline hook
2021-01-09 09:57:46 +02:00
3921cd497c
Update to otel v0.14
2020-11-21 09:56:52 +02:00
13782c03d0
Tweak otel span and attr names
2020-11-15 14:30:27 +02:00
566840fe27
otel: add RemoteAddr
2020-09-28 17:35:49 +03:00
c357d18624
Faster renew the subscription
2020-09-05 10:56:09 +03:00
6db422f051
Port pool fixes
2020-08-15 15:45:15 +03:00
8a3f304b25
Log with context to associate all log by traceID ( #1413 )
...
* Log with context to associate all log by traceID
2020-07-18 09:04:36 +03:00
f2645d373d
Merge pull request #1405 from fishy/atomic-value-last-dial-error
...
Use atomic.Value instead of lock for ConnPool.lastDialError
2020-07-16 10:41:42 +03:00
14c843ef89
gofumports
2020-07-16 09:52:07 +03:00
62469e4f42
Introduce metrics capture with OpenTelemetry ( #1398 )
...
* internal: Add instrumentation
Co-authored-by: reggiemcdonald <regmcdonald95@gmail.com >
Co-authored-by: Tyler Yahn <MrAlias@users.noreply.github.com >
2020-07-15 12:07:07 +03:00
4f70db6849
Use atomic.Value instead of lock for ConnPool.lastDialError
...
This makes the reading and writing of lastDialError from the pool
faster, as atomic.Value is much more lightweight than the mutex.
Note that using error in atomic.Value directly could cause panics,
because errors could have inconsistent types. Thus wrap them with a
simple struct.
2020-07-14 11:25:59 -07:00
1831363467
Add RecordError
2020-07-09 10:39:46 +03:00
8eed1e67ff
Add OpenTelemetryHook
2020-06-09 17:17:41 +03:00
3dcb844106
Bump major version
2020-05-19 08:52:38 +03:00
f5593121e0
Add ctx as first arg
2020-05-19 08:52:38 +03:00
39881392de
code fmt
2020-04-30 17:46:50 +08:00
4d5f8a5df3
fix data race
2020-04-30 14:34:48 +08:00
a2de1fe668
internal/pool: include details when conn is in a bad state
2019-09-13 16:52:05 +03:00
cb2d1c89e6
internal/pool: exit conn pool fast ( #1155 )
...
* internal/pool: exit conn pool reaper fast
2019-09-09 11:50:28 +03:00
e694ed0084
Cleanup
2019-08-18 17:11:07 +03:00
eaeb8f2a08
internal: return an error on setting deadline
2019-08-16 17:50:57 +03:00
4d3ed95bd9
Add conn health check
2019-08-09 15:11:52 +03:00
7779accbea
Use semantic import versioning
2019-08-08 14:29:44 +03:00
87225c1cf9
malign struct fields
2019-08-08 14:22:01 +03:00
e0fed4d581
Remove atomic.Value.Store(nil)
2019-08-08 14:04:19 +03:00
2927e15b6b
Retry BadConnError
2019-08-08 11:44:55 +03:00
27f3b27893
Fix names
2019-08-07 16:12:01 +03:00
4e9cea8876
Add proper SingleConnPool implementation
2019-08-03 17:31:28 +03:00
efa4a78883
Close single conn connection pool
2019-08-01 14:59:53 -07:00
6d8db67ef5
Cleanup
2019-07-28 10:53:40 +03:00
6cd6cd828f
protect pollSize and idleConnsLen with mutex ( #1105 )
...
Fix poolSize and idleConnsLen when conn can't be created
2019-07-28 09:56:57 +03:00
f3ce3362a0
Add golangci-lint
2019-07-25 14:36:50 +03:00
2cbb5194fb
Fix WithContext and add tests
2019-07-04 11:57:54 +03:00
717362d3e9
Inc StaleConns in ReapStaleConns
2019-06-24 15:27:03 +03:00
3bdf64784a
Cleanup
2019-06-17 12:32:40 +03:00
aa5f492665
internal/pool: cleanup
2019-06-15 10:34:38 +03:00
880e05d975
Cleanup
2019-06-14 16:00:03 +03:00
