Versions in this module Expand all Collapse all v0 v0.24.0 Jul 16, 2019 Changes in this version + const CfgRoot + func CfgAuthOpts(cfg *viper.Viper) *shttp.AuthenticationOpts + func NewSubscriber(pipeline *Pipeline, cfg *viper.Viper) (*websocket.StructSpeaker, error) + func SubscriberRun(s *websocket.StructSpeaker) + type Classifier interface + GetFlowTag func(fl *flow.Flow) Tag + func NewClassify(cfg *viper.Viper) (Classifier, error) + type Compressor interface + Compress func(b []byte) (bytes.Buffer, error) + func NewCompressGzip() (Compressor, error) + type Encoder interface + Encode func(in []interface{}) ([]byte, error) + func NewEncodeJSON() (Encoder, error) + type Filterer interface + IsExcluded func(tag Tag) bool + func NewFilter(tags ...string) (Filterer, error) + func NewFilterFromConfig(cfg *viper.Viper) (Filterer, error) + type Pipeline struct + Classifier Classifier + Compressor Compressor + Encoder Encoder + Filterer Filterer + Storer Storer + Transformer Transformer + func NewPipeline(transformer Transformer, classifier Classifier, filterer Filterer, ...) *Pipeline + func (p *Pipeline) OnStructMessage(c ws.Speaker, msg *ws.StructMessage) + type StoreS3 struct + func NewStoreS3(client objectStoreClient, bucket, objectPrefix string, ...) (*StoreS3, error) + func NewStoreS3FromConfig(cfg *viper.Viper) (*StoreS3, error) + func (s *StoreS3) DeleteObject(objectKey *string) error + func (s *StoreS3) ListObjects() ([]*string, error) + func (s *StoreS3) ReadObjectFlows(objectKey *string, objectFlows interface{}) error + func (s *StoreS3) SetPipeline(pipeline *Pipeline) + func (s *StoreS3) StoreFlows(flows []*flow.Flow) error + type Storer interface + SetPipeline func(p *Pipeline) + StoreFlows func(flows []*flow.Flow) error + func NewStoreFromConfig(cfg *viper.Viper) (Storer, error) + func NewStoreLog() (Storer, error) + type Tag string + type Transformer interface + Transform func(f *flow.Flow) interface{}
Go to main page