sinks

Documentation

Index

• Constants
• type Sink
• type SinkImpl
  • func NewSink(sink Sink, log logger.Underlying, registry go_metrics.Registry, ...) (SinkImpl, error)

Constants

const (
	KafkaSink    Sink = "kafka"
	StdOutSink        = "stdout"
	NewRelicSink      = "new_relic"
	KentikSink        = "kentik"
	FileSink          = "file"
	NetSink           = "net"
	HttpSink          = "http"
	SplunkSink        = "splunk"
	PromSink          = "prometheus"
	S3Sink            = "s3"
	GCloudSink        = "gcloud"
	GCPPubSub         = "gcppubsub"
)

Types

type Sink

type Sink string

type SinkImpl

type SinkImpl interface {
	Init(context.Context, formats.Format, kt.Compression, formats.Formatter) error
	Send(context.Context, *kt.Output)
	Close()
	HttpInfo() map[string]float64
}

func NewSink

func NewSink(sink Sink, log logger.Underlying, registry go_metrics.Registry, tooBig chan int, conf *kt.KentikConfig, logTee chan string) (SinkImpl, error)