etcd

package

v0.6.2 Latest Latest Go to latest Published: Dec 22, 2025 License: PostgreSQL Imports: 23 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 Backend
- func NewBackend(store *Store, options *backend.Options, workerID string) *Backend
type Store
- func NewStore(client *clientv3.Client, root string) *Store
- func (s *Store) Txn(ops ...storage.TxnOperation) storage.Txn

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Backend ¶

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

func NewBackend ¶

func NewBackend(store *Store, options *backend.Options, workerID string) *Backend

func (*Backend) CancelWorkflowInstance ¶

func (b *Backend) CancelWorkflowInstance(ctx context.Context, instance *workflow.Instance, cancelEvent *history.Event) error

func (*Backend) Close ¶

func (b *Backend) Close() error

func (*Backend) CompleteActivityTask ¶

func (b *Backend) CompleteActivityTask(ctx context.Context, task *backend.ActivityTask, result *history.Event) error

func (*Backend) CompleteWorkflowTask ¶

func (b *Backend) CompleteWorkflowTask(
	ctx context.Context,
	task *backend.WorkflowTask,
	state core.WorkflowInstanceState,
	executedEvents, activityEvents, timerEvents []*history.Event,
	workflowEvents []*history.WorkflowEvent,
) error

func (*Backend) CreateWorkflowInstance ¶

func (b *Backend) CreateWorkflowInstance(ctx context.Context, instance *workflow.Instance, event *history.Event) error

func (*Backend) ExtendActivityTask ¶

func (b *Backend) ExtendActivityTask(ctx context.Context, task *backend.ActivityTask) error

func (*Backend) ExtendWorkflowTask ¶

func (b *Backend) ExtendWorkflowTask(ctx context.Context, task *backend.WorkflowTask) error

func (*Backend) FeatureSupported ¶

func (b *Backend) FeatureSupported(feature backend.Feature) bool

func (*Backend) GetActivityTask ¶

func (b *Backend) GetActivityTask(ctx context.Context, queues []workflow.Queue) (*backend.ActivityTask, error)

func (*Backend) GetStats ¶

func (b *Backend) GetStats(ctx context.Context) (*backend.Stats, error)

func (*Backend) GetWorkflowInstance ¶

func (b *Backend) GetWorkflowInstance(ctx context.Context, instance *core.WorkflowInstance) (*diag.WorkflowInstanceRef, error)

func (*Backend) GetWorkflowInstanceHistory ¶

func (b *Backend) GetWorkflowInstanceHistory(ctx context.Context, instance *workflow.Instance, lastSequenceID *int64) ([]*history.Event, error)

func (*Backend) GetWorkflowInstanceState ¶

func (b *Backend) GetWorkflowInstanceState(ctx context.Context, instance *workflow.Instance) (core.WorkflowInstanceState, error)

func (*Backend) GetWorkflowInstances ¶

func (b *Backend) GetWorkflowInstances(ctx context.Context, afterInstanceID, afterExecutionID string, count int) ([]*diag.WorkflowInstanceRef, error)

func (*Backend) GetWorkflowTask ¶

func (b *Backend) GetWorkflowTask(ctx context.Context, queues []workflow.Queue) (*backend.WorkflowTask, error)

func (*Backend) GetWorkflowTree ¶

func (b *Backend) GetWorkflowTree(ctx context.Context, instance *core.WorkflowInstance) (*diag.WorkflowInstanceTree, error)

func (*Backend) Metrics ¶

func (b *Backend) Metrics() metrics.Client

func (*Backend) Options ¶

func (b *Backend) Options() *backend.Options

func (*Backend) PrepareActivityQueues ¶

func (b *Backend) PrepareActivityQueues(ctx context.Context, queues []workflow.Queue) error

func (*Backend) PrepareWorkflowQueues ¶

func (b *Backend) PrepareWorkflowQueues(ctx context.Context, queues []workflow.Queue) error

func (*Backend) RemoveWorkflowInstance ¶

func (b *Backend) RemoveWorkflowInstance(ctx context.Context, instance *workflow.Instance) error

func (*Backend) RemoveWorkflowInstances ¶

func (b *Backend) RemoveWorkflowInstances(ctx context.Context, options ...backend.RemovalOption) error

func (*Backend) SignalWorkflow ¶

func (b *Backend) SignalWorkflow(ctx context.Context, instanceID string, event *history.Event) error

func (*Backend) Tracer ¶

func (b *Backend) Tracer() trace.Tracer

type Store ¶

type Store struct {
	ActivityLock           *activity_lock.Store
	ActivityQueueItem      *activity_queue_item.Store
	HistoryEvent           *history_event.Store
	PendingEvent           *pending_event.Store
	WorkflowInstance       *workflow_instance.Store
	WorkflowInstanceLock   *workflow_instance_lock.Store
	WorkflowInstanceSticky *workflow_instance_sticky.Store
	WorkflowQueueItem      *workflow_queue_item.Store
	// contains filtered or unexported fields
}

func NewStore ¶

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

func (*Store) Txn ¶

func (s *Store) Txn(ops ...storage.TxnOperation) storage.Txn

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
activity_lock
activity_queue_item
history_event
pending_event
workflow_instance
workflow_instance_lock
workflow_instance_sticky
workflow_queue_item

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