util

Documentation

Index

• func AddStepToWorkflowObject(kubeconfig *string, stepName string, objName string)
• func ConvertJsonStringToMap(s string) map[string]string
• func ConvertMapToJsonString(m map[string]string) string
• func CreateEmptyWorkflowObject(kubeconfig *string, objName string)
• func CreateObject(kubeconfig *string, namespace string, group string, version string, ...)
• func GenerateWorkflowObjName() string
• func GetKubeConfig() *string
• func GetObj(kubeconfig *string, namespace string, group string, version string, ...) *unstructured.Unstructured
• func GetWorkflowObjectFlowDataValue(kubeconfig *string, objName string, path string) string
• func ListObj(kubeconfig *string, namespace string, group string, version string, ...) *unstructured.UnstructuredList
• func ParseFlowDataKey(path string) string
• func SetWorkflowObjectFlowData(kubeconfig *string, objName string, path string, value string)
• func SetWorkflowObjectStepToComplete(kubeconfig *string, objName string, stepName string)
• func WatchObject(kubeconfig *string, namespace string, group string, version string, ...) <-chan watch.Event
• type GVR

Functions

func AddStepToWorkflowObject

func AddStepToWorkflowObject(kubeconfig *string, stepName string, objName string)

func ConvertJsonStringToMap

func ConvertJsonStringToMap(s string) map[string]string

func ConvertMapToJsonString

func ConvertMapToJsonString(m map[string]string) string

func CreateEmptyWorkflowObject

func CreateEmptyWorkflowObject(kubeconfig *string, objName string)

func CreateObject

func CreateObject(kubeconfig *string, namespace string, group string, version string, resource string, obj *unstructured.Unstructured)

func GenerateWorkflowObjName

func GenerateWorkflowObjName() string

func GetKubeConfig

func GetKubeConfig() *string

func GetObj

func GetObj(kubeconfig *string, namespace string, group string, version string, resource string, objName string) *unstructured.Unstructured

func GetWorkflowObjectFlowDataValue

func GetWorkflowObjectFlowDataValue(kubeconfig *string, objName string, path string) string

func ListObj

func ListObj(kubeconfig *string, namespace string, group string, version string, resource string) *unstructured.UnstructuredList

func ParseFlowDataKey

func ParseFlowDataKey(path string) string

func SetWorkflowObjectFlowData

func SetWorkflowObjectFlowData(kubeconfig *string, objName string, path string, value string)

func SetWorkflowObjectStepToComplete

func SetWorkflowObjectStepToComplete(kubeconfig *string, objName string, stepName string)

func WatchObject

func WatchObject(kubeconfig *string, namespace string, group string, version string, resource string) <-chan watch.Event

Types

type GVR

type GVR struct {
	Group    string `json:"group"`
	Version  string `json:"version"`
	Resource string `json:"resource"`
}