k8ssvc

package

Go to main page

Versions in this module

v0

v0.9.6

May 8, 2018

v0.9.5

Apr 6, 2018

Changes in this version

type K8sSvc

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

v0.9.4

Feb 28, 2018

Changes in this version

+ func GetStatefulSetPodNames(service string, replicas int64, backward bool) []string

type K8sSvc

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

v0.9.3

Feb 5, 2018

Changes in this version

+ const EnvInitContainerCluster

+ const EnvInitContainerPodName

+ const EnvInitContainerServiceName

+ const EnvInitContainerTestMode

+ const K8sServiceInitContainerImage

+ const K8sServiceStopContainerImage

+ func CreateStaticIPFile(ip string) error

+ func IsStaticIPFileExist() (bool, error)

+ func ReadStaticIP() (ip string, err error)

+ type K8sInfo struct

+ func NewK8sInfo(clustername string, fullhostname string) *K8sInfo

+ func (s *K8sInfo) GetContainerClusterID() string

+ func (s *K8sInfo) GetLocalContainerInstanceID() string

type K8sSvc

+ func NewTestK8sSvc(cluster string, cloudPlatform string, namespace string, config *rest.Config) (*K8sSvc, error)

+ func (s *K8sSvc) CreateReplicaSet(ctx context.Context, opts *containersvc.CreateServiceOptions) error

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

+ func (s *K8sSvc) DeleteReplicaSet(ctx context.Context, service string) error

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

+ func (s *K8sSvc) GetContainerSvcType() string

v0.9.2

Jan 1, 2018

Changes in this version

+ var ErrVolumeClaimExist = errors.New("PersistentVolumeClaim Exists")

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

+ type K8sSvc struct

+ func NewK8sSvc(cloudPlatform string, namespace string) (*K8sSvc, error)

+ func NewK8sSvcWithConfig(cloudPlatform string, namespace string, config *rest.Config) (*K8sSvc, error)

+ func (s *K8sSvc) CreatePV(ctx context.Context, service string, pvname string, sclassname string, ...) (*corev1.PersistentVolume, error)

+ func (s *K8sSvc) CreatePVC(ctx context.Context, service string, pvcname string, pvname string, ...) (*corev1.PersistentVolumeClaim, error)

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

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

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

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

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

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

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

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

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

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

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

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