Documentation
¶
Index ¶
- func AddNewNodeToCr(node v1.Node, crName, namespace string, client runtimeClient.Client) error
- func AddPvToSpecificNode(nodeId, crName, namespace string, storageConfig *v1.StorageConfig, ...) error
- func CheckIfObjectUpdated(log zap.Logger, desiredType reflect.Type, current, desired runtime.Object) bool
- func Cr(name, namespace string, client runtimeClient.Client) (*v1.NifiCluster, error)
- func DeleteStatus(c client.Client, nodeId string, cluster *v1.NifiCluster, ...) error
- func IsAlreadyOwnedError(err error) bool
- func IsMarkedForDeletion(m metav1.ObjectMeta) bool
- func IsPodContainsPendingContainer(pod *corev1.Pod) bool
- func IsPodContainsTerminatedContainer(pod *corev1.Pod) bool
- func IsPodTerminatedOrShutdown(pod *corev1.Pod) bool
- func LookupNifiCluster(client runtimeClient.Client, clusterName, clusterNamespace string) (cluster *v1.NifiCluster, err error)
- func LookupNifiParameterContext(client runtimeClient.Client, ...) (parameterContext *v1.NifiParameterContext, err error)
- func LookupNifiRegistryClient(client runtimeClient.Client, ...) (registryClient *v1.NifiRegistryClient, err error)
- func LookupNifiUser(client runtimeClient.Client, userName, userNamespace string) (user *v1.NifiUser, err error)
- func LookupSecret(client runtimeClient.Client, secretName, secretNamespace string) (secret *corev1.Secret, err error)
- func PodReady(pod *corev1.Pod) bool
- func Reconcile(log zap.Logger, client runtimeClient.Client, desired runtimeClient.Object, ...) error
- func RemoveNodeFromCr(nodeId, crName, namespace string, client runtimeClient.Client) error
- func UpdateCRStatus(c client.Client, cluster *v1.NifiCluster, currentStatus v1.NifiClusterStatus, ...) error
- func UpdateCrWithRollingUpgrade(errorCount int, cr *v1.NifiCluster, client runtimeClient.Client) error
- func UpdateNodeStatus(c client.Client, nodeIds []string, cluster *v1.NifiCluster, ...) error
- func UpdateRollingUpgradeState(c client.Client, cluster *v1.NifiCluster, currentStatus v1.NifiClusterStatus, ...) error
- func UpdateRootProcessGroupIdStatus(c client.Client, cluster *v1.NifiCluster, currentStatus v1.NifiClusterStatus, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddNewNodeToCr ¶
AddNewNodeToCr modifies the CR and adds a new node
func AddPvToSpecificNode ¶
func AddPvToSpecificNode(nodeId, crName, namespace string, storageConfig *v1.StorageConfig, client runtimeClient.Client) error
AddPvToSpecificNode adds a new PV to a specific node
func CheckIfObjectUpdated ¶
func CheckIfObjectUpdated(log zap.Logger, desiredType reflect.Type, current, desired runtime.Object) bool
CheckIfObjectUpdated checks if the given object is updated using K8sObjectMatcher
func Cr ¶
func Cr(name, namespace string, client runtimeClient.Client) (*v1.NifiCluster, error)
Cr returns the given cr object
func DeleteStatus ¶
func DeleteStatus(c client.Client, nodeId string, cluster *v1.NifiCluster, currentStatus v1.NifiClusterStatus, logger zap.Logger) error
DeleteStatus deletes the given node state from the CR
func IsAlreadyOwnedError ¶
IsAlreadyOwnedError checks if a controller already own the instance
func IsMarkedForDeletion ¶
func IsMarkedForDeletion(m metav1.ObjectMeta) bool
IsMarkedForDeletion determines if the object is marked for deletion
func LookupNifiCluster ¶
func LookupNifiCluster(client runtimeClient.Client, clusterName, clusterNamespace string) (cluster *v1.NifiCluster, err error)
LookupNifiCluster returns the running cluster instance based on its name and namespace
func LookupNifiParameterContext ¶
func LookupNifiParameterContext(client runtimeClient.Client, parameterContextName, parameterContextNamespace string) (parameterContext *v1.NifiParameterContext, err error)
LookupNifiParameterContext returns the parameter context instance based on its name and namespace
func LookupNifiRegistryClient ¶
func LookupNifiRegistryClient(client runtimeClient.Client, registryClientName, registryClientNamespace string) (registryClient *v1.NifiRegistryClient, err error)
LookupNifiRegistryClient returns the running registry client instance based on its name and namespace
func LookupNifiUser ¶
func LookupNifiUser(client runtimeClient.Client, userName, userNamespace string) (user *v1.NifiUser, err error)
LookupNifiUser returns the user instance based on its name and namespace
func LookupSecret ¶
func LookupSecret(client runtimeClient.Client, secretName, secretNamespace string) (secret *corev1.Secret, err error)
LookupSecret returns the secret instance based on its name and namespace
func Reconcile ¶
func Reconcile(log zap.Logger, client runtimeClient.Client, desired runtimeClient.Object, cr *nifikopv1.NifiCluster, currentStatus *nifikopv1.NifiClusterStatus) error
Reconcile reconciles K8S resources
func RemoveNodeFromCr ¶
func RemoveNodeFromCr(nodeId, crName, namespace string, client runtimeClient.Client) error
RemoveNodeFromCr modifies the CR and removes the given node from the cluster
func UpdateCRStatus ¶
func UpdateCRStatus(c client.Client, cluster *v1.NifiCluster, currentStatus v1.NifiClusterStatus, state interface{}, logger zap.Logger) error
UpdateCRStatus updates the cluster state
func UpdateCrWithRollingUpgrade ¶
func UpdateCrWithRollingUpgrade(errorCount int, cr *v1.NifiCluster, client runtimeClient.Client) error
UpdateCrWithRollingUpgrade modifies CR status
func UpdateNodeStatus ¶
func UpdateNodeStatus(c client.Client, nodeIds []string, cluster *v1.NifiCluster, currentStatus v1.NifiClusterStatus, state interface{}, logger zap.Logger) error
UpdateNodeStatus updates the node status with rack and configuration infos
func UpdateRollingUpgradeState ¶
func UpdateRollingUpgradeState(c client.Client, cluster *v1.NifiCluster, currentStatus v1.NifiClusterStatus, time time.Time, logger zap.Logger) error
UpdateRollingUpgradeState updates the state of the cluster with rolling upgrade info
func UpdateRootProcessGroupIdStatus ¶
func UpdateRootProcessGroupIdStatus(c client.Client, cluster *v1.NifiCluster, currentStatus v1.NifiClusterStatus, id string, logger zap.Logger) error
UpdateRootProcessGroupIdStatus updates the cluster root process group id
Types ¶
This section is empty.
Source Files