nifi

Documentation

Index

• Constants
• func ComputeHostListenerNodeAddress(nodeId int32, clusterName, namespace string, headlessServiceEnabled bool, ...) string
• func ComputeHostListenerNodeHostname(nodeId int32, clusterName, namespace string, headlessServiceEnabled bool, ...) string
• func ComputeNodeName(nodeId int32, clusterName string) string
• func ComputeRequestNiFiAllNodeAddress(clusterName, namespace string, headlessServiceEnabled bool, ...) string
• func ComputeRequestNiFiAllNodeHostname(clusterName, namespace string, headlessServiceEnabled bool, ...) string
• func ComputeRequestNiFiAllNodeNamespace(clusterName, namespace string, headlessServiceEnabled, useExternalDNS bool) string
• func ComputeRequestNiFiAllNodeNamespaceFull(clusterName, namespace string, headlessServiceEnabled, useExternalDNS bool) string
• func ComputeRequestNiFiAllNodeService(clusterName string, headlessServiceEnabled bool) string
• func ComputeRequestNiFiNodeAddress(nodeId int32, clusterName, namespace string, headlessServiceEnabled bool, ...) string
• func ComputeRequestNiFiNodeHostname(nodeId int32, clusterName, namespace string, headlessServiceEnabled bool, ...) string
• func ComputeRequestNiFiNodeNamespace(nodeId int32, clusterName, namespace string, ...) string
• func ComputeRequestNiFiNodeNamespaceFull(nodeId int32, clusterName, namespace string, ...) string
• func ComputeRequestNiFiNodeService(nodeId int32, clusterName string, headlessServiceEnabled bool) string
• func GenerateHostListenerNodeAddressFromCluster(nodeId int32, cluster *v1alpha1.NifiCluster) string
• func GenerateHostListenerNodeHostnameFromCluster(nodeId int32, cluster *v1alpha1.NifiCluster) string
• func GenerateRequestNiFiAllNodeAddressFromCluster(cluster *v1alpha1.NifiCluster) string
• func GenerateRequestNiFiAllNodeHostnameFromCluster(cluster *v1alpha1.NifiCluster) string
• func GenerateRequestNiFiNodeAddressFromCluster(nodeId int32, cluster *v1alpha1.NifiCluster) string
• func GenerateRequestNiFiNodeHostnameFromCluster(nodeId int32, cluster *v1alpha1.NifiCluster) string
• func InternalListenerForComm(internalListeners []v1alpha1.InternalListenerConfig) v1alpha1.InternalListenerConfig
• func LabelsForNifi(name string) map[string]string
• func ParseStringToInt32(nodeId string) (int32, error)
• func ParseTimeStampToUnixTime(timestamp string) (time.Time, error)

Constants

const (
	PrefixNodeNameTemplate = "%s-"
	SuffixNodeNameTemplate = "-node"
	RootNodeNameTemplate   = "%d"
	NodeNameTemplate       = PrefixNodeNameTemplate + RootNodeNameTemplate + SuffixNodeNameTemplate
	// AllNodeServiceTemplate template for Nifi all nodes service
	AllNodeServiceTemplate = "%s-all-node"
	// HeadlessServiceTemplate template for Nifi headless service
	HeadlessServiceTemplate = "%s-headless"

	// TimeStampLayout defines the date format used.
	TimeStampLayout = "Mon, 2 Jan 2006 15:04:05 GMT"
)

Functions

func ComputeHostListenerNodeAddress

func ComputeHostListenerNodeAddress(
	nodeId int32,
	clusterName, namespace string,
	headlessServiceEnabled bool,
	clusterDomain string,
	useExternalDNS bool,
	internalListeners []v1alpha1.InternalListenerConfig) string

func ComputeHostListenerNodeHostname

func ComputeHostListenerNodeHostname(
	nodeId int32,
	clusterName, namespace string,
	headlessServiceEnabled bool,
	clusterDomain string,
	useExternalDNS bool) string

func ComputeNodeName

func ComputeNodeName(nodeId int32, clusterName string) string

