wrappers

package
v0.0.0-...-abfb793 Latest Latest
Warning

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

 Go to latest Published: Oct 2, 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 

func GetKeyPairName() string

func GetLatestECSOptimizedAMIID 

func GetLatestECSOptimizedAMIID() (string, error)

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 (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 

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

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 EC2Wrapper) RunInstance(count *int64, clusterName *string, instanceProfileName *string, keyName *string, amiID *string) ([]*string, error)

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)

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 

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

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.