Package ginkgowrapper wraps Ginkgo Fail and Skip functions to panic with structured data instead of a constant string.

AddCleanupAction installs a function that will be called in the event of the whole test being terminated.

AddOrUpdateAvoidPodOnNode adds avoidPods annotations to node, will override if it exists.

AfterReadingAllFlags makes changes to the context after all flags have been read.

Checks whether all registered nodes are ready.

ApiCallToPerfData transforms APIResponsiveness to PerfData.

Asserts that cleanup of a namespace wrt selectors occurred.

BindClusterRole binds the cluster role at the cluster scope.

BindClusterRoleInNamespace binds the cluster role at the namespace scope.

BindRoleInNamespace binds the role at the namespace scope.

The following helper functions can block/unblock network from source host to destination host by manipulating iptable rules.

BuildInsecureClient returns an insecure http client.

CheckConnectivityToHost launches a pod to test connectivity to the specified host.

CheckDeploymentRevisionAndImage checks if the input deployment's and its new replica set's revision and image are as expected.

CheckForAllJobPodsRunning uses c to check in the Job named jobName in ns is running.

CheckForControllerManagerHealthy checks that the controller manager does not crash within "duration".

CheckNewRSAnnotations check if the new RS's annotation is as expected.

CheckNodesReady waits up to nt for expect nodes accessed by c to be ready, returning an error if this doesn't happen in time.

CheckPodsCondition returns whether all pods whose names are listed in podNames in namespace ns are in the condition, using c and waiting at most timeout.

CheckPodsRunningReady returns whether all pods whose names are listed in podNames in namespace ns are running and ready, using c and waiting at most timeout.

CheckPodsRunningReadyOrSucceeded returns whether all pods whose names are listed in podNames in namespace ns are running and ready, or succeeded; use c and waiting at most timeout.

CheckTestingNSDeletedExcept checks whether all e2e based existing namespaces are in the Terminating state and waits until they are finally deleted.

Stops everything from filePath from namespace ns and checks if everything matching selectors from the given namespace is correctly stopped.

CleanupGCEResources cleans up GCE Service Type=LoadBalancer resources with the given name.

Wrapper function for ginkgo It.

ConstructFirewallForLBService returns the expected GCE firewall rule for a loadbalancer type service.

ConstructHealthCheckFirewallForLBService returns the expected GCE firewall rule for a loadbalancer type service.

CoreDump SSHs to the master and all nodes and dumps their logs into dir.

CPUUsageToPerfData transforms NodesCPUSummary to PerfData.

CPUUsageToPerfDataWithLabels transforms NodesCPUSummary to PerfData with additional labels.

Define and create a pod with a mounted PV.

create empty file at given path on the pod.

CreateExecPodOrFail creates a simple busybox pod in a sleep loop used as a vessel for kubectl exec commands.

CreateIngressComformanceTests generates an slice of sequential test cases: a simple http ingress, ingress with HTTPS, ingress HTTPS with a modified hostname, ingress https with a modified URLMap.

CreateJob uses c to create job in namespace ns.

CreatePod with given claims based on node selector.

create the PVC resource.

Create a PVC followed by the PV based on the passed in nfs-server ip and namespace.

Create a PV followed by the PVC based on the passed in nfs-server ip and namespace.

Create the desired number of PVs and PVCs and return them in separate maps.

create security pod with given claims.

CreateStatefulSetService creates a Headless Service with Name name and Selector set to match labels.

Wrapper for StartVolumeServer().

CreateTestCRD creates a new CRD specifically for the calling test.

CreateTestingNS should be used by every test, note that we append a common prefix to the provided test name.

CreateUnschedulablePod with given claims based on node selector.

Create the test pod, wait for (hopefully) success, and then delete the pod.

DeleteAllStatefulSets deletes all StatefulSet API Objects in Namespace ns.

DeleteJob uses c to delete the Job named name in namespace ns.

DeleteNamespaces deletes all namespaces that match the given delete and skip filters.

Delete the PV.

Delete the Claim.

Deletes the passed-in pod and waits for the pod to be terminated.

Delete the PVC and wait for the PV to enter its expected phase.

Wraps deletePVCandValidatePV() by calling the function in a loop over the PV map.

DeleteRCAndWaitForGC deletes only the Replication Controller and waits for GC to delete the pods.

