facade

Documentation

Index

• type ClusterState
  • func NewClusterState(css *client.BloxCSS) (ClusterState, error)
• type ECS
  • func NewECS(ecs ecsiface.ECSAPI) ECS
• type MockClusterState
  • func NewMockClusterState(ctrl *gomock.Controller) *MockClusterState
  • func (_m *MockClusterState) EXPECT() *_MockClusterStateRecorder
  • func (_m *MockClusterState) ListInstances(cluster string) ([]*models.ContainerInstance, error)
  • func (_m *MockClusterState) ListTasks(cluster string) ([]*models.Task, error)

Types

type ClusterState

type ClusterState interface {
	ListInstances(cluster string) ([]*models.ContainerInstance, error)
	ListTasks(cluster string) ([]*models.Task, error)
}

ClusterState defines methods to get cluster and task state

func NewClusterState

func NewClusterState(css *client.BloxCSS) (ClusterState, error)

type ECS

type ECS interface {
	StartTask(
		clusterArn string,
		containerInstances []*string,
		startedBy string,
		taskDefinition string) (*ecs.StartTaskOutput, error)

	ListClusters() ([]*string, error)
	DescribeCluster(cluster *string) (*ecs.Cluster, error)
	DescribeTaskDefinition(taskDefinition *string) (*ecs.TaskDefinition, error)
	ListTasks(cluster string, startedBy string) ([]*string, error)
	ListTasksByInstance(cluster string, instanceARN string) ([]*string, error)
	DescribeTasks(cluster string, tasks []*string) (*ecs.DescribeTasksOutput, error)
	StopTask(clusterArn string, taskArn string) error
}

func NewECS

func NewECS(ecs ecsiface.ECSAPI) ECS

type MockClusterState

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

Mock of ClusterState interface

func NewMockClusterState

func NewMockClusterState(ctrl *gomock.Controller) *MockClusterState

func (*MockClusterState) EXPECT

func (_m *MockClusterState) EXPECT() *_MockClusterStateRecorder

func (*MockClusterState) ListInstances

func (_m *MockClusterState) ListInstances(cluster string) ([]*models.ContainerInstance, error)

func (*MockClusterState) ListTasks

func (_m *MockClusterState) ListTasks(cluster string) ([]*models.Task, error)