Versions in this module Expand all Collapse all v4 v4.22.0 Oct 23, 2023 Changes in this version + func ExecuteAll(ctx context.Context, procs []V1, msgs ...message.Batch) ([]message.Batch, error) + func ExecuteCatchAll(ctx context.Context, procs []V1, msgs ...message.Batch) ([]message.Batch, error) + func ExecuteTryAll(ctx context.Context, procs []V1, msgs ...message.Batch) ([]message.Batch, error) + func MarkErr(part *message.Part, span *tracing.Span, err error) + type AutoObserved interface + Close func(ctx context.Context) error + Process func(ctx context.Context, p *message.Part) ([]*message.Part, error) + type AutoObservedBatched interface + Close func(ctx context.Context) error + ProcessBatch func(ctx *BatchProcContext, b message.Batch) ([]message.Batch, error) + type BatchProcContext struct + func TestBatchProcContext(ctx context.Context, spans []*tracing.Span, parts []*message.Part) *BatchProcContext + func (b *BatchProcContext) Context() context.Context + func (b *BatchProcContext) OnError(err error, index int, p *message.Part) + func (b *BatchProcContext) Span(index int) *tracing.Span + type BoundsCheckConfig struct + MaxPartSize int + MaxParts int + MinPartSize int + MinParts int + func NewBoundsCheckConfig() BoundsCheckConfig + type BranchConfig struct + Processors []Config + RequestMap string + ResultMap string + func NewBranchConfig() BranchConfig + type CacheConfig struct + Key string + Operator string + Resource string + TTL string + Value string + func NewCacheConfig() CacheConfig + type CompressConfig struct + Algorithm string + Level int + func NewCompressConfig() CompressConfig + type Config struct + Bloblang string + BoundsCheck BoundsCheckConfig + Branch BranchConfig + Cache CacheConfig + Catch []Config + Compress CompressConfig + Decompress DecompressConfig + Dedupe DedupeConfig + ForEach []Config + Grok GrokConfig + GroupBy GroupByConfig + GroupByValue GroupByValueConfig + InsertPart InsertPartConfig + JMESPath JMESPathConfig + JQ JQConfig + JSONSchema JSONSchemaConfig + Label string + Log LogConfig + Metric MetricConfig + Noop struct{} + Parallel ParallelConfig + ParseLog ParseLogConfig + Plugin any + RateLimit RateLimitConfig + Resource string + SelectParts SelectPartsConfig + Sleep SleepConfig + Split SplitConfig + Subprocess SubprocessConfig + Switch SwitchConfig + SyncResponse struct{} + Try []Config + Type string + While WhileConfig + Workflow WorkflowConfig + XML XMLConfig + func NewConfig() Config + func (conf *Config) UnmarshalYAML(value *yaml.Node) error + type DecompressConfig struct + Algorithm string + func NewDecompressConfig() DecompressConfig + type DedupeConfig struct + Cache string + DropOnCacheErr bool + Key string + func NewDedupeConfig() DedupeConfig + type GrokConfig struct + Expressions []string + NamedOnly bool + PatternDefinitions map[string]string + PatternPaths []string + RemoveEmpty bool + UseDefaults bool + func NewGrokConfig() GrokConfig + type GroupByConfig []GroupByElement + func NewGroupByConfig() GroupByConfig + type GroupByElement struct + Check string + Processors []Config + type GroupByValueConfig struct + Value string + func NewGroupByValueConfig() GroupByValueConfig + type InsertPartConfig struct + Content string + Index int + func NewInsertPartConfig() InsertPartConfig + type JMESPathConfig struct + Query string + func NewJMESPathConfig() JMESPathConfig + type JQConfig struct + OutputRaw bool + Query string + Raw bool + func NewJQConfig() JQConfig + type JSONSchemaConfig struct + Schema string + SchemaPath string + func NewJSONSchemaConfig() JSONSchemaConfig + type LogConfig struct + Fields map[string]string + FieldsMapping string + Level string + Message string + func NewLogConfig() LogConfig + type MetricConfig struct + Labels map[string]string + Name string + Type string + Value string + func NewMetricConfig() MetricConfig + type ParallelConfig struct + Cap int + Processors []Config + func NewParallelConfig() ParallelConfig + type ParseLogConfig struct + BestEffort bool + Codec string + Format string + WithRFC3339 bool + WithTimezone string + WithYear string + func NewParseLogConfig() ParseLogConfig + type Pipeline interface + Consume func(<-chan message.Transaction) error + TransactionChan func() <-chan message.Transaction + TriggerCloseNow func() + WaitForClose func(ctx context.Context) error + type PipelineConstructorFunc func() (Pipeline, error) + type RateLimitConfig struct + Resource string + func NewRateLimitConfig() RateLimitConfig + type SelectPartsConfig struct + Parts []int + func NewSelectPartsConfig() SelectPartsConfig + type SleepConfig struct + Duration string + func NewSleepConfig() SleepConfig + type SplitConfig struct + ByteSize int + Size int + func NewSplitConfig() SplitConfig + type SubprocessConfig struct + Args []string + CodecRecv string + CodecSend string + MaxBuffer int + Name string + func NewSubprocessConfig() SubprocessConfig + type SwitchCaseConfig struct + Check string + Fallthrough bool + Processors []Config + func NewSwitchCaseConfig() SwitchCaseConfig + func (s *SwitchCaseConfig) UnmarshalJSON(bytes []byte) error + func (s *SwitchCaseConfig) UnmarshalYAML(unmarshal func(any) error) error + type SwitchConfig []SwitchCaseConfig + func NewSwitchConfig() SwitchConfig + type V1 interface + Close func(ctx context.Context) error + ProcessBatch func(ctx context.Context, b message.Batch) ([]message.Batch, error) + func NewAutoObservedBatchedProcessor(typeStr string, p AutoObservedBatched, mgr component.Observability) V1 + func NewAutoObservedProcessor(typeStr string, p AutoObserved, mgr component.Observability) V1 + func Unwrap(p V1) V1 + type WhileConfig struct + AtLeastOnce bool + Check string + MaxLoops int + Processors []Config + func NewWhileConfig() WhileConfig + type WorkflowConfig struct + BranchResources []string + Branches map[string]BranchConfig + MetaPath string + Order [][]string + func NewWorkflowConfig() WorkflowConfig + type XMLConfig struct + Cast bool + Operator string + func NewXMLConfig() XMLConfig
Go to main page