heartbeat

type Actor struct {
	ID          string        // unique heartbeat identifier
	Interval    time.Duration // expected interval between pings
	Description string        // human‐friendly description of this heartbeat
	Grace       time.Duration // grace period before triggering an alert
	Receivers   []string      // list of receiver IDs to notify upon alerts

	LastBump time.Time // timestamp of the last received heartbeat

	State HeartbeatState // current state (idle, active, grace, missing, etc.)
	// contains filtered or unexported fields
}

type ActorConfig struct {
	ID          string                           // unique heartbeat identifier
	Description string                           // human-readable description of the heartbeat
	Interval    time.Duration                    // expected interval between heartbeat pings
	Grace       time.Duration                    // grace period after a missed ping before triggering an alert
	Receivers   []string                         // list of receiver IDs to notify on failure
	Logger      *slog.Logger                     // logger scoped to this actor
	History     *servicehistory.Recorder         // store to persist heartbeat and notification events
	DispatchCh  chan<- notifier.NotificationData // channel to send notifications through the dispatcher
	Metrics     *metrics.Registry                // metrics registry
}

type ActorFactory interface {
	Build(cfg HeartbeatConfig) (*Actor, error)
}

type DefaultActorFactory struct {
	Logger     *slog.Logger
	History    *servicehistory.Recorder
	Metrics    *metrics.Registry
	DispatchCh chan<- notifier.NotificationData
}

type EventType int

type HeartbeatConfig struct {
	ID          string        `json:"id"`
	Description string        `json:"description"`
	Interval    time.Duration `json:"interval"`
	Grace       time.Duration `json:"grace"`
	Receivers   []string      `json:"receivers"`
}

type HeartbeatConfigMap map[string]HeartbeatConfig

type HeartbeatState string

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

type ReconcileResult struct {
	Added   int
	Updated int
	Removed int
}