destination

type Destination interface {
	Publish(map[string]interface{})
}

type DiscardDestination struct {
	Config *DiscardDestinationConfig
}

type DiscardDestinationConfig struct {
}

type ElasticseachDestination struct {
	Config *ElasticseachDestinationConfig
	// contains filtered or unexported fields
}

type ElasticseachDestinationConfig struct {
	Index               string   `yaml:"index"`
	TimestampField      string   `yaml:"timestamp_field"`
	SynchronousIndexing bool     `yaml:"synchronous_indexing"`
	Addresses           []string `yaml:"addresses"`
	ElasticsearchConfig *elasticsearch.Config
	BulkIndexerConfig   *esutil.BulkIndexerConfig
}

type LokiDestination struct {
	Config *LokiDestinationConfig
	// contains filtered or unexported fields
}

type LokiDestinationConfig struct {
	PushURL        string            `yaml:"push_url"`
	StaticLabels   map[string]string `yaml:"static_labels"`
	DynamicLabels  []string          `yaml:"dynamic_labels"`
	BatchWait      time.Duration     `yaml:"batch_wait"`
	BatchSize      int               `yaml:"batch_size"`
	MakeLokiSuffer bool              `yaml:"make_loki_suffer"`
}

type PrometheusDestination struct {
	Config *PrometheusDestinationConfig
	// contains filtered or unexported fields
}

type PrometheusDestinationConfig struct {
	Namespace           string        `yaml:"namespace"`
	MetricLabels        []string      `yaml:"metric_labels"`
	VisibilityTimeout   time.Duration `yaml:"visibility_timeout"`
	GCInterval          time.Duration `yaml:"gc_interval"`
	CountBytes          bool          `yaml:"count_bytes"`
	CountPackets        bool          `yaml:"count_packets"`
	CountFlows          bool          `yaml:"count_flows"`
	ObserveFlowDuration bool          `yaml:"observe_flow_duration"`
	FlowDurationBuckets []float64     `yaml:"flow_duration_buckets"`
	ExportIpInfo        bool          `yaml:"export_ip_info"`
	IpInfoLabels        []string      `yaml:"ip_info_labels"`
}

type StdoutDestination struct {
	Config *StdoutDestinationConfig

	Writer io.Writer
	// contains filtered or unexported fields
}

type StdoutDestinationConfig struct {
	Format string `yaml:"format"`
}