Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ExtractAggregate ¶
type ExtractAggregate struct {
Aggregates aggregate.Aggregates
}
func (*ExtractAggregate) Extract ¶
func (ea *ExtractAggregate) Extract(entries []config.GenericMap) []config.GenericMap
Extract extracts a flow before being stored
type ExtractTimebased ¶ added in v0.1.4
type ExtractTimebased struct { Filters []timebased.FilterStruct IndexKeyStructs map[string]*timebased.IndexKeyTable }
func (*ExtractTimebased) Extract ¶ added in v0.1.4
func (et *ExtractTimebased) Extract(entries []config.GenericMap) []config.GenericMap
Extract extracts a flow before being stored
type Extractor ¶
type Extractor interface {
Extract(in []config.GenericMap) []config.GenericMap
}
func NewExtractAggregate ¶
func NewExtractAggregate(params config.StageParam) (Extractor, error)
NewExtractAggregate creates a new extractor
func NewExtractTimebased ¶ added in v0.1.4
func NewExtractTimebased(params config.StageParam) (Extractor, error)
NewExtractTimebased creates a new extractor
Click to show internal directories.
Click to hide internal directories.