grpcpool

Documentation

Index

• Variables
• type Client
• type GRPCPool
  • func (p *GRPCPool) Get(addr string) (rpc.TaskClient, error)
  • func (p *GRPCPool) Release(addr string)

Variables

var (
	Pool = &GRPCPool{
		conns: make(map[string]*Client),
	}
)

Types

type Client

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

type GRPCPool

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

func (*GRPCPool) Get

func (p *GRPCPool) Get(addr string) (rpc.TaskClient, error)

func (*GRPCPool) Release

func (p *GRPCPool) Release(addr string)

释放连接