dispatcher

package

v0.1.4 Latest Latest Go to latest Published: Feb 19, 2026 License: GPL-3.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Dispatcher interface {
	Start(ctx context.Context) error
	Stop() error
	SetRunnerChangeCallback(cb RunnerChangeCallback)
}

Dispatcher defines the interface for the job dispatch service.

func NewDispatcher(
	log logrus.FieldLogger,
	cfg *config.Config,
	st store.Store,
	q queue.Service,
	ghClient github.Client,
) Dispatcher

NewDispatcher creates a new dispatcher.

type RunnerChangeCallback func(runner *store.Runner)

RunnerChangeCallback is called when a runner's status changes.