task

Documentation

Index

• type ContainerDefinition
• type TaskDefinition
  • func CreateTaskDefinition(taskDefName string, data string, basedir string, manager *aws.AwsManager) (*TaskDefinition, error)
• type TaskDefinitionController
  • func NewTaskDefinitionController(manager *efaws.AwsManager, projectDir string, targetResource string, ...) (*TaskDefinitionController, error)
  • func (self *TaskDefinitionController) ApplyTaskDefinitionPlan(task *TaskUpdatePlan) (*ecs.RegisterTaskDefinitionOutput, error)
  • func (self *TaskDefinitionController) ApplyTaskDefinitionPlans(plans []*TaskUpdatePlan) ([]*ecs.RegisterTaskDefinitionOutput, error)
  • func (self *TaskDefinitionController) CreateTaskUpdatePlan(task *TaskDefinition) *TaskUpdatePlan
  • func (self *TaskDefinitionController) CreateTaskUpdatePlans(tasks map[string]*TaskDefinition) []*TaskUpdatePlan
  • func (self *TaskDefinitionController) GetTaskDefinitionMap() map[string]*TaskDefinition
• type TaskUpdatePlan
• type Ulimit
• type UpdateContainer
• type VolumeInfo
  • func CreateVolumeInfo(value string) (*VolumeInfo, error)
  • func CreateVolumeInfoItems(values []string) ([]*VolumeInfo, error)

Types

type ContainerDefinition

type ContainerDefinition struct {
	Name                   string
	Image                  string            `yaml:"image"`
	Ports                  []string          `yaml:"ports"`
	Environment            map[string]string `yaml:"environment"`
	EnvFiles               []string          `yaml:"env_file"`
	Links                  []string          `yaml:"links"`
	Volumes                []string          `yaml:"volumes"`
	VolumesFrom            []string          `yaml:"volumes_from"`
	Memory                 int64             `yaml:"memory"`
	CpuUnits               int64             `yaml:"cpu_units"`
	Essential              bool              `yaml:"essential"`
	EntryPoint             string            `yaml:"entry_point"`
	Command                string            `yaml:"command"`
	DisableNetworking      bool              `yaml:"disable_networking"`
	DnsSearchDomains       []string          `yaml:"dns_search"`
	DnsServers             []string          `yaml:"dns"`
	DockerLabels           map[string]string `yaml:"labels"`
	DockerSecurityOptions  []string          `yaml:"security_opt"`
	ExtraHosts             []string          `yaml:"extra_hosts"`
	Hostname               string            `yaml:"hostname"`
	LogDriver              string            `yaml:"log_driver"`
	LogOpt                 map[string]string `yaml:"log_opt"`
	Privileged             bool              `yaml:"privileged"`
	ReadonlyRootFilesystem bool              `yaml:"read_only"`
	Ulimits                map[string]Ulimit `yaml:"ulimits"`
	User                   string            `yaml:"user"`
	WorkingDirectory       string            `yaml:"working_dir"`
}

type TaskDefinition

type TaskDefinition struct {
	Name                 string
	ContainerDefinitions map[string]*ContainerDefinition
}

func CreateTaskDefinition

func CreateTaskDefinition(taskDefName string, data string, basedir string, manager *aws.AwsManager) (*TaskDefinition, error)

type TaskDefinitionController

type TaskDefinitionController struct {
	TargetResource string
	// contains filtered or unexported fields
}

func NewTaskDefinitionController

func NewTaskDefinitionController(manager *efaws.AwsManager, projectDir string, targetResource string, params map[string]string) (*TaskDefinitionController, error)

func (*TaskDefinitionController) ApplyTaskDefinitionPlan

func (self *TaskDefinitionController) ApplyTaskDefinitionPlan(task *TaskUpdatePlan) (*ecs.RegisterTaskDefinitionOutput, error)

func (*TaskDefinitionController) ApplyTaskDefinitionPlans

func (self *TaskDefinitionController) ApplyTaskDefinitionPlans(plans []*TaskUpdatePlan) ([]*ecs.RegisterTaskDefinitionOutput, error)

func (*TaskDefinitionController) CreateTaskUpdatePlan

func (self *TaskDefinitionController) CreateTaskUpdatePlan(task *TaskDefinition) *TaskUpdatePlan

func (*TaskDefinitionController) CreateTaskUpdatePlans

func (self *TaskDefinitionController) CreateTaskUpdatePlans(tasks map[string]*TaskDefinition) []*TaskUpdatePlan

func (*TaskDefinitionController) GetTaskDefinitionMap

func (self *TaskDefinitionController) GetTaskDefinitionMap() map[string]*TaskDefinition

type TaskUpdatePlan

type TaskUpdatePlan struct {
	Name          string
	NewContainers map[string]*ContainerDefinition
}

type Ulimit

type Ulimit struct {
	Soft int64 `yaml:"soft"`
	Hard int64 `yaml:"hard"`
}

type UpdateContainer

type UpdateContainer struct {
	Before *ecs.ContainerDefinition
	After  *ContainerDefinition
}

type VolumeInfo

type VolumeInfo struct {
	Volume     *ecs.Volume
	MountPoint *ecs.MountPoint
}

func CreateVolumeInfo

func CreateVolumeInfo(value string) (*VolumeInfo, error)

func CreateVolumeInfoItems

func CreateVolumeInfoItems(values []string) ([]*VolumeInfo, error)