Documentation
¶
Index ¶
Constants ¶
View Source
const ( WorkflowType = "rpc-external-storage" State1 = "S1" State2 = "S2" UpdateDataAttributesRPC = "update-data-attributes" SmallDataKey = "small-data" LargeDataKey = "large-data" // Small data stays in Temporal (under threshold) SmallDataContent = "small-data-content" // Initial data for testing InitialSmallDataContent = "initial-small-data" )
Variables ¶
View Source
var ( // Large data goes to external storage (over threshold) - 1KB+ LargeDataContent = "large-data-content-" + strings.Repeat("x", 1000) // Initial large data for testing - 1KB+ InitialLargeDataContent = "initial-large-data-" + strings.Repeat("y", 1000) )
View Source
var ( SmallDataValue = iwfidl.EncodedObject{ Encoding: iwfidl.PtrString("json"), Data: iwfidl.PtrString(SmallDataContent), } LargeDataValue = iwfidl.EncodedObject{ Encoding: iwfidl.PtrString("json"), Data: iwfidl.PtrString(LargeDataContent), } InitialSmallData = iwfidl.EncodedObject{ Encoding: iwfidl.PtrString("json"), Data: iwfidl.PtrString(InitialSmallDataContent), } InitialLargeData = iwfidl.EncodedObject{ Encoding: iwfidl.PtrString("json"), Data: iwfidl.PtrString(InitialLargeDataContent), } TestInput = iwfidl.EncodedObject{ Encoding: iwfidl.PtrString("json"), Data: iwfidl.PtrString("test-input-value"), } TestOutput = iwfidl.EncodedObject{ Encoding: iwfidl.PtrString("json"), Data: iwfidl.PtrString("test-output-value"), } )
Functions ¶
func NewHandler ¶
func NewHandler() common.WorkflowHandlerWithRpc
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.