DeleteResourceAndPods deletes a given resource and all pods it spawned.

DeleteResourceAndWaitForGC deletes only given resource and waits for GC to delete the pods.

DsFromManifest reads a .json/yaml file and returns the daemonset in it.

EnableAndDisableInternalLB returns two functions for enabling and disabling the internal load balancer setting for the supported cloud providers: GCE/GKE and Azure.

EnsureLoadBalancerResourcesDeleted ensures that cloud load balancer resources that were created are actually cleaned up.

ExpectNoErrorWithOffset checks if "err" is set, and if so, fails assertion while logging the error at "offset" levels above its caller (for example, for call chain f -> g -> ExpectNoErrorWithOffset(1, ...) error would be logged for "f").

FailfWithOffset calls "Fail" and logs the error at "offset" levels above its caller (for example, for call chain f -> g -> FailfWithOffset(1, ...) error would be logged for "f").

Filters nodes in NodeList in place, removing nodes that do not satisfy the given condition TODO: consider merging with pkg/client/cache.NodeLister.

FormatRuntimeOperationErrorRate formats the runtime operation error rate to string.

GcloudComputeResourceCreate creates a compute resource with a name and arguments.

GcloudComputeResourceDelete deletes the specified compute resource by name and project.

GenerateRSACerts generates a basic self signed certificate using a key length of rsaBits, valid for validFor time.

GetAzureCloud returns azure cloud provider.

GetClusterName returns the CLUSTER_NAME env we set for e2e cluster.

GetE2eFirewalls returns all firewall rules we create for an e2e cluster.

GetHostExternalAddress gets the node for a pod and returns the first External address.

GetInstancePrefix returns the INSTANCE_PREFIX env we set for e2e cluster.

GetInstanceTags gets tags from GCE instance with given name.

GetJob uses c to get the Job in namespace ns named name.

GetJobPods returns a list of Pods belonging to a Job.

GetKubeletLatencyMetrics gets all latency related kubelet metrics.

GetKubeletPods retrieves the list of pods on the kubelet.

GetKubeletRunningPods retrieves the list of running pods on the kubelet.

TODO: figure out how to move this to kubemark directory (need to factor test SSH out of e2e framework).

GetLogToFileFunc is a convenience function that returns a function that have the same interface as Logf, but writes to a specified file.

GetMasterAddress returns the hostname/external IP/internal IP as appropriate for e2e tests on a particular provider which is the address of the interface used for communication with the kubelet.

GetMasterAndWorkerNodesOrDie will return a list masters and schedulable worker nodes.

GetNodeExternalIP returns node external IP concatenated with port 22 for ssh e.g.

GetNodePortURL returns the url to a nodeport Service.

GetNodeTags gets k8s node tag from one of the nodes.

GetPauseImageName fetches the pause image name for the same architecture as the apiserver.

TODO(random-liu): Change this to be a member function of the framework.

GetPodsForDeployment gets pods for the given deployment.

GetPodsScheduled returns a number of currently scheduled and not scheduled Pods.

GetReadySchedulableNodesOrDie addresses the common use case of getting nodes you can do work on.

GetServerArchitecture fetches the architecture of the cluster's apiserver.

GetSigner returns an ssh.Signer for the provider ("gce", etc.) that can be used to SSH to their nodes.

HighLatencyKubeletOperations logs and counts the high latency metrics exported by the kubelet server via /metrics.

Prints top five summary metrics for request types with latency and returns number of such request types above threshold.

Insert index.html with given content into given volume.

IsHTTPErrorCode returns true if the error is a google api error matching the corresponding HTTP error code.

KubectlCmd runs the kubectl executable through the wrapper script.

KubectlVersion gets the version of kubectl that's currently being used (see --kubectl-path in e2e.go to use an alternate kubectl).

KubectlVersionGTE returns true if the kubectl version is greater than or equal to v.

Wrapper function for ginkgo describe.

LaunchHostExecPod launches a hostexec pod in the given namespace and waits until it's Running.

LaunchWebserverPod launches a pod serving http on port 8080 to act as the target for networking connectivity checks.

LogSuspiciousLatency logs metrics/docker errors from all nodes that had slow startup times If latencyDataLag is nil then it will be populated from latencyData.

Looks for the given string in the output of fn, repeatedly calling fn until the timeout is reached or the string is found.

