k8s

package
v1.12.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 11, 2020 License: Apache-2.0 Imports: 26 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type K8sAPIVersion 

type K8sAPIVersion string

K8sAPIVersion represents valid kubernetes api version of a native or custom resource 

const (
	// ExtensionsV1Beta1KA is the extensions/v1beta API
	ExtensionsV1Beta1KA K8sAPIVersion = "extensions/v1beta1"

	// AppsV1KA refers to kubernetes API version
	// apps/v1
	AppsV1KA K8sAPIVersion = "apps/v1"

	// AppsV1B1KA is the apps/v1beta1 API
	AppsV1B1KA K8sAPIVersion = "apps/v1beta1"

	// CoreV1KA is the v1 API
	CoreV1KA K8sAPIVersion = "v1"

	// OEV1alpha1KA is the openebs.io/v1alpha1 API
	OEV1alpha1KA K8sAPIVersion = "openebs.io/v1alpha1"

	// StorageV1KA is the storage.k8s.io/v1 API
	StorageV1KA K8sAPIVersion = "storage.k8s.io/v1"

	BatchV1KA K8sAPIVersion = "batch/v1"
)

type K8sClient 

type K8sClient struct {

	// PV refers to a K8s PersistentVolume object
	PV *api_core_v1.PersistentVolume

	// PVC refers to a K8s PersistentVolumeClaim object
	// NOTE: This property enables unit testing
	PVC *api_core_v1.PersistentVolumeClaim

	// Pod refers to a K8s Pod object
	// NOTE: This property enables unit testing
	Pod *api_core_v1.Pod

	// Service refers to a K8s Service object
	// NOTE: This property enables unit testing
	Service *api_core_v1.Service

	// ConfigMap refers to a K8s Service object
	// NOTE: This property enables unit testing
	ConfigMap *api_core_v1.ConfigMap

	// Deployment refers to a K8s Deployment object
	// NOTE: This property enables unit testing
	Deployment *api_extn_v1beta1.Deployment

	// StorageClass refers to a K8s StorageClass object
	// NOTE: This property is useful to mock
	// during unit testing
	StorageClass *api_storage_v1.StorageClass

	// BlockDevice refers to a K8s BlockDevice CRD object
	// NOTE: This property is useful to mock
	// during unit testing
	BlockDevice *api_ndm_v1alpha1.BlockDevice

	// StoragePoolClaim refers to a K8s StoragePoolClaim CRD object
	// NOTE: This property is useful to mock
	// during unit testing
	StoragePoolClaim *api_oe_v1alpha1.StoragePoolClaim

	// CStorPoolCluster refers to a K8s CStorPoolCluster CRD object
	// NOTE: This property is useful to mock
	// during unit testing
	CStorPoolCluster *api_oe_v1alpha1.CStorPoolCluster

	// StoragePool refers to a K8s StoragePool CRD object
	// NOTE: This property is useful to mock
	// during unit testing
	StoragePool *api_oe_v1alpha1.StoragePool

	// CStorPool refers to a K8s CStorPool CRD object
	// NOTE: This property is useful to mock
	// during unit testing
	CStorPool *api_oe_v1alpha1.CStorPool

	// CStorVolume refers to a K8s CStorVolume CRD object
	// NOTE: This property is useful to mock
	// during unit testing
	CStorVolume *api_oe_v1alpha1.CStorVolume

	// CStorVolumeReplica refers to a K8s CStorVolumeReplica CRD object
	// NOTE: This property is useful to mock
	// during unit testing
	CStorVolumeReplica *api_oe_v1alpha1.CStorVolumeReplica

	// CASTemplate refers to a K8s CASTemplate custom resource
	// NOTE: This property is useful to mock
	// during unit testing
	CASTemplate *api_oe_v1alpha1.CASTemplate
	// contains filtered or unexported fields
}

K8sClient provides the necessary utility to operate over various K8s Kind objects

func NewK8sClient 

func NewK8sClient(ns string) (*K8sClient, error)

NewK8sClient creates a new K8sClient

func (*K8sClient) CreateAppsV1B1Deployment 

