workflow_instance_sticky

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) Create 

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

func (*Store) DeleteByKey 

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

func (*Store) GetByKey 

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

func (*Store) Key 

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

func (*Store) Put 

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

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"`
	CreatedAt          time.Time `json:"created_at"`
	WorkerID           string    `json:"worker_id"`
}

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.