agent

type ActionCache interface {
	Fill(job domain.Job)
	Reclaim() error
}

type Agent struct {
	Version       string
	FailedRequest string
	FailedVersion string
	UpdateError   string
	Update        func(context.Context, string, string) error
	Healthy       func(context.Context) error
	Name          string
	Labels        []string
	Driver        driver.Driver
	Client        *api.Client

	// MinFreeDisk is the free-space floor on the driver's image store, in bytes.
	// Under it the agent deselects itself — it keeps polling but reports no free
	// capacity, so the work stays schedulable on a host that can actually run it
	// instead of failing here. Zero disables the gate, as does a driver that
	// can't locate its store.
	MinFreeDisk uint64

	// ReclaimFloor is the free-space mark reclaim works to keep clear. It is
	// separate from MinFreeDisk so that disabling the gate leaves upkeep
	// running: an operator who never wants work refused still wants the caches
	// collected. Zero disables reclaim.
	ReclaimFloor uint64

	// Metrics receives the agent's series; served only when the operator sets
	// a metrics listen address.
	Metrics *metrics.Agent

	// Actions, when set, is filled from each finished job and emptied first
	// under disk pressure.
	Actions ActionCache

	// Source, when set, says when a pending job has left GitHub's queue: it
	// was not re-emitted by the last clean pass of its scope. A paused or
	// failing scope evicts nothing, so a job still waiting is never dropped.
	Source Freshness
	// contains filtered or unexported fields
}

type DispatchObserver interface {
	DispatchDone(handle string, failed bool)
}

type Freshness interface {
	// RelistGap bounds how stale an emitted job's state can be.
	RelistGap() time.Duration
}

type Minter interface {
	Mint(ctx context.Context, name string, job domain.Job, labels []string) (string, error)
}