Documentation
¶
Index ¶
- func BoolPointer(b bool) *bool
- func ConvertMapStringToMapStringPointer(inputMap map[string]string) map[string]*string
- func ConvertStringToInt32(s string) int32
- func ExtractSecretsResourceVersion(secrets []*corev1.Secret) []v1.SecretResourceVersion
- func GetEnvWithDefault(key string, fallback string) string
- func GetK8sVersion() (major *int, minor *int, err error)
- func GetNodeConfig(node v1.Node, clusterSpec v1.NifiClusterSpec) (*v1.NodeConfig, error)
- func GetNodeImage(nodeConfig *v1.NodeConfig, clusterImage string) string
- func GetRequeueInterval(interval int, offset int) time.Duration
- func Hash(s string) string
- func Int32Pointer(i int32) *int32
- func Int64Pointer(i int64) *int64
- func IntPointer(i int) *int
- func IntstrPointer(i int) *intstr.IntOrString
- func IsK8sPrior1_21() bool
- func IsSSLEnabledForInternalCommunication(l []v1.InternalListenerConfig) (enabled bool)
- func IsSecretResourceVersionUpdated(secrets []*corev1.Secret, secretsResourceVersion []v1.SecretResourceVersion) bool
- func MapStringStringPointer(in map[string]string) (out map[string]*string)
- func Max(x, y int) int
- func MaxSlice32(s []int32) (int32, error)
- func MergeAnnotations(annotations ...map[string]string) map[string]string
- func MergeHostAliases(globalAliases []corev1.HostAlias, overrideAliases []corev1.HostAlias) []corev1.HostAlias
- func MergeLabels(l ...map[string]string) map[string]string
- func MinSlice32(s []int32) (int32, error)
- func MonitoringAnnotations(port int) map[string]string
- func MustConvertToInt(str string, name string) int
- func NifiUserSliceContains(list []*v1.NifiUser, u *v1.NifiUser) bool
- func NodesToIdList(nodes []v1.Node) (ids []int32)
- func NodesToIdMap(nodes []v1.Node) (nodeMap map[int32]v1.Node)
- func ParsePropertiesFormat(properties string) map[string]string
- func StringPointer(s string) *string
- func StringSliceCompare(list1 []string, list2 []string) bool
- func StringSliceContains(list []string, s string) bool
- func StringSliceRemove(list []string, s string) []string
- func StringSliceStrictCompare(list1 []string, list2 []string) bool
- func SubtractNodes(originalNodes []v1.Node, nodesToRemove []v1.Node) (results []v1.Node)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConvertMapStringToMapStringPointer ¶
ConvertMapStringToMapStringPointer converts a simple map[string]string to map[string]*string.
func ConvertStringToInt32 ¶
ConvertStringToInt32 converts the given string to int32.
func ExtractSecretsResourceVersion ¶
func ExtractSecretsResourceVersion(secrets []*corev1.Secret) []v1.SecretResourceVersion
func GetEnvWithDefault ¶
func GetK8sVersion ¶
func GetNodeConfig ¶
func GetNodeConfig(node v1.Node, clusterSpec v1.NifiClusterSpec) (*v1.NodeConfig, error)
GetNodeConfig compose the nodeConfig for a given nifi node.
func GetNodeImage ¶
func GetNodeImage(nodeConfig *v1.NodeConfig, clusterImage string) string
GetNodeImage returns the used node image.
func Int32Pointer ¶
Int32Pointer generates int32 pointer from int32.
func Int64Pointer ¶
Int64Pointer generates int64 pointer from int64.
func IntstrPointer ¶
func IntstrPointer(i int) *intstr.IntOrString
IntstrPointer generate IntOrString pointer from int.
func IsK8sPrior1_21 ¶
func IsK8sPrior1_21() bool
func IsSSLEnabledForInternalCommunication ¶
func IsSSLEnabledForInternalCommunication(l []v1.InternalListenerConfig) (enabled bool)
IsSSLEnabledForInternalCommunication checks if ssl is enabled for internal communication.
func IsSecretResourceVersionUpdated ¶
func IsSecretResourceVersionUpdated(secrets []*corev1.Secret, secretsResourceVersion []v1.SecretResourceVersion) bool
func MapStringStringPointer ¶
MapStringStringPointer generates a map[string]*string.
func MergeHostAliases ¶
func MergeHostAliases(globalAliases []corev1.HostAlias, overrideAliases []corev1.HostAlias) []corev1.HostAlias
MergeHostAliases takes two host alias lists and merges them. For IP conflicts, the latter/second list takes precedence.
func MergeLabels ¶
MergeLabels merges two given labels.
func MonitoringAnnotations ¶
MonitoringAnnotations returns specific prometheus annotations.
func MustConvertToInt ¶
func NifiUserSliceContains ¶
NifiUserSliceContains returns true if list contains s.
func NodesToIdList ¶
func ParsePropertiesFormat ¶
ParsePropertiesFormat parses the properties format configuration into map[string]string.
func StringPointer ¶
StringPointer generates string pointer from string.
func StringSliceCompare ¶
StringSliceCompare returns true if the two lists of string are the same.
func StringSliceContains ¶
StringSliceContains returns true if list contains s.
func StringSliceRemove ¶
StringSliceRemove will remove s from list.
func StringSliceStrictCompare ¶
StringSliceStrictCompare returns true if the two lists of string are the same with the order taking into account.
Types ¶
This section is empty.
Source Files
Directories