Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

dpsink

package

Go to main page

Versions in this module

v0

v0.6.0

Jun 17, 2015

v0.5.0

May 21, 2015

v0.4.0

May 1, 2015

Changes in this version

+ type Counter struct

+ CallsInFlight int64

+ ProcessErrorPoints int64

+ TotalDatapoints int64

+ TotalProcessCalls int64

+ TotalProcessErrors int64

+ TotalProcessTimeNs int64

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

+ func (c *Counter) Stats(dimensions map[string]string) []*datapoint.Datapoint

+ 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 ErrCallback func(error)

+ func LogCallback(msg string, log *logrus.Logger) ErrCallback

+ 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

+ type RateLimitErrorLogging struct

+ Callback ErrCallback

+ LogThrottle time.Duration

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

+ type Sink interface

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

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