workflow_instance

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 6, 2025 License: PostgreSQL Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Store

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

func NewStore

func NewStore(client *clientv3.Client, root string) *Store

func (*Store) Create

func (s *Store) Create(item *Value) storage.PutOp[*Value]

func (*Store) DeleteByKey

func (s *Store) DeleteByKey(instanceID, executionID string) storage.DeleteOp

func (*Store) ExistsByKey

func (s *Store) ExistsByKey(instanceID, executionID string) storage.ExistsOp

func (*Store) GetAll

func (s *Store) GetAll() storage.GetMultipleOp[*Value]

func (*Store) GetByInstanceID

func (s *Store) GetByInstanceID(instanceID string) storage.GetMultipleOp[*Value]

func (*Store) GetByKey

func (s *Store) GetByKey(instanceID, executionID string) storage.GetOp[*Value]

func (*Store) InstanceIDPrefix

func (s *Store) InstanceIDPrefix(instanceID string) string

func (*Store) InstancesPrefix

func (s *Store) InstancesPrefix() string

func (*Store) Key

func (s *Store) Key(instanceID, executionID string) string

func (*Store) Update

func (s *Store) Update(item *Value) storage.PutOp[*Value]

type Value

type Value struct {
	storage.StoredValue
	WorkflowInstance *workflow.Instance         `json:"workflow_instance"`
	CreatedAt        time.Time                  `json:"created_at"`
	FinishedAt       *time.Time                 `json:"finished_at,omitempty"`
	Queue            core.Queue                 `json:"queue"`
	Metadata         *metadata.WorkflowMetadata `json:"metadata"`
	State            core.WorkflowInstanceState `json:"state"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL