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 GetParameterContextRefNamespace(ns string, ref v1alpha1.ParameterContextReference) string
• func GetRegistryClientRefNamespace(ns string, ref v1alpha1.RegistryClientReference) string
• func GetSecretRefNamespace(ns string, ref v1alpha1.SecretReference) string
• func GetUserRefNamespace(ns string, ref v1alpha1.UserReference) string
• func NewNodeConnection(log logr.Logger, client client.Client, cluster *v1alpha1.NifiCluster) (node nificlient.NifiClient, err error)
• func Reconciled() (reconcile.Result, error)
• func Requeue() (reconcile.Result, error)
• func RequeueAfter(time time.Duration) (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 GetParameterContextRefNamespace

func GetParameterContextRefNamespace(ns string, ref v1alpha1.ParameterContextReference) string

GetParameterContextRefNamespace returns the expected namespace for a Nifi parameter context referenced by a dataflow CR. It takes the namespace of the CR as the first argument and the reference itself as the second.

func GetRegistryClientRefNamespace

func GetRegistryClientRefNamespace(ns string, ref v1alpha1.RegistryClientReference) string

GetRegistryClientRefNamespace returns the expected namespace for a Nifi registry client referenced by a dataflow CR. It takes the namespace of the CR as the first argument and the reference itself as the second.

func GetSecretRefNamespace

func GetSecretRefNamespace(ns string, ref v1alpha1.SecretReference) string

GetSecretRefNamespace returns the expected namespace for a Nifi secret referenced by a parameter context CR. It takes the namespace of the CR as the first argument and the reference itself as the second.

func GetUserRefNamespace

func GetUserRefNamespace(ns string, ref v1alpha1.UserReference) string

GetUserRefNamespace returns the expected namespace for a Nifi user referenced by a parameter context 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 Requeue

func Requeue() (reconcile.Result, error)

func RequeueAfter

func RequeueAfter(time time.Duration) (reconcile.Result, error)

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