strict

func NewRetryFeedbackPipelineCtor ¶ added in v1.6.0

func NewRetryFeedbackPipelineCtor() func(conf pipeline.Config, mgr bundle.NewManagement) (processor.Pipeline, error)

NewRetryFeedbackPipelineCtor wraps a processing pipeline with a FeedbackProcessor, where failed transactions will be re-routed back into a Bento pipeline (and therefore re-processed).

func OptSetRetryModeFromManager ¶ added in v1.6.0

func OptSetRetryModeFromManager() []manager.OptFunc

OptSetRetryModeFromManager returns a set of options that re-configure a manager to automatically retry failed/errored messages. It applies retryable configurations to all plugins within the bundle.Environment, affecting both components and resources, in addition to functions and methods of the bloblang.Environment. This ensures the manager operates in a mode suitable for retrying errored messages.

func OptSetStrictModeFromManager ¶ added in v1.6.0

func OptSetStrictModeFromManager() []manager.OptFunc

OptSetStrictModeFromManager returns a set of options that re-configure a manager to automatically reject failed/errored messages. It applies strict rejection configurations to all plugins within the bundle.Environment, affecting both components and resources, in addition to functions and methods of the bloblang.Environment. This ensures the manager operates in a mode suitable for rejecting all errored messages.

func RetryBundle ¶ added in v1.6.0

func RetryBundle(b *bundle.Environment) *bundle.Environment

RetryBundle wraps input.processors and output.processors pipeline constructors with FeedbackProcessors for re-routing failed transactions back into a pipeline for retrying.

func StrictBloblangEnvironment ¶ added in v1.6.0

func StrictBloblangEnvironment(nm bundle.NewManagement) *bloblang.Environment

func StrictBundle ¶

func StrictBundle(b *bundle.Environment) *bundle.Environment

StrictBundle modifies a provided bundle environment so that all procesors will fail an entire batch if any any message-level error is encountered. These failed batches are nacked and/or reprocessed depending on your input.