Versions in this module Expand all Collapse all v0 v0.6.1 Jul 31, 2023 v0.0.4 Jul 31, 2023 Changes in this version + func NewStream(ctx context.Context, ri rpcinfo.RPCInfo, handler remote.ClientTransHandler, ...) (streaming.Stream, error) + type Client interface + Recv func(ctx context.Context, ri rpcinfo.RPCInfo, resp remote.Message) (err error) + Recycle func() + Send func(ctx context.Context, ri rpcinfo.RPCInfo, req remote.Message) (err error) + func NewClient(ctx context.Context, ri rpcinfo.RPCInfo, handler remote.TransHandler, ...) (Client, error) + type ConnWrapper struct + func NewConnWrapper(connPool remote.ConnPool) *ConnWrapper + func (cm *ConnWrapper) GetConn(ctx context.Context, d remote.Dialer, ri rpcinfo.RPCInfo) (net.Conn, error) + func (cm *ConnWrapper) ReleaseConn(err error, ri rpcinfo.RPCInfo)
Go to main page