helper

Documentation

Index

• func ClusterAutoscalerRequired(pools []extensionsv1alpha1.WorkerPool) bool
• func Decode(codecIDString string, data []byte) ([]byte, error)
• func DeterminePrimaryIPFamily(ipFamilies []extensionsv1alpha1.IPFamily) extensionsv1alpha1.IPFamily
• func FilePathsFrom(files []extensionsv1alpha1.File) []string
• func GetDNSRecordTTL(ttl *int64) int64
• func GetDNSRecordType(address string) extensionsv1alpha1.DNSRecordType
• func GetMachineDeploymentClusterAutoscalerAnnotations(caOptions *extensionsv1alpha1.ClusterAutoscalerOptions) map[string]string
• func HasContainerdConfiguration(criConfig *extensionsv1alpha1.CRIConfig) bool
• func ParseFileCodecID(s string) (extensionsv1alpha1.FileCodecID, error)
• type FileCodec
  • func FileCodecForID(id extensionsv1alpha1.FileCodecID) FileCodec

Functions

func ClusterAutoscalerRequired

func ClusterAutoscalerRequired(pools []extensionsv1alpha1.WorkerPool) bool

ClusterAutoscalerRequired returns whether the given worker pool configuration indicates that a cluster-autoscaler is needed.

func Decode

func Decode(codecIDString string, data []byte) ([]byte, error)

Decode decodes the given data using the codec from resolving the given codecIDString. It's a shorthand for parsing the FileCodecID and calling the `Decode` method on the obtained FileCodec.

func DeterminePrimaryIPFamily

func DeterminePrimaryIPFamily(ipFamilies []extensionsv1alpha1.IPFamily) extensionsv1alpha1.IPFamily

DeterminePrimaryIPFamily determines the primary IP family out of a specified list of IP families.

func FilePathsFrom

func FilePathsFrom(files []extensionsv1alpha1.File) []string

FilePathsFrom returns the paths for all the given files.

func GetDNSRecordTTL

func GetDNSRecordTTL(ttl *int64) int64

GetDNSRecordTTL returns the value of the given ttl, or 120 if nil.

func GetDNSRecordType

func GetDNSRecordType(address string) extensionsv1alpha1.DNSRecordType

GetDNSRecordType returns the appropriate DNS record type (A/AAAA or CNAME) for the given address.

func GetMachineDeploymentClusterAutoscalerAnnotations

func GetMachineDeploymentClusterAutoscalerAnnotations(caOptions *extensionsv1alpha1.ClusterAutoscalerOptions) map[string]string

GetMachineDeploymentClusterAutoscalerAnnotations returns a map of annotations with values intended to be used as cluster-autoscaler options for the worker group

func HasContainerdConfiguration

func HasContainerdConfiguration(criConfig *extensionsv1alpha1.CRIConfig) bool

HasContainerdConfiguration returns true if containerd is the configured CRI and has a proper configuration.

func ParseFileCodecID

func ParseFileCodecID(s string) (extensionsv1alpha1.FileCodecID, error)

ParseFileCodecID tries to parse a string into a FileCodecID.

Types

type FileCodec

type FileCodec interface {
	Encode([]byte) ([]byte, error)
	Decode([]byte) ([]byte, error)
}

FileCodec is a codec to en- and decode data in cloud-init scripts with.j

var (
	// PlainFileCodec is a noop FileCodec.
	PlainFileCodec FileCodec = plainFileCodec{}
	// B64FileCodec is the base64 FileCodec.
	B64FileCodec FileCodec = b64FileCodec{}
)

func FileCodecForID

func FileCodecForID(id extensionsv1alpha1.FileCodecID) FileCodec

FileCodecForID retrieves the FileCodec for the given FileCodecID.