awsecs

package
v0.0.0-...-264ff9f Latest Latest
Warning

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

Go to latest
Published: Mar 4, 2018 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL