engine

type ErrorEvent ¶ added in v0.2.0

type ErrorEvent struct {
	Error error
}

ErrorEvent is generic event to notify of errors across actors

func (e ErrorEvent) GetType() EventType

type Event ¶

type Event interface {
	//GetType returns event-type
	GetType() EventType
}

type EventType ¶

type EventType string

const (
	StartDeploymentEventType         EventType = "StartDeploymentEvent"
	StopTasksEventType               EventType = "StopTasksEvent"
	SchedulerErrorEventType          EventType = "SchedulerErrorEvent"
	SchedulerEnvironmentEventType    EventType = "SchedulerEnvironmentEvent"
	ErrorEventType                   EventType = "ErrorEventType"
	StopTasksResultType              EventType = "StopTasksResultType"
	StartDeploymentResultType        EventType = "StartDeploymentResultType"
	StartPendingDeploymentResultType EventType = "StartPendingDeploymentResultType"

	MonitorErrorEventType               EventType = "MonitorErrorEventType"
	UpdateInProgressDeploymentEventType EventType = "UpdateInProgressDeploymentEvent"
	StartPendingDeploymentEventType     EventType = "StartPendingDeploymentEvent"
)

type Monitor ¶

type Monitor interface {
	PendingMonitorLoop(tickerDuration time.Duration)
	InProgressMonitorLoop(tickerDuration time.Duration)
}

func NewMonitor(
	ctx context.Context,
	environmentService environment.EnvironmentService,
	events chan<- Event) Monitor

type MonitorErrorEvent ¶ added in v0.2.0

type MonitorErrorEvent struct {
	Error error
}

MonitorErrorEvent is message used to notify of any execution errors from Monitor

func (e MonitorErrorEvent) GetType() EventType

type SchedulerEnvironmentEvent ¶

type SchedulerEnvironmentEvent struct {
	Environment environmenttypes.Environment
	Message     string
}

SchedulerEnvironmentEvent is message used to notify of any execution errors from Scheduler

func (e SchedulerEnvironmentEvent) GetType() EventType

type SchedulerErrorEvent ¶

type SchedulerErrorEvent struct {
	Error       error
	Environment environmenttypes.Environment
}

SchedulerErrorEvent is message used to notify of any execution errors from Scheduler

func (e SchedulerErrorEvent) GetType() EventType

type StartDeploymentEvent ¶

type StartDeploymentEvent struct {
	Instances   []*string
	Environment environmenttypes.Environment
}

StartDeploymentEvent is message used to notify actors to perform a deployment using environment

func (e StartDeploymentEvent) GetType() EventType

type StartDeploymentResult ¶ added in v0.2.0

type StartDeploymentResult struct {
	Deployment types.Deployment
}

StartDeploymentResult is result of StartDeploymentEvent action

func (e StartDeploymentResult) GetType() EventType

type StartPendingDeploymentEvent ¶ added in v0.2.0

type StartPendingDeploymentEvent struct {
	Environment environmenttypes.Environment
}

func (e StartPendingDeploymentEvent) GetType() EventType

type StartPendingDeploymentResult ¶ added in v0.2.0

type StartPendingDeploymentResult struct {
	Deployment types.Deployment
}

StartPendingDeploymentResult is result of StartPendingDeploymentEvent action

func (e StartPendingDeploymentResult) GetType() EventType

type StopTasksEvent ¶

type StopTasksEvent struct {
	Cluster     string
	Tasks       []string
	Environment environmenttypes.Environment
}

StopTasksEvent is message used to notify actors to stop tasks

func (e StopTasksEvent) GetType() EventType

type StopTasksResult ¶ added in v0.2.0

type StopTasksResult struct {
	StoppedTasks []string
}

StopTasksResult is result of stop tasks action

func (e StopTasksResult) GetType() EventType

type UpdateInProgressDeploymentEvent ¶

type UpdateInProgressDeploymentEvent struct {
	Environment environmenttypes.Environment
}

func (e UpdateInProgressDeploymentEvent) GetType() EventType