kubernetesclient

Documentation

Index

• Variables
• type K8SClient
  • func NewK8SClient(kubeconfig string) (*K8SClient, error)
  • func (k *K8SClient) GetCluster(ctx context.Context, name, namespace string) (*clustercrd.Cluster, error)
  • func (k *K8SClient) GetSecret(ctx context.Context, name, namespace string) (*v1.Secret, error)
  • func (k *K8SClient) GetServiceAccount(ctx context.Context, name, namespace string) (*v1.ServiceAccount, error)
  • func (k *K8SClient) ListStatefulSets(ctx context.Context, namespace string, opts metav1.ListOptions) (*appsv1.StatefulSetList, error)
  • func (k *K8SClient) UpdateCluster(ctx context.Context, cluster *clustercrd.Cluster) error
  • func (k *K8SClient) UpdateStatusCluster(ctx context.Context, cluster *clustercrd.Cluster) error

Variables

var (
	ClusterGroupResrource = schema.GroupVersionResource{
		Group:    clustercrd.GroupVersion.Group,
		Version:  clustercrd.GroupVersion.Version,
		Resource: "clusters",
	}
)

Types

type K8SClient

type K8SClient struct {
	kubernetes.Clientset
	Dynamic dynamic.Interface
}

func NewK8SClient

func NewK8SClient(kubeconfig string) (*K8SClient, error)

func (*K8SClient) GetCluster

func (k *K8SClient) GetCluster(ctx context.Context, name, namespace string) (*clustercrd.Cluster, error)

func (*K8SClient) GetSecret

func (k *K8SClient) GetSecret(ctx context.Context, name, namespace string) (*v1.Secret, error)

func (*K8SClient) GetServiceAccount

func (k *K8SClient) GetServiceAccount(ctx context.Context, name, namespace string) (*v1.ServiceAccount, error)

func (*K8SClient) ListStatefulSets

func (k *K8SClient) ListStatefulSets(ctx context.Context, namespace string, opts metav1.ListOptions) (*appsv1.StatefulSetList, error)

func (*K8SClient) UpdateCluster

func (k *K8SClient) UpdateCluster(ctx context.Context, cluster *clustercrd.Cluster) error

func (*K8SClient) UpdateStatusCluster

func (k *K8SClient) UpdateStatusCluster(ctx context.Context, cluster *clustercrd.Cluster) error