func (k *K8sClient) CreateAppsV1B1Deployment(d *api_apps_v1beta1.Deployment) (*api_apps_v1beta1.Deployment, error)

CreateAppsV1B1Deployment creates the K8s Deployment with the provided name

func (*K8sClient) CreateAppsV1B1DeploymentAsRaw 

func (k *K8sClient) CreateAppsV1B1DeploymentAsRaw(d *api_apps_v1beta1.Deployment) (result []byte, err error)

CreateAppsV1B1DeploymentAsRaw creates a K8s Deployment

func (*K8sClient) CreateAppsV1Deployment 

func (k *K8sClient) CreateAppsV1Deployment(d *api_apps_v1.Deployment) (*api_apps_v1.Deployment, error)

CreateAppsV1Deployment creates the K8s Deployment with the provided name

func (*K8sClient) CreateAppsV1DeploymentAsRaw 

func (k *K8sClient) CreateAppsV1DeploymentAsRaw(d *api_apps_v1.Deployment) (result []byte, err error)

CreateAppsV1DeploymentAsRaw creates a K8s Deployment based on apps/v1 apiVersion

func (*K8sClient) CreateAppsV1STSAsRaw 

func (k *K8sClient) CreateAppsV1STSAsRaw(sts *api_apps_v1.StatefulSet) ([]byte, error)

CreateAppsV1STSAsRaw creates a kubernetes StatefulSet

func (*K8sClient) CreateBatchV1JobAsRaw 

func (k *K8sClient) CreateBatchV1JobAsRaw(j *api_batch_v1.Job) ([]byte, error)

CreateBatchV1JobAsRaw creates a kubernetes Job

func (*K8sClient) CreateCoreV1Service 

func (k *K8sClient) CreateCoreV1Service(svc *api_core_v1.Service) (*api_core_v1.Service, error)

CreateCoreV1Service creates a K8s Service

func (*K8sClient) CreateCoreV1ServiceAsRaw 

func (k *K8sClient) CreateCoreV1ServiceAsRaw(s *api_core_v1.Service) (result []byte, err error)

CreateCoreV1ServiceAsRaw creates a K8s Service

func (*K8sClient) CreateExtnV1B1Deployment 

func (k *K8sClient) CreateExtnV1B1Deployment(d *api_extn_v1beta1.Deployment) (*api_extn_v1beta1.Deployment, error)

CreateExtnV1B1Deployment creates a K8s Deployment

func (*K8sClient) CreateExtnV1B1DeploymentAsRaw 

func (k *K8sClient) CreateExtnV1B1DeploymentAsRaw(d *api_extn_v1beta1.Deployment) (result []byte, err error)

CreateExtnV1B1DeploymentAsRaw creates a K8s Deployment

func (*K8sClient) CreateOEV1alpha1CSP 

func (k *K8sClient) CreateOEV1alpha1CSP(csp *api_oe_v1alpha1.CStorPool) (*api_oe_v1alpha1.CStorPool, error)

CreateOEV1alpha1CSP creates a CStorPool

func (*K8sClient) CreateOEV1alpha1CSPAsRaw 

func (k *K8sClient) CreateOEV1alpha1CSPAsRaw(v *api_oe_v1alpha1.CStorPool) (result []byte, err error)

CreateOEV1alpha1CSPAsRaw creates a CStorVolume

func (*K8sClient) CreateOEV1alpha1CV 

func (k *K8sClient) CreateOEV1alpha1CV(cv *api_oe_v1alpha1.CStorVolume) (*api_oe_v1alpha1.CStorVolume, error)

CreateOEV1alpha1CV creates a CStorVolume

func (*K8sClient) CreateOEV1alpha1CVAsRaw 

func (k *K8sClient) CreateOEV1alpha1CVAsRaw(v *api_oe_v1alpha1.CStorVolume) (result []byte, err error)

CreateOEV1alpha1CVAsRaw creates a CStorVolume

func (*K8sClient) CreateOEV1alpha1CVR 

func (k *K8sClient) CreateOEV1alpha1CVR(cvr *api_oe_v1alpha1.CStorVolumeReplica) (*api_oe_v1alpha1.CStorVolumeReplica, error)

CreateOEV1alpha1CVR creates a CStorVolumeReplica

