service

Documentation

Index

• func CreateServiceMap(data string) (map[string]Service, error)
• type Cluster
• type LoadBalancer
• type Service
  • func (self *Service) FindLoadBalancerByContainer(conname string, port int64) *LoadBalancer
  • func (self *Service) FindLoadBalancerByName(name string) *LoadBalancer
• type ServiceController
  • func NewServiceController(manager *aws.AwsManager, projectDir string, targetResources []string, ...) (*ServiceController, error)
  • func (self *ServiceController) ApplyServicePlan(plan *ServiceUpdatePlan) error
  • func (self *ServiceController) ApplyServicePlans(plans []*ServiceUpdatePlan)
  • func (self *ServiceController) CreateServiceUpdatePlan(cluster Cluster) (*ServiceUpdatePlan, error)
  • func (self *ServiceController) CreateServiceUpdatePlans() ([]*ServiceUpdatePlan, error)
  • func (self *ServiceController) GetClusters() []Cluster
  • func (self *ServiceController) RoundColorStatus(status string) *color.Escape
  • func (self *ServiceController) WaitActiveService(cluster string, service string) error
• type ServiceUpdatePlan
• type TaskWatchStatus

Functions

func CreateServiceMap

func CreateServiceMap(data string) (map[string]Service, error)

Types

type Cluster

type Cluster struct {
	Name     string
	Services map[string]Service
}

type LoadBalancer

type LoadBalancer struct {
	Name          string `yaml:"name"`
	ContainerName string `yaml:"container_name"`
	ContainerPort int64  `yaml:"container_port"`
}

type Service

type Service struct {
	Name             string
	TaskDefinition   string         `yaml:"task_definition"`
	DesiredCount     int64          `yaml:"desired_count"`
	KeepDesiredCount bool           `yaml:"keep_desired_count"`
	LoadBalancers    []LoadBalancer `yaml:"load_balancers"`
	Role             string         `yaml:"role"`
}

func (*Service) FindLoadBalancerByContainer

func (self *Service) FindLoadBalancerByContainer(conname string, port int64) *LoadBalancer

func (*Service) FindLoadBalancerByName

func (self *Service) FindLoadBalancerByName(name string) *LoadBalancer

type ServiceController

type ServiceController struct {
	// contains filtered or unexported fields
}

func NewServiceController

func NewServiceController(manager *aws.AwsManager, projectDir string, targetResources []string, params map[string]string) (*ServiceController, error)

func (*ServiceController) ApplyServicePlan

func (self *ServiceController) ApplyServicePlan(plan *ServiceUpdatePlan) error

func (*ServiceController) ApplyServicePlans

func (self *ServiceController) ApplyServicePlans(plans []*ServiceUpdatePlan)

func (*ServiceController) CreateServiceUpdatePlan

func (self *ServiceController) CreateServiceUpdatePlan(cluster Cluster) (*ServiceUpdatePlan, error)

func (*ServiceController) CreateServiceUpdatePlans

func (self *ServiceController) CreateServiceUpdatePlans() ([]*ServiceUpdatePlan, error)

func (*ServiceController) GetClusters

func (self *ServiceController) GetClusters() []Cluster

func (*ServiceController) RoundColorStatus

func (self *ServiceController) RoundColorStatus(status string) *color.Escape

func (*ServiceController) WaitActiveService

func (self *ServiceController) WaitActiveService(cluster string, service string) error

type ServiceUpdatePlan

type ServiceUpdatePlan struct {
	Name            string
	InstanceARNs    []*string
	CurrentServices map[string]*ecs.Service
	NewServices     map[string]*Service
}

type TaskWatchStatus

type TaskWatchStatus int

const (
	WatchContinue TaskWatchStatus = iota
	WatchFinish
	WatchTerminate
)