AddNewNodeToCr modifies the CR and adds a new node.

AddPvToSpecificNode adds a new PV to a specific node.

CheckIfObjectUpdated checks if the given object is updated using K8sObjectMatcher.

Cr returns the given cr object.

DeleteStatus deletes the given node state from the CR.

IsAlreadyOwnedError checks if a controller already own the instance.

IsMarkedForDeletion determines if the object is marked for deletion.

LookupNifiCluster returns the running cluster instance based on its name and namespace.

LookupNifiParameterContext returns the parameter context instance based on its name and namespace.

LookupNifiRegistryClient returns the running registry client instance based on its name and namespace.

LookupNifiUser returns the user instance based on its name and namespace.

LookupSecret returns the secret instance based on its name and namespace.

Reconcile reconciles K8S resources.

RemoveNodeFromCr modifies the CR and removes the given node from the cluster.

UpdateCRStatus updates the cluster state.

UpdateCrWithRollingUpgrade modifies CR status.

UpdateNodeStatus updates the node status with rack and configuration infos.

UpdateRollingUpgradeState updates the state of the cluster with rolling upgrade info.

UpdateRootProcessGroupIdStatus updates the cluster root process group id.