temporal

package

v1.19.3 Latest Latest Go to latest Published: Jan 9, 2026 License: MIT Imports: 22 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 ¶

func BlobStoreCleanup(ctx workflow.Context, storeId string) (int, error)
func Interpreter(ctx workflow.Context, input service.InterpreterWorkflowInput) (*service.InterpreterWorkflowOutput, error)
func WaitforStateCompletionWorkflow(ctx workflow.Context) (*service.WaitForStateCompletionWorkflowOutput, error)
type InterpreterWorker
- func NewInterpreterWorker(config config.Config, temporalClient client.Client, taskQueue string, ...) *InterpreterWorker

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func BlobStoreCleanup ¶ added in v1.18.4

func BlobStoreCleanup(ctx workflow.Context, storeId string) (int, error)

func Interpreter ¶

func Interpreter(ctx workflow.Context, input service.InterpreterWorkflowInput) (*service.InterpreterWorkflowOutput, error)

func WaitforStateCompletionWorkflow ¶ added in v1.8.0

func WaitforStateCompletionWorkflow(ctx workflow.Context) (*service.WaitForStateCompletionWorkflowOutput, error)

Types ¶

type InterpreterWorker ¶

type InterpreterWorker struct {
	// contains filtered or unexported fields
}

func NewInterpreterWorker ¶

func NewInterpreterWorker(
	config config.Config, temporalClient client.Client, taskQueue string, memoEncryption bool,
	memoEncryptionConverter converter.DataConverter, unifiedClient uclient.UnifiedClient,
	store blobstore.BlobStore,
) *InterpreterWorker

func (*InterpreterWorker) Close ¶

func (iw *InterpreterWorker) Close()

func (*InterpreterWorker) Start ¶

func (iw *InterpreterWorker) Start()

func (*InterpreterWorker) StartWithStickyCacheDisabledForTest ¶ added in v1.12.0

func (iw *InterpreterWorker) StartWithStickyCacheDisabledForTest()

Source Files ¶

View all Source files

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