common

Documentation

Index

• Variables
• func ApplyClusterRefLabel(cluster *v1alpha1.NifiCluster, labels map[string]string) map[string]string
• func CheckNodeConnectionError(logger logr.Logger, err error) (ctrl.Result, error)
• func ClusterLabelString(cluster *v1alpha1.NifiCluster) string
• func GetClusterRefNamespace(ns string, ref v1alpha1.ClusterReference) string
• func NewNodeConnection(log logr.Logger, client client.Client, cluster *v1alpha1.NifiCluster) (node nificlient.NifiClient, err error)
• func Reconciled() (reconcile.Result, error)
• func RequeueWithError(logger logr.Logger, msg string, err error) (reconcile.Result, error)

Variables

var ClusterRefLabel = "nifiCluster"

Functions

func ApplyClusterRefLabel

func ApplyClusterRefLabel(cluster *v1alpha1.NifiCluster, labels map[string]string) map[string]string

applyClusterRefLabel ensures a map of labels contains a reference to a parent nifi cluster

func CheckNodeConnectionError

func CheckNodeConnectionError(logger logr.Logger, err error) (ctrl.Result, error)

checkNodeConnectionError is a convenience wrapper for returning from common node connection errors

func ClusterLabelString

func ClusterLabelString(cluster *v1alpha1.NifiCluster) string

clusterLabelString returns the label value for a cluster reference

func GetClusterRefNamespace

func GetClusterRefNamespace(ns string, ref v1alpha1.ClusterReference) string

getClusterRefNamespace returns the expected namespace for a Nifi cluster referenced by a user/dataflow CR. It takes the namespace of the CR as the first argument and the reference itself as the second.

func NewNodeConnection

func NewNodeConnection(log logr.Logger, client client.Client, cluster *v1alpha1.NifiCluster) (node nificlient.NifiClient, err error)

newNodeConnection is a convenience wrapper for creating a node connection and creating a safer close function

func Reconciled

func Reconciled() (reconcile.Result, error)

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

func RequeueWithError

func RequeueWithError(logger logr.Logger, msg string, err error) (reconcile.Result, error)

requeueWithError is a convenience wrapper around logging an error message separate from the stacktrace and then passing the error through to the controller manager