optionv1xns

package
v1.14.4 Latest Latest
Warning

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

 Go to latest Published: Dec 19, 2024 License: MIT Imports: 18 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-go_temporal. DO NOT EDIT. versions: 

protoc-gen-go_temporal 1.14.4-next (7c69f56bb01f4f341493709180241a5625d7d83b)
go go1.23.3
protoc (unknown)

source: test/option/v1/option.proto

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CancelTestWorkflow 

func CancelTestWorkflow(ctx workflow.Context, workflowID string, runID string) error

CancelTestWorkflow cancels an existing workflow

func CancelTestWorkflowAsync 

func CancelTestWorkflowAsync(ctx workflow.Context, workflowID string, runID string) workflow.Future

CancelTestWorkflowAsync cancels an existing workflow

func RegisterTestActivities 

func RegisterTestActivities(r worker.ActivityRegistry, c v1.TestClient, options ...*TestOptions)

RegisterTestActivities registers test.option.v1.Test cross-namespace activities

func UpdateWithInput 

func UpdateWithInput(ctx workflow.Context, workflowID string, runID string, req *v1.UpdateWithInputRequest, opts ...*UpdateWithInputUpdateOptions) error

UpdateWithInput executes a(n) test.option.v1.Test.UpdateWithInput update and blocks until error or response received

func WorkflowWithInput 

func WorkflowWithInput(ctx workflow.Context, req *v1.WorkflowWithInputRequest, opts ...*WorkflowWithInputWorkflowOptions) error

WorkflowWithInput executes a(n) test.option.v1.Test.WorkflowWithInput workflow and blocks until error or response is received

Types

type TestOptions 

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

TestOptions is used to configure test.option.v1.Test xns activity registration

func NewTestOptions 

func NewTestOptions() *TestOptions

NewTestOptions initializes a new TestOptions value

func (*TestOptions) WithErrorConverter 

func (opts *TestOptions) WithErrorConverter(errorConverter func(error) error) *TestOptions

WithErrorConverter overrides the default error converter applied to xns activity errors

func (*TestOptions) WithFilter 

func (opts *TestOptions) WithFilter(filter func(string) string) *TestOptions

Filter is used to filter registered xns activities or customize their name

type UpdateWithInputHandle 

type UpdateWithInputHandle interface {
	// Cancel cancels the update activity
	Cancel(workflow.Context) error

	// Future returns the inner workflow.Future
	Future() workflow.Future

	// Get blocks on update completion and returns the result
	Get(workflow.Context) error

	// ID returns the update id
	ID() string
}

UpdateWithInputHandle provides a handle to a test.option.v1.Test.UpdateWithInput workflow update

func UpdateWithInputAsync 

func UpdateWithInputAsync(ctx workflow.Context, workflowID string, runID string, req *v1.UpdateWithInputRequest, opts ...*UpdateWithInputUpdateOptions) (UpdateWithInputHandle, error)

UpdateWithInputAsync executes a(n) test.option.v1.Test.UpdateWithInput update and blocks until error or response received

type UpdateWithInputUpdateOptions 

type UpdateWithInputUpdateOptions struct {
	ActivityOptions       *workflow.ActivityOptions
	HeartbeatInterval     time.Duration
	UpdateWorkflowOptions *client.UpdateWorkflowOptions
}

UpdateWithInputUpdateOptions are used to configure a(n) test.option.v1.Test.UpdateWithInput update execution

func NewUpdateWithInputUpdateOptions 

func NewUpdateWithInputUpdateOptions() *UpdateWithInputUpdateOptions

NewUpdateWithInputUpdateOptions initializes a new UpdateWithInputUpdateOptions value

func (*UpdateWithInputUpdateOptions) WithActivityOptions 

func (opts *UpdateWithInputUpdateOptions) WithActivityOptions(ao workflow.ActivityOptions) *UpdateWithInputUpdateOptions

WithActivityOptions can be used to customize the activity options

func (*UpdateWithInputUpdateOptions) WithHeartbeatInterval 