func (*K8sClient) CreateOEV1alpha1CVRAsRaw 

func (k *K8sClient) CreateOEV1alpha1CVRAsRaw(vr *api_oe_v1alpha1.CStorVolumeReplica) (result []byte, err error)

CreateOEV1alpha1CVRAsRaw creates a CStorVolumeReplica

func (*K8sClient) CreateOEV1alpha1SP 

func (k *K8sClient) CreateOEV1alpha1SP(sp *api_oe_v1alpha1.StoragePool) (*api_oe_v1alpha1.StoragePool, error)

CreateOEV1alpha1SP creates a StoragePool

func (*K8sClient) CreateOEV1alpha1SPAsRaw 

func (k *K8sClient) CreateOEV1alpha1SPAsRaw(v *api_oe_v1alpha1.StoragePool) (result []byte, err error)

CreateOEV1alpha1SPAsRaw creates a StoragePool

func (*K8sClient) DeleteAppsV1B1Deployment 

func (k *K8sClient) DeleteAppsV1B1Deployment(name string) error

DeleteAppsV1B1Deployment deletes the K8s Deployment with the provided name

func (*K8sClient) DeleteAppsV1Deployment 

func (k *K8sClient) DeleteAppsV1Deployment(name string) error

DeleteAppsV1Deployment deletes the K8s Deployment with the provided name

func (*K8sClient) DeleteAppsV1STS 

func (k *K8sClient) DeleteAppsV1STS(name string) error

DeleteAppsV1STS deletes a kubernetes StatefulSet object

func (*K8sClient) DeleteBatchV1Job 

func (k *K8sClient) DeleteBatchV1Job(name string) error

DeleteBatchV1Job deletes a K8s job

func (*K8sClient) DeleteCoreV1Service 

func (k *K8sClient) DeleteCoreV1Service(name string) error

DeleteCoreV1Service deletes a K8s Service

func (*K8sClient) DeleteExtnV1B1Deployment 

func (k *K8sClient) DeleteExtnV1B1Deployment(name string) error

DeleteExtnV1B1Deployment deletes the K8s Deployment with the provided name

func (*K8sClient) DeleteOEV1alpha1CSP 

func (k *K8sClient) DeleteOEV1alpha1CSP(name string) error

DeleteOEV1alpha1CSP deletes the CStorPool with the provided name

func (*K8sClient) DeleteOEV1alpha1CSV 

func (k *K8sClient) DeleteOEV1alpha1CSV(name string) error

DeleteOEV1alpha1CSV deletes the CStorVolume with the provided name

func (*K8sClient) DeleteOEV1alpha1CVR 

func (k *K8sClient) DeleteOEV1alpha1CVR(name string) error

DeleteOEV1alpha1CVR deletes the CStorVolumeReplica with the provided name

func (*K8sClient) DeleteOEV1alpha1SP 

func (k *K8sClient) DeleteOEV1alpha1SP(name string) error

DeleteOEV1alpha1SP deletes the StoragePool with the provided name

func (*K8sClient) GetAppsV1B1Deployment 

func (k *K8sClient) GetAppsV1B1Deployment(name string, opts mach_apis_meta_v1.GetOptions) (*api_apps_v1beta1.Deployment, error)

GetAppsV1B1Deployment fetches the K8s Deployment with the provided name

func (*K8sClient) GetAppsV1B1DeploymentAsRaw 

func (k *K8sClient) GetAppsV1B1DeploymentAsRaw(name string) (result []byte, err error)

GetAppsV1B1DeploymentAsRaw fetches the K8s Deployment with the provided name

func (*K8sClient) GetBatchV1JobAsRaw 

func (k *K8sClient) GetBatchV1JobAsRaw(name string) (result []byte, err error)

GetBatchV1JobAsRaw returns a Job instance

func (*K8sClient) GetConfigMap 

func (k *K8sClient) GetConfigMap(name string, opts mach_apis_meta_v1.GetOptions) (*api_core_v1.ConfigMap, error)

GetConfigMap fetches the K8s ConfigMap with the provided name

func (*K8sClient) GetCoreV1PVCAsRaw 

func (k *K8sClient) GetCoreV1PVCAsRaw(name string) (result []byte, err error)

GetCoreV1PVCAsRaw fetches the K8s PVC with the provided name

func (*K8sClient) GetCoreV1PersistentVolumeAsRaw 

func (k *K8sClient) GetCoreV1PersistentVolumeAsRaw(name string) (result []byte, err error)

GetCoreV1PersistentVolumeAsRaw fetches the K8s PersistentVolume with the provided name

func (*K8sClient) GetDeployment 

func (k *K8sClient) GetDeployment(name string, opts mach_apis_meta_v1.GetOptions) (*api_extn_v1beta1.Deployment, error)

GetDeployment fetches the K8s Deployment with the provided name

func (*K8sClient) GetExtnV1B1DeploymentAsRaw 

func (k *K8sClient) GetExtnV1B1DeploymentAsRaw(name string) (result []byte, err error)

GetExtnV1B1DeploymentAsRaw fetches the K8s Deployment with the provided name

func (*K8sClient) GetKCS 

func (k *K8sClient) GetKCS() *kubernetes.Clientset

GetKCS is a getter method for fetching kubernetes clientset as the kubernetes clientset is not exported.

func (*K8sClient) GetNDMCS 

func (k *K8sClient) GetNDMCS() *ndm.Clientset

GetNDMCS is a getter method for fetching ndm clientset as the ndm clientset is not exported.

func (*K8sClient) GetOECS 

func (k *K8sClient) GetOECS() *openebs.Clientset

GetOECS is a getter method for fetching openebs clientset as the openebs clientset is not exported.

func (*K8sClient) GetOEV1alpha1BlockDevice 

func (k *K8sClient) GetOEV1alpha1BlockDevice(name string) (*api_ndm_v1alpha1.BlockDevice, error)

GetOEV1alpha1BlockDevice fetches the disk specs based on the provided name

func (*K8sClient) GetOEV1alpha1BlockDeviceAsRaw 

func (k *K8sClient) GetOEV1alpha1BlockDeviceAsRaw(name string) (result []byte, err error)

GetOEV1alpha1BlockDeviceAsRaw fetches the OpenEBS Disk with the provided name

func (*K8sClient) GetOEV1alpha1CAST 

func (k *K8sClient) GetOEV1alpha1CAST(name string, opts mach_apis_meta_v1.GetOptions) (*api_oe_v1alpha1.CASTemplate, error)

GetOEV1alpha1CAST fetches the OpenEBS CASTemplate specs based on the provided name

func (*K8sClient) GetOEV1alpha1CSP 

func (k *K8sClient) GetOEV1alpha1CSP(name string) (*api_oe_v1alpha1.CStorPool, error)

GetOEV1alpha1CSP fetches the OpenEBS CStorPool specs based on the provided name

func (*K8sClient) GetOEV1alpha1CSPAsRaw 

func (k *K8sClient) GetOEV1alpha1CSPAsRaw(name string) (result []byte, err error)

GetOEV1alpha1CSPAsRaw fetches the OpenEBS CSP with the provided name

func (*K8sClient) GetOEV1alpha1CSPC 

func (k *K8sClient) GetOEV1alpha1CSPC(name string) (*api_oe_v1alpha1.CStorPoolCluster, error)

GetOEV1alpha1CSPC fetches the OpenEBS CStorPoolCluster specs based on the provided name

func (*K8sClient) GetOEV1alpha1CSPCAsRaw 

func (k *K8sClient) GetOEV1alpha1CSPCAsRaw(name string) (result []byte, err error)

GetOEV1alpha1CSPCAsRaw fetches the OpenEBS CSPC with the provided name

func (*K8sClient) GetOEV1alpha1CV 

func (k *K8sClient) GetOEV1alpha1CV(name string) (*api_oe_v1alpha1.CStorVolume, error)

GetOEV1alpha1CV fetches the OpenEBS CStorVolume specs based on the provided name

func (*K8sClient) GetOEV1alpha1CVR 

func (k *K8sClient) GetOEV1alpha1CVR(name string) (*api_oe_v1alpha1.CStorVolumeReplica, error)

