runnerhttp

type ContentStore interface {
	PutContent(context.Context, jobcontract.ContentIdentity, io.Reader) (bool, error)
}

type Dependencies struct {
	Host         *jobhost.Host
	Maintenance  *jobhost.Maintenance
	Scheduling   *jobhost.Scheduling
	Repository   ReadRepository
	TokenSHA256  [32]byte
	Capabilities jobcontract.RunnerCapabilities
	Content      ContentStore
}

type ErrorResponse struct {
	Contract  int    `json:"contract"`
	Code      string `json:"code"`
	Message   string `json:"message"`
	Field     string `json:"field,omitempty"`
	Retryable bool   `json:"retryable"`
}

type Handler struct {
	// contains filtered or unexported fields
}

type ReadRepository interface {
	GetJob(context.Context, string) (jobcontract.Snapshot, error)
	GetJobSpec(context.Context, string) (jobcontract.JobSpec, error)
	JobEvents(context.Context, string, uint64, uint32) (jobhost.EventPage, error)
	ReadPerformanceResult(context.Context, string) (jobhost.PerformanceResultDocument, error)
	ListJobs(context.Context, jobhost.JobListQuery) (jobhost.JobPage, error)
	ReadRunReport(context.Context, string, string) (jobhost.RunReportDocument, error)
	ReadPerformanceArchive(context.Context, string, string) (jobhost.PerformanceArchiveDocument, error)
}