grpc_client_pool

Documentation

Index

• Variables
• type ClientCon
  • func (c *ClientCon) Release()
• type ClientPool
  • func NewClientPool(config *PoolConfig) *ClientPool
  • func (cp *ClientPool) Get() (*ClientCon, error)
  • func (cp *ClientPool) GetNumberOfConnectionsInUse() int
  • func (cp *ClientPool) GetNumberOfIdleConnections() int
  • func (cp *ClientPool) GetNumberOfOpenConnections() int
• type PoolConfig

Variables

var (
	ErrConnectionWaitTimeout error = errors.New("connection queue wait timeout")
)

Types

type ClientCon

type ClientCon struct {
	Conn *grpc.ClientConn
	// contains filtered or unexported fields
}

func (*ClientCon) Release

func (c *ClientCon) Release()

type ClientPool

type ClientPool struct {
	// contains filtered or unexported fields
}

func NewClientPool

func NewClientPool(config *PoolConfig) *ClientPool

func (*ClientPool) Get

func (cp *ClientPool) Get() (*ClientCon, error)

func (*ClientPool) GetNumberOfConnectionsInUse

func (cp *ClientPool) GetNumberOfConnectionsInUse() int

func (*ClientPool) GetNumberOfIdleConnections

func (cp *ClientPool) GetNumberOfIdleConnections() int

func (*ClientPool) GetNumberOfOpenConnections

func (cp *ClientPool) GetNumberOfOpenConnections() int

type PoolConfig

type PoolConfig struct {
	MaxOpenConnection     int
	MaxIdleConnection     int
	ConnectionQueueLength int
	NewClientDuration     time.Duration
	Address               string
	ConfigOptions         []grpc.DialOption
}