scheduler

type ClusterConfig interface {
	ClusterID() string
	VaultConfig
}

type Event struct {
	UnitName string
	Message  string
}

type Reason int

type Scheduler interface {
	// ValidateCluster checks if the cluster is suitable to run the configured job.
	ValidateCluster() error

	// ConfigureCluster configures the cluster for use by J2.
	ConfigureCluster(config ClusterConfig) error

	// List returns the names of all units on the cluster
	List() ([]Unit, error)

	GetState(Unit) (UnitState, error)

	// HasChanged returns true when the given unit is different on the system (or does not exist on the system)
	HasChanged(UnitData) ([]string, bool, error)

	Stop(events chan Event, reason Reason, units ...Unit) (StopStats, error)
	Destroy(events chan Event, reason Reason, units ...Unit) error

	Start(events chan Event, units UnitDataList) error

	IsUnitForScalingGroup(unit Unit, scalingGroup uint) bool
	IsUnitForJob(unit Unit) bool
	IsUnitForTaskGroup(unit Unit, g jobs.TaskGroupName) bool

	UpdateStopDelay(time.Duration) time.Duration
	UpdateDestroyDelay(time.Duration) time.Duration
}

type StopStats struct {
	StoppedUnits       int
	StoppedGlobalUnits int
}

type Unit interface {
	Name() string
}

type UnitData interface {
	Unit
	Content() string
}

type UnitDataList interface {
	Len() int
	Get(index int) UnitData
}

type UnitState struct {
	Failed  bool
	Message string
}

type VaultConfig interface {
	VaultAddress() string
	VaultCACert() string
	VaultCAPath() string
}