Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PlannerStats ¶
type PlannerStats struct {
ID string `json:"id"`
Schedule string `json:"schedule"`
State string `json:"state"`
Progress float64 `json:"progress"`
StartedAt time.Time `json:"started_at"`
ExecutionTime time.Duration `json:"execution_time"`
Cooldown time.Duration `json:"cooldown"`
Retries uint `json:"retries"`
Labels labels.Set `json:"labels"`
Error string `json:"error"`
}
type PlannerStatsOptions ¶
type PubsubMessage ¶
type PubsubMessage struct {
From string `json:"from"`
Topic string `json:"topic"`
Kind string `json:"kind"`
Payload any `json:"payload"`
}
PubsubMessage represents an event delivered through a subscription channel.
type SupervisorInitPolicy ¶ added in v0.6.9
SupervisorInitPolicy shapes how a service's init turn retries: MaxRetries bounds the attempts (0 one pass, -1 until ctx cancels), Delay is the backoff base, doubling up to MaxDelay.
type SupervisorMonitorPolicy ¶ added in v0.6.9
type SupervisorMonitorPolicy struct {
Interval time.Duration
MaxRetries int
RestartDelay time.Duration
}
SupervisorMonitorPolicy shapes the health monitor: Interval is the sweep cadence (0 disables monitoring), MaxRetries bounds in-process restarts per service (0 none - a liveness failure escalates immediately, -1 unlimited), RestartDelay pauses before each restart attempt.
type SupervisorStats ¶ added in v0.4.0
type SupervisorStats struct {
Name string
Initialized bool
InitializedAt time.Time
InitializationErr error
Started bool
StartedAt time.Time
StartErr error
Stopped bool
StoppedAt time.Time
StopErr error
HealthcheckedAt time.Time
HealthcheckErr error
LivenessErr error
Ready bool
ReadinessErr error
Restarts int
RestartedAt time.Time
InitDuration time.Duration
StartDuration time.Duration
StopDuration time.Duration
Source common.Service
}
func (*SupervisorStats) Healthcheck ¶ added in v0.4.0
func (s *SupervisorStats) Healthcheck() error
func (*SupervisorStats) Uptime ¶ added in v0.4.0
func (s *SupervisorStats) Uptime() time.Duration
type SupervisorStopPolicy ¶ added in v0.6.9
SupervisorStopPolicy shapes how a shutdown ends: Timeout bounds the whole stop, 0 waits indefinitely.