GetOEV1alpha1CVR fetches the OpenEBS CStorVolumeReplica specs based on the provided name

func (*K8sClient) GetOEV1alpha1RunTask 

func (k *K8sClient) GetOEV1alpha1RunTask(name string, opts mach_apis_meta_v1.GetOptions) (*api_oe_v1alpha1.RunTask, error)

GetOEV1alpha1RunTask fetches the OpenEBS CASTemplate specs based on the provided name

func (*K8sClient) GetOEV1alpha1SP 

func (k *K8sClient) GetOEV1alpha1SP(name string) (*api_oe_v1alpha1.StoragePool, error)

GetOEV1alpha1SP fetches the OpenEBS StoragePool specs based on the provided name

func (*K8sClient) GetOEV1alpha1SPAsRaw 

func (k *K8sClient) GetOEV1alpha1SPAsRaw(name string) (result []byte, err error)

GetOEV1alpha1SPAsRaw fetches the OpenEBS SP with the provided name

func (*K8sClient) GetOEV1alpha1SPC 

func (k *K8sClient) GetOEV1alpha1SPC(name string) (*api_oe_v1alpha1.StoragePoolClaim, error)

GetOEV1alpha1SPC fetches the OpenEBS StoragePoolClaim specs based on the provided name

func (*K8sClient) GetOEV1alpha1SPCAsRaw 

func (k *K8sClient) GetOEV1alpha1SPCAsRaw(name string) (result []byte, err error)

GetOEV1alpha1SPCAsRaw fetches the OpenEBS SPC with the provided name

func (*K8sClient) GetPV 

func (k *K8sClient) GetPV(name string, opts mach_apis_meta_v1.GetOptions) (*api_core_v1.PersistentVolume, error)

GetPV fetches the K8s PV with the provided name

func (*K8sClient) GetPVC 

func (k *K8sClient) GetPVC(name string, opts mach_apis_meta_v1.GetOptions) (*api_core_v1.PersistentVolumeClaim, error)

GetPVC fetches the K8s PVC with the provided name

func (*K8sClient) GetPod 

func (k *K8sClient) GetPod(name string, opts mach_apis_meta_v1.GetOptions) (*api_core_v1.Pod, error)

GetPod fetches the K8s Pod with the provided name

func (*K8sClient) GetPods 

func (k *K8sClient) GetPods() ([]api_core_v1.Pod, error)

GetPods fetches the K8s Pods

func (*K8sClient) GetService 

func (k *K8sClient) GetService(name string, opts mach_apis_meta_v1.GetOptions) (*api_core_v1.Service, error)

GetService fetches the K8s Service with the provided name

func (*K8sClient) GetStorageV1SC 

func (k *K8sClient) GetStorageV1SC(name string, opts mach_apis_meta_v1.GetOptions) (*api_storage_v1.StorageClass, error)

GetStorageV1SC fetches the K8s StorageClass specs based on the provided name

func (*K8sClient) GetStorageV1SCAsRaw 

func (k *K8sClient) GetStorageV1SCAsRaw(name string) (result []byte, err error)

GetStorageV1SCAsRaw returns a StorageClass instance

func (*K8sClient) ListAppsV1B1DeploymentAsRaw 

func (k *K8sClient) ListAppsV1B1DeploymentAsRaw(opts mach_apis_meta_v1.ListOptions) (result []byte, err error)

ListAppsV1B1DeploymentAsRaw fetches a list of K8s Deployments as per the provided options

func (*K8sClient) ListAppsV1DeploymentAsRaw 

func (k *K8sClient) ListAppsV1DeploymentAsRaw(opts mach_apis_meta_v1.ListOptions) (result []byte, err error)

ListAppsV1DeploymentAsRaw fetches a list of K8s apps/v1 Deployments as per the provided options

func (*K8sClient) ListCoreV1PVAsRaw 

func (k *K8sClient) ListCoreV1PVAsRaw(opts mach_apis_meta_v1.ListOptions) (result []byte, err error)

ListCoreV1PVAsRaw fetches a list of K8s PVs with the provided options

func (*K8sClient) ListCoreV1PVCAsRaw 

func (k *K8sClient) ListCoreV1PVCAsRaw(opts mach_apis_meta_v1.ListOptions) (result []byte, err error)

ListCoreV1PVCAsRaw fetches a list of K8s PVCs with the provided options

func (*K8sClient) ListCoreV1PodAsRaw 

func (k *K8sClient) ListCoreV1PodAsRaw(opts mach_apis_meta_v1.ListOptions) (result []byte, err error)

ListCoreV1PodAsRaw fetches a list of K8s Pods as per the provided options

func (*K8sClient) ListCoreV1ServiceAsRaw 

func (k *K8sClient) ListCoreV1ServiceAsRaw(opts mach_apis_meta_v1.ListOptions) (result []byte, err error)

ListCoreV1ServiceAsRaw fetches a list of K8s Services as per the provided options

func (*K8sClient) ListExtnV1B1DeploymentAsRaw 

func (k *K8sClient) ListExtnV1B1DeploymentAsRaw(opts mach_apis_meta_v1.ListOptions) (result []byte, err error)

ListExtnV1B1DeploymentAsRaw fetches a list of K8s Deployments as per the provided options

func (*K8sClient) ListOEV1alpha1BlockDeviceRaw 

func (k *K8sClient) ListOEV1alpha1BlockDeviceRaw(opts mach_apis_meta_v1.ListOptions) (result []byte, err error)

ListOEV1alpha1BlockDeviceRaw fetches a list of BlockDevices as per the provided options

func (*K8sClient) ListOEV1alpha1CSPRaw 

func (k *K8sClient) ListOEV1alpha1CSPRaw(opts mach_apis_meta_v1.ListOptions) (result []byte, err error)

ListOEV1alpha1CSPRaw fetches a list of CStorPool as per the provided options

func (*K8sClient) ListOEV1alpha1CVRRaw 

func (k *K8sClient) ListOEV1alpha1CVRRaw(opts mach_apis_meta_v1.ListOptions) (result []byte, err error)

ListOEV1alpha1CVRRaw fetches a list of CStorVolumeReplica as per the provided options

func (*K8sClient) ListOEV1alpha1CVRaw 

func (k *K8sClient) ListOEV1alpha1CVRaw(opts mach_apis_meta_v1.ListOptions) (result []byte, err error)

ListOEV1alpha1CVRaw fetches a list of CStorVolume as per the provided options

func (*K8sClient) ListOEV1alpha1SPRaw 

func (k *K8sClient) ListOEV1alpha1SPRaw(opts mach_apis_meta_v1.ListOptions) (result []byte, err error)

ListOEV1alpha1SPRaw fetches a list of StoragePool as per the provided options

func (*K8sClient) PatchAppsV1DeploymentAsRaw 

func (k *K8sClient) PatchAppsV1DeploymentAsRaw(name string, patchType types.PatchType, patches []byte) (result []byte, err error)

PatchAppsV1DeploymentAsRaw patches the K8s Deployment with the provided patches

func (*K8sClient) PatchCoreV1ServiceAsRaw 

func (k *K8sClient) PatchCoreV1ServiceAsRaw(name string, patchType types.PatchType, patches []byte) (result []byte, err error)

PatchCoreV1ServiceAsRaw patches the K8s Service with the provided patches

func (*K8sClient) PatchExtnV1B1Deployment 

func (k *K8sClient) PatchExtnV1B1Deployment(name string, patchType types.PatchType, patches []byte) (*api_extn_v1beta1.Deployment, error)

PatchExtnV1B1Deployment patches the K8s Deployment with the provided patches

func (*K8sClient) PatchExtnV1B1DeploymentAsRaw 

func (k *K8sClient) PatchExtnV1B1DeploymentAsRaw(name string, patchType types.PatchType, patches []byte) (result []byte, err error)

PatchExtnV1B1DeploymentAsRaw patches the K8s Deployment with the provided patches

func (*K8sClient) PatchOEV1alpha1CSPCAsRaw 

func (k *K8sClient) PatchOEV1alpha1CSPCAsRaw(name string, patchType types.PatchType, patches []byte) (result *api_oe_v1alpha1.CStorPoolCluster, err error)

PatchOEV1alpha1CSPCAsRaw patches the CSPC object with the provided patches

func (*K8sClient) PatchOEV1alpha1CSV 

func (k *K8sClient) PatchOEV1alpha1CSV(name, namespace string, patchType types.PatchType, patches []byte) (result *api_oe_v1alpha1.CStorVolume, err error)

PatchOEV1alpha1CSV patches the CSV object with the provided patches

func (*K8sClient) PatchOEV1alpha1CVR 

func (k *K8sClient) PatchOEV1alpha1CVR(name, namespace string, patchType types.PatchType, patches []byte) (result *api_oe_v1alpha1.CStorVolumeReplica, err error)

PatchOEV1alpha1CVR patches the CVR object with the provided patches

func (*K8sClient) PatchOEV1alpha1SPCAsRaw 

func (k *K8sClient) PatchOEV1alpha1SPCAsRaw(name string, patchType types.PatchType, patches []byte) (result *api_oe_v1alpha1.StoragePoolClaim, err error)

PatchOEV1alpha1SPCAsRaw patches the SPC object with the provided patches

type K8sKind 

type K8sKind string

K8sKind represents the Kinds understood by Kubernetes 

const (
	// STSKK refers to Kubernetes StatefulSet kind
	STSKK K8sKind = "StatefulSet"

	// JobKK is a Kubernetes Job kind
	JobKK K8sKind = "Job"

	// StorageClassKK is a K8s StorageClass Kind
	StorageClassKK K8sKind = "StorageClass"

	// PodKK is a K8s Pod Kind
	PodKK K8sKind = "Pod"

	// DeploymentKK is a K8s Deployment Kind
	DeploymentKK K8sKind = "Deployment"

	// ReplicaSetKK is a K8s ReplicaSet Kind
	ReplicaSetKK K8sKind = "ReplicaSet"

	// ConfigMapKK is a K8s ConfigMap Kind
	ConfigMapKK K8sKind = "ConfigMap"

	// ServiceKK is a K8s Service Kind
	ServiceKK K8sKind = "Service"

	// CRDKK is a K8s CustomResourceDefinition Kind
	CRDKK K8sKind = "CustomResourceDefinition"

	// StroagePoolCRKK is a K8s CR of kind StoragePool
	StroagePoolCRKK K8sKind = "StoragePool"

	// StroagePoolClaimCRKK is a K8s CR of kind StoragePool
	StroagePoolClaimCRKK K8sKind = "StoragePoolClaim"

	// CStorPoolClusterCRKK is a K8s CR of kind CStorPoolCluster
	CStorPoolClusterCRKK K8sKind = "CStorPoolCluster"

	// PersistentVolumeKK is K8s PersistentVolume Kind
	PersistentVolumeKK K8sKind = "PersistentVolume"

	// PersistentVolumeClaimKK is a K8s PersistentVolumeClaim Kind
	PersistentVolumeClaimKK K8sKind = "PersistentVolumeClaim"

	// CstorPoolCRKK is a K8s CR of kind CStorPool
	CStorPoolCRKK K8sKind = "CStorPool"

	// DiskCRKK is a K8s CR of kind Disk
	DiskCRKK K8sKind = "Disk"

	// BlockDeviceCRKK is a K8s CR of kind BlockDevice
	BlockDeviceCRKK K8sKind = "BlockDevice"

	// CstorVolumeCRKK is a K8s CR of kind CStorVolume
	CStorVolumeCRKK K8sKind = "CStorVolume"

	// CstorVolumeReplicaCRKK is a K8s CR of kind CStorVolumeReplica
	CStorVolumeReplicaCRKK K8sKind = "CStorVolumeReplica"

	// UpgradeResultCRKK is a K8s CR of kind UpgradeResult
	UpgradeResultCRKK K8sKind = "UpgradeResult"

	// VolumeSnapshotDataCRKK is a K8s CR of kind VolumeSnapshotData
	VolumeSnapshotDataCRKK K8sKind = "VolumeSnapshotData"

	// VolumeSnapshotCRKK is a K8s CR of kind VolumeSnapshotData
	VolumeSnapshotCRKK K8sKind = "VolumeSnapshot"
)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.