zanzibar

package

Go to main page

Versions in this module

v1

v1.4.1-hotfix-maintenence

Feb 6, 2024

v1.4.1-hotfix-maintenance

Feb 6, 2024

v1.3.5-hotfix-maintenance

Feb 2, 2024

v1.3.4-hotfix-maintenance

Jan 26, 2024

v1.3.3-hotfix-maintenance

Jan 22, 2024

v1.3.2-hotfix-maintenance

Nov 14, 2023

v1.3.0

Aug 3, 2023

Changes in this version

type RWTStruct

+ func DecorateWithRecover(ctx context.Context, wireVal *wire.Value, logger ContextLogger, ...) (resp RWTStruct, err error)

type TChannelClientOption

+ RetryOn tchannel.RetryOn

v1.1.1

Feb 21, 2022

Changes in this version

+ const ClientResponseDurationKey

+ const ClientTypeKey

+ const TraceIDKey

+ const TraceSampledKey

+ const TraceSpanKey

+ func GetAPIEnvironment(endpoint *RouterEndpoint, r *http.Request) string

+ func GetCtxLogCounterFromCtx(ctx context.Context) int

+ func GetCtxLogLevelOrDebugLevelFromCtx(ctx context.Context) zapcore.Level

type ClientHTTPResponse

+ Duration time.Duration

type ContextLogger

+ DebugZ func(ctx context.Context, msg string, fields ...zap.Field) context.Context

+ ErrorZ func(ctx context.Context, msg string, fields ...zap.Field) context.Context

+ InfoZ func(ctx context.Context, msg string, fields ...zap.Field) context.Context

+ PanicZ func(ctx context.Context, msg string, fields ...zap.Field) context.Context

+ SetSkipZanzibarLogs func(bool)

+ WarnZ func(ctx context.Context, msg string, fields ...zap.Field) context.Context

type DefaultDependencies

+ Gateway *Gateway

+ ServerTChannel *tchannel.Channel

type GRPCClientOpts

+ ContextLogger ContextLogger

type Gateway

+ ClientTChannels map[string]*tchannel.Channel

+ ServerTChannel *tchannel.Channel

+ ServerTChannelRouter *TChannelRouter

+ TChannelSubLoggerLevel zapcore.Level

+ func (gateway *Gateway) SetupClientTChannel(config *StaticConfig, serviceName string) *tchannel.Channel

type HTTPClient

+ ContextLogger ContextLogger

type Header

+ Unset func(key string)

type RWTStruct

+ Decode func(sr stream.Reader) error

+ Encode func(sw stream.Writer) error

type ServerHTTPHeader

+ func (zh ServerHTTPHeader) Unset(key string)

type ServerHTTPResponse

+ ClientType string

+ DownstreamFinishTime time.Duration

+ Err error

+ func (res *ServerHTTPResponse) GetPendingResponseObject() interface{}

type ServerTChannelHeader

+ func (th ServerTChannelHeader) Unset(key string)

type StaticConfig

+ func (conf *StaticConfig) AsYaml() ([]byte, error)

type TChannelClient

+ ContextLogger ContextLogger

type TChannelClientOption

+ MaxAttempts int

v0

v0.6.5

Aug 24, 2020

Changes in this version

+ const MetricEndpointAppErrors

+ const MetricEndpointPanics

+ func GetEndpointRequestHeadersFromCtx(ctx context.Context) map[string]string

+ func GetLogFieldsFromCtx(ctx context.Context) []zap.Field

+ func GetScopeTagsFromCtx(ctx context.Context) map[string]string

+ func GetShardKeyFromCtx(ctx context.Context) string

+ func ParamsFromContext(ctx context.Context) url.Values

+ func RequestUUIDFromCtx(ctx context.Context) string

+ func WithEndpointRequestHeadersField(ctx context.Context, requestHeaders map[string]string) context.Context

+ func WithLogFields(ctx context.Context, newFields ...zap.Field) context.Context

+ func WithScopeTags(ctx context.Context, newFields map[string]string) context.Context

+ func WithShardKey(ctx context.Context, sk string) context.Context

type ClientHTTPRequest

+ ClientTargetEndpoint string

+ ContextLogger ContextLogger

+ Metrics ContextMetrics

+ func (req *ClientHTTPRequest) WriteBytes(method, url string, headers map[string]string, rawBody []byte) error

type ClientHTTPResponse

+ func (res *ClientHTTPResponse) ReadAndUnmarshalBodyMultipleOptions(vs []interface{}) (interface{}, error)

+ func (res *ClientHTTPResponse) UnmarshalBody(v interface{}, rawBody []byte) error

+ type ContextExtractor interface

+ ExtractLogFields func(ctx context.Context) []zap.Field

+ ExtractScopeTags func(ctx context.Context) map[string]string

+ type ContextExtractors struct

+ LogFieldsExtractors []ContextLogFieldsExtractor

+ ScopeTagsExtractors []ContextScopeTagsExtractor

+ func (c *ContextExtractors) ExtractLogFields(ctx context.Context) []zap.Field

+ func (c *ContextExtractors) ExtractScopeTags(ctx context.Context) map[string]string

+ type ContextLogFieldsExtractor func(context.Context) []zap.Field

+ type ContextLogger interface

+ Check func(lvl zapcore.Level, msg string) *zapcore.CheckedEntry

+ Debug func(ctx context.Context, msg string, fields ...zap.Field)

+ Error func(ctx context.Context, msg string, fields ...zap.Field)

+ Info func(ctx context.Context, msg string, fields ...zap.Field)

+ Panic func(ctx context.Context, msg string, fields ...zap.Field)

+ Warn func(ctx context.Context, msg string, fields ...zap.Field)

+ func NewContextLogger(log *zap.Logger) ContextLogger

+ type ContextMetrics interface

+ IncCounter func(ctx context.Context, name string, value int64)

+ RecordHistogramDuration func(ctx context.Context, name string, d time.Duration)

+ RecordTimer func(ctx context.Context, name string, d time.Duration)

+ func NewContextMetrics(scope tally.Scope) ContextMetrics

+ type ContextScopeTagsExtractor func(context.Context) map[string]string

type DefaultDependencies

+ ContextExtractor ContextExtractor

+ ContextLogger ContextLogger

+ ContextMetrics ContextMetrics

+ GRPCClientDispatcher *yarpc.Dispatcher

+ JSONWrapper jsonwrapper.JSONWrapper

+ type GRPCClientCallHelper interface

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

+ Start func()

+ func NewGRPCClientCallHelper(ctx context.Context, serviceMethod string, opts *GRPCClientOpts) (context.Context, GRPCClientCallHelper)

+ type GRPCClientOpts struct

+ CircuitBreakerDisabled bool

+ ContextExtractor ContextExtractor

+ Loggers map[string]*zap.Logger

+ Metrics ContextMetrics

+ RequestUUIDHeaderKey string

+ RoutingKey string

+ ScopeTags map[string]map[string]string

+ Timeout time.Duration

+ func NewGRPCClientOpts(logger *zap.Logger, metrics ContextMetrics, contextExtractor ContextExtractor, ...) *GRPCClientOpts

type Gateway

+ ContextExtractor ContextExtractor

+ ContextLogger ContextLogger

+ ContextMetrics ContextMetrics

+ GRPCClientDispatcher *yarpc.Dispatcher

+ JSONWrapper jsonwrapper.JSONWrapper

type HTTPClient

+ JSONWrapper jsonwrapper.JSONWrapper

+ func NewHTTPClientContext(logger *zap.Logger, ContextMetrics ContextMetrics, ...) *HTTPClient

type HTTPRouter

+ Handle func(method, pattern string, handler http.Handler) error

type Header

+ EnsureContext func(ctx context.Context, keys []string, logger ContextLogger) error

+ Values func(key string) ([]string, bool)

+ type Logger interface

+ Check func(lvl zapcore.Level, msg string) *zapcore.CheckedEntry

+ Debug func(msg string, fields ...zap.Field)

+ Error func(msg string, fields ...zap.Field)

+ Info func(msg string, fields ...zap.Field)

+ Panic func(msg string, fields ...zap.Field)

+ Warn func(msg string, fields ...zap.Field)

type Options

+ GetContextFieldExtractors func() []ContextLogFieldsExtractor

