visibility

package

Go to main page

Versions in this module

v1

v1.4.0

Sep 10, 2019

v1.3.3

Sep 4, 2019

v1.3.2

Sep 4, 2019

Changes in this version

type MetricsContext

+ func (m *MetricsContext) GetMetricVal(name string) float64

v1.3.1

Sep 3, 2019

v1.3.0

Aug 31, 2019

v1.2.0

Aug 31, 2019

Changes in this version

type MetricsContext

+ func (m *MetricsContext) GetMetric(name string) (val float64, unit cloudwatch.StandardUnit)

+ func (m *MetricsContext) Reset()

v1.1.0

Aug 20, 2019

Changes in this version

type DefaultMetricsSink

+ Suffix string

type TracingAndMetricsOptions

+ XrayName string

v1.0.0

Aug 16, 2019

Changes in this version

+ const MetricsNamespaceName

+ const OperationNameKey

+ const ZapLoggerEchoContextKey

+ var NullSink = &nullSink

+ func CL(ctx context.Context) *zap.Logger

+ func CLS(ctx context.Context) *zap.SugaredLogger

+ func ExtractSegmentMetrics(segment *xray.Segment) []cloudwatch.MetricDatum

+ func GetZapLoggerFromEchoLogger(logger echo.Logger) *zap.Logger

+ func ImbueContext(ctx context.Context, logger *zap.Logger) context.Context

+ func IsAmznTraceId(id string) bool

+ func OapiRequestValidatorWithMetrics(swagger *openapi3.Swagger, apiPath string, validator AuthValidatorFunc, ...) echo.MiddlewareFunc

+ func RunInstrumented(ctx context.Context, name string, sink MetricsSink, logger *zap.Logger, ...) error

+ func SetOperationNameForMetrics(segment *xray.Segment, opName string)

+ func TracingAndLoggingMiddlewareHook(opts TracingAndMetricsOptions) echo.MiddlewareFunc

+ func XrayLogAdapter(logger *zap.Logger, minLevel xraylog.LogLevel) xraylog.Logger

+ type AuthValidatorFunc func(c context.Context, input *openapi3filter.AuthenticationInput) error

+ type DefaultMetricsSink struct

+ AppName string

+ AwsConfig aws.Config

+ Prefix string

+ func NewMetricsSink(awsConfig aws.Config, appName string, prefix string) *DefaultMetricsSink

+ func (m *DefaultMetricsSink) SendMetrics(ctx context.Context) error

+ func (m *DefaultMetricsSink) SubmitSegmentMetrics(seg *xray.Segment)

+ type MetricEntry struct

+ Timestamp time.Time

+ Unit cloudwatch.StandardUnit

+ Val float64

+ type MetricsContext struct

+ func GetMetricContext(segment *xray.Segment) *MetricsContext

+ func (m *MetricsContext) AddCount(name string, val float64)

+ func (m *MetricsContext) AddDuration(name string, duration time.Duration)

+ func (m *MetricsContext) AddMetric(name string, val float64, unit cloudwatch.StandardUnit)

+ func (m *MetricsContext) Benchmark(name string) *TimeMeasurement

+ func (m *MetricsContext) SetCount(name string, val float64)

+ func (m *MetricsContext) SetDuration(name string, duration time.Duration)

+ func (m *MetricsContext) SetMetric(name string, val float64, unit cloudwatch.StandardUnit)

+ type MetricsSink interface

+ SubmitSegmentMetrics func(seg *xray.Segment)

+ type ProcessContext struct

+ Done chan struct{}

+ Name string

+ Parent *ProcessRegistry

+ func (pc *ProcessContext) Run(proc func(ctx context.Context) error)

+ func (pc *ProcessContext) RunPeriodicProcess(period time.Duration, proc func(ctx context.Context) error)

+ func (pc *ProcessContext) Wait()

+ type ProcessRegistry struct

+ func NewProcessRegistry(xrayPrefix string, logger *zap.Logger, metrics MetricsSink) *ProcessRegistry

+ func (p *ProcessRegistry) Close()

+ func (p *ProcessRegistry) CreateProcessContext(name string) ProcessContext

+ func (p *ProcessRegistry) GetWaitChannel(processName string) <-chan struct{}

+ func (p *ProcessRegistry) HasProcess(name string) bool

+ func (p *ProcessRegistry) LogRunning() string

+ type TimeMeasurement struct

+ func (t *TimeMeasurement) Done()

+ type TracingAndMetricsOptions struct

+ DebugMode bool

+ EnableXray bool

+ HostNameOverride string

+ Logger *zap.Logger

+ Prefix string

+ XRayLogLevel xraylog.LogLevel

+ func (t *TracingAndMetricsOptions) Validate()

+ type XrayStackTrace struct

+ func NewXrayStackTrace(skipFrames int, msg interface{}) *XrayStackTrace

+ func (s *XrayStackTrace) Error() string

+ func (s *XrayStackTrace) Field() zap.Field

+ func (s *XrayStackTrace) JSONStack() interface{}

+ func (s *XrayStackTrace) StackTrace() []uintptr

+ type ZapLoggerWrapper struct

+ func NewLoggerWrapper(zLogger *zap.Logger) *ZapLoggerWrapper

+ func (l *ZapLoggerWrapper) Debug(i ...interface{})

+ func (l *ZapLoggerWrapper) Debugf(format string, args ...interface{})

+ func (l *ZapLoggerWrapper) Debugj(j log.JSON)

+ func (l *ZapLoggerWrapper) Error(i ...interface{})

+ func (l *ZapLoggerWrapper) Errorf(format string, args ...interface{})

+ func (l *ZapLoggerWrapper) Errorj(j log.JSON)

+ func (l *ZapLoggerWrapper) Fatal(i ...interface{})

+ func (l *ZapLoggerWrapper) Fatalf(format string, args ...interface{})

+ func (l *ZapLoggerWrapper) Fatalj(j log.JSON)

+ func (l *ZapLoggerWrapper) Info(i ...interface{})

+ func (l *ZapLoggerWrapper) Infof(format string, args ...interface{})

+ func (l *ZapLoggerWrapper) Infoj(j log.JSON)

+ func (l *ZapLoggerWrapper) Level() log.Lvl

+ func (l *ZapLoggerWrapper) Output() io.Writer

+ func (l *ZapLoggerWrapper) Panic(i ...interface{})

+ func (l *ZapLoggerWrapper) Panicf(format string, args ...interface{})

+ func (l *ZapLoggerWrapper) Panicj(j log.JSON)

+ func (l *ZapLoggerWrapper) Prefix() string

+ func (l *ZapLoggerWrapper) Print(i ...interface{})

+ func (l *ZapLoggerWrapper) Printf(format string, args ...interface{})

+ func (l *ZapLoggerWrapper) Printj(j log.JSON)

+ func (l *ZapLoggerWrapper) SetHeader(h string)

+ func (l *ZapLoggerWrapper) SetLevel(lvl log.Lvl)

+ func (l *ZapLoggerWrapper) SetPrefix(s string)

+ func (l *ZapLoggerWrapper) Warn(i ...interface{})

+ func (l *ZapLoggerWrapper) Warnf(format string, args ...interface{})

+ func (l *ZapLoggerWrapper) Warnj(j log.JSON)

+ func (l ZapLoggerWrapper) SetOutput(w io.Writer)

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