core

type Classifier interface {
	GetFlowTag(fl *flow.Flow) Tag
}

type Compressor interface {
	Compress(b []byte) (bytes.Buffer, error)
}

type Encoder interface {
	Encode(in []interface{}) ([]byte, error)
}

type Filterer interface {
	IsExcluded(tag Tag) bool
}

type Pipeline struct {
	Transformer Transformer
	Classifier  Classifier
	Filterer    Filterer
	Encoder     Encoder
	Compressor  Compressor
	Storer      Storer
}

type StoreS3 struct {
	// contains filtered or unexported fields
}

type Storer interface {
	StoreFlows(flows []*flow.Flow) error
	SetPipeline(p *Pipeline)
}

type Tag string

type Transformer interface {
	// Transform transforms a flow before being stored
	Transform(f *flow.Flow) interface{}
}