velaql

Documentation

Index

• Constants
• Variables
• func NewViewContext() (wfContext.Context, error)
• func ParseParameter(parameter string) (map[string]interface{}, error)
• func ParseViewIntoConfigMap(viewStr, name string) (*v1.ConfigMap, error)
• func StoreViewFromFile(ctx context.Context, c client.Client, path, viewName string) error
• func ValidateView(viewStr string) error
• type QueryParameterKey
• type QueryView
  • func ParseVelaQL(ql string) (QueryView, error)
  • func ParseVelaQLFromPath(velaQLViewPath string) (*QueryView, error)
• type ViewContext
  • func (c ViewContext) Commit() error
  • func (c ViewContext) DeleteMutableValue(_ ...string)
  • func (c ViewContext) DeleteValueInMemory(_ ...string)
  • func (c ViewContext) GetMutableValue(_ ...string) string
  • func (c ViewContext) GetStore() *corev1.ConfigMap
  • func (c ViewContext) GetValueInMemory(_ ...string) (interface{}, bool)
  • func (c ViewContext) GetVar(paths ...string) (*value.Value, error)
  • func (c ViewContext) IncreaseCountValueInMemory(_ ...string) int
  • func (c ViewContext) MakeParameter(parameter string) (*value.Value, error)
  • func (c ViewContext) SetMutableValue(_ string, _ ...string)
  • func (c ViewContext) SetValueInMemory(_ interface{}, _ ...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, pd *packages.PackageDiscover) *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"
	// KeyWordTemplate represents template keyword
	KeyWordTemplate = "template"
	// 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{}

func ParseViewIntoConfigMap

func ParseViewIntoConfigMap(viewStr, name string) (*v1.ConfigMap, error)

ParseViewIntoConfigMap parses a CUE string (representing a view) into a ConfigMap ready to be stored into etcd.

func StoreViewFromFile

func StoreViewFromFile(ctx context.Context, c client.Client, path, viewName string) error

StoreViewFromFile reads a view from the specified CUE file, and stores into a ConfigMap in vela-system namespace. So the user can use the view in VelaQL later.

By saying file, it can actually be a file, URL, or stdin (-).

func ValidateView

func ValidateView(viewStr string) error

ValidateView makes sure the cue provided can use as view.

For now, we only check 1. cue is valid 2. `status` or `view` field exists

Types

type QueryParameterKey

type QueryParameterKey struct {
	Outputs workflowv1alpha1.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

func ParseVelaQLFromPath

func ParseVelaQLFromPath(velaQLViewPath string) (*QueryView, error)

ParseVelaQLFromPath will parse a velaQL file path 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(_ ...string)

DeleteMutableValue delete mutable data in workflow context.

func (ViewContext) DeleteValueInMemory

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

DeleteValueInMemory delete data in workflow context memory store.

func (ViewContext) GetMutableValue

func (c ViewContext) GetMutableValue(_ ...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(_ ...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(_ ...string) int

IncreaseCountValueInMemory increase count in workflow context memory store.

func (ViewContext) MakeParameter

func (c ViewContext) MakeParameter(parameter string) (*value.Value, error)

MakeParameter make 'value' with string

func (ViewContext) SetMutableValue

func (c ViewContext) SetMutableValue(_ string, _ ...string)

SetMutableValue set mutable data in workflow context config map.

func (ViewContext) SetValueInMemory

func (c ViewContext) SetValueInMemory(_ interface{}, _ ...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, 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