temporal

Documentation

Index

• 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
  • func (iw *InterpreterWorker) Close()
  • func (iw *InterpreterWorker) Start()
  • func (iw *InterpreterWorker) StartWithStickyCacheDisabledForTest()

Functions

func Interpreter

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

func WaitforStateCompletionWorkflow

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,
) *InterpreterWorker

func (*InterpreterWorker) Close

func (iw *InterpreterWorker) Close()

func (*InterpreterWorker) Start

func (iw *InterpreterWorker) Start()

func (*InterpreterWorker) StartWithStickyCacheDisabledForTest

func (iw *InterpreterWorker) StartWithStickyCacheDisabledForTest()