grpcpool

package

v1.2.1 Latest Latest Go to latest Published: Sep 6, 2017 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

View Source

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

This section is empty.

type CustomCredential struct {
	Token string
}

func (c CustomCredential) GetRequestMetadata(ctx context.Context, uri ...string) (map[string]string, error)

func (c CustomCredential) RequireTransportSecurity() bool

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

var (
	Pool GRPCPool
)

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

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

func (p *GRPCPool) Release(addr string)

释放连接池

func (p *GRPCPool) ReleaseAll()

释放所有连接池