Versions in this module Expand all Collapse all v0 v0.22.1 Jul 14, 2023 Changes in this version + func RegisterInterceptor(newRI RequestInterceptor) (restore func()) + type GRPCOptions struct + Addresses []string + Caller string + Encoding string + MaxResponseSize int + RoutingDelegate string + RoutingKey string + Tracer opentracing.Tracer + type HTTPOptions struct + Encoding string + Method string + RoutingDelegate string + RoutingKey string + ShardKey string + SourceService string + TargetService string + Tracer opentracing.Tracer + URLs []string + type Protocol int + const GRPC + const HTTP + const TChannel + const Unknown + type Request struct + Baggage map[string]string + Body []byte + Headers map[string]string + Method string + ShardKey string + TargetService string + Timeout time.Duration + TransportHeaders map[string]string + func ApplyInterceptor(ctx context.Context, req *Request) (*Request, error) + type RequestInterceptor interface + Apply func(ctx context.Context, req *Request) (*Request, error) + type Response struct + Body []byte + Headers map[string]string + TransportFields map[string]interface{} + type StreamRequest struct + Request *Request + type StreamTransport interface + CallStream func(ctx context.Context, request *StreamRequest) (*transport.ClientStream, error) + type TChannelOptions struct + Encoding string + LogLevel *tchannel.LogLevel + Peers []string + RoutingDelegate string + RoutingKey string + ShardKey string + SourceService string + TargetService string + TraceSampleRate float64 + Tracer opentracing.Tracer + TransportOpts map[string]string + type Transport interface + Call func(ctx context.Context, request *Request) (*Response, error) + Protocol func() Protocol + Tracer func() opentracing.Tracer + func NewHTTP(opts HTTPOptions) (Transport, error) + func NewTChannel(opts TChannelOptions) (Transport, error) + type TransportCloser interface + func NewGRPC(options GRPCOptions) (TransportCloser, error)