wrappers

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 15, 2017 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetClusterName 

func GetClusterName() string

func GetKeyPairName added in v0.3.0 

func GetKeyPairName() string

func GetLatestECSOptimizedAMIID added in v0.3.0 

func GetLatestECSOptimizedAMIID() (string, error)

func ValidateECSContainerInstance added in v0.3.0 

func ValidateECSContainerInstance(ecsWrapper ECSWrapper, clusterName string) error

ValidateECSContainerInstance validates that an ECS instance was launched within a cluster 'clusterName'

Types

type CSSWrapper 

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

func NewCSSWrapper 

func NewCSSWrapper() CSSWrapper

func (CSSWrapper) FilterInstancesByClusterName 

func (wrapper CSSWrapper) FilterInstancesByClusterName(clusterName string) ([]*models.ContainerInstance, error)

func (CSSWrapper) FilterTasksByCluster 

func (wrapper CSSWrapper) FilterTasksByCluster(cluster string) ([]*models.Task, error)

func (CSSWrapper) FilterTasksByStartedBy added in v0.2.0 

func (wrapper CSSWrapper) FilterTasksByStartedBy(startedBy string) ([]*models.Task, error)

func (CSSWrapper) FilterTasksByStatus 

func (wrapper CSSWrapper) FilterTasksByStatus(status string) ([]*models.Task, error)

func (CSSWrapper) FilterTasksByStatusAndCluster added in v0.2.0 

func (wrapper CSSWrapper) FilterTasksByStatusAndCluster(status string, cluster string) ([]*models.Task, error)

func (CSSWrapper) GetInstance 

func (wrapper CSSWrapper) GetInstance(clusterName string, instanceARN string) (*models.ContainerInstance, error)

func (CSSWrapper) GetTask 

func (wrapper CSSWrapper) GetTask(clusterName string, taskARN string) (*models.Task, error)

func (CSSWrapper) ListInstances 

func (wrapper CSSWrapper) ListInstances() ([]*models.ContainerInstance, error)

func (CSSWrapper) ListTasks 

func (wrapper CSSWrapper) ListTasks() ([]*models.Task, error)

func (CSSWrapper) ListTasksWithAllFilters added in v0.2.0 

func (wrapper CSSWrapper) ListTasksWithAllFilters(status string, cluster string, startedBy string) ([]*models.Task, error)

func (CSSWrapper) StreamInstances added in v0.2.0 

func (wrapper CSSWrapper) StreamInstances() (*io.PipeReader, error)

func (CSSWrapper) StreamInstancesWithEntityVersion added in v0.2.0 

func (wrapper CSSWrapper) StreamInstancesWithEntityVersion(entityVersion string) (*io.PipeReader, error)

func (CSSWrapper) StreamTasks added in v0.2.0 

func (wrapper CSSWrapper) StreamTasks() (*io.PipeReader, error)

func (CSSWrapper) StreamTasksWithEntityVersion added in v0.2.0 

func (wrapper CSSWrapper) StreamTasksWithEntityVersion(entityVersion string) (*io.PipeReader, error)

func (CSSWrapper) TryGetInstance 

func (wrapper CSSWrapper) TryGetInstance(instanceARN string) (string, string, error)

func (CSSWrapper) TryGetTask 

func (wrapper CSSWrapper) TryGetTask(taskARN string) (string, string, error)

func (CSSWrapper) TryListInstancesWithInvalidCluster added in v0.2.0 

func (wrapper CSSWrapper) TryListInstancesWithInvalidCluster(cluster string) (string, string, error)

func (CSSWrapper) TryListInstancesWithInvalidStatus added in v0.2.0 

func (wrapper CSSWrapper) TryListInstancesWithInvalidStatus(status string) (string, string, error)

func (CSSWrapper) TryListTasksWithInvalidCluster added in v0.2.0 

func (wrapper CSSWrapper) TryListTasksWithInvalidCluster(cluster string) (string, string, error)

func (CSSWrapper) TryListTasksWithInvalidStatus added in v0.2.0 

func (wrapper CSSWrapper) TryListTasksWithInvalidStatus(status string) (string, string, error)

type EC2Wrapper added in v0.3.0 

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

func NewEC2Wrapper added in v0.3.0 

