Versions in this module Expand all Collapse all v1 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