Documentation
¶
Index ¶
Constants ¶
View Source
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_PROM_REMOTE = "prometheus_remote" FORMAT_NR = "new_relic" FORMAT_NRM = "new_relic_metric" FORMAT_SPLUNK = "splunk" FORMAT_DDOG = "ddog" FORMAT_KFLOW = "kflow" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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, registry go_metrics.Registry, compression kt.Compression, cfg *ktranslate.Config) (Formatter, error)
Click to show internal directories.
Click to hide internal directories.