ArrayContains tells whether a contains x.

ArrayFind returns the smallest index i at which x == a[i], or len(a) if there is no such index.

CmpResourceList returns true if the resourceList a is equal to b,.

CmpResources returns true if the resource requirements a is equal to b,.

EnsureEnvVar updates existingEnvVars with desired, reconciling any possible differences.

EnsureObjectMeta ensure Labels, Annotations.

EnvVarReconciler implements basic env var reconciliation.

FindEnvVar returns the smallest index i at which x == a[i], or -1 if there is no such index.

FindVolumeByName returns the smallest index i at which x.Name == a[i].Name, or -1 if there is no such index.

FindVolumeMountByMountPath returns the smallest index i at which x.MountPath == a[i].MountPath, or -1 if there is no such index.

FindVolumeMountByMountPath returns the smallest index i at which x.MountPath == a[i].MountPath, or -1 if there is no such index.

GenericConsoleLinkMutator performs the reconciliation for consolelink objects.

GetMasterConsoleLink creates the consolelink obj for a target.

GetMasterConsoleLinkName returns the consolelink name.

GetOperatorNamespace returns the namespace the operator should be running in.

GetWatchNamespace returns the Namespace the operator should be watching for changes.

HasAppGenerationChanged returns true if the system-app Deployment's generation doesn't match the Job's annotation tracking it.

HasJobCompleted checks if the provided Job has completed.

IsDeploymentAvailable returns true when the provided Deployment has the "Available" condition set to true.

IsDeploymentProgressing returns true when the provided Deployment is progressing with new ReplicaSet.

IsRouteReady returns true when all Ingresses of the Route have the "Admitted" Condition set to true.

IsRunInCluster checks if the operator is run in cluster.

IsRunLocally checks if the operator is run locally.

Returns a new map containing the contents of `from` and the contents of `to`.

NewTaskRunner TaskRunner Constructor.

PortFromURL infers port number if it is not explict.

ReconcileErrorHandler reads the error type and based on that, it responsds with either a requeue true or false.

RemoveDuplicateEnvVars removes duplicate env vars by name from a slice.

RouteFindByHost returns the smallest index i at which a route with a given host is found or -1 if there is no such index.

SetURLDefaultPort adds the default Port if not set.

https://newbedev.com/check-for-equality-on-slices-without-order.

UIDBasedJobName returns a Job name that is compromised of the provided prefix, a hyphen and the provided uid: "<prefix>-<uid>".

ConsoleLinkMasterNamePrefix is the prefix applied to Console link for system master.

ConsoleLinkText is the text of the consoleLink shown on the webconsole.

InvalidError represents that the combination of configuration in the resource spec is not supported.

OrphanError represents that the configuration in the resource spec contains reference to some not existing resource.

DefaultTransport is the default logging transport that wraps http.DefaultTransport.

Errors.

InvalidDNS1123Regexp not alphanumeric.

NonAlphanumRegexp not alphanumeric.

NonWordCharRegexp not word characters (== [^0-9A-Za-z_]).

TemplateRegexp used to render openapi server URLs.

MemoryCache implements a simple memory cache No expiration No eviction policies Not threadsafe.

OasMappingRuleExtension contains fields from the v1beta1.MappingRuleSpec type that can only be set in an OAS extension.

Transport implements http.RoundTripper.

WaitError represents that the current cluster state is not ready to continue.

go:generate moq -out pod_executor_moq.go .

SpecError is exposed by errors that can be converted to an api.Status object for finer grained details.

TaskRunner abstracts task running engine.