Versions in this module Expand all Collapse all v2 v2.16.0 Sep 14, 2023 v2.15.0 Apr 11, 2023 Changes in this version + func ParseURI(s string) (string, bool, error) + func SendUnary(cli *Client, info common.CallMethodInfo, req, resp message.Message, ...) error + type CallOption func(*callParameters) + func WithContext(ctx context.Context) CallOption + type Client struct + func New(opts ...Option) *Client + func (c *Client) Conn() io.Closer + func (c *Client) Init(info common.CallMethodInfo, opts ...CallOption) (MessageReadWriter, error) + type MessageReadWriter interface + type MessageReader interface + ReadMessage func(message.Message) error + func OpenServerStream(cli *Client, info common.CallMethodInfo, req message.Message, ...) (MessageReader, error) + type MessageReaderCloser interface + type MessageWriter interface + WriteMessage func(message.Message) error + type MessageWriterCloser interface + func OpenClientStream(cli *Client, info common.CallMethodInfo, resp message.Message, ...) (MessageWriterCloser, error) + type Option func(*cfg) + func WithDialTimeout(v time.Duration) Option + func WithGRPCConn(v *grpc.ClientConn) Option + func WithGRPCDialOptions(opts []grpc.DialOption) Option + func WithNetworkAddress(v string) Option + func WithNetworkURIAddress(addr string, tlsCfg *tls.Config) []Option + func WithRWTimeout(v time.Duration) Option + func WithTLSCfg(v *tls.Config) Option