util

Documentation

Index

• func BoolPointer(b bool) *bool
• func ConvertMapStringToMapStringPointer(inputMap map[string]string) map[string]*string
• func ConvertStringToInt32(s string) int32
• func GetEnvWithDefault(key string, fallback string) string
• func GetNodeConfig(node v1alpha1.Node, clusterSpec v1alpha1.NifiClusterSpec) (*v1alpha1.NodeConfig, error)
• func GetNodeImage(nodeConfig *v1alpha1.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 IsSSLEnabledForInternalCommunication(l []v1alpha1.InternalListenerConfig) (enabled bool)
• func MapStringStringPointer(in map[string]string) (out map[string]*string)
• func Max(x, y int) int
• func MergeAnnotations(annotations ...map[string]string) map[string]string
• func MergeLabels(l ...map[string]string) map[string]string
• func MonitoringAnnotations(port int) map[string]string
• func MustConvertToInt(str string, name string) int
• func NifiUserSliceContains(list []*v1alpha1.NifiUser, u *v1alpha1.NifiUser) bool
• func NodesToIdList(nodes []v1alpha1.Node) (ids []int32)
• func ParsePropertiesFormat(properties string) map[string]string
• func StringPointer(s string) *string
• func StringSliceContains(list []string, s string) bool
• func StringSliceRemove(list []string, s string) []string

Functions

func BoolPointer

func BoolPointer(b bool) *bool

BoolPointer generates bool pointer from bool

func ConvertMapStringToMapStringPointer

func ConvertMapStringToMapStringPointer(inputMap map[string]string) map[string]*string

ConvertMapStringToMapStringPointer converts a simple map[string]string to map[string]*string

func ConvertStringToInt32

func ConvertStringToInt32(s string) int32

ConvertStringToInt32 converts the given string to int32

func GetEnvWithDefault

func GetEnvWithDefault(key string, fallback string) string

func GetNodeConfig

func GetNodeConfig(node v1alpha1.Node, clusterSpec v1alpha1.NifiClusterSpec) (*v1alpha1.NodeConfig, error)

GetNodeConfig compose the nodeConfig for a given nifi node

func GetNodeImage

func GetNodeImage(nodeConfig *v1alpha1.NodeConfig, clusterImage string) string

GetNodeImage returns the used node image

func GetRequeueInterval

func GetRequeueInterval(interval int, offset int) time.Duration

func Hash

func Hash(s string) string

func Int32Pointer

func Int32Pointer(i int32) *int32

Int32Pointer generates int32 pointer from int32

func Int64Pointer

func Int64Pointer(i int64) *int64

Int64Pointer generates int64 pointer from int64

func IntPointer

func IntPointer(i int) *int

IntPointer generates int pointer from int

func IntstrPointer

func IntstrPointer(i int) *intstr.IntOrString

IntstrPointer generate IntOrString pointer from int

func IsSSLEnabledForInternalCommunication

func IsSSLEnabledForInternalCommunication(l []v1alpha1.InternalListenerConfig) (enabled bool)

IsSSLEnabledForInternalCommunication checks if ssl is enabled for internal communication

func MapStringStringPointer

func MapStringStringPointer(in map[string]string) (out map[string]*string)

MapStringStringPointer generates a map[string]*string

func Max

func Max(x, y int) int

computes the max between 2 ints

func MergeAnnotations

func MergeAnnotations(annotations ...map[string]string) map[string]string

func MergeLabels

func MergeLabels(l ...map[string]string) map[string]string

MergeLabels merges two given labels

func MonitoringAnnotations

func MonitoringAnnotations(port int) map[string]string

MonitoringAnnotations returns specific prometheus annotations

func MustConvertToInt

func MustConvertToInt(str string, name string) int

func NifiUserSliceContains

func NifiUserSliceContains(list []*v1alpha1.NifiUser, u *v1alpha1.NifiUser) bool

NifiUserSliceContains returns true if list contains s

func NodesToIdList

func NodesToIdList(nodes []v1alpha1.Node) (ids []int32)

func ParsePropertiesFormat

func ParsePropertiesFormat(properties string) map[string]string

ParsePropertiesFormat parses the properties format configuration into map[string]string

func StringPointer

func StringPointer(s string) *string

StringPointer generates string pointer from string

func StringSliceContains

func StringSliceContains(list []string, s string) bool

StringSliceContains returns true if list contains s

func StringSliceRemove

func StringSliceRemove(list []string, s string) []string

StringSliceRemove will remove s from list