Versions in this module Expand all Collapse all v3 v3.15.4 May 30, 2020 v3.15.2 May 30, 2020 v3.15.1 May 30, 2020 Changes in this version + const TypeAWK + const TypeArchive + const TypeAvro + const TypeBatch + const TypeBloblang + const TypeBoundsCheck + const TypeCache + const TypeCatch + const TypeCompress + const TypeConditional + const TypeDecode + const TypeDecompress + const TypeDedupe + const TypeEncode + const TypeFilter + const TypeFilterParts + const TypeForEach + const TypeGrok + const TypeGroupBy + const TypeGroupByValue + const TypeHTTP + const TypeHash + const TypeHashSample + const TypeInsertPart + const TypeJMESPath + const TypeJSON + const TypeJSONSchema + const TypeLambda + const TypeLog + const TypeMergeJSON + const TypeMetadata + const TypeMetric + const TypeNoop + const TypeNumber + const TypeParallel + const TypeParseLog + const TypeProcessBatch + const TypeProcessDAG + const TypeProcessField + const TypeProcessMap + const TypeRateLimit + const TypeRedis + const TypeResource + const TypeSQL + const TypeSample + const TypeSelectParts + const TypeSleep + const TypeSplit + const TypeSubprocess + const TypeSwitch + const TypeSyncResponse + const TypeText + const TypeThrottle + const TypeTry + const TypeUnarchive + const TypeWhile + const TypeWorkflow + const TypeXML + var Constructors = map[string]TypeSpec + var DocsUsesBatches = ... + var FailFlagKey = types.FailFlagKey + func Block(typeStr, reason string) + func ClearFail(part types.Part) + func Descriptions() string + func DocumentPlugin(typeString, description string, configSanitiser PluginConfigSanitiser) + func ExecuteAll(procs []types.Processor, msgs ...types.Message) ([]types.Message, types.Response) + func ExecuteCatchAll(procs []types.Processor, msgs ...types.Message) ([]types.Message, types.Response) + func ExecuteTryAll(procs []types.Processor, msgs ...types.Message) ([]types.Message, types.Response) + func FlagErr(part types.Part, err error) + func FlagFail(part types.Part) + func HasFailed(part types.Part) bool + func IteratePartsWithSpan(operationName string, parts []int, msg types.Message, ...) + func PluginCount() int + func PluginDescriptions() string + func RegisterPlugin(typeString string, configConstructor PluginConfigConstructor, ...) + func SanitiseConfig(conf Config) (interface{}, error) + type AWK struct + func (a *AWK) CloseAsync() + func (a *AWK) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (a *AWK) WaitForClose(timeout time.Duration) error + type AWKConfig struct + Codec string + Parts []int + Program string + func NewAWKConfig() AWKConfig + type Archive struct + func (d *Archive) CloseAsync() + func (d *Archive) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (d *Archive) WaitForClose(timeout time.Duration) error + type ArchiveConfig struct + Format string + Path string + func NewArchiveConfig() ArchiveConfig + type Avro struct + func (p *Avro) CloseAsync() + func (p *Avro) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (p *Avro) WaitForClose(timeout time.Duration) error + type AvroConfig struct + Encoding string + Operator string + Parts []int + Schema string + SchemaPath string + func NewAvroConfig() AvroConfig + type Batch struct + func (b *Batch) CloseAsync() + func (b *Batch) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (b *Batch) WaitForClose(timeout time.Duration) error + type BatchConfig struct + ByteSize int + Condition condition.Config + Count int + Period string + func NewBatchConfig() BatchConfig + type Bloblang struct + func (b *Bloblang) CloseAsync() + func (b *Bloblang) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (b *Bloblang) WaitForClose(timeout time.Duration) error + type BloblangConfig string + func NewBloblangConfig() BloblangConfig + type BoundsCheck struct + func (m *BoundsCheck) CloseAsync() + func (m *BoundsCheck) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (m *BoundsCheck) WaitForClose(timeout time.Duration) error + type BoundsCheckConfig struct + MaxPartSize int + MaxParts int + MinPartSize int + MinParts int + func NewBoundsCheckConfig() BoundsCheckConfig + type Cache struct + func (c *Cache) CloseAsync() + func (c *Cache) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (c *Cache) WaitForClose(timeout time.Duration) error + type CacheConfig struct + Cache string + Key string + Operator string + Parts []int + Value string + func NewCacheConfig() CacheConfig + type Catch struct + func (p *Catch) CloseAsync() + func (p *Catch) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (p *Catch) WaitForClose(timeout time.Duration) error + type CatchConfig []Config + func NewCatchConfig() CatchConfig + type Compress struct + func (c *Compress) CloseAsync() + func (c *Compress) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (c *Compress) WaitForClose(timeout time.Duration) error + type CompressConfig struct + Algorithm string + Level int + Parts []int + func NewCompressConfig() CompressConfig + type Conditional struct + func (c *Conditional) CloseAsync() + func (c *Conditional) ProcessMessage(msg types.Message) (msgs []types.Message, res types.Response) + func (c *Conditional) WaitForClose(timeout time.Duration) error + type ConditionalConfig struct + Condition condition.Config + ElseProcessors []Config + Processors []Config + func NewConditionalConfig() ConditionalConfig + type Config struct + AWK AWKConfig + Archive ArchiveConfig + Avro AvroConfig + Batch BatchConfig + Bloblang BloblangConfig + BoundsCheck BoundsCheckConfig + Cache CacheConfig + Catch CatchConfig + Compress CompressConfig + Conditional ConditionalConfig + Decode DecodeConfig + Decompress DecompressConfig + Dedupe DedupeConfig + Encode EncodeConfig + Filter FilterConfig + FilterParts FilterPartsConfig + ForEach ForEachConfig + Grok GrokConfig + GroupBy GroupByConfig + GroupByValue GroupByValueConfig + HTTP HTTPConfig + Hash HashConfig + HashSample HashSampleConfig + InsertPart InsertPartConfig + JMESPath JMESPathConfig + JSON JSONConfig + JSONSchema JSONSchemaConfig + Lambda LambdaConfig + Log LogConfig + MergeJSON MergeJSONConfig + Metadata MetadataConfig + Metric MetricConfig + Number NumberConfig + Parallel ParallelConfig + ParseLog ParseLogConfig + Plugin interface{} + ProcessBatch ForEachConfig + ProcessDAG ProcessDAGConfig + ProcessField ProcessFieldConfig + ProcessMap ProcessMapConfig + RateLimit RateLimitConfig + Redis RedisConfig + Resource string + SQL SQLConfig + Sample SampleConfig + SelectParts SelectPartsConfig + Sleep SleepConfig + Split SplitConfig + Subprocess SubprocessConfig + Switch SwitchConfig + SyncResponse SyncResponseConfig + Text TextConfig + Throttle ThrottleConfig + Try TryConfig + Type string + Unarchive UnarchiveConfig + While WhileConfig + Workflow WorkflowConfig + XML XMLConfig + func NewConfig() Config + func (m *Config) UnmarshalYAML(value *yaml.Node) error + type DAGDepsConfig struct + Dependencies []string + func NewDAGDepsConfig() DAGDepsConfig + func (p *DAGDepsConfig) UnmarshalJSON(bytes []byte) error + func (p *DAGDepsConfig) UnmarshalYAML(unmarshal func(interface{}) error) error + type Decode struct + func (c *Decode) CloseAsync() + func (c *Decode) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (c *Decode) WaitForClose(timeout time.Duration) error + type DecodeConfig struct + Parts []int + Scheme string + func NewDecodeConfig() DecodeConfig + type Decompress struct + func (d *Decompress) CloseAsync() + func (d *Decompress) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (d *Decompress) WaitForClose(timeout time.Duration) error + type DecompressConfig struct + Algorithm string + Parts []int + func NewDecompressConfig() DecompressConfig + type Dedupe struct + func (d *Dedupe) CloseAsync() + func (d *Dedupe) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (d *Dedupe) WaitForClose(timeout time.Duration) error + type DedupeConfig struct + Cache string + DropOnCacheErr bool + HashType string + Key string + Parts []int + func NewDedupeConfig() DedupeConfig + type DepProcessMapConfig struct + func NewDepProcessMapConfig() DepProcessMapConfig + type Encode struct + func (c *Encode) CloseAsync() + func (c *Encode) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (c *Encode) WaitForClose(timeout time.Duration) error + type EncodeConfig struct + Parts []int + Scheme string + func NewEncodeConfig() EncodeConfig + type Filter struct + func (c *Filter) CloseAsync() + func (c *Filter) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (c *Filter) WaitForClose(timeout time.Duration) error + type FilterConfig struct + func NewFilterConfig() FilterConfig + func (f FilterConfig) MarshalYAML() (interface{}, error) + type FilterParts struct + func (c *FilterParts) CloseAsync() + func (c *FilterParts) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (c *FilterParts) WaitForClose(timeout time.Duration) error + type FilterPartsConfig struct + func NewFilterPartsConfig() FilterPartsConfig + func (f FilterPartsConfig) MarshalYAML() (interface{}, error) + type ForEach struct + func (p *ForEach) CloseAsync() + func (p *ForEach) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (p *ForEach) WaitForClose(timeout time.Duration) error + type ForEachConfig []Config + func NewForEachConfig() ForEachConfig + type Grok struct + func (g *Grok) CloseAsync() + func (g *Grok) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (g *Grok) WaitForClose(timeout time.Duration) error + type GrokConfig struct + NamedOnly bool + Parts []int + PatternDefinitions map[string]string + Patterns []string + RemoveEmpty bool + To string + UseDefaults bool + func NewGrokConfig() GrokConfig + type GroupBy struct + func (g *GroupBy) CloseAsync() + func (g *GroupBy) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (g *GroupBy) WaitForClose(timeout time.Duration) error + type GroupByConfig []GroupByElement + func NewGroupByConfig() GroupByConfig + type GroupByElement struct + Condition condition.Config + Processors []Config + type GroupByValue struct + func (g *GroupByValue) CloseAsync() + func (g *GroupByValue) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (g *GroupByValue) WaitForClose(timeout time.Duration) error + type GroupByValueConfig struct + Value string + func NewGroupByValueConfig() GroupByValueConfig + type HTTP struct + func (h *HTTP) CloseAsync() + func (h *HTTP) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (h *HTTP) WaitForClose(timeout time.Duration) error + type HTTPConfig struct + Client client.Config + MaxParallel int + Parallel bool + func NewHTTPConfig() HTTPConfig + type Hash struct + func (c *Hash) CloseAsync() + func (c *Hash) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (c *Hash) WaitForClose(timeout time.Duration) error + type HashConfig struct + Algorithm string + Key string + Parts []int + func NewHashConfig() HashConfig + type HashSample struct + func (s *HashSample) CloseAsync() + func (s *HashSample) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (s *HashSample) WaitForClose(timeout time.Duration) error + type HashSampleConfig struct + Parts []int + RetainMax float64 + RetainMin float64 + func NewHashSampleConfig() HashSampleConfig + type InsertPart struct + func (p *InsertPart) CloseAsync() + func (p *InsertPart) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (p *InsertPart) WaitForClose(timeout time.Duration) error + type InsertPartConfig struct + Content string + Index int + func NewInsertPartConfig() InsertPartConfig + type JMESPath struct + func (p *JMESPath) CloseAsync() + func (p *JMESPath) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (p *JMESPath) WaitForClose(timeout time.Duration) error + type JMESPathConfig struct + Parts []int + Query string + func NewJMESPathConfig() JMESPathConfig + type JSON struct + func (p *JSON) CloseAsync() + func (p *JSON) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (p *JSON) WaitForClose(timeout time.Duration) error + type JSONConfig struct + Operator string + Parts []int + Path string + Value rawJSONValue + func NewJSONConfig() JSONConfig + type JSONSchema struct + func (s *JSONSchema) CloseAsync() + func (s *JSONSchema) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (s *JSONSchema) WaitForClose(timeout time.Duration) error + type JSONSchemaConfig struct + Parts []int + Schema string + SchemaPath string + func NewJSONSchemaConfig() JSONSchemaConfig + type Lambda struct + func (l *Lambda) CloseAsync() + func (l *Lambda) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (l *Lambda) WaitForClose(timeout time.Duration) error + type LambdaConfig struct + Parallel bool + func NewLambdaConfig() LambdaConfig + type Log struct + func (l *Log) CloseAsync() + func (l *Log) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (l *Log) WaitForClose(timeout time.Duration) error + type LogConfig struct + Fields map[string]string + Level string + Message string + func NewLogConfig() LogConfig + type MergeJSON struct + func (p *MergeJSON) CloseAsync() + func (p *MergeJSON) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (p *MergeJSON) WaitForClose(timeout time.Duration) error + type MergeJSONConfig struct + Parts []int + RetainParts bool + func NewMergeJSONConfig() MergeJSONConfig + type Metadata struct + func (p *Metadata) CloseAsync() + func (p *Metadata) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (p *Metadata) WaitForClose(timeout time.Duration) error + type MetadataConfig struct + Key string + Operator string + Parts []int + Value string + func NewMetadataConfig() MetadataConfig + type Metric struct + func (m *Metric) CloseAsync() + func (m *Metric) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (m *Metric) WaitForClose(timeout time.Duration) error + type MetricConfig struct + Labels map[string]string + Path string + Type string + Value string + func NewMetricConfig() MetricConfig + type Noop struct + func (c *Noop) CloseAsync() + func (c *Noop) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (c *Noop) WaitForClose(timeout time.Duration) error + type Number struct + func (n *Number) CloseAsync() + func (n *Number) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (n *Number) WaitForClose(timeout time.Duration) error + type NumberConfig struct + Operator string + Parts []int + Value interface{} + func NewNumberConfig() NumberConfig + type Parallel struct + func (p *Parallel) CloseAsync() + func (p *Parallel) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (p *Parallel) WaitForClose(timeout time.Duration) error + type ParallelConfig struct + Cap int + Processors []Config + func NewParallelConfig() ParallelConfig + type ParseLog struct + func (s *ParseLog) CloseAsync() + func (s *ParseLog) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (s *ParseLog) WaitForClose(timeout time.Duration) error + type ParseLogConfig struct + BestEffort bool + Codec string + Format string + Parts []int + WithRFC3339 bool + WithTimezone string + WithYear string + func NewParseLogConfig() ParseLogConfig + type PluginConfigConstructor func() interface + type PluginConfigSanitiser func(conf interface{}) interface + type PluginConstructor func(config interface{}, manager types.Manager, logger log.Modular, ...) (types.Processor, error) + type ProcessDAG struct + func (p *ProcessDAG) CloseAsync() + func (p *ProcessDAG) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (p *ProcessDAG) WaitForClose(timeout time.Duration) error + type ProcessDAGConfig map[string]DepProcessMapConfig + func NewProcessDAGConfig() ProcessDAGConfig + type ProcessField struct + func (p *ProcessField) CloseAsync() + func (p *ProcessField) ProcessMessage(msg types.Message) (msgs []types.Message, res types.Response) + func (p *ProcessField) WaitForClose(timeout time.Duration) error + type ProcessFieldConfig struct + Codec string + Parts []int + Path string + Processors []Config + ResultType string + func NewProcessFieldConfig() ProcessFieldConfig + type ProcessMap struct + func NewProcessMap(conf ProcessMapConfig, mgr types.Manager, log log.Modular, stats metrics.Type) (*ProcessMap, error) + func (p *ProcessMap) CloseAsync() + func (p *ProcessMap) CreateResult(msg types.Message) error + func (p *ProcessMap) OverlayResult(payload, response types.Message) ([]int, error) + func (p *ProcessMap) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (p *ProcessMap) TargetsProvided() []string + func (p *ProcessMap) TargetsUsed() []string + func (p *ProcessMap) WaitForClose(timeout time.Duration) error + type ProcessMapConfig struct + Conditions []condition.Config + Parts []int + Postmap map[string]string + PostmapOptional map[string]string + Premap map[string]string + PremapOptional map[string]string + Processors []Config + func NewProcessMapConfig() ProcessMapConfig + func (p *ProcessMapConfig) UnmarshalJSON(bytes []byte) error + func (p *ProcessMapConfig) UnmarshalYAML(unmarshal func(interface{}) error) error + func (p ProcessMapConfig) Sanitise() (map[string]interface{}, error) + type RateLimit struct + func (r *RateLimit) CloseAsync() + func (r *RateLimit) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (r *RateLimit) WaitForClose(timeout time.Duration) error + type RateLimitConfig struct + Resource string + func NewRateLimitConfig() RateLimitConfig + type Redis struct + func (r *Redis) CloseAsync() + func (r *Redis) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (r *Redis) WaitForClose(timeout time.Duration) error + type RedisConfig struct + Key string + Operator string + Parts []int + Retries int + RetryPeriod string + URL string + func NewRedisConfig() RedisConfig + type Resource struct + func (r *Resource) CloseAsync() + func (r *Resource) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (r *Resource) WaitForClose(timeout time.Duration) error + type SQL struct + func (s *SQL) CloseAsync() + func (s *SQL) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (s *SQL) WaitForClose(timeout time.Duration) error + type SQLConfig struct + Args []string + DSN string + Driver string + Query string + ResultCodec string + func NewSQLConfig() SQLConfig + type Sample struct + func (s *Sample) CloseAsync() + func (s *Sample) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (s *Sample) WaitForClose(timeout time.Duration) error + type SampleConfig struct + RandomSeed int64 + Retain float64 + func NewSampleConfig() SampleConfig + type SelectParts struct + func (m *SelectParts) CloseAsync() + func (m *SelectParts) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (m *SelectParts) WaitForClose(timeout time.Duration) error + type SelectPartsConfig struct + Parts []int + func NewSelectPartsConfig() SelectPartsConfig + type Sleep struct + func (s *Sleep) CloseAsync() + func (s *Sleep) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (s *Sleep) WaitForClose(timeout time.Duration) error + type SleepConfig struct + Duration string + func NewSleepConfig() SleepConfig + type Split struct + func (s *Split) CloseAsync() + func (s *Split) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (s *Split) WaitForClose(timeout time.Duration) error + type SplitConfig struct + ByteSize int + Size int + func NewSplitConfig() SplitConfig + type Subprocess struct + func (e *Subprocess) CloseAsync() + func (e *Subprocess) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (e *Subprocess) WaitForClose(timeout time.Duration) error + type SubprocessConfig struct + Args []string + MaxBuffer int + Name string + Parts []int + func NewSubprocessConfig() SubprocessConfig + type Switch struct + func (s *Switch) CloseAsync() + func (s *Switch) ProcessMessage(msg types.Message) (msgs []types.Message, res types.Response) + func (s *Switch) WaitForClose(timeout time.Duration) error + type SwitchCaseConfig struct + Condition condition.Config + Fallthrough bool + Processors []Config + func NewSwitchCaseConfig() SwitchCaseConfig + func (s *SwitchCaseConfig) UnmarshalJSON(bytes []byte) error + func (s *SwitchCaseConfig) UnmarshalYAML(unmarshal func(interface{}) error) error + type SwitchConfig []SwitchCaseConfig + func NewSwitchConfig() SwitchConfig + type SyncResponse struct + func (s *SyncResponse) CloseAsync() + func (s *SyncResponse) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (s *SyncResponse) WaitForClose(timeout time.Duration) error + type SyncResponseConfig struct + func NewSyncResponseConfig() SyncResponseConfig + type Text struct + func (t *Text) CloseAsync() + func (t *Text) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (t *Text) WaitForClose(timeout time.Duration) error + type TextConfig struct + Arg string + Operator string + Parts []int + Value string + func NewTextConfig() TextConfig + type Throttle struct + func (m *Throttle) CloseAsync() + func (m *Throttle) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (m *Throttle) WaitForClose(timeout time.Duration) error + type ThrottleConfig struct + Period string + func NewThrottleConfig() ThrottleConfig + type Try struct + func (p *Try) CloseAsync() + func (p *Try) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (p *Try) WaitForClose(timeout time.Duration) error + type TryConfig []Config + func NewTryConfig() TryConfig + type Type interface + ProcessMessage func(msg types.Message) ([]types.Message, types.Response) + func New(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewAWK(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewArchive(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewAvro(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewBatch(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewBloblang(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewBoundsCheck(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewCache(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewCatch(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewCompress(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 NewDecode(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewDecompress(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewDedupe(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) + func NewFilter(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewFilterParts(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewForEach(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewGrok(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewGroupBy(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewGroupByValue(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewHTTP(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewHash(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewHashSample(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewInsertPart(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewJMESPath(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewJSON(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewJSONSchema(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewLambda(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewLog(conf Config, mgr types.Manager, logger log.Modular, stats metrics.Type) (Type, error) + func NewMergeJSON(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewMetadata(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewMetric(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewNoop(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewNumber(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewParallel(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewParseLog(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewProcessBatch(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewProcessDAG(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewProcessField(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewRateLimit(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewRedis(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewResource(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewSQL(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewSample(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewSelectParts(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewSleep(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewSplit(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewSubprocess(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewSwitch(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewSyncResponse(conf Config, mgr types.Manager, logger log.Modular, stats metrics.Type) (Type, error) + func NewText(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewThrottle(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewTry(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewUnarchive(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewWhile(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewWorkflow(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + func NewXML(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (Type, error) + type TypeSpec struct + Deprecated bool + Description string + FieldSpecs docs.FieldSpecs + Footnotes string + Summary string + UsesBatches bool + type Unarchive struct + func (d *Unarchive) CloseAsync() + func (d *Unarchive) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (d *Unarchive) WaitForClose(timeout time.Duration) error + type UnarchiveConfig struct + Format string + Parts []int + func NewUnarchiveConfig() UnarchiveConfig + type While struct + func (w *While) CloseAsync() + func (w *While) ProcessMessage(msg types.Message) (msgs []types.Message, res types.Response) + func (w *While) WaitForClose(timeout time.Duration) error + type WhileConfig struct + AtLeastOnce bool + Condition condition.Config + MaxLoops int + Processors []Config + func NewWhileConfig() WhileConfig + type Workflow struct + func (w *Workflow) CloseAsync() + func (w *Workflow) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (w *Workflow) WaitForClose(timeout time.Duration) error + type WorkflowConfig struct + MetaPath string + Stages map[string]DepProcessMapConfig + func NewWorkflowConfig() WorkflowConfig + type XML struct + func (p *XML) CloseAsync() + func (p *XML) ProcessMessage(msg types.Message) ([]types.Message, types.Response) + func (p *XML) WaitForClose(timeout time.Duration) error + type XMLConfig struct + Operator string + Parts []int + func NewXMLConfig() XMLConfig Other modules containing this package github.com/windhooked/benthos