processor

Aug 27, 2018

Changes in this version

+ const TypeMetric

type Config

+ Metric MetricConfig

+ type Metric struct

+ func (m *Metric) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ type MetricConfig struct

+ Labels map[string]string

+ Path string

+ Type string

+ Value string

+ func NewMetricConfig() MetricConfig

type Type

+ func NewMetric(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

Aug 22, 2018

Changes in this version

+ const TypeHash

type Config

+ Hash HashConfig

+ type Hash struct

+ func (c *Hash) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ type HashConfig struct

+ Algorithm string

+ Parts []int

+ func NewHashConfig() HashConfig

type Type

+ func NewHash(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

Aug 10, 2018

Changes in this version

+ const TypeThrottle

type Config

+ Throttle ThrottleConfig

+ type Throttle struct

+ func (m *Throttle) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ type ThrottleConfig struct

+ Period string

+ func NewThrottleConfig() ThrottleConfig

type Type

+ func NewThrottle(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

Aug 6, 2018

Changes in this version

+ type SplitConfig struct

+ Size int

+ func NewSplitConfig() SplitConfig

Aug 6, 2018

Changes in this version

type MetadataConfig

+ Parts []int

Aug 3, 2018

Changes in this version

+ const TypeArchive

+ const TypeBatch

+ const TypeBoundsCheck

+ const TypeCombine

+ const TypeCompress

+ const TypeConditional

+ const TypeDecode

+ const TypeDecompress

+ const TypeDedupe

+ const TypeEncode

+ const TypeFilter

+ const TypeFilterParts

+ const TypeGrok

+ const TypeHTTP

+ const TypeHashSample

+ const TypeInsertPart

+ const TypeJMESPath

+ const TypeJSON

+ const TypeMergeJSON

+ const TypeMetadata

+ const TypeNoop

+ const TypeProcessField

+ const TypeProcessMap

+ const TypeSample

+ const TypeSelectParts

+ const TypeSplit

+ const TypeText

+ const TypeUnarchive

type HTTPConfig

+ MaxParallel int

+ Parallel bool

Jul 31, 2018

Changes in this version

type ProcessMapConfig

+ Conditions []condition.Config

+ PostmapOptional map[string]string

Jul 27, 2018

Changes in this version

type DedupeConfig

+ Key string

Jul 26, 2018

Changes in this version

type Config

+ Metadata MetadataConfig

+ type Metadata struct

+ func (p *Metadata) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ type MetadataConfig struct

+ Key string

+ Operator string

+ Value string

+ func NewMetadataConfig() MetadataConfig

type Type

+ func NewMetadata(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

Jul 25, 2018

Changes in this version

type BatchConfig

+ Condition condition.Config

Jul 23, 2018

Changes in this version

type Config

+ Text TextConfig

type ProcessMapConfig

+ PremapOptional map[string]string

+ type Text struct

+ func (t *Text) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ type TextConfig struct

+ Arg string

+ Operator string

+ Parts []int

+ Value string

+ func NewTextConfig() TextConfig

type Type

+ func NewText(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

Jul 20, 2018

Changes in this version

type Config

+ ProcessField ProcessFieldConfig

+ ProcessMap ProcessMapConfig

+ type ProcessField struct

+ func (p *ProcessField) ProcessMessage(msg types.Message) (msgs []types.Message, res types.Response)

+ type ProcessFieldConfig struct

+ Parts []int

+ Path string

+ Processors []Config

+ func NewProcessFieldConfig() ProcessFieldConfig

+ type ProcessMap struct

+ func (p *ProcessMap) ProcessMessage(msg types.Message) (msgs []types.Message, res types.Response)

+ type ProcessMapConfig struct

+ Parts []int

+ Postmap map[string]string

+ Premap map[string]string

+ Processors []Config

+ StrictPremap bool

+ func NewProcessMapConfig() ProcessMapConfig

type Type

+ func NewProcessField(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

+ func NewProcessMap(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

Jul 8, 2018

Changes in this version

type BatchConfig

+ PeriodMS int

type Config

+ Decode DecodeConfig

+ Encode EncodeConfig

+ type Decode struct

+ func (c *Decode) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ type DecodeConfig struct

+ Parts []int

+ Scheme string

+ func NewDecodeConfig() DecodeConfig

+ type Encode struct

+ func (c *Encode) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ type EncodeConfig struct

+ Parts []int

+ Scheme string

+ func NewEncodeConfig() EncodeConfig

type Type

+ func NewDecode(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

+ func NewEncode(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

Jul 4, 2018

Changes in this version

type Config

+ HTTP HTTPConfig

+ type HTTP struct

+ func (h *HTTP) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ type HTTPConfig struct

+ Client client.Config

+ Parts []int

+ RequestMap map[string]string

+ ResponseMap map[string]string

+ StrictReqMapping bool

+ func NewHTTPConfig() HTTPConfig

type Type

+ func NewHTTP(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

Jun 24, 2018

Changes in this version

type Config

+ FilterParts FilterPartsConfig

+ type FilterParts struct

+ func (c *FilterParts) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ type FilterPartsConfig struct

+ func NewFilterPartsConfig() FilterPartsConfig

type Type

+ func NewFilterParts(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

Jun 15, 2018

Changes in this version

type Config

+ JSON JSONConfig

+ type JSON struct

+ func (p *JSON) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ type JSONConfig struct

+ Operator string

+ Parts []int

+ Path string

+ Value rawJSONValue

+ func NewJSONConfig() JSONConfig

type Type

+ func NewJSON(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

Jun 10, 2018

Changes in this version

type Config

+ Grok GrokConfig

+ type Grok struct

+ func (g *Grok) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ type GrokConfig struct

+ NamedOnly bool

+ Parts []int

+ Patterns []string

+ RemoveEmpty bool

+ To string

+ UseDefaults bool

+ func NewGrokConfig() GrokConfig

type Type

+ func NewGrok(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

Jun 6, 2018

Changes in this version

type ConditionalConfig

+ ElseProcessors []Config

type Config

+ DeleteJSON DeleteJSONConfig

+ type DeleteJSON struct

+ func (p *DeleteJSON) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ type DeleteJSONConfig struct

+ Parts []int

+ Path string

+ func NewDeleteJSONConfig() DeleteJSONConfig

type Type

+ func NewDeleteJSON(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

Jun 2, 2018

Changes in this version

+ type Batch struct

+ func (c *Batch) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ type BatchConfig struct

+ ByteSize int

+ func NewBatchConfig() BatchConfig

+ type Conditional struct

+ func (c *Conditional) ProcessMessage(msg types.Message) (msgs []types.Message, res types.Response)

+ type ConditionalConfig struct

+ Condition condition.Config

+ Processors []Config

+ func NewConditionalConfig() ConditionalConfig

type Config

+ Batch BatchConfig

+ Conditional ConditionalConfig

+ Filter FilterConfig

+ type Filter struct

+ func (c *Filter) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ type FilterConfig struct

+ func NewFilterConfig() FilterConfig

type Type

+ func NewBatch(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

+ func NewConditional(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

+ func NewFilter(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

May 17, 2018

Changes in this version

type DedupeConfig

+ JSONPaths []string

May 17, 2018

Changes in this version

type DedupeConfig

+ JSONPath string

May 15, 2018

Changes in this version

type Config

+ MergeJSON MergeJSONConfig

+ type MergeJSON struct

+ func (p *MergeJSON) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ type MergeJSONConfig struct

+ Parts []int

+ RetainParts bool

+ func NewMergeJSONConfig() MergeJSONConfig

type Type

+ func NewMergeJSON(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

Apr 24, 2018

Changes in this version

type JMESPathConfig

+ Parts []int

type SelectJSONConfig

+ Parts []int

type SetJSONConfig

+ Parts []int

Apr 5, 2018

Changes in this version

type DedupeConfig

+ DropOnCacheErr bool

Mar 26, 2018

Changes in this version

type Config

+ JMESPath JMESPathConfig

+ type JMESPath struct

+ func (p *JMESPath) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ type JMESPathConfig struct

+ Part int

+ Query string

+ func NewJMESPathConfig() JMESPathConfig

type Type

+ func NewJMESPath(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

Mar 21, 2018

Changes in this version

type Config

+ Dedupe DedupeConfig

+ SelectJSON SelectJSONConfig

+ type Dedupe struct

+ func (d *Dedupe) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ type DedupeConfig struct

+ Cache string

+ HashType string

+ Parts []int

+ func NewDedupeConfig() DedupeConfig

+ type SelectJSON struct

+ func (p *SelectJSON) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ type SelectJSONConfig struct

+ Part int

+ Path string

+ func NewSelectJSONConfig() SelectJSONConfig

type Type

+ func NewDedupe(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

+ func NewSelectJSON(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error)

Mar 8, 2018

Changes in this version

type BoundsCheckConfig

+ MinPartSize int

Mar 5, 2018

Changes in this version

+ type Condition struct

+ func (c *Condition) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ type ConditionConfig struct

+ func NewConditionConfig() ConditionConfig

type Config

+ Condition ConditionConfig

type Type

+ func NewCondition(conf Config, log log.Modular, stats metrics.Type) (Type, error)

Mar 2, 2018

Changes in this version

+ var Constructors = map[string]TypeSpec

+ type TypeSpec struct

Feb 22, 2018

Changes in this version

+ func SanitiseConfig(conf Config) (interface{}, error)

Feb 12, 2018

Changes in this version

+ type Archive struct

+ func (d *Archive) ProcessMessage(msg *types.Message) ([]*types.Message, types.Response)

+ type ArchiveConfig struct

+ Format string

+ Path string

+ func NewArchiveConfig() ArchiveConfig

+ type Compress struct

+ func (c *Compress) ProcessMessage(msg *types.Message) ([]*types.Message, types.Response)

+ type CompressConfig struct

+ Algorithm string

+ Level int

+ Parts []int

+ func NewCompressConfig() CompressConfig

type Config

+ Archive ArchiveConfig

+ Compress CompressConfig

type Type

+ func NewArchive(conf Config, log log.Modular, stats metrics.Type) (Type, error)

+ func NewCompress(conf Config, log log.Modular, stats metrics.Type) (Type, error)

Feb 8, 2018

Changes in this version

type Config

+ Split struct{}

+ type Split struct

+ func (s *Split) ProcessMessage(msg *types.Message) ([]*types.Message, types.Response)

type Type

+ func NewSplit(conf Config, log log.Modular, stats metrics.Type) (Type, error)

Feb 7, 2018

Changes in this version

type Config

+ Decompress DecompressConfig

+ Unarchive UnarchiveConfig

+ type Decompress struct

+ func (d *Decompress) ProcessMessage(msg *types.Message) (*types.Message, types.Response, bool)

+ type DecompressConfig struct

+ Algorithm string

+ Parts []int

+ func NewDecompressConfig() DecompressConfig

type Type

+ func NewDecompress(conf Config, log log.Modular, stats metrics.Type) (Type, error)

+ func NewUnarchive(conf Config, log log.Modular, stats metrics.Type) (Type, error)

+ type Unarchive struct

+ func (d *Unarchive) ProcessMessage(msg *types.Message) (*types.Message, types.Response, bool)

+ type UnarchiveConfig struct

+ Format string

+ Parts []int

+ func NewUnarchiveConfig() UnarchiveConfig

Feb 1, 2018

Changes in this version

+ var ErrEmptyTargetPath = errors.New("target path is empty")

type Config

+ SetJSON SetJSONConfig

+ type SetJSON struct

+ func (p *SetJSON) ProcessMessage(msg *types.Message) (*types.Message, types.Response, bool)

+ type SetJSONConfig struct

+ Part int

+ Path string

+ Value rawJSONValue

+ func NewSetJSONConfig() SetJSONConfig

type Type

+ func NewSetJSON(conf Config, log log.Modular, stats metrics.Type) (Type, error)

Jan 26, 2018

Changes in this version

type Config

+ InsertPart InsertPartConfig

+ type InsertPart struct

+ func (p *InsertPart) ProcessMessage(msg *types.Message) (*types.Message, types.Response, bool)

+ type InsertPartConfig struct

+ Content string

+ Index int

+ func NewInsertPartConfig() InsertPartConfig

type Type

+ func NewInsertPart(conf Config, log log.Modular, stats metrics.Type) (Type, error)

Jan 16, 2018

Changes in this version

type Config

+ HashSample HashSampleConfig

+ type HashSample struct

+ func (s *HashSample) ProcessMessage(msg *types.Message) (*types.Message, types.Response, bool)

+ type HashSampleConfig struct

+ Parts []int

+ RetainMax float64

+ RetainMin float64

+ func NewHashSampleConfig() HashSampleConfig

type Type

+ func NewHashSample(conf Config, log log.Modular, stats metrics.Type) (Type, error)

Jan 5, 2018

Changes in this version

+ type Noop struct

+ func (c *Noop) ProcessMessage(msg *types.Message) (*types.Message, types.Response, bool)

type Type

+ func NewNoop(conf Config, log log.Modular, stats metrics.Type) (Type, error)

Nov 15, 2017

Changes in this version

type Config

+ SelectParts SelectPartsConfig

+ type SelectParts struct

+ func (m *SelectParts) ProcessMessage(msg *types.Message) (*types.Message, types.Response, bool)

+ type SelectPartsConfig struct

+ Parts []int

+ func NewSelectPartsConfig() SelectPartsConfig

type Type

+ func NewSelectParts(conf Config, log log.Modular, stats metrics.Type) (Type, error)

Nov 8, 2017

Changes in this version

type Config

+ Sample SampleConfig

+ type Sample struct

+ func (s *Sample) ProcessMessage(msg *types.Message) (*types.Message, types.Response, bool)

+ type SampleConfig struct

+ RandomSeed int64

+ Retain float64

+ func NewSampleConfig() SampleConfig

type Type

+ func NewSample(conf Config, log log.Modular, stats metrics.Type) (Type, error)

Oct 17, 2017

Changes in this version

+ type Combine struct

+ func (c *Combine) ProcessMessage(msg *types.Message) (*types.Message, types.Response, bool)

+ type CombineConfig struct

+ Parts int

+ func NewCombineConfig() CombineConfig

type Config

+ Combine CombineConfig

type Type

+ func NewCombine(conf Config, log log.Modular, stats metrics.Type) (Type, error)

Oct 10, 2017

Changes in this version

+ func Descriptions() string

+ type BlobToMulti struct

+ func (m *BlobToMulti) ProcessMessage(msg *types.Message) (*types.Message, bool)

+ type BoundsCheck struct

+ func (m *BoundsCheck) ProcessMessage(msg *types.Message) (*types.Message, bool)

+ type BoundsCheckConfig struct

+ MaxPartSize int

+ MaxParts int

+ MinParts int

+ func NewBoundsCheckConfig() BoundsCheckConfig

+ type Config struct

+ BlobToMulti struct{}

+ BoundsCheck BoundsCheckConfig

+ MultiToBlob struct{}

+ Type string

+ func NewConfig() Config

+ func (m *Config) UnmarshalJSON(bytes []byte) error

+ func (m *Config) UnmarshalYAML(unmarshal func(interface{}) error) error

+ type MultiToBlob struct

+ func (m MultiToBlob) ProcessMessage(msg *types.Message) (*types.Message, bool)

+ type Type interface

+ ProcessMessage func(msg *types.Message) (*types.Message, bool)

+ func New(conf Config, log log.Modular, stats metrics.Type) (Type, error)

+ func NewBlobToMulti(conf Config, log log.Modular, stats metrics.Type) (Type, error)

+ func NewBoundsCheck(conf Config, log log.Modular, stats metrics.Type) (Type, error)

+ func NewMultiToBlob(conf Config, log log.Modular, stats metrics.Type) (Type, error)