xnsv1

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

v1.13.0

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 ProvisionFooChildOptions

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

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

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

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

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

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

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

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

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

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

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

type ProvisionFooOptions

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

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

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

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

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

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

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

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

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

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

v1.12.0

Apr 19, 2024

Changes in this version

+ type ExampleWorkflowFunctions interface

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

+ func NewExampleWorkflowFunctions() ExampleWorkflowFunctions

+ type XnsWorkflowFunctions interface

+ ProvisionFoo func(workflow.Context, *ProvisionFooRequest) (*ProvisionFooResponse, error)

+ func NewXnsWorkflowFunctions() XnsWorkflowFunctions

v1.11.0

Apr 12, 2024

v1.10.4

Apr 9, 2024

v1.10.3

Apr 5, 2024

v1.10.2

Apr 4, 2024

Changes in this version

+ const CreateFooWorkflowName

+ const ExampleTaskQueue

+ const GetFooProgressQueryName

+ const NotifyActivityName

+ const ProvisionFooWorkflowName

+ const SetFooProgressSignalName

+ const UpdateFooProgressUpdateName

+ const XnsTaskQueue

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

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

+ var File_example_xns_v1_xns_proto protoreflect.FileDescriptor

+ var Foo_Status_name = map[int32]string

+ var Foo_Status_value = map[string]int32

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

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

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

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

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

+ func NewExampleClientOptions() *exampleClientOptions

+ func NewXnsCli(options ...*XnsCliOptions) (*v2.App, error)

+ func NewXnsCliCommand(options ...*XnsCliOptions) (*v2.Command, error)

+ func NewXnsClientOptions() *xnsClientOptions

+ 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 RegisterProvisionFooWorkflow(r worker.WorkflowRegistry, ...)

+ func RegisterXnsActivities(r worker.ActivityRegistry, activities XnsActivities)

+ func RegisterXnsWorkflows(r worker.WorkflowRegistry, workflows XnsWorkflows)

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

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

+ func WithExampleSchemeTypes() scheme.Option

+ func WithXnsSchemeTypes() scheme.Option

+ 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 CreateFooOptions struct

+ func NewCreateFooOptions() *CreateFooOptions

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

+ type CreateFooRequest struct

+ Name string

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

+ 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

+ Run func() client.WorkflowRun

+ 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 CreateFooWorkflowInput struct

+ Req *CreateFooRequest

+ SetFooProgress *SetFooProgressSignal

+ 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)

+ GetUpdateFooProgress func(ctx context.Context, req client.GetWorkflowUpdateHandleOptions) (UpdateFooProgressHandle, 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, options ...*exampleClientOptions) ExampleClient

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

+ type ExampleWorkflows interface

+ CreateFoo func(ctx workflow.Context, input *CreateFooWorkflowInput) (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 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 *ProvisionFooRequest, ...) (*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 ProvisionFooOptions struct

+ func NewProvisionFooOptions() *ProvisionFooOptions

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

+ type ProvisionFooRequest struct

+ Name string

+ func UnmarshalCliFlagsToProvisionFooRequest(cmd *v2.Context) (*ProvisionFooRequest, error)

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

+ func (*ProvisionFooRequest) ProtoMessage()

+ func (x *ProvisionFooRequest) GetName() string

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

+ func (x *ProvisionFooRequest) Reset()

+ func (x *ProvisionFooRequest) String() string

+ type ProvisionFooResponse struct

+ Foo *Foo

+ func ProvisionFooChild(ctx workflow.Context, req *ProvisionFooRequest, ...) (*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 *ProvisionFooRequest

+ type SetFooProgressRequest struct

+ Progress float32

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

+ 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 NewSetFooProgressSignal(ctx workflow.Context) *SetFooProgressSignal

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

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

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

+ 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) GetUpdateFooProgress(ctx context.Context, req client.GetWorkflowUpdateHandleOptions) (UpdateFooProgressHandle, 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 TestXnsClient struct

+ func NewTestXnsClient(env *testsuite.TestWorkflowEnvironment, workflows XnsWorkflows, ...) *TestXnsClient

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

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

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

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

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

+ type UpdateFooProgressHandle interface

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

+ RunID func() string

+ UpdateID func() string

+ WorkflowID func() string

+ type UpdateFooProgressOptions struct

+ Options *client.UpdateWorkflowWithOptionsRequest

+ func NewUpdateFooProgressOptions() *UpdateFooProgressOptions

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

+ type XnsActivities interface

+ type XnsCliOptions struct

+ func NewXnsCliOptions() *XnsCliOptions

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

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

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

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

+ type XnsClient 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 *ProvisionFooRequest, opts ...*ProvisionFooOptions) (*ProvisionFooResponse, error)

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

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

+ func NewXnsClient(c client.Client, options ...*xnsClientOptions) XnsClient

+ func NewXnsClientWithOptions(c client.Client, opts client.Options, options ...*xnsClientOptions) (XnsClient, error)

+ type XnsWorkflows interface

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

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