util

Documentation

Index

• Constants
• func CleanupNamespaces(ctx context.Context, clientSet kubernetes.Interface, labelSelector string)
• func CleanupNonNamespacedResources(ctx context.Context, clientSet kubernetes.Interface, ...)
• func ClusterHealthCheck(clientSet kubernetes.Interface)
• func ClusterHealthyVanillaK8s(clientset kubernetes.Interface) bool
• func ConfigureLogging(cmd *cobra.Command)
• func CreateFile(fileName string, fileContent []byte) error
• func CreateNamespace(clientSet kubernetes.Interface, name string, nsLabels map[string]string, ...) error
• func DeleteNonNamespacedResources(ctx context.Context, resources *unstructured.UnstructuredList, ...)
• func EnvToMap() map[string]interface{}
• func ReadConfig(configFile string) (io.Reader, error)
• func ReadEmbedConfig(embedFs embed.FS, configFile string) (io.Reader, error)
• func ReadUserMetadata(inputFile string) (map[string]interface{}, error)
• func RenderTemplate(original []byte, inputData interface{}, options templateOption) ([]byte, error)
• func RetryWithExponentialBackOff(fn wait.ConditionFunc, duration time.Duration, factor, jitter float64, ...) error
• func SetupCmd(cmd *cobra.Command)

Constants

const (
	MissingKeyError templateOption = "missingkey=error"
	MissingKeyZero  templateOption = "missingkey=zero"
)

Functions

func CleanupNamespaces

func CleanupNamespaces(ctx context.Context, clientSet kubernetes.Interface, labelSelector string)

CleanupNamespaces deletes namespaces with the given selector

func CleanupNonNamespacedResources

func CleanupNonNamespacedResources(ctx context.Context, clientSet kubernetes.Interface, dynamicClient dynamic.Interface, labelSelector string)

Cleanup non-namespaced resources with the given selector

func ClusterHealthCheck

func ClusterHealthCheck(clientSet kubernetes.Interface)

func ClusterHealthyVanillaK8s

func ClusterHealthyVanillaK8s(clientset kubernetes.Interface) bool

func ConfigureLogging

func ConfigureLogging(cmd *cobra.Command)

Configures kube-burner's logging level

func CreateFile

func CreateFile(fileName string, fileContent []byte) error

CreateFile creates a new file and writes content into it

func CreateNamespace

func CreateNamespace(clientSet kubernetes.Interface, name string, nsLabels map[string]string, nsAnnotations map[string]string) error

func DeleteNonNamespacedResources

func DeleteNonNamespacedResources(ctx context.Context, resources *unstructured.UnstructuredList, resourceInterface dynamic.NamespaceableResourceInterface)

func EnvToMap

func EnvToMap() map[string]interface{}

EnvToMap returns the host environment variables as a map

func ReadConfig

func ReadConfig(configFile string) (io.Reader, error)

ReadConfig reads configuration from the given path or URL

func ReadEmbedConfig

func ReadEmbedConfig(embedFs embed.FS, configFile string) (io.Reader, error)

ReadEmbedConfig reads configuration files from the given embed filesystem

func ReadUserMetadata

func ReadUserMetadata(inputFile string) (map[string]interface{}, error)

func RenderTemplate

func RenderTemplate(original []byte, inputData interface{}, options templateOption) ([]byte, error)

RenderTemplate renders a go-template

func RetryWithExponentialBackOff

func RetryWithExponentialBackOff(fn wait.ConditionFunc, duration time.Duration, factor, jitter float64, timeout time.Duration) error

RetryWithExponentialBackOff a utility for retrying the given function with exponential backoff.

func SetupCmd

func SetupCmd(cmd *cobra.Command)

Bootstraps kube-burner cmd with some common flags