pending_event

package

v0.7.0 Latest Latest Go to latest Published: Mar 27, 2026 License: PostgreSQL Imports: 4 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/pgEdge/control-plane

Links

Open Source Insights

Documentation ¶

Index ¶

type Store
- func NewStore(client *clientv3.Client, root string) *Store
type Value
- func NewValue(workflowInstanceID string, workflowExecutionID string, event *history.Event) *Value

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"`
	CreatedAt           int64          `json:"created_at"`
}

func NewValue ¶ added in v0.7.0

func NewValue(
	workflowInstanceID string,
	workflowExecutionID string,
	event *history.Event,
) *Value

Source Files ¶

View all Source files

store.go

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