worker

type DispatcherClient interface {
	DispatchJobs(context.Context, func(*core.JobRecord, uint64) (bool, error)) error
}

type HandleJobFunc func(*core.JobRecord, uint64) (bool, error)

type JobUpdaterClient interface {
	UpdateJob(*core.JobRecord, uint64) (uint64, error)
	UploadLogArtifact(string, string) (string, error)
	UploadResultsArtifact(string, string) (string, error)
	UploadScriptArtifact(string, string) (string, error)
}

type Worker interface {
	Run(context.Context) error
}

type WorkerClient interface {
	DispatcherClient
	JobUpdaterClient
}