util

package
v0.0.1-alpha Latest Latest
Warning

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

Go to latest
Published: Apr 28, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetImageName

func GetImageName(fullName string) (name string, tags []string)

func GetPodsForSvc

func GetPodsForSvc(svc *corev1.Service, namespace string, k8sClient typev1.CoreV1Interface) (*corev1.PodList, error)

func IsFuzzerEvent

func IsFuzzerEvent(object *metav1.ObjectMeta) bool

func IsJobReady

func IsJobReady(clientset kubernetes.Interface, jobName string, namespace string) wait.ConditionFunc

func IsKubernetesEvent

func IsKubernetesEvent(object *metav1.ObjectMeta) bool

func IsPodRunning

func IsPodRunning(clientSet kubernetes.Interface, pod *corev1.Pod) wait.ConditionFunc

func IsSvcRunning

func IsSvcRunning(c typev1.CoreV1Interface, service *corev1.Service) wait.ConditionFunc

IsSvcRunning return a condition function that indicates whether the given pod is currently running

func NamespaceExist

func NamespaceExist(clientset kubernetes.Interface, namespace string) bool

func PodExist

func PodExist(clientSet kubernetes.Interface, namespace string, podName string) bool

func SplitImageId

func SplitImageId(imageId string) (hash string, hashType string)

func WaitForJobReady

func WaitForJobReady(clientset kubernetes.Interface, jobName string, namespace string, timeout time.Duration) error

func WaitForPodReady

func WaitForPodReady(clientSet kubernetes.Interface, pod *corev1.Pod, timeout time.Duration) error

func WaitForSvcReady

func WaitForSvcReady(c kubernetes.Interface, service *corev1.Service, timeout time.Duration) error

WaitForSvcReady Wait until the service has a running pod available Returns an error if the pod never enters the running state.

Types

This section is empty.

Jump to

Keyboard shortcuts

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