grpcpool

Nov 28, 2024

Changes in this version

+ const BackoffMaxDelay

+ const DialTimeout

+ const InitialConnWindowSize

+ const InitialWindowSize

+ const KeepAliveTime

+ const KeepAliveTimeout

+ const MaxRecvMsgSize

+ const MaxSendMsgSize

+ var DefaultOptions = Options

+ var ErrClosed = errors.New("pool is closed")

+ func Dial(address string) (*grpc.ClientConn, error)

+ func DialTest(address string) (*grpc.ClientConn, error)

+ type Conn interface

+ Close func() error

+ Value func() *grpc.ClientConn

+ type Options struct

+ Dial func(address string) (*grpc.ClientConn, error)

+ MaxActive int

+ MaxConcurrentStreams int

+ MaxIdle int

+ Reuse bool

+ type Pool interface

+ Close func() error

+ Get func() (Conn, error)

+ Status func() string

+ func New(address string, option Options) (Pool, error)