mutex

package
v0.8.0 Latest Latest
Warning

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

Go to latest
Published: Jun 23, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Activites added in v0.7.0

type Activites struct {
	Client mutexv1.Client
}

Activities manages shared state for activities

func (*Activites) Mutex added in v0.7.0

func (a *Activites) Mutex(ctx context.Context, req *mutexv1.MutexRequest) error

Mutex locks a shared resource and can be called from a parent workflow

type MutexWorkflow added in v0.7.0

type MutexWorkflow struct {
	*mutexv1.MutexInput
	// contains filtered or unexported fields
}

MutexWorkflow provides a mutex over a shared resource

func (*MutexWorkflow) Execute added in v0.7.0

func (wf *MutexWorkflow) Execute(ctx workflow.Context) error

Execute defines the entrypoint to a MutexWorkflow

type SampleWorkflowWithMutexWorkflow added in v0.7.0

type SampleWorkflowWithMutexWorkflow struct {
	*mutexv1.SampleWorkflowWithMutexInput
	// contains filtered or unexported fields
}

SampleWorkflowWithMutexWorkflow simulates a long running workflow requiring exclusive access to a shared resource

func (*SampleWorkflowWithMutexWorkflow) Execute added in v0.7.0

Execute defines the entrypoint to a TransferWorkflow

type Workflows

type Workflows struct{}

Workflows manages shared state for workflow constructors

func (*Workflows) Mutex added in v0.7.0

LockAccount initializes a new MutexWorkflow value

func (*Workflows) SampleWorkflowWithMutex added in v0.7.0

SampleWorkflowWithMutex initializes a new SampleWorkflowWithMutexWorkflow value

Directories

Path Synopsis
Code generated by protoc-gen-go_temporal.
Code generated by protoc-gen-go_temporal.

Jump to

Keyboard shortcuts

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