nifi

Documentation

Index

• Constants
• Variables
• func ComputeHostListenerNodeAddress(nodeId int32, clusterName, namespace string, clusterDomain string, ...) string
• func ComputeHostListenerNodeHostname(nodeId int32, clusterName, namespace string, clusterDomain string, ...) string
• func ComputeNodeName(nodeId int32, clusterName string) string
• func ComputeRequestNiFiAllNodeAddress(clusterName, namespace string, clusterDomain string, useExternalDNS bool, ...) string
• func ComputeRequestNiFiAllNodeHostname(clusterName, namespace string, clusterDomain string, useExternalDNS bool, ...) string
• func ComputeRequestNiFiAllNodeNamespace(clusterName, namespace string, useExternalDNS bool, serviceTemplate string) string
• func ComputeRequestNiFiAllNodeNamespaceFull(clusterName, namespace string, useExternalDNS bool, serviceTemplate string) string
• func ComputeRequestNiFiAllNodeService(clusterName string, serviceTemplate string) 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 *v1.NifiCluster) string
• func GenerateHostListenerNodeHostnameFromCluster(nodeId int32, cluster *v1.NifiCluster) string
• func GenerateRequestNiFiAllNodeAddressFromCluster(cluster *v1.NifiCluster) string
• func GenerateRequestNiFiAllNodeHostnameFromCluster(cluster *v1.NifiCluster) string
• func GenerateRequestNiFiNodeAddressFromCluster(nodeId int32, cluster *v1.NifiCluster) string
• func GenerateRequestNiFiNodeHostnameFromCluster(nodeId int32, cluster *v1.NifiCluster) string
• func InternalListenerForComm(internalListeners []v1.InternalListenerConfig) v1.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

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

Variables

var (
	NifiDataVolumeMountKey = fmt.Sprintf("%s/nifi-data", v1.GroupVersion.Group)
)

Functions

func ComputeHostListenerNodeAddress

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

func ComputeHostListenerNodeHostname

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

func ComputeNodeName

func ComputeNodeName(nodeId int32, clusterName string) string

> RequestNiFI >> Node

func ComputeRequestNiFiAllNodeAddress

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

func ComputeRequestNiFiAllNodeHostname

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

func ComputeRequestNiFiAllNodeNamespace

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

func ComputeRequestNiFiAllNodeNamespaceFull

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

func ComputeRequestNiFiAllNodeService

func ComputeRequestNiFiAllNodeService(
	clusterName string, serviceTemplate string) string

>> All node

func ComputeRequestNiFiNodeAddress

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

func ComputeRequestNiFiNodeHostname

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

func ComputeRequestNiFiNodeNamespace

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

func ComputeRequestNiFiNodeNamespaceFull

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

func ComputeRequestNiFiNodeService

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

func GenerateHostListenerNodeAddressFromCluster

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

func GenerateHostListenerNodeHostnameFromCluster

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

func GenerateRequestNiFiAllNodeAddressFromCluster

func GenerateRequestNiFiAllNodeAddressFromCluster(cluster *v1.NifiCluster) string

func GenerateRequestNiFiAllNodeHostnameFromCluster

func GenerateRequestNiFiAllNodeHostnameFromCluster(cluster *v1.NifiCluster) string

func GenerateRequestNiFiNodeAddressFromCluster

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

func GenerateRequestNiFiNodeHostnameFromCluster

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

func InternalListenerForComm

func InternalListenerForComm(internalListeners []v1.InternalListenerConfig) v1.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