agent

type Agent struct {
	// ID uniquely identifies the agent.
	ID string

	logr.Logger

	// DataDir stores artefacts relating to runs, i.e. downloaded plugins,
	// modules (?), configuration versions, state, etc.
	DataDir string

	// ServerAddr is the address (<host>:<port>) of the OTF server to connect
	// to.
	ServerAddr string

	ConfigurationVersionService otf.ConfigurationVersionService
	StateVersionService         otf.StateVersionService

	Spooler

	*Supervisor
}

type Cancelable interface {
	Cancel(force bool)
}

type Executor struct {
	logr.Logger

	RunService                  otf.RunService
	ConfigurationVersionService otf.ConfigurationVersionService
	StateVersionService         otf.StateVersionService
}

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

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

type MockSpooler struct {
	Spooler
	// contains filtered or unexported fields
}

type MockSpoolerOption func(*MockSpooler)

type RunLister interface {
	List(otf.RunListOptions) (*otf.RunList, error)
}

type Spooler interface {
	// Start the daemon
	Start(context.Context)

	// GetJob receives spooled job
	GetJob() <-chan otf.Job

	// GetCancelation receives cancelation request for a job
	GetCancelation() <-chan otf.Job
}

type SpoolerDaemon struct {

	// EventService allows subscribing to stream of events
	otf.EventService

	// Logger for logging various events
	logr.Logger
	// contains filtered or unexported fields
}

type Supervisor struct {
	logr.Logger

	RunService                  otf.RunService
	ConfigurationVersionService otf.ConfigurationVersionService
	StateVersionService         otf.StateVersionService

	Spooler

	*Terminator
	// contains filtered or unexported fields
}

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

type Worker struct {
	*Supervisor
}