Documentation
¶
Index ¶
- func FindIngressHosts(name string, namespace string) ([]string, error)
- func GetAPIExtensionsClient() (apiextensionsclientset.Interface, error)
- func GetClientConfig() (*restclient.Config, error)
- func GetClientset() (kubernetes.Interface, error)
- func GetJenkinsClient() (versioned.Interface, error)
- func IsRetryableAPIError(err error) bool
- func IsSSOInitialized(sso *v1.SSO) (bool, error)
- func RegisterSSOCRD(apiClient apiextensionsclientset.Interface) error
- func WaitForDeploymentToStabilize(c kubernetes.Interface, namespace, name string, timeout time.Duration) error
- func WaitForJobComplete(c kubernetes.Interface, namespace, name string, ...) error
- func WaitForPodComplete(pods corev1.PodInterface, podName string, timeout time.Duration) error
- func WaitForPodReady(pods corev1.PodInterface, podName string) error
- func WaitForPodsWithLabelRunning(c kubernetes.Interface, namespace string, label labels.Selector, ...) error
- func WaitForService(c kubernetes.Interface, namespace, name string, exist bool, ...) error
- func WaitForServiceEndpointsNum(c kubernetes.Interface, namespace, serviceName string, expectNum int, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FindIngressHosts ¶
FindIngressHosts searches an ingress resource by name and retrieves its hosts
func GetAPIExtensionsClient ¶
func GetAPIExtensionsClient() (apiextensionsclientset.Interface, error)
GetAPIExtensionsClient returns the k8s api extensions client
func GetClientConfig ¶
func GetClientConfig() (*restclient.Config, error)
GetClientConfig return the k8s configuration
func GetClientset ¶
func GetClientset() (kubernetes.Interface, error)
GetClientset creates a new k8s client
func GetJenkinsClient ¶
GetJenkinsClient returns the Jenkins CRDs client
func IsRetryableAPIError ¶
IsRetryableAPIError indicates if the given error is retryable
func IsSSOInitialized ¶
IsSSOInitialized checks if the SSO is initialized by retrieving the current state from k8s
func RegisterSSOCRD ¶
func RegisterSSOCRD(apiClient apiextensionsclientset.Interface) error
RegisterSSOCRD ensures that the CRD is registered for SSO
func WaitForDeploymentToStabilize ¶
func WaitForDeploymentToStabilize(c kubernetes.Interface, namespace, name string, timeout time.Duration) error
WaitForDeploymentToStabilize waits till the Deployment has a matching generation/replica count between spec and status.
func WaitForJobComplete ¶
func WaitForJobComplete(c kubernetes.Interface, namespace, name string, interval, timeout time.Duration) error
WaitForJobComplete wait for a job to complete
func WaitForPodComplete ¶
WaitForPodComplete wait for given POD to complete
func WaitForPodReady ¶
func WaitForPodReady(pods corev1.PodInterface, podName string) error
WaitForPodReady waits for given POD to become ready
func WaitForPodsWithLabelRunning ¶
func WaitForPodsWithLabelRunning(c kubernetes.Interface, namespace string, label labels.Selector, timeout time.Duration) error
WaitForPodsWithLabelRunning waits for all matching pods to become Running and at least one matching pod exists.
func WaitForService ¶
func WaitForService(c kubernetes.Interface, namespace, name string, exist bool, interval, timeout time.Duration) error
WaitForService waits until the service appears (exist == true), or disappears (exist == false)
func WaitForServiceEndpointsNum ¶
func WaitForServiceEndpointsNum(c kubernetes.Interface, namespace, serviceName string, expectNum int, interval, timeout time.Duration) error
WaitForServiceEndpointsNum waits until the amount of endpoints that implement service to expectNum.
Types ¶
This section is empty.
Source Files