kube

package

Go to main page

Versions in this module

v0

v0.8.1

Mar 22, 2023

Changes in this version

+ const AllPodsKeyword

+ const SomePodsKeyword

type Client

+ func (kc *Client) SomeOrAllPodsInNamespaceWithSelectorHaveStringInLogsSinceTime(SomeOrAll, namespace, selector, searchkeyword, sinceTime string) error

+ func (kc *Client) SomePodsInNamespaceWithSelectorDontHaveStringInLogsSinceTime(namespace, selector, searchkeyword, sinceTime string) error

v0.8.0

Feb 23, 2023

Changes in this version

+ const CustomResourceAPIVersion

+ const CustomResourceGroup

+ const CustomResourceKind

+ const CustomeResourceDomain

+ const InstanceGroupNamespace

+ const StateCreated

+ const StateDeleted

+ const StateUpgraded

+ var CustomResourceName = fmt.Sprintf("%v.%v", CustomResourceGroup, CustomeResourceDomain)

+ var InstanceGroupResource = schema.GroupVersionResource

type Client

+ Timestamps map[string]time.Time

+ func (kc *Client) DeleteResourcesAtPath(resourcesPath string) error

+ func (kc *Client) GetDaemonset(name, namespace string) (*appsv1.DaemonSet, error)

+ func (kc *Client) GetDeployment(name, namespace string) (*appsv1.Deployment, error)

+ func (kc *Client) GetIngress(name, namespace string) (*networkingv1.Ingress, error)

+ func (kc *Client) GetIngressEndpoint(name, namespace string, port int, path string) (string, error)

+ func (kc *Client) GetNodes() error

+ func (kc *Client) GetPersistentVolume(name string) (*corev1.PersistentVolume, error)

+ func (kc *Client) GetPods(namespace string) error

+ func (kc *Client) GetPodsWithSelector(namespace, selector string) error

+ func (kc *Client) IngressAvailable(name, namespace string, port int, path string) error

+ func (kc *Client) KubernetesCluster() error

+ func (kc *Client) KubernetesClusterShouldBe(state string) error

+ func (kc *Client) ListInstanceGroups() (*unstructured.UnstructuredList, error)

+ func (kc *Client) ListNodes() (*corev1.NodeList, error)

+ func (kc *Client) ListPersistentVolumes() (*corev1.PersistentVolumeList, error)

+ func (kc *Client) ListPodsWithLabelSelector(namespace, selector string) (*corev1.PodList, error)

+ func (kc *Client) ListStatefulSets(namespace string) (*appsv1.StatefulSetList, error)

+ func (kc *Client) NoMatchingStringInLogsSinceTime(namespace, selector, searchkeyword, sinceTime string) error

+ func (kc *Client) PersistentVolExists(volName, expectedPhase string) error

+ func (kc *Client) PodsWithSelectorHaveRestartCountLessThan(namespace string, selector string, expectedRestartCountLessThan int) error

+ func (kc *Client) ResourceIsRunning(kind, name, namespace string) error

+ func (kc *Client) ResourceOperationWithResult(operation, resourceFileName, expectedResult string) error

+ func (kc *Client) ResourceOperationWithResultInNamespace(operation, resourceFileName, namespace, expectedResult string) error

+ func (kc *Client) SecretDelete(secretName, namespace string) error

+ func (kc *Client) SecretOperationFromEnvironmentVariable(operation, secretName, namespace, environmentVariable string) error

+ func (kc *Client) SendTrafficToIngress(tps int, name, namespace string, port int, path string, duration int, ...) error

+ func (kc *Client) SetTimestamp(timestampName string) error

+ func (kc *Client) ThePodsInNamespaceShouldHaveLabels(podName string, namespace string, labels string) error

+ func (kc *Client) ThePodsInNamespaceWithSelectorHasThisSentenceInLogsSinceTime(namespace, selector, searchkeyword, sinceTime string, timeout int) error

+ func (kc *Client) ThePodsInNamespaceWithSelectorHaveNoErrorsInLogsSinceTime(namespace string, selector string, sinceTime string) error

+ func (kc *Client) ThePodsInNamespaceWithSelectorHaveSomeErrorsInLogsSinceTime(namespace string, selector string, sinceTime string) error

+ func (kc *Client) ThePodsInNamespaceWithSelectorShouldHaveLabels(namespace string, selector string, labels string) error

+ func (kc *Client) Validate() error

+ func (kc *Client) ValidatePrometheusVolumeClaimTemplatesName(statefulsetName string, namespace string, volumeClaimTemplatesName string) error

+ func (kc *Client) VerifyInstanceGroups() error

v0.7.1

Aug 18, 2022

v0.7.0

Aug 18, 2022

Changes in this version

type Client

+ func (kc *Client) MultiResourceOperationInNamespace(operation, resourceFileName, ns string) error

+ func (kc *Client) ResourceOperationInNamespace(operation, resourceFileName, ns string) error

v0.6.2

Aug 12, 2022

v0.6.1

Jun 3, 2022

v0.6.0

Jun 1, 2022

Changes in this version

+ const DefaultFilePath

+ const DefaultWaiterTries

type Client

+ WaiterInterval time.Duration

+ WaiterTries int

v0.5.0

Mar 10, 2022

v0.4.1

Jan 10, 2022

v0.4.0

Dec 21, 2021

Changes in this version

type Client

+ func (kc *Client) ClusterRbacIsFound(resource, name string) error

v0.3.0

Dec 10, 2021

Changes in this version

type Client

+ func (kc *Client) ResourceInNamespace(resource, name, ns string) error

v0.2.0

Aug 13, 2021

Changes in this version

type Client

+ func (kc *Client) MultiResourceOperation(operation, resourceFileName string) error

v0.1.2

Jul 12, 2021

v0.1.1

May 25, 2021

v0.1.0

May 24, 2021

v0.0.3

May 14, 2021

v0.0.2

Feb 23, 2021

Changes in this version

type Client

+ TemplateArguments interface{}

+ func (kc *Client) DeploymentInNamespace(name, ns string) error

+ func (kc *Client) ScaleDeployment(name, ns string, replica int32) error

v0.0.1

Aug 21, 2020

Changes in this version

+ const DefaultWaiterInterval

+ const DefaultWaiterRetries

+ const NodeStateFound

+ const NodeStateReady

+ const OperationCreate

+ const OperationDelete

+ const OperationSubmit

+ const OperationUpdate

+ const ResourceStateCreated

+ const ResourceStateDeleted

+ type Client struct

+ DiscoveryInterface discovery.DiscoveryInterface

+ DynamicInterface dynamic.Interface

+ FilesPath string

+ KubeInterface kubernetes.Interface

+ func (kc *Client) AKubernetesCluster() error

+ func (kc *Client) DeleteAllTestResources() error

+ func (kc *Client) NodesWithSelectorShouldBe(n int, selector, state string) error

+ func (kc *Client) ResourceConditionShouldBe(resourceFileName, cType, status string) error

+ func (kc *Client) ResourceOperation(operation, resourceFileName string) error

+ func (kc *Client) ResourceShouldBe(resourceFileName, state string) error

+ func (kc *Client) ResourceShouldConvergeToSelector(resourceFileName, selector string) error

+ func (kc *Client) UpdateResourceWithField(resourceFileName, key string, value string) error

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