func (opts *UpdateWithInputUpdateOptions) WithHeartbeatInterval(d time.Duration) *UpdateWithInputUpdateOptions

WithHeartbeatInterval can be used to customize the activity heartbeat interval

func (*UpdateWithInputUpdateOptions) WithUpdateWorkflowOptions 

func (opts *UpdateWithInputUpdateOptions) WithUpdateWorkflowOptions(uwo client.UpdateWorkflowOptions) *UpdateWithInputUpdateOptions

WithUpdateWorkflowOptions can be used to customize the update workflow options

type WorkflowWithInputRun 

type WorkflowWithInputRun interface {
	// Cancel cancels the workflow
	Cancel(workflow.Context) error

	// Future returns the inner workflow.Future
	Future() workflow.Future

	// Get returns the inner workflow.Future
	Get(workflow.Context) error

	// ID returns the workflow id
	ID() string

	// UpdateWithInput executes a(n) test.option.v1.Test.UpdateWithInput update and blocks until completion
	UpdateWithInput(workflow.Context, *v1.UpdateWithInputRequest, ...*UpdateWithInputUpdateOptions) error

	// UpdateWithInputAsync executes a(n) test.option.v1.Test.UpdateWithInput update and returns a handle to the underlying activity
	UpdateWithInputAsync(workflow.Context, *v1.UpdateWithInputRequest, ...*UpdateWithInputUpdateOptions) (UpdateWithInputHandle, error)
}

WorkflowWithInputRun provides a handle to a test.option.v1.Test.WorkflowWithInput workflow execution

func WorkflowWithInputAsync 

func WorkflowWithInputAsync(ctx workflow.Context, req *v1.WorkflowWithInputRequest, opts ...*WorkflowWithInputWorkflowOptions) (WorkflowWithInputRun, error)

WorkflowWithInputAsync executes a(n) test.option.v1.Test.WorkflowWithInput workflow and returns a handle to the underlying activity

type WorkflowWithInputWorkflowOptions 

type WorkflowWithInputWorkflowOptions struct {
	ActivityOptions      *workflow.ActivityOptions
	Detached             bool
	HeartbeatInterval    time.Duration
	ParentClosePolicy    enumsv1.ParentClosePolicy
	StartWorkflowOptions *client.StartWorkflowOptions
}

WorkflowWithInputWorkflowOptions are used to configure a(n) test.option.v1.Test.WorkflowWithInput workflow execution

func NewWorkflowWithInputWorkflowOptions 

func NewWorkflowWithInputWorkflowOptions() *WorkflowWithInputWorkflowOptions

NewWorkflowWithInputWorkflowOptions initializes a new WorkflowWithInputWorkflowOptions value

func (*WorkflowWithInputWorkflowOptions) WithActivityOptions 

func (opts *WorkflowWithInputWorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *WorkflowWithInputWorkflowOptions

WithActivityOptions can be used to customize the activity options

func (*WorkflowWithInputWorkflowOptions) WithDetached 

func (opts *WorkflowWithInputWorkflowOptions) WithDetached(d bool) *WorkflowWithInputWorkflowOptions

WithDetached can be used to start a workflow execution and exit immediately

func (*WorkflowWithInputWorkflowOptions) WithHeartbeatInterval 

func (opts *WorkflowWithInputWorkflowOptions) WithHeartbeatInterval(d time.Duration) *WorkflowWithInputWorkflowOptions

WithHeartbeatInterval can be used to customize the activity heartbeat interval

func (*WorkflowWithInputWorkflowOptions) WithParentClosePolicy added in v1.13.1 

func (opts *WorkflowWithInputWorkflowOptions) WithParentClosePolicy(policy enumsv1.ParentClosePolicy) *WorkflowWithInputWorkflowOptions

WithParentClosePolicy can be used to customize the cancellation propagation behavior

func (*WorkflowWithInputWorkflowOptions) WithStartWorkflow 

func (opts *WorkflowWithInputWorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *WorkflowWithInputWorkflowOptions

WithStartWorkflowOptions can be used to customize the start workflow options

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.