worker

Documentation

Index

• type DispatcherClient
• type HandleJobFunc
• type JobUpdaterClient
• type Worker
  • func NewWorker(c WorkerClient, jobsDir string) (Worker, error)
• type WorkerClient

Types

type DispatcherClient

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

type HandleJobFunc

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

type JobUpdaterClient

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

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

func NewWorker

func NewWorker(c WorkerClient, jobsDir string) (Worker, error)

type WorkerClient

type WorkerClient interface {
	DispatcherClient
	JobUpdaterClient
}