utils

package

Go to main page

Versions in this module

v1

v1.5.4

Feb 18, 2019

Changes in this version

+ const RegistryConfigMap

+ func CopyConfigMap(client kubernetes.Interface, ...) error

+ func CopyRegistryCertConfigMap(client kubernetes.Interface, destNamespace string) (string, error)

v1.5.3

Feb 12, 2019

v1.5.2

Feb 6, 2019

Changes in this version

+ const RegistryHostName

+ const RegistryHostNs

v1.5.1

Jan 18, 2019

v1.5.0

Jan 11, 2019

Changes in this version

+ const TinyCoreIsoRegistryURL

+ func CreatePVFromDefinition(clientSet *kubernetes.Clientset, def *k8sv1.PersistentVolume) (*k8sv1.PersistentVolume, error)

+ func DeletePV(clientSet *kubernetes.Clientset, pv *k8sv1.PersistentVolume) error

+ func IsExpectedNode(clientSet *kubernetes.Clientset, nodeName, podName, namespace string, ...) error

+ func NewCloningDataVolume(dataVolumeName string, size string, sourcePvc *k8sv1.PersistentVolumeClaim) *cdiv1.DataVolume

+ func NewDataVolumeForBlankRawImage(dataVolumeName, size string) *cdiv1.DataVolume

+ func NewDataVolumeForImageCloning(dataVolumeName, size string, namespace, pvcName string) *cdiv1.DataVolume

+ func NewDataVolumeForUpload(dataVolumeName string, size string) *cdiv1.DataVolume

+ func NewDataVolumeWithRegistryImport(dataVolumeName string, size string, registryURL string) *cdiv1.DataVolume

+ func NewPVCDefinitionWithSelector(pvcName, size string, selector map[string]string, ...) *k8sv1.PersistentVolumeClaim

+ func NewPVDefinition(pvName string, size string, labels map[string]string, storageClassName string) *k8sv1.PersistentVolume

+ func WaitTimeoutForPVReady(clientSet *kubernetes.Clientset, pvName string, timeout time.Duration) error

+ func WaitTimeoutForPVStatus(clientSet *kubernetes.Clientset, pvName string, ...) error

v1.4.2

Jan 16, 2019

v1.4.1

Dec 6, 2018

Changes in this version

+ const DefaultImagePath

v1.4.0

Nov 30, 2018

Changes in this version

+ func ArchiveFiles(targetFile, tgtDir string, sourceFilesNames ...string) (string, error)

+ func DeleteSecret(clientSet *kubernetes.Clientset, namespace string, secret v1.Secret) error

+ func WaitPVCDeleted(clientSet *kubernetes.Clientset, pvcName, namespace string, ...) (bool, error)

v1.3.0

Oct 17, 2018

Changes in this version

+ const HTTPAuthPort

+ const HTTPNoAuthPort

+ func NewDataVolumeWithHTTPImport(dataVolumeName string, size string, httpURL string) *cdiv1.DataVolume

v1.2.0

Sep 28, 2018

Changes in this version

+ const AccessKeyValue

+ const DataVolumeCreateTime

+ const DataVolumeDeleteTime

+ const DataVolumePhaseTime

+ const DefaultPvcMountPath

+ const FileHostName

+ const FileHostNs

+ const FileHostS3Bucket

+ const HttpAuthPort

+ const HttpNoAuthPort

+ const PodWaitForTime

+ const S3Port

+ const SecretKeyValue

+ const SecretPollInterval

+ const SecretPollPeriod

+ const ServicePollInterval

+ const ServicePollPeriod

+ const TinyCoreIsoURL

+ const UploadFileMD5

+ func CreateDataVolumeFromDefinition(clientSet *cdiclientset.Clientset, namespace string, def *cdiv1.DataVolume) (*cdiv1.DataVolume, error)

+ func CreateExecutorPodWithPVC(clientSet *kubernetes.Clientset, podName, namespace string, ...) (*k8sv1.Pod, error)

+ func CreatePVCFromDefinition(clientSet *kubernetes.Clientset, namespace string, ...) (*k8sv1.PersistentVolumeClaim, error)

+ func CreatePod(clientSet *kubernetes.Clientset, namespace string, podDef *k8sv1.Pod) (*k8sv1.Pod, error)

+ func CreateSecretFromDefinition(c *kubernetes.Clientset, secret *v1.Secret) (*v1.Secret, error)

+ func DeleteDataVolume(clientSet *cdiclientset.Clientset, namespace string, ...) error

+ func DeletePVC(clientSet *kubernetes.Clientset, namespace string, ...) error

+ func DeletePod(clientSet *kubernetes.Clientset, pod *k8sv1.Pod, namespace string) error

+ func DownloadImageToNode(clientSet *kubernetes.Clientset, cliCommandPath string) error

+ func FindPVC(clientSet *kubernetes.Clientset, namespace, pvcName string) (*k8sv1.PersistentVolumeClaim, error)

+ func FindPodByPrefix(clientSet *kubernetes.Clientset, namespace, prefix, labelSelector string) (*k8sv1.Pod, error)

+ func FormatTestData(srcFile, tgtDir string, targetFormats ...string) (string, error)

+ func GetServiceInNamespace(c *kubernetes.Clientset, ns, name string) (*v1.Service, error)

+ func GetServiceInNamespaceOrDie(c *kubernetes.Clientset, ns, name string) *v1.Service

+ func GetServiceNodePortByName(svc *v1.Service, name string) (int, error)

+ func GetServicePortByName(svc *v1.Service, name string) (int, error)

+ func GetServicesInNamespaceByLabel(c *kubernetes.Clientset, ns, labelSelector string) (*v1.ServiceList, error)

+ func NewDataVolumeWithHttpImport(dataVolumeName string, size string, httpUrl string) *cdiv1.DataVolume

+ func NewDataVolumeWithPVCImport(dataVolumeName string, size string, targetPvc *k8sv1.PersistentVolumeClaim) *cdiv1.DataVolume

+ func NewPVCDefinition(pvcName string, size string, annotations, labels map[string]string) *k8sv1.PersistentVolumeClaim

+ func NewPodWithPVC(podName, cmd string, pvc *k8sv1.PersistentVolumeClaim) *k8sv1.Pod

+ func NewSecretDefinition(labels, stringData map[string]string, data map[string][]byte, ...) *v1.Secret

+ func PodGetNode(clientSet *kubernetes.Clientset, podName, namespace string) (string, error)

+ func RequestUploadToken(clientSet *cdiClientset.Clientset, pvc *k8sv1.PersistentVolumeClaim) (string, error)

+ func RunGoCLICommand(cliPath string, args ...string) ([]byte, error)

+ func UploadImageFromNode(clientSet *kubernetes.Clientset, cliCommandPath, token string) error

+ func UploadPVCDefinition() *k8sv1.PersistentVolumeClaim

+ func UploadPodName(pvc *k8sv1.PersistentVolumeClaim) string

+ func WaitForDataVolumePhase(clientSet *cdiclientset.Clientset, namespace string, ...) error

+ func WaitForDeploymentReplicasReady(c *kubernetes.Clientset, namespace, name string) error

+ func WaitForDeploymentReplicasReadyOrDie(c *kubernetes.Clientset, namespace, name string)

+ func WaitForPVCAnnotation(clientSet *kubernetes.Clientset, namespace string, ...) (string, bool, error)

+ func WaitForPVCAnnotationWithValue(clientSet *kubernetes.Clientset, namespace string, ...) (bool, error)

+ func WaitForPersistentVolumeClaimPhase(clientSet *kubernetes.Clientset, namespace string, ...) error

+ func WaitPVCUploadPodStatusRunning(clientSet *kubernetes.Clientset, pvc *k8sv1.PersistentVolumeClaim) (bool, error)

+ func WaitPodDeleted(clientSet *kubernetes.Clientset, podName, namespace string, ...) (bool, error)

+ func WaitTimeoutForPodReady(clientSet *kubernetes.Clientset, podName, namespace string, ...) error

+ func WaitTimeoutForPodStatus(clientSet *kubernetes.Clientset, podName, namespace string, ...) error

+ func WaitTimeoutForPodSucceeded(clientSet *kubernetes.Clientset, podName, namespace string, ...) error

v1.2.0-alpha.2

Sep 24, 2018

v1.2.0-alpha.1

Sep 12, 2018

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL