servicecommands

Oct 11, 2026

Changes in this version

type Manager

+ Events events.Publisher

Sep 3, 2026

Changes in this version

+ const ActionReloadAlerts

Aug 24, 2026

Changes in this version

+ const ActionReloadAuthProviders

+ const ActionReloadLogSinks

Aug 19, 2026

Changes in this version

+ const ActionPersistConfig

+ const ActionRestart

+ const StatusConsumed

+ const StatusExpired

+ const StatusPending

+ const StatusRecovered

+ var ErrInvalidAction = errors.New("invalid service command action")

+ var ErrInvalidTarget = errors.New("invalid service command target")

+ type Manager struct

+ DB *gorm.DB

+ func NewManager(db *gorm.DB) *Manager

+ func (m *Manager) ConsumeNext(targetService, consumedBy string, now time.Time) (ServiceCommand, bool, error)

+ func (m *Manager) Get(commandID string) (ServiceCommand, error)

+ func (m *Manager) MarkRecovered(targetService, recoveredBy string, now time.Time) (int64, error)

+ func (m *Manager) Request(targetService, action, requestedBy, requestedFrom string, ttl time.Duration) (ServiceCommand, error)

+ func (m *Manager) RequestRestart(targetService, requestedBy, requestedFrom string, ttl time.Duration) (ServiceCommand, error)

+ type ServiceCommand struct

+ Action string

+ CommandID string

+ ConsumedAt *time.Time

+ ConsumedBy string

+ ExpiresAt time.Time

+ RecoveredAt *time.Time

+ RecoveredBy string

+ RequestedBy string

+ RequestedFrom string

+ TargetService string

+ func (c ServiceCommand) Status(now time.Time) string