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 CallOptionInfoFromCtx(ctx context.Context) (res string) + func CallOptionsFromCtx(ctx context.Context) (res []callopt.Option) + func ClientErrorHandlerWithAddr(ctx context.Context, err error) error + func DefaultClientErrorHandler(ctx context.Context, err error) error + func NewCtxWithCallOptions(ctx context.Context, opts []callopt.Option) context.Context + func WithContextMiddlewares(ctx context.Context, mws ...endpoint.Middleware) context.Context + func WithMetaHandler(h remote.MetaHandler) client.Option + type Client interface + Call func(ctx context.Context, method string, request, response interface{}) error + func NewClient(svcInfo *serviceinfo.ServiceInfo, opts ...Option) (Client, error) + func NewServiceInlineClient(svcInfo *serviceinfo.ServiceInfo, s ServerInitialInfo, opts ...Option) (Client, error) + type ContextServiceInlineHandler interface + ReadMeta func(cliCtx, svrCtx context.Context, resp interface{}) (newCliCtx context.Context, err error) + WriteMeta func(cliCtx, svrCtx context.Context, req interface{}) (newSvrCtx context.Context, err error) + type Option = client.Option + func WithACLRules(rules ...acl.RejectFunc) Option + func WithBackupRequest(p *retry.BackupPolicy) Option + func WithBoundHandler(h remote.BoundHandler) Option + func WithCircuitBreaker(s *circuitbreak.CBSuite) Option + func WithClientBasicInfo(ebi *rpcinfo.EndpointBasicInfo) Option + func WithCloseCallbacks(callback func() error) Option + func WithCodec(c remote.Codec) Option + func WithConnMetric() Option + func WithConnPool(pool remote.ConnPool) Option + func WithConnReporterEnabled() Option + func WithConnectTimeout(d time.Duration) Option + func WithDestService(svr string) Option + func WithDiagnosisService(ds diagnosis.Service) Option + func WithDialer(d remote.Dialer) Option + func WithErrorHandler(f func(context.Context, error) error) Option + func WithFailureRetry(p *retry.FailurePolicy) Option + func WithFallback(fb *fallback.Policy) Option + func WithFirstMetaHandler(h remote.MetaHandler) Option + func WithFramedTransport() Option + func WithGRPCConnPoolSize(s uint32) Option + func WithGRPCInitialConnWindowSize(s uint32) Option + func WithGRPCInitialWindowSize(s uint32) Option + func WithGRPCKeepaliveParams(kp grpc.ClientKeepalive) Option + func WithGRPCMaxHeaderListSize(s uint32) Option + func WithGRPCReadBufferSize(s uint32) Option + func WithGRPCTLSConfig(tlsConfig *tls.Config) Option + func WithGRPCWriteBufferSize(s uint32) Option + func WithGeneric(g generic.Generic) Option + func WithHTTPConnection() Option + func WithHTTPResolver(r http.Resolver) Option + func WithHostPorts(hostports ...string) Option + func WithInstanceMW(mw endpoint.Middleware) Option + func WithLoadBalancer(lb loadbalance.Loadbalancer, opts ...*lbcache.Options) Option + func WithLogger(logger klog.FormatLogger) Option + func WithLongConnection(cfg connpool.IdleConfig) Option + func WithMiddleware(mw endpoint.Middleware) Option + func WithMiddlewareBuilder(mwb endpoint.MiddlewareBuilder) Option + func WithMuxConnection(connNum int) Option + func WithPayloadCodec(c remote.PayloadCodec) Option + func WithProxy(p proxy.ForwardProxy) Option + func WithRPCTimeout(d time.Duration) Option + func WithResolver(r discovery.Resolver) Option + func WithRetryContainer(rc *retry.Container) Option + func WithRetryMethodPolicies(mp map[string]retry.Policy) Option + func WithShortConnection() Option + func WithSpecifiedResultRetry(rr *retry.ShouldResultRetry) Option + func WithStatsLevel(level stats.Level) Option + func WithSuite(suite Suite) Option + func WithTag(key, val string) Option + func WithTimeoutProvider(p rpcinfo.TimeoutProvider) Option + func WithTracer(c stats.Tracer) Option + func WithTransHandlerFactory(f remote.ClientTransHandlerFactory) Option + func WithTransportProtocol(tp transport.Protocol) Option + func WithWarmingUp(wuo *warmup.ClientOption) Option + func WithXDSSuite(suite xds.ClientSuite) Option + type Options = client.Options + type ServerInitialInfo interface + Endpoints func() endpoint.Endpoint + GetServiceInfo func() *serviceinfo.ServiceInfo + Option func() *internal_server.Options + type Streaming interface + Stream func(ctx context.Context, method string, request, response interface{}) error + type Suite interface + Options func() []Option
Go to main page