optionv1xns

May 14, 2024

Changes in this version

type WorkflowWithInputWorkflowOptions

+ ParentClosePolicy v11.ParentClosePolicy

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

May 3, 2024

Changes in this version

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

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

+ func RegisterTestActivities(r worker.ActivityRegistry, c v1.TestClient, options ...*TestOptions)

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

+ func WorkflowWithInput(ctx workflow.Context, req *v1.WorkflowWithInputRequest, ...) error

+ type TestOptions struct

+ func NewTestOptions() *TestOptions

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

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

+ type UpdateWithInputHandle interface

+ Cancel func(workflow.Context) error

+ Future func() workflow.Future

+ Get func(workflow.Context) error

+ ID func() string

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

+ type UpdateWithInputUpdateOptions struct

+ ActivityOptions *workflow.ActivityOptions

+ HeartbeatInterval time.Duration

+ UpdateWorkflowOptions *client.UpdateWorkflowWithOptionsRequest

+ func NewUpdateWithInputUpdateOptions() *UpdateWithInputUpdateOptions

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

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

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

+ type WorkflowWithInputRun interface

+ Cancel func(workflow.Context) error

+ Future func() workflow.Future

+ Get func(workflow.Context) error

+ ID func() string

+ UpdateWithInput func(workflow.Context, *v1.UpdateWithInputRequest, ...*UpdateWithInputUpdateOptions) error

+ UpdateWithInputAsync func(workflow.Context, *v1.UpdateWithInputRequest, ...*UpdateWithInputUpdateOptions) (UpdateWithInputHandle, error)

+ func WorkflowWithInputAsync(ctx workflow.Context, req *v1.WorkflowWithInputRequest, ...) (WorkflowWithInputRun, error)

+ type WorkflowWithInputWorkflowOptions struct

+ ActivityOptions *workflow.ActivityOptions

+ Detached bool

+ HeartbeatInterval time.Duration

+ StartWorkflowOptions *client.StartWorkflowOptions

+ func NewWorkflowWithInputWorkflowOptions() *WorkflowWithInputWorkflowOptions

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

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

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

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