nifi

Documentation

Index

• Constants
• func ComputeNiFiAddress(clusterName, namespace string, headlessServiceEnabled bool, ...) string
• func ComputeNiFiHostname(clusterName, namespace string, headlessServiceEnabled bool, ...) string
• func ComputeNodeAddress(nodeId int32, clusterName, namespace string, headlessServiceEnabled bool, ...) string
• func ComputeNodeHostname(nodeId int32, clusterName, namespace string, headlessServiceEnabled bool, ...) string
• func ComputeNodeHostnameFromCluster(nodeId int32, cluster *v1alpha1.NifiCluster) string
• func ComputeNodeName(nodeId int32, clusterName string) string
• func ComputeNodeServiceName(nodeId int32, clusterName string, headlessServiceEnabled bool) string
• func ComputeNodeServiceNameFull(nodeId int32, clusterName, namespace string, ...) string
• func ComputeNodeServiceNameNs(nodeId int32, clusterName, namespace string, ...) string
• func ComputeServiceName(clusterName string, headlessServiceEnabled bool) string
• func ComputeServiceNameFull(clusterName, namespace string, headlessServiceEnabled, useExternalDNS bool) string
• func ComputeServiceNameWithNamespace(clusterName, namespace string, headlessServiceEnabled, useExternalDNS bool) string
• func GenerateNiFiAddressFromCluster(cluster *v1alpha1.NifiCluster) string
• func GenerateNodeAddressFromCluster(nodeId int32, cluster *v1alpha1.NifiCluster) string
• func InternalListenerForComm(internalListeners []v1alpha1.InternalListenerConfig) v1alpha1.InternalListenerConfig
• 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 ComputeNiFiAddress

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

func ComputeNiFiHostname

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

func ComputeNodeAddress

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

func ComputeNodeHostname

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

func ComputeNodeHostnameFromCluster

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

func ComputeNodeName

func ComputeNodeName(nodeId int32, clusterName string) string

ComputeNodeName return the node name with right format.

func ComputeNodeServiceName

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

func ComputeNodeServiceNameFull

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

ComputeNodeServiceNameFull return the node service name in svc format

func ComputeNodeServiceNameNs

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

ComputeNodeServiceNameNs return the node service name in namespace format

func ComputeServiceName

func ComputeServiceName(clusterName string, headlessServiceEnabled bool) string

ComputeServiceName return the service name with the right format

func ComputeServiceNameFull

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

func ComputeServiceNameWithNamespace

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

ComputeServiceNameWithNamespace return the service name with namespace with the right format

func GenerateNiFiAddressFromCluster

func GenerateNiFiAddressFromCluster(cluster *v1alpha1.NifiCluster) string

func GenerateNodeAddressFromCluster

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

func InternalListenerForComm

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

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