grpcpool

Documentation

Index

• Variables
• type GRPCPool
  • func (p *GRPCPool) Get(addr string) (*grpc.ClientConn, error)
  • func (p *GRPCPool) Put(addr string, conn *grpc.ClientConn) error
  • func (p *GRPCPool) Release(addr string)
  • func (p *GRPCPool) ReleaseAll()

Variables

var (
	ErrInvalidConn = errors.New("invalid connection")
)

Types

type GRPCPool

type GRPCPool struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

var (
	Pool GRPCPool
)

func (*GRPCPool) Get

func (p *GRPCPool) Get(addr string) (*grpc.ClientConn, error)

func (*GRPCPool) Put

func (p *GRPCPool) Put(addr string, conn *grpc.ClientConn) error

func (*GRPCPool) Release

func (p *GRPCPool) Release(addr string)

释放连接池

func (*GRPCPool) ReleaseAll

func (p *GRPCPool) ReleaseAll()

释放所有连接池