containersvc

May 8, 2018

Changes in this version

+ const JournalVolumeNamePrefix

+ func GetServiceJournalVolumeName(serviceUUID string) string

Apr 6, 2018

Changes in this version

type ContainerSvc

+ UpdateService func(ctx context.Context, opts *UpdateServiceOptions) error

type MemContainerSvc

+ func (m *MemContainerSvc) UpdateService(ctx context.Context, opts *UpdateServiceOptions) error

+ type UpdateServiceOptions struct

+ Cluster string

+ ExternalDNS bool

+ MaxCPUUnits *int64

+ MaxMemMB *int64

+ PortMappings []common.PortMapping

+ ReleaseVersion string

+ ReserveCPUUnits *int64

+ ReserveMemMB *int64

+ ServiceName string

Feb 28, 2018

Changes in this version

type CommonOptions

+ ServiceType string

type ContainerSvc

+ RollingRestartService func(ctx context.Context, cluster string, service string, ...) error

type MemContainerSvc

+ func (m *MemContainerSvc) RollingRestartService(ctx context.Context, cluster string, service string, ...) error

+ type RollingRestartOptions struct

+ Replicas int64

+ ServiceTasks []string

+ StatusMessage string

type VolumeOptions

+ Encrypted bool

Feb 5, 2018

Changes in this version

+ var ErrVolumeExist = errors.New("Volume Exists")

type ContainerSvc

+ CreateServiceVolume func(ctx context.Context, service string, memberIndex int64, volumeID string, ...) (existingVolumeID string, err error)

+ DeleteServiceVolume func(ctx context.Context, service string, memberIndex int64, journal bool) error

+ GetContainerSvcType func() string

type CreateServiceOptions

+ ExternalDNS bool

+ ExternalStaticIP bool

type MemContainerSvc

+ func (m *MemContainerSvc) CreateServiceVolume(ctx context.Context, service string, memberIndex int64, volumeID string, ...) (existingVolumeID string, err error)

+ func (m *MemContainerSvc) DeleteServiceVolume(ctx context.Context, service string, memberIndex int64, journal bool) error

+ func (m *MemContainerSvc) GetContainerSvcType() string

Jan 1, 2018

Changes in this version

type ContainerSvc

+ ScaleService func(ctx context.Context, cluster string, service string, desiredCount int64) error

type CreateServiceOptions

+ DataVolume *VolumeOptions

+ JournalVolume *VolumeOptions

+ KubeOptions *K8sOptions

+ type K8sOptions struct

+ ExternalDNS bool

+ InitContainerImage string

+ ServicePort int64

type MemContainerSvc

+ func (m *MemContainerSvc) ScaleService(ctx context.Context, cluster string, service string, desiredCount int64) error

+ type VolumeOptions struct

+ Iops int64

+ MountPath string

+ SizeGB int64

+ VolumeType string

Dec 6, 2017

Changes in this version

type CreateServiceOptions

+ JournalContainerPath string

Oct 27, 2017

Changes in this version

type CreateServiceOptions

+ Place *Placement

+ type Placement struct

+ Zones []string

Sep 9, 2017

Changes in this version

+ const TestBusyBoxContainerImage

+ var ErrContainerSvcNoTask = errors.New("The service has no task on the ContainerInstance")

+ var ErrContainerSvcTooManyTasks = errors.New("The service has more than one tasks on the same ContainerInstance")

+ var ErrInvalidCluster = errors.New("InvalidCluster")

+ var ErrInvalidContainerInstanceID = errors.New("InvalidContainerInstanceID")

+ func GenVolumeSourceForSwarm(serviceUUID string) string

+ func GenVolumeSourceName(serviceUUID string, index int64) string

+ func ParseVolumeSource(volName string) (string, int64, error)

+ func VolumeSourceHasTaskSlot(volName string) bool

+ type CommonOptions struct

+ Cluster string

+ ContainerImage string

+ LogConfig *cloudlog.LogConfig

+ Resource *common.Resources

+ ServiceName string

+ ServiceUUID string

+ type ContainerSvc interface

+ CreateService func(ctx context.Context, opts *CreateServiceOptions) error

+ DeleteService func(ctx context.Context, cluster string, service string) error

+ DeleteTask func(ctx context.Context, cluster string, service string, taskType string) error

+ GetServiceStatus func(ctx context.Context, cluster string, service string) (*common.ServiceStatus, error)

+ GetServiceTask func(ctx context.Context, cluster string, service string, ...) (serviceTaskID string, err error)

+ GetTaskStatus func(ctx context.Context, cluster string, taskID string) (*common.TaskStatus, error)

+ IsServiceExist func(ctx context.Context, cluster string, service string) (bool, error)

+ ListActiveServiceTasks func(ctx context.Context, cluster string, service string) (serviceTaskIDs map[string]bool, err error)

+ RestartService func(ctx context.Context, cluster string, service string, desiredCount int64) error

+ RunTask func(ctx context.Context, opts *RunTaskOptions) (taskID string, err error)

+ StopService func(ctx context.Context, cluster string, service string) error

+ type CreateServiceOptions struct

+ Common *CommonOptions

+ ContainerPath string

+ Envkvs []*common.EnvKeyValuePair

+ PortMappings []common.PortMapping

+ Replicas int64

+ type Info interface

+ GetContainerClusterID func() string

+ GetLocalContainerInstanceID func() string

+ type MemContainerSvc struct

+ func NewMemContainerSvc() *MemContainerSvc

+ func (m *MemContainerSvc) AddServiceTask(ctx context.Context, cluster string, service string, taskID string, ...) error

+ func (m *MemContainerSvc) CreateService(ctx context.Context, opts *CreateServiceOptions) error

+ func (m *MemContainerSvc) DeleteService(ctx context.Context, cluster string, service string) error

+ func (m *MemContainerSvc) DeleteTask(ctx context.Context, cluster string, service string, taskType string) error

+ func (m *MemContainerSvc) GetServiceStatus(ctx context.Context, cluster string, service string) (*common.ServiceStatus, error)

+ func (m *MemContainerSvc) GetServiceTask(ctx context.Context, cluster string, service string, ...) (taskID string, err error)

+ func (m *MemContainerSvc) GetTaskStatus(ctx context.Context, cluster string, taskID string) (*common.TaskStatus, error)

+ func (m *MemContainerSvc) IsServiceExist(ctx context.Context, cluster string, service string) (bool, error)

+ func (m *MemContainerSvc) ListActiveServiceTasks(ctx context.Context, cluster string, service string) (taskIDs map[string]bool, err error)

+ func (m *MemContainerSvc) RestartService(ctx context.Context, cluster string, service string, desiredCount int64) error

+ func (m *MemContainerSvc) RunTask(ctx context.Context, opts *RunTaskOptions) (taskID string, err error)

+ func (m *MemContainerSvc) StopService(ctx context.Context, cluster string, service string) error

+ type MockContainerSvcInfo struct

+ func NewMockContainerSvcInfo() *MockContainerSvcInfo

+ func (m *MockContainerSvcInfo) GetContainerClusterID() string

+ func (m *MockContainerSvcInfo) GetLocalContainerInstanceID() string

+ type RunTaskOptions struct

+ Common *CommonOptions

+ Envkvs []*common.EnvKeyValuePair

+ TaskType string