Documentation ¶
Overview ¶
Code generated by protoc-gen-go_temporal. DO NOT EDIT. versions:
protoc-gen-go_temporal 1.14.6-next (0ec9655dd1130535a5c8cfbda7a326aef9ac448a) go go1.23.4 protoc (unknown)
source: test/simple/v1/simple.proto
Index ¶
- func CancelDeprecatedWorkflow(ctx workflow.Context, workflowID string, runID string) error
- func CancelDeprecatedWorkflowAsync(ctx workflow.Context, workflowID string, runID string) workflow.Future
- func CancelIgnoredWorkflow(ctx workflow.Context, workflowID string, runID string) error
- func CancelIgnoredWorkflowAsync(ctx workflow.Context, workflowID string, runID string) workflow.Future
- func CancelOnlyActivitiesWorkflow(ctx workflow.Context, workflowID string, runID string) error
- func CancelOnlyActivitiesWorkflowAsync(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, ...) (*v1.OtherQueryResponse, error)
- func OtherSignal(ctx workflow.Context, workflowID string, runID string, ...) error
- func OtherUpdate(ctx workflow.Context, workflowID string, runID string, ...) (*v1.OtherUpdateResponse, error)
- func OtherWorkflow(ctx workflow.Context, req *v1.OtherWorkflowRequest, ...) (*v1.OtherWorkflowResponse, error)
- func RegisterDeprecatedActivities(r worker.ActivityRegistry, c v1.DeprecatedClient, ...)
- func RegisterIgnoredActivities(r worker.ActivityRegistry, c v1.IgnoredClient, options ...*IgnoredOptions)
- func RegisterOnlyActivitiesActivities(r worker.ActivityRegistry, c v1.OnlyActivitiesClient, ...)
- func RegisterOtherActivities(r worker.ActivityRegistry, c v1.OtherClient, options ...*OtherOptions)
- func RegisterSimpleActivities(r worker.ActivityRegistry, c v1.SimpleClient, options ...*SimpleOptions)
- func SomeDeprecatedQuery1(ctx workflow.Context, workflowID string, runID string, ...) (*v1.SomeDeprecatedMessage, error)deprecated
- func SomeDeprecatedQuery2(ctx workflow.Context, workflowID string, runID string, ...) (*v1.SomeDeprecatedMessage, error)deprecated
- func SomeDeprecatedSignal1(ctx workflow.Context, workflowID string, runID string, ...) errordeprecated
- func SomeDeprecatedSignal2(ctx workflow.Context, workflowID string, runID string, ...) errordeprecated
- func SomeDeprecatedUpdate1(ctx workflow.Context, workflowID string, runID string, ...) (*v1.SomeDeprecatedMessage, error)deprecated
- func SomeDeprecatedUpdate2(ctx workflow.Context, workflowID string, runID string, ...) (*v1.SomeDeprecatedMessage, error)deprecated
- func SomeDeprecatedWorkflow1(ctx workflow.Context, req *v1.SomeDeprecatedMessage, ...) (*v1.SomeDeprecatedMessage, error)deprecated
- func SomeDeprecatedWorkflow1WithSomeDeprecatedSignal1(ctx workflow.Context, req *v1.SomeDeprecatedMessage, ...) (*v1.SomeDeprecatedMessage, error)deprecated
- func SomeDeprecatedWorkflow2(ctx workflow.Context, req *v1.SomeDeprecatedMessage, ...) (*v1.SomeDeprecatedMessage, error)deprecated
- func SomeDeprecatedWorkflow2WithSomeDeprecatedSignal2(ctx workflow.Context, req *v1.SomeDeprecatedMessage, ...) (*v1.SomeDeprecatedMessage, error)deprecated
- func SomeQuery1(ctx workflow.Context, workflowID string, runID string, ...) (*v1.SomeQuery1Response, error)
- func SomeQuery2(ctx workflow.Context, workflowID string, runID string, ...) (*v1.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, ...) (*v1.SomeUpdate1Response, error)
- func SomeWorkflow1(ctx workflow.Context, req *v1.SomeWorkflow1Request, ...) (*v1.SomeWorkflow1Response, error)
- func SomeWorkflow2(ctx workflow.Context, opts ...*SomeWorkflow2WorkflowOptions) error
- func SomeWorkflow2WithSomeSignal1(ctx workflow.Context, opts ...*SomeWorkflow2WorkflowOptions) error
- func SomeWorkflow3(ctx workflow.Context, req *v1.SomeWorkflow3Request, ...) error
- func SomeWorkflow3WithSomeSignal2(ctx workflow.Context, req *v1.SomeWorkflow3Request, ...) errordeprecated
- func SomeWorkflow4(ctx workflow.Context, req *v11.PaginatedRequest, ...) (*v11.PaginatedResponse, error)
- func What(ctx workflow.Context, req *v1.WhatRequest, opts ...*WhatWorkflowOptions) error
- type DeprecatedOptions
- type IgnoredOptions
- type OnlyActivitiesOptions
- 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.UpdateWorkflowOptions) *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) WithParentClosePolicy(policy enumsv1.ParentClosePolicy) *OtherWorkflowWorkflowOptions
- func (opts *OtherWorkflowWorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *OtherWorkflowWorkflowOptions
- type SimpleOptions
- type SomeDeprecatedQuery1QueryHandle
- type SomeDeprecatedQuery1QueryOptions
- type SomeDeprecatedQuery2QueryHandle
- type SomeDeprecatedQuery2QueryOptions
- type SomeDeprecatedSignal1SignalHandle
- type SomeDeprecatedSignal1SignalOptions
- type SomeDeprecatedSignal2SignalHandle
- type SomeDeprecatedSignal2SignalOptions
- type SomeDeprecatedUpdate1Handle
- type SomeDeprecatedUpdate1UpdateOptions
- func (opts *SomeDeprecatedUpdate1UpdateOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeDeprecatedUpdate1UpdateOptions
- func (opts *SomeDeprecatedUpdate1UpdateOptions) WithHeartbeatInterval(d time.Duration) *SomeDeprecatedUpdate1UpdateOptions
- func (opts *SomeDeprecatedUpdate1UpdateOptions) WithUpdateWorkflowOptions(uwo client.UpdateWorkflowOptions) *SomeDeprecatedUpdate1UpdateOptions
- type SomeDeprecatedUpdate2Handle
- type SomeDeprecatedUpdate2UpdateOptions
- func (opts *SomeDeprecatedUpdate2UpdateOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeDeprecatedUpdate2UpdateOptions
- func (opts *SomeDeprecatedUpdate2UpdateOptions) WithHeartbeatInterval(d time.Duration) *SomeDeprecatedUpdate2UpdateOptions
- func (opts *SomeDeprecatedUpdate2UpdateOptions) WithUpdateWorkflowOptions(uwo client.UpdateWorkflowOptions) *SomeDeprecatedUpdate2UpdateOptions
- type SomeDeprecatedWorkflow1Run
- func SomeDeprecatedWorkflow1Async(ctx workflow.Context, req *v1.SomeDeprecatedMessage, ...) (SomeDeprecatedWorkflow1Run, error)deprecated
- func SomeDeprecatedWorkflow1WithSomeDeprecatedSignal1Async(ctx workflow.Context, req *v1.SomeDeprecatedMessage, ...) (SomeDeprecatedWorkflow1Run, error)deprecated
- type SomeDeprecatedWorkflow1WorkflowOptions
- func (opts *SomeDeprecatedWorkflow1WorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeDeprecatedWorkflow1WorkflowOptions
- func (opts *SomeDeprecatedWorkflow1WorkflowOptions) WithDetached(d bool) *SomeDeprecatedWorkflow1WorkflowOptions
- func (opts *SomeDeprecatedWorkflow1WorkflowOptions) WithHeartbeatInterval(d time.Duration) *SomeDeprecatedWorkflow1WorkflowOptions
- func (opts *SomeDeprecatedWorkflow1WorkflowOptions) WithParentClosePolicy(policy enumsv1.ParentClosePolicy) *SomeDeprecatedWorkflow1WorkflowOptions
- func (opts *SomeDeprecatedWorkflow1WorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *SomeDeprecatedWorkflow1WorkflowOptions
- type SomeDeprecatedWorkflow2Run
- func SomeDeprecatedWorkflow2Async(ctx workflow.Context, req *v1.SomeDeprecatedMessage, ...) (SomeDeprecatedWorkflow2Run, error)deprecated
- func SomeDeprecatedWorkflow2WithSomeDeprecatedSignal2Async(ctx workflow.Context, req *v1.SomeDeprecatedMessage, ...) (SomeDeprecatedWorkflow2Run, error)deprecated
- type SomeDeprecatedWorkflow2WorkflowOptions
- func (opts *SomeDeprecatedWorkflow2WorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeDeprecatedWorkflow2WorkflowOptions
- func (opts *SomeDeprecatedWorkflow2WorkflowOptions) WithDetached(d bool) *SomeDeprecatedWorkflow2WorkflowOptions
- func (opts *SomeDeprecatedWorkflow2WorkflowOptions) WithHeartbeatInterval(d time.Duration) *SomeDeprecatedWorkflow2WorkflowOptions
- func (opts *SomeDeprecatedWorkflow2WorkflowOptions) WithParentClosePolicy(policy enumsv1.ParentClosePolicy) *SomeDeprecatedWorkflow2WorkflowOptions
- func (opts *SomeDeprecatedWorkflow2WorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *SomeDeprecatedWorkflow2WorkflowOptions
- 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.UpdateWorkflowOptions) *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) WithParentClosePolicy(policy enumsv1.ParentClosePolicy) *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) WithParentClosePolicy(policy enumsv1.ParentClosePolicy) *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) WithParentClosePolicy(policy enumsv1.ParentClosePolicy) *SomeWorkflow3WorkflowOptions
- func (opts *SomeWorkflow3WorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *SomeWorkflow3WorkflowOptions
- type SomeWorkflow4Run
- type SomeWorkflow4WorkflowOptions
- func (opts *SomeWorkflow4WorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeWorkflow4WorkflowOptions
- func (opts *SomeWorkflow4WorkflowOptions) WithDetached(d bool) *SomeWorkflow4WorkflowOptions
- func (opts *SomeWorkflow4WorkflowOptions) WithHeartbeatInterval(d time.Duration) *SomeWorkflow4WorkflowOptions
- func (opts *SomeWorkflow4WorkflowOptions) WithParentClosePolicy(policy enumsv1.ParentClosePolicy) *SomeWorkflow4WorkflowOptions
- func (opts *SomeWorkflow4WorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *SomeWorkflow4WorkflowOptions
- 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) WithParentClosePolicy(policy enumsv1.ParentClosePolicy) *WhatWorkflowOptions
- func (opts *WhatWorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *WhatWorkflowOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CancelDeprecatedWorkflow ¶
CancelDeprecatedWorkflow cancels an existing workflow
func CancelDeprecatedWorkflowAsync ¶
func CancelDeprecatedWorkflowAsync(ctx workflow.Context, workflowID string, runID string) workflow.Future
CancelDeprecatedWorkflowAsync cancels an existing workflow
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 CancelOnlyActivitiesWorkflow ¶
CancelOnlyActivitiesWorkflow cancels an existing workflow
func CancelOnlyActivitiesWorkflowAsync ¶
func CancelOnlyActivitiesWorkflowAsync(ctx workflow.Context, workflowID string, runID string) workflow.Future
CancelOnlyActivitiesWorkflowAsync 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) (*v1.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 *v1.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 *v1.OtherUpdateRequest, opts ...*OtherUpdateUpdateOptions) (*v1.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 *v1.OtherWorkflowRequest, opts ...*OtherWorkflowWorkflowOptions) (*v1.OtherWorkflowResponse, error)
OtherWorkflow executes a(n) mycompany.simple.Other.OtherWorkflow workflow and blocks until error or response is received
func RegisterDeprecatedActivities ¶
func RegisterDeprecatedActivities(r worker.ActivityRegistry, c v1.DeprecatedClient, options ...*DeprecatedOptions)
RegisterDeprecatedActivities registers mycompany.simple.Deprecated cross-namespace activities
func RegisterIgnoredActivities ¶
func RegisterIgnoredActivities(r worker.ActivityRegistry, c v1.IgnoredClient, options ...*IgnoredOptions)
RegisterIgnoredActivities registers mycompany.simple.Ignored cross-namespace activities
func RegisterOnlyActivitiesActivities ¶
func RegisterOnlyActivitiesActivities(r worker.ActivityRegistry, c v1.OnlyActivitiesClient, options ...*OnlyActivitiesOptions)
RegisterOnlyActivitiesActivities registers mycompany.simple.OnlyActivities cross-namespace activities
func RegisterOtherActivities ¶
func RegisterOtherActivities(r worker.ActivityRegistry, c v1.OtherClient, options ...*OtherOptions)
RegisterOtherActivities registers mycompany.simple.Other cross-namespace activities
func RegisterSimpleActivities ¶
func RegisterSimpleActivities(r worker.ActivityRegistry, c v1.SimpleClient, options ...*SimpleOptions)
RegisterSimpleActivities registers mycompany.simple.Simple cross-namespace activities
func SomeDeprecatedQuery1
deprecated
func SomeDeprecatedQuery1(ctx workflow.Context, workflowID string, runID string, req *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedQuery1QueryOptions) (*v1.SomeDeprecatedMessage, error)
SomeDeprecatedQuery1 does something else
Deprecated: Do not use.
func SomeDeprecatedQuery2
deprecated
func SomeDeprecatedQuery2(ctx workflow.Context, workflowID string, runID string, req *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedQuery2QueryOptions) (*v1.SomeDeprecatedMessage, error)
SomeDeprecatedQuery2 does something else
Deprecated: a custom query deprecation message.
func SomeDeprecatedSignal1
deprecated
func SomeDeprecatedSignal1(ctx workflow.Context, workflowID string, runID string, req *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedSignal1SignalOptions) error
SomeDeprecatedSignal1 does something else
Deprecated: Do not use.
func SomeDeprecatedSignal2
deprecated
func SomeDeprecatedSignal2(ctx workflow.Context, workflowID string, runID string, req *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedSignal2SignalOptions) error
SomeDeprecatedSignal2 does something else
Deprecated: a custom signal deprecation message.
func SomeDeprecatedUpdate1
deprecated
func SomeDeprecatedUpdate1(ctx workflow.Context, workflowID string, runID string, req *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedUpdate1UpdateOptions) (*v1.SomeDeprecatedMessage, error)
SomeDeprecatedUpdate1 does something else
Deprecated: Do not use.
func SomeDeprecatedUpdate2
deprecated
func SomeDeprecatedUpdate2(ctx workflow.Context, workflowID string, runID string, req *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedUpdate2UpdateOptions) (*v1.SomeDeprecatedMessage, error)
SomeDeprecatedUpdate2 does something else
Deprecated: a custom signal deprecation message.
func SomeDeprecatedWorkflow1
deprecated
func SomeDeprecatedWorkflow1(ctx workflow.Context, req *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow1WorkflowOptions) (*v1.SomeDeprecatedMessage, error)
SomeDeprecatedWorkflow1 does something
Deprecated: Do not use.
func SomeDeprecatedWorkflow1WithSomeDeprecatedSignal1
deprecated
func SomeDeprecatedWorkflow1WithSomeDeprecatedSignal1(ctx workflow.Context, req *v1.SomeDeprecatedMessage, signal *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow1WorkflowOptions) (*v1.SomeDeprecatedMessage, error)
SomeDeprecatedWorkflow1WithSomeDeprecatedSignal1 sends a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal1 signal to a mycompany.simple.Deprecated.SomeDeprecatedWorkflow1 workflow, starting it if necessary, and blocks until the workflow completes
Deprecated: Do not use.
func SomeDeprecatedWorkflow2
deprecated
func SomeDeprecatedWorkflow2(ctx workflow.Context, req *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow2WorkflowOptions) (*v1.SomeDeprecatedMessage, error)
SomeDeprecatedWorkflow2 does something else
Deprecated: a custom workflow deprecation message.
func SomeDeprecatedWorkflow2WithSomeDeprecatedSignal2
deprecated
func SomeDeprecatedWorkflow2WithSomeDeprecatedSignal2(ctx workflow.Context, req *v1.SomeDeprecatedMessage, signal *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow2WorkflowOptions) (*v1.SomeDeprecatedMessage, error)
SomeDeprecatedWorkflow2WithSomeDeprecatedSignal2 sends a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal2 signal to a mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow, starting it if necessary, and blocks until the workflow completes
Deprecated: Do not use.
func SomeQuery1 ¶
func SomeQuery1(ctx workflow.Context, workflowID string, runID string, opts ...*SomeQuery1QueryOptions) (*v1.SomeQuery1Response, error)
SomeQuery1 queries some thing.
func SomeQuery2 ¶
func SomeQuery2(ctx workflow.Context, workflowID string, runID string, req *v1.SomeQuery2Request, opts ...*SomeQuery2QueryOptions) (*v1.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 *v1.SomeSignal2Request, opts ...*SomeSignal2SignalOptions) error
SomeSignal2 is a signal.
func SomeSignal3 ¶
func SomeSignal3(ctx workflow.Context, workflowID string, runID string, req *v1.SomeSignal3Request, opts ...*SomeSignal3SignalOptions) error
SomeSignal3 is a signal.
func SomeUpdate1 ¶
func SomeUpdate1(ctx workflow.Context, workflowID string, runID string, req *v1.SomeUpdate1Request, opts ...*SomeUpdate1UpdateOptions) (*v1.SomeUpdate1Response, error)
SomeUpdate1 updates a SomeWorkflow2
func SomeWorkflow1 ¶
func SomeWorkflow1(ctx workflow.Context, req *v1.SomeWorkflow1Request, opts ...*SomeWorkflow1WorkflowOptions) (*v1.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
SomeWorkflow2WithSomeSignal1 sends a(n) mycompany.simple.Simple.SomeSignal1 signal to a mycompany.simple.SomeWorkflow2 workflow, starting it if necessary, and blocks until the workflow completes
func SomeWorkflow3 ¶
func SomeWorkflow3(ctx workflow.Context, req *v1.SomeWorkflow3Request, opts ...*SomeWorkflow3WorkflowOptions) error
SomeWorkflow3 does some workflow thing. Deprecated: Use SomeWorkflow2 instead.
func SomeWorkflow3WithSomeSignal2
deprecated
func SomeWorkflow3WithSomeSignal2(ctx workflow.Context, req *v1.SomeWorkflow3Request, signal *v1.SomeSignal2Request, opts ...*SomeWorkflow3WorkflowOptions) error
SomeWorkflow3WithSomeSignal2 sends a(n) mycompany.simple.Simple.SomeSignal2 signal to a mycompany.simple.Simple.SomeWorkflow3 workflow, starting it if necessary, and blocks until the workflow completes
Deprecated: Do not use.
func SomeWorkflow4 ¶ added in v1.13.2
func SomeWorkflow4(ctx workflow.Context, req *v11.PaginatedRequest, opts ...*SomeWorkflow4WorkflowOptions) (*v11.PaginatedResponse, error)
SomeWorkflow4 retrieves a paginated list of items
func What ¶
func What(ctx workflow.Context, req *v1.WhatRequest, opts ...*WhatWorkflowOptions) error
What executes a(n) mycompany.simple.Ignored.What workflow and blocks until error or response is received
Types ¶
type DeprecatedOptions ¶
type DeprecatedOptions struct {
// contains filtered or unexported fields
}
DeprecatedOptions is used to configure mycompany.simple.Deprecated xns activity registration
func NewDeprecatedOptions ¶
func NewDeprecatedOptions() *DeprecatedOptions
NewDeprecatedOptions initializes a new DeprecatedOptions value
func (*DeprecatedOptions) WithErrorConverter ¶
func (opts *DeprecatedOptions) WithErrorConverter(errorConverter func(error) error) *DeprecatedOptions
WithErrorConverter overrides the default error converter applied to xns activity errors
func (*DeprecatedOptions) WithFilter ¶
func (opts *DeprecatedOptions) WithFilter(filter func(string) string) *DeprecatedOptions
Filter is used to filter registered xns activities or customize their name
type IgnoredOptions ¶
type IgnoredOptions struct {
// contains filtered or unexported fields
}
IgnoredOptions is used to configure mycompany.simple.Ignored xns activity registration
func NewIgnoredOptions ¶
func NewIgnoredOptions() *IgnoredOptions
NewIgnoredOptions initializes a new IgnoredOptions value
func (*IgnoredOptions) WithErrorConverter ¶
func (opts *IgnoredOptions) WithErrorConverter(errorConverter func(error) error) *IgnoredOptions
WithErrorConverter overrides the default error converter applied to xns activity errors
func (*IgnoredOptions) WithFilter ¶
func (opts *IgnoredOptions) WithFilter(filter func(string) string) *IgnoredOptions
Filter is used to filter registered xns activities or customize their name
type OnlyActivitiesOptions ¶
type OnlyActivitiesOptions struct {
// contains filtered or unexported fields
}
OnlyActivitiesOptions is used to configure mycompany.simple.OnlyActivities xns activity registration
func NewOnlyActivitiesOptions ¶
func NewOnlyActivitiesOptions() *OnlyActivitiesOptions
NewOnlyActivitiesOptions initializes a new OnlyActivitiesOptions value
func (*OnlyActivitiesOptions) WithErrorConverter ¶
func (opts *OnlyActivitiesOptions) WithErrorConverter(errorConverter func(error) error) *OnlyActivitiesOptions
WithErrorConverter overrides the default error converter applied to xns activity errors
func (*OnlyActivitiesOptions) WithFilter ¶
func (opts *OnlyActivitiesOptions) WithFilter(filter func(string) string) *OnlyActivitiesOptions
Filter is used to filter registered xns activities or customize their name
type OtherOptions ¶
type OtherOptions struct {
// contains filtered or unexported fields
}
OtherOptions is used to configure mycompany.simple.Other xns activity registration
func NewOtherOptions ¶
func NewOtherOptions() *OtherOptions
NewOtherOptions initializes a new OtherOptions value
func (*OtherOptions) WithErrorConverter ¶
func (opts *OtherOptions) WithErrorConverter(errorConverter func(error) error) *OtherOptions
WithErrorConverter overrides the default error converter applied to xns activity errors
func (*OtherOptions) WithFilter ¶
func (opts *OtherOptions) WithFilter(filter func(string) string) *OtherOptions
Filter is used to filter registered xns activities or customize their name
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) (*v1.OtherQueryResponse, error) }
OtherQueryQueryHandle provides a handle for a mycompany.simple.Other.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 returns a handle to the activity
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 mycompany.simple.Other.OtherSignal signal activity
func OtherSignalAsync ¶
func OtherSignalAsync(ctx workflow.Context, workflowID string, runID string, req *v1.OtherSignalRequest, opts ...*OtherSignalSignalOptions) (OtherSignalSignalHandle, error)
OtherSignalAsync executes a(n) mycompany.simple.Other.OtherSignal signal
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) (*v1.OtherUpdateResponse, error) // ID returns the update id ID() string }
OtherUpdateHandle provides a handle to a mycompany.simple.Other.OtherUpdate workflow update
func OtherUpdateAsync ¶
func OtherUpdateAsync(ctx workflow.Context, workflowID string, runID string, req *v1.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.UpdateWorkflowOptions }
OtherUpdateUpdateOptions are used to configure a(n) mycompany.simple.Other.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.UpdateWorkflowOptions) *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) (*v1.OtherWorkflowResponse, error) // ID returns the workflow id ID() string }
OtherWorkflowRun provides a handle to a mycompany.simple.Other.OtherWorkflow workflow execution
func OtherWorkflowAsync ¶
func OtherWorkflowAsync(ctx workflow.Context, req *v1.OtherWorkflowRequest, opts ...*OtherWorkflowWorkflowOptions) (OtherWorkflowRun, error)
OtherWorkflowAsync executes a(n) mycompany.simple.Other.OtherWorkflow workflow and returns a handle to the underlying activity
type OtherWorkflowWorkflowOptions ¶
type OtherWorkflowWorkflowOptions struct { ActivityOptions *workflow.ActivityOptions Detached bool HeartbeatInterval time.Duration ParentClosePolicy enumsv1.ParentClosePolicy StartWorkflowOptions *client.StartWorkflowOptions }
OtherWorkflowWorkflowOptions are used to configure a(n) mycompany.simple.Other.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) WithParentClosePolicy ¶ added in v1.13.1
func (opts *OtherWorkflowWorkflowOptions) WithParentClosePolicy(policy enumsv1.ParentClosePolicy) *OtherWorkflowWorkflowOptions
WithParentClosePolicy can be used to customize the cancellation propagation behavior
func (*OtherWorkflowWorkflowOptions) WithStartWorkflow ¶
func (opts *OtherWorkflowWorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *OtherWorkflowWorkflowOptions
WithStartWorkflowOptions can be used to customize the start workflow options
type SimpleOptions ¶
type SimpleOptions struct {
// contains filtered or unexported fields
}
SimpleOptions is used to configure mycompany.simple.Simple xns activity registration
func NewSimpleOptions ¶
func NewSimpleOptions() *SimpleOptions
NewSimpleOptions initializes a new SimpleOptions value
func (*SimpleOptions) WithErrorConverter ¶
func (opts *SimpleOptions) WithErrorConverter(errorConverter func(error) error) *SimpleOptions
WithErrorConverter overrides the default error converter applied to xns activity errors
func (*SimpleOptions) WithFilter ¶
func (opts *SimpleOptions) WithFilter(filter func(string) string) *SimpleOptions
Filter is used to filter registered xns activities or customize their name
type SomeDeprecatedQuery1QueryHandle ¶
type SomeDeprecatedQuery1QueryHandle 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) (*v1.SomeDeprecatedMessage, error) }
SomeDeprecatedQuery1QueryHandle provides a handle for a mycompany.simple.Deprecated.SomeDeprecatedQuery1 query activity
func SomeDeprecatedQuery1Async
deprecated
func SomeDeprecatedQuery1Async(ctx workflow.Context, workflowID string, runID string, req *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedQuery1QueryOptions) (SomeDeprecatedQuery1QueryHandle, error)
SomeDeprecatedQuery1Async executes a(n) mycompany.simple.Deprecated.SomeDeprecatedQuery1 query and returns a handle to the activity
Deprecated: Do not use.
type SomeDeprecatedQuery1QueryOptions ¶
type SomeDeprecatedQuery1QueryOptions struct { ActivityOptions *workflow.ActivityOptions HeartbeatInterval time.Duration }
SomeDeprecatedQuery1QueryOptions are used to configure a(n) mycompany.simple.Deprecated.SomeDeprecatedQuery1 query execution
func NewSomeDeprecatedQuery1QueryOptions ¶
func NewSomeDeprecatedQuery1QueryOptions() *SomeDeprecatedQuery1QueryOptions
NewSomeDeprecatedQuery1QueryOptions initializes a new SomeDeprecatedQuery1QueryOptions value
func (*SomeDeprecatedQuery1QueryOptions) WithActivityOptions ¶
func (opts *SomeDeprecatedQuery1QueryOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeDeprecatedQuery1QueryOptions
WithActivityOptions can be used to customize the activity options
func (*SomeDeprecatedQuery1QueryOptions) WithHeartbeatInterval ¶
func (opts *SomeDeprecatedQuery1QueryOptions) WithHeartbeatInterval(d time.Duration) *SomeDeprecatedQuery1QueryOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
type SomeDeprecatedQuery2QueryHandle ¶
type SomeDeprecatedQuery2QueryHandle 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) (*v1.SomeDeprecatedMessage, error) }
SomeDeprecatedQuery2QueryHandle provides a handle for a mycompany.simple.Deprecated.SomeDeprecatedQuery2 query activity
func SomeDeprecatedQuery2Async
deprecated
func SomeDeprecatedQuery2Async(ctx workflow.Context, workflowID string, runID string, req *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedQuery2QueryOptions) (SomeDeprecatedQuery2QueryHandle, error)
SomeDeprecatedQuery2Async executes a(n) mycompany.simple.Deprecated.SomeDeprecatedQuery2 query and returns a handle to the activity
Deprecated: Do not use.
type SomeDeprecatedQuery2QueryOptions ¶
type SomeDeprecatedQuery2QueryOptions struct { ActivityOptions *workflow.ActivityOptions HeartbeatInterval time.Duration }
SomeDeprecatedQuery2QueryOptions are used to configure a(n) mycompany.simple.Deprecated.SomeDeprecatedQuery2 query execution
func NewSomeDeprecatedQuery2QueryOptions ¶
func NewSomeDeprecatedQuery2QueryOptions() *SomeDeprecatedQuery2QueryOptions
NewSomeDeprecatedQuery2QueryOptions initializes a new SomeDeprecatedQuery2QueryOptions value
func (*SomeDeprecatedQuery2QueryOptions) WithActivityOptions ¶
func (opts *SomeDeprecatedQuery2QueryOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeDeprecatedQuery2QueryOptions
WithActivityOptions can be used to customize the activity options
func (*SomeDeprecatedQuery2QueryOptions) WithHeartbeatInterval ¶
func (opts *SomeDeprecatedQuery2QueryOptions) WithHeartbeatInterval(d time.Duration) *SomeDeprecatedQuery2QueryOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
type SomeDeprecatedSignal1SignalHandle ¶
type SomeDeprecatedSignal1SignalHandle 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 }
SomeDeprecatedSignal1SignalHandle provides a handle for a mycompany.simple.Deprecated.SomeDeprecatedSignal1 signal activity
func SomeDeprecatedSignal1Async
deprecated
func SomeDeprecatedSignal1Async(ctx workflow.Context, workflowID string, runID string, req *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedSignal1SignalOptions) (SomeDeprecatedSignal1SignalHandle, error)
SomeDeprecatedSignal1Async executes a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal1 signal
Deprecated: Do not use.
type SomeDeprecatedSignal1SignalOptions ¶
type SomeDeprecatedSignal1SignalOptions struct { ActivityOptions *workflow.ActivityOptions HeartbeatInterval time.Duration }
SomeDeprecatedSignal1SignalOptions are used to configure a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal1 signal execution
func NewSomeDeprecatedSignal1SignalOptions ¶
func NewSomeDeprecatedSignal1SignalOptions() *SomeDeprecatedSignal1SignalOptions
NewSomeDeprecatedSignal1SignalOptions initializes a new SomeDeprecatedSignal1SignalOptions value
func (*SomeDeprecatedSignal1SignalOptions) WithActivityOptions ¶
func (opts *SomeDeprecatedSignal1SignalOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeDeprecatedSignal1SignalOptions
WithActivityOptions can be used to customize the activity options
func (*SomeDeprecatedSignal1SignalOptions) WithHeartbeatInterval ¶
func (opts *SomeDeprecatedSignal1SignalOptions) WithHeartbeatInterval(d time.Duration) *SomeDeprecatedSignal1SignalOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
type SomeDeprecatedSignal2SignalHandle ¶
type SomeDeprecatedSignal2SignalHandle 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 }
SomeDeprecatedSignal2SignalHandle provides a handle for a mycompany.simple.Deprecated.SomeDeprecatedSignal2 signal activity
func SomeDeprecatedSignal2Async
deprecated
func SomeDeprecatedSignal2Async(ctx workflow.Context, workflowID string, runID string, req *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedSignal2SignalOptions) (SomeDeprecatedSignal2SignalHandle, error)
SomeDeprecatedSignal2Async executes a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal2 signal
Deprecated: Do not use.
type SomeDeprecatedSignal2SignalOptions ¶
type SomeDeprecatedSignal2SignalOptions struct { ActivityOptions *workflow.ActivityOptions HeartbeatInterval time.Duration }
SomeDeprecatedSignal2SignalOptions are used to configure a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal2 signal execution
func NewSomeDeprecatedSignal2SignalOptions ¶
func NewSomeDeprecatedSignal2SignalOptions() *SomeDeprecatedSignal2SignalOptions
NewSomeDeprecatedSignal2SignalOptions initializes a new SomeDeprecatedSignal2SignalOptions value
func (*SomeDeprecatedSignal2SignalOptions) WithActivityOptions ¶
func (opts *SomeDeprecatedSignal2SignalOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeDeprecatedSignal2SignalOptions
WithActivityOptions can be used to customize the activity options
func (*SomeDeprecatedSignal2SignalOptions) WithHeartbeatInterval ¶
func (opts *SomeDeprecatedSignal2SignalOptions) WithHeartbeatInterval(d time.Duration) *SomeDeprecatedSignal2SignalOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
type SomeDeprecatedUpdate1Handle ¶
type SomeDeprecatedUpdate1Handle 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) (*v1.SomeDeprecatedMessage, error) // ID returns the update id ID() string }
SomeDeprecatedUpdate1Handle provides a handle to a mycompany.simple.Deprecated.SomeDeprecatedUpdate1 workflow update
func SomeDeprecatedUpdate1Async
deprecated
func SomeDeprecatedUpdate1Async(ctx workflow.Context, workflowID string, runID string, req *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedUpdate1UpdateOptions) (SomeDeprecatedUpdate1Handle, error)
SomeDeprecatedUpdate1Async executes a(n) mycompany.simple.Deprecated.SomeDeprecatedUpdate1 update and blocks until error or response received
Deprecated: Do not use.
type SomeDeprecatedUpdate1UpdateOptions ¶
type SomeDeprecatedUpdate1UpdateOptions struct { ActivityOptions *workflow.ActivityOptions HeartbeatInterval time.Duration UpdateWorkflowOptions *client.UpdateWorkflowOptions }
SomeDeprecatedUpdate1UpdateOptions are used to configure a(n) mycompany.simple.Deprecated.SomeDeprecatedUpdate1 update execution
func NewSomeDeprecatedUpdate1UpdateOptions ¶
func NewSomeDeprecatedUpdate1UpdateOptions() *SomeDeprecatedUpdate1UpdateOptions
NewSomeDeprecatedUpdate1UpdateOptions initializes a new SomeDeprecatedUpdate1UpdateOptions value
func (*SomeDeprecatedUpdate1UpdateOptions) WithActivityOptions ¶
func (opts *SomeDeprecatedUpdate1UpdateOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeDeprecatedUpdate1UpdateOptions
WithActivityOptions can be used to customize the activity options
func (*SomeDeprecatedUpdate1UpdateOptions) WithHeartbeatInterval ¶
func (opts *SomeDeprecatedUpdate1UpdateOptions) WithHeartbeatInterval(d time.Duration) *SomeDeprecatedUpdate1UpdateOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
func (*SomeDeprecatedUpdate1UpdateOptions) WithUpdateWorkflowOptions ¶
func (opts *SomeDeprecatedUpdate1UpdateOptions) WithUpdateWorkflowOptions(uwo client.UpdateWorkflowOptions) *SomeDeprecatedUpdate1UpdateOptions
WithUpdateWorkflowOptions can be used to customize the update workflow options
type SomeDeprecatedUpdate2Handle ¶
type SomeDeprecatedUpdate2Handle 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) (*v1.SomeDeprecatedMessage, error) // ID returns the update id ID() string }
SomeDeprecatedUpdate2Handle provides a handle to a mycompany.simple.Deprecated.SomeDeprecatedUpdate2 workflow update
func SomeDeprecatedUpdate2Async
deprecated
func SomeDeprecatedUpdate2Async(ctx workflow.Context, workflowID string, runID string, req *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedUpdate2UpdateOptions) (SomeDeprecatedUpdate2Handle, error)
SomeDeprecatedUpdate2Async executes a(n) mycompany.simple.Deprecated.SomeDeprecatedUpdate2 update and blocks until error or response received
Deprecated: Do not use.
type SomeDeprecatedUpdate2UpdateOptions ¶
type SomeDeprecatedUpdate2UpdateOptions struct { ActivityOptions *workflow.ActivityOptions HeartbeatInterval time.Duration UpdateWorkflowOptions *client.UpdateWorkflowOptions }
SomeDeprecatedUpdate2UpdateOptions are used to configure a(n) mycompany.simple.Deprecated.SomeDeprecatedUpdate2 update execution
func NewSomeDeprecatedUpdate2UpdateOptions ¶
func NewSomeDeprecatedUpdate2UpdateOptions() *SomeDeprecatedUpdate2UpdateOptions
NewSomeDeprecatedUpdate2UpdateOptions initializes a new SomeDeprecatedUpdate2UpdateOptions value
func (*SomeDeprecatedUpdate2UpdateOptions) WithActivityOptions ¶
func (opts *SomeDeprecatedUpdate2UpdateOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeDeprecatedUpdate2UpdateOptions
WithActivityOptions can be used to customize the activity options
func (*SomeDeprecatedUpdate2UpdateOptions) WithHeartbeatInterval ¶
func (opts *SomeDeprecatedUpdate2UpdateOptions) WithHeartbeatInterval(d time.Duration) *SomeDeprecatedUpdate2UpdateOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
func (*SomeDeprecatedUpdate2UpdateOptions) WithUpdateWorkflowOptions ¶
func (opts *SomeDeprecatedUpdate2UpdateOptions) WithUpdateWorkflowOptions(uwo client.UpdateWorkflowOptions) *SomeDeprecatedUpdate2UpdateOptions
WithUpdateWorkflowOptions can be used to customize the update workflow options
type SomeDeprecatedWorkflow1Run ¶
type SomeDeprecatedWorkflow1Run 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) (*v1.SomeDeprecatedMessage, error) // ID returns the workflow id ID() string // SomeDeprecatedQuery1 does something else // // Deprecated: Do not use. SomeDeprecatedQuery1(workflow.Context, *v1.SomeDeprecatedMessage, ...*SomeDeprecatedQuery1QueryOptions) (*v1.SomeDeprecatedMessage, error) // SomeDeprecatedQuery1 does something else // // Deprecated: Do not use. SomeDeprecatedQuery1Async(workflow.Context, *v1.SomeDeprecatedMessage, ...*SomeDeprecatedQuery1QueryOptions) (SomeDeprecatedQuery1QueryHandle, error) // SomeDeprecatedSignal1 does something else // // Deprecated: Do not use. SomeDeprecatedSignal1(workflow.Context, *v1.SomeDeprecatedMessage, ...*SomeDeprecatedSignal1SignalOptions) error // SomeDeprecatedSignal1 does something else // // Deprecated: Do not use. SomeDeprecatedSignal1Async(workflow.Context, *v1.SomeDeprecatedMessage, ...*SomeDeprecatedSignal1SignalOptions) (SomeDeprecatedSignal1SignalHandle, error) // SomeDeprecatedUpdate1 does something else // // Deprecated: Do not use. SomeDeprecatedUpdate1(workflow.Context, *v1.SomeDeprecatedMessage, ...*SomeDeprecatedUpdate1UpdateOptions) (*v1.SomeDeprecatedMessage, error) // SomeDeprecatedUpdate1 does something else // // Deprecated: Do not use. SomeDeprecatedUpdate1Async(workflow.Context, *v1.SomeDeprecatedMessage, ...*SomeDeprecatedUpdate1UpdateOptions) (SomeDeprecatedUpdate1Handle, error) }
SomeDeprecatedWorkflow1Run provides a handle to a mycompany.simple.Deprecated.SomeDeprecatedWorkflow1 workflow execution
func SomeDeprecatedWorkflow1Async
deprecated
func SomeDeprecatedWorkflow1Async(ctx workflow.Context, req *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow1WorkflowOptions) (SomeDeprecatedWorkflow1Run, error)
SomeDeprecatedWorkflow1 does something
Deprecated: Do not use.
func SomeDeprecatedWorkflow1WithSomeDeprecatedSignal1Async
deprecated
func SomeDeprecatedWorkflow1WithSomeDeprecatedSignal1Async(ctx workflow.Context, req *v1.SomeDeprecatedMessage, signal *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow1WorkflowOptions) (SomeDeprecatedWorkflow1Run, error)
SomeDeprecatedWorkflow1WithSomeDeprecatedSignal1Async sends a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal1 signal to a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow1 workflow, starting it if necessary, and returns a handle to the underlying activity
Deprecated: Do not use.
type SomeDeprecatedWorkflow1WorkflowOptions ¶
type SomeDeprecatedWorkflow1WorkflowOptions struct { ActivityOptions *workflow.ActivityOptions Detached bool HeartbeatInterval time.Duration ParentClosePolicy enumsv1.ParentClosePolicy StartWorkflowOptions *client.StartWorkflowOptions }
SomeDeprecatedWorkflow1WorkflowOptions are used to configure a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow1 workflow execution
func NewSomeDeprecatedWorkflow1WorkflowOptions ¶
func NewSomeDeprecatedWorkflow1WorkflowOptions() *SomeDeprecatedWorkflow1WorkflowOptions
NewSomeDeprecatedWorkflow1WorkflowOptions initializes a new SomeDeprecatedWorkflow1WorkflowOptions value
func (*SomeDeprecatedWorkflow1WorkflowOptions) WithActivityOptions ¶
func (opts *SomeDeprecatedWorkflow1WorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeDeprecatedWorkflow1WorkflowOptions
WithActivityOptions can be used to customize the activity options
func (*SomeDeprecatedWorkflow1WorkflowOptions) WithDetached ¶
func (opts *SomeDeprecatedWorkflow1WorkflowOptions) WithDetached(d bool) *SomeDeprecatedWorkflow1WorkflowOptions
WithDetached can be used to start a workflow execution and exit immediately
func (*SomeDeprecatedWorkflow1WorkflowOptions) WithHeartbeatInterval ¶
func (opts *SomeDeprecatedWorkflow1WorkflowOptions) WithHeartbeatInterval(d time.Duration) *SomeDeprecatedWorkflow1WorkflowOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
func (*SomeDeprecatedWorkflow1WorkflowOptions) WithParentClosePolicy ¶ added in v1.13.1
func (opts *SomeDeprecatedWorkflow1WorkflowOptions) WithParentClosePolicy(policy enumsv1.ParentClosePolicy) *SomeDeprecatedWorkflow1WorkflowOptions
WithParentClosePolicy can be used to customize the cancellation propagation behavior
func (*SomeDeprecatedWorkflow1WorkflowOptions) WithStartWorkflow ¶
func (opts *SomeDeprecatedWorkflow1WorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *SomeDeprecatedWorkflow1WorkflowOptions
WithStartWorkflowOptions can be used to customize the start workflow options
type SomeDeprecatedWorkflow2Run ¶
type SomeDeprecatedWorkflow2Run 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) (*v1.SomeDeprecatedMessage, error) // ID returns the workflow id ID() string // SomeDeprecatedQuery2 does something else // // Deprecated: a custom query deprecation message. SomeDeprecatedQuery2(workflow.Context, *v1.SomeDeprecatedMessage, ...*SomeDeprecatedQuery2QueryOptions) (*v1.SomeDeprecatedMessage, error) // SomeDeprecatedQuery2 does something else // // Deprecated: a custom query deprecation message. SomeDeprecatedQuery2Async(workflow.Context, *v1.SomeDeprecatedMessage, ...*SomeDeprecatedQuery2QueryOptions) (SomeDeprecatedQuery2QueryHandle, error) // SomeDeprecatedSignal2 does something else // // Deprecated: a custom signal deprecation message. SomeDeprecatedSignal2(workflow.Context, *v1.SomeDeprecatedMessage, ...*SomeDeprecatedSignal2SignalOptions) error // SomeDeprecatedSignal2 does something else // // Deprecated: a custom signal deprecation message. SomeDeprecatedSignal2Async(workflow.Context, *v1.SomeDeprecatedMessage, ...*SomeDeprecatedSignal2SignalOptions) (SomeDeprecatedSignal2SignalHandle, error) // SomeDeprecatedUpdate2 does something else // // Deprecated: a custom signal deprecation message. SomeDeprecatedUpdate2(workflow.Context, *v1.SomeDeprecatedMessage, ...*SomeDeprecatedUpdate2UpdateOptions) (*v1.SomeDeprecatedMessage, error) // SomeDeprecatedUpdate2 does something else // // Deprecated: a custom signal deprecation message. SomeDeprecatedUpdate2Async(workflow.Context, *v1.SomeDeprecatedMessage, ...*SomeDeprecatedUpdate2UpdateOptions) (SomeDeprecatedUpdate2Handle, error) }
SomeDeprecatedWorkflow2Run provides a handle to a mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow execution
func SomeDeprecatedWorkflow2Async
deprecated
func SomeDeprecatedWorkflow2Async(ctx workflow.Context, req *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow2WorkflowOptions) (SomeDeprecatedWorkflow2Run, error)
SomeDeprecatedWorkflow2 does something else
Deprecated: a custom workflow deprecation message.
func SomeDeprecatedWorkflow2WithSomeDeprecatedSignal2Async
deprecated
func SomeDeprecatedWorkflow2WithSomeDeprecatedSignal2Async(ctx workflow.Context, req *v1.SomeDeprecatedMessage, signal *v1.SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow2WorkflowOptions) (SomeDeprecatedWorkflow2Run, error)
SomeDeprecatedWorkflow2WithSomeDeprecatedSignal2Async sends a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal2 signal to a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow, starting it if necessary, and returns a handle to the underlying activity
Deprecated: Do not use.
type SomeDeprecatedWorkflow2WorkflowOptions ¶
type SomeDeprecatedWorkflow2WorkflowOptions struct { ActivityOptions *workflow.ActivityOptions Detached bool HeartbeatInterval time.Duration ParentClosePolicy enumsv1.ParentClosePolicy StartWorkflowOptions *client.StartWorkflowOptions }
SomeDeprecatedWorkflow2WorkflowOptions are used to configure a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow execution
func NewSomeDeprecatedWorkflow2WorkflowOptions ¶
func NewSomeDeprecatedWorkflow2WorkflowOptions() *SomeDeprecatedWorkflow2WorkflowOptions
NewSomeDeprecatedWorkflow2WorkflowOptions initializes a new SomeDeprecatedWorkflow2WorkflowOptions value
func (*SomeDeprecatedWorkflow2WorkflowOptions) WithActivityOptions ¶
func (opts *SomeDeprecatedWorkflow2WorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeDeprecatedWorkflow2WorkflowOptions
WithActivityOptions can be used to customize the activity options
func (*SomeDeprecatedWorkflow2WorkflowOptions) WithDetached ¶
func (opts *SomeDeprecatedWorkflow2WorkflowOptions) WithDetached(d bool) *SomeDeprecatedWorkflow2WorkflowOptions
WithDetached can be used to start a workflow execution and exit immediately
func (*SomeDeprecatedWorkflow2WorkflowOptions) WithHeartbeatInterval ¶
func (opts *SomeDeprecatedWorkflow2WorkflowOptions) WithHeartbeatInterval(d time.Duration) *SomeDeprecatedWorkflow2WorkflowOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
func (*SomeDeprecatedWorkflow2WorkflowOptions) WithParentClosePolicy ¶ added in v1.13.1
func (opts *SomeDeprecatedWorkflow2WorkflowOptions) WithParentClosePolicy(policy enumsv1.ParentClosePolicy) *SomeDeprecatedWorkflow2WorkflowOptions
WithParentClosePolicy can be used to customize the cancellation propagation behavior
func (*SomeDeprecatedWorkflow2WorkflowOptions) WithStartWorkflow ¶
func (opts *SomeDeprecatedWorkflow2WorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *SomeDeprecatedWorkflow2WorkflowOptions
WithStartWorkflowOptions can be used to customize the start workflow options
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) (*v1.SomeQuery1Response, error) }
SomeQuery1QueryHandle provides a handle for a mycompany.simple.Simple.SomeQuery1 query activity
func SomeQuery1Async ¶
func SomeQuery1Async(ctx workflow.Context, workflowID string, runID string, opts ...*SomeQuery1QueryOptions) (SomeQuery1QueryHandle, error)
SomeQuery1Async executes a(n) mycompany.simple.Simple.SomeQuery1 query and returns a handle to the activity
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) (*v1.SomeQuery2Response, error) }
SomeQuery2QueryHandle provides a handle for a mycompany.simple.Simple.SomeQuery2 query activity
func SomeQuery2Async ¶
func SomeQuery2Async(ctx workflow.Context, workflowID string, runID string, req *v1.SomeQuery2Request, opts ...*SomeQuery2QueryOptions) (SomeQuery2QueryHandle, error)
SomeQuery2Async executes a(n) mycompany.simple.Simple.SomeQuery2 query and returns a handle to the activity
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 mycompany.simple.Simple.SomeSignal1 signal activity
func SomeSignal1Async ¶
func SomeSignal1Async(ctx workflow.Context, workflowID string, runID string, opts ...*SomeSignal1SignalOptions) (SomeSignal1SignalHandle, error)
SomeSignal1Async executes a(n) mycompany.simple.Simple.SomeSignal1 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 mycompany.simple.Simple.SomeSignal2 signal activity
func SomeSignal2Async ¶
func SomeSignal2Async(ctx workflow.Context, workflowID string, runID string, req *v1.SomeSignal2Request, opts ...*SomeSignal2SignalOptions) (SomeSignal2SignalHandle, error)
SomeSignal2Async executes a(n) mycompany.simple.Simple.SomeSignal2 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 mycompany.simple.Simple.SomeSignal3 signal activity
func SomeSignal3Async ¶
func SomeSignal3Async(ctx workflow.Context, workflowID string, runID string, req *v1.SomeSignal3Request, opts ...*SomeSignal3SignalOptions) (SomeSignal3SignalHandle, error)
SomeSignal3Async executes a(n) mycompany.simple.Simple.SomeSignal3 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) (*v1.SomeUpdate1Response, error) // ID returns the update id ID() string }
SomeUpdate1Handle provides a handle to a mycompany.simple.Simple.SomeUpdate1 workflow update
func SomeUpdate1Async ¶
func SomeUpdate1Async(ctx workflow.Context, workflowID string, runID string, req *v1.SomeUpdate1Request, opts ...*SomeUpdate1UpdateOptions) (SomeUpdate1Handle, error)
SomeUpdate1Async executes a(n) mycompany.simple.Simple.SomeUpdate1 update and blocks until error or response received
type SomeUpdate1UpdateOptions ¶
type SomeUpdate1UpdateOptions struct { ActivityOptions *workflow.ActivityOptions HeartbeatInterval time.Duration UpdateWorkflowOptions *client.UpdateWorkflowOptions }
SomeUpdate1UpdateOptions are used to configure a(n) mycompany.simple.Simple.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.UpdateWorkflowOptions) *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) (*v1.SomeWorkflow1Response, error) // ID returns the workflow id ID() string // SomeQuery1 queries some thing. SomeQuery1(workflow.Context, ...*SomeQuery1QueryOptions) (*v1.SomeQuery1Response, error) // SomeQuery1 queries some thing. SomeQuery1Async(workflow.Context, ...*SomeQuery1QueryOptions) (SomeQuery1QueryHandle, error) // SomeQuery2 queries some thing. SomeQuery2(workflow.Context, *v1.SomeQuery2Request, ...*SomeQuery2QueryOptions) (*v1.SomeQuery2Response, error) // SomeQuery2 queries some thing. SomeQuery2Async(workflow.Context, *v1.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, *v1.SomeSignal2Request, ...*SomeSignal2SignalOptions) error // SomeSignal2 is a signal. SomeSignal2Async(workflow.Context, *v1.SomeSignal2Request, ...*SomeSignal2SignalOptions) (SomeSignal2SignalHandle, error) }
SomeWorkflow1Run provides a handle to a mycompany.simple.SomeWorkflow1 workflow execution
func SomeWorkflow1Async ¶
func SomeWorkflow1Async(ctx workflow.Context, req *v1.SomeWorkflow1Request, opts ...*SomeWorkflow1WorkflowOptions) (SomeWorkflow1Run, error)
SomeWorkflow1 does some workflow thing.
type SomeWorkflow1WorkflowOptions ¶
type SomeWorkflow1WorkflowOptions struct { ActivityOptions *workflow.ActivityOptions Detached bool HeartbeatInterval time.Duration ParentClosePolicy enumsv1.ParentClosePolicy StartWorkflowOptions *client.StartWorkflowOptions }
SomeWorkflow1WorkflowOptions are used to configure a(n) mycompany.simple.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) WithParentClosePolicy ¶ added in v1.13.1
func (opts *SomeWorkflow1WorkflowOptions) WithParentClosePolicy(policy enumsv1.ParentClosePolicy) *SomeWorkflow1WorkflowOptions
WithParentClosePolicy can be used to customize the cancellation propagation behavior
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, *v1.SomeUpdate1Request, ...*SomeUpdate1UpdateOptions) (*v1.SomeUpdate1Response, error) // SomeUpdate1 updates a SomeWorkflow2 SomeUpdate1Async(workflow.Context, *v1.SomeUpdate1Request, ...*SomeUpdate1UpdateOptions) (SomeUpdate1Handle, error) }
SomeWorkflow2Run provides a handle to a mycompany.simple.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)
SomeWorkflow2WithSomeSignal1Async sends a(n) mycompany.simple.Simple.SomeSignal1 signal to a(n) mycompany.simple.SomeWorkflow2 workflow, starting it if necessary, and returns a handle to the underlying activity
type SomeWorkflow2WorkflowOptions ¶
type SomeWorkflow2WorkflowOptions struct { ActivityOptions *workflow.ActivityOptions Detached bool HeartbeatInterval time.Duration ParentClosePolicy enumsv1.ParentClosePolicy StartWorkflowOptions *client.StartWorkflowOptions }
SomeWorkflow2WorkflowOptions are used to configure a(n) mycompany.simple.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) WithParentClosePolicy ¶ added in v1.13.1
func (opts *SomeWorkflow2WorkflowOptions) WithParentClosePolicy(policy enumsv1.ParentClosePolicy) *SomeWorkflow2WorkflowOptions
WithParentClosePolicy can be used to customize the cancellation propagation behavior
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, *v1.SomeSignal2Request, ...*SomeSignal2SignalOptions) error // SomeSignal2 is a signal. SomeSignal2Async(workflow.Context, *v1.SomeSignal2Request, ...*SomeSignal2SignalOptions) (SomeSignal2SignalHandle, error) }
SomeWorkflow3Run provides a handle to a mycompany.simple.Simple.SomeWorkflow3 workflow execution
func SomeWorkflow3Async ¶
func SomeWorkflow3Async(ctx workflow.Context, req *v1.SomeWorkflow3Request, opts ...*SomeWorkflow3WorkflowOptions) (SomeWorkflow3Run, error)
SomeWorkflow3 does some workflow thing. Deprecated: Use SomeWorkflow2 instead.
func SomeWorkflow3WithSomeSignal2Async
deprecated
func SomeWorkflow3WithSomeSignal2Async(ctx workflow.Context, req *v1.SomeWorkflow3Request, signal *v1.SomeSignal2Request, opts ...*SomeWorkflow3WorkflowOptions) (SomeWorkflow3Run, error)
SomeWorkflow3WithSomeSignal2Async sends a(n) mycompany.simple.Simple.SomeSignal2 signal to a(n) mycompany.simple.Simple.SomeWorkflow3 workflow, starting it if necessary, and returns a handle to the underlying activity
Deprecated: Do not use.
type SomeWorkflow3WorkflowOptions ¶
type SomeWorkflow3WorkflowOptions struct { ActivityOptions *workflow.ActivityOptions Detached bool HeartbeatInterval time.Duration ParentClosePolicy enumsv1.ParentClosePolicy StartWorkflowOptions *client.StartWorkflowOptions }
SomeWorkflow3WorkflowOptions are used to configure a(n) mycompany.simple.Simple.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) WithParentClosePolicy ¶ added in v1.13.1
func (opts *SomeWorkflow3WorkflowOptions) WithParentClosePolicy(policy enumsv1.ParentClosePolicy) *SomeWorkflow3WorkflowOptions
WithParentClosePolicy can be used to customize the cancellation propagation behavior
func (*SomeWorkflow3WorkflowOptions) WithStartWorkflow ¶
func (opts *SomeWorkflow3WorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *SomeWorkflow3WorkflowOptions
WithStartWorkflowOptions can be used to customize the start workflow options
type SomeWorkflow4Run ¶ added in v1.13.2
type SomeWorkflow4Run 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) (*v11.PaginatedResponse, error) // ID returns the workflow id ID() string }
SomeWorkflow4Run provides a handle to a mycompany.simple.Simple.SomeWorkflow4 workflow execution
func SomeWorkflow4Async ¶ added in v1.13.2
func SomeWorkflow4Async(ctx workflow.Context, req *v11.PaginatedRequest, opts ...*SomeWorkflow4WorkflowOptions) (SomeWorkflow4Run, error)
SomeWorkflow4 retrieves a paginated list of items
type SomeWorkflow4WorkflowOptions ¶ added in v1.13.2
type SomeWorkflow4WorkflowOptions struct { ActivityOptions *workflow.ActivityOptions Detached bool HeartbeatInterval time.Duration ParentClosePolicy enumsv1.ParentClosePolicy StartWorkflowOptions *client.StartWorkflowOptions }
SomeWorkflow4WorkflowOptions are used to configure a(n) mycompany.simple.Simple.SomeWorkflow4 workflow execution
func NewSomeWorkflow4WorkflowOptions ¶ added in v1.13.2
func NewSomeWorkflow4WorkflowOptions() *SomeWorkflow4WorkflowOptions
NewSomeWorkflow4WorkflowOptions initializes a new SomeWorkflow4WorkflowOptions value
func (*SomeWorkflow4WorkflowOptions) WithActivityOptions ¶ added in v1.13.2
func (opts *SomeWorkflow4WorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *SomeWorkflow4WorkflowOptions
WithActivityOptions can be used to customize the activity options
func (*SomeWorkflow4WorkflowOptions) WithDetached ¶ added in v1.13.2
func (opts *SomeWorkflow4WorkflowOptions) WithDetached(d bool) *SomeWorkflow4WorkflowOptions
WithDetached can be used to start a workflow execution and exit immediately
func (*SomeWorkflow4WorkflowOptions) WithHeartbeatInterval ¶ added in v1.13.2
func (opts *SomeWorkflow4WorkflowOptions) WithHeartbeatInterval(d time.Duration) *SomeWorkflow4WorkflowOptions
WithHeartbeatInterval can be used to customize the activity heartbeat interval
func (*SomeWorkflow4WorkflowOptions) WithParentClosePolicy ¶ added in v1.13.2
func (opts *SomeWorkflow4WorkflowOptions) WithParentClosePolicy(policy enumsv1.ParentClosePolicy) *SomeWorkflow4WorkflowOptions
WithParentClosePolicy can be used to customize the cancellation propagation behavior
func (*SomeWorkflow4WorkflowOptions) WithStartWorkflow ¶ added in v1.13.2
func (opts *SomeWorkflow4WorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *SomeWorkflow4WorkflowOptions
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 mycompany.simple.Ignored.What workflow execution
func WhatAsync ¶
func WhatAsync(ctx workflow.Context, req *v1.WhatRequest, opts ...*WhatWorkflowOptions) (WhatRun, error)
WhatAsync executes a(n) mycompany.simple.Ignored.What workflow and returns a handle to the underlying activity
type WhatWorkflowOptions ¶
type WhatWorkflowOptions struct { ActivityOptions *workflow.ActivityOptions Detached bool HeartbeatInterval time.Duration ParentClosePolicy enumsv1.ParentClosePolicy StartWorkflowOptions *client.StartWorkflowOptions }
WhatWorkflowOptions are used to configure a(n) mycompany.simple.Ignored.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) WithParentClosePolicy ¶ added in v1.13.1
func (opts *WhatWorkflowOptions) WithParentClosePolicy(policy enumsv1.ParentClosePolicy) *WhatWorkflowOptions
WithParentClosePolicy can be used to customize the cancellation propagation behavior
func (*WhatWorkflowOptions) WithStartWorkflow ¶
func (opts *WhatWorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *WhatWorkflowOptions
WithStartWorkflowOptions can be used to customize the start workflow options