workflow_instance_lock

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: 3 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) GetByKey

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

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
	WorkflowInstanceID  string    `json:"workflow_instance_id"`
	WorkflowExecutionID string    `json:"workflow_execution_id"`
	CreatedAt           time.Time `json:"created_at"`
	WorkerID            string    `json:"worker_id"`
	WorkerInstanceID    string    `json:"worker_instance_id"`
}

func (*Value) CanBeReassignedTo

func (v *Value) CanBeReassignedTo(workerID, workerInstanceID string) bool

Jump to

Keyboard shortcuts

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