pool

Documentation

Index

• Variables
• type Connection
  • func NewConnection(c *grpc.ClientConn) *Connection
• type GRPCPool
  • func NewGRPCPool(host string, options *Options, dialOptions ...grpc.DialOption) (*GRPCPool, error)
  • func (pool *GRPCPool) Get() (*grpc.ClientConn, error)
  • func (pool *GRPCPool) Put(connection *grpc.ClientConn) error
• type Options
  • func NewOptions() *Options

Variables

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

Types

type Connection

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

func NewConnection

func NewConnection(c *grpc.ClientConn) *Connection

type GRPCPool

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

func NewGRPCPool

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

func (*GRPCPool) Get

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

func (*GRPCPool) Put

func (pool *GRPCPool) Put(connection *grpc.ClientConn) error

type Options

type Options struct {
	InitCap     int
	MaxCap      int
	DialTimeout time.Duration
	IdleTimeout time.Duration
}

func NewOptions

func NewOptions() *Options