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 Extractor ¶
type Extractor interface {
Extract(in []config.GenericMap) []config.GenericMap
}
func NewExtractAggregate ¶
func NewExtractAggregate(params config.StageParam) (Extractor, error)
NewExtractAggregate creates a new extractor
Click to show internal directories.
Click to hide internal directories.