xnserrv1xns

package
v1.13.1 Latest Latest
Warning

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

 Go to latest Published: May 14, 2024 License: MIT Imports: 17 Imported by: 0

Documentation

Overview

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

protoc-gen-go_temporal 1.13.1-next (b7a15c407f9a9490670a48b7f288c936cdd1bc48)
go go1.22.3
protoc (unknown)

source: test/xnserr/v1/xnserr.proto

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CallSleep 

func CallSleep(ctx workflow.Context, req *v1.CallSleepRequest, opts ...*CallSleepWorkflowOptions) error

CallSleep executes a(n) test.xnserr.v1.Client.CallSleep workflow and blocks until error or response is received

func CancelClientWorkflow 

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

CancelClientWorkflow cancels an existing workflow

func CancelClientWorkflowAsync 

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

CancelClientWorkflowAsync cancels an existing workflow

func CancelServerWorkflow 

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

CancelServerWorkflow cancels an existing workflow

func CancelServerWorkflowAsync 

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

CancelServerWorkflowAsync cancels an existing workflow

func RegisterClientActivities 

func RegisterClientActivities(r worker.ActivityRegistry, c v1.ClientClient, options ...*ClientOptions)

RegisterClientActivities registers test.xnserr.v1.Client cross-namespace activities

func RegisterServerActivities 

func RegisterServerActivities(r worker.ActivityRegistry, c v1.ServerClient, options ...*ServerOptions)

RegisterServerActivities registers test.xnserr.v1.Server cross-namespace activities

func Sleep 

func Sleep(ctx workflow.Context, req *v1.SleepRequest, opts ...*SleepWorkflowOptions) error

Sleep executes a(n) test.xnserr.v1.Server.Sleep workflow and blocks until error or response is received

Types

type CallSleepRun 

type CallSleepRun 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
}

CallSleepRun provides a handle to a test.xnserr.v1.Client.CallSleep workflow execution

func CallSleepAsync 

func CallSleepAsync(ctx workflow.Context, req *v1.CallSleepRequest, opts ...*CallSleepWorkflowOptions) (CallSleepRun, error)

CallSleepAsync executes a(n) test.xnserr.v1.Client.CallSleep workflow and returns a handle to the underlying activity

type CallSleepWorkflowOptions 

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

CallSleepWorkflowOptions are used to configure a(n) test.xnserr.v1.Client.CallSleep workflow execution

func NewCallSleepWorkflowOptions 

func NewCallSleepWorkflowOptions() *CallSleepWorkflowOptions

NewCallSleepWorkflowOptions initializes a new CallSleepWorkflowOptions value

func (*CallSleepWorkflowOptions) WithActivityOptions 

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

WithActivityOptions can be used to customize the activity options

func (*CallSleepWorkflowOptions) WithDetached 

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

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

func (*CallSleepWorkflowOptions) WithHeartbeatInterval 

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

WithHeartbeatInterval can be used to customize the activity heartbeat interval

func (*CallSleepWorkflowOptions) WithParentClosePolicy added in v1.13.1 

func (opts *CallSleepWorkflowOptions) WithParentClosePolicy(policy v11.ParentClosePolicy) *CallSleepWorkflowOptions

WithParentClosePolicy can be used to customize the cancellation propagation behavior

func (*CallSleepWorkflowOptions) WithStartWorkflow 

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

WithStartWorkflowOptions can be used to customize the start workflow options

type ClientOptions 

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

ClientOptions is used to configure test.xnserr.v1.Client xns activity registration

func NewClientOptions 

func NewClientOptions() *ClientOptions

NewClientOptions initializes a new ClientOptions value

func (*ClientOptions) WithErrorConverter 

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

WithErrorConverter overrides the default error converter applied to xns activity errors

func (*ClientOptions) WithFilter 

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

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

type ServerOptions 

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

ServerOptions is used to configure test.xnserr.v1.Server xns activity registration

func NewServerOptions 

func NewServerOptions() *ServerOptions

NewServerOptions initializes a new ServerOptions value

func (*ServerOptions) WithErrorConverter 

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

WithErrorConverter overrides the default error converter applied to xns activity errors

func (*ServerOptions) WithFilter 

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

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

type SleepRun 

type SleepRun 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
}

SleepRun provides a handle to a test.xnserr.v1.Server.Sleep workflow execution

func SleepAsync 

func SleepAsync(ctx workflow.Context, req *v1.SleepRequest, opts ...*SleepWorkflowOptions) (SleepRun, error)

SleepAsync executes a(n) test.xnserr.v1.Server.Sleep workflow and returns a handle to the underlying activity

type SleepWorkflowOptions 

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

SleepWorkflowOptions are used to configure a(n) test.xnserr.v1.Server.Sleep workflow execution

func NewSleepWorkflowOptions 

func NewSleepWorkflowOptions() *SleepWorkflowOptions

NewSleepWorkflowOptions initializes a new SleepWorkflowOptions value

func (*SleepWorkflowOptions) WithActivityOptions 

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

WithActivityOptions can be used to customize the activity options

func (*SleepWorkflowOptions) WithDetached 

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

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

func (*SleepWorkflowOptions) WithHeartbeatInterval 

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

WithHeartbeatInterval can be used to customize the activity heartbeat interval

func (*SleepWorkflowOptions) WithParentClosePolicy added in v1.13.1 

func (opts *SleepWorkflowOptions) WithParentClosePolicy(policy v11.ParentClosePolicy) *SleepWorkflowOptions

WithParentClosePolicy can be used to customize the cancellation propagation behavior

func (*SleepWorkflowOptions) WithStartWorkflow 

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

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.