Documentation ¶
Index ¶
- func GetClusterName() string
- func GetKeyPairName() string
- func GetLatestECSOptimizedAMIID() (string, error)
- func ValidateECSContainerInstance(ecsWrapper ECSWrapper, clusterName string) error
- type CSSWrapper
- func (wrapper CSSWrapper) FilterInstancesByClusterName(clusterName string) ([]*models.ContainerInstance, error)
- func (wrapper CSSWrapper) FilterTasksByCluster(cluster string) ([]*models.Task, error)
- func (wrapper CSSWrapper) FilterTasksByStartedBy(startedBy string) ([]*models.Task, error)
- func (wrapper CSSWrapper) FilterTasksByStatus(status string) ([]*models.Task, error)
- func (wrapper CSSWrapper) FilterTasksByStatusAndCluster(status string, cluster string) ([]*models.Task, error)
- func (wrapper CSSWrapper) GetInstance(clusterName string, instanceARN string) (*models.ContainerInstance, error)
- func (wrapper CSSWrapper) GetTask(clusterName string, taskARN string) (*models.Task, error)
- func (wrapper CSSWrapper) ListInstances() ([]*models.ContainerInstance, error)
- func (wrapper CSSWrapper) ListTasks() ([]*models.Task, error)
- func (wrapper CSSWrapper) ListTasksWithAllFilters(status string, cluster string, startedBy string) ([]*models.Task, error)
- func (wrapper CSSWrapper) StreamInstances() (*io.PipeReader, error)
- func (wrapper CSSWrapper) StreamInstancesWithEntityVersion(entityVersion string) (*io.PipeReader, error)
- func (wrapper CSSWrapper) StreamTasks() (*io.PipeReader, error)
- func (wrapper CSSWrapper) StreamTasksWithEntityVersion(entityVersion string) (*io.PipeReader, error)
- func (wrapper CSSWrapper) TryGetInstance(instanceARN string) (string, string, error)
- func (wrapper CSSWrapper) TryGetTask(taskARN string) (string, string, error)
- func (wrapper CSSWrapper) TryListInstancesWithInvalidCluster(cluster string) (string, string, error)
- func (wrapper CSSWrapper) TryListInstancesWithInvalidStatus(status string) (string, string, error)
- func (wrapper CSSWrapper) TryListTasksWithInvalidCluster(cluster string) (string, string, error)
- func (wrapper CSSWrapper) TryListTasksWithInvalidStatus(status string) (string, string, error)
- type EC2Wrapper
- type ECSWrapper
- func (ecsWrapper ECSWrapper) CreateCluster(clusterName *string) error
- func (ecsWrapper ECSWrapper) DeleteCluster(clusterName *string) error
- func (ecsWrapper ECSWrapper) DeregisterContainerInstances(clusterName *string, instanceARNs []*string) error
- func (ecsWrapper ECSWrapper) DeregisterTaskDefinition(taskDefnARN string) error
- func (ecsWrapper ECSWrapper) DescribeContainerInstance(clusterName string, instanceARN string) (ecs.ContainerInstance, error)
- func (ecsWrapper ECSWrapper) DescribeTaskDefinition(taskDefn string) (string, error)
- func (ecsWrapper ECSWrapper) ListContainerInstances(clusterName string) ([]*string, error)
- func (ecsWrapper ECSWrapper) ListTasks(clusterName string) ([]*string, error)
- func (ecsWrapper ECSWrapper) RegisterSleep360TaskDefinition() (string, error)
- func (ecsWrapper ECSWrapper) StartTask(clusterName string, taskDefn string, startedBy string) (ecs.Task, error)
- func (ecsWrapper ECSWrapper) StopTask(clusterName string, taskARN string) error
- type IAMWrapper
- func (iamWrapper IAMWrapper) AddRoleToInstanceProfile(roleName *string, instanceProfileName *string) error
- func (iamWrapper IAMWrapper) AttachRolePolicy(policyARN *string, roleName *string) error
- func (iamWrapper IAMWrapper) CreateInstanceProfile(instanceProfileName *string) error
- func (iamWrapper IAMWrapper) CreateRole(roleName *string, assumeRolePolicyDocument *string) error
- func (iamWrapper IAMWrapper) DeleteInstanceProfile(instanceProfile *string) error
- func (iamWrapper IAMWrapper) DeleteRole(roleName *string) error
- func (iamWrapper IAMWrapper) DetachRolePolicy(policyARN *string, roleName *string) error
- func (iamWrapper IAMWrapper) GetInstanceProfile(instanceProfileName *string) error
- func (iamWrapper IAMWrapper) GetRole(roleName *string) error
- func (iamWrapper IAMWrapper) RemoveRoleFromInstanceProfile(roleName *string, instanceProfileName *string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetClusterName ¶
func GetClusterName() string
func GetKeyPairName ¶
func GetKeyPairName() string
func ValidateECSContainerInstance ¶
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 ¶
func (wrapper CSSWrapper) FilterTasksByStartedBy(startedBy string) ([]*models.Task, error)
func (CSSWrapper) FilterTasksByStatus ¶
func (wrapper CSSWrapper) FilterTasksByStatus(status string) ([]*models.Task, error)
func (CSSWrapper) FilterTasksByStatusAndCluster ¶
func (CSSWrapper) GetInstance ¶
func (wrapper CSSWrapper) GetInstance(clusterName string, instanceARN string) (*models.ContainerInstance, error)
func (CSSWrapper) ListInstances ¶
func (wrapper CSSWrapper) ListInstances() ([]*models.ContainerInstance, error)
func (CSSWrapper) ListTasksWithAllFilters ¶
func (CSSWrapper) StreamInstances ¶
func (wrapper CSSWrapper) StreamInstances() (*io.PipeReader, error)
func (CSSWrapper) StreamInstancesWithEntityVersion ¶
func (wrapper CSSWrapper) StreamInstancesWithEntityVersion(entityVersion string) (*io.PipeReader, error)
func (CSSWrapper) StreamTasks ¶
func (wrapper CSSWrapper) StreamTasks() (*io.PipeReader, error)
func (CSSWrapper) StreamTasksWithEntityVersion ¶
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 ¶
func (wrapper CSSWrapper) TryListInstancesWithInvalidCluster(cluster string) (string, string, error)
func (CSSWrapper) TryListInstancesWithInvalidStatus ¶
func (wrapper CSSWrapper) TryListInstancesWithInvalidStatus(status string) (string, string, error)
func (CSSWrapper) TryListTasksWithInvalidCluster ¶
func (wrapper CSSWrapper) TryListTasksWithInvalidCluster(cluster string) (string, string, error)
func (CSSWrapper) TryListTasksWithInvalidStatus ¶
func (wrapper CSSWrapper) TryListTasksWithInvalidStatus(status string) (string, string, error)
type EC2Wrapper ¶
type EC2Wrapper struct {
// contains filtered or unexported fields
}
func NewEC2Wrapper ¶
func NewEC2Wrapper() EC2Wrapper
func (EC2Wrapper) RunInstance ¶
func (EC2Wrapper) TerminateInstances ¶
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 ¶
func (ecsWrapper ECSWrapper) CreateCluster(clusterName *string) error
func (ECSWrapper) DeleteCluster ¶
func (ecsWrapper ECSWrapper) DeleteCluster(clusterName *string) error
func (ECSWrapper) DeregisterContainerInstances ¶
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)
type IAMWrapper ¶
type IAMWrapper struct {
// contains filtered or unexported fields
}
func NewIAMWrapper ¶
func NewIAMWrapper() IAMWrapper
func (IAMWrapper) AddRoleToInstanceProfile ¶
func (iamWrapper IAMWrapper) AddRoleToInstanceProfile(roleName *string, instanceProfileName *string) error
func (IAMWrapper) AttachRolePolicy ¶
func (iamWrapper IAMWrapper) AttachRolePolicy(policyARN *string, roleName *string) error
func (IAMWrapper) CreateInstanceProfile ¶
func (iamWrapper IAMWrapper) CreateInstanceProfile(instanceProfileName *string) error
func (IAMWrapper) CreateRole ¶
func (iamWrapper IAMWrapper) CreateRole(roleName *string, assumeRolePolicyDocument *string) error
func (IAMWrapper) DeleteInstanceProfile ¶
func (iamWrapper IAMWrapper) DeleteInstanceProfile(instanceProfile *string) error
func (IAMWrapper) DeleteRole ¶
func (iamWrapper IAMWrapper) DeleteRole(roleName *string) error
func (IAMWrapper) DetachRolePolicy ¶
func (iamWrapper IAMWrapper) DetachRolePolicy(policyARN *string, roleName *string) error
func (IAMWrapper) GetInstanceProfile ¶
func (iamWrapper IAMWrapper) GetInstanceProfile(instanceProfileName *string) error
func (IAMWrapper) GetRole ¶
func (iamWrapper IAMWrapper) GetRole(roleName *string) error
func (IAMWrapper) RemoveRoleFromInstanceProfile ¶
func (iamWrapper IAMWrapper) RemoveRoleFromInstanceProfile(roleName *string, instanceProfileName *string) error
Click to show internal directories.
Click to hide internal directories.