output

Documentation

Index

• Variables
• func Description(async, batches bool, content string) string
• func GetMaxInFlight(o interface{}) (int, bool)

Variables

var InjectTracingSpanMappingDocs = docs.FieldBloblang(
	"inject_tracing_map",
	"EXPERIMENTAL: A [Bloblang mapping](/docs/guides/bloblang/about) used to inject an object containing tracing propagation information into outbound messages. The specification of the injected fields will match the format used by the service wide tracer.",
	`meta = meta().merge(this)`,
	`root.meta.span = this`,
).AtVersion("3.45.0").Advanced()

InjectTracingSpanMappingDocs returns a field spec describing an inject tracing span mapping.

Functions

func Description

func Description(async, batches bool, content string) string

Description appends standard feature descriptions to an output description based on various features of the output.

func GetMaxInFlight

func GetMaxInFlight(o interface{}) (int, bool)

GetMaxInFlight attempts to derive a max in flight value from the provided output, and returns the count and a boolean flag indicating whether the output provided that value. This value can be used to determine a sensible value for parent outputs, but should not be relied upon as part of dispatcher logic.