locking

package

v1.19.3 Latest Latest Go to latest Published: Jan 9, 2026 License: MIT Imports: 13 Imported by: 0

Details

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

Repository

github.com/indeedeng/iwf

Links

Documentation ¶

Index ¶

Constants
Variables
func NewHandler() common.WorkflowHandlerWithRpc

Constants ¶

View Source

const (
	WorkflowType                  = "locking"
	State1                        = "S1"
	State2                        = "S2"
	StateWaiting                  = "StateWaiting"
	TestDataAttributeKey1         = "test-data-attribute-1"
	TestDataAttributeKey2         = "test-data-attribute-2"
	RPCName                       = "increase-counter"
	InternalChannelName           = "test-channel"
	TestSearchAttributeKeywordKey = "CustomKeywordField"
	TestSearchAttributeIntKey     = "CustomIntField"

	ShouldUnblockStateWaiting = "shouldUnblockStateWaiting"

	InParallelS2 = 10

	NumUnusedSignals = 4

	UnusedSignalChannelName   = "test-unused-signal-channel"
	UnusedInternalChannelName = "test-unused-internal-channel"
)

*

This test workflow has three states, using REST controller to implement the workflow directly. *
State1:
- WaitUntil method does nothing
- Execute method will move to State Waiting, and 10 instances of State 2
State2:
- WaitUntil update SA
- Execute method will update data attributes and will gracefully complete workflow
StateWaiting:
- WaitUntil will proceed once the internal channel has been published to
- Execute method will gracefully complete workflow

Variables ¶

View Source

var TestValue = &iwfidl.EncodedObject{
	Encoding: iwfidl.PtrString("json"),
	Data:     iwfidl.PtrString("data"),
}

View Source

var UnblockValue = &iwfidl.EncodedObject{
	Encoding: iwfidl.PtrString("json"),
	Data:     iwfidl.PtrString(ShouldUnblockStateWaiting),
}

Functions ¶

func NewHandler ¶

func NewHandler() common.WorkflowHandlerWithRpc

Types ¶

This section is empty.

Source Files ¶

View all Source files

routers.go

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