type github.com/go-redis/redis/v8/internal/pool.ConnPool
35 uses
github.com/go-redis/redis/v8/internal/pool (current package)
pool.go#L69: type ConnPool struct {
pool.go#L90: var _ Pooler = (*ConnPool)(nil)
pool.go#L92: func NewConnPool(opt *Options) *ConnPool {
pool.go#L93: p := &ConnPool{
pool.go#L113: func (p *ConnPool) checkMinIdleConns() {
pool.go#L132: func (p *ConnPool) addIdleConn() error {
pool.go#L145: func (p *ConnPool) NewConn(ctx context.Context) (*Conn, error) {
pool.go#L149: func (p *ConnPool) newConn(ctx context.Context, pooled bool) (*Conn, error) {
pool.go#L170: func (p *ConnPool) dialConn(ctx context.Context, pooled bool) (*Conn, error) {
pool.go#L194: func (p *ConnPool) tryDial() {
pool.go#L213: func (p *ConnPool) setLastDialError(err error) {
pool.go#L217: func (p *ConnPool) getLastDialError() error {
pool.go#L226: func (p *ConnPool) Get(ctx context.Context) (*Conn, error) {
pool.go#L265: func (p *ConnPool) getTurn() {
pool.go#L269: func (p *ConnPool) waitTurn(ctx context.Context) error {
pool.go#L305: func (p *ConnPool) freeTurn() {
pool.go#L309: func (p *ConnPool) popIdle() *Conn {
pool.go#L322: func (p *ConnPool) Put(ctx context.Context, cn *Conn) {
pool.go#L341: func (p *ConnPool) Remove(ctx context.Context, cn *Conn, reason error) {
pool.go#L347: func (p *ConnPool) CloseConn(cn *Conn) error {
pool.go#L352: func (p *ConnPool) removeConnWithLock(cn *Conn) {
pool.go#L358: func (p *ConnPool) removeConn(cn *Conn) {
pool.go#L371: func (p *ConnPool) closeConn(cn *Conn) error {
pool.go#L379: func (p *ConnPool) Len() int {
pool.go#L387: func (p *ConnPool) IdleLen() int {
pool.go#L394: func (p *ConnPool) Stats() *Stats {
pool.go#L407: func (p *ConnPool) closed() bool {
pool.go#L411: func (p *ConnPool) Filter(fn func(*Conn) bool) error {
pool.go#L426: func (p *ConnPool) Close() error {
pool.go#L448: func (p *ConnPool) reaper(frequency time.Duration) {
pool.go#L472: func (p *ConnPool) ReapStaleConns() (int, error) {
pool.go#L493: func (p *ConnPool) reapStaleConn() *Conn {
pool.go#L510: func (p *ConnPool) isStaleConn(cn *Conn) bool {
github.com/go-redis/redis/v8
cluster.go#L1060: _, err := node.Client.connPool.(*pool.ConnPool).ReapStaleConns()
options.go#L244: func newConnPool(opt *Options) *pool.ConnPool {
 |
The pages are generated with Golds v0.3.2-preview. (GOOS=darwin GOARCH=amd64)
Golds is a Go 101 project developed by Tapir Liu.
PR and bug reports are welcome and can be submitted to the issue list.
Please follow @Go100and1 (reachable from the left QR code) to get the latest news of Golds. |