grpcpool

README

grpc-pool

Create a pool of dialed channels and use them in a pooled manner.

Documentation

Index

• type Connection
• type ConnectionPool
  • func NewConnectionPool(activeCount int, dialFunc func() (*grpc.ClientConn, error)) (*ConnectionPool, error)
  • func (self *ConnectionPool) Close()
  • func (self *ConnectionPool) Get() (Connection, error)
• type GrpcConnection
  • func (self *GrpcConnection) Close() error
  • func (self *GrpcConnection) Get() *grpc.ClientConn
• type Pool

Types

type Connection

type Connection interface {
	Close() error
	Get() *grpc.ClientConn
}

type ConnectionPool

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

func NewConnectionPool

func NewConnectionPool(activeCount int, dialFunc func() (*grpc.ClientConn, error)) (*ConnectionPool, error)

func (*ConnectionPool) Close

func (self *ConnectionPool) Close()

func (*ConnectionPool) Get

func (self *ConnectionPool) Get() (Connection, error)

type GrpcConnection

type GrpcConnection struct {
	GrpcConn *grpc.ClientConn
	// contains filtered or unexported fields
}

func (*GrpcConnection) Close

func (self *GrpcConnection) Close() error

func (*GrpcConnection) Get

func (self *GrpcConnection) Get() *grpc.ClientConn

type Pool

type Pool interface {
	Get() (Connection, error)
	Close()
	// contains filtered or unexported methods
}