jobhost

type Acceptance struct {
	Spec             jobcontract.JobSpec
	Origin           domain.ExecutionOrigin
	SecretCommitment string
	AcceptedAt       time.Time
	ContentClaims    []jobcontent.Claim
}

type Change struct {
	JobID            string
	ExpectedRevision uint64
	Status           domain.RunStatus
	Failure          *domain.RunFailure
	At               time.Time
}

type Clock interface{ Now() time.Time }

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

type CoreDependencies struct {
	Repository       CoreRepository
	Runs             runs.Executor
	Transport        http.RoundTripper
	Clock            Clock
	ReportDiagnostic func(runs.Diagnostic)
}

type CoreRepository interface {
	RunRepository
	PerformanceExecutionRepository
}

type Dependencies struct {
	Repository     Repository
	Executor       Executor
	Guard          Guard
	Clock          Clock
	Policy         Policy
	Target         jobcontract.ExecutionTarget
	InstallationID string
	EngineBuildID  string
	NodeID         string
	RunnerVersion  string
	CommitmentKey  []byte
}

type EventPage struct {
	Events       []jobcontract.Event `json:"events"`
	LastSequence uint64              `json:"last_sequence"`
	HasMore      bool                `json:"has_more"`
}

type Execution struct {
	Spec        jobcontract.JobSpec
	Secrets     map[string]*credentials.Lease
	StopSending <-chan struct{}
	OnProgress  func(quicktest.PerformanceProgress)
	// A known storage fault must make the owner unavailable before Core joins
	// its workers. This callback must not wait for execution to finish.
	OnPersistenceFailure func()
}

type Executor interface {
	Execute(context.Context, Execution) (Outcome, error)
	Settle(context.Context, jobcontract.JobSpec, Outcome) error
}

type Guard interface {
	Reserve(context.Context, jobcontract.JobSpec) (io.Closer, error)
}

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

type Identity struct {
	Target         jobcontract.ExecutionTarget
	InstallationID string
	EngineBuildID  string
	Origin         domain.ExecutionOrigin
	Policy         Policy
}

type JobListQuery struct {
	InstallationID string
	Target         jobcontract.ExecutionTarget
	After          uint64
	Limit          uint32
}

type JobPage struct {
	Contract   int                    `json:"contract"`
	Jobs       []jobcontract.Snapshot `json:"jobs"`
	NextCursor string                 `json:"next_cursor"`
	HasMore    bool                   `json:"has_more"`
}

type LocalIdentity struct {
	NodeID         string
	InstallationID string
	CommitmentKey  []byte
}

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

type MaintenanceResult struct {
	Record jobcontract.MaintenanceRecord `json:"record"`
	Status Status                        `json:"status"`
}

type MaintenanceStore interface {
	Read(context.Context) (*jobcontract.MaintenanceRecord, error)
	Write(context.Context, jobcontract.MaintenanceRecord) error
	// Sync establishes durability after an ambiguous write. Read visibility alone
	// cannot confirm a failed rename-directory fsync.
	Sync(context.Context) error
}

type Outcome struct {
	Status  domain.RunStatus
	Failure *domain.RunFailure
}

type PerformanceArchiveDocument struct {
	Report    quicktest.PerformanceReport
	Reference jobcontract.ReportReference
	Document  []byte
}

type PerformanceExecutionRepository interface {
	PerformanceRepository
	quicktest.PerformanceArchive
	GetJob(context.Context, string) (jobcontract.Snapshot, error)
	GetJobSpec(context.Context, string) (jobcontract.JobSpec, error)
	GetQuickPerformanceReport(context.Context, string) (quicktest.PerformanceReport, error)
}

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

type PerformanceExecutorDependencies struct {
	Repository PerformanceExecutionRepository
	Transport  http.RoundTripper
	Clock      Clock
}

type PerformanceObservationWrite struct {
	JobID            string
	ExpectedRevision uint64
	At               time.Time
	Checkpoint       quicktest.PerformanceCheckpoint
}

type PerformanceRepository interface {
	RecordPerformanceObservation(context.Context, PerformanceObservationWrite) (jobcontract.PerformanceObservation, error)
	GetPerformanceObservation(context.Context, string) (jobcontract.PerformanceObservation, error)
	SealPerformanceResult(context.Context, string, time.Time) (PerformanceResultDocument, error)
	ReadPerformanceResult(context.Context, string) (PerformanceResultDocument, error)
}

type PerformanceResultDocument struct {
	Result    jobcontract.PerformanceResult
	Reference jobcontract.PerformanceResultReference
	Document  []byte
}

type Policy struct {
	MaxActiveJobs    uint32        `json:"max_active_jobs"`
	MaxQueuedJobs    uint32        `json:"max_queued_jobs"`
	MaxConcurrency   uint32        `json:"max_concurrency"`
	QueueTimeout     time.Duration `json:"queue_timeout"`
	ExecutionTimeout time.Duration `json:"execution_timeout"`
}

type Repository interface {
	AcceptJob(context.Context, Acceptance) (jobcontract.Snapshot, bool, error)
	LookupJob(context.Context, Acceptance) (jobcontract.Snapshot, error)
	GetJob(context.Context, string) (jobcontract.Snapshot, error)
	GetJobSpec(context.Context, string) (jobcontract.JobSpec, error)
	ChangeJob(context.Context, Change) (jobcontract.Snapshot, error)
	ApplyJobCommand(context.Context, jobcontract.Command, time.Time) (jobcontract.CommandConfirmation, bool, error)
	GetJobCommand(context.Context, string) (jobcontract.CommandConfirmation, error)
	JobEvents(context.Context, string, uint64, uint32) (EventPage, error)
	ActiveJobs(context.Context) ([]jobcontract.Snapshot, error)
	RecoveryJobs(context.Context) ([]jobcontract.Snapshot, error)
	RecordJobProgress(context.Context, string, quicktest.PerformanceProgress, time.Time) error
	MarkJobSettled(context.Context, string) error
}

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

type RunExecutorDependencies struct {
	Repository       RunRepository
	Executor         runs.Executor
	Clock            Clock
	ReportDiagnostic func(runs.Diagnostic)
}

type RunReportDocument struct {
	Report    domain.Report
	Reference jobcontract.ReportReference
	Document  []byte
}

type RunRepository interface {
	runs.ExecutionRepository
	comparisons.ExecutionRepository
	reporting.ReportRepository
	ListReportsForRuns(context.Context, []string) ([]domain.Report, error)
}

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

type Status struct {
	MaxActiveJobs          uint32 `json:"-"`
	Ready                  bool   `json:"ready"`
	Healthy                bool   `json:"healthy"`
	Active                 uint32 `json:"active"`
	Queued                 uint32 `json:"queued"`
	Pending                uint32 `json:"pending"`
	MaintenanceOperationID string `json:"maintenance_operation_id"`
}

type TaskConcurrencyStore interface {
	Save(context.Context, uint32, uint32) error
}