pending_event

package
v0.6.2 Latest Latest
Warning

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

 Go to latest Published: Dec 22, 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) AllEventsPrefix 

func (s *Store) AllEventsPrefix() string

func (*Store) Create 

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

func (*Store) DeleteByInstanceExecution 

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

func (*Store) DeleteByKey 

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

func (*Store) GetAll 

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

func (*Store) GetByInstanceExecution 

func (s *Store) GetByInstanceExecution(instanceID, executionID string) storage.GetMultipleOp[*Value]

func (*Store) GetByKey 

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

func (*Store) InstanceExecutionPrefix 

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

func (*Store) Key 

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

func (*Store) Put 

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

type Value 

type Value struct {
	storage.StoredValue
	WorkflowInstanceID  string         `json:"workflow_instance_id"`
	WorkflowExecutionID string         `json:"workflow_execution_id"`
	Event               *history.Event `json:"event"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.