grpc_connection_pool

Oct 19, 2020

Changes in this version

+ type StreamHandler func(interface{}) error

Oct 19, 2020

Changes in this version

type Connection

+ func (connection *Connection) GetStream(name string) (interface{}, error)

type GRPCPool

+ func (pool *GRPCPool) GetStream(name string) (interface{}, error)

+ func (pool *GRPCPool) GetStreamInitializer(name string) StreamInitializer

+ func (pool *GRPCPool) SetStreamInitializer(name string, initializer StreamInitializer)

+ type StreamInitializer func(*grpc.ClientConn) (interface{}, error)

Oct 5, 2020

Changes in this version

+ var ErrExceeded = errors.New("Maximum number of connections exceeded")

+ var ErrUnavailable = errors.New("No available connection")

+ type Connection struct

+ func NewConnection(c *grpc.ClientConn) *Connection

+ type GRPCPool struct

+ func NewGRPCPool(host string, options *Options, dialOptions ...grpc.DialOption) (*GRPCPool, error)

+ func (pool *GRPCPool) Get() (*grpc.ClientConn, error)

+ func (pool *GRPCPool) Pop() (*grpc.ClientConn, error)

+ func (pool *GRPCPool) Push(connection *grpc.ClientConn) error

+ type Options struct

+ DialTimeout time.Duration

+ InitCap int

+ MaxCap int

+ func NewOptions() *Options