func NewEC2Wrapper() EC2Wrapper

func (EC2Wrapper) RunInstance added in v0.3.0 

func (ec2Wrapper EC2Wrapper) RunInstance(count *int64, clusterName *string, instanceProfileName *string, keyName *string, amiID *string) ([]*string, error)

func (EC2Wrapper) TerminateInstances added in v0.3.0 

func (ec2Wrapper EC2Wrapper) TerminateInstances(instanceIDs []*string) error

type ECSWrapper 

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

func NewECSWrapper 

func NewECSWrapper() ECSWrapper

func (ECSWrapper) CreateCluster added in v0.3.0 

func (ecsWrapper ECSWrapper) CreateCluster(clusterName *string) error

func (ECSWrapper) DeleteCluster added in v0.3.0 

func (ecsWrapper ECSWrapper) DeleteCluster(clusterName *string) error

func (ECSWrapper) DeregisterContainerInstances added in v0.3.0 

func (ecsWrapper ECSWrapper) DeregisterContainerInstances(clusterName *string, instanceARNs []*string) error

func (ECSWrapper) DeregisterTaskDefinition 

func (ecsWrapper ECSWrapper) DeregisterTaskDefinition(taskDefnARN string) error

func (ECSWrapper) DescribeContainerInstance 

func (ecsWrapper ECSWrapper) DescribeContainerInstance(clusterName string, instanceARN string) (ecs.ContainerInstance, error)

func (ECSWrapper) DescribeTaskDefinition 

func (ecsWrapper ECSWrapper) DescribeTaskDefinition(taskDefn string) (string, error)

func (ECSWrapper) ListContainerInstances 

func (ecsWrapper ECSWrapper) ListContainerInstances(clusterName string) ([]*string, error)

func (ECSWrapper) ListTasks 

func (ecsWrapper ECSWrapper) ListTasks(clusterName string) ([]*string, error)

func (ECSWrapper) RegisterSleep360TaskDefinition 

func (ecsWrapper ECSWrapper) RegisterSleep360TaskDefinition() (string, error)

func (ECSWrapper) StartTask 

func (ecsWrapper ECSWrapper) StartTask(clusterName string, taskDefn string, startedBy string) (ecs.Task, error)

func (ECSWrapper) StopTask 

func (ecsWrapper ECSWrapper) StopTask(clusterName string, taskARN string) error

type IAMWrapper added in v0.3.0 

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

func NewIAMWrapper added in v0.3.0 

func NewIAMWrapper() IAMWrapper

func (IAMWrapper) AddRoleToInstanceProfile added in v0.3.0 

func (iamWrapper IAMWrapper) AddRoleToInstanceProfile(roleName *string, instanceProfileName *string) error

func (IAMWrapper) AttachRolePolicy added in v0.3.0 

func (iamWrapper IAMWrapper) AttachRolePolicy(policyARN *string, roleName *string) error

func (IAMWrapper) CreateInstanceProfile added in v0.3.0 

func (iamWrapper IAMWrapper) CreateInstanceProfile(instanceProfileName *string) error

func (IAMWrapper) CreateRole added in v0.3.0 

func (iamWrapper IAMWrapper) CreateRole(roleName *string, assumeRolePolicyDocument *string) error

func (IAMWrapper) DeleteInstanceProfile added in v0.3.0 

func (iamWrapper IAMWrapper) DeleteInstanceProfile(instanceProfile *string) error

func (IAMWrapper) DeleteRole added in v0.3.0 

func (iamWrapper IAMWrapper) DeleteRole(roleName *string) error

func (IAMWrapper) DetachRolePolicy added in v0.3.0 

func (iamWrapper IAMWrapper) DetachRolePolicy(policyARN *string, roleName *string) error

func (IAMWrapper) GetInstanceProfile added in v0.3.0 

func (iamWrapper IAMWrapper) GetInstanceProfile(instanceProfileName *string) error

func (IAMWrapper) GetRole added in v0.3.0 

func (iamWrapper IAMWrapper) GetRole(roleName *string) error

func (IAMWrapper) RemoveRoleFromInstanceProfile added in v0.3.0 

func (iamWrapper IAMWrapper) RemoveRoleFromInstanceProfile(roleName *string, instanceProfileName *string) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.