Versions in this module Expand all Collapse all v0 v0.0.2 Mar 2, 2021 Changes in this version type Machine + func (m *Machine) WaitForPodCount(namespace string, labels string, count int) error + func (m *Machine) WaitForServiceAccount(namespace string, name string) error v0.0.1 Sep 25, 2020 Changes in this version + const DefaultInterval + const DefaultTimeout + type ChanResult struct + Error error + type Machine struct + Clientset *kubernetes.Clientset + PollInterval time.Duration + PollTimeout time.Duration + func NewMachine() Machine + func (m *Machine) CollectJobs(namespace string, labels string, n int) ([]batchv1.Job, error) + func (m *Machine) CollectSecret(namespace string, name string) (*corev1.Secret, error) + func (m *Machine) ConfigMapExists(namespace string, name string) (bool, error) + func (m *Machine) ContainExpectedEvent(events []corev1.Event, reason string, message string) bool + func (m *Machine) ContainJob(jobs []batchv1.Job, name string) bool + func (m *Machine) CreateConfigMap(namespace string, configMap corev1.ConfigMap) (TearDownFunc, error) + func (m *Machine) CreateEndpoints(namespace string, ep corev1.Endpoints) (TearDownFunc, error) + func (m *Machine) CreateLabeledNamespace(namespace string, labels map[string]string) (TearDownFunc, error) + func (m *Machine) CreateNamespace(namespace string) (TearDownFunc, error) + func (m *Machine) CreatePod(namespace string, pod corev1.Pod) (TearDownFunc, error) + func (m *Machine) CreateSecret(namespace string, secret corev1.Secret) (TearDownFunc, error) + func (m *Machine) CreateService(namespace string, service corev1.Service) (TearDownFunc, error) + func (m *Machine) DeleteJobs(namespace string, labels string) (bool, error) + func (m *Machine) DeleteNamespace(namespace string) error + func (m *Machine) DeleteSecrets(namespace string) (bool, error) + func (m *Machine) GetConfigMap(namespace string, name string) (*corev1.ConfigMap, error) + func (m *Machine) GetEndpoints(namespace string, name string) (*corev1.Endpoints, error) + func (m *Machine) GetNodes() ([]corev1.Node, error) + func (m *Machine) GetPod(namespace string, name string) (*corev1.Pod, error) + func (m *Machine) GetPodContainerLogs(namespace, podName, containerName string) (string, error) + func (m *Machine) GetPodLogs(namespace, podName string) (string, error) + func (m *Machine) GetPods(namespace string, labels string) (*corev1.PodList, error) + func (m *Machine) GetSecret(namespace string, name string) (*corev1.Secret, error) + func (m *Machine) GetService(namespace string, name string) (*corev1.Service, error) + func (m *Machine) InitContainerRunning(namespace, podName, containerName string) (bool, error) + func (m *Machine) JobExists(namespace string, name string) (bool, error) + func (m *Machine) PodContainsLogMsg(namespace, podName, containerName, msg string) error + func (m *Machine) PodCount(namespace string, labels string, match func(corev1.Pod) bool) (int, error) + func (m *Machine) PodLabeled(namespace string, name string, desiredLabel, desiredValue string) (bool, error) + func (m *Machine) PodReady(namespace string, name string) (bool, error) + func (m *Machine) PodRunning(namespace string, name string) (bool, error) + func (m *Machine) PodsDeleted(namespace string) (bool, error) + func (m *Machine) PodsFailing(namespace string, labels string) (bool, error) + func (m *Machine) PodsRunning(namespace string, labels string) (bool, error) + func (m *Machine) SecretExists(namespace string, name string) (bool, error) + func (m *Machine) SubsetsExist(namespace string, endpointsName string) (bool, error) + func (m *Machine) TearDownAll(funcs []TearDownFunc) error + func (m *Machine) UpdateConfigMap(namespace string, configMap corev1.ConfigMap) (*corev1.ConfigMap, TearDownFunc, error) + func (m *Machine) UpdateEndpoints(namespace string, ep corev1.Endpoints) (*corev1.Endpoints, TearDownFunc, error) + func (m *Machine) UpdatePod(namespace string, pod corev1.Pod) (*corev1.Pod, TearDownFunc, error) + func (m *Machine) UpdateSecret(namespace string, secret corev1.Secret) (*corev1.Secret, TearDownFunc, error) + func (m *Machine) UpdateService(namespace string, svc corev1.Service) (*corev1.Service, TearDownFunc, error) + func (m *Machine) WaitForConfigMap(namespace string, name string) error + func (m *Machine) WaitForInitContainerRunning(namespace, podName, containerName string) error + func (m *Machine) WaitForJobDeletion(namespace string, name string) error + func (m *Machine) WaitForJobExists(namespace string, labels string) (bool, error) + func (m *Machine) WaitForJobsDeleted(namespace string, labels string) error + func (m *Machine) WaitForLogMsg(logs *observer.ObservedLogs, msg string) error + func (m *Machine) WaitForPod(namespace string, name string) error + func (m *Machine) WaitForPodContainerLogMatchRegexp(namespace string, podName string, containerName string, regExp string) error + func (m *Machine) WaitForPodContainerLogMsg(namespace, podName, containerName, msg string) error + func (m *Machine) WaitForPodFailures(namespace string, labels string) error + func (m *Machine) WaitForPodLogMatchRegexp(namespace string, podName string, regExp string) error + func (m *Machine) WaitForPodLogMsg(namespace string, podName string, msg string) error + func (m *Machine) WaitForPodReady(namespace string, name string) error + func (m *Machine) WaitForPods(namespace string, labels string) error + func (m *Machine) WaitForPodsDelete(namespace string) error + func (m *Machine) WaitForPortReachable(protocol, uri string) error + func (m *Machine) WaitForSecret(namespace string, name string) error + func (m *Machine) WaitForSecretChange(namespace string, name string, changed SecretChangedFunc) error + func (m *Machine) WaitForSecretDeletion(namespace string, name string) error + func (m *Machine) WaitForSubsetsExist(namespace string, endpointsName string) error + type SecretChangedFunc func(corev1.Secret) bool + type TearDownFunc func() error
Go to main page