Documentation
¶
Index ¶
- Variables
- type K8sSvc
- 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
Constants ¶
This section is empty.
Variables ¶
var ( // ErrVolumeExist means PersistentVolume exists ErrVolumeExist = errors.New("PersistentVolume Exists") // ErrVolumeClaimExist means PersistentVolumeClaim exists ErrVolumeClaimExist = errors.New("PersistentVolumeClaim Exists") )
Functions ¶
This section is empty.
Types ¶
type K8sSvc ¶
type K8sSvc struct {
// contains filtered or unexported fields
}
K8sSvc implements the containersvc interface for kubernetes. https://kubernetes.io/docs/tasks/access-application-cluster/access-cluster
func NewK8sSvcWithConfig ¶
func NewK8sSvcWithConfig(cloudPlatform string, namespace string, config *rest.Config) (*K8sSvc, error)
NewK8sSvcWithConfig creates a new K8sSvc instance with the config.
func (*K8sSvc) CreatePV ¶
func (s *K8sSvc) CreatePV(ctx context.Context, service string, pvname string, sclassname string, volID string, volSizeGB int64, fsType string) (*corev1.PersistentVolume, error)
CreatePV creates a PersistentVolume.
func (*K8sSvc) CreatePVC ¶
func (s *K8sSvc) CreatePVC(ctx context.Context, service string, pvcname string, pvname string, sclassname string, volSizeGB int64) (*corev1.PersistentVolumeClaim, error)
CreatePVC creates a PersistentVolumeClaim.
func (*K8sSvc) CreateService ¶
func (s *K8sSvc) CreateService(ctx context.Context, opts *containersvc.CreateServiceOptions) error
CreateService creates the headless service, storage class and statefulset.
func (*K8sSvc) DeleteService ¶
DeleteService deletes the service on the container platform. Expect no error (nil) if service does not exist.
func (*K8sSvc) DeleteTask ¶
func (s *K8sSvc) DeleteTask(ctx context.Context, cluster string, service string, taskType string) error
DeleteTask deletes the task.
func (*K8sSvc) GetServiceStatus ¶
func (s *K8sSvc) GetServiceStatus(ctx context.Context, cluster string, service string) (*common.ServiceStatus, error)
GetServiceStatus returns the service status.
func (*K8sSvc) GetServiceTask ¶
func (s *K8sSvc) GetServiceTask(ctx context.Context, cluster string, service string, containerInstanceID string) (serviceTaskID string, err error)
GetServiceTask gets the service task on the container instance.
func (*K8sSvc) GetTaskStatus ¶
func (s *K8sSvc) GetTaskStatus(ctx context.Context, cluster string, taskID string) (*common.TaskStatus, error)
GetTaskStatus gets the task status.
func (*K8sSvc) IsServiceExist ¶
IsServiceExist checks if service exists. If not exist, return false & nil. If exists, return true & nil. If meets any error, error will be returned.
func (*K8sSvc) ListActiveServiceTasks ¶
func (s *K8sSvc) ListActiveServiceTasks(ctx context.Context, cluster string, service string) (serviceTaskIDs map[string]bool, err error)
ListActiveServiceTasks lists the active (pending and running) tasks of the service.
func (*K8sSvc) RunTask ¶
func (s *K8sSvc) RunTask(ctx context.Context, opts *containersvc.RunTaskOptions) (taskID string, err error)
RunTask runs a task.
Source Files
Directories