+ GetContextScopeExtractors func() []ContextScopeTagsExtractor

+ JSONWrapper jsonwrapper.JSONWrapper

+ MetricsDefaultBuckets tally.Buckets

+ RequestUUIDHeaderKey string

type RouterEndpoint

+ JSONWrapper jsonwrapper.JSONWrapper

type ServerHTTPHeader

+ func (zh ServerHTTPHeader) EnsureContext(ctx context.Context, keys []string, logger ContextLogger) error

+ func (zh ServerHTTPHeader) Values(key string) ([]string, bool)

type ServerHTTPRequest

+ func (req *ServerHTTPRequest) Context() context.Context

+ func (req *ServerHTTPRequest) GetQueryBoolSet(key string) (map[bool]struct{}, bool)

+ func (req *ServerHTTPRequest) GetQueryFloat64Set(key string) (map[float64]struct{}, bool)

+ func (req *ServerHTTPRequest) GetQueryInt16Set(key string) (map[int16]struct{}, bool)

+ func (req *ServerHTTPRequest) GetQueryInt32Set(key string) (map[int32]struct{}, bool)

+ func (req *ServerHTTPRequest) GetQueryInt64Set(key string) (map[int64]struct{}, bool)

+ func (req *ServerHTTPRequest) GetQueryInt8Set(key string) (map[int8]struct{}, bool)

+ func (req *ServerHTTPRequest) GetQueryValueList(key string) ([]string, bool)

+ func (req *ServerHTTPRequest) GetQueryValueSet(key string) (map[string]struct{}, bool)

+ func (req *ServerHTTPRequest) LogAndSendQueryError(err error, expected, key, value string)

+ func (req *ServerHTTPRequest) ReplaceBody(body []byte)

+ func (req *ServerHTTPRequest) SetQueryValue(key string, value string)

+ func (req *ServerHTTPRequest) StartTime() time.Time

type ServerHTTPResponse

+ func (res *ServerHTTPResponse) Headers() http.Header

+ func (res *ServerHTTPResponse) MarshalResponseJSON(body interface{}) []byte

+ func (res *ServerHTTPResponse) SendResponse(statusCode int, headers Header, body interface{}, bytes []byte)

+ func (res *ServerHTTPResponse) WriteBytes(statusCode int, headers Header, bytes []byte)

type ServerTChannelHeader

+ func (th ServerTChannelHeader) EnsureContext(ctx context.Context, keys []string, logger ContextLogger) error

+ func (th ServerTChannelHeader) Values(key string) ([]string, bool)

type TChannelClient

+ func NewTChannelClientContext(ch *tchannel.Channel, logger *zap.Logger, metrics ContextMetrics, ...) *TChannelClient

type TChannelClientOption

+ AltChannelMap map[string]*tchannel.SubChannel

+ HeaderPatterns []string

+ RequestUUIDHeaderKey string

+ RuleEngine ruleengine.RuleEngine

v0.1.0

Aug 17, 2018

Changes in this version

+ func EnsureEmpty(r io.Reader, stage string) error

+ func GetBuffer() *bytes.Buffer

+ func GetDirnameFromRuntimeCaller(file string) string

+ func GetHostname() string

+ func GetRequestEndpointFromCtx(ctx context.Context) string

+ func GetRequestUUIDFromCtx(ctx context.Context) uuid.UUID

+ func GetRoutingDelegateFromCtx(ctx context.Context) string

+ func LogErrorWarnTimeout(logger *zap.Logger, err error, msg string)

+ func NewInstrumentedZapCore(core zapcore.Core, allHostsScope tally.Scope) zapcore.Core

+ func NewTChannelLogger(logger *zap.Logger) tchannel.Logger

+ func NewTChannelStatsReporter(scope tally.Scope) tchannel.StatsReporter

+ func PutBuffer(buf *bytes.Buffer)

+ func ReadHeaders(r io.Reader) (map[string]string, error)

+ func ReadStruct(reader io.Reader, s RWTStruct) error

+ func WithEndpointField(ctx context.Context, endpoint string) context.Context

+ func WithRoutingDelegate(ctx context.Context, rd string) context.Context

+ func WriteHeaders(w io.Writer, headers map[string]string) error

+ type ClientHTTPRequest struct

+ ClientID string

+ Logger *zap.Logger

+ MethodName string

+ func NewClientHTTPRequest(clientID, methodName string, client *HTTPClient) *ClientHTTPRequest

+ func (req *ClientHTTPRequest) CheckHeaders(expected []string) error

+ func (req *ClientHTTPRequest) Do(ctx context.Context) (*ClientHTTPResponse, error)

+ func (req *ClientHTTPRequest) InjectSpanToHeader(span opentracing.Span, format interface{}) error

+ func (req *ClientHTTPRequest) WriteJSON(method, url string, headers map[string]string, body json.Marshaler) error

+ type ClientHTTPResponse struct

+ Header http.Header

+ StatusCode int

+ func NewClientHTTPResponse(req *ClientHTTPRequest) *ClientHTTPResponse

+ func (res *ClientHTTPResponse) CheckOKResponse(okResponses []int)

+ func (res *ClientHTTPResponse) GetRawBody() []byte

+ func (res *ClientHTTPResponse) ReadAll() ([]byte, error)

+ func (res *ClientHTTPResponse) ReadAndUnmarshalBody(v interface{}) error

+ type ConfigOption struct

+ func ConfigFileContents(fileBytes []byte) *ConfigOption

+ func ConfigFilePath(path string) *ConfigOption

+ type DefaultDependencies struct

+ Channel *tchannel.Channel

+ Config *StaticConfig

+ Logger *zap.Logger

+ Scope tally.Scope

+ Tracer opentracing.Tracer

+ type Gateway struct

+ AllHostScope tally.Scope

+ Channel *tchannel.Channel

+ Config *StaticConfig

+ HTTPPort int32

+ HTTPRouter *HTTPRouter

+ Logger *zap.Logger

+ PerHostScope tally.Scope

+ RealHTTPAddr string

+ RealHTTPPort int32

+ RealTChannelAddr string

+ RealTChannelPort int32

+ RootScope tally.Scope

+ ServiceName string

+ TChannelPort int32

+ TChannelRouter *TChannelRouter

+ Tracer opentracing.Tracer

+ WaitGroup *sync.WaitGroup

+ func CreateGateway(config *StaticConfig, opts *Options) (*Gateway, error)

+ func (gateway *Gateway) Bootstrap() error

+ func (gateway *Gateway) Close()

+ func (gateway *Gateway) InspectOrDie() map[string]interface{}

+ func (gateway *Gateway) Shutdown()

+ func (gateway *Gateway) ShutdownTimeout() time.Duration

+ func (gateway *Gateway) SubLogger(name string, level zapcore.Level) *zap.Logger

+ func (gateway *Gateway) Wait()

+ type HTTPClient struct

+ BaseURL string

+ Client *http.Client

+ DefaultHeaders map[string]string

+ func NewHTTPClient(logger *zap.Logger, scope tally.Scope, clientID string, methodNames []string, ...) *HTTPClient

+ type HTTPRouter struct

+ func NewHTTPRouter(gateway *Gateway) *HTTPRouter

+ func (router *HTTPRouter) Register(method, urlpattern string, endpoint *RouterEndpoint) error

+ func (router *HTTPRouter) RegisterRaw(method, prefix string, handler http.HandlerFunc)

+ func (router *HTTPRouter) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type HTTPServer struct

+ Logger *zap.Logger

+ RealAddr string

+ RealIP string

+ RealPort int32

+ func (server *HTTPServer) Close()

+ func (server *HTTPServer) JustListen() (net.Listener, error)

+ func (server *HTTPServer) JustServe(waitGroup *sync.WaitGroup)

+ type HTTPStatusMap map[int]tally.Counter

+ func (hsm HTTPStatusMap) IncrStatus(statusCode int, count int64)

+ type HandlerFn func(context.Context, *ServerHTTPRequest, *ServerHTTPResponse)

+ type Header interface

+ Add func(key string, value string)

+ Ensure func(keys []string, logger *zap.Logger) error

+ Get func(key string) (string, bool)

+ Keys func() []string

+ Set func(key string, value string)

+ type InboundHTTPMetrics struct

+ func NewInboundHTTPMetrics(scope tally.Scope) *InboundHTTPMetrics

