k8s

Documentation

Index

• func BuildClient(server string, configV1 clientcmdapiv1.Config) (*kubernetes.Clientset, *rest.Config, error)
• type CRDInterface
  • func NewCRDOperation(dyn dynamic.Interface) CRDInterface
• type CRDOperation
  • func (o *CRDOperation) Create(ctx context.Context, gvk schema.GroupVersionResource, ...) (*unstructured.Unstructured, error)
  • func (o *CRDOperation) Delete(ctx context.Context, gvk schema.GroupVersionResource, namespace, name string) error
  • func (o *CRDOperation) Get(ctx context.Context, gvk schema.GroupVersionResource, namespace, name string) (*unstructured.Unstructured, error)
  • func (o *CRDOperation) List(ctx context.Context, gvk schema.GroupVersionResource, ...) (*unstructured.UnstructuredList, error)
  • func (o *CRDOperation) Update(ctx context.Context, gvk schema.GroupVersionResource, namespace, name string, ...) (*unstructured.Unstructured, error)
• type ConfigmapInterface
  • func NewConfigmapOperation(client *kubernetes.Clientset) ConfigmapInterface
• type ConfigmapOperation
  • func (c ConfigmapOperation) Create(ctx context.Context, confMap *v1.ConfigMap) (*v1.ConfigMap, error)
  • func (c ConfigmapOperation) Delete(ctx context.Context, namespace, name string) error
  • func (c ConfigmapOperation) Get(ctx context.Context, namespace, name string) (*v1.ConfigMap, error)
  • func (c ConfigmapOperation) List(ctx context.Context, queryParam metadata.CommonQueryParameter) ([]v1.ConfigMap, error)
  • func (c ConfigmapOperation) Update(ctx context.Context, namespace, name string, configMap *v1.ConfigMap) (*v1.ConfigMap, error)
• type DeploymentInterface
  • func NewDeploymentOperation(client *kubernetes.Clientset) DeploymentInterface
• type DeploymentOperation
  • func (o DeploymentOperation) Create(ctx context.Context, deployment *appsv1.Deployment) (*appsv1.Deployment, error)
  • func (o DeploymentOperation) Get(ctx context.Context, namespace, name string) (*appsv1.Deployment, error)
  • func (o DeploymentOperation) Update(ctx context.Context, namespace, name string, deployment *appsv1.Deployment) (*appsv1.Deployment, error)
• type HorizontalPodAutoScalerInterface
  • func NewHorizontalPodAutoScalerOperation(client *kubernetes.Clientset) HorizontalPodAutoScalerInterface
• type HorizontalPodAutoScalerOperation
  • func (o *HorizontalPodAutoScalerOperation) Create(ctx context.Context, scaler *v1.HorizontalPodAutoscaler) (*v1.HorizontalPodAutoscaler, error)
  • func (o *HorizontalPodAutoScalerOperation) Delete(ctx context.Context, namespace, name string) error
  • func (o *HorizontalPodAutoScalerOperation) Get(ctx context.Context, namespace, name string) (*v1.HorizontalPodAutoscaler, error)
  • func (o *HorizontalPodAutoScalerOperation) List(ctx context.Context, queryParam metadata.CommonQueryParameter) ([]v1.HorizontalPodAutoscaler, error)
  • func (o *HorizontalPodAutoScalerOperation) Update(ctx context.Context, namespace, name string, ...) (*v1.HorizontalPodAutoscaler, error)
• type K8sClient
  • func GetClient(clusterName string) (*K8sClient, error)
• type PodFormatStatus
  • func GetFormatStatus(pod *corev1.Pod) (*PodFormatStatus, error)

Functions

func BuildClient

func BuildClient(server string, configV1 clientcmdapiv1.Config) (*kubernetes.Clientset, *rest.Config, error)

Types

type CRDInterface

type CRDInterface interface {
	Create(ctx context.Context, gvk schema.GroupVersionResource, data map[string]interface{}) (*unstructured.Unstructured, error)
	Delete(ctx context.Context, gvk schema.GroupVersionResource, namespace, name string) error
	Get(ctx context.Context, gvk schema.GroupVersionResource, namespace, name string) (*unstructured.Unstructured, error)
	List(ctx context.Context, gvk schema.GroupVersionResource, queryParam metadata.CommonQueryParameter) (*unstructured.UnstructuredList, error)
	Update(ctx context.Context, gvk schema.GroupVersionResource, namespace, name string, data map[string]interface{}) (*unstructured.Unstructured, error)
}

func NewCRDOperation

func NewCRDOperation(dyn dynamic.Interface) CRDInterface

type CRDOperation

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

func (*CRDOperation) Create

func (o *CRDOperation) Create(ctx context.Context, gvk schema.GroupVersionResource, data map[string]interface{}) (*unstructured.Unstructured, error)

func (*CRDOperation) Delete

func (o *CRDOperation) Delete(ctx context.Context, gvk schema.GroupVersionResource, namespace, name string) error

func (*CRDOperation) Get

func (o *CRDOperation) Get(ctx context.Context, gvk schema.GroupVersionResource, namespace, name string) (*unstructured.Unstructured, error)

func (*CRDOperation) List

func (o *CRDOperation) List(ctx context.Context, gvk schema.GroupVersionResource, queryParam metadata.CommonQueryParameter) (*unstructured.UnstructuredList, error)

func (*CRDOperation) Update

func (o *CRDOperation) Update(ctx context.Context, gvk schema.GroupVersionResource, namespace, name string, data map[string]interface{}) (*unstructured.Unstructured, error)

type ConfigmapInterface

type ConfigmapInterface interface {
	Create(ctx context.Context, confMap *v1.ConfigMap) (*v1.ConfigMap, error)
	List(ctx context.Context, queryParam metadata.CommonQueryParameter) ([]v1.ConfigMap, error)
	Delete(ctx context.Context, namespace, name string) error
	Get(ctx context.Context, namespace, name string) (*v1.ConfigMap, error)
	Update(ctx context.Context, namespace, name string, configMap *v1.ConfigMap) (*v1.ConfigMap, error)
}

func NewConfigmapOperation

func NewConfigmapOperation(client *kubernetes.Clientset) ConfigmapInterface

type ConfigmapOperation

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

func (ConfigmapOperation) Create

func (c ConfigmapOperation) Create(ctx context.Context, confMap *v1.ConfigMap) (*v1.ConfigMap, error)

func (ConfigmapOperation) Delete

func (c ConfigmapOperation) Delete(ctx context.Context, namespace, name string) error

func (ConfigmapOperation) Get

func (c ConfigmapOperation) Get(ctx context.Context, namespace, name string) (*v1.ConfigMap, error)

func (ConfigmapOperation) List

func (c ConfigmapOperation) List(ctx context.Context, queryParam metadata.CommonQueryParameter) ([]v1.ConfigMap, error)

func (ConfigmapOperation) Update

func (c ConfigmapOperation) Update(ctx context.Context, namespace, name string, configMap *v1.ConfigMap) (*v1.ConfigMap, error)

type DeploymentInterface

type DeploymentInterface interface {
	Get(ctx context.Context, namespace, name string) (*appsv1.Deployment, error)
	Create(ctx context.Context, deployment *appsv1.Deployment) (*appsv1.Deployment, error)
	Update(ctx context.Context, namespace, name string, deployment *appsv1.Deployment) (*appsv1.Deployment, error)
}

func NewDeploymentOperation

func NewDeploymentOperation(client *kubernetes.Clientset) DeploymentInterface

type DeploymentOperation

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

func (DeploymentOperation) Create

func (o DeploymentOperation) Create(ctx context.Context, deployment *appsv1.Deployment) (*appsv1.Deployment, error)

func (DeploymentOperation) Get

func (o DeploymentOperation) Get(ctx context.Context, namespace, name string) (*appsv1.Deployment, error)

func (DeploymentOperation) Update

func (o DeploymentOperation) Update(ctx context.Context, namespace, name string, deployment *appsv1.Deployment) (*appsv1.Deployment, error)

type HorizontalPodAutoScalerInterface

type HorizontalPodAutoScalerInterface interface {
	Create(ctx context.Context, scaler *v1.HorizontalPodAutoscaler) (*v1.HorizontalPodAutoscaler, error)
	List(ctx context.Context, queryParam metadata.CommonQueryParameter) ([]v1.HorizontalPodAutoscaler, error)
	Get(ctx context.Context, namespace, name string) (*v1.HorizontalPodAutoscaler, error)
	Update(ctx context.Context, namespace, name string, scaler *v1.HorizontalPodAutoscaler) (*v1.HorizontalPodAutoscaler, error)
	Delete(ctx context.Context, namespace, name string) error
}

func NewHorizontalPodAutoScalerOperation

func NewHorizontalPodAutoScalerOperation(client *kubernetes.Clientset) HorizontalPodAutoScalerInterface

type HorizontalPodAutoScalerOperation

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

func (*HorizontalPodAutoScalerOperation) Create

func (o *HorizontalPodAutoScalerOperation) Create(ctx context.Context, scaler *v1.HorizontalPodAutoscaler) (*v1.HorizontalPodAutoscaler, error)

func (*HorizontalPodAutoScalerOperation) Delete

func (o *HorizontalPodAutoScalerOperation) Delete(ctx context.Context, namespace, name string) error

func (*HorizontalPodAutoScalerOperation) Get

func (o *HorizontalPodAutoScalerOperation) Get(ctx context.Context, namespace, name string) (*v1.HorizontalPodAutoscaler, error)

func (*HorizontalPodAutoScalerOperation) List

func (o *HorizontalPodAutoScalerOperation) List(ctx context.Context, queryParam metadata.CommonQueryParameter) ([]v1.HorizontalPodAutoscaler, error)

func (*HorizontalPodAutoScalerOperation) Update

func (o *HorizontalPodAutoScalerOperation) Update(ctx context.Context, namespace, name string, scaler *v1.HorizontalPodAutoscaler) (*v1.HorizontalPodAutoscaler, error)

type K8sClient

type K8sClient struct {
	RestConfig *rest.Config
	ClientV1   *kubernetes.Clientset
}

func GetClient

func GetClient(clusterName string) (*K8sClient, error)

type PodFormatStatus

type PodFormatStatus struct {
	Ready  string `json:"ready"`
	Reason string `json:"reason"`
}

func GetFormatStatus

func GetFormatStatus(pod *corev1.Pod) (*PodFormatStatus, error)