dpsink

package

Go to main page

Versions in this module

v1

v1.1.6

Jun 5, 2018

Changes in this version

+ type HistoCounter struct

+ DatapointBucket *sfxclient.RollingBucket

+ EventBucket *sfxclient.RollingBucket

+ SpanBucket *sfxclient.RollingBucket

+ func NewHistoCounter(sink *Counter) *HistoCounter

+ func (h *HistoCounter) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint, next Sink) error

+ func (h *HistoCounter) AddEvents(ctx context.Context, events []*event.Event, next Sink) error

+ func (h *HistoCounter) AddSpans(ctx context.Context, spans []*trace.Span, next trace.Sink) error

+ func (h *HistoCounter) Datapoints() []*datapoint.Datapoint

v1.1.5

May 17, 2018

Changes in this version

type Counter

+ ProcessErrorEvents int64

+ ProcessErrorSpans int64

+ TotalSpans int64

+ func (c *Counter) AddSpans(ctx context.Context, spans []*trace.Span, next trace.Sink) error

type ItemFlagger

+ SpanMetaName string

+ func (f *ItemFlagger) AddSpans(ctx context.Context, spans []*trace.Span, next trace.Sink) error

v1.1.4

May 17, 2018

v1.1.3

Apr 6, 2018

v1.1.2

Mar 22, 2018

v1.1.1

Mar 12, 2018

v1.1.0

Dec 26, 2017

v1.0.0

Mar 17, 2017

Changes in this version

+ var DefaultLogger = log.DefaultLogger.CreateChild()

+ var Discard = discardSink

+ type Counter struct

+ CallsInFlight int64

+ Logger log.Logger

+ ProcessErrorPoints int64

+ TotalDatapoints int64

+ TotalEvents int64

+ TotalProcessCalls int64

+ TotalProcessErrors int64

+ TotalProcessTimeNs int64

+ func (c *Counter) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint, next Sink) error

+ func (c *Counter) AddEvents(ctx context.Context, events []*event.Event, next Sink) error

+ func (c *Counter) Datapoints() []*datapoint.Datapoint

+ type DSink interface

+ AddDatapoints func(ctx context.Context, points []*datapoint.Datapoint) error

+ type ESink interface

+ AddEvents func(ctx context.Context, events []*event.Event) error

+ type EmptyMetricFilter struct

+ EmptyMetricFiltered int64

+ func (e *EmptyMetricFilter) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint, next Sink) error

+ func (e *EmptyMetricFilter) FilterDatapoints(points []*datapoint.Datapoint) []*datapoint.Datapoint

+ type FlagCheck interface

+ HasFlag func(ctx context.Context) bool

+ type ItemFlagger struct

+ CtxFlagCheck FlagCheck

+ EventMetaName string

+ Logger log.Logger

+ MetricDimensionName string

+ func (f *ItemFlagger) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint, next Sink) error

+ func (f *ItemFlagger) AddEvents(ctx context.Context, events []*event.Event, next Sink) error

+ func (f *ItemFlagger) Datapoints() []*datapoint.Datapoint

+ func (f *ItemFlagger) GetDimensions() map[string]string

+ func (f *ItemFlagger) HasDatapointFlag(dp *datapoint.Datapoint) bool

+ func (f *ItemFlagger) HasEventFlag(ev *event.Event) bool

+ func (f *ItemFlagger) ServeHTTP(rw http.ResponseWriter, req *http.Request)

+ func (f *ItemFlagger) SetDatapointFlag(dp *datapoint.Datapoint)

+ func (f *ItemFlagger) SetDatapointFlags(ctx context.Context, points []*datapoint.Datapoint)

+ func (f *ItemFlagger) SetDimensions(dims map[string]string)

+ func (f *ItemFlagger) SetEventFlag(ev *event.Event)

+ func (f *ItemFlagger) Var() expvar.Var

+ type MiddlewareConstructor func(sendTo Sink) Sink

+ func NextWrap(wrapping NextSink) MiddlewareConstructor

+ type NextSink interface

+ AddDatapoints func(ctx context.Context, points []*datapoint.Datapoint, next Sink) error

+ AddEvents func(ctx context.Context, events []*event.Event, next Sink) error

+ type RateLimitErrorLogging struct

+ LogThrottle time.Duration

+ Logger log.Logger

+ func (e *RateLimitErrorLogging) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint, next Sink) error

+ func (e *RateLimitErrorLogging) AddEvents(ctx context.Context, points []*event.Event, next Sink) error

+ type Sink interface

+ func FromChain(endSink Sink, sinks ...MiddlewareConstructor) Sink

+ func IncludingDimensions(dims map[string]string, sink Sink) Sink

+ type WithDimensions struct

+ Dimensions map[string]string

+ func (w *WithDimensions) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint, next Sink) error

+ func (w *WithDimensions) AddEvents(ctx context.Context, events []*event.Event, next Sink) error

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