rpc

package

v1.18.3 Latest Latest Go to latest Published: Jul 30, 2025 License: MIT Imports: 11 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

Open Source Insights

Documentation ¶

Index ¶

Constants ¶

View Source

const (
	WorkflowType              = "rpc"
	State1                    = "S1"
	State2                    = "S2"
	TestInterStateChannelName = "test-TestInterStateChannelName"
	RPCName                   = "test-RPCName"
	RPCNameReadOnly           = "test-RPC-readonly"
	RPCNameError              = "test-RPC-error"

	TestDataAttributeKey = "test-data-attribute"

	TestSearchAttributeKeywordKey    = "CustomKeywordField"
	TestSearchAttributeKeywordValue1 = "keyword-value1"
	TestSearchAttributeKeywordValue2 = "keyword-value2"

	TestSearchAttributeIntKey    = "CustomIntField"
	TestSearchAttributeBoolKey   = "CustomBoolField"
	TestSearchAttributeIntValue1 = 1
	TestSearchAttributeIntValue2 = 2

	WorkerApiErrorDetails = "test-details"
	WorkerApiErrorType    = "test-type"
)

*

This test workflow has two states, using REST controller to implement the workflow directly. *
State1:
- WaitUntil updates attribute data and data objects and then waits until the channel has been published to
- Execute method moves to State2
State2:
- WaitUntil method does nothing
- Execute method will gracefully complete workflow

Variables ¶

View Source

var TestDataAttributeVal1 = iwfidl.EncodedObject{
	Encoding: iwfidl.PtrString("json"),
	Data:     iwfidl.PtrString("test-data-attribute-value1"),
}

View Source

var TestDataAttributeVal2 = iwfidl.EncodedObject{
	Encoding: iwfidl.PtrString("json"),
	Data:     iwfidl.PtrString("test-data-attribute-value2"),
}

View Source

var TestInput = iwfidl.EncodedObject{
	Encoding: iwfidl.PtrString("json"),
	Data:     iwfidl.PtrString("test-input-value"),
}

View Source

var TestInterstateChannelValue = iwfidl.EncodedObject{
	Encoding: iwfidl.PtrString("json"),
	Data:     iwfidl.PtrString("test-interstatechannel-value"),
}

View Source

var TestOutput = iwfidl.EncodedObject{
	Encoding: iwfidl.PtrString("json"),
	Data:     iwfidl.PtrString("test-output-value"),
}

View Source

var TestRecordEvent = iwfidl.EncodedObject{
	Encoding: iwfidl.PtrString("json"),
	Data:     iwfidl.PtrString("test-record-event-value"),
}

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