shared

Documentation

Index

• Variables
• type ClientConn
  • func (c *ClientConn) Connection() *grpc.ClientConn
  • func (c *ClientConn) Return()
• type Pool
  • func New(factory grpcpool.ConnectionFactory, idleTimeout time.Duration) *Pool
  • func (p *Pool) Close()
  • func (p *Pool) Get(ctx context.Context) (grpcpool.PoolClientConn, error)

Variables

var ErrClientConnClosing = status.Error(codes.Canceled, "grpc: the client connection is closing")

var ErrClientConnNotOk = status.Error(codes.Unavailable, "grpc: error - connection not ok")

Types

type ClientConn

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

func (*ClientConn) Connection

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

func (*ClientConn) Return

func (c *ClientConn) Return()

type Pool

type Pool struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New(factory grpcpool.ConnectionFactory, idleTimeout time.Duration) *Pool

func (*Pool) Close

func (p *Pool) Close()

func (*Pool) Get

func (p *Pool) Get(ctx context.Context) (grpcpool.PoolClientConn, error)