Looks for the given string in a file in a specific pod container.

Looks for the given string in the log of a specific pod container.

Looks for the given string in the output of a command executed in a specific pod container.

MakeDeployment creates a deployment definition based on the namespace.

MakeFirewallNameForLBService return the expected firewall name for a LB service.

Returns a PV definition based on the nfs server IP.

Returns a PVC definition based on the namespace.

Returns a pod definition based on the namespace.

Returns a pod definition based on the namespace.

Returns a pod definition based on the namespace.

TODO(mrhohn): Remove this function when kube-proxy is run as a DaemonSet by default.

MigTemplate (GCE-only) returns the name of the MIG template that the nodes of the cluster use.

NewNetworkingTestNodeE2EConfig creates and sets up a new test config helper for Node E2E.

NewFramework makes a new framework and sets up a BeforeEach/AfterEach for you (you can write additional before/after each functions).

GlusterFS-specific wrapper for CreateStorageServer.

NewHostExecPodSpec returns the pod spec of hostexec pod.

NewIngressTestJig instantiates struct with client.

iSCSI-specific wrapper for CreateStorageServer.

NewLogsVerifier creates a new LogsSizeVerifier which will stop when stopChannel is closed.

NewNetworkingTestConfig creates and sets up a new test config helper.

NFS-specific wrapper for CreateStorageServer.

CephRBD-specific wrapper for CreateStorageServer.

NewServiceTestJig allocates and inits a new ServiceTestJig.

NewStatefulSet creates a new NGINX StatefulSet for testing.

NewStatefulSetPVC returns a PersistentVolumeClaim named name, for testing StatefulSets.

NewStatefulSetScale creates a new StatefulSet scale subresource and returns it.

NewStatefulSetTester creates a StatefulSetTester that uses c to interact with the API server.

NewTestJob returns a Job which does one of several testing behaviors.

NodeAddresses returns the first address of the given type of each node.

NodeExec execs the given cmd on node via SSH.

NodeProxyRequest performs a get on a node proxy endpoint given the nodename and rest client.

NodeSSHHosts returns SSH-able host names for all schedulable nodes - this excludes master node.

TODO(mrhohn): Remove this function when kube-proxy is run as a DaemonSet by default.

TODO make this generic and not linked to COS only NumberOfGPUs returs the number of GPUs advertised by a node This is based on the Device Plugin system and expected to run on a COS based node After the NVIDIA drivers were installed.

Returns number of ready Nodes excluding Master Node.

NVIDIADevicePlugin returns the official Google Device Plugin pod for NVIDIA GPU in GKE.

OpenWebSocketForURL constructs a websocket connection to the provided URL, using the client config, with the specified protocols.

PackProtocolsPortsFromFirewall packs protocols and ports in an unified way for verification.

ParseKVLines parses output that looks like lines containing "<key>: <val>" and returns <val> if <key> is found.

PodStartupLatencyToPerfData transforms PodStartupLatency to PerfData.

PollURL polls till the url responds with a healthy http code.

PrintPerfData prints the perfdata in json format with PerfResultTag prefix.

Creates a PodSecurityPolicy that allows everything.

Clean up a pv and pvc in a single pv/pvc test case.

Clean up pvs and pvcs in multi-pv-pvc test cases.

RcByNameContainer returns a ReplicationControoler with specified name and container.

RcByNamePort returns a ReplicationController with specified name and port.

RealVersion turns a version constants into a version string deployable on GKE.

Register flags specific to the cluster e2e test suite.

Register flags common to all e2e test suites.

Register flags specific to the node e2e test suite.

RemoveAnnotationOffNode removes AvoidPods annotations from the node.

RemoveCleanupAction removes a function that was installed by AddCleanupAction.

RemoveLabelOffNode is for cleaning up labels temporarily added to node, won't fail if target label doesn't exist or has been removed.

Resets latency metrics in apiserver.

ResourceUsageToPerfData transforms ResourceUsagePerNode to PerfData.

ResourceUsageToPerfDataWithLabels transforms ResourceUsagePerNode to PerfData with additional labels.

RunCleanupActions runs all functions installed by AddCleanupAction.

RunCmd runs cmd using args and returns its stdout and stderr.

RunCmdEnv runs cmd with the provided environment and args and returns its stdout and stderr.

