formats

Documentation

Index

• Constants
• type Format
• type Formatter
  • func NewFormat(format Format, log logger.Underlying, compression kt.Compression) (Formatter, error)

Constants

const (
	FORMAT_AVRO          Format = "avro"
	FORMAT_ELASTICSEARCH        = "elasticsearch"
	FORMAT_JSON                 = "json"
	FORMAT_JSON_FLAT            = "flat_json"
	FORMAT_NETFLOW              = "netflow"
	FORMAT_INFLUX               = "influx"
	FORMAT_CARBON               = "carbon"
	FORMAT_PROM                 = "prometheus"
	FORMAT_NR                   = "new_relic"
	FORMAT_NRM                  = "new_relic_metric"
	FORMAT_SPLUNK               = "splunk"
	FORMAT_KFLOW                = "kflow"
)

Types

type Format

type Format string

type Formatter

type Formatter interface {
	To([]*kt.JCHF, []byte) (*kt.Output, error)
	From(*kt.Output) ([]map[string]interface{}, error)
	Rollup([]rollup.Rollup) (*kt.Output, error)
}

func NewFormat

func NewFormat(format Format, log logger.Underlying, compression kt.Compression) (Formatter, error)