Documentation
¶
Overview ¶
Code generated by protoc-gen-go_temporal. DO NOT EDIT. versions:
protoc-gen-go_temporal 1.6.1-next (d4aa571c65defba7c1853c6d86735fadf40a4cf8) go go1.21.5 protoc (unknown)
source: simple/simple.proto
Index ¶
- func CancelIgnoredWorkflow(ctx workflow.Context, workflowID string, runID string) error
- func CancelIgnoredWorkflowAsync(ctx workflow.Context, workflowID string, runID string) workflow.Future
- func CancelOtherWorkflow(ctx workflow.Context, workflowID string, runID string) error
- func CancelOtherWorkflowAsync(ctx workflow.Context, workflowID string, runID string) workflow.Future
- func CancelSimpleWorkflow(ctx workflow.Context, workflowID string, runID string) error
- func CancelSimpleWorkflowAsync(ctx workflow.Context, workflowID string, runID string) workflow.Future
- func OtherQuery(ctx workflow.Context, workflowID string, runID string, ...) (*simple.OtherQueryResponse, error)
- func OtherSignal(ctx workflow.Context, workflowID string, runID string, ...) error
- func OtherUpdate(ctx workflow.Context, workflowID string, runID string, ...) (*simple.OtherUpdateResponse, error)
- func OtherWorkflow(ctx workflow.Context, req *simple.OtherWorkflowRequest, ...) (*simple.OtherWorkflowResponse, error)
- func RegisterIgnoredActivities(r worker.ActivityRegistry, c simple.IgnoredClient, opts ...IgnoredOptions)
- func RegisterOtherActivities(r worker.ActivityRegistry, c simple.OtherClient, opts ...OtherOptions)
- func RegisterSimpleActivities(r worker.ActivityRegistry, c simple.SimpleClient, opts ...SimpleOptions)
- func SomeQuery1(ctx workflow.Context, workflowID string, runID string, ...) (*simple.SomeQuery1Response, error)
- func SomeQuery2(ctx workflow.Context, workflowID string, runID string, ...) (*simple.SomeQuery2Response, error)
- func SomeSignal1(ctx workflow.Context, workflowID string, runID string, ...) error
- func SomeSignal2(ctx workflow.Context, workflowID string, runID string, ...) error
- func SomeSignal3(ctx workflow.Context, workflowID string, runID string, ...) error
- func SomeUpdate1(ctx workflow.Context, workflowID string, runID string, ...) (*simple.SomeUpdate1Response, error)
- func SomeWorkflow1(ctx workflow.Context, req *simple.SomeWorkflow1Request, ...) (*simple.SomeWorkflow1Response, error)
- func SomeWorkflow2(ctx workflow.Context, opts ...*SomeWorkflow2WorkflowOptions) error
- func SomeWorkflow2WithSomeSignal1(ctx workflow.Context, opts ...*SomeWorkflow2WorkflowOptions) error
- func SomeWorkflow3(ctx workflow.Context, req *simple.SomeWorkflow3Request, ...) error
- func SomeWorkflow3WithSomeSignal2(ctx workflow.Context, req *simple.SomeWorkflow3Request, ...) error
- func What(ctx workflow.Context, req *simple.WhatRequest, opts ...*WhatWorkflowOptions) error
- type IgnoredOptions
- type OtherOptions
- type OtherQueryQueryHandle
- type OtherQueryQueryOptions
- type OtherSignalSignalHandle
- type OtherSignalSignalOptions
- type OtherUpdateHandle
- type OtherUpdateUpdateOptions
- func (opts *OtherUpdateUpdateOptions) WithActivityOptions(ao workflow.ActivityOptions) *OtherUpdateUpdateOptions
- func (opts *OtherUpdateUpdateOptions) WithHeartbeatInterval(d time.Duration) *OtherUpdateUpdateOptions
- func (opts *OtherUpdateUpdateOptions) WithUpdateWorkflowOptions(uwo client.UpdateWorkflowWithOptionsRequest) *OtherUpdateUpdateOptions
- type OtherWorkflowRun
- type OtherWorkflowWorkflowOptions
- func (opts *OtherWorkflowWorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *OtherWorkflowWorkflowOptions
- func (opts *OtherWorkflowWorkflowOptions) WithDetached(d bool) *OtherWorkflowWorkflowOptions
- func (opts *OtherWorkflowWorkflowOptions) WithHeartbeatInterval(d time.Duration) *OtherWorkflowWorkflowOptions
- func (opts *OtherWorkflowWorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *OtherWorkflowWorkflowOptions
- type SimpleOptions
- type SomeQuery1QueryHandle
- type SomeQuery1QueryOptions
- type SomeQuery2QueryHandle
- type SomeQuery2QueryOptions
- type SomeSignal1SignalHandle
- type SomeSignal1SignalOptions
- type SomeSignal2SignalHandle
- type SomeSignal2SignalOptions
- type SomeSignal3SignalHandle
- type SomeSignal3SignalOptions
- type SomeUpdate1Handle
- type SomeUpdate1UpdateOptions
- func (opts *SomeUpdate1UpdateOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeUpdate1UpdateOptions
- func (opts *SomeUpdate1UpdateOptions) WithHeartbeatInterval(d time.Duration) *SomeUpdate1UpdateOptions
- func (opts *SomeUpdate1UpdateOptions) WithUpdateWorkflowOptions(uwo client.UpdateWorkflowWithOptionsRequest) *SomeUpdate1UpdateOptions
- type SomeWorkflow1Run
- type SomeWorkflow1WorkflowOptions
- func (opts *SomeWorkflow1WorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeWorkflow1WorkflowOptions
- func (opts *SomeWorkflow1WorkflowOptions) WithDetached(d bool) *SomeWorkflow1WorkflowOptions
- func (opts *SomeWorkflow1WorkflowOptions) WithHeartbeatInterval(d time.Duration) *SomeWorkflow1WorkflowOptions
- func (opts *SomeWorkflow1WorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *SomeWorkflow1WorkflowOptions
- type SomeWorkflow2Run
- type SomeWorkflow2WorkflowOptions
- func (opts *SomeWorkflow2WorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeWorkflow2WorkflowOptions
- func (opts *SomeWorkflow2WorkflowOptions) WithDetached(d bool) *SomeWorkflow2WorkflowOptions
- func (opts *SomeWorkflow2WorkflowOptions) WithHeartbeatInterval(d time.Duration) *SomeWorkflow2WorkflowOptions
- func (opts *SomeWorkflow2WorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *SomeWorkflow2WorkflowOptions
- type SomeWorkflow3Run
- type SomeWorkflow3WorkflowOptions
- func (opts *SomeWorkflow3WorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeWorkflow3WorkflowOptions
- func (opts *SomeWorkflow3WorkflowOptions) WithDetached(d bool) *SomeWorkflow3WorkflowOptions
- func (opts *SomeWorkflow3WorkflowOptions) WithHeartbeatInterval(d time.Duration) *SomeWorkflow3WorkflowOptions
- func (opts *SomeWorkflow3WorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *SomeWorkflow3WorkflowOptions
- type WhatRun
- type WhatWorkflowOptions
- func (opts *WhatWorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *WhatWorkflowOptions
- func (opts *WhatWorkflowOptions) WithDetached(d bool) *WhatWorkflowOptions
- func (opts *WhatWorkflowOptions) WithHeartbeatInterval(d time.Duration) *WhatWorkflowOptions
- func (opts *WhatWorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *WhatWorkflowOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CancelIgnoredWorkflow ¶
CancelIgnoredWorkflow cancels an existing workflow
func CancelIgnoredWorkflowAsync ¶
func CancelIgnoredWorkflowAsync(ctx workflow.Context, workflowID string, runID string) workflow.Future
CancelIgnoredWorkflowAsync cancels an existing workflow
func CancelOtherWorkflow ¶
CancelOtherWorkflow cancels an existing workflow
func CancelOtherWorkflowAsync ¶
func CancelOtherWorkflowAsync(ctx workflow.Context, workflowID string, runID string) workflow.Future
CancelOtherWorkflowAsync cancels an existing workflow
func CancelSimpleWorkflow ¶
CancelSimpleWorkflow cancels an existing workflow
func CancelSimpleWorkflowAsync ¶
func CancelSimpleWorkflowAsync(ctx workflow.Context, workflowID string, runID string) workflow.Future
CancelSimpleWorkflowAsync cancels an existing workflow
func OtherQuery ¶
func OtherQuery(ctx workflow.Context, workflowID string, runID string, opts ...*OtherQueryQueryOptions) (*simple.OtherQueryResponse, error)
OtherQuery executes a(n) mycompany.simple.Other.OtherQuery query and blocks until error or response received
func OtherSignal ¶
func OtherSignal(ctx workflow.Context, workflowID string, runID string, req *simple.OtherSignalRequest, opts ...*OtherSignalSignalOptions) error
OtherSignal executes a(n) mycompany.simple.Other.OtherSignal signal
func OtherUpdate ¶
func OtherUpdate(ctx workflow.Context, workflowID string, runID string, req *simple.OtherUpdateRequest, opts ...*OtherUpdateUpdateOptions) (*simple.OtherUpdateResponse, error)
OtherUpdate executes a(n) mycompany.simple.Other.OtherUpdate update and blocks until error or response received
func OtherWorkflow ¶
func OtherWorkflow(ctx workflow.Context, req *simple.OtherWorkflowRequest, opts ...*OtherWorkflowWorkflowOptions) (*simple.OtherWorkflowResponse, error)
OtherWorkflow executes a(n) mycompany.simple.Other.OtherWorkflow workflow and blocks until error or response received
func RegisterIgnoredActivities ¶
func RegisterIgnoredActivities(r worker.ActivityRegistry, c simple.IgnoredClient, opts ...IgnoredOptions)
RegisterIgnoredActivities registers mycompany.simple.Ignored cross-namespace activities
func RegisterOtherActivities ¶
func RegisterOtherActivities(r worker.ActivityRegistry, c simple.OtherClient, opts ...OtherOptions)
RegisterOtherActivities registers mycompany.simple.Other cross-namespace activities
func RegisterSimpleActivities ¶
func RegisterSimpleActivities(r worker.ActivityRegistry, c simple.SimpleClient, opts ...SimpleOptions)
RegisterSimpleActivities registers mycompany.simple.Simple cross-namespace activities
func SomeQuery1 ¶
func SomeQuery1(ctx workflow.Context, workflowID string, runID string, opts ...*SomeQuery1QueryOptions) (*simple.SomeQuery1Response, error)
SomeQuery1 queries some thing.
func SomeQuery2 ¶
func SomeQuery2(ctx workflow.Context, workflowID string, runID string, req *simple.SomeQuery2Request, opts ...*SomeQuery2QueryOptions) (*simple.SomeQuery2Response, error)
SomeQuery2 queries some thing.
func SomeSignal1 ¶
func SomeSignal1(ctx workflow.Context, workflowID string, runID string, opts ...*SomeSignal1SignalOptions) error
SomeSignal1 is a signal.
func SomeSignal2 ¶
func SomeSignal2(ctx workflow.Context, workflowID string, runID string, req *simple.SomeSignal2Request, opts ...*SomeSignal2SignalOptions) error
SomeSignal2 is a signal.
func SomeSignal3 ¶
func SomeSignal3(ctx workflow.Context, workflowID string, runID string, req *simple.SomeSignal3Request, opts ...*SomeSignal3SignalOptions) error
SomeSignal3 is a signal.
func SomeUpdate1 ¶
func SomeUpdate1(ctx workflow.Context, workflowID string, runID string, req *simple.SomeUpdate1Request, opts ...*SomeUpdate1UpdateOptions) (*simple.SomeUpdate1Response, error)
SomeUpdate1 updates a SomeWorkflow2
func SomeWorkflow1 ¶
func SomeWorkflow1(ctx workflow.Context, req *simple.SomeWorkflow1Request, opts ...*SomeWorkflow1WorkflowOptions) (*simple.SomeWorkflow1Response, error)
SomeWorkflow1 does some workflow thing.
func SomeWorkflow2 ¶
func SomeWorkflow2(ctx workflow.Context, opts ...*SomeWorkflow2WorkflowOptions) error
SomeWorkflow2 does some workflow thing.
func SomeWorkflow2WithSomeSignal1 ¶
func SomeWorkflow2WithSomeSignal1(ctx workflow.Context, opts ...*SomeWorkflow2WorkflowOptions) error
SomeWorkflow2 does some workflow thing.
func SomeWorkflow3 ¶
func SomeWorkflow3(ctx workflow.Context, req *simple.SomeWorkflow3Request, opts ...*SomeWorkflow3WorkflowOptions) error
SomeWorkflow3 does some workflow thing.
func SomeWorkflow3WithSomeSignal2 ¶
func SomeWorkflow3WithSomeSignal2(ctx workflow.Context, req *simple.SomeWorkflow3Request, signal *simple.SomeSignal2Request, opts ...*SomeWorkflow3WorkflowOptions) error
SomeWorkflow3 does some workflow thing.
func What ¶
func What(ctx workflow.Context, req *simple.WhatRequest, opts ...*WhatWorkflowOptions) error
What executes a(n) mycompany.simple.Ignored.What workflow and blocks until error or response received
Types ¶
type IgnoredOptions ¶ added in v1.5.2
type IgnoredOptions struct {
// Filter is used to filter xns activity registrations. It receives as
// input the original activity name, and should return one of the following:
// 1. the original activity name, for no changes
// 2. a modified activity name, to override the original activity name
// 3. an empty string, to skip registration
Filter func(string) string
}
IgnoredOptions is used to configure mycompany.simple.Ignored xns activity registration
type OtherOptions ¶ added in v1.5.2
type OtherOptions struct {
// Filter is used to filter xns activity registrations. It receives as
// input the original activity name, and should return one of the following:
// 1. the original activity name, for no changes
// 2. a modified activity name, to override the original activity name
// 3. an empty string, to skip registration
Filter func(string) string
}
OtherOptions is used to configure mycompany.simple.Other xns activity registration
type OtherQueryQueryHandle ¶
type OtherQueryQueryHandle 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) (*simple.OtherQueryResponse, error)
}
OtherQueryQueryHandle provides a handle for a OtherQuery query activity
func OtherQueryAsync ¶
func OtherQueryAsync(ctx workflow.Context, workflowID string, runID string, opts ...*OtherQueryQueryOptions) (OtherQueryQueryHandle, error)
OtherQueryAsync executes a(n) mycompany.simple.Other.OtherQuery query and blocks until error or response received
type OtherQueryQueryOptions ¶
type OtherQueryQueryOptions struct {
ActivityOptions *workflow.ActivityOptions
HeartbeatInterval time.Duration
}
OtherQueryQueryOptions are used to configure a(n) mycompany.simple.Other.OtherQuery query execution
func NewOtherQueryQueryOptions ¶
func NewOtherQueryQueryOptions() *OtherQueryQueryOptions
NewOtherQueryQueryOptions initializes a new OtherQueryQueryOptions value
func (*OtherQueryQueryOptions) WithActivityOptions ¶
func (opts *OtherQueryQueryOptions) WithActivityOptions(ao workflow.ActivityOptions) *OtherQueryQueryOptions
WithActivityOptions can be used to customize the activity options
func (*OtherQueryQueryOptions) WithHeartbeatInterval ¶
func (opts *OtherQueryQueryOptions) WithHeartbeatInterval(d time.Duration) *OtherQueryQueryOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
type OtherSignalSignalHandle ¶
type OtherSignalSignalHandle 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
}
OtherSignalSignalHandle provides a handle for a OtherSignal signal activity
func OtherSignalAsync ¶
func OtherSignalAsync(ctx workflow.Context, workflowID string, runID string, req *simple.OtherSignalRequest, opts ...*OtherSignalSignalOptions) (OtherSignalSignalHandle, error)
OtherSignalAsync executes a(n) mycompany.simple.Other.OtherSignal query
type OtherSignalSignalOptions ¶
type OtherSignalSignalOptions struct {
ActivityOptions *workflow.ActivityOptions
HeartbeatInterval time.Duration
}
OtherSignalSignalOptions are used to configure a(n) mycompany.simple.Other.OtherSignal signal execution
func NewOtherSignalSignalOptions ¶
func NewOtherSignalSignalOptions() *OtherSignalSignalOptions
NewOtherSignalSignalOptions initializes a new OtherSignalSignalOptions value
func (*OtherSignalSignalOptions) WithActivityOptions ¶
func (opts *OtherSignalSignalOptions) WithActivityOptions(ao workflow.ActivityOptions) *OtherSignalSignalOptions
WithActivityOptions can be used to customize the activity options
func (*OtherSignalSignalOptions) WithHeartbeatInterval ¶
func (opts *OtherSignalSignalOptions) WithHeartbeatInterval(d time.Duration) *OtherSignalSignalOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
type OtherUpdateHandle ¶
type OtherUpdateHandle 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) (*simple.OtherUpdateResponse, error)
// ID returns the update id
ID() string
}
OtherUpdateHandle provides a handle to a OtherUpdate workflow update
func OtherUpdateAsync ¶
func OtherUpdateAsync(ctx workflow.Context, workflowID string, runID string, req *simple.OtherUpdateRequest, opts ...*OtherUpdateUpdateOptions) (OtherUpdateHandle, error)
OtherUpdateAsync executes a(n) mycompany.simple.Other.OtherUpdate update and blocks until error or response received
type OtherUpdateUpdateOptions ¶
type OtherUpdateUpdateOptions struct {
ActivityOptions *workflow.ActivityOptions
HeartbeatInterval time.Duration
UpdateWorkflowOptions *client.UpdateWorkflowWithOptionsRequest
}
OtherUpdateUpdateOptions are used to configure a(n) OtherUpdate update execution
func NewOtherUpdateUpdateOptions ¶
func NewOtherUpdateUpdateOptions() *OtherUpdateUpdateOptions
NewOtherUpdateUpdateOptions initializes a new OtherUpdateUpdateOptions value
func (*OtherUpdateUpdateOptions) WithActivityOptions ¶
func (opts *OtherUpdateUpdateOptions) WithActivityOptions(ao workflow.ActivityOptions) *OtherUpdateUpdateOptions
WithActivityOptions can be used to customize the activity options
func (*OtherUpdateUpdateOptions) WithHeartbeatInterval ¶
func (opts *OtherUpdateUpdateOptions) WithHeartbeatInterval(d time.Duration) *OtherUpdateUpdateOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
func (*OtherUpdateUpdateOptions) WithUpdateWorkflowOptions ¶
func (opts *OtherUpdateUpdateOptions) WithUpdateWorkflowOptions(uwo client.UpdateWorkflowWithOptionsRequest) *OtherUpdateUpdateOptions
WithUpdateWorkflowOptions can be used to customize the update workflow options
type OtherWorkflowRun ¶
type OtherWorkflowRun 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) (*simple.OtherWorkflowResponse, error)
// ID returns the workflow id
ID() string
}
OtherWorkflowRun provides a handle to a OtherWorkflow workflow execution
func OtherWorkflowAsync ¶
func OtherWorkflowAsync(ctx workflow.Context, req *simple.OtherWorkflowRequest, opts ...*OtherWorkflowWorkflowOptions) (OtherWorkflowRun, error)
OtherWorkflowAsync executes a(n) mycompany.simple.Other.OtherWorkflow workflow and blocks until error or response received
type OtherWorkflowWorkflowOptions ¶
type OtherWorkflowWorkflowOptions struct {
ActivityOptions *workflow.ActivityOptions
Detached bool
HeartbeatInterval time.Duration
StartWorkflowOptions *client.StartWorkflowOptions
}
OtherWorkflowWorkflowOptions are used to configure a(n) OtherWorkflow workflow execution
func NewOtherWorkflowWorkflowOptions ¶
func NewOtherWorkflowWorkflowOptions() *OtherWorkflowWorkflowOptions
NewOtherWorkflowWorkflowOptions initializes a new OtherWorkflowWorkflowOptions value
func (*OtherWorkflowWorkflowOptions) WithActivityOptions ¶
func (opts *OtherWorkflowWorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *OtherWorkflowWorkflowOptions
WithActivityOptions can be used to customize the activity options
func (*OtherWorkflowWorkflowOptions) WithDetached ¶
func (opts *OtherWorkflowWorkflowOptions) WithDetached(d bool) *OtherWorkflowWorkflowOptions
WithDetached can be used to start a workflow execution and exit immediately
func (*OtherWorkflowWorkflowOptions) WithHeartbeatInterval ¶
func (opts *OtherWorkflowWorkflowOptions) WithHeartbeatInterval(d time.Duration) *OtherWorkflowWorkflowOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
func (*OtherWorkflowWorkflowOptions) WithStartWorkflow ¶
func (opts *OtherWorkflowWorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *OtherWorkflowWorkflowOptions
WithStartWorkflowOptions can be used to customize the start workflow options
type SimpleOptions ¶ added in v1.5.2
type SimpleOptions struct {
// Filter is used to filter xns activity registrations. It receives as
// input the original activity name, and should return one of the following:
// 1. the original activity name, for no changes
// 2. a modified activity name, to override the original activity name
// 3. an empty string, to skip registration
Filter func(string) string
}
SimpleOptions is used to configure mycompany.simple.Simple xns activity registration
type SomeQuery1QueryHandle ¶
type SomeQuery1QueryHandle 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) (*simple.SomeQuery1Response, error)
}
SomeQuery1QueryHandle provides a handle for a SomeQuery1 query activity
func SomeQuery1Async ¶
func SomeQuery1Async(ctx workflow.Context, workflowID string, runID string, opts ...*SomeQuery1QueryOptions) (SomeQuery1QueryHandle, error)
SomeQuery1 queries some thing.
type SomeQuery1QueryOptions ¶
type SomeQuery1QueryOptions struct {
ActivityOptions *workflow.ActivityOptions
HeartbeatInterval time.Duration
}
SomeQuery1QueryOptions are used to configure a(n) mycompany.simple.Simple.SomeQuery1 query execution
func NewSomeQuery1QueryOptions ¶
func NewSomeQuery1QueryOptions() *SomeQuery1QueryOptions
NewSomeQuery1QueryOptions initializes a new SomeQuery1QueryOptions value
func (*SomeQuery1QueryOptions) WithActivityOptions ¶
func (opts *SomeQuery1QueryOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeQuery1QueryOptions
WithActivityOptions can be used to customize the activity options
func (*SomeQuery1QueryOptions) WithHeartbeatInterval ¶
func (opts *SomeQuery1QueryOptions) WithHeartbeatInterval(d time.Duration) *SomeQuery1QueryOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
type SomeQuery2QueryHandle ¶
type SomeQuery2QueryHandle 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) (*simple.SomeQuery2Response, error)
}
SomeQuery2QueryHandle provides a handle for a SomeQuery2 query activity
func SomeQuery2Async ¶
func SomeQuery2Async(ctx workflow.Context, workflowID string, runID string, req *simple.SomeQuery2Request, opts ...*SomeQuery2QueryOptions) (SomeQuery2QueryHandle, error)
SomeQuery2 queries some thing.
type SomeQuery2QueryOptions ¶
type SomeQuery2QueryOptions struct {
ActivityOptions *workflow.ActivityOptions
HeartbeatInterval time.Duration
}
SomeQuery2QueryOptions are used to configure a(n) mycompany.simple.Simple.SomeQuery2 query execution
func NewSomeQuery2QueryOptions ¶
func NewSomeQuery2QueryOptions() *SomeQuery2QueryOptions
NewSomeQuery2QueryOptions initializes a new SomeQuery2QueryOptions value
func (*SomeQuery2QueryOptions) WithActivityOptions ¶
func (opts *SomeQuery2QueryOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeQuery2QueryOptions
WithActivityOptions can be used to customize the activity options
func (*SomeQuery2QueryOptions) WithHeartbeatInterval ¶
func (opts *SomeQuery2QueryOptions) WithHeartbeatInterval(d time.Duration) *SomeQuery2QueryOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
type SomeSignal1SignalHandle ¶
type SomeSignal1SignalHandle 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
}
SomeSignal1SignalHandle provides a handle for a SomeSignal1 signal activity
func SomeSignal1Async ¶
func SomeSignal1Async(ctx workflow.Context, workflowID string, runID string, opts ...*SomeSignal1SignalOptions) (SomeSignal1SignalHandle, error)
SomeSignal1 is a signal.
type SomeSignal1SignalOptions ¶
type SomeSignal1SignalOptions struct {
ActivityOptions *workflow.ActivityOptions
HeartbeatInterval time.Duration
}
SomeSignal1SignalOptions are used to configure a(n) mycompany.simple.Simple.SomeSignal1 signal execution
func NewSomeSignal1SignalOptions ¶
func NewSomeSignal1SignalOptions() *SomeSignal1SignalOptions
NewSomeSignal1SignalOptions initializes a new SomeSignal1SignalOptions value
func (*SomeSignal1SignalOptions) WithActivityOptions ¶
func (opts *SomeSignal1SignalOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeSignal1SignalOptions
WithActivityOptions can be used to customize the activity options
func (*SomeSignal1SignalOptions) WithHeartbeatInterval ¶
func (opts *SomeSignal1SignalOptions) WithHeartbeatInterval(d time.Duration) *SomeSignal1SignalOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
type SomeSignal2SignalHandle ¶
type SomeSignal2SignalHandle 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
}
SomeSignal2SignalHandle provides a handle for a SomeSignal2 signal activity
func SomeSignal2Async ¶
func SomeSignal2Async(ctx workflow.Context, workflowID string, runID string, req *simple.SomeSignal2Request, opts ...*SomeSignal2SignalOptions) (SomeSignal2SignalHandle, error)
SomeSignal2 is a signal.
type SomeSignal2SignalOptions ¶
type SomeSignal2SignalOptions struct {
ActivityOptions *workflow.ActivityOptions
HeartbeatInterval time.Duration
}
SomeSignal2SignalOptions are used to configure a(n) mycompany.simple.Simple.SomeSignal2 signal execution
func NewSomeSignal2SignalOptions ¶
func NewSomeSignal2SignalOptions() *SomeSignal2SignalOptions
NewSomeSignal2SignalOptions initializes a new SomeSignal2SignalOptions value
func (*SomeSignal2SignalOptions) WithActivityOptions ¶
func (opts *SomeSignal2SignalOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeSignal2SignalOptions
WithActivityOptions can be used to customize the activity options
func (*SomeSignal2SignalOptions) WithHeartbeatInterval ¶
func (opts *SomeSignal2SignalOptions) WithHeartbeatInterval(d time.Duration) *SomeSignal2SignalOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
type SomeSignal3SignalHandle ¶
type SomeSignal3SignalHandle 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
}
SomeSignal3SignalHandle provides a handle for a SomeSignal3 signal activity
func SomeSignal3Async ¶
func SomeSignal3Async(ctx workflow.Context, workflowID string, runID string, req *simple.SomeSignal3Request, opts ...*SomeSignal3SignalOptions) (SomeSignal3SignalHandle, error)
SomeSignal3 is a signal.
type SomeSignal3SignalOptions ¶
type SomeSignal3SignalOptions struct {
ActivityOptions *workflow.ActivityOptions
HeartbeatInterval time.Duration
}
SomeSignal3SignalOptions are used to configure a(n) mycompany.simple.Simple.SomeSignal3 signal execution
func NewSomeSignal3SignalOptions ¶
func NewSomeSignal3SignalOptions() *SomeSignal3SignalOptions
NewSomeSignal3SignalOptions initializes a new SomeSignal3SignalOptions value
func (*SomeSignal3SignalOptions) WithActivityOptions ¶
func (opts *SomeSignal3SignalOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeSignal3SignalOptions
WithActivityOptions can be used to customize the activity options
func (*SomeSignal3SignalOptions) WithHeartbeatInterval ¶
func (opts *SomeSignal3SignalOptions) WithHeartbeatInterval(d time.Duration) *SomeSignal3SignalOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
type SomeUpdate1Handle ¶
type SomeUpdate1Handle 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) (*simple.SomeUpdate1Response, error)
// ID returns the update id
ID() string
}
SomeUpdate1Handle provides a handle to a SomeUpdate1 workflow update
func SomeUpdate1Async ¶
func SomeUpdate1Async(ctx workflow.Context, workflowID string, runID string, req *simple.SomeUpdate1Request, opts ...*SomeUpdate1UpdateOptions) (SomeUpdate1Handle, error)
SomeUpdate1 updates a SomeWorkflow2
type SomeUpdate1UpdateOptions ¶
type SomeUpdate1UpdateOptions struct {
ActivityOptions *workflow.ActivityOptions
HeartbeatInterval time.Duration
UpdateWorkflowOptions *client.UpdateWorkflowWithOptionsRequest
}
SomeUpdate1UpdateOptions are used to configure a(n) SomeUpdate1 update execution
func NewSomeUpdate1UpdateOptions ¶
func NewSomeUpdate1UpdateOptions() *SomeUpdate1UpdateOptions
NewSomeUpdate1UpdateOptions initializes a new SomeUpdate1UpdateOptions value
func (*SomeUpdate1UpdateOptions) WithActivityOptions ¶
func (opts *SomeUpdate1UpdateOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeUpdate1UpdateOptions
WithActivityOptions can be used to customize the activity options
func (*SomeUpdate1UpdateOptions) WithHeartbeatInterval ¶
func (opts *SomeUpdate1UpdateOptions) WithHeartbeatInterval(d time.Duration) *SomeUpdate1UpdateOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
func (*SomeUpdate1UpdateOptions) WithUpdateWorkflowOptions ¶
func (opts *SomeUpdate1UpdateOptions) WithUpdateWorkflowOptions(uwo client.UpdateWorkflowWithOptionsRequest) *SomeUpdate1UpdateOptions
WithUpdateWorkflowOptions can be used to customize the update workflow options
type SomeWorkflow1Run ¶
type SomeWorkflow1Run 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) (*simple.SomeWorkflow1Response, error)
// ID returns the workflow id
ID() string
// SomeQuery1 queries some thing.
SomeQuery1(workflow.Context, ...*SomeQuery1QueryOptions) (*simple.SomeQuery1Response, error)
// SomeQuery1 queries some thing.
SomeQuery1Async(workflow.Context, ...*SomeQuery1QueryOptions) (SomeQuery1QueryHandle, error)
// SomeQuery2 queries some thing.
SomeQuery2(workflow.Context, *simple.SomeQuery2Request, ...*SomeQuery2QueryOptions) (*simple.SomeQuery2Response, error)
// SomeQuery2 queries some thing.
SomeQuery2Async(workflow.Context, *simple.SomeQuery2Request, ...*SomeQuery2QueryOptions) (SomeQuery2QueryHandle, error)
// SomeSignal1 is a signal.
SomeSignal1(workflow.Context, ...*SomeSignal1SignalOptions) error
// SomeSignal1 is a signal.
SomeSignal1Async(workflow.Context, ...*SomeSignal1SignalOptions) (SomeSignal1SignalHandle, error)
// SomeSignal2 is a signal.
SomeSignal2(workflow.Context, *simple.SomeSignal2Request, ...*SomeSignal2SignalOptions) error
// SomeSignal2 is a signal.
SomeSignal2Async(workflow.Context, *simple.SomeSignal2Request, ...*SomeSignal2SignalOptions) (SomeSignal2SignalHandle, error)
}
SomeWorkflow1Run provides a handle to a SomeWorkflow1 workflow execution
func SomeWorkflow1Async ¶
func SomeWorkflow1Async(ctx workflow.Context, req *simple.SomeWorkflow1Request, opts ...*SomeWorkflow1WorkflowOptions) (SomeWorkflow1Run, error)
SomeWorkflow1 does some workflow thing.
type SomeWorkflow1WorkflowOptions ¶
type SomeWorkflow1WorkflowOptions struct {
ActivityOptions *workflow.ActivityOptions
Detached bool
HeartbeatInterval time.Duration
StartWorkflowOptions *client.StartWorkflowOptions
}
SomeWorkflow1WorkflowOptions are used to configure a(n) SomeWorkflow1 workflow execution
func NewSomeWorkflow1WorkflowOptions ¶
func NewSomeWorkflow1WorkflowOptions() *SomeWorkflow1WorkflowOptions
NewSomeWorkflow1WorkflowOptions initializes a new SomeWorkflow1WorkflowOptions value
func (*SomeWorkflow1WorkflowOptions) WithActivityOptions ¶
func (opts *SomeWorkflow1WorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeWorkflow1WorkflowOptions
WithActivityOptions can be used to customize the activity options
func (*SomeWorkflow1WorkflowOptions) WithDetached ¶
func (opts *SomeWorkflow1WorkflowOptions) WithDetached(d bool) *SomeWorkflow1WorkflowOptions
WithDetached can be used to start a workflow execution and exit immediately
func (*SomeWorkflow1WorkflowOptions) WithHeartbeatInterval ¶
func (opts *SomeWorkflow1WorkflowOptions) WithHeartbeatInterval(d time.Duration) *SomeWorkflow1WorkflowOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
func (*SomeWorkflow1WorkflowOptions) WithStartWorkflow ¶
func (opts *SomeWorkflow1WorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *SomeWorkflow1WorkflowOptions
WithStartWorkflowOptions can be used to customize the start workflow options
type SomeWorkflow2Run ¶
type SomeWorkflow2Run 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
// SomeSignal1 is a signal.
SomeSignal1(workflow.Context, ...*SomeSignal1SignalOptions) error
// SomeSignal1 is a signal.
SomeSignal1Async(workflow.Context, ...*SomeSignal1SignalOptions) (SomeSignal1SignalHandle, error)
// SomeUpdate1 updates a SomeWorkflow2
SomeUpdate1(workflow.Context, *simple.SomeUpdate1Request, ...*SomeUpdate1UpdateOptions) (*simple.SomeUpdate1Response, error)
// SomeUpdate1 updates a SomeWorkflow2
SomeUpdate1Async(workflow.Context, *simple.SomeUpdate1Request, ...*SomeUpdate1UpdateOptions) (SomeUpdate1Handle, error)
}
SomeWorkflow2Run provides a handle to a SomeWorkflow2 workflow execution
func SomeWorkflow2Async ¶
func SomeWorkflow2Async(ctx workflow.Context, opts ...*SomeWorkflow2WorkflowOptions) (SomeWorkflow2Run, error)
SomeWorkflow2 does some workflow thing.
func SomeWorkflow2WithSomeSignal1Async ¶
func SomeWorkflow2WithSomeSignal1Async(ctx workflow.Context, opts ...*SomeWorkflow2WorkflowOptions) (SomeWorkflow2Run, error)
SomeWorkflow2 does some workflow thing.
type SomeWorkflow2WorkflowOptions ¶
type SomeWorkflow2WorkflowOptions struct {
ActivityOptions *workflow.ActivityOptions
Detached bool
HeartbeatInterval time.Duration
StartWorkflowOptions *client.StartWorkflowOptions
}
SomeWorkflow2WorkflowOptions are used to configure a(n) SomeWorkflow2 workflow execution
func NewSomeWorkflow2WorkflowOptions ¶
func NewSomeWorkflow2WorkflowOptions() *SomeWorkflow2WorkflowOptions
NewSomeWorkflow2WorkflowOptions initializes a new SomeWorkflow2WorkflowOptions value
func (*SomeWorkflow2WorkflowOptions) WithActivityOptions ¶
func (opts *SomeWorkflow2WorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeWorkflow2WorkflowOptions
WithActivityOptions can be used to customize the activity options
func (*SomeWorkflow2WorkflowOptions) WithDetached ¶
func (opts *SomeWorkflow2WorkflowOptions) WithDetached(d bool) *SomeWorkflow2WorkflowOptions
WithDetached can be used to start a workflow execution and exit immediately
func (*SomeWorkflow2WorkflowOptions) WithHeartbeatInterval ¶
func (opts *SomeWorkflow2WorkflowOptions) WithHeartbeatInterval(d time.Duration) *SomeWorkflow2WorkflowOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
func (*SomeWorkflow2WorkflowOptions) WithStartWorkflow ¶
func (opts *SomeWorkflow2WorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *SomeWorkflow2WorkflowOptions
WithStartWorkflowOptions can be used to customize the start workflow options
type SomeWorkflow3Run ¶
type SomeWorkflow3Run 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
// SomeSignal2 is a signal.
SomeSignal2(workflow.Context, *simple.SomeSignal2Request, ...*SomeSignal2SignalOptions) error
// SomeSignal2 is a signal.
SomeSignal2Async(workflow.Context, *simple.SomeSignal2Request, ...*SomeSignal2SignalOptions) (SomeSignal2SignalHandle, error)
}
SomeWorkflow3Run provides a handle to a SomeWorkflow3 workflow execution
func SomeWorkflow3Async ¶
func SomeWorkflow3Async(ctx workflow.Context, req *simple.SomeWorkflow3Request, opts ...*SomeWorkflow3WorkflowOptions) (SomeWorkflow3Run, error)
SomeWorkflow3 does some workflow thing.
func SomeWorkflow3WithSomeSignal2Async ¶
func SomeWorkflow3WithSomeSignal2Async(ctx workflow.Context, req *simple.SomeWorkflow3Request, signal *simple.SomeSignal2Request, opts ...*SomeWorkflow3WorkflowOptions) (SomeWorkflow3Run, error)
SomeWorkflow3 does some workflow thing.
type SomeWorkflow3WorkflowOptions ¶
type SomeWorkflow3WorkflowOptions struct {
ActivityOptions *workflow.ActivityOptions
Detached bool
HeartbeatInterval time.Duration
StartWorkflowOptions *client.StartWorkflowOptions
}
SomeWorkflow3WorkflowOptions are used to configure a(n) SomeWorkflow3 workflow execution
func NewSomeWorkflow3WorkflowOptions ¶
func NewSomeWorkflow3WorkflowOptions() *SomeWorkflow3WorkflowOptions
NewSomeWorkflow3WorkflowOptions initializes a new SomeWorkflow3WorkflowOptions value
func (*SomeWorkflow3WorkflowOptions) WithActivityOptions ¶
func (opts *SomeWorkflow3WorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeWorkflow3WorkflowOptions
WithActivityOptions can be used to customize the activity options
func (*SomeWorkflow3WorkflowOptions) WithDetached ¶
func (opts *SomeWorkflow3WorkflowOptions) WithDetached(d bool) *SomeWorkflow3WorkflowOptions
WithDetached can be used to start a workflow execution and exit immediately
func (*SomeWorkflow3WorkflowOptions) WithHeartbeatInterval ¶
func (opts *SomeWorkflow3WorkflowOptions) WithHeartbeatInterval(d time.Duration) *SomeWorkflow3WorkflowOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
func (*SomeWorkflow3WorkflowOptions) WithStartWorkflow ¶
func (opts *SomeWorkflow3WorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *SomeWorkflow3WorkflowOptions
WithStartWorkflowOptions can be used to customize the start workflow options
type WhatRun ¶
type WhatRun 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
}
WhatRun provides a handle to a What workflow execution
func WhatAsync ¶
func WhatAsync(ctx workflow.Context, req *simple.WhatRequest, opts ...*WhatWorkflowOptions) (WhatRun, error)
WhatAsync executes a(n) mycompany.simple.Ignored.What workflow and blocks until error or response received
type WhatWorkflowOptions ¶
type WhatWorkflowOptions struct {
ActivityOptions *workflow.ActivityOptions
Detached bool
HeartbeatInterval time.Duration
StartWorkflowOptions *client.StartWorkflowOptions
}
WhatWorkflowOptions are used to configure a(n) What workflow execution
func NewWhatWorkflowOptions ¶
func NewWhatWorkflowOptions() *WhatWorkflowOptions
NewWhatWorkflowOptions initializes a new WhatWorkflowOptions value
func (*WhatWorkflowOptions) WithActivityOptions ¶
func (opts *WhatWorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *WhatWorkflowOptions
WithActivityOptions can be used to customize the activity options
func (*WhatWorkflowOptions) WithDetached ¶
func (opts *WhatWorkflowOptions) WithDetached(d bool) *WhatWorkflowOptions
WithDetached can be used to start a workflow execution and exit immediately
func (*WhatWorkflowOptions) WithHeartbeatInterval ¶
func (opts *WhatWorkflowOptions) WithHeartbeatInterval(d time.Duration) *WhatWorkflowOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
func (*WhatWorkflowOptions) WithStartWorkflow ¶
func (opts *WhatWorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *WhatWorkflowOptions
WithStartWorkflowOptions can be used to customize the start workflow options