LineAndColOf returns the line and column position of a tailing clip from an input.

NewExecutor initialises a new mapping executor from a map of query functions, and a list of assignments to be executed on each mapping.

NewJSONAssignment creates a new JSON assignment.

NewMetaAssignment creates a new meta assignment.

NewStatement initialises a new mapping statement from an Assignment and query.Function.

NewTargetPath constructs a new target path from a type and zero or more path segments.

NewVarAssignment creates a new variable assignment.

TargetTypes.

TargetTypes.

TargetTypes.

AssignmentContext contains references to all potential assignment destinations of a given mapping.

Executor is a parsed bloblang mapping that can be executed on a Benthos message.

JSONAssignment creates a path within the structured message and assigns it a value.

MetaAssignment assigns a value to a metadata key of a message.

Statement describes an isolated mapping statement, where the result of a query function is to be mapped according to an Assignment.

TargetPath represents a target type and segmented path that a query function references.

VarAssignment creates a variable and assigns it a value.

Assignment represents a way of assigning a queried value to something within an assignment context.

Message is an interface type to be given to a query function, it allows the function to resolve fields and metadata from a message.

TargetType represents a mapping target type, which is a destination for a query result to be mapped into a message.