> RequestNiFI >> Node

func ComputeRequestNiFiAllNodeAddress

func ComputeRequestNiFiAllNodeAddress(
	clusterName, namespace string,
	headlessServiceEnabled bool,
	clusterDomain string,
	useExternalDNS bool,
	internalListeners []v1alpha1.InternalListenerConfig) string

func ComputeRequestNiFiAllNodeHostname

func ComputeRequestNiFiAllNodeHostname(
	clusterName, namespace string,
	headlessServiceEnabled bool,
	clusterDomain string,
	useExternalDNS bool) string

func ComputeRequestNiFiAllNodeNamespace

func ComputeRequestNiFiAllNodeNamespace(clusterName, namespace string, headlessServiceEnabled, useExternalDNS bool) string

func ComputeRequestNiFiAllNodeNamespaceFull

func ComputeRequestNiFiAllNodeNamespaceFull(
	clusterName, namespace string,
	headlessServiceEnabled, useExternalDNS bool) string

func ComputeRequestNiFiAllNodeService

func ComputeRequestNiFiAllNodeService(clusterName string, headlessServiceEnabled bool) string

>> All node

func ComputeRequestNiFiNodeAddress

func ComputeRequestNiFiNodeAddress(
	nodeId int32,
	clusterName, namespace string,
	headlessServiceEnabled bool,
	clusterDomain string,
	useExternalDNS bool,
	internalListeners []v1alpha1.InternalListenerConfig) string

func ComputeRequestNiFiNodeHostname

func ComputeRequestNiFiNodeHostname(
	nodeId int32,
	clusterName, namespace string,
	headlessServiceEnabled bool,
	clusterDomain string,
	useExternalDNS bool) string

func ComputeRequestNiFiNodeNamespace

func ComputeRequestNiFiNodeNamespace(nodeId int32, clusterName, namespace string, headlessServiceEnabled, useExternalDNS bool) string

func ComputeRequestNiFiNodeNamespaceFull

func ComputeRequestNiFiNodeNamespaceFull(
	nodeId int32,
	clusterName, namespace string,
	headlessServiceEnabled, useExternalDNS bool) string

func ComputeRequestNiFiNodeService

func ComputeRequestNiFiNodeService(nodeId int32, clusterName string, headlessServiceEnabled bool) string

func GenerateHostListenerNodeAddressFromCluster

func GenerateHostListenerNodeAddressFromCluster(nodeId int32, cluster *v1alpha1.NifiCluster) string

func GenerateHostListenerNodeHostnameFromCluster

func GenerateHostListenerNodeHostnameFromCluster(nodeId int32, cluster *v1alpha1.NifiCluster) string

func GenerateRequestNiFiAllNodeAddressFromCluster

func GenerateRequestNiFiAllNodeAddressFromCluster(cluster *v1alpha1.NifiCluster) string

func GenerateRequestNiFiAllNodeHostnameFromCluster

func GenerateRequestNiFiAllNodeHostnameFromCluster(cluster *v1alpha1.NifiCluster) string

func GenerateRequestNiFiNodeAddressFromCluster

func GenerateRequestNiFiNodeAddressFromCluster(nodeId int32, cluster *v1alpha1.NifiCluster) string

func GenerateRequestNiFiNodeHostnameFromCluster

func GenerateRequestNiFiNodeHostnameFromCluster(nodeId int32, cluster *v1alpha1.NifiCluster) string

func InternalListenerForComm

func InternalListenerForComm(internalListeners []v1alpha1.InternalListenerConfig) v1alpha1.InternalListenerConfig

func LabelsForNifi

func LabelsForNifi(name string) map[string]string

LabelsForNifi returns the labels for selecting the resources belonging to the given Nifi CR name.

func ParseStringToInt32

func ParseStringToInt32(nodeId string) (int32, error)

func ParseTimeStampToUnixTime

func ParseTimeStampToUnixTime(timestamp string) (time.Time, error)

ParseTimeStampToUnixTime parses the given CC timeStamp to time format