probe

package

v0.20.0 Latest Latest Go to latest Published: Oct 20, 2026 License: BSD-2-Clause Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type CommandPublisher interface {
	Publish(ctx context.Context, operation string, payload interface{}) error
}

CommandPublisher publishes a single serialised command to the request topic.

func NewCommandPublisher(sender cdb.CommandObjectSender) CommandPublisher

NewCommandPublisher creates a CommandPublisher backed by the given sender.

type ConfigProvider interface {
	Get(ctx context.Context) ([]agentv1.Config, error)
}

ConfigProvider lists all known Config CRs.

type HealthcheckRunner interface {
	Run(ctx context.Context) error
}

HealthcheckRunner executes one liveness check tick: publishes create-task + update-frontmatter per Config CR.

func NewHealthcheckRunner(
	configProvider ConfigProvider,
	publisher CommandPublisher,
	branch base.Branch,
) HealthcheckRunner

NewHealthcheckRunner creates a HealthcheckRunner.

Path	Synopsis
mocks Code generated by counterfeiter.	Code generated by counterfeiter.