supervisor

package
v0.60.3 Latest Latest
Warning

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

Go to latest
Published: Aug 11, 2026 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ActionBackoff     = "backoff"
	ActionDeferred    = "deferred"
	ActionDetached    = "detached"
	ActionEnsured     = "ensured"
	ActionStartFailed = "start_failed"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Adapter

type Adapter interface {
	Probe(ctx context.Context, target string) error
}

type Reconciler

type Reconciler struct {
	Wake                WakeRunner
	Adapter             Adapter
	Now                 func() time.Time
	BackoffBase         time.Duration
	BackoffMax          time.Duration
	Jitter              func(time.Duration) time.Duration
	InjectVia           string
	WakeTimeout         time.Duration
	ActiveCheckInterval time.Duration
	DetachedBackoffBase time.Duration
	DetachedBackoffMax  time.Duration
}

func (Reconciler) Reconcile

func (r Reconciler) Reconcile(ctx context.Context, entry registry.Entry) (registry.Entry, Result)

func (Reconciler) StartFresh

func (r Reconciler) StartFresh(ctx context.Context, entry registry.Entry) (registry.Entry, Result)

type Result

type Result struct {
	Action     string
	AMQTouched bool
	Error      error
}

type WakeRunner

type WakeRunner interface {
	StartWake(ctx context.Context, req amq.StartWakeRequest) error
}

Jump to

Keyboard shortcuts

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