examplev1xns

package

Go to main page

Versions in this module

v1

v1.14.3

Aug 10, 2024

v1.14.2

Jul 1, 2024

v1.14.1

Jun 21, 2024

v1.14.0

Jun 20, 2024

v1.13.3

Jun 13, 2024

v1.13.2

May 31, 2024

v1.13.1

May 14, 2024

Changes in this version

type CreateFooWorkflowOptions

+ ParentClosePolicy v11.ParentClosePolicy

+ func (opts *CreateFooWorkflowOptions) WithParentClosePolicy(policy v11.ParentClosePolicy) *CreateFooWorkflowOptions

v1.13.0

May 3, 2024

v1.12.0

Apr 19, 2024

v1.11.0

Apr 12, 2024

v1.10.4

Apr 9, 2024

Changes in this version

type ExampleOptions

+ func NewExampleOptions() *ExampleOptions

+ func (opts *ExampleOptions) WithErrorConverter(errorConverter func(error) error) *ExampleOptions

+ func (opts *ExampleOptions) WithFilter(filter func(string) string) *ExampleOptions

v1.10.3

Apr 5, 2024

v1.10.2

Apr 4, 2024

v1.10.1

Mar 21, 2024

v1.10.0

Mar 20, 2024

v1.9.0

Mar 14, 2024

v1.8.2

Mar 2, 2024

v1.8.1

Jan 30, 2024

v1.8.0

Jan 16, 2024

v1.7.0

Jan 12, 2024

v1.6.0

Jan 2, 2024

v1.5.3

Dec 27, 2023

v1.5.2

Dec 27, 2023

Changes in this version

+ type ExampleOptions struct

+ Filter func(string) string

+ type ExternalOptions struct

+ Filter func(string) string

v1.5.1

Dec 27, 2023

v1.5.0

Dec 26, 2023

Changes in this version

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

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

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

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

+ func CreateFoo(ctx workflow.Context, req *v1.CreateFooInput, ...) (*v1.CreateFooResponse, error)

+ func CreateFooWithSetFooProgress(ctx workflow.Context, req *v1.CreateFooInput, signal *v1.SetFooProgressRequest, ...) (*v1.CreateFooResponse, error)

+ func GetFooProgress(ctx workflow.Context, workflowID string, runID string, ...) (*v1.GetFooProgressResponse, error)

+ func ProvisionFoo(ctx workflow.Context, req *v1.ProvisionFooInput, ...) (*v1.ProvisionFooResponse, error)

+ func RegisterExampleActivities(r worker.ActivityRegistry, c v1.ExampleClient)

+ func RegisterExternalActivities(r worker.ActivityRegistry, c v1.ExternalClient)

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

+ func UpdateFooProgress(ctx workflow.Context, workflowID string, runID string, ...) (*v1.GetFooProgressResponse, error)

+ type CreateFooRun interface

+ Cancel func(workflow.Context) error

+ Future func() workflow.Future

+ Get func(workflow.Context) (*v1.CreateFooResponse, error)

+ GetFooProgress func(workflow.Context, ...*GetFooProgressQueryOptions) (*v1.GetFooProgressResponse, error)

+ GetFooProgressAsync func(workflow.Context, ...*GetFooProgressQueryOptions) (GetFooProgressQueryHandle, error)

+ ID func() string

+ SetFooProgress func(workflow.Context, *v1.SetFooProgressRequest, ...*SetFooProgressSignalOptions) error

+ SetFooProgressAsync func(workflow.Context, *v1.SetFooProgressRequest, ...*SetFooProgressSignalOptions) (SetFooProgressSignalHandle, error)

+ UpdateFooProgress func(workflow.Context, *v1.SetFooProgressRequest, ...) (*v1.GetFooProgressResponse, error)

+ UpdateFooProgressAsync func(workflow.Context, *v1.SetFooProgressRequest, ...) (UpdateFooProgressHandle, error)

+ func CreateFooAsync(ctx workflow.Context, req *v1.CreateFooInput, ...) (CreateFooRun, error)

+ func CreateFooWithSetFooProgressAsync(ctx workflow.Context, req *v1.CreateFooInput, signal *v1.SetFooProgressRequest, ...) (CreateFooRun, error)

+ type CreateFooWorkflowOptions struct

+ ActivityOptions *workflow.ActivityOptions

+ Detached bool

+ HeartbeatInterval time.Duration

+ StartWorkflowOptions *client.StartWorkflowOptions

+ func NewCreateFooWorkflowOptions() *CreateFooWorkflowOptions

