k8s

Documentation

Index

• Constants
• type Client
  • func NewKubeClient(client client.Client, clientset k8sclientset.Interface, fieldManager string) Client
• type KubeClient
  • func (c *KubeClient) Delete(ctx context.Context, object *unstructured.Unstructured) error
  • func (c *KubeClient) DeletePVCsWithLabel(ctx context.Context, labelSelector string, ...) error
  • func (c *KubeClient) DestinationRuleCRDExists(ctx context.Context) (bool, error)
  • func (c *KubeClient) GetCRD(ctx context.Context, name string) (*apiextensionsv1.CustomResourceDefinition, error)
  • func (c *KubeClient) GetSecret(ctx context.Context, name, namespace string) (*apiv1.Secret, error)
  • func (c *KubeClient) GetStatefulSet(ctx context.Context, name, namespace string) (*appsv1.StatefulSet, error)
  • func (c *KubeClient) PatchApply(ctx context.Context, object *unstructured.Unstructured) error

Constants

const (
	// DestinationRuleCrdName defines the CRD name for DestinationRule as in Istio.
	DestinationRuleCrdName string = "destinationrules.networking.istio.io"
	// DestinationRuleKind defines the Kind name for DestinationRule as in Istio.
	DestinationRuleKind string = "DestinationRule"
	// DestinationRuleAPIVersion defines the API version for DestinationRule as in Istio.
	DestinationRuleAPIVersion string = "networking.istio.io/v1alpha3"
)

Types

type Client

type Client interface {
	PatchApply(context.Context, *unstructured.Unstructured) error
	GetStatefulSet(context.Context, string, string) (*appsv1.StatefulSet, error)
	Delete(context.Context, *unstructured.Unstructured) error
	GetSecret(context.Context, string, string) (*apiv1.Secret, error)
	GetCRD(context.Context, string) (*apiextensionsv1.CustomResourceDefinition, error)
	DestinationRuleCRDExists(context.Context) (bool, error)
	DeletePVCsWithLabel(context.Context, string, string, string) error
}

func NewKubeClient

func NewKubeClient(client client.Client, clientset k8sclientset.Interface, fieldManager string) Client

type KubeClient

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

func (*KubeClient) Delete

func (c *KubeClient) Delete(ctx context.Context, object *unstructured.Unstructured) error

func (*KubeClient) DeletePVCsWithLabel

func (c *KubeClient) DeletePVCsWithLabel(ctx context.Context, labelSelector string,
	mustHaveNamePrefix, namespace string) error

func (*KubeClient) DestinationRuleCRDExists

func (c *KubeClient) DestinationRuleCRDExists(ctx context.Context) (bool, error)

func (*KubeClient) GetCRD

func (c *KubeClient) GetCRD(ctx context.Context, name string) (*apiextensionsv1.CustomResourceDefinition, error)

func (*KubeClient) GetSecret

func (c *KubeClient) GetSecret(ctx context.Context, name, namespace string) (*apiv1.Secret, error)

func (*KubeClient) GetStatefulSet

func (c *KubeClient) GetStatefulSet(ctx context.Context, name, namespace string) (*appsv1.StatefulSet, error)

func (*KubeClient) PatchApply

func (c *KubeClient) PatchApply(ctx context.Context, object *unstructured.Unstructured) error