Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CommandPublisher ¶
type CommandPublisher interface {
Publish(ctx context.Context, operation string, payload interface{}) error
}
CommandPublisher publishes a single serialised command to the request topic.
func NewCommandPublisher ¶
func NewCommandPublisher(sender cdb.CommandObjectSender) CommandPublisher
NewCommandPublisher creates a CommandPublisher backed by the given sender.
type ConfigProvider ¶
ConfigProvider lists all known Config CRs.
type HealthcheckRunner ¶
HealthcheckRunner executes one liveness check tick: publishes create-task + update-frontmatter per Config CR.
func NewHealthcheckRunner ¶
func NewHealthcheckRunner( configProvider ConfigProvider, publisher CommandPublisher, branch base.Branch, targetVault string, ) HealthcheckRunner
NewHealthcheckRunner creates a HealthcheckRunner.
targetVault is the vault this executor owns (TASK_VAULT, defaulting to VAULT_NAME). It is stamped onto every published create-task command: the controller substitutes routing.LegacyDefaultVault ("openclaw") when TargetVault is empty and skips the create as a cross-vault write, so an unstamped probe is silently dropped on every vault but openclaw.
Source Files
Directories