utils

Documentation

Index

• func CheckComplianceStatus(g Gomega, managedPlc *unstructured.Unstructured, expectedCompliance string)
• func DoConfigPolicyMessageTest(clientHubDynamic dynamic.Interface, ...)
• func GetClusterLevelWithTimeout(clientHubDynamic dynamic.Interface, gvr schema.GroupVersionResource, ...) *unstructured.Unstructured
• func GetComplianceState(managedPlc *unstructured.Unstructured) (result interface{})
• func GetFieldFromSecret(secret *unstructured.Unstructured, field string) (result interface{})
• func GetLastEvaluated(configPolicy *unstructured.Unstructured) (string, int64)
• func GetMatchingEvents(client kubernetes.Interface, namespace, objName, reasonRegex, msgRegex string, ...) []corev1.Event
• func GetMetrics(metricPatterns ...string) []string
• func GetServerVersion(clientManaged kubernetes.Interface) string
• func GetStatusMessage(managedPlc *unstructured.Unstructured) (result interface{})
• func GetWithTimeout(clientHubDynamic dynamic.Interface, gvr schema.GroupVersionResource, ...) *unstructured.Unstructured
• func Kubectl(args ...string)
• func KubectlDelete(args ...string)
• func ParseYaml(file string) *unstructured.Unstructured

Functions

func CheckComplianceStatus

func CheckComplianceStatus(g Gomega, managedPlc *unstructured.Unstructured, expectedCompliance string)

func DoConfigPolicyMessageTest

func DoConfigPolicyMessageTest(clientHubDynamic dynamic.Interface,
	gvrConfigPolicy schema.GroupVersionResource, namespace string, policyName string,
	templateIdx int, timeout int, expectedMsg string,
)

func GetClusterLevelWithTimeout

func GetClusterLevelWithTimeout(
	clientHubDynamic dynamic.Interface,
	gvr schema.GroupVersionResource,
	name string,
	wantFound bool,
	timeout int,
) *unstructured.Unstructured

GetClusterLevelWithTimeout keeps polling to get the object for timeout seconds until wantFound is met (true for found, false for not found)

func GetComplianceState

func GetComplianceState(managedPlc *unstructured.Unstructured) (result interface{})

GetComplianceState parses status field of configurationPolicy to get compliance

func GetFieldFromSecret

func GetFieldFromSecret(secret *unstructured.Unstructured, field string) (result interface{})

GetFieldFromSecret parses data field of secrets for the specified field

func GetLastEvaluated

func GetLastEvaluated(configPolicy *unstructured.Unstructured) (string, int64)

GetLastEvaluated parses the configuration policy and returns the status.lastEvaluated and status.lastEvaluatedGeneration fields. If they are not set, then default null values are returned.

func GetMatchingEvents

func GetMatchingEvents(
	client kubernetes.Interface, namespace, objName, reasonRegex, msgRegex string, timeout int,
) []corev1.Event

func GetMetrics

func GetMetrics(metricPatterns ...string) []string

GetMetrics execs into the config-policy-controller pod and curls the metrics endpoint, filters the response with the given patterns, and returns the value(s) for the matching metric(s).

func GetServerVersion

func GetServerVersion(clientManaged kubernetes.Interface) string

func GetStatusMessage

func GetStatusMessage(managedPlc *unstructured.Unstructured) (result interface{})

GetStatusMessage parses status field to get message

func GetWithTimeout

func GetWithTimeout(
	clientHubDynamic dynamic.Interface,
	gvr schema.GroupVersionResource,
	name, namespace string,
	wantFound bool,
	timeout int,
) *unstructured.Unstructured

GetWithTimeout keeps polling to get the object for timeout seconds until wantFound is met (true for found, false for not found)

func Kubectl

func Kubectl(args ...string)

Kubectl executes kubectl commands

func KubectlDelete

func KubectlDelete(args ...string)

KubectlDelete executes a delete command, ignoring not found errors, and skipping the wait if not provided

func ParseYaml

func ParseYaml(file string) *unstructured.Unstructured

ParseYaml read given yaml file and unmarshal it to &unstructured.Unstructured{}