streamclient

func ConvertOptionFrom(opt client.Option) Option

Deprecated: it's not supposed to be called by users directly; may be removed in future versions. ConvertOptionFrom converts client.Option to streamclient.Option It's convenient for creating StreamOption from existing client.Option Note: NOT all client.Option(s) converted will work for stream clients; Even if it works for now, it's NOT guaranteed that it will always work for future versions.

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

Deprecated: Use client.WithACLRules instead, this requires enabling the streamx feature.

func WithClientBasicInfo(ebi *rpcinfo.EndpointBasicInfo) Option

Deprecated: Use client.WithClientBasicInfo instead, this requires enabling the streamx feature.

func WithCloseCallbacks(callback func() error) Option

Deprecated: Use client.WithCloseCallbacks instead, this requires enabling the streamx feature.

func WithConnReporterEnabled() Option

Deprecated: Use client.WithConnReporterEnabled instead, this requires enabling the streamx feature.

func WithConnectTimeout(d time.Duration) Option

Deprecated: Use client.WithConnectTimeout instead, this requires enabling the streamx feature.

func WithContextBackup(backupHandler func(prev, cur context.Context) (ctx context.Context, backup bool)) Option

Deprecated: Use client.WithContextBackup instead, this requires enabling the streamx feature.

func WithDestService(svr string) Option

Deprecated: Use client.WithDestService instead, this requires enabling the streamx feature.

func WithDiagnosisService(ds diagnosis.Service) Option

Deprecated: Use client.WithDiagnosisService instead, this requires enabling the streamx feature.

func WithDialer(d remote.Dialer) Option

Deprecated: Use client.WithDialer instead, this requires enabling the streamx feature.

func WithErrorHandler(f func(context.Context, error) error) Option

Deprecated: Use client.WithErrorHandler instead, this requires enabling the streamx feature.

func WithFirstMetaHandler(h remote.MetaHandler) Option

Deprecated: Use client.WithFirstMetaHandler instead, this requires enabling the streamx feature.

func WithGRPCConnPoolSize(s uint32) Option

Deprecated: Use client.WithGRPCConnPoolSize instead, this requires enabling the streamx feature.

func WithGRPCInitialConnWindowSize(s uint32) Option

Deprecated: Use client.WithGRPCInitialConnWindowSize instead, this requires enabling the streamx feature.

func WithGRPCInitialWindowSize(s uint32) Option

Deprecated: Use client.WithGRPCInitialWindowSize instead, this requires enabling the streamx feature.

func WithGRPCKeepaliveParams(kp grpc.ClientKeepalive) Option

Deprecated: Use client.WithGRPCKeepaliveParams instead, this requires enabling the streamx feature.

func WithGRPCMaxHeaderListSize(s uint32) Option

Deprecated: Use client.WithGRPCMaxHeaderListSize instead, this requires enabling the streamx feature.

func WithGRPCReadBufferSize(s uint32) Option

Deprecated: Use client.WithGRPCReadBufferSize instead, this requires enabling the streamx feature.

func WithGRPCTLSConfig(tlsConfig *tls.Config) Option

Deprecated: Use client.WithGRPCTLSConfig instead, this requires enabling the streamx feature.

func WithGRPCWriteBufferSize(s uint32) Option

Deprecated: Use client.WithGRPCWriteBufferSize instead, this requires enabling the streamx feature.

func WithHTTPResolver(r http.Resolver) Option

Deprecated: Use client.WithHTTPResolver instead, this requires enabling the streamx feature.

func WithHostPorts(hostPorts ...string) Option

Deprecated: Use client.WithHostPorts instead, this requires enabling the streamx feature.

func WithInstanceMW(mw endpoint.Middleware) Option

Deprecated: Use client.WithInstanceMW instead, this requires enabling the streamx feature.

func WithLoadBalancer(lb loadbalance.Loadbalancer, opts ...*lbcache.Options) Option

Deprecated: Use client.WithLoadBalancer instead, this requires enabling the streamx feature.

func WithMetaHandler(h remote.MetaHandler) Option

Deprecated: Use client.WithMetaHandler instead, this requires enabling the streamx feature.

func WithMiddleware(mw endpoint.Middleware) Option

Deprecated: Use client.WithMiddleware instead, this requires enabling the streamx feature.

func WithMiddlewareBuilder(mwb endpoint.MiddlewareBuilder) Option

Deprecated: Use client.WithMiddlewareBuilder instead, this requires enabling the streamx feature.

func WithPayloadCodec(c remote.PayloadCodec) Option

Deprecated: Use client.WithPayloadCodec instead, this requires enabling the streamx feature.

func WithProxy(p proxy.ForwardProxy) Option

Deprecated: Use client.WithProxy instead, this requires enabling the streamx feature.

func WithRecvMiddleware(mw endpoint.RecvMiddleware) Option

Deprecated: Use client.WithStreamRecvMiddleware instead, this requires enabling the streamx feature.

func WithRecvMiddlewareBuilder(mwb endpoint.RecvMiddlewareBuilder) Option

Deprecated: Use client.WithStreamRecvMiddlewareBuilder instead, this requires enabling the streamx feature.

func WithResolver(r discovery.Resolver) Option

Deprecated: Use client.WithResolver instead, this requires enabling the streamx feature.

func WithSendMiddleware(mw endpoint.SendMiddleware) Option

Deprecated: Use client.WithStreamSendMiddleware instead, this requires enabling the streamx feature.

func WithSendMiddlewareBuilder(mwb endpoint.SendMiddlewareBuilder) Option

Deprecated: Use client.WithStreamSendMiddlewareBuilder instead, this requires enabling the streamx feature.

func WithStatsLevel(level stats.Level) Option

Deprecated: Use client.WithStatsLevel instead, this requires enabling the streamx feature.

func WithSuite(suite client.Suite) Option

Deprecated: Use client.WithSuite instead, this requires enabling the streamx feature.

func WithTag(key, val string) Option

Deprecated: Use client.WithTag instead, this requires enabling the streamx feature.

func WithTracer(c stats.Tracer) Option

Deprecated: Use client.WithTracer instead, this requires enabling the streamx feature.

func WithWarmingUp(wuo *warmup.ClientOption) Option

Deprecated: Use client.WithWarmingUp instead, this requires enabling the streamx feature.

func WithXDSSuite(suite xds.ClientSuite) Option

Deprecated: Use client.WithXDSSuite instead, this requires enabling the streamx feature.