+ type InboundTChannelMetrics struct

+ func NewInboundTChannelMetrics(scope tally.Scope) *InboundTChannelMetrics

+ type MiddlewareHandle interface

+ HandleRequest func(ctx context.Context, req *ServerHTTPRequest, res *ServerHTTPResponse, ...) bool

+ HandleResponse func(ctx context.Context, res *ServerHTTPResponse, shared SharedState)

+ JSONSchema func() *jsonschema.Document

+ Name func() string

+ type MiddlewareStack struct

+ func NewStack(middlewares []MiddlewareHandle, handle HandlerFn) *MiddlewareStack

+ func (m *MiddlewareStack) Handle(ctx context.Context, req *ServerHTTPRequest, res *ServerHTTPResponse)

+ func (m *MiddlewareStack) Middlewares() []MiddlewareHandle

+ type MiddlewareTchannelHandle interface

+ HandleRequest func(ctx context.Context, reqHeaders map[string]string, wireValue *wire.Value, ...) (bool, error)

+ HandleResponse func(ctx context.Context, rwt RWTStruct, shared TchannelSharedState) RWTStruct

+ JSONSchema func() *jsonschema.Document

+ Name func() string

+ type MiddlewareTchannelStack struct

+ func NewTchannelStack(middlewares []MiddlewareTchannelHandle, handler TChannelHandler) *MiddlewareTchannelStack

+ func (m *MiddlewareTchannelStack) Handle(ctx context.Context, reqHeaders map[string]string, wireValue *wire.Value) (bool, RWTStruct, map[string]string, error)

+ func (m *MiddlewareTchannelStack) TchannelMiddlewares() []MiddlewareTchannelHandle

+ type Options struct

+ LogWriter zapcore.WriteSyncer

+ MetricsBackend tally.CachedStatsReporter

+ type OutboundHTTPMetrics struct

+ func NewOutboundHTTPMetrics(scope tally.Scope) *OutboundHTTPMetrics

+ type OutboundTChannelMetrics struct

+ func NewOutboundTChannelMetrics(scope tally.Scope) *OutboundTChannelMetrics

+ type PostResponseCB func(ctx context.Context, method string, response RWTStruct)

+ type RWTStruct interface

+ FromWire func(wire.Value) error

+ ToWire func() (wire.Value, error)

+ type RawTChannelClient struct

+ func NewRawTChannelClient(ch *tchannel.Channel, logger *zap.Logger, scope tally.Scope, ...) *RawTChannelClient

+ func (r *RawTChannelClient) Call(ctx context.Context, thriftService, methodName string, ...) (success bool, resHeaders map[string]string, err error)

+ type RouterEndpoint struct

+ EndpointName string

+ HandlerFn HandlerFn

+ HandlerName string

+ func NewRouterEndpoint(logger *zap.Logger, scope tally.Scope, tracer opentracing.Tracer, ...) *RouterEndpoint

+ func (endpoint *RouterEndpoint) HandleRequest(w http.ResponseWriter, r *http.Request, params httprouter.Params)

+ type RuntimeMetricsCollector interface

+ IsRunning func() bool

+ Start func()

+ Stop func()

+ func NewRuntimeMetricsCollector(opts RuntimeMetricsOptions, scope tally.Scope) RuntimeMetricsCollector

+ func StartRuntimeMetricsCollector(config RuntimeMetricsOptions, scope tally.Scope) RuntimeMetricsCollector

+ type RuntimeMetricsOptions struct

+ CollectInterval time.Duration

+ EnableCPUMetrics bool

+ EnableGCMetrics bool

+ EnableMemMetrics bool

+ type ServerHTTPHeader http.Header

+ func NewServerHTTPHeader(h http.Header) ServerHTTPHeader

+ func (zh ServerHTTPHeader) Add(key string, value string)

+ func (zh ServerHTTPHeader) Ensure(keys []string, logger *zap.Logger) error

+ func (zh ServerHTTPHeader) Get(key string) (string, bool)

+ func (zh ServerHTTPHeader) GetAll(key string) []string

+ func (zh ServerHTTPHeader) GetOrEmptyStr(key string) string

+ func (zh ServerHTTPHeader) Keys() []string

