k8s

Documentation

Index

• Variables
• type DeploymentManager
  • func (m *DeploymentManager) DeleteDeployment(ctx context.Context, namespace, name string) error
  • func (m *DeploymentManager) SetDeployment(ctx context.Context, namespace string, service *models.ServiceInfo, ...) error
• type K8SManager
  • func New(clientSet *kubernetes.Clientset) *K8SManager
• type NamespaceManager
  • func (m *NamespaceManager) CreateNamespace(ctx context.Context, name string) error
  • func (m *NamespaceManager) GetNamespace(ctx context.Context, name string) (*corev1.Namespace, error)
• type PodsManager
  • func (m *PodsManager) ListPods(ctx context.Context, namespace, service string) ([]*models.PodInfo, error)
• type ServiceManager
  • func (m *ServiceManager) DeleteService(ctx context.Context, namespace string, service string) error
  • func (m *ServiceManager) SetService(ctx context.Context, namespace string, service *models.ServiceInfo, ...) error

Variables

var (
	ERRDeploymentConflict = fmt.Errorf("deployment already exists")
	ERRDeploymentNotFound = fmt.Errorf("deployment not found")
)

var (
	ERRNamespaceConflict = fmt.Errorf("namespace already exists")
	ERRNamespaceNotExist = fmt.Errorf("namespace not exist")
)

var (
	ERRServiceNotFound = fmt.Errorf("service not found")
	ERRServiceConflict = fmt.Errorf("service already exists")
)

Types

type DeploymentManager

type DeploymentManager struct {
	ClientSet *kubernetes.Clientset
}

DeploymentManager impl deployment operations.

func (*DeploymentManager) DeleteDeployment

func (m *DeploymentManager) DeleteDeployment(ctx context.Context, namespace, name string) error

DeleteDeployment delete deployment.

func (*DeploymentManager) SetDeployment

func (m *DeploymentManager) SetDeployment(
	ctx context.Context,
	namespace string,
	service *models.ServiceInfo,
	versionInfo *models.ServiceVersion,
) error

SetDeployment create deployment if not exist, update if exist.

type K8SManager

type K8SManager struct {
	*NamespaceManager
	*ServiceManager
	*DeploymentManager
	*PodsManager
}

func New

func New(clientSet *kubernetes.Clientset) *K8SManager

type NamespaceManager

type NamespaceManager struct {
	ClientSet *kubernetes.Clientset
}

func (*NamespaceManager) CreateNamespace

func (m *NamespaceManager) CreateNamespace(ctx context.Context, name string) error

func (*NamespaceManager) GetNamespace

func (m *NamespaceManager) GetNamespace(ctx context.Context, name string) (*corev1.Namespace, error)

type PodsManager

type PodsManager struct {
	ClientSet *kubernetes.Clientset
}

func (*PodsManager) ListPods

func (m *PodsManager) ListPods(ctx context.Context, namespace, service string) ([]*models.PodInfo, error)

type ServiceManager

type ServiceManager struct {
	ClientSet *kubernetes.Clientset
}

ServiceManager impl service operations.

func (*ServiceManager) DeleteService

func (m *ServiceManager) DeleteService(
	ctx context.Context,
	namespace string,
	service string,
) error

func (*ServiceManager) SetService

func (m *ServiceManager) SetService(
	ctx context.Context,
	namespace string,
	service *models.ServiceInfo,
	versionInfo *models.ServiceVersion,
) error

SetService create service if not exist, update if exist.