+ func (opts *CreateFooWorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *CreateFooWorkflowOptions

+ func (opts *CreateFooWorkflowOptions) WithDetached(d bool) *CreateFooWorkflowOptions

+ func (opts *CreateFooWorkflowOptions) WithHeartbeatInterval(d time.Duration) *CreateFooWorkflowOptions

+ func (opts *CreateFooWorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *CreateFooWorkflowOptions

+ type GetFooProgressQueryHandle interface

+ Cancel func(workflow.Context) error

+ Future func() workflow.Future

+ Get func(workflow.Context) (*v1.GetFooProgressResponse, error)

+ func GetFooProgressAsync(ctx workflow.Context, workflowID string, runID string, ...) (GetFooProgressQueryHandle, error)

+ type GetFooProgressQueryOptions struct

+ ActivityOptions *workflow.ActivityOptions

+ HeartbeatInterval time.Duration

+ func NewGetFooProgressQueryOptions() *GetFooProgressQueryOptions

+ func (opts *GetFooProgressQueryOptions) WithActivityOptions(ao workflow.ActivityOptions) *GetFooProgressQueryOptions

+ func (opts *GetFooProgressQueryOptions) WithHeartbeatInterval(d time.Duration) *GetFooProgressQueryOptions

+ type ProvisionFooRun interface

+ Cancel func(workflow.Context) error

+ Future func() workflow.Future

+ Get func(workflow.Context) (*v1.ProvisionFooResponse, error)

+ ID func() string

+ func ProvisionFooAsync(ctx workflow.Context, req *v1.ProvisionFooInput, ...) (ProvisionFooRun, error)

+ type ProvisionFooWorkflowOptions struct

+ ActivityOptions *workflow.ActivityOptions

+ Detached bool

+ HeartbeatInterval time.Duration

+ StartWorkflowOptions *client.StartWorkflowOptions

+ func NewProvisionFooWorkflowOptions() *ProvisionFooWorkflowOptions

+ func (opts *ProvisionFooWorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *ProvisionFooWorkflowOptions

+ func (opts *ProvisionFooWorkflowOptions) WithDetached(d bool) *ProvisionFooWorkflowOptions

+ func (opts *ProvisionFooWorkflowOptions) WithHeartbeatInterval(d time.Duration) *ProvisionFooWorkflowOptions

+ func (opts *ProvisionFooWorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *ProvisionFooWorkflowOptions

+ type SetFooProgressSignalHandle interface

+ Cancel func(workflow.Context) error

+ Future func() workflow.Future

+ Get func(workflow.Context) error

+ func SetFooProgressAsync(ctx workflow.Context, workflowID string, runID string, ...) (SetFooProgressSignalHandle, error)

+ type SetFooProgressSignalOptions struct

+ ActivityOptions *workflow.ActivityOptions

+ HeartbeatInterval time.Duration

+ func NewSetFooProgressSignalOptions() *SetFooProgressSignalOptions

+ func (opts *SetFooProgressSignalOptions) WithActivityOptions(ao workflow.ActivityOptions) *SetFooProgressSignalOptions

+ func (opts *SetFooProgressSignalOptions) WithHeartbeatInterval(d time.Duration) *SetFooProgressSignalOptions

+ type UpdateFooProgressHandle interface

+ Cancel func(workflow.Context) error

+ Future func() workflow.Future

+ Get func(workflow.Context) (*v1.GetFooProgressResponse, error)

+ ID func() string

+ func UpdateFooProgressAsync(ctx workflow.Context, workflowID string, runID string, ...) (UpdateFooProgressHandle, error)

+ type UpdateFooProgressUpdateOptions struct

+ ActivityOptions *workflow.ActivityOptions

+ HeartbeatInterval time.Duration

+ UpdateWorkflowOptions *client.UpdateWorkflowWithOptionsRequest

+ func NewUpdateFooProgressUpdateOptions() *UpdateFooProgressUpdateOptions

+ func (opts *UpdateFooProgressUpdateOptions) WithActivityOptions(ao workflow.ActivityOptions) *UpdateFooProgressUpdateOptions

+ func (opts *UpdateFooProgressUpdateOptions) WithHeartbeatInterval(d time.Duration) *UpdateFooProgressUpdateOptions

+ func (opts *UpdateFooProgressUpdateOptions) WithUpdateWorkflowOptions(uwo client.UpdateWorkflowWithOptionsRequest) *UpdateFooProgressUpdateOptions

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL