awsecs

Documentation

Index

• func DeleteKeyPair(ec2Svc *ec2.EC2, awsCluster *hpaws.AWSCluster) error
• func GetSupportInstanceTypes(awsProfile *hpaws.AWSProfile, regionName string, availabilityZoneName string) ([]string, error)
• func Max(x, y int) int
• type ClusterInfo
• type ECSDeployer
  • func NewDeployer(config *viper.Viper, cluster clusters.Cluster, deployment *apis.Deployment) (*ECSDeployer, error)
  • func (ecsDeployer *ECSDeployer) CreateDeployment(uploadedFiles map[string]string) (interface{}, error)
  • func (ecsDeployer *ECSDeployer) DeleteDeployment() error
  • func (ecsDeployer *ECSDeployer) DeployExtensions(extensions *apis.Deployment, newDeployment *apis.Deployment) error
  • func (ecsDeployer *ECSDeployer) GetCluster() clusters.Cluster
  • func (ecsDeployer *ECSDeployer) GetKubeConfigPath() (string, error)
  • func (ecsDeployer *ECSDeployer) GetLog() *log.FileLog
  • func (ecsDeployer *ECSDeployer) GetScheduler() *job.Scheduler
  • func (ecsDeployer *ECSDeployer) GetServiceAddress(serviceName string) (*apis.ServiceAddress, error)
  • func (ecsDeployer *ECSDeployer) GetServiceMappings() (map[string]interface{}, error)
  • func (ecsDeployer *ECSDeployer) GetServiceUrl(serviceName string) (string, error)
  • func (ecsDeployer *ECSDeployer) GetStoreInfo() interface{}
  • func (ecsDeployer *ECSDeployer) NewStoreInfo() interface{}
  • func (ecsDeployer *ECSDeployer) ReloadClusterState(storeInfo interface{}) error
  • func (ecsDeployer *ECSDeployer) SetScheduler(sheduler *job.Scheduler)
  • func (ecsDeployer *ECSDeployer) SetupEC2Infra(user string, uploadedFiles map[string]string, ec2Svc *ec2.EC2, iamSvc *iam.IAM, ...) error
  • func (ecsDeployer *ECSDeployer) UpdateDeployment(updateDeployment *apis.Deployment) error

Functions

func DeleteKeyPair

func DeleteKeyPair(ec2Svc *ec2.EC2, awsCluster *hpaws.AWSCluster) error

func GetSupportInstanceTypes

func GetSupportInstanceTypes(
	awsProfile *hpaws.AWSProfile,
	regionName string,
	availabilityZoneName string) ([]string, error)

func Max

func Max(x, y int) int

Max compare two inputs and return bigger one

Types

type ClusterInfo

type ClusterInfo struct {
	ContainerInstances []*ecs.ContainerInstance
	Reservations       []*ec2.Reservation
	Tasks              []*ecs.Task
}

type ECSDeployer

type ECSDeployer struct {
	Config     *viper.Viper
	AWSCluster *aws.AWSCluster

	Deployment    *apis.Deployment
	DeploymentLog *log.FileLog
	Scheduler     *job.Scheduler
}

func NewDeployer

func NewDeployer(
	config *viper.Viper,
	cluster clusters.Cluster,
	deployment *apis.Deployment) (*ECSDeployer, error)

NewDeployer return the EC2 of Deployer

func (*ECSDeployer) CreateDeployment

func (ecsDeployer *ECSDeployer) CreateDeployment(uploadedFiles map[string]string) (interface{}, error)

CreateDeployment start a deployment

func (*ECSDeployer) DeleteDeployment

func (ecsDeployer *ECSDeployer) DeleteDeployment() error

DeleteDeployment clean up the cluster from AWS ECS.

func (*ECSDeployer) DeployExtensions

func (ecsDeployer *ECSDeployer) DeployExtensions(
	extensions *apis.Deployment,
	newDeployment *apis.Deployment) error

func (*ECSDeployer) GetCluster

func (ecsDeployer *ECSDeployer) GetCluster() clusters.Cluster

func (*ECSDeployer) GetKubeConfigPath

func (ecsDeployer *ECSDeployer) GetKubeConfigPath() (string, error)

func (*ECSDeployer) GetLog

func (ecsDeployer *ECSDeployer) GetLog() *log.FileLog

func (*ECSDeployer) GetScheduler

func (ecsDeployer *ECSDeployer) GetScheduler() *job.Scheduler

func (*ECSDeployer) GetServiceAddress

func (ecsDeployer *ECSDeployer) GetServiceAddress(serviceName string) (*apis.ServiceAddress, error)

func (*ECSDeployer) GetServiceMappings

func (ecsDeployer *ECSDeployer) GetServiceMappings() (map[string]interface{}, error)

func (*ECSDeployer) GetServiceUrl

func (ecsDeployer *ECSDeployer) GetServiceUrl(serviceName string) (string, error)

func (*ECSDeployer) GetStoreInfo

func (ecsDeployer *ECSDeployer) GetStoreInfo() interface{}

func (*ECSDeployer) NewStoreInfo

func (ecsDeployer *ECSDeployer) NewStoreInfo() interface{}

func (*ECSDeployer) ReloadClusterState

func (ecsDeployer *ECSDeployer) ReloadClusterState(storeInfo interface{}) error

ReloadClusterState reload EC2 cluster state

func (*ECSDeployer) SetScheduler

func (ecsDeployer *ECSDeployer) SetScheduler(sheduler *job.Scheduler)

func (*ECSDeployer) SetupEC2Infra

func (ecsDeployer *ECSDeployer) SetupEC2Infra(user string, uploadedFiles map[string]string, ec2Svc *ec2.EC2, iamSvc *iam.IAM, images map[string]string) error

func (*ECSDeployer) UpdateDeployment

func (ecsDeployer *ECSDeployer) UpdateDeployment(updateDeployment *apis.Deployment) error