providerretry

package
v1.2.0 Latest Latest
Warning

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

Go to latest
Published: Aug 23, 2026 License: AGPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type RecoveryResult

type RecoveryResult struct {
	Applied            bool      `json:"applied"`
	Key                string    `json:"key"`
	EntityID           string    `json:"entity_id"`
	ScaleSetID         uint      `json:"scale_set_id"`
	ErrorClass         string    `json:"error_class"`
	ExpectedUpdatedAt  time.Time `json:"expected_updated_at"`
	PreviousGeneration uint64    `json:"previous_generation"`
	Generation         uint64    `json:"generation"`
	RecoveredAt        time.Time `json:"recovered_at"`
}

func RecoverTerminal

func RecoverTerminal(ctx context.Context, journalPath, lockPath, key, entityID string, scaleSetID uint, errorClass string, expectedUpdatedAt time.Time, apply bool) (RecoveryResult, error)

type Snapshot

type Snapshot struct {
	Generation                uint64         `json:"generation"`
	Records                   int            `json:"records"`
	DeferredRecords           int            `json:"deferred_records"`
	TerminalCircuits          int            `json:"terminal_circuits"`
	ByErrorClass              map[string]int `json:"by_error_class"`
	DeferredByErrorClass      map[string]int `json:"deferred_by_error_class"`
	OldestTerminalAgeSeconds  int64          `json:"oldest_terminal_age_seconds"`
	NextRetryDelaySeconds     int64          `json:"next_retry_delay_seconds"`
	SharedCapacitySaturated   bool           `json:"shared_capacity_saturated"`
	SharedCapacityProbeOwned  bool           `json:"shared_capacity_probe_owned"`
	SharedCapacityProbeActive bool           `json:"shared_capacity_probe_active"`
	SharedCapacityWaiters     int            `json:"shared_capacity_waiters"`
	SharedCapacityAgeSeconds  int64          `json:"shared_capacity_age_seconds"`
	SharedCapacityWakeReason  string         `json:"shared_capacity_wake_reason,omitempty"`
}

Snapshot is the bounded, identity-free operational view of the durable provider-create retry journal. Dynamic tenant, scale-set, job and runner identities deliberately stay out of metrics.

func Inspect

func Inspect(path string, now time.Time) (Snapshot, error)

Inspect returns a read-only summary. A terminal domain is counted once even when concrete per-instance attempts remain, because only the domain record can block an entire scale set.

Jump to

Keyboard shortcuts

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