# Functions
ExecuteAll attempts to execute a slice of processors to a message.
ExecuteCatchAll attempts to execute a slice of processors to only messages that have failed a processing step.
ExecuteTryAll attempts to execute a slice of processors to messages, if a message has failed a processing step it is prevented from being sent to subsequent processors.
MarkErr marks a message part as having failed.
NewAutoObservedBatchProcessor wraps an AutoObservedBatched processor with an implementation of V1 which handles observability information.
NewAutoObservedProcessor wraps an AutoObserved processor with an implementation of V1 which handles observability information.
NewBoundsCheckConfig returns a BoundsCheckConfig with default values.
NewBranchConfig returns a BranchConfig with default values.
NewCacheConfig returns a CacheConfig with default values.
NewCompressConfig returns a CompressConfig with default values.
NewConfig returns a configuration struct fully populated with default values.
NewDecompressConfig returns a DecompressConfig with default values.
NewDedupeConfig returns a DedupeConfig with default values.
NewGrokConfig returns a GrokConfig with default values.
NewGroupByConfig returns a GroupByConfig with default values.
NewGroupByValueConfig returns a GroupByValueConfig with default values.
NewInsertPartConfig returns a InsertPartConfig with default values.
NewJMESPathConfig returns a JMESPathConfig with default values.
NewJQConfig returns a JQConfig with default values.
NewJSONSchemaConfig returns a JSONSchemaConfig with default values.
NewLogConfig returns a LogConfig with default values.
NewMetricConfig returns a MetricConfig with default values.
NewMongoDBConfig returns a MongoDBConfig with default values.
NewParallelConfig returns a default ParallelConfig.
NewParseLogConfig returns a ParseLogConfig with default values.
NewProtobufConfig returns a ProtobufConfig with default values.
NewRateLimitConfig returns a RateLimitConfig with default values.
NewSelectPartsConfig returns a SelectPartsConfig with default values.
NewSleepConfig returns a SleepConfig with default values.
NewSplitConfig returns a SplitConfig with default values.
NewSubprocessConfig returns a SubprocessConfig with default values.
NewSwitchCaseConfig returns a new SwitchCaseConfig with default values.
NewSwitchConfig returns a default SwitchConfig.
NewWhileConfig returns a default WhileConfig.
NewWorkflowConfig returns a default WorkflowConfig.
NewXMLConfig returns a XMLConfig with default values.
TestBatchProcContext creates a context for batch processors.
Unwrap attempts to access a wrapped processor from the provided implementation where applicable, otherwise the provided processor is returned.
# Structs
BatchProcContext provides methods for triggering observability updates and accessing processor specific spans.
BoundsCheckConfig contains configuration fields for the BoundsCheck processor.
BranchConfig contains configuration fields for the Branch processor.
CacheConfig contains configuration fields for the Cache processor.
CompressConfig contains configuration fields for the Compress processor.
Config is the all encompassing configuration struct for all processor types.
DecompressConfig contains configuration fields for the Decompress processor.
DedupeConfig contains configuration fields for the Dedupe processor.
GrokConfig contains configuration fields for the Grok processor.
GroupByElement represents a group determined by a condition and a list of group specific processors.
GroupByValueConfig is a configuration struct containing fields for the GroupByValue processor, which breaks message batches down into N batches of a smaller size according to a function interpolated string evaluated per message part.
InsertPartConfig contains configuration fields for the InsertPart processor.
JMESPathConfig contains configuration fields for the JMESPath processor.
JQConfig contains configuration fields for the JQ processor.
JSONSchemaConfig is a configuration struct containing fields for the jsonschema processor.
LogConfig contains configuration fields for the Log processor.
MetricConfig contains configuration fields for the Metric processor.
MongoDBConfig contains configuration fields for the MongoDB processor.
ParallelConfig is a config struct containing fields for the Parallel processor.
ParseLogConfig contains configuration fields for the ParseLog processor.
ProtobufConfig contains configuration fields for the Protobuf processor.
RateLimitConfig contains configuration fields for the RateLimit processor.
SelectPartsConfig contains configuration fields for the SelectParts processor.
SleepConfig contains configuration fields for the Sleep processor.
SplitConfig is a configuration struct containing fields for the Split processor, which breaks message batches down into batches of a smaller size.
SubprocessConfig contains configuration fields for the Subprocess processor.
SwitchCaseConfig contains a condition, processors and other fields for an individual case in the Switch processor.
WhileConfig is a config struct containing fields for the While processor.
WorkflowConfig is a config struct containing fields for the Workflow processor.
XMLConfig contains configuration fields for the XML processor.
# Interfaces
AutoObserved is a simpler processor interface to implement than V1 as it is not required to emit observability information within the implementation itself.
AutoObservedBatched is a simpler processor interface to implement than V1 as it is not required to emit observability information within the implementation itself.
Pipeline is an interface that implements channel based consumer and producer methods for streaming data through a processing pipeline.
V1 is a common interface implemented by processors.
# Type aliases
GroupByConfig is a configuration struct containing fields for the GroupBy processor, which breaks message batches down into N batches of a smaller size according to conditions.
PipelineConstructorFunc is a constructor to be called for each parallel stream pipeline thread in order to construct a custom pipeline implementation.
SwitchConfig is a config struct containing fields for the Switch processor.