Versions in this module Expand all Collapse all v3 v3.80.13 Sep 25, 2024 v3.80.12 Sep 24, 2024 Changes in this version + const Banned + const Created + const Destroyed + const Offline + const Online + const Unknown + func IsBadConn(err error, goodConnCodes ...grpcCodes.Code) bool + func UseWrapping(ctx context.Context) bool + func WithAppendOptions(cc grpc.ClientConnInterface, appendOpts ...grpc.CallOption) grpc.ClientConnInterface + func WithBeforeFunc(cc grpc.ClientConnInterface, before func()) grpc.ClientConnInterface + func WithContextModifier(cc grpc.ClientConnInterface, ...) grpc.ClientConnInterface + func WithoutWrapping(ctx context.Context) context.Context + type Config interface + ConnectionTTL func() time.Duration + DialTimeout func() time.Duration + GrpcDialOptions func() []grpc.DialOption + Trace func() *trace.Driver + type Conn interface + Endpoint func() endpoint.Endpoint + GetState func() State + IsState func(states ...State) bool + LastUsage func() time.Time + Ping func(ctx context.Context) error + SetState func(ctx context.Context, state State) State + Unban func(ctx context.Context) State + func New(e endpoint.Endpoint, config Config, opts ...option) Conn + type Pool struct + func NewPool(ctx context.Context, config Config) *Pool + func (p *Pool) Allow(ctx context.Context, cc Conn) + func (p *Pool) Ban(ctx context.Context, cc Conn, cause error) + func (p *Pool) Get(endpoint endpoint.Endpoint) Conn + func (p *Pool) Release(ctx context.Context) (finalErr error) + func (p *Pool) Take(context.Context) error + type State int8 + func (s State) Code() int + func (s State) IsValid() bool + func (s State) String() string
Go to main page