kube

func EvaluateWait ¶

func EvaluateWait(waitPayload types.Wait) error

This is specific to Lula - Check if we need to execute any wait operations.

func GetResourcesDynamically ¶

func GetResourcesDynamically(ctx context.Context,
	resource types.ResourceRule) (
	[]map[string]interface{}, error)

GetResourcesDynamically() requires a dynamic interface and processes GVR to return []map[string]interface{} This function is used to query the cluster for specific subset of resources required for processing

func QueryCluster ¶

func QueryCluster(ctx context.Context, resources []types.Resource) (map[string]interface{}, error)

QueryCluster() requires context and a Payload as input and returns []unstructured.Unstructured This function is used to query the cluster for all resources required for processing

func WaitForCondition ¶

func WaitForCondition(condition string, namespace string, timeout string, args ...string) (err error)

This is required bootstrapping for use of RunWait()

func WaitForExistence ¶

func WaitForExistence(kind string, namespace string, timeout time.Duration) (err error)