engine

Documentation

Index

• func StartDispatcher(ctx context.Context, environmentSvc deployment.Environment, ...) chan<- Event
• type Event
• type EventType
• type Monitor
  • func NewMonitor(ctx context.Context, environment deployment.Environment, events chan<- Event) Monitor
• type Scheduler
  • func NewScheduler(ctx context.Context, events chan<- Event, ...) *Scheduler
  • func (scheduler *Scheduler) Start()
• type SchedulerEnvironmentEvent
  • func (e SchedulerEnvironmentEvent) GetType() EventType
• type SchedulerErrorEvent
  • func (e SchedulerErrorEvent) GetType() EventType
• type StartDeploymentEvent
  • func (e StartDeploymentEvent) GetType() EventType
• type StopTasksEvent
  • func (e StopTasksEvent) GetType() EventType
• type UpdateInProgressDeploymentEvent
  • func (e UpdateInProgressDeploymentEvent) GetType() EventType

Functions

func StartDispatcher

func StartDispatcher(ctx context.Context, environmentSvc deployment.Environment,
	deploymentSvc deployment.Deployment, ecs facade.ECS, css facade.ClusterState,
	deploymentWorker deployment.DeploymentWorker) chan<- Event

StartDispatcher starts dispatcher. dispatcher listens to events on channel and forwards them to workers

Types

type Event

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

type EventType

type EventType string

const (
	StartDeploymentEventType            EventType = "StartDeploymentEvent"
	StopTasksEventType                  EventType = "StopTasksEvent"
	UpdateInProgressDeploymentEventType EventType = "UpdateInProgressDeploymentEvent"
	SchedulerErrorEventType             EventType = "SchedulerErrorEvent"
	SchedulerEnvironmentEventType       EventType = "SchedulerEnvironmentEvent"
)

type Monitor

type Monitor interface {
	InProgressMonitorLoop()
}

func NewMonitor

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

type Scheduler

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

Scheduler loops through all the environments and makes sure they reach their eventual state.

func NewScheduler

func NewScheduler(ctx context.Context, events chan<- Event, environmentSvc deployment.Environment,
	deploymentSvc deployment.Deployment, css facade.ClusterState, ecs facade.ECS) *Scheduler

func (*Scheduler) Start

func (scheduler *Scheduler) Start()

type SchedulerEnvironmentEvent

type SchedulerEnvironmentEvent struct {
	Environment types.Environment
	Message     string
}

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

func (SchedulerEnvironmentEvent) GetType

func (e SchedulerEnvironmentEvent) GetType() EventType

type SchedulerErrorEvent

type SchedulerErrorEvent struct {
	Error       error
	Environment types.Environment
}

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

func (SchedulerErrorEvent) GetType

func (e SchedulerErrorEvent) GetType() EventType

type StartDeploymentEvent

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

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

func (StartDeploymentEvent) GetType

func (e StartDeploymentEvent) GetType() EventType

type StopTasksEvent

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

StopTasksEvent is message used to notify actors to stop tasks

func (StopTasksEvent) GetType

func (e StopTasksEvent) GetType() EventType

type UpdateInProgressDeploymentEvent

type UpdateInProgressDeploymentEvent struct {
	Environment types.Environment
}

func (UpdateInProgressDeploymentEvent) GetType

func (e UpdateInProgressDeploymentEvent) GetType() EventType