Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + const PolicyInMemory + const PolicyPassThrough + const PolicyResourceVersionCache + const PolicyTrackTerminated + var ErrStaleWorkflowError = fmt.Errorf("stale Workflow Found error") + var ErrWorkflowNotFound = fmt.Errorf("workflow not-found error") + var ErrWorkflowTerminated = fmt.Errorf("workflow has already been terminated") + var ErrWorkflowToLarge = fmt.Errorf("workflow too large") + func IsNotFound(err error) bool + func IsWorkflowStale(err error) bool + func IsWorkflowTerminated(err error) bool + func IsWorkflowTooLarge(err error) bool + func SetConfig(cfg *Config) error + type Config struct + Policy Policy + func GetConfig() *Config + func (cfg Config) GetPFlagSet(prefix string) *pflag.FlagSet + type InmemoryWorkflowStore struct + func NewInMemoryWorkflowStore() *InmemoryWorkflowStore + func (i *InmemoryWorkflowStore) Create(ctx context.Context, w *v1alpha1.KozmoWorkflow) error + func (i *InmemoryWorkflowStore) Delete(ctx context.Context, namespace, name string) error + func (i *InmemoryWorkflowStore) Get(ctx context.Context, namespace, name string) (*v1alpha1.KozmoWorkflow, error) + func (i *InmemoryWorkflowStore) Update(ctx context.Context, w *v1alpha1.KozmoWorkflow, priorityClass PriorityClass) (newWF *v1alpha1.KozmoWorkflow, err error) + func (i *InmemoryWorkflowStore) UpdateStatus(ctx context.Context, w *v1alpha1.KozmoWorkflow, priorityClass PriorityClass) (newWF *v1alpha1.KozmoWorkflow, err error) + type KozmoWorkflow interface + Get func(ctx context.Context, namespace, name string) (*v1alpha1.KozmoWorkflow, error) + Update func(ctx context.Context, workflow *v1alpha1.KozmoWorkflow, ...) (newWF *v1alpha1.KozmoWorkflow, err error) + UpdateStatus func(ctx context.Context, workflow *v1alpha1.KozmoWorkflow, ...) (newWF *v1alpha1.KozmoWorkflow, err error) + func NewPassthroughWorkflowStore(_ context.Context, scope promutils.Scope, ...) KozmoWorkflow + func NewResourceVersionCachingStore(_ context.Context, scope promutils.Scope, workflowStore KozmoWorkflow) KozmoWorkflow + func NewTerminatedTrackingStore(_ context.Context, scope promutils.Scope, workflowStore KozmoWorkflow) (KozmoWorkflow, error) + func NewWorkflowStore(ctx context.Context, cfg *Config, lister v1alpha1.KozmoWorkflowLister, ...) (KozmoWorkflow, error) + type Policy = string + type PriorityClass int + const PriorityClassCritical + const PriorityClassRegular
Go to main page