types

Documentation

Index

• type BadRequestError
  • func NewBadRequestError(err error) BadRequestError
• type Deployment
  • func NewDeployment(taskDefinition string, token string) (*Deployment, error)
  • func (d *Deployment) UpdateDeploymentToCompleted(failedInstances []*ecs.Failure) error
  • func (d *Deployment) UpdateDeploymentToInProgress(desiredTaskCount int, failedInstances []*ecs.Failure) error
• type DeploymentHealth
• type DeploymentStatus
• type Environment
  • func NewEnvironment(name string, taskDefinition string, cluster string) (*Environment, error)
  • func (e *Environment) AddPendingDeployment(d Deployment) error
  • func (e *Environment) SortDeploymentsReverseChronologically() ([]Deployment, error)
  • func (e *Environment) UpdatePendingDeploymentToInProgress() error
• type EnvironmentFacade
  • func NewEnvironmentFacade(css facade.ClusterState) (EnvironmentFacade, error)
• type EnvironmentHealth
• type MockEnvironmentFacade
  • func NewMockEnvironmentFacade(ctrl *gomock.Controller) *MockEnvironmentFacade
  • func (_m *MockEnvironmentFacade) EXPECT() *_MockEnvironmentFacadeRecorder
  • func (_m *MockEnvironmentFacade) InstanceARNs(environment *Environment) ([]*string, error)
• type NotFoundError
  • func NewNotFoundError(err error) NotFoundError

Types

type BadRequestError

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

func NewBadRequestError

func NewBadRequestError(err error) BadRequestError

type Deployment

type Deployment struct {
	ID               string
	Status           DeploymentStatus
	Health           DeploymentHealth
	TaskDefinition   string
	DesiredTaskCount int
	Token            string

	FailedInstances []*ecs.Failure
	StartTime       time.Time
	EndTime         time.Time
}

func NewDeployment

func NewDeployment(taskDefinition string, token string) (*Deployment, error)

func (*Deployment) UpdateDeploymentToCompleted

func (d *Deployment) UpdateDeploymentToCompleted(failedInstances []*ecs.Failure) error

func (*Deployment) UpdateDeploymentToInProgress

func (d *Deployment) UpdateDeploymentToInProgress(
	desiredTaskCount int,
	failedInstances []*ecs.Failure) error

type DeploymentHealth

type DeploymentHealth uint8

const (
	DeploymentHealthy DeploymentHealth = iota
	DeploymentUnhealthy
)

type DeploymentStatus

type DeploymentStatus uint8

const (
	DeploymentPending DeploymentStatus = iota
	DeploymentInProgress
	DeploymentCompleted
)

type Environment

type Environment struct {
	Token                 string
	Name                  string
	DesiredTaskDefinition string
	DesiredTaskCount      int
	Cluster               string
	Health                EnvironmentHealth

	// ID of the deployment created by the latest create-deployment call.
	PendingDeploymentID string
	// ID of the deployment that is currently in-progress. Background workers will pick
	// up this deployment to launch tasks on new instances if there is an in-progress deployment.
	// Otherwise, if no in-progress deployment exists, background workers pick up the latest completed deployment.
	InProgressDeploymentID string

	// deploymentID -> deployment
	Deployments map[string]Deployment
}

func NewEnvironment

func NewEnvironment(name string, taskDefinition string, cluster string) (*Environment, error)

func (*Environment) AddPendingDeployment

func (e *Environment) AddPendingDeployment(d Deployment) error

func (*Environment) SortDeploymentsReverseChronologically

func (e *Environment) SortDeploymentsReverseChronologically() ([]Deployment, error)

SortDeploymentsReverseChronologically returns deployments ordered reverse-chronologically: latest startTime first

func (*Environment) UpdatePendingDeploymentToInProgress

func (e *Environment) UpdatePendingDeploymentToInProgress() error

type EnvironmentFacade

type EnvironmentFacade interface {
	InstanceARNs(environment *Environment) ([]*string, error)
}

func NewEnvironmentFacade

func NewEnvironmentFacade(css facade.ClusterState) (EnvironmentFacade, error)

type EnvironmentHealth

type EnvironmentHealth uint8

const (
	EnvironmentHealthy EnvironmentHealth = iota
	EnvironmentUnhealthy
)

type MockEnvironmentFacade

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

Mock of EnvironmentFacade interface

func NewMockEnvironmentFacade

func NewMockEnvironmentFacade(ctrl *gomock.Controller) *MockEnvironmentFacade

func (*MockEnvironmentFacade) EXPECT

func (_m *MockEnvironmentFacade) EXPECT() *_MockEnvironmentFacadeRecorder

func (*MockEnvironmentFacade) InstanceARNs

func (_m *MockEnvironmentFacade) InstanceARNs(environment *Environment) ([]*string, error)

type NotFoundError

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

func NewNotFoundError

func NewNotFoundError(err error) NotFoundError