type github.com/go-redis/redis/v8/internal/pool.Conn

79 uses

	github.com/go-redis/redis/v8/internal/pool (current package)
		conn.go#L16: type Conn struct {
		conn.go#L29: func NewConn(netConn net.Conn) *Conn {
		conn.go#L30: 	cn := &Conn{
		conn.go#L41: func (cn *Conn) UsedAt() time.Time {
		conn.go#L46: func (cn *Conn) SetUsedAt(tm time.Time) {
		conn.go#L50: func (cn *Conn) SetNetConn(netConn net.Conn) {
		conn.go#L56: func (cn *Conn) Write(b []byte) (int, error) {
		conn.go#L60: func (cn *Conn) RemoteAddr() net.Addr {
		conn.go#L64: func (cn *Conn) WithReader(ctx context.Context, timeout time.Duration, fn func(rd *proto.Reader) error) error {
		conn.go#L76: func (cn *Conn) WithWriter(
		conn.go#L102: func (cn *Conn) Close() error {
		conn.go#L106: func (cn *Conn) deadline(ctx context.Context, timeout time.Duration) time.Time {
		pool.go#L39: 	NewConn(context.Context) (*Conn, error)
		pool.go#L40: 	CloseConn(*Conn) error
		pool.go#L42: 	Get(context.Context) (*Conn, error)
		pool.go#L43: 	Put(context.Context, *Conn)
		pool.go#L44: 	Remove(context.Context, *Conn, error)
		pool.go#L55: 	OnClose func(*Conn) error
		pool.go#L79: 	conns        []*Conn
		pool.go#L80: 	idleConns    []*Conn
		pool.go#L97: 		conns:     make([]*Conn, 0, opt.PoolSize),
		pool.go#L98: 		idleConns: make([]*Conn, 0, opt.PoolSize),
		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#L226: func (p *ConnPool) Get(ctx context.Context) (*Conn, error) {
		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#L411: func (p *ConnPool) Filter(fn func(*Conn) bool) error {
		pool.go#L493: func (p *ConnPool) reapStaleConn() *Conn {
		pool.go#L510: func (p *ConnPool) isStaleConn(cn *Conn) bool {
		pool_single.go#L7: 	cn        *Conn
		pool_single.go#L13: func NewSingleConnPool(pool Pooler, cn *Conn) *SingleConnPool {
		pool_single.go#L20: func (p *SingleConnPool) NewConn(ctx context.Context) (*Conn, error) {
		pool_single.go#L24: func (p *SingleConnPool) CloseConn(cn *Conn) error {
		pool_single.go#L28: func (p *SingleConnPool) Get(ctx context.Context) (*Conn, error) {
		pool_single.go#L35: func (p *SingleConnPool) Put(ctx context.Context, cn *Conn) {}
		pool_single.go#L37: func (p *SingleConnPool) Remove(ctx context.Context, cn *Conn, reason error) {
		pool_sticky.go#L41: 	ch    chan *Conn
		pool_sticky.go#L53: 			ch:   make(chan *Conn, 1),
		pool_sticky.go#L60: func (p *StickyConnPool) NewConn(ctx context.Context) (*Conn, error) {
		pool_sticky.go#L64: func (p *StickyConnPool) CloseConn(cn *Conn) error {
		pool_sticky.go#L68: func (p *StickyConnPool) Get(ctx context.Context) (*Conn, error) {
		pool_sticky.go#L99: func (p *StickyConnPool) Put(ctx context.Context, cn *Conn) {
		pool_sticky.go#L108: func (p *StickyConnPool) freeConn(ctx context.Context, cn *Conn) {
		pool_sticky.go#L116: func (p *StickyConnPool) Remove(ctx context.Context, cn *Conn, reason error) {

	github.com/go-redis/redis/v8
		cluster.go#L1176: 		return node.Client.withConn(ctx, func(ctx context.Context, cn *pool.Conn) error {
		cluster.go#L1334: 		return node.Client.withConn(ctx, func(ctx context.Context, cn *pool.Conn) error {
		cluster.go#L1497: 		newConn: func(ctx context.Context, channels []string) (*pool.Conn, error) {
		cluster.go#L1522: 		closeConn: func(cn *pool.Conn) error {
		pubsub.go#L32: 	newConn   func(ctx context.Context, channels []string) (*pool.Conn, error)
		pubsub.go#L33: 	closeConn func(*pool.Conn) error
		pubsub.go#L36: 	cn       *pool.Conn
		pubsub.go#L61: func (c *PubSub) connWithLock(ctx context.Context) (*pool.Conn, error) {
		pubsub.go#L68: func (c *PubSub) conn(ctx context.Context, newChannels []string) (*pool.Conn, error) {
		pubsub.go#L93: func (c *PubSub) writeCmd(ctx context.Context, cn *pool.Conn, cmd Cmder) error {
		pubsub.go#L99: func (c *PubSub) resubscribe(ctx context.Context, cn *pool.Conn) error {
		pubsub.go#L127: 	ctx context.Context, cn *pool.Conn, redisCmd string, channels []string,
		pubsub.go#L140: 	cn *pool.Conn,
		pubsub.go#L149: func (c *PubSub) releaseConn(ctx context.Context, cn *pool.Conn, err error, allowTimeout bool) {
		redis.go#L153: func (c *baseClient) newConn(ctx context.Context) (*pool.Conn, error) {
		redis.go#L168: func (c *baseClient) getConn(ctx context.Context) (*pool.Conn, error) {
		redis.go#L187: func (c *baseClient) _getConn(ctx context.Context) (*pool.Conn, error) {
		redis.go#L211: func (c *baseClient) initConn(ctx context.Context, cn *pool.Conn) error {
		redis.go#L256: func (c *baseClient) releaseConn(ctx context.Context, cn *pool.Conn, err error) {
		redis.go#L269: 	ctx context.Context, fn func(context.Context, *pool.Conn) error,
		redis.go#L308: 			err := c.withConn(ctx, func(ctx context.Context, cn *pool.Conn) error {
		redis.go#L382: type pipelineProcessor func(context.Context, *pool.Conn, []Cmder) (bool, error)
		redis.go#L407: 		lastErr = c.withConn(ctx, func(ctx context.Context, cn *pool.Conn) error {
		redis.go#L420: 	ctx context.Context, cn *pool.Conn, cmds []Cmder,
		redis.go#L446: 	ctx context.Context, cn *pool.Conn, cmds []Cmder,
		redis.go#L633: 		newConn: func(ctx context.Context, channels []string) (*pool.Conn, error) {
		sentinel.go#L181: 		_ = connPool.Filter(func(cn *pool.Conn) bool {
		sentinel.go#L263: 		newConn: func(ctx context.Context, channels []string) (*pool.Conn, error) {