client

Mar 18, 2024

Changes in this version

type ServerInitialInfo

+ BuildServiceInlineInvokeChain func() endpoint.Endpoint

Nov 29, 2023

Changes in this version

type ServerInitialInfo

+ GetServiceInfos func() map[string]*serviceinfo.ServiceInfo

Aug 15, 2023

Changes in this version

type Option

+ func WithContextBackup(...) Option

Jun 13, 2023

Changes in this version

+ func ClientErrorHandlerWithAddr(ctx context.Context, err error) error

type Client

+ 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 ServerInitialInfo interface

+ Endpoints func() endpoint.Endpoint

+ GetServiceInfo func() *serviceinfo.ServiceInfo

+ Option func() *internal_server.Options

Mar 8, 2023

Changes in this version

type Option

+ func WithFallback(fb *fallback.Policy) Option

+ func WithGRPCTLSConfig(tlsConfig *tls.Config) Option

Nov 2, 2022

Changes in this version

+ func WithContextMiddlewares(ctx context.Context, mws ...endpoint.Middleware) context.Context

Aug 26, 2022

Changes in this version

type Option

+ func WithRetryMethodPolicies(mp map[string]retry.Policy) Option

+ func WithSpecifiedResultRetry(rr *retry.ShouldResultRetry) Option

+ func WithXDSSuite(suite xds.ClientSuite) Option

Jul 14, 2022

Changes in this version

+ func DefaultClientErrorHandler(err error) error

Apr 29, 2022

Changes in this version

type Option

+ func WithGRPCReadBufferSize(s uint32) Option

+ func WithGRPCWriteBufferSize(s uint32) Option

+ func WithWarmingUp(wuo *warmup.ClientOption) Option

Feb 24, 2022

Changes in this version

type 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

Sep 26, 2021

Changes in this version

type Option

+ func WithCircuitBreaker(s *circuitbreak.CBSuite) Option

+ func WithTimeoutProvider(p rpcinfo.TimeoutProvider) Option

Jul 30, 2021

Changes in this version

type Option

+ func WithShortConnection() Option

Jul 9, 2021

Changes in this version

+ func CallOptionInfoFromCtx(ctx context.Context) (res string)

+ func CallOptionsFromCtx(ctx context.Context) (res []callopt.Option)

+ func NewCtxWithCallOptions(ctx context.Context, opts []callopt.Option) context.Context

+ func WithMetaHandler(h remote.MetaHandler) client.Option

+ type Client interface

+ Call func(ctx context.Context, method string, request interface{}, response interface{}) error

+ func NewClient(svcInfo *serviceinfo.ServiceInfo, opts ...Option) (Client, error)

+ type Option = client.Option

+ func WithACLRules(rules ...acl.RejectFunc) Option

+ func WithBackupRequest(p *retry.BackupPolicy) Option

+ func WithBoundHandler(h remote.BoundHandler) 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(error) error) Option

+ func WithFailureRetry(p *retry.FailurePolicy) Option

+ func WithFirstMetaHandler(h remote.MetaHandler) Option

+ func WithFramedTransport() 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 WithStatsLevel(level stats.Level) Option

+ func WithSuite(suite Suite) Option

+ func WithTag(key, val string) Option

+ func WithTracer(c stats.Tracer) Option

+ func WithTransHandlerFactory(f remote.ClientTransHandlerFactory) Option

+ func WithTransportProtocol(tp transport.Protocol) Option

+ type Options = client.Options

+ type Streaming interface

+ Stream func(ctx context.Context, method string, request interface{}, response interface{}) error

+ type Suite interface

+ Options func() []Option