+ func (zh ServerHTTPHeader) Set(key string, value string)

+ type ServerHTTPRequest struct

+ EndpointName string

+ HandlerName string

+ Header Header

+ Logger *zap.Logger

+ Method string

+ Params httprouter.Params

+ URL *url.URL

+ func NewServerHTTPRequest(w http.ResponseWriter, r *http.Request, params httprouter.Params, ...) *ServerHTTPRequest

+ func (req *ServerHTTPRequest) CheckHeaders(headers []string) bool

+ func (req *ServerHTTPRequest) CheckQueryValue(key string) bool

+ func (req *ServerHTTPRequest) GetQueryBool(key string) (bool, bool)

+ func (req *ServerHTTPRequest) GetQueryBoolList(key string) ([]bool, bool)

+ func (req *ServerHTTPRequest) GetQueryFloat64(key string) (float64, bool)

+ func (req *ServerHTTPRequest) GetQueryFloat64List(key string) ([]float64, bool)

+ func (req *ServerHTTPRequest) GetQueryInt16(key string) (int16, bool)

+ func (req *ServerHTTPRequest) GetQueryInt16List(key string) ([]int16, bool)

+ func (req *ServerHTTPRequest) GetQueryInt32(key string) (int32, bool)

+ func (req *ServerHTTPRequest) GetQueryInt32List(key string) ([]int32, bool)

+ func (req *ServerHTTPRequest) GetQueryInt64(key string) (int64, bool)

+ func (req *ServerHTTPRequest) GetQueryInt64List(key string) ([]int64, bool)

+ func (req *ServerHTTPRequest) GetQueryInt8(key string) (int8, bool)

+ func (req *ServerHTTPRequest) GetQueryInt8List(key string) ([]int8, bool)

+ func (req *ServerHTTPRequest) GetQueryValue(key string) (string, bool)

+ func (req *ServerHTTPRequest) GetQueryValues(key string) ([]string, bool)

+ func (req *ServerHTTPRequest) GetRawBody() []byte

+ func (req *ServerHTTPRequest) GetSpan() opentracing.Span

+ func (req *ServerHTTPRequest) HasQueryPrefix(prefix string) bool

+ func (req *ServerHTTPRequest) HasQueryValue(key string) bool

+ func (req *ServerHTTPRequest) PeekBody(keys ...string) ([]byte, jsonparser.ValueType, error)

+ func (req *ServerHTTPRequest) ReadAll() ([]byte, bool)

+ func (req *ServerHTTPRequest) ReadAndUnmarshalBody(body json.Unmarshaler) bool

+ func (req *ServerHTTPRequest) UnmarshalBody(body json.Unmarshaler, rawBody []byte) bool

+ type ServerHTTPResponse struct

+ Request *ServerHTTPRequest

+ StatusCode int

+ func NewServerHTTPResponse(w http.ResponseWriter, req *ServerHTTPRequest) *ServerHTTPResponse

+ func (res *ServerHTTPResponse) GetPendingResponse() ([]byte, int)

+ func (res *ServerHTTPResponse) PeekBody(keys ...string) ([]byte, jsonparser.ValueType, error)

+ func (res *ServerHTTPResponse) SendError(statusCode int, errMsg string, errCause error)

+ func (res *ServerHTTPResponse) SendErrorString(statusCode int, errMsg string)

+ func (res *ServerHTTPResponse) WriteJSON(statusCode int, headers Header, body json.Marshaler)

+ func (res *ServerHTTPResponse) WriteJSONBytes(statusCode int, headers Header, bytes []byte)

+ type ServerTChannelHeader map[string]string

+ func (th ServerTChannelHeader) Add(key string, value string)

+ func (th ServerTChannelHeader) Ensure(keys []string, logger *zap.Logger) error

+ func (th ServerTChannelHeader) Get(key string) (string, bool)

+ func (th ServerTChannelHeader) Keys() []string

+ func (th ServerTChannelHeader) Set(key string, value string)

+ type SharedState struct

+ func NewSharedState(middlewares []MiddlewareHandle) SharedState

+ func (s SharedState) GetState(name string) interface{}

+ func (s SharedState) SetState(m MiddlewareHandle, state interface{})

+ type StaticConfig struct

+ func NewStaticConfigOrDie(configOptions []*ConfigOption, seedConfig map[string]interface{}) *StaticConfig

+ func (conf *StaticConfig) ContainsKey(key string) bool

+ func (conf *StaticConfig) Destroy()

+ func (conf *StaticConfig) Freeze()

+ func (conf *StaticConfig) InspectOrDie() map[string]interface{}

+ func (conf *StaticConfig) MustGetBoolean(key string) bool

+ func (conf *StaticConfig) MustGetFloat(key string) float64

+ func (conf *StaticConfig) MustGetInt(key string) int64

+ func (conf *StaticConfig) MustGetString(key string) string

+ func (conf *StaticConfig) MustGetStruct(key string, ptr interface{})

+ func (conf *StaticConfig) SetConfigValueOrDie(key string, bytes []byte, dataType string)

+ func (conf *StaticConfig) SetSeedOrDie(key string, value interface{})

+ type StaticConfigValue struct

+ type TChannelCaller interface

+ Call func(ctx context.Context, service, method string, reqHeaders map[string]string, ...) (success bool, respHeaders map[string]string, err error)

+ type TChannelClient struct

+ ClientID string

+ Loggers map[string]*zap.Logger

+ Scopes map[string]tally.Scope

+ func NewTChannelClient(ch *tchannel.Channel, logger *zap.Logger, scope tally.Scope, ...) *TChannelClient

+ func (c *TChannelClient) Call(ctx context.Context, thriftService, methodName string, ...) (success bool, resHeaders map[string]string, err error)

+ func (c *TChannelClient) CallThruAltChannel(ctx context.Context, thriftService, methodName string, ...) (success bool, resHeaders map[string]string, err error)

+ type TChannelClientOption struct

+ AltSubchannelName string

+ ClientID string

+ MethodNames map[string]string

+ RoutingKey *string

+ ServiceName string

+ Timeout time.Duration

+ TimeoutPerAttempt time.Duration

+ type TChannelEndpoint struct

+ EndpointID string

+ HandlerID string

+ Logger *zap.Logger

+ Method string

+ Scope tally.Scope

+ func NewTChannelEndpoint(logger *zap.Logger, scope tally.Scope, endpointID, handlerID, method string, ...) *TChannelEndpoint

+ func NewTChannelEndpointWithPostResponseCB(logger *zap.Logger, scope tally.Scope, endpointID, handlerID, method string, ...) *TChannelEndpoint

+ type TChannelHandler interface

+ Handle func(ctx context.Context, reqHeaders map[string]string, wireValue *wire.Value) (success bool, resp RWTStruct, respHeaders map[string]string, err error)

+ type TChannelLogger struct

+ func (l TChannelLogger) Debug(msg string)

+ func (l TChannelLogger) Debugf(msg string, args ...interface{})

+ func (l TChannelLogger) Enabled(tlevel tchannel.LogLevel) bool

+ func (l TChannelLogger) Error(msg string)

+ func (l TChannelLogger) Fatal(msg string)

+ func (l TChannelLogger) Fields() tchannel.LogFields

+ func (l TChannelLogger) Info(msg string)

+ func (l TChannelLogger) Infof(msg string, args ...interface{})

+ func (l TChannelLogger) Warn(msg string)

+ func (l TChannelLogger) WithFields(fields ...tchannel.LogField) tchannel.Logger

+ type TChannelRouter struct

+ func NewTChannelRouter(registrar tchannel.Registrar, g *Gateway) *TChannelRouter

+ func (s *TChannelRouter) Handle(ctx context.Context, call *tchannel.InboundCall)

+ func (s *TChannelRouter) Register(e *TChannelEndpoint) error

+ type TchannelSharedState struct

+ func NewTchannelSharedState(middlewares []MiddlewareTchannelHandle) TchannelSharedState

+ func (s TchannelSharedState) GetTchannelState(name string) interface{}

+ func (s TchannelSharedState) SetTchannelState(m MiddlewareTchannelHandle, state interface{})

+ type UnexpectedHTTPError struct

+ RawBody []byte

+ StatusCode int

+ func (rawErr *UnexpectedHTTPError) Error() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL