sinks

Documentation

Index

• func RunTruncatingBuffer(inputChan <-chan *events.Envelope, bufferSize uint, ...) *truncatingbuffer.TruncatingBuffer
• type Metric
• type Sink

Functions

func RunTruncatingBuffer

func RunTruncatingBuffer(inputChan <-chan *events.Envelope, bufferSize uint, context truncatingbuffer.BufferContext, stopChannel chan struct{}) *truncatingbuffer.TruncatingBuffer

Types

type Metric

type Metric struct {
	Name  string
	Value int64
}

type Sink

type Sink interface {
	AppID() string
	Run(<-chan *events.Envelope)
	Identifier() string
	ShouldReceiveErrors() bool
}