BackgroundDeleteObject deletes the object in the background, usually used in the Reconcile method.

BuildPodHostDNS builds the host dns of pod.

CheckedRequeueWithError passes the error through to the controller manager, it ignores unknown errors.

CheckResourceExists checks whether resource exist or not.

DeleteOwnedResources deletes the matched resources which are owned by the owner.

GetConfigSpecReconcilePhase gets the configuration phase.

GetContainerByConfigSpec searches for container using the configmap of config from the pod e.g.: ClusterDefinition.configTemplateRef: - Name: "mysql-8.0" VolumeName: "mysql_config" PodTemplate.containers[*].volumeMounts: - mountPath: /data/config name: mysql_config - mountPath: /data name: data - mountPath: /log name: log.

GetContainerID gets the containerID from pod by name.

GetCoreNum gets content of Resources.Limits.cpu.

GetMemorySize gets content of Resources.Limits.memory.

GetPodContainer gets the pod container by name.

GetPodContainerWithVolumeMount searches for containers mounting the volume.

GetPodListByInstanceSet gets ITS pod list.

GetPodRevision gets the revision of Pod by inspecting the StatefulSetRevisionLabel.

GetRequestMemorySize gets content of Resources.Limits.memory.

GetStorageSizeFromPersistentVolume gets content of Resources.Requests.storage.

GetUncachedObjects returns a list of K8s objects, for these object types, and their list types, client.Reader will read directly from the API server instead of the cache, which may not be up-to-date.

GetVolumeMountName finds the volume with mount name.

HandleCRDeletion handles CR deletion, adds finalizer if found a non-deleting object and removes finalizer during deletion process.

IgnoreIsAlreadyExists returns errors if 'err' is not type of AlreadyExists.

IsApplyConfigChanged checks if the configuration is changed.

IsNotFound returns true if the specified error is the error type of ErrorTypeNotFound.

IsPodFailedAndTimedOut checks if the pod is failed and timed out.

IsRequeueError checks if the error is the RequeueError.

IsRerender checks if the configuration template is changed.

IsTargetError checks if the error is the target error.

MergeAndValidateConfigs merges and validates configuration files.

MergeMetadataMapInplace merges two map[string]string, the targetMap will be updated.

NewDelayedRequeueError creates a delayed requeue error which only returns in the last step of the DAG.

NewFatalError returns a new Error with ErrorTypeFatal.

NewNotFound returns a new Error with ErrorTypeNotFound.

NewPortManager creates a new PortManager TODO[ziang] Putting all the port information in one configmap may have performance issues and is not secure enough.

PodIsReady checks if pod is ready.

PodIsReadyWithLabel checks if pod is ready for ConsensusSet/ReplicationSet component, it will be available when the pod is ready and labeled with role.

Reconciled returns an empty result with nil error to signal a successful reconcile to the controller manager.

RecordCreatedEvent records an event when a CR created successfully.

RequeueWithError requeues when an error occurs.

RequeueWithErrorAndRecordEvent requeues when an error occurs.

ResolveContainerDefaultFields set default value for some known fields of proto Container @pcontainer.

ResolvePodSpecDefaultFields set default value for some known fields of proto PodSpec @pobj.

ResultToP converts a Result object to a pointer.

SetOwnership provides helper function controllerutil.SetControllerReference/controllerutil.SetOwnerReference and controllerutil.AddFinalizer if not exists.

UnwrapControllerError unwraps the Controller error from target error.

ValidateReferenceCR validates existing referencing CRs, if exists, requeue reconcile after 30 seconds.

ErrorType for cluster controller.

ErrorTypeExpectedInProcess is used to indicate that the operation is expected to be in process.

fatal error.

waiting for next reconcile.

ErrorTypeNotFound not found any resource.

ErrorType for preflight.

requeue for reconcile.

ErrorWaitCacheRefresh waits for synchronization of the corresponding object cache in client-go from ApiServer.

PodContainerFailedTimeout the timeout for container of pod failures, the component phase will be set to Failed after this time.

RequestCtx wrapper for reconcile procedure context parameters.

ByPodName sorts a list of jobs by pod name.

ErrorType is explicit error type.