rpcStorage

package
v1.19.0 Latest Latest
Warning

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

Go to latest
Published: Aug 29, 2025 License: MIT Imports: 11 Imported by: 0

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.

Jump to

Keyboard shortcuts

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