remotecli

type Client interface {
	// RPCInfo as param just avoid to get it from ctx
	Send(ctx context.Context, ri rpcinfo.RPCInfo, req remote.Message) (err error)
	Recv(ctx context.Context, ri rpcinfo.RPCInfo, resp remote.Message) (err error)
	Recycle()
}

type ConnReleaser interface {
	ReleaseConn(err error, ri rpcinfo.RPCInfo)
}

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

type StreamConnManager struct {
	ConnReleaser
}