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 ¶
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 (*Reconciler) ReconcileEmitFailures ¶
func (r *Reconciler) ReconcileEmitFailures(ctx context.Context) (EmitReconcileResult, error)
ReconcileEmitFailures retries deterministic workflow emits that failed to enqueue
Click to show internal directories.
Click to hide internal directories.