examplev1

May 3, 2024

Changes in this version

type CreateFooChildOptions

+ func (o *CreateFooChildOptions) Build(ctx workflow.Context, req protoreflect.Message) (workflow.ChildWorkflowOptions, error)

+ func (o *CreateFooChildOptions) WithExecutionTimeout(d time.Duration) *CreateFooChildOptions

+ func (o *CreateFooChildOptions) WithID(id string) *CreateFooChildOptions

+ func (o *CreateFooChildOptions) WithIDReusePolicy(policy v1.WorkflowIdReusePolicy) *CreateFooChildOptions

+ func (o *CreateFooChildOptions) WithParentClosePolicy(policy v1.ParentClosePolicy) *CreateFooChildOptions

+ func (o *CreateFooChildOptions) WithRetryPolicy(policy *temporal.RetryPolicy) *CreateFooChildOptions

+ func (o *CreateFooChildOptions) WithRunTimeout(d time.Duration) *CreateFooChildOptions

+ func (o *CreateFooChildOptions) WithSearchAttributes(sa map[string]any) *CreateFooChildOptions

+ func (o *CreateFooChildOptions) WithTaskQueue(tq string) *CreateFooChildOptions

+ func (o *CreateFooChildOptions) WithTaskTimeout(d time.Duration) *CreateFooChildOptions

+ func (o *CreateFooChildOptions) WithWaitForCancellation(wait bool) *CreateFooChildOptions

type CreateFooOptions

+ func (o *CreateFooOptions) Build(req protoreflect.Message) (client.StartWorkflowOptions, error)

+ func (o *CreateFooOptions) WithExecutionTimeout(d time.Duration) *CreateFooOptions

+ func (o *CreateFooOptions) WithID(id string) *CreateFooOptions

+ func (o *CreateFooOptions) WithIDReusePolicy(policy v1.WorkflowIdReusePolicy) *CreateFooOptions

+ func (o *CreateFooOptions) WithRetryPolicy(policy *temporal.RetryPolicy) *CreateFooOptions

+ func (o *CreateFooOptions) WithRunTimeout(d time.Duration) *CreateFooOptions

+ func (o *CreateFooOptions) WithSearchAttributes(sa map[string]any) *CreateFooOptions

+ func (o *CreateFooOptions) WithTaskQueue(tq string) *CreateFooOptions

+ func (o *CreateFooOptions) WithTaskTimeout(d time.Duration) *CreateFooOptions

type NotifyActivityOptions

+ func (o *NotifyActivityOptions) Build(ctx workflow.Context) (workflow.Context, error)

+ func (o *NotifyActivityOptions) WithHeartbeatTimeout(d time.Duration) *NotifyActivityOptions

+ func (o *NotifyActivityOptions) WithRetryPolicy(policy *temporal.RetryPolicy) *NotifyActivityOptions

+ func (o *NotifyActivityOptions) WithScheduleToCloseTimeout(d time.Duration) *NotifyActivityOptions

+ func (o *NotifyActivityOptions) WithScheduleToStartTimeout(d time.Duration) *NotifyActivityOptions

+ func (o *NotifyActivityOptions) WithStartToCloseTimeout(d time.Duration) *NotifyActivityOptions

+ func (o *NotifyActivityOptions) WithTaskQueue(tq string) *NotifyActivityOptions

+ func (o *NotifyActivityOptions) WithWaitForCancellation(wait bool) *NotifyActivityOptions

type NotifyLocalActivityOptions

+ func (o *NotifyLocalActivityOptions) Build(ctx workflow.Context) (workflow.Context, error)

+ func (o *NotifyLocalActivityOptions) WithRetryPolicy(policy *temporal.RetryPolicy) *NotifyLocalActivityOptions

+ func (o *NotifyLocalActivityOptions) WithScheduleToCloseTimeout(d time.Duration) *NotifyLocalActivityOptions

+ func (o *NotifyLocalActivityOptions) WithStartToCloseTimeout(d time.Duration) *NotifyLocalActivityOptions

type UpdateFooProgressOptions

+ func (o *UpdateFooProgressOptions) Build(workflowID string, runID string, req *SetFooProgressRequest) (opts *client.UpdateWorkflowWithOptionsRequest, err error)

+ func (o *UpdateFooProgressOptions) WithUpdateID(id string) *UpdateFooProgressOptions

+ func (o *UpdateFooProgressOptions) WithWaitPolicy(policy v1.UpdateWorkflowExecutionLifecycleStage) *UpdateFooProgressOptions

Apr 19, 2024

Changes in this version

+ type ExampleWorkflowFunctions interface

+ CreateFoo func(workflow.Context, *CreateFooRequest) (*CreateFooResponse, error)

+ func NewExampleWorkflowFunctions() ExampleWorkflowFunctions

Apr 4, 2024

Changes in this version

type SetFooProgressSignal

+ func NewSetFooProgressSignal(ctx workflow.Context) *SetFooProgressSignal

type UpdateFooProgressOptions

+ Options *client.UpdateWorkflowWithOptionsRequest

Mar 14, 2024

Changes in this version

+ func NewExampleClientOptions() *exampleClientOptions

+ func NewExternalClientOptions() *externalClientOptions

Jan 12, 2024

Changes in this version

+ func WithExampleSchemeTypes() scheme.Option

+ func WithExternalSchemeTypes() scheme.Option

Jan 2, 2024

Changes in this version

type SetFooProgressSignal

+ func (s *SetFooProgressSignal) ReceiveWithTimeout(ctx workflow.Context, timeout time.Duration) (resp *SetFooProgressRequest, ok bool, more bool)

Dec 26, 2023

Changes in this version

+ const ExternalTaskQueue

+ const ProvisionFooWorkflowName

+ var ProvisionFooFunction func(workflow.Context, *ProvisionFooInput) (*ProvisionFooResponse, error)

+ var ProvisionFooIdexpression = expression.MustParseExpression("provision-foo/${! name.slug() }")

+ func NewExternalCli(options ...*ExternalCliOptions) (*v2.App, error)

+ func NewExternalCliCommand(options ...*ExternalCliOptions) (*v2.Command, error)

+ func RegisterExternalActivities(r worker.ActivityRegistry, activities ExternalActivities)

+ func RegisterExternalWorkflows(r worker.WorkflowRegistry, workflows ExternalWorkflows)

+ func RegisterProvisionFooWorkflow(r worker.WorkflowRegistry, ...)

type ExampleClient

+ GetUpdateFooProgress func(ctx context.Context, req client.GetWorkflowUpdateHandleOptions) (UpdateFooProgressHandle, error)

+ type ExternalActivities interface

+ type ExternalCliOptions struct

+ func NewExternalCliOptions() *ExternalCliOptions

+ func (opts *ExternalCliOptions) WithAfter(fn func(*v2.Context) error) *ExternalCliOptions

+ func (opts *ExternalCliOptions) WithBefore(fn func(*v2.Context) error) *ExternalCliOptions

+ func (opts *ExternalCliOptions) WithClient(fn func(*v2.Context) (client.Client, error)) *ExternalCliOptions

+ func (opts *ExternalCliOptions) WithWorker(fn func(*v2.Context, client.Client) (worker.Worker, error)) *ExternalCliOptions

+ type ExternalClient interface

+ CancelWorkflow func(ctx context.Context, workflowID string, runID string) error

+ GetProvisionFoo func(ctx context.Context, workflowID string, runID string) ProvisionFooRun

+ ProvisionFoo func(ctx context.Context, req *ProvisionFooInput, opts ...*ProvisionFooOptions) (*ProvisionFooResponse, error)

+ ProvisionFooAsync func(ctx context.Context, req *ProvisionFooInput, opts ...*ProvisionFooOptions) (ProvisionFooRun, error)

+ TerminateWorkflow func(ctx context.Context, workflowID string, runID string, reason string, ...) error

+ func NewExternalClient(c client.Client) ExternalClient

+ func NewExternalClientWithOptions(c client.Client, opts client.Options) (ExternalClient, error)

+ type ExternalWorkflows interface

+ ProvisionFoo func(ctx workflow.Context, input *ProvisionFooWorkflowInput) (ProvisionFooWorkflow, error)

+ type ProvisionFooChildOptions struct

+ func NewProvisionFooChildOptions() *ProvisionFooChildOptions

+ func (opts *ProvisionFooChildOptions) WithChildWorkflowOptions(options workflow.ChildWorkflowOptions) *ProvisionFooChildOptions

+ type ProvisionFooChildRun struct

+ Future workflow.ChildWorkflowFuture

+ func ProvisionFooChildAsync(ctx workflow.Context, req *ProvisionFooInput, ...) (*ProvisionFooChildRun, error)

+ func (r *ProvisionFooChildRun) Get(ctx workflow.Context) (*ProvisionFooResponse, error)

+ func (r *ProvisionFooChildRun) Select(sel workflow.Selector, fn func(*ProvisionFooChildRun)) workflow.Selector

+ func (r *ProvisionFooChildRun) SelectStart(sel workflow.Selector, fn func(*ProvisionFooChildRun)) workflow.Selector

+ func (r *ProvisionFooChildRun) WaitStart(ctx workflow.Context) (*workflow.Execution, error)

+ type ProvisionFooInput struct

+ RequestName string

+ func UnmarshalCliFlagsToProvisionFooInput(cmd *v2.Context) (*ProvisionFooInput, error)

+ func (*ProvisionFooInput) Descriptor() ([]byte, []int)

+ func (*ProvisionFooInput) ProtoMessage()

+ func (x *ProvisionFooInput) GetRequestName() string

+ func (x *ProvisionFooInput) ProtoReflect() protoreflect.Message

+ func (x *ProvisionFooInput) Reset()

+ func (x *ProvisionFooInput) String() string

+ type ProvisionFooOptions struct

+ func NewProvisionFooOptions() *ProvisionFooOptions

+ func (opts *ProvisionFooOptions) WithStartWorkflowOptions(options client.StartWorkflowOptions) *ProvisionFooOptions

+ type ProvisionFooResponse struct

+ Foo *Foo

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

+ func (*ProvisionFooResponse) Descriptor() ([]byte, []int)

+ func (*ProvisionFooResponse) ProtoMessage()

+ func (x *ProvisionFooResponse) GetFoo() *Foo

+ func (x *ProvisionFooResponse) ProtoReflect() protoreflect.Message

+ func (x *ProvisionFooResponse) Reset()

+ func (x *ProvisionFooResponse) String() string

+ type ProvisionFooRun interface

+ Cancel func(ctx context.Context) error

+ Get func(ctx context.Context) (*ProvisionFooResponse, error)

+ ID func() string

+ Run func() client.WorkflowRun

+ RunID func() string

+ Terminate func(ctx context.Context, reason string, details ...interface{}) error

+ type ProvisionFooWorkflow interface

+ Execute func(ctx workflow.Context) (*ProvisionFooResponse, error)

+ type ProvisionFooWorkflowInput struct

+ Req *ProvisionFooInput

type TestExampleClient

+ func (c *TestExampleClient) GetUpdateFooProgress(ctx context.Context, req client.GetWorkflowUpdateHandleOptions) (UpdateFooProgressHandle, error)

+ type TestExternalClient struct

+ func NewTestExternalClient(env *testsuite.TestWorkflowEnvironment, workflows ExternalWorkflows, ...) *TestExternalClient

+ func (c *TestExternalClient) CancelWorkflow(ctx context.Context, workflowID string, runID string) error

+ func (c *TestExternalClient) GetProvisionFoo(ctx context.Context, workflowID string, runID string) ProvisionFooRun

+ func (c *TestExternalClient) ProvisionFoo(ctx context.Context, req *ProvisionFooInput, opts ...*ProvisionFooOptions) (*ProvisionFooResponse, error)

+ func (c *TestExternalClient) ProvisionFooAsync(ctx context.Context, req *ProvisionFooInput, options ...*ProvisionFooOptions) (ProvisionFooRun, error)

+ func (c *TestExternalClient) TerminateWorkflow(ctx context.Context, workflowID string, runID string, reason string, ...) error

Dec 21, 2023

Changes in this version

type CreateFooRun

+ Run func() client.WorkflowRun

Dec 20, 2023

Changes in this version

type CreateFooInput

+ RequestName string

+ func UnmarshalCliFlagsToCreateFooInput(cmd *v2.Context) (*CreateFooInput, error)

+ func (*CreateFooInput) Descriptor() ([]byte, []int)

+ func (*CreateFooInput) ProtoMessage()

+ func (x *CreateFooInput) GetRequestName() string

+ func (x *CreateFooInput) ProtoReflect() protoreflect.Message

+ func (x *CreateFooInput) Reset()

+ func (x *CreateFooInput) String() string

+ type CreateFooWorkflowInput struct

+ Req *CreateFooInput

+ SetFooProgress *SetFooProgressSignal

Nov 26, 2023

Changes in this version

+ var CreateFooIdexpression = expression.MustParseExpression("create-foo/${!name.slug()}")

+ var UpdateFooProgressIdexpression = expression.MustParseExpression("update-progress/${! progress.string() }")

type CreateFooRequest

+ func UnmarshalCliFlagsToCreateFooRequest(cmd *v2.Context) (*CreateFooRequest, error)

type SetFooProgressRequest

+ func UnmarshalCliFlagsToSetFooProgressRequest(cmd *v2.Context) (*SetFooProgressRequest, error)

Oct 22, 2023

Changes in this version

+ var CreateFooSearchAttributesMapping = expression.MustParseMapping("foo = name\ncreated_at = now().ts_tz(\"UTC\")\n")

Sep 13, 2023

Changes in this version

+ const CreateFooWorkflowName

+ const ExampleTaskQueue

+ const GetFooProgressQueryName

+ const NotifyActivityName

+ const SetFooProgressSignalName

+ const UpdateFooProgressUpdateName

+ var CreateFooFunction func(workflow.Context, *CreateFooRequest) (*CreateFooResponse, error)

+ var CreateFooIDExpression = expression.MustParseExpression("create-foo/${!name.slug()}")

+ var File_example_v1_example_proto protoreflect.FileDescriptor

+ var Foo_Status_name = map[int32]string

+ var Foo_Status_value = map[string]int32

+ var UpdateFooProgressIDExpression = expression.MustParseExpression("update-progress/${! progress.string() }")

+ func NewExampleCli(options ...*ExampleCliOptions) (*v2.App, error)

+ func NewExampleCliCommand(options ...*ExampleCliOptions) (*v2.Command, error)

+ func Notify(ctx workflow.Context, req *NotifyRequest, options ...*NotifyActivityOptions) error

+ func NotifyLocal(ctx workflow.Context, req *NotifyRequest, ...) error

+ func RegisterCreateFooWorkflow(r worker.WorkflowRegistry, ...)

+ func RegisterExampleActivities(r worker.ActivityRegistry, activities ExampleActivities)

+ func RegisterExampleWorkflows(r worker.WorkflowRegistry, workflows ExampleWorkflows)

+ func RegisterNotifyActivity(r worker.ActivityRegistry, fn func(context.Context, *NotifyRequest) error)

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

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

+ type CreateFooChildOptions struct

+ func NewCreateFooChildOptions() *CreateFooChildOptions

+ func (opts *CreateFooChildOptions) WithChildWorkflowOptions(options workflow.ChildWorkflowOptions) *CreateFooChildOptions

+ type CreateFooChildRun struct

+ Future workflow.ChildWorkflowFuture

+ func CreateFooChildAsync(ctx workflow.Context, req *CreateFooRequest, options ...*CreateFooChildOptions) (*CreateFooChildRun, error)

+ func (r *CreateFooChildRun) Get(ctx workflow.Context) (*CreateFooResponse, error)

+ func (r *CreateFooChildRun) Select(sel workflow.Selector, fn func(CreateFooChildRun)) workflow.Selector

+ func (r *CreateFooChildRun) SelectStart(sel workflow.Selector, fn func(CreateFooChildRun)) workflow.Selector

+ func (r *CreateFooChildRun) SetFooProgress(ctx workflow.Context, input *SetFooProgressRequest) error

+ func (r *CreateFooChildRun) SetFooProgressAsync(ctx workflow.Context, input *SetFooProgressRequest) workflow.Future

+ func (r *CreateFooChildRun) WaitStart(ctx workflow.Context) (*workflow.Execution, error)

+ type CreateFooInput struct

+ Req *CreateFooRequest

+ SetFooProgress *SetFooProgressSignal

+ type CreateFooOptions struct

+ func NewCreateFooOptions() *CreateFooOptions

+ func (opts *CreateFooOptions) WithStartWorkflowOptions(options client.StartWorkflowOptions) *CreateFooOptions

+ type CreateFooRequest struct

+ Name string

+ func (*CreateFooRequest) Descriptor() ([]byte, []int)

+ func (*CreateFooRequest) ProtoMessage()

+ func (x *CreateFooRequest) GetName() string

+ func (x *CreateFooRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateFooRequest) Reset()

+ func (x *CreateFooRequest) String() string

+ type CreateFooResponse struct

+ Foo *Foo

+ func CreateFooChild(ctx workflow.Context, req *CreateFooRequest, options ...*CreateFooChildOptions) (*CreateFooResponse, error)

+ func (*CreateFooResponse) Descriptor() ([]byte, []int)

+ func (*CreateFooResponse) ProtoMessage()

+ func (x *CreateFooResponse) GetFoo() *Foo

+ func (x *CreateFooResponse) ProtoReflect() protoreflect.Message

+ func (x *CreateFooResponse) Reset()

+ func (x *CreateFooResponse) String() string

+ type CreateFooRun interface

+ Cancel func(ctx context.Context) error

+ Get func(ctx context.Context) (*CreateFooResponse, error)

+ GetFooProgress func(ctx context.Context) (*GetFooProgressResponse, error)

+ ID func() string

+ RunID func() string

+ SetFooProgress func(ctx context.Context, req *SetFooProgressRequest) error

+ Terminate func(ctx context.Context, reason string, details ...interface{}) error

+ UpdateFooProgress func(ctx context.Context, req *SetFooProgressRequest, ...) (*GetFooProgressResponse, error)

+ UpdateFooProgressAsync func(ctx context.Context, req *SetFooProgressRequest, ...) (UpdateFooProgressHandle, error)

+ type CreateFooWorkflow interface

+ Execute func(ctx workflow.Context) (*CreateFooResponse, error)

+ GetFooProgress func() (*GetFooProgressResponse, error)

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

+ type ExampleActivities interface

+ Notify func(ctx context.Context, req *NotifyRequest) error

+ type ExampleCliOptions struct

+ func NewExampleCliOptions() *ExampleCliOptions

+ func (opts *ExampleCliOptions) WithAfter(fn func(*v2.Context) error) *ExampleCliOptions

+ func (opts *ExampleCliOptions) WithBefore(fn func(*v2.Context) error) *ExampleCliOptions

+ func (opts *ExampleCliOptions) WithClient(fn func(*v2.Context) (client.Client, error)) *ExampleCliOptions

+ func (opts *ExampleCliOptions) WithWorker(fn func(*v2.Context, client.Client) (worker.Worker, error)) *ExampleCliOptions

+ type ExampleClient interface

+ CancelWorkflow func(ctx context.Context, workflowID string, runID string) error

+ CreateFoo func(ctx context.Context, req *CreateFooRequest, opts ...*CreateFooOptions) (*CreateFooResponse, error)

+ CreateFooAsync func(ctx context.Context, req *CreateFooRequest, opts ...*CreateFooOptions) (CreateFooRun, error)

+ CreateFooWithSetFooProgress func(ctx context.Context, req *CreateFooRequest, signal *SetFooProgressRequest, ...) (*CreateFooResponse, error)

+ CreateFooWithSetFooProgressAsync func(ctx context.Context, req *CreateFooRequest, signal *SetFooProgressRequest, ...) (CreateFooRun, error)

+ GetCreateFoo func(ctx context.Context, workflowID string, runID string) CreateFooRun

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

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

+ TerminateWorkflow func(ctx context.Context, workflowID string, runID string, reason string, ...) error

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

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

+ func NewExampleClient(c client.Client) ExampleClient

+ func NewExampleClientWithOptions(c client.Client, opts client.Options) (ExampleClient, error)

+ type ExampleWorkflows interface

+ CreateFoo func(ctx workflow.Context, input *CreateFooInput) (CreateFooWorkflow, error)

+ type Foo struct

+ Name string

+ Status Foo_Status

+ func (*Foo) Descriptor() ([]byte, []int)

+ func (*Foo) ProtoMessage()

+ func (x *Foo) GetName() string

+ func (x *Foo) GetStatus() Foo_Status

+ func (x *Foo) ProtoReflect() protoreflect.Message

+ func (x *Foo) Reset()

+ func (x *Foo) String() string

+ type Foo_Status int32

+ const Foo_FOO_STATUS_CREATING

+ const Foo_FOO_STATUS_READY

+ const Foo_FOO_STATUS_UNSPECIFIED

+ func (Foo_Status) Descriptor() protoreflect.EnumDescriptor

+ func (Foo_Status) EnumDescriptor() ([]byte, []int)

+ func (Foo_Status) Type() protoreflect.EnumType

+ func (x Foo_Status) Enum() *Foo_Status

+ func (x Foo_Status) Number() protoreflect.EnumNumber

+ func (x Foo_Status) String() string

+ type GetFooProgressResponse struct

+ Progress float32

+ Status Foo_Status

+ func (*GetFooProgressResponse) Descriptor() ([]byte, []int)

+ func (*GetFooProgressResponse) ProtoMessage()

+ func (x *GetFooProgressResponse) GetProgress() float32

+ func (x *GetFooProgressResponse) GetStatus() Foo_Status

+ func (x *GetFooProgressResponse) ProtoReflect() protoreflect.Message

+ func (x *GetFooProgressResponse) Reset()

+ func (x *GetFooProgressResponse) String() string

+ type NotifyActivityOptions struct

+ func NewNotifyActivityOptions() *NotifyActivityOptions

+ func (opts *NotifyActivityOptions) WithActivityOptions(options workflow.ActivityOptions) *NotifyActivityOptions

+ type NotifyFuture struct

+ Future workflow.Future

+ func NotifyAsync(ctx workflow.Context, req *NotifyRequest, options ...*NotifyActivityOptions) *NotifyFuture

+ func NotifyLocalAsync(ctx workflow.Context, req *NotifyRequest, ...) *NotifyFuture

+ func (f *NotifyFuture) Get(ctx workflow.Context) error

+ func (f *NotifyFuture) Select(sel workflow.Selector, fn func(*NotifyFuture)) workflow.Selector

+ type NotifyLocalActivityOptions struct

+ func NewNotifyLocalActivityOptions() *NotifyLocalActivityOptions

+ func (opts *NotifyLocalActivityOptions) Local(fn func(context.Context, *NotifyRequest) error) *NotifyLocalActivityOptions

+ func (opts *NotifyLocalActivityOptions) WithLocalActivityOptions(options workflow.LocalActivityOptions) *NotifyLocalActivityOptions

+ type NotifyRequest struct

+ Message string

+ func (*NotifyRequest) Descriptor() ([]byte, []int)

+ func (*NotifyRequest) ProtoMessage()

+ func (x *NotifyRequest) GetMessage() string

+ func (x *NotifyRequest) ProtoReflect() protoreflect.Message

+ func (x *NotifyRequest) Reset()

+ func (x *NotifyRequest) String() string

+ type SetFooProgressRequest struct

+ Progress float32

+ func (*SetFooProgressRequest) Descriptor() ([]byte, []int)

+ func (*SetFooProgressRequest) ProtoMessage()

+ func (x *SetFooProgressRequest) GetProgress() float32

+ func (x *SetFooProgressRequest) ProtoReflect() protoreflect.Message

+ func (x *SetFooProgressRequest) Reset()

+ func (x *SetFooProgressRequest) String() string

+ type SetFooProgressSignal struct

+ Channel workflow.ReceiveChannel

+ func (s *SetFooProgressSignal) Receive(ctx workflow.Context) (*SetFooProgressRequest, bool)

+ func (s *SetFooProgressSignal) ReceiveAsync() *SetFooProgressRequest

+ func (s *SetFooProgressSignal) Select(sel workflow.Selector, fn func(*SetFooProgressRequest)) workflow.Selector

+ type TestExampleClient struct

+ func NewTestExampleClient(env *testsuite.TestWorkflowEnvironment, workflows ExampleWorkflows, ...) *TestExampleClient

+ func (c *TestExampleClient) CancelWorkflow(ctx context.Context, workflowID string, runID string) error

+ func (c *TestExampleClient) CreateFoo(ctx context.Context, req *CreateFooRequest, opts ...*CreateFooOptions) (*CreateFooResponse, error)

+ func (c *TestExampleClient) CreateFooAsync(ctx context.Context, req *CreateFooRequest, options ...*CreateFooOptions) (CreateFooRun, error)

+ func (c *TestExampleClient) CreateFooWithSetFooProgress(ctx context.Context, req *CreateFooRequest, signal *SetFooProgressRequest, ...) (*CreateFooResponse, error)

+ func (c *TestExampleClient) CreateFooWithSetFooProgressAsync(ctx context.Context, req *CreateFooRequest, signal *SetFooProgressRequest, ...) (CreateFooRun, error)

+ func (c *TestExampleClient) GetCreateFoo(ctx context.Context, workflowID string, runID string) CreateFooRun

+ func (c *TestExampleClient) GetFooProgress(ctx context.Context, workflowID string, runID string) (*GetFooProgressResponse, error)

+ func (c *TestExampleClient) SetFooProgress(ctx context.Context, workflowID string, runID string, ...) error

+ func (c *TestExampleClient) TerminateWorkflow(ctx context.Context, workflowID string, runID string, reason string, ...) error

+ func (c *TestExampleClient) UpdateFooProgress(ctx context.Context, workflowID string, runID string, ...) (*GetFooProgressResponse, error)

+ func (c *TestExampleClient) UpdateFooProgressAsync(ctx context.Context, workflowID string, runID string, ...) (UpdateFooProgressHandle, error)

+ type UpdateFooProgressHandle interface

+ Get func(ctx context.Context) (*GetFooProgressResponse, error)

+ RunID func() string

+ UpdateID func() string

+ WorkflowID func() string

+ type UpdateFooProgressOptions struct

+ func NewUpdateFooProgressOptions() *UpdateFooProgressOptions

+ func (opts *UpdateFooProgressOptions) WithUpdateWorkflowOptions(options client.UpdateWorkflowWithOptionsRequest) *UpdateFooProgressOptions