context

Documentation

Index

• Constants
• Variables
• func CleanupMemoryStore(name, ns string)
• type Context
  • func LoadContext(cli client.Client, ns, name, ctxName string) (Context, error)
  • func NewContext(ctx context.Context, cli client.Client, ns, name string, ...) (Context, error)
• type WorkflowContext
  • func (wf *WorkflowContext) Commit() error
  • func (wf *WorkflowContext) DeleteMutableValue(paths ...string)
  • func (wf *WorkflowContext) DeleteValueInMemory(paths ...string)
  • func (wf *WorkflowContext) GetMutableValue(paths ...string) string
  • func (wf *WorkflowContext) GetStore() *corev1.ConfigMap
  • func (wf *WorkflowContext) GetValueInMemory(paths ...string) (interface{}, bool)
  • func (wf *WorkflowContext) GetVar(paths ...string) (*value.Value, error)
  • func (wf *WorkflowContext) IncreaseCountValueInMemory(paths ...string) int
  • func (wf *WorkflowContext) LoadFromConfigMap(cm corev1.ConfigMap) error
  • func (wf *WorkflowContext) MakeParameter(parameter string) (*value.Value, error)
  • func (wf *WorkflowContext) SetMutableValue(data string, paths ...string)
  • func (wf *WorkflowContext) SetValueInMemory(data interface{}, paths ...string)
  • func (wf *WorkflowContext) SetVar(v *value.Value, paths ...string) error
  • func (wf *WorkflowContext) StoreRef() *corev1.ObjectReference

Constants

const (
	// ConfigMapKeyVars is the key in ConfigMap Data field for containing data of variable
	ConfigMapKeyVars = "vars"
	// AnnotationStartTimestamp is the annotation key of the workflow start  timestamp
	AnnotationStartTimestamp = "vela.io/startTime"
)

Variables

var (
	// EnableInMemoryContext optimize workflow context storage by storing it in memory instead of etcd
	EnableInMemoryContext = false
)

var MemStore = &inMemoryContextStorage{
	contexts: map[string]*v1.ConfigMap{},
}

MemStore store in-memory context

Functions

func CleanupMemoryStore

func CleanupMemoryStore(name, ns string)

CleanupMemoryStore cleans up memory store.

Types

type Context

type Context interface {
	GetVar(paths ...string) (*value.Value, error)
	SetVar(v *value.Value, paths ...string) error
	GetStore() *corev1.ConfigMap
	GetMutableValue(path ...string) string
	SetMutableValue(data string, path ...string)
	DeleteMutableValue(paths ...string)
	IncreaseCountValueInMemory(paths ...string) int
	SetValueInMemory(data interface{}, paths ...string)
	GetValueInMemory(paths ...string) (interface{}, bool)
	DeleteValueInMemory(paths ...string)
	Commit() error
	MakeParameter(parameter string) (*value.Value, error)
	StoreRef() *corev1.ObjectReference
}

Context is workflow context interface

func LoadContext

func LoadContext(cli client.Client, ns, name, ctxName string) (Context, error)

LoadContext load workflow context from store.

func NewContext

func NewContext(ctx context.Context, cli client.Client, ns, name string, owner []metav1.OwnerReference) (Context, error)

NewContext new workflow context without initialize data.

type WorkflowContext

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

WorkflowContext is workflow context.

func (*WorkflowContext) Commit

func (wf *WorkflowContext) Commit() error

Commit the workflow context and persist it's content.

func (*WorkflowContext) DeleteMutableValue

func (wf *WorkflowContext) DeleteMutableValue(paths ...string)

DeleteMutableValue delete mutable data in workflow context.

func (*WorkflowContext) DeleteValueInMemory

func (wf *WorkflowContext) DeleteValueInMemory(paths ...string)

DeleteValueInMemory delete data in workflow context memory store.

func (*WorkflowContext) GetMutableValue

func (wf *WorkflowContext) GetMutableValue(paths ...string) string

GetMutableValue get mutable data from workflow context.

func (*WorkflowContext) GetStore

func (wf *WorkflowContext) GetStore() *corev1.ConfigMap

GetStore get store of workflow context.

func (*WorkflowContext) GetValueInMemory

func (wf *WorkflowContext) GetValueInMemory(paths ...string) (interface{}, bool)

GetValueInMemory get data in workflow context memory store.

func (*WorkflowContext) GetVar

func (wf *WorkflowContext) GetVar(paths ...string) (*value.Value, error)

GetVar get variable from workflow context.

func (*WorkflowContext) IncreaseCountValueInMemory

func (wf *WorkflowContext) IncreaseCountValueInMemory(paths ...string) int

IncreaseCountValueInMemory increase count in workflow context memory store.

func (*WorkflowContext) LoadFromConfigMap

func (wf *WorkflowContext) LoadFromConfigMap(cm corev1.ConfigMap) error

LoadFromConfigMap recover workflow context from configMap.

func (*WorkflowContext) MakeParameter

func (wf *WorkflowContext) MakeParameter(parameter string) (*value.Value, error)

MakeParameter make 'value' with string

func (*WorkflowContext) SetMutableValue

func (wf *WorkflowContext) SetMutableValue(data string, paths ...string)

SetMutableValue set mutable data in workflow context config map.

func (*WorkflowContext) SetValueInMemory

func (wf *WorkflowContext) SetValueInMemory(data interface{}, paths ...string)

SetValueInMemory set data in workflow context memory store.

func (*WorkflowContext) SetVar

func (wf *WorkflowContext) SetVar(v *value.Value, paths ...string) error

SetVar set variable to workflow context.

func (*WorkflowContext) StoreRef

func (wf *WorkflowContext) StoreRef() *corev1.ObjectReference

StoreRef return the store reference of workflow context.