k8sutils

type ConfigOption func(*rest.Config)

type ConfigmapOps interface {
	// CreateConfigmap creates the given configmap
	CreateConfigmap(context.Context, *coreV1.ConfigMap) (*coreV1.ConfigMap, error)
	// GetConfigmap gets the configmap object given its name and namespace
	GetConfigmap(context.Context, string, string) (*coreV1.ConfigMap, error)
	// UpdateConfigmap update the configmap object given its name and namespace
	UpdateConfigmap(context.Context, *coreV1.ConfigMap) (*coreV1.ConfigMap, error)
	// DeleteConfigmap delete the configmap object given its name and namespace
	DeleteConfigmap(context.Context, *coreV1.ConfigMap) error
}

type Interface interface {
	// GetNodeTopology returns configured kubernetes node's topological labels
	GetNodeTopology(ctx context.Context, nodeName string) (map[string]string, error)

	// GetVolume returns volumes on the node at K8S side
	GetVolume(ctx context.Context, nodeName string, driverName string) (map[string]struct{}, error)

	// GetPVByName get all pv info
	GetPVByName(ctx context.Context, name string) (*corev1.PersistentVolume, error)

	// ListPods get pods by namespace
	ListPods(ctx context.Context, namespace string) (*corev1.PodList, error)

	// GetPod get pod by name and namespace
	GetPod(ctx context.Context, namespace, podName string) (*corev1.Pod, error)

	// GetVolumeAttributes returns volume attributes of PV
	GetVolumeAttributes(ctx context.Context, pvName string) (map[string]string, error)

	// GetVolumeAttrsByVolumeId returns volume attributes of PV from volume id
	GetVolumeAttrsByVolumeId(volumeId string) ([]map[string]string, error)

	// GetDTreeParentNameByVolumeId returns dDTreeParentname field of PV by volume id
	GetDTreeParentNameByVolumeId(volumeId string) (string, error)

	// GetKvCacheStoreIdByVolumeId returns kvCacheStoreId field of PV by volume id
	GetKvCacheStoreIdByVolumeId(volumeId string) (string, error)

	// UpdateVAsWithHostMap updates VAs with the given host map
	UpdateVAsWithHostMap(ctx context.Context, volumeId string, hostMap map[string]map[string]interface{}) error

	// GetMappingHostsByVolumeId returns mapping hosts in VAs by volume id
	GetMappingHostsByVolumeId(volumeId string) ([]string, error)

	// GetVAsByPVName returns VAs by pv name
	GetVAsByPVName(pvName string) ([]*storagev1.VolumeAttachment, error)

	// Activate the k8s helpers when start the service
	Activate()
	// Deactivate the k8s helpers when stop the service
	Deactivate()

	ConfigmapOps
	// contains filtered or unexported methods
}

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

type NotFoundError struct{}

type Option func(*k8sUtilsConfig)

type ResourceAccessor[T runtime.Object] struct {
	// contains filtered or unexported fields
}