Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( DroppedAttrs = map[string]bool{ "sampled_packet_size": true, "lat/long_dest": true, "member_id": true, "dst_eth_mac": true, "src_eth_mac": true, "ult_exit_port": true, "app_protocol": true, "dst_route_prefix": true, "src_route_prefix": true, "trf_termination": true, "simple_trf_prof": true, } KeepAttrs = map[string]bool{ "lost": true, "sent": true, "src_geo_city": true, "src_geo_region": true, "dst_geo_city": true, "dst_geo_region": true, } )
Functions ¶
This section is empty.
Types ¶
type ElasticsearchFormat ¶
func NewFormat ¶
func NewFormat(log logger.Underlying, compression kt.Compression) (*ElasticsearchFormat, error)
func (*ElasticsearchFormat) From ¶
func (f *ElasticsearchFormat) From(raw *kt.Output) ([]map[string]interface{}, error)
Click to show internal directories.
Click to hide internal directories.