sinks

Documentation

Index

• func RunTruncatingBuffer(inputChan <-chan *events.Envelope, bufferSize uint, logger *gosteno.Logger, ...) *truncatingbuffer.TruncatingBuffer
• type DropCounter
  • func NewDropCounter(appID string, drainURL string, metricUpdateChannel chan<- int64) DropCounter
  • func (dc *DropCounter) GetInstrumentationMetric() Metric
  • func (dc *DropCounter) UpdateDroppedMessageCount(messageCount int64)
• type Metric
• type Sink

Functions

func RunTruncatingBuffer

func RunTruncatingBuffer(inputChan <-chan *events.Envelope, bufferSize uint, logger *gosteno.Logger, dropsondeOrigin string) *truncatingbuffer.TruncatingBuffer

Types

type DropCounter

type DropCounter struct {
	// contains filtered or unexported fields
}

func NewDropCounter

func NewDropCounter(appID string, drainURL string, metricUpdateChannel chan<- int64) DropCounter

func (*DropCounter) GetInstrumentationMetric

func (dc *DropCounter) GetInstrumentationMetric() Metric

func (*DropCounter) UpdateDroppedMessageCount

func (dc *DropCounter) UpdateDroppedMessageCount(messageCount int64)

type Metric

type Metric struct {
	Name  string
	Value int64
	Tags  map[string]interface{}
}

type Sink

type Sink interface {
	StreamId() string
	Run(<-chan *events.Envelope)
	Identifier() string
	ShouldReceiveErrors() bool
	GetInstrumentationMetric() Metric
	UpdateDroppedMessageCount(int64)
}