nifi

package
v0.0.0-...-6a6528c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 11, 2021 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source
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"
)

Variables

This section is empty.

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 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

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL