util

package

v0.3.6 Latest Latest Go to latest Published: Jun 10, 2020 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/flintdev/workflow-engine

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func CheckAllStepStatus(kubeconfig *string, objName string) (string, string, error)
func CheckAllStepStatusByList(kubeconfig *string, objName string, stepsList []string) (string, error)
func CheckIfWorkflowIsTriggered(kubeconfig *string, modelObjName string) (bool, error)
func ConvertJsonStringToMap(s string) (map[string]interface{}, error)
func ConvertJsonStringToStringMap(s string) (map[string]string, error)
func ConvertMapToJsonString(m map[string]string) (string, error)
func CreateEmptyWorkflowObject(kubeconfig *string, wfObjName string, modelObjName string) error
func CreateObject(kubeconfig *string, namespace string, group string, version string, ...) error
func GenerateWorkflowObjName() string
func GetKubeConfig() *string
func GetObj(kubeconfig *string, namespace string, group string, version string, ...) (*unstructured.Unstructured, error)
func GetPendingWorkflowList(kubeconfig *string, modelObjName string, currentStep string) (*unstructured.UnstructuredList, error)
func GetWorkflowObjectFlowDataValue(kubeconfig *string, objName string, path string) (interface{}, error)
func GetWorkflowObjectStatus(kubeconfig *string, objName string) (string, error)
func ListObj(kubeconfig *string, namespace string, group string, version string, ...) (*unstructured.UnstructuredList, error)
func ParseFlowDataKey(path string) string
func RemoveWorkflowObjectPendingStepLabel(kubeconfig *string, objName string, stepName string) error
func SetPendingStepToWorkflowObject(kubeconfig *string, stepName string, objName string) error
func SetStepToWorkflowObject(kubeconfig *string, stepName string, objName string) error
func SetWorkflowObjectCurrentStep(kubeconfig *string, objName string, currentStep string) error
func SetWorkflowObjectCurrentStepLabel(kubeconfig *string, objName string, currentStep string) error
func SetWorkflowObjectFailedStep(kubeconfig *string, objName string, stepName string, stepMessage string) error
func SetWorkflowObjectFlowData(kubeconfig *string, objName string, path string, value string) error
func SetWorkflowObjectMessage(kubeconfig *string, objName string, wfMessage string) error
func SetWorkflowObjectPendingStepLabel(kubeconfig *string, objName string, stepName string) error
func SetWorkflowObjectStatus(kubeconfig *string, objName string, status string) error
func SetWorkflowObjectStep(kubeconfig *string, objName string, stepName string) error
func SetWorkflowObjectStepToComplete(kubeconfig *string, objName string, stepName string, message string) error
func SetWorkflowObjectStepToFailure(kubeconfig *string, objName string, stepName string, message string) error
func SetWorkflowObjectStepToPending(kubeconfig *string, objName string, stepName string, message string) error
func SetWorkflowObjectStepToRunning(kubeconfig *string, objName string, stepName string, message string) error
func SetWorkflowObjectToComplete(kubeconfig *string, objName string) error
func SetWorkflowObjectToFailure(kubeconfig *string, objName string, wfMessage string) error
func SetWorkflowObjectToPending(kubeconfig *string, objName string) error
func SetWorkflowObjectToRunning(kubeconfig *string, objName string) error
func WatchObject(kubeconfig *string, namespace string, group string, version string, ...) <-chan watch.Event
type GVR

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL