common

Documentation

Index

• func AddonGVR() schema.GroupVersionResource
• func CRDGVR() schema.GroupVersionResource
• func ContainsString(slice []string, s string) bool
• func ConvertWorkflowPhaseToAddonPhase(lifecycle addonv1.LifecycleStep, phase wfv1.WorkflowPhase) addonv1.ApplicationAssemblyPhase
• func ExtractChecksumAndLifecycleStep(addonWorkflowName string) (string, addonv1.LifecycleStep, error)
• func FromUnstructured(un *unstructured.Unstructured) (*addonv1.Addon, error)
• func FromUnstructuredObj(un *unstructured.Unstructured, v interface{}) error
• func GetAddonMgrScheme() *runtime.Scheme
• func GetCurrentTimestamp() int64
• func IsExpired(startTime int64, ttlTime int64) bool
• func NewAddonClient(cfg *rest.Config) addonv1versioned.Interface
• func NewWFClient(cfg *rest.Config) wfv1versioned.Interface
• func NewWorkflowInformer(dclient dynamic.Interface, ns string, resyncPeriod time.Duration) cache.SharedIndexInformer
• func RemoveString(slice []string, s string) (result []string)
• func SecretGVR() schema.GroupVersionResource
• func ToUnstructured(wf *wfv1.Workflow) (*unstructured.Unstructured, error)
• func WorkFlowFromUnstructured(un *unstructured.Unstructured) (*wfv1.Workflow, error)
• func WorkflowGVR() schema.GroupVersionResource
• func WorkflowType() *unstructured.Unstructured
• type Validator

Functions

func AddonGVR

func AddonGVR() schema.GroupVersionResource

AddonGVR returns the schema representation of the addon resource

func CRDGVR

func CRDGVR() schema.GroupVersionResource

CRDGVR returns the schema representation for customresourcedefinitions

func ContainsString

func ContainsString(slice []string, s string) bool

ContainsString helper function to check string in a slice of strings.

func ConvertWorkflowPhaseToAddonPhase

func ConvertWorkflowPhaseToAddonPhase(lifecycle addonv1.LifecycleStep, phase wfv1.WorkflowPhase) addonv1.ApplicationAssemblyPhase

func ExtractChecksumAndLifecycleStep

func ExtractChecksumAndLifecycleStep(addonWorkflowName string) (string, addonv1.LifecycleStep, error)

ExtractChecksumAndLifecycleStep extracts the checksum and lifecycle step from the workflow name

func FromUnstructured

func FromUnstructured(un *unstructured.Unstructured) (*addonv1.Addon, error)

func FromUnstructuredObj

func FromUnstructuredObj(un *unstructured.Unstructured, v interface{}) error

FromUnstructuredObj convert unstructured to objects

func GetAddonMgrScheme

func GetAddonMgrScheme() *runtime.Scheme

func GetCurrentTimestamp

func GetCurrentTimestamp() int64

GetCurrentTimestamp -- get current timestamp in millisecond

func IsExpired

func IsExpired(startTime int64, ttlTime int64) bool

IsExpired --- check if reached ttl time

func NewAddonClient

func NewAddonClient(cfg *rest.Config) addonv1versioned.Interface

NewAddonClient - declare new addon client

func NewWFClient

func NewWFClient(cfg *rest.Config) wfv1versioned.Interface

NewWFClient -- declare new workflow client

func NewWorkflowInformer

func NewWorkflowInformer(dclient dynamic.Interface, ns string, resyncPeriod time.Duration) cache.SharedIndexInformer

func RemoveString

func RemoveString(slice []string, s string) (result []string)

RemoveString helper function to remove a string in a slice of strings.

func SecretGVR

func SecretGVR() schema.GroupVersionResource

SecretGVR returns the schema representation of the secret resource

func ToUnstructured

func ToUnstructured(wf *wfv1.Workflow) (*unstructured.Unstructured, error)

ToUnstructured converts an workflow to an Unstructured object

func WorkFlowFromUnstructured

func WorkFlowFromUnstructured(un *unstructured.Unstructured) (*wfv1.Workflow, error)

func WorkflowGVR

func WorkflowGVR() schema.GroupVersionResource

WorkflowGVR returns the schema representation of the workflow resource

func WorkflowType

func WorkflowType() *unstructured.Unstructured

WorkflowType return an unstructured workflow type object

Types

type Validator

type Validator interface {
	Validate() (bool, error)
	ValidateDependencies() error
}

Validator is a common interface for validators