0x5010 / grpcp Goto Github PK

Contributors

Stargazers

Forkers

webmi saisaixv kissmonx juelite yushuai1 wangxx2026 dzengzhiqiang veliamsli gdzy1987 lingling1420q hotion reggiepy zhanglei jhchc imsong52 small-lei banposeu shuff1e hucqli shameby duanjunxiao javaorz microyahoo xj-sz chinamcat andywu1998 frankfanslc githubw2015 mcatorg liyang-11 yexua futurez

conn, _ := grpcp.GetConn(addr)  // get conn with grpcp default pool
// defer conn.Close()  // no close, close will disconnect
client := pb.NewGreeterClient(conn)
r, _ := client.SayHello(context.Background(), &pb.HelloRequest{Name: name})

func (ct *ConnectionTracker) getConn(addr string, force bool) (*grpc.ClientConn, error) {
	ct.Lock()
	tc, ok := ct.connections[addr]
	if !ok {
		tc = &trackedConn{
			addr:    addr,
			tracker: ct,
		}
		ct.connections[addr] = tc
	}
	ct.Unlock()