util

package
v0.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 7, 2020 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const WFGroup = "flint.flint.com"
View Source 
const WFNamespace = "default"
View Source 
const WFResource = "workflows"
View Source 
const WFVersion = "v1"

Variables

This section is empty.

Functions

func CheckAllStepStatus added in v0.2.8 

func CheckAllStepStatus(kubeconfig *string, objName string) (string, string, error)

func CheckAllStepStatusByList added in v0.2.8 

func CheckAllStepStatusByList(kubeconfig *string, objName string, stepsList []string) (string, error)

func CheckIfWorkflowIsTriggered added in v0.2.2 

func CheckIfWorkflowIsTriggered(kubeconfig *string, modelObjName string) (bool, error)

func ConvertJsonStringToMap 

func ConvertJsonStringToMap(s string) (map[string]interface{}, error)

func ConvertJsonStringToStringMap added in v0.2.9 

func ConvertJsonStringToStringMap(s string) (map[string]string, error)

func ConvertMapToJsonString 

func ConvertMapToJsonString(m map[string]string) (string, error)

func CreateEmptyWorkflowObject 

func CreateEmptyWorkflowObject(kubeconfig *string, wfObjName string, modelObjName string) error

func CreateObject 

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

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, error)

func GetPendingWorkflowList added in v0.2.2 

func GetPendingWorkflowList(kubeconfig *string, modelObjName string, currentStep string) (*unstructured.UnstructuredList, error)

func GetWorkflowObjectFlowDataValue 

func GetWorkflowObjectFlowDataValue(kubeconfig *string, objName string, path string) (interface{}, error)

func GetWorkflowObjectStatus added in v0.2.8 

func GetWorkflowObjectStatus(kubeconfig *string, objName string) (string, error)

func ListObj 

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

func ParseFlowDataKey added in v0.1.3 

func ParseFlowDataKey(path string) string

func RemoveWorkflowObjectPendingStepLabel added in v0.2.8 

func RemoveWorkflowObjectPendingStepLabel(kubeconfig *string, objName string, stepName string) error

func SetPendingStepToWorkflowObject added in v0.2.8 

func SetPendingStepToWorkflowObject(kubeconfig *string, stepName string, objName string) error

func SetStepToWorkflowObject added in v0.2.2 

func SetStepToWorkflowObject(kubeconfig *string, stepName string, objName string) error

func SetWorkflowObjectCurrentStep added in v0.2.2 

func SetWorkflowObjectCurrentStep(kubeconfig *string, objName string, currentStep string) error

func SetWorkflowObjectCurrentStepLabel added in v0.2.2 

func SetWorkflowObjectCurrentStepLabel(kubeconfig *string, objName string, currentStep string) error

func SetWorkflowObjectFailedStep added in v0.2.6 

func SetWorkflowObjectFailedStep(kubeconfig *string, objName string, stepName string, stepMessage string) error

func SetWorkflowObjectFlowData 

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

func SetWorkflowObjectMessage added in v0.2.6 

func SetWorkflowObjectMessage(kubeconfig *string, objName string, wfMessage string) error

func SetWorkflowObjectPendingStepLabel added in v0.2.8 

func SetWorkflowObjectPendingStepLabel(kubeconfig *string, objName string, stepName string) error

func SetWorkflowObjectStatus added in v0.2.6 

func SetWorkflowObjectStatus(kubeconfig *string, objName string, status string) error

func SetWorkflowObjectStep added in v0.2.6 

func SetWorkflowObjectStep(kubeconfig *string, objName string, stepName string) error

func SetWorkflowObjectStepToComplete 

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

func SetWorkflowObjectStepToFailure added in v0.2.2 

func SetWorkflowObjectStepToFailure(kubeconfig *string, objName string, stepName string, message string) error

func SetWorkflowObjectStepToPending added in v0.2.2 

func SetWorkflowObjectStepToPending(kubeconfig *string, objName string, stepName string, message string) error

func SetWorkflowObjectStepToRunning added in v0.2.2 

func SetWorkflowObjectStepToRunning(kubeconfig *string, objName string, stepName string, message string) error

func SetWorkflowObjectToComplete added in v0.2.6 

func SetWorkflowObjectToComplete(kubeconfig *string, objName string) error

func SetWorkflowObjectToFailure added in v0.2.6 

func SetWorkflowObjectToFailure(kubeconfig *string, objName string, wfMessage string) error

func SetWorkflowObjectToPending added in v0.2.6 

func SetWorkflowObjectToPending(kubeconfig *string, objName string) error

func SetWorkflowObjectToRunning added in v0.2.6 

func SetWorkflowObjectToRunning(kubeconfig *string, objName string) error

func WatchObject 

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

Types

type GVR added in v0.1.6 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.