transport

Documentation

Index

• type Pool
  • func NewPool(opts *PoolOptions) (*Pool, error)
  • func (c *Pool) Close()
  • func (c *Pool) ClosePool(addr string)
  • func (c *Pool) Conn(ctx context.Context, addr string) (*grpcpool.ClientConn, error)
• type PoolOptions

Types

type Pool

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

func NewPool

func NewPool(opts *PoolOptions) (*Pool, error)

func (*Pool) Close

func (c *Pool) Close()

func (*Pool) ClosePool

func (c *Pool) ClosePool(addr string)

func (*Pool) Conn

func (c *Pool) Conn(ctx context.Context, addr string) (*grpcpool.ClientConn, error)

type PoolOptions

type PoolOptions struct {
	NewConn         func(addr string) (*grpc.ClientConn, error)
	IdleTimeout     time.Duration
	MaxLifeDuration time.Duration
	Init            int
	Capacity        int
}