velaql

Documentation

Index

• Constants
• Variables
• func NewViewContext() (wfContext.Context, error)
• func ParseParameter(parameter string) (map[string]interface{}, error)
• type QueryParameterKey
• type QueryView
  • func ParseVelaQL(ql string) (QueryView, error)
• type ViewContext
  • func (c ViewContext) Commit() error
  • func (c ViewContext) DeleteMutableValue(paths ...string)
  • func (c ViewContext) DeleteValueInMemory(paths ...string)
  • func (c ViewContext) GetComponent(name string) (*wfContext.ComponentManifest, error)
  • func (c ViewContext) GetComponents() map[string]*wfContext.ComponentManifest
  • func (c ViewContext) GetMutableValue(paths ...string) string
  • func (c ViewContext) GetStore() *corev1.ConfigMap
  • func (c ViewContext) GetValueInMemory(paths ...string) (interface{}, bool)
  • func (c ViewContext) GetVar(paths ...string) (*value.Value, error)
  • func (c ViewContext) IncreaseCountValueInMemory(paths ...string) int
  • func (c ViewContext) MakeParameter(parameter interface{}) (*value.Value, error)
  • func (c ViewContext) PatchComponent(name string, patchValue *value.Value) error
  • func (c ViewContext) SetMutableValue(data string, paths ...string)
  • func (c ViewContext) SetValueInMemory(data interface{}, paths ...string)
  • func (c ViewContext) SetVar(v *value.Value, paths ...string) error
  • func (c ViewContext) StoreRef() *corev1.ObjectReference
• type ViewHandler
  • func NewViewHandler(cli client.Client, cfg *rest.Config, dm discoverymapper.DiscoveryMapper, ...) *ViewHandler
  • func (handler *ViewHandler) QueryView(ctx context.Context, qv QueryView) (*value.Value, error)

Constants

const (
	// PatternQL is the pattern string of velaQL, velaQL's query syntax is `ViewName{key1=value1 ,key2="value2",}.Export`
	PatternQL = `(?P<view>[a-z0-9](?:[a-z0-9\-]{0,61}[a-z0-9])?)(?P<parameter>{.*?})?\.?(?P<export>[_a-zA-Z][\._a-zA-Z0-9]*)?`
	// PatternKV is the pattern string of parameter
	PatternKV = `(?P<key>[^=]+)=(?P<value>[^=]*?)(?:,|$)`
	// KeyWordView represent view keyword
	KeyWordView = "view"
	// KeyWordParameter represent parameter keyword
	KeyWordParameter = "parameter"
	// KeyWordExport represent export keyword
	KeyWordExport = "export"
	// DefaultExportValue is the default Export value
	DefaultExportValue = "status"
)

const (

	// ViewTaskPhaseSucceeded means view task run succeeded.
	ViewTaskPhaseSucceeded = "succeeded"
)

Variables

var OutputsTemplate = `
{
    "outputs": [
        {
            "valueFrom": "%s",
            "name": "%s"
        }
    ]
}
`

OutputsTemplate output template

Functions

func NewViewContext

func NewViewContext() (wfContext.Context, error)

NewViewContext new view context

func ParseParameter

func ParseParameter(parameter string) (map[string]interface{}, error)

ParseParameter parse parameter to map[string]interface{}

Types

type QueryParameterKey

type QueryParameterKey struct {
	Outputs common.StepOutputs `json:"outputs"`
}

QueryParameterKey query parameter key

type QueryView

type QueryView struct {
	View      string
	Parameter map[string]interface{}
	Export    string
}

QueryView contains query data

func ParseVelaQL

func ParseVelaQL(ql string) (QueryView, error)

ParseVelaQL parse velaQL to QueryView

type ViewContext

type ViewContext struct {
	// contains filtered or unexported fields
}

ViewContext is view context

func (ViewContext) Commit

func (c ViewContext) Commit() error

Commit the workflow context and persist it's content.

func (ViewContext) DeleteMutableValue

func (c ViewContext) DeleteMutableValue(paths ...string)

DeleteMutableValue delete mutable data in workflow context.

func (ViewContext) DeleteValueInMemory

func (c ViewContext) DeleteValueInMemory(paths ...string)

DeleteValueInMemory delete data in workflow context memory store.

func (ViewContext) GetComponent

func (c ViewContext) GetComponent(name string) (*wfContext.ComponentManifest, error)

GetComponent Get ComponentManifest from workflow context.

func (ViewContext) GetComponents

func (c ViewContext) GetComponents() map[string]*wfContext.ComponentManifest

GetComponents Get All ComponentManifest from workflow context.

func (ViewContext) GetMutableValue

func (c ViewContext) GetMutableValue(paths ...string) string

GetMutableValue get mutable data from workflow context.

func (ViewContext) GetStore

func (c ViewContext) GetStore() *corev1.ConfigMap

GetStore get configmap of workflow context.

func (ViewContext) GetValueInMemory

func (c ViewContext) GetValueInMemory(paths ...string) (interface{}, bool)

GetValueInMemory get data in workflow context memory store.

func (ViewContext) GetVar

func (c ViewContext) GetVar(paths ...string) (*value.Value, error)

GetVar get variable from workflow context.

func (ViewContext) IncreaseCountValueInMemory

func (c ViewContext) IncreaseCountValueInMemory(paths ...string) int

IncreaseCountValueInMemory increase count in workflow context memory store.

func (ViewContext) MakeParameter

func (c ViewContext) MakeParameter(parameter interface{}) (*value.Value, error)

MakeParameter make 'value' with interface{}

func (ViewContext) PatchComponent

func (c ViewContext) PatchComponent(name string, patchValue *value.Value) error

PatchComponent patch component with value.

func (ViewContext) SetMutableValue

func (c ViewContext) SetMutableValue(data string, paths ...string)

SetMutableValue set mutable data in workflow context config map.

func (ViewContext) SetValueInMemory

func (c ViewContext) SetValueInMemory(data interface{}, paths ...string)

SetValueInMemory set data in workflow context memory store.

func (ViewContext) SetVar

func (c ViewContext) SetVar(v *value.Value, paths ...string) error

SetVar set variable to workflow context.

func (ViewContext) StoreRef

func (c ViewContext) StoreRef() *corev1.ObjectReference

StoreRef return the store reference of workflow context.

type ViewHandler

type ViewHandler struct {
	// contains filtered or unexported fields
}

ViewHandler view handler

func NewViewHandler

func NewViewHandler(cli client.Client, cfg *rest.Config, dm discoverymapper.DiscoveryMapper, pd *packages.PackageDiscover) *ViewHandler

NewViewHandler new view handler

func (*ViewHandler) QueryView

func (handler *ViewHandler) QueryView(ctx context.Context, qv QueryView) (*value.Value, error)

QueryView generate view step