interop

Documentation

Overview

Package interop provides utilities for initializing Benthos components that default to the old APIs, but when the provided manager supports it the new APIs are used.

TODO: V4 Remove this package

Index

• func GetLabel(mgr types.Manager) string
• func LabelChild(label string, mgr types.Manager, logger log.Modular, stats metrics.Type) (types.Manager, log.Modular, metrics.Type)
• func LabelRoot(label string, mgr types.Manager, logger log.Modular, stats metrics.Type) (types.Manager, log.Modular, metrics.Type)
• func LabelStream(label string, mgr types.Manager, logger log.Modular, stats metrics.Type) (types.Manager, log.Modular, metrics.Type)

Functions

func GetLabel

func GetLabel(mgr types.Manager) string

GetLabel attempts the extract the current label of a component by obtaining it from a manager. If the manager does not support label methods then it instead falls back to a UUID, and somehow failing that returns an empty string.

func LabelChild

func LabelChild(label string, mgr types.Manager, logger log.Modular, stats metrics.Type) (types.Manager, log.Modular, metrics.Type)

LabelChild expands the label of the provided observability components.

func LabelRoot

func LabelRoot(label string, mgr types.Manager, logger log.Modular, stats metrics.Type) (types.Manager, log.Modular, metrics.Type)

LabelRoot replaces the label of the provided observability components.

func LabelStream

func LabelStream(label string, mgr types.Manager, logger log.Modular, stats metrics.Type) (types.Manager, log.Modular, metrics.Type)

LabelStream expands the label of the provided observability components with a stream identifier.