reconciler

package
v1.11.21 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 11, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Package reconciler provides workflow reconciliation helpers.

Index

Constants

This section is empty.

Variables

View Source
var (
	// ErrEmitFailureMissingPayload indicates emit failure details are incomplete
	ErrEmitFailureMissingPayload = errors.New("emit failure missing topic or payload")
)

Functions

This section is empty.

Types

type EmitReconcileResult

type EmitReconcileResult struct {
	// Attempted is the count of retry attempts
	Attempted int
	// Recovered is the count of recovered emit failures
	Recovered int
	// Failed is the count of emit failures that remain retryable
	Failed int
	// Terminal is the count of emit failures marked terminal
	Terminal int
	// Skipped is the count of events skipped during reconciliation
	Skipped int
}

EmitReconcileResult summarizes a reconciliation pass over emit failures

type Option

type Option func(*Reconciler)

Option configures a Reconciler

func WithMaxAttempts

func WithMaxAttempts(maxRetries int) Option

WithMaxAttempts overrides the default max retry attempts

type Reconciler

type Reconciler struct {
	// contains filtered or unexported fields
}

Reconciler re-emits workflow events that failed to enqueue

func New

func New(client *generated.Client, runtime *gala.Gala, opts ...Option) (*Reconciler, error)

New constructs a workflow reconciler

func (*Reconciler) ReconcileEmitFailures

func (r *Reconciler) ReconcileEmitFailures(ctx context.Context) (EmitReconcileResult, error)

ReconcileEmitFailures retries deterministic workflow emits that failed to enqueue

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL