client

Documentation

Index

• func GetPodCondition(status *corev1.PodStatus, conditionType corev1.PodConditionType) (int, *corev1.PodCondition)
• func GetPodConditionFromList(conditions []corev1.PodCondition, conditionType corev1.PodConditionType) (int, *corev1.PodCondition)
• func GetStringSliceValue(u *unstructured.Unstructured, defValue []string, fldPath ...string) []string
• func GetStringValue(u *unstructured.Unstructured, defValue string, fldPath ...string) string
• type KubeClient
  • func NewKubeClient(ctx context.Context, cs kubernetes.Interface, dc dynamic.Interface, ...) *KubeClient
  • func (client *KubeClient) GetDriverConfiguration(volDetails common.VolumeMountDetails) (common.VolumeMountDetails, error)
  • func (client *KubeClient) GetHealthCheckGVR() schema.GroupVersionResource
  • func (client *KubeClient) GetInformerFactory() dynamicinformer.DynamicSharedInformerFactory
  • func (client *KubeClient) GetMarketplaceDataset(namespace string, name string) (*common.Dataset, error)
  • func (client *KubeClient) GetMarketplaceDatasets(namespace string) ([]common.Dataset, error)
  • func (client *KubeClient) GetPodDetails(req *csi.NodePublishVolumeRequest) (*corev1.Pod, error)
  • func (client *KubeClient) GetPodsToReconcile(nodeName, namespace string) ([]corev1.Pod, error)
  • func (client *KubeClient) GetSecret(namespace string, name string) (*corev1.Secret, error)
  • func (client *KubeClient) GetVolumeMountDetails(req *csi.NodePublishVolumeRequest) (common.VolumeMountDetails, error)
  • func (client *KubeClient) ParseDatasetSpec(dsu *unstructured.Unstructured) (*common.Dataset, error)
  • func (client *KubeClient) TagPodForTracking(req *csi.NodePublishVolumeRequest, volMountDetails common.VolumeMountDetails)
  • func (client *KubeClient) UpdateHealthCheckStatus(nodeName string, namespace string, name string, ...)
  • func (client *KubeClient) UpdatePodOnNodePublishVolume(req *csi.NodePublishVolumeRequest, volMountDetails common.VolumeMountDetails, ...)
  • func (client *KubeClient) UpdatePodStatusOnReconcile(volMountDetails common.VolumeMountDetails, mountedDatasetCount int, ...)

Functions

func GetPodCondition

func GetPodCondition(status *corev1.PodStatus, conditionType corev1.PodConditionType) (int, *corev1.PodCondition)

func GetPodConditionFromList

func GetPodConditionFromList(conditions []corev1.PodCondition, conditionType corev1.PodConditionType) (int, *corev1.PodCondition)

func GetStringSliceValue

func GetStringSliceValue(u *unstructured.Unstructured, defValue []string, fldPath ...string) []string

func GetStringValue

func GetStringValue(u *unstructured.Unstructured, defValue string, fldPath ...string) string

Types

type KubeClient

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

KubeClient ...

func NewKubeClient

func NewKubeClient(ctx context.Context, cs kubernetes.Interface, dc dynamic.Interface, helper helper.DriverHelper) *KubeClient

NewKubeClient returns a new instance of KubeClient

func (*KubeClient) GetDriverConfiguration

func (client *KubeClient) GetDriverConfiguration(volDetails common.VolumeMountDetails) (common.VolumeMountDetails, error)

func (*KubeClient) GetHealthCheckGVR

func (client *KubeClient) GetHealthCheckGVR() schema.GroupVersionResource

func (*KubeClient) GetInformerFactory

func (client *KubeClient) GetInformerFactory() dynamicinformer.DynamicSharedInformerFactory

func (*KubeClient) GetMarketplaceDataset

func (client *KubeClient) GetMarketplaceDataset(namespace string, name string) (*common.Dataset, error)

func (*KubeClient) GetMarketplaceDatasets

func (client *KubeClient) GetMarketplaceDatasets(namespace string) ([]common.Dataset, error)

func (*KubeClient) GetPodDetails

func (client *KubeClient) GetPodDetails(req *csi.NodePublishVolumeRequest) (*corev1.Pod, error)

func (*KubeClient) GetPodsToReconcile

func (client *KubeClient) GetPodsToReconcile(nodeName, namespace string) ([]corev1.Pod, error)

func (*KubeClient) GetSecret

func (client *KubeClient) GetSecret(namespace string, name string) (*corev1.Secret, error)

func (*KubeClient) GetVolumeMountDetails

func (client *KubeClient) GetVolumeMountDetails(req *csi.NodePublishVolumeRequest) (common.VolumeMountDetails, error)

GetDatasets ...

func (*KubeClient) ParseDatasetSpec

func (client *KubeClient) ParseDatasetSpec(dsu *unstructured.Unstructured) (*common.Dataset, error)

func (*KubeClient) TagPodForTracking

func (client *KubeClient) TagPodForTracking(req *csi.NodePublishVolumeRequest, volMountDetails common.VolumeMountDetails)

func (*KubeClient) UpdateHealthCheckStatus

func (client *KubeClient) UpdateHealthCheckStatus(nodeName string, namespace string, name string, hcStatus common.HealthCheckStatus)

func (*KubeClient) UpdatePodOnNodePublishVolume

func (client *KubeClient) UpdatePodOnNodePublishVolume(req *csi.NodePublishVolumeRequest, volMountDetails common.VolumeMountDetails, mountedDatasetCount int, mountError error)

func (*KubeClient) UpdatePodStatusOnReconcile

func (client *KubeClient) UpdatePodStatusOnReconcile(volMountDetails common.VolumeMountDetails, mountedDatasetCount int, mountError error)