Documentation
¶
Overview ¶
Code generated by protoc-gen-go_temporal. DO NOT EDIT. versions:
protoc-gen-go_temporal 1.12.1-next (ec80fd34c1a9a69042c74c5d3da0091b91ac2e0c) go go1.22.1 protoc (unknown)
source: test/xnserr/v1/xnserr.proto
Index ¶
- func CallSleep(ctx workflow.Context, req *v1.CallSleepRequest, ...) error
- func CancelClientWorkflow(ctx workflow.Context, workflowID string, runID string) error
- func CancelClientWorkflowAsync(ctx workflow.Context, workflowID string, runID string) workflow.Future
- func CancelServerWorkflow(ctx workflow.Context, workflowID string, runID string) error
- func CancelServerWorkflowAsync(ctx workflow.Context, workflowID string, runID string) workflow.Future
- func RegisterClientActivities(r worker.ActivityRegistry, c v1.ClientClient, options ...*ClientOptions)
- func RegisterServerActivities(r worker.ActivityRegistry, c v1.ServerClient, options ...*ServerOptions)
- func Sleep(ctx workflow.Context, req *v1.SleepRequest, opts ...*SleepWorkflowOptions) error
- type CallSleepRun
- type CallSleepWorkflowOptions
- func (opts *CallSleepWorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *CallSleepWorkflowOptions
- func (opts *CallSleepWorkflowOptions) WithDetached(d bool) *CallSleepWorkflowOptions
- func (opts *CallSleepWorkflowOptions) WithHeartbeatInterval(d time.Duration) *CallSleepWorkflowOptions
- func (opts *CallSleepWorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *CallSleepWorkflowOptions
- type ClientOptions
- type ServerOptions
- type SleepRun
- type SleepWorkflowOptions
- func (opts *SleepWorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *SleepWorkflowOptions
- func (opts *SleepWorkflowOptions) WithDetached(d bool) *SleepWorkflowOptions
- func (opts *SleepWorkflowOptions) WithHeartbeatInterval(d time.Duration) *SleepWorkflowOptions
- func (opts *SleepWorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *SleepWorkflowOptions
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 received
func CancelClientWorkflow ¶
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 ¶
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 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 blocks until error or response received
type CallSleepWorkflowOptions ¶
type CallSleepWorkflowOptions struct {
ActivityOptions *workflow.ActivityOptions
Detached bool
HeartbeatInterval time.Duration
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) 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 blocks until error or response received
type SleepWorkflowOptions ¶
type SleepWorkflowOptions struct {
ActivityOptions *workflow.ActivityOptions
Detached bool
HeartbeatInterval time.Duration
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) WithStartWorkflow ¶
func (opts *SleepWorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *SleepWorkflowOptions
WithStartWorkflowOptions can be used to customize the start workflow options
Source Files