RunHostCmd runs the given cmd in the context of the given pod using `kubectl exec` inside of a shell.

RunHostCmdOrDie calls RunHostCmd and dies on error.

RunHostCmdWithRetries calls RunHostCmd and retries all errors until it succeeds or the specified timeout expires.

RunKubectl is a convenience wrapper over kubectlBuilder.

RunKubectlOrDie is a convenience wrapper over kubectlBuilder.

RunKubectlOrDieInput is a convenience wrapper over kubectlBuilder that takes input to stdin.

RunKubemciCmd is a convenience wrapper over kubectlBuilder to run kubemci.

SameStringArray verifies whether two string arrays have the same strings, return error if not.

ScaleRCByLabels scales an RC via ns/label lookup.

ServerVersionGTE returns true if v is greater than or equal to the server version.

SetInstanceTags sets tags on GCE instance with given name.

SimpleGET executes a get on the given url, returns error if non-200 returned.

SSH synchronously SSHs to a node running on provider and runs cmd.

StartApiserverCPUProfileGatherer is a polling-based gatherer of the apiserver's CPU profile.

StartServeHostnameService creates a replication controller that serves its hostname and a service on top of it.

Starts a container specified by config.serverImage and exports all config.serverPorts from it.

A list of containers for which we want to collect resource usage.

Blocks outgoing network traffic on 'node'.

Start a client pod using given VolumeSource (exported by startVolumeServer()) and check that the pod sees expected data, e.g.

Rough equivalent of ctrl+c for cleaning up processes.

UpdateJob uses c to updated job in namespace ns.

UpdateJobFunc updates the job object.

UpdateService fetches a service, calls the update function on it, and then attempts to send the updated service.

ValidateController is a generic mechanism for testing RC's that are running.

VerifyFirewallRule verifies whether the result firewall is consistent with the expected firewall.

Sanity check for GCE testing.

Verifies whether 50, 90 and 99th percentiles of PodStartupLatency are within the threshold.

Verifies (currently just by logging them) the scheduling latencies.

VerifyServeHostnameServiceUp wgets the given serviceIP:servicePort from the given host and from within a pod.

ViperizeFlags sets up all flag and config processing.

Clean both server and client pods.

Search for bound PVs and PVCs by examining pvols for non-nil claimRefs.

WaitForAllJobPodsRunning wait for all pods for the Job named JobName in namespace ns to become Running.

checks whether all registered nodes are ready and all required Pods are running on them.

WaitForAuthorizationUpdate checks if the given user can perform the named verb and action.

Wait up to PodListTimeout for getting pods of the specified controller name and return them.

Wait up to 10 minutes for pods to become Running.

WaitForDefaultServiceAccountInNamespace waits for the default service account to be provisioned the default service account is what is associated with pods when they do not specify a service account as a result, pods are not able to be provisioned in a namespace until the service account is provisioned.

Waits for the deployment to complete, and don't check if rolling update strategy is broken.

Waits for the deployment to complete, and check rolling update strategy isn't broken at any times.

Waits for the deployment to clean up old rcs.

WaitForDeploymentRevisionAndImage waits for the deployment's and its new RS's revision and container image to match the given revision and image.

WaitForDeploymentRollbackCleared waits for given deployment either started rolling back or doesn't need to rollback.

WaitForDeploymentUpdatedReplicasGTE waits for given deployment to be observed by the controller and has at least a number of updatedReplicas.

Waits for the number of events on the given object to reach a desired count.

WaitForJobFailure uses c to wait for up to timeout for the Job named jobName in namespace ns to fail.

WaitForJobFinish uses c to wait for compeletions to complete for the Job jobName in namespace ns.

waitForMasters waits until the cluster has the desired number of ready masters in it.

WaitForMatchPodsCondition finds match pods based on the input ListOptions.

WaitForAuthorizationUpdate checks if the given user can perform the named verb and action on the named resource.

WaitForNodeToBe returns whether node "name's" condition state matches wantTrue within timeout.

WaitForNodeToBeNotReady returns whether node name is not ready (i.e.

WaitForNodeToBeReady returns whether node name is ready within timeout.

Waits for the number of events on the given object to be at least a desired count.

WaitForPersistentVolumeClaimDeleted waits for a PersistentVolumeClaim to be removed from the system until timeout occurs, whichever comes first.

WaitForPersistentVolumeClaimPhase waits for a PersistentVolumeClaim to be in a specific phase or until timeout occurs, whichever comes first.

WaitForPersistentVolumeDeleted waits for a PersistentVolume to get deleted or until timeout occurs, whichever comes first.

WaitForPersistentVolumePhase waits for a PersistentVolume to be in a specific phase or until timeout occurs, whichever comes first.

Waits default amount of time (PodStartTimeout) for the specified pod to become running.

WaitForPodNameUnschedulableInNamespace returns an error if it takes too long for the pod to become Pending and have condition Status equal to Unschedulable, if the pod Get api returns an error (IsNotFound or other), or if the pod failed with an unexpected reason.

Waits default amount of time (DefaultPodDeletionTimeout) for the specified pod to stop running.

WaitForPodNotPending returns an error if it took too long for the pod to go out of pending state.

Waits default amount of time (PodStartTimeout) for the specified pod to become running.

WaitForPodsRunningReady waits up to timeout to ensure that all pods in namespace ns are either running and ready, or failed but controlled by a controller.

WaitForPodsSuccess waits till all labels matching the given selector enter the Success state.

WaitForPodSuccessInNamespace returns nil if the pod reached state success, or an error if it reached failure or until podStartupTimeout.

WaitForPodSuccessInNamespaceSlow returns nil if the pod reached state success, or an error if it reached failure or until slowPodStartupTimeout.

Wait up to PodListTimeout for getting pods with certain label.

Wait for exact amount of matching pods to become running and ready.

Wait for all matching pods to become scheduled and at least one matching pod exists.

wait until all pvcs phase set to bound.

WaitForRCPodToDisappear returns nil if the pod from the given replication controller (described by rcName) no longer exists.

WaitForRCToStabilize waits till the RC has a matching generation/replica count between spec and status.

WaitForReadyNodes waits until the cluster has desired size and there is no not-ready nodes in it.

WaitForReadyReplicaSet waits until the replicaset has all of its replicas ready.

WaitForReplicationController waits until the RC appears (exist == true), or disappears (exist == false).

WaitForReplicationControllerwithSelector waits until any RC with given selector appears (exist == true), or disappears (exist == false).

WaitForService waits until the service appears (exist == true), or disappears (exist == false).

WaitForServiceEndpointsNum waits until the amount of endpoints that implement service to expectNum.

WaitForServiceWithSelector waits until any service with given selector appears (exist == true), or disappears (exist == false).

WaitForStableCluster waits until all existing pods are scheduled and returns their amount.

Wait for the pv and pvc to bind to each other.

WatchRecreateDeployment watches Recreate deployments and ensures no new pods will run at the same time with old pods.

How long claims have to become bound.

How long claims have to become deleted.

How long claims have to become dynamically provisioned.

CurrentKubeletPerfMetricsVersion is the current kubelet performance metrics version.

Default value for how long the CPU profile is gathered for.

TODO(mikedanese): reset this to 5 minutes once #47135 is resolved.

Set ports outside of 30000-32767, 80 and 8080 to avoid being whitelisted by the e2e cluster.

GCPMaxInstancesInInstanceGroup is the maximum number of instances supported in one instance group on GCP.

TODO: Parametrize it by making it a feature in TestFramework.

ImagePrePullingTimeout is the time we wait for the e2e-image-puller static pods to pull the list of seeded images.

Allow HTTP annotation defined in ingress repository.

Ingress class annotation defined in ingress repository.

IngressManifestPath is the parent path to yaml test manifests.

Pre-shared-cert annotation defined in ingress repository.

IngressReqTimeout is the timeout on a single http request.

Static IP annotation defined in ingress repository.

Job selector name.

How long to wait for a job to finish.

KubeProxyEndpointLagTimeout is the maximum time a kube-proxy daemon on a node is allowed to not notice an Endpoint update.

KubeProxyLagTimeout is the maximum time a kube-proxy daemon on a node is allowed to not notice a Service update, such as type=NodePort.

Time required by the loadbalancer to cleanup, proportional to numApps/Ing.

How long to wait for a load balancer to be created/modified.TODO: once support ticket 21807001 is resolved, reduce this timeout back to something reasonable.

LoadBalancerLagTimeoutAWS is the delay between ELB creation and serving traffic on AWS.

LoadBalancerLagTimeoutDefault is the maximum time a load balancer is allowed to not respond after creation.

On average it takes ~6 minutes for a single backend to come online in GCE.

Don't test with more than 3 nodes.

Ingress class annotation value for multi cluster ingress.

If there are any orphaned namespaces to clean up, this test is running on a long lived cluster.

How long nodes have to be "ready" when a test begins.

NodeStartupThreshold is a rough estimate of the time allocated for a pod to start on a node.

GPUResourceName is the extended name of the GPU resource since v1.8 this uses the device plugin mechanism.

How long to wait for the pod to be listable.

How long pods have to be "ready" when a test begins.

Initial pod start can be delayed O(minutes) by slow docker pulls TODO: Make this 30 seconds once #4566 is resolved.

How often to Poll pods, nodes and claims.

How long PVs have to become bound.

How long PVs have to become deleted.

How long PVs have to beome reclaimed.

How long a node is allowed to become "Ready" after it is restarted before the test is considered failed.

How long a pod is allowed to become "running" and "ready" after a node restart before test is considered failed.

service accounts are provisioned after namespace creation a service account is required to support pod creation in a namespace as part of admission control.

How long to wait for a service endpoint to be resolvable.

ServiceTestTimeout is used for most polling/waiting activities.

Number of checks to hit a given set of endpoints when enable session affinity.

How long to try single API calls (like 'get' or 'list').

Timeout for stateful pods to change state.

Poll interval for StatefulSet tests.

Timeout interval for StatefulSet operations.

Waiting period for volume server (Ceph, ...) to initialize itself.

Label allocated to the image puller static pod that runs on each node before e2es.

ImageWhiteList is the images used in the current test suite.

ProvidersWithSSH are those providers where each node is accessible with SSH.

unique identifier of the e2e run.

Serve hostname image name.

This should match whatever the default/configured range is.

E2ETestNodePreparer implements testutil.TestNodePreparer interface, which is used to create/modify Nodes before running a test.

ExecOptions passed to ExecWithOptions.

Framework supports common operations used by e2e tests; it will keep a client & a namespace for you.

GCEIngressController manages implementation details of Ingress on GCE/GKE.

IngressConformanceTests contains a closure with an entry and exit log line.

IngressTestJig holds the relevant state and parameters of the ingress test.

KubeletMetric stores metrics scraped from the kubelet server's /metric endpoint.

Dashboard metrics.

LogSizeGatherer is a worker which grabs a WorkItem from the channel and does assigned work.

LogsSizeVerifier gathers data about log files sizes from master and node machines.

NetworkingTestConfig is a convenience class around some utility methods for testing kubeproxy/networking/services/endpoints.

NginxIngressController manages implementation details of Ingress on Nginx.

NodeTestContextType is part of TestContextType, it is shared by all node e2e test.

PersistentVolumeConfig is consumed by MakePersistentVolume() to generate a PV object for varying storage options (NFS, ceph, glusterFS, etc.).

PodLatencyData encapsulates pod startup latency information.

PodStateVerification represents a verification of pod state.

ResourceMonitor manages a resourceCollector per node.

RuntimeOperationErrorRate is the error rate of a specified runtime operation.

RuntimeOperationMonitor is the tool getting and parsing docker operation metrics.

Simple helper class to avoid too much boilerplate in tests.

A test jig to help service testing.

StatefulSetTester is a struct that contains utility methods for testing StatefulSet related functionality.

TestCrd holds all the pieces needed to test with the CRD.

TimestampedSize contains a size together with a time of measurement.

VolumeTest contains a volume to mount into a client pod and its expected content.

Configuration of one tests.

WorkItem is a command for a worker that contains an IP of machine from which we want to gather data and paths to all files we're interested in.

CleanCrdFn declares the clean up function needed to remove the CRD.

ContainersCPUSummary is indexed by the container name with each entry a (percentile, value) map.

KubeletMetricByLatency implements sort.Interface for []KubeletMetric based on the latency field.

node -> file -> data.

NodeRuntimeOperationErrorRate is the runtime operation error rate on one node.

NodesCPUSummary is indexed by the node name with each entry a ContainersCPUSummary map.

we can't have int here, as JSON does not accept integer keys.

VerifyStatefulPodFunc is a func that examines a StatefulSetPod.