optionv1

package
v1.14.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 19, 2024 License: MIT Imports: 29 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-go_temporal. DO NOT EDIT. versions: 

protoc-gen-go_temporal 1.14.4-next (7c69f56bb01f4f341493709180241a5625d7d83b)
go go1.23.3
protoc (unknown)

source: test/option/v1/option.proto

Index

Constants

View Source 
const (
	ActivityWithInputActivityName = "test.option.v1.Test.ActivityWithInput"
)

test.option.v1.Test activity names

View Source 
const TestTaskQueue = "option-v1"

TestTaskQueue is the default task-queue for a test.option.v1.Test worker

View Source 
const (
	UpdateWithInputUpdateName = "test.option.v1.Test.UpdateWithInput"
)

test.option.v1.Test update names

View Source 
const (
	WorkflowWithInputWorkflowName = "test.option.v1.Test.WorkflowWithInput"
)

test.option.v1.Test workflow names

Variables

View Source 
var File_test_option_v1_option_proto protoreflect.FileDescriptor
View Source 
var (
	UpdateWithInputIdexpression = expression.MustParseExpression("update-with-input:${! name.or(throw(\"name is required\")) }")
)

test.option.v1.Test update id expressions

View Source 
var (
	// WorkflowWithInputFunction implements a "test.option.v1.Test.WorkflowWithInput" workflow
	WorkflowWithInputFunction func(workflow.Context, *WorkflowWithInputRequest) error
)

Reference to generated workflow functions

View Source 
var (
	WorkflowWithInputIdexpression = expression.MustParseExpression("workflow-with-input:${! name.or(throw(\"name is required\")) }")
)

test.option.v1.Test workflow id expressions

View Source 
var (
	WorkflowWithInputSearchAttributesMapping = expression.MustParseMapping("name = name \n")
)

test.option.v1.Test workflow search attribute mappings

Functions

func NewTestCli 

func NewTestCli(options ...*TestCliOptions) (*v2.App, error)

NewTestCli initializes a cli for a(n) test.option.v1.Test service

func NewTestCliCommand 

func NewTestCliCommand(options ...*TestCliOptions) (*v2.Command, error)

NewTestCliCommand initializes a cli command for a test.option.v1.Test service with subcommands for each query, signal, update, and workflow

func NewTestClientOptions 

func NewTestClientOptions() *testClientOptions

NewTestClientOptions initializes a new testClientOptions value

func RegisterActivityWithInputActivity 

func RegisterActivityWithInputActivity(r worker.ActivityRegistry, fn func(context.Context, *ActivityWithInputRequest) (*ActivityWithInputResponse, error))

RegisterActivityWithInputActivity registers a test.option.v1.Test.ActivityWithInput activity

func RegisterTestActivities 

func RegisterTestActivities(r worker.ActivityRegistry, activities TestActivities)

RegisterTestActivities registers activities with a worker

func RegisterTestWorkflows 

func RegisterTestWorkflows(r worker.WorkflowRegistry, workflows TestWorkflows)

RegisterTestWorkflows registers test.option.v1.Test workflows with the given worker

func RegisterWorkflowWithInputWorkflow 

func RegisterWorkflowWithInputWorkflow(r worker.WorkflowRegistry, wf func(workflow.Context, *WorkflowWithInputWorkflowInput) (WorkflowWithInputWorkflow, error))

RegisterWorkflowWithInputWorkflow registers a test.option.v1.Test.WorkflowWithInput workflow with the given worker

func WithTestSchemeTypes 

func WithTestSchemeTypes() scheme.Option

WithTestSchemeTypes registers all Test protobuf types with the given scheme

func WorkflowWithInputChild 

func WorkflowWithInputChild(ctx workflow.Context, req *WorkflowWithInputRequest, options ...*WorkflowWithInputChildOptions) error

WorkflowWithInputChild executes a child test.option.v1.Test.WorkflowWithInput workflow and blocks until error or response received

Types

type ActivityWithInputActivityOptions 

type ActivityWithInputActivityOptions struct {
	// contains filtered or unexported fields
}

ActivityWithInputActivityOptions provides configuration for a(n) test.option.v1.Test.ActivityWithInput activity

func NewActivityWithInputActivityOptions 

func NewActivityWithInputActivityOptions() *ActivityWithInputActivityOptions

NewActivityWithInputActivityOptions initializes a new ActivityWithInputActivityOptions value

func (*ActivityWithInputActivityOptions) Build 

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

Build initializes a workflow.Context with appropriate ActivityOptions values derived from schema defaults and any user-defined overrides

func (*ActivityWithInputActivityOptions) WithActivityOptions 

func (o *ActivityWithInputActivityOptions) WithActivityOptions(options workflow.ActivityOptions) *ActivityWithInputActivityOptions

WithActivityOptions specifies an initial ActivityOptions value to which defaults will be applied

func (*ActivityWithInputActivityOptions) WithHeartbeatTimeout 

func (o *ActivityWithInputActivityOptions) WithHeartbeatTimeout(d time.Duration) *ActivityWithInputActivityOptions

WithHeartbeatTimeout sets the HeartbeatTimeout value

func (*ActivityWithInputActivityOptions) WithRetryPolicy 

func (o *ActivityWithInputActivityOptions) WithRetryPolicy(policy *temporal.RetryPolicy) *ActivityWithInputActivityOptions

WithRetryPolicy sets the RetryPolicy value

func (*ActivityWithInputActivityOptions) WithScheduleToCloseTimeout 

func (o *ActivityWithInputActivityOptions) WithScheduleToCloseTimeout(d time.Duration) *ActivityWithInputActivityOptions

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*ActivityWithInputActivityOptions) WithScheduleToStartTimeout 

func (o *ActivityWithInputActivityOptions) WithScheduleToStartTimeout(d time.Duration) *ActivityWithInputActivityOptions

WithScheduleToStartTimeout sets the ScheduleToStartTimeout value

func (*ActivityWithInputActivityOptions) WithStartToCloseTimeout 

func (o *ActivityWithInputActivityOptions) WithStartToCloseTimeout(d time.Duration) *ActivityWithInputActivityOptions

WithStartToCloseTimeout sets the StartToCloseTimeout value

func (*ActivityWithInputActivityOptions) WithTaskQueue 

func (o *ActivityWithInputActivityOptions) WithTaskQueue(tq string) *ActivityWithInputActivityOptions

WithTaskQueue sets the TaskQueue value

func (*ActivityWithInputActivityOptions) WithWaitForCancellation 

func (o *ActivityWithInputActivityOptions) WithWaitForCancellation(wait bool) *ActivityWithInputActivityOptions

WithWaitForCancellation sets the WaitForCancellation value

type ActivityWithInputFuture 

type ActivityWithInputFuture struct {
	Future workflow.Future
}

ActivityWithInputFuture describes a(n) test.option.v1.Test.ActivityWithInput activity execution

func ActivityWithInputAsync 

func ActivityWithInputAsync(ctx workflow.Context, req *ActivityWithInputRequest, options ...*ActivityWithInputActivityOptions) *ActivityWithInputFuture

ActivityWithInputAsync executes a(n) test.option.v1.Test.ActivityWithInput activity (asynchronously)

func ActivityWithInputLocalAsync 

func ActivityWithInputLocalAsync(ctx workflow.Context, req *ActivityWithInputRequest, options ...*ActivityWithInputLocalActivityOptions) *ActivityWithInputFuture

ActivityWithInputLocalAsync executes a(n) test.option.v1.Test.ActivityWithInput activity (asynchronously, locally)

func (*ActivityWithInputFuture) Get 

func (f *ActivityWithInputFuture) Get(ctx workflow.Context) (*ActivityWithInputResponse, error)

Get blocks on the activity's completion, returning the response

func (*ActivityWithInputFuture) Select 

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

Select adds the activity's completion to the selector, callback can be nil

type ActivityWithInputLocalActivityOptions 

type ActivityWithInputLocalActivityOptions struct {
	// contains filtered or unexported fields
}

ActivityWithInputLocalActivityOptions provides configuration for a(n) test.option.v1.Test.ActivityWithInput activity

func NewActivityWithInputLocalActivityOptions 

func NewActivityWithInputLocalActivityOptions() *ActivityWithInputLocalActivityOptions

NewActivityWithInputLocalActivityOptions initializes a new ActivityWithInputLocalActivityOptions value

func (*ActivityWithInputLocalActivityOptions) Build 

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

Build initializes a workflow.Context with appropriate LocalActivityOptions values derived from schema defaults and any user-defined overrides

func (*ActivityWithInputLocalActivityOptions) Local 

func (o *ActivityWithInputLocalActivityOptions) Local(fn func(context.Context, *ActivityWithInputRequest) (*ActivityWithInputResponse, error)) *ActivityWithInputLocalActivityOptions

Local specifies a custom test.option.v1.Test.ActivityWithInput implementation

func (*ActivityWithInputLocalActivityOptions) WithLocalActivityOptions 

func (o *ActivityWithInputLocalActivityOptions) WithLocalActivityOptions(options workflow.LocalActivityOptions) *ActivityWithInputLocalActivityOptions

WithLocalActivityOptions specifies an initial LocalActivityOptions value to which defaults will be applied

func (*ActivityWithInputLocalActivityOptions) WithRetryPolicy 

func (o *ActivityWithInputLocalActivityOptions) WithRetryPolicy(policy *temporal.RetryPolicy) *ActivityWithInputLocalActivityOptions

WithRetryPolicy sets the RetryPolicy value

func (*ActivityWithInputLocalActivityOptions) WithScheduleToCloseTimeout 

func (o *ActivityWithInputLocalActivityOptions) WithScheduleToCloseTimeout(d time.Duration) *ActivityWithInputLocalActivityOptions

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*ActivityWithInputLocalActivityOptions) WithStartToCloseTimeout 

func (o *ActivityWithInputLocalActivityOptions) WithStartToCloseTimeout(d time.Duration) *ActivityWithInputLocalActivityOptions

WithStartToCloseTimeout sets the StartToCloseTimeout value

type ActivityWithInputRequest 

type ActivityWithInputRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ActivityWithInputRequest) Descriptor deprecated 

func (*ActivityWithInputRequest) Descriptor() ([]byte, []int)

Deprecated: Use ActivityWithInputRequest.ProtoReflect.Descriptor instead.

func (*ActivityWithInputRequest) GetName 

func (x *ActivityWithInputRequest) GetName() string

func (*ActivityWithInputRequest) ProtoMessage 

func (*ActivityWithInputRequest) ProtoMessage()

func (*ActivityWithInputRequest) ProtoReflect 

func (x *ActivityWithInputRequest) ProtoReflect() protoreflect.Message

func (*ActivityWithInputRequest) Reset 

func (x *ActivityWithInputRequest) Reset()

func (*ActivityWithInputRequest) String 

func (x *ActivityWithInputRequest) String() string

type ActivityWithInputResponse 

type ActivityWithInputResponse struct {
	Result string `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func ActivityWithInput 

func ActivityWithInput(ctx workflow.Context, req *ActivityWithInputRequest, options ...*ActivityWithInputActivityOptions) (*ActivityWithInputResponse, error)

ActivityWithInput executes a(n) test.option.v1.Test.ActivityWithInput activity

func ActivityWithInputLocal 

func ActivityWithInputLocal(ctx workflow.Context, req *ActivityWithInputRequest, options ...*ActivityWithInputLocalActivityOptions) (*ActivityWithInputResponse, error)

ActivityWithInputLocal executes a(n) test.option.v1.Test.ActivityWithInput activity (locally)

func (*ActivityWithInputResponse) Descriptor deprecated 

func (*ActivityWithInputResponse) Descriptor() ([]byte, []int)

Deprecated: Use ActivityWithInputResponse.ProtoReflect.Descriptor instead.

func (*ActivityWithInputResponse) GetResult 

func (x *ActivityWithInputResponse) GetResult() string

func (*ActivityWithInputResponse) ProtoMessage 

func (*ActivityWithInputResponse) ProtoMessage()

func (*ActivityWithInputResponse) ProtoReflect 

func (x *ActivityWithInputResponse) ProtoReflect() protoreflect.Message

func (*ActivityWithInputResponse) Reset 

func (x *ActivityWithInputResponse) Reset()

func (*ActivityWithInputResponse) String 

func (x *ActivityWithInputResponse) String() string

type TestActivities 

type TestActivities interface {
	// test.option.v1.Test.ActivityWithInput implements a(n) test.option.v1.Test.ActivityWithInput activity definition
	ActivityWithInput(ctx context.Context, req *ActivityWithInputRequest) (*ActivityWithInputResponse, error)
}

TestActivities describes available worker activities

type TestCliOptions 

type TestCliOptions struct {
	// contains filtered or unexported fields
}

TestCliOptions describes runtime configuration for test.option.v1.Test cli

func NewTestCliOptions 

func NewTestCliOptions() *TestCliOptions

NewTestCliOptions initializes a new TestCliOptions value

func (*TestCliOptions) WithAfter 

func (opts *TestCliOptions) WithAfter(fn func(*v2.Context) error) *TestCliOptions

WithAfter injects a custom After hook to be run after any command invocation

func (*TestCliOptions) WithBefore 

func (opts *TestCliOptions) WithBefore(fn func(*v2.Context) error) *TestCliOptions

WithBefore injects a custom Before hook to be run prior to any command invocation

func (*TestCliOptions) WithClient 

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

WithClient provides a Temporal client factory for use by commands

func (*TestCliOptions) WithWorker 

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

WithWorker provides an method for initializing a worker

type TestClient 

type TestClient interface {
	// WorkflowWithInput executes a(n) test.option.v1.Test.WorkflowWithInput workflow and blocks until error or response received
	WorkflowWithInput(ctx context.Context, req *WorkflowWithInputRequest, opts ...*WorkflowWithInputOptions) error

	// WorkflowWithInputAsync starts a(n) test.option.v1.Test.WorkflowWithInput workflow and returns a handle to the workflow run
	WorkflowWithInputAsync(ctx context.Context, req *WorkflowWithInputRequest, opts ...*WorkflowWithInputOptions) (WorkflowWithInputRun, error)

	// GetWorkflowWithInput retrieves a handle to an existing test.option.v1.Test.WorkflowWithInput workflow execution
	GetWorkflowWithInput(ctx context.Context, workflowID string, runID string) WorkflowWithInputRun

	// CancelWorkflow requests cancellation of an existing workflow execution
	CancelWorkflow(ctx context.Context, workflowID string, runID string) error

	// TerminateWorkflow an existing workflow execution
	TerminateWorkflow(ctx context.Context, workflowID string, runID string, reason string, details ...interface{}) error

	// UpdateWithInput executes a(n) test.option.v1.Test.UpdateWithInput update and blocks until update completion
	UpdateWithInput(ctx context.Context, workflowID string, runID string, req *UpdateWithInputRequest, opts ...*UpdateWithInputOptions) error

	// UpdateWithInputAsync starts a(n) test.option.v1.Test.UpdateWithInput update and returns a handle to the workflow update
	UpdateWithInputAsync(ctx context.Context, workflowID string, runID string, req *UpdateWithInputRequest, opts ...*UpdateWithInputOptions) (UpdateWithInputHandle, error)

	// GetUpdateWithInput retrieves a handle to an existing test.option.v1.Test.UpdateWithInput update
	GetUpdateWithInput(ctx context.Context, req client.GetWorkflowUpdateHandleOptions) (UpdateWithInputHandle, error)
}

TestClient describes a client for a(n) test.option.v1.Test worker

func NewTestClient 

func NewTestClient(c client.Client, options ...*testClientOptions) TestClient

NewTestClient initializes a new test.option.v1.Test client

func NewTestClientWithOptions 

func NewTestClientWithOptions(c client.Client, opts client.Options, options ...*testClientOptions) (TestClient, error)

NewTestClientWithOptions initializes a new Test client with the given options

type TestTestClient 

type TestTestClient struct {
	// contains filtered or unexported fields
}

TestClient provides a testsuite-compatible Client

func NewTestTestClient 

func NewTestTestClient(env *testsuite.TestWorkflowEnvironment, workflows TestWorkflows, activities TestActivities) *TestTestClient

NewTestTestClient initializes a new TestTestClient value

func (*TestTestClient) CancelWorkflow 

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

CancelWorkflow requests cancellation of an existing workflow execution

func (*TestTestClient) GetUpdateWithInput 

func (c *TestTestClient) GetUpdateWithInput(ctx context.Context, req client.GetWorkflowUpdateHandleOptions) (UpdateWithInputHandle, error)

GetUpdateWithInput retrieves a handle to an existing test.option.v1.Test.UpdateWithInput update

func (*TestTestClient) GetWorkflowWithInput 

func (c *TestTestClient) GetWorkflowWithInput(ctx context.Context, workflowID string, runID string) WorkflowWithInputRun

GetWorkflowWithInput is a noop

func (*TestTestClient) TerminateWorkflow 

func (c *TestTestClient) TerminateWorkflow(ctx context.Context, workflowID string, runID string, reason string, details ...interface{}) error

TerminateWorkflow terminates an existing workflow execution

func (*TestTestClient) UpdateWithInput 

func (c *TestTestClient) UpdateWithInput(ctx context.Context, workflowID string, runID string, req *UpdateWithInputRequest, opts ...*UpdateWithInputOptions) error

UpdateWithInput executes a(n) test.option.v1.Test.UpdateWithInput update in the test environment

func (*TestTestClient) UpdateWithInputAsync 

func (c *TestTestClient) UpdateWithInputAsync(ctx context.Context, workflowID string, runID string, req *UpdateWithInputRequest, opts ...*UpdateWithInputOptions) (UpdateWithInputHandle, error)

UpdateWithInputAsync executes a(n) test.option.v1.Test.UpdateWithInput update in the test environment

func (*TestTestClient) WorkflowWithInput 

func (c *TestTestClient) WorkflowWithInput(ctx context.Context, req *WorkflowWithInputRequest, opts ...*WorkflowWithInputOptions) error

WorkflowWithInput executes a(n) test.option.v1.Test.WorkflowWithInput workflow in the test environment

func (*TestTestClient) WorkflowWithInputAsync 

func (c *TestTestClient) WorkflowWithInputAsync(ctx context.Context, req *WorkflowWithInputRequest, options ...*WorkflowWithInputOptions) (WorkflowWithInputRun, error)

WorkflowWithInputAsync executes a(n) test.option.v1.Test.WorkflowWithInput workflow in the test environment

type TestWorkflowFunctions 

type TestWorkflowFunctions interface {
	// WorkflowWithInput executes a "test.option.v1.Test.WorkflowWithInput" workflow inline
	WorkflowWithInput(workflow.Context, *WorkflowWithInputRequest) error
}

TestWorkflowFunctions describes a mockable dependency for inlining workflows within other workflows

func NewTestWorkflowFunctions 

func NewTestWorkflowFunctions() TestWorkflowFunctions

type TestWorkflows 

type TestWorkflows interface {
	// WorkflowWithInput initializes a new a(n) WorkflowWithInputWorkflow implementation
	WorkflowWithInput(ctx workflow.Context, input *WorkflowWithInputWorkflowInput) (WorkflowWithInputWorkflow, error)
}

TestWorkflows provides methods for initializing new test.option.v1.Test workflow values

type UpdateWithInputHandle 

type UpdateWithInputHandle interface {
	// WorkflowID returns the workflow ID
	WorkflowID() string
	// RunID returns the workflow instance ID
	RunID() string
	// UpdateID returns the update ID
	UpdateID() string
	// Get blocks until the workflow is complete and returns the result
	Get(ctx context.Context) error
}

UpdateWithInputHandle describes a(n) test.option.v1.Test.UpdateWithInput update handle

type UpdateWithInputOptions 

type UpdateWithInputOptions struct {
	Options *client.UpdateWorkflowOptions
	// contains filtered or unexported fields
}

UpdateWithInputOptions provides configuration for a test.option.v1.Test.UpdateWithInput update operation

func NewUpdateWithInputOptions 

func NewUpdateWithInputOptions() *UpdateWithInputOptions

NewUpdateWithInputOptions initializes a new UpdateWithInputOptions value

func (*UpdateWithInputOptions) Build 

func (o *UpdateWithInputOptions) Build(workflowID string, runID string, req *UpdateWithInputRequest) (opts *client.UpdateWorkflowOptions, err error)

Build initializes a new client.UpdateWorkflowOptions with defaults and overrides applied

func (*UpdateWithInputOptions) WithUpdateID 

func (o *UpdateWithInputOptions) WithUpdateID(id string) *UpdateWithInputOptions

WithUpdateID sets the UpdateID

func (*UpdateWithInputOptions) WithUpdateWorkflowOptions 

func (o *UpdateWithInputOptions) WithUpdateWorkflowOptions(options client.UpdateWorkflowOptions) *UpdateWithInputOptions

WithUpdateWorkflowOptions sets the initial client.UpdateWorkflowOptions

func (*UpdateWithInputOptions) WithWaitPolicy 

func (o *UpdateWithInputOptions) WithWaitPolicy(policy client.WorkflowUpdateStage) *UpdateWithInputOptions

WithWaitPolicy sets the WaitPolicy

type UpdateWithInputRequest 

type UpdateWithInputRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func UnmarshalCliFlagsToUpdateWithInputRequest 

func UnmarshalCliFlagsToUpdateWithInputRequest(cmd *v2.Context) (*UpdateWithInputRequest, error)

UnmarshalCliFlagsToUpdateWithInputRequest unmarshals a UpdateWithInputRequest from command line flags

func (*UpdateWithInputRequest) Descriptor deprecated 

func (*UpdateWithInputRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateWithInputRequest.ProtoReflect.Descriptor instead.

func (*UpdateWithInputRequest) GetName 

func (x *UpdateWithInputRequest) GetName() string

func (*UpdateWithInputRequest) ProtoMessage 

func (*UpdateWithInputRequest) ProtoMessage()

func (*UpdateWithInputRequest) ProtoReflect 

func (x *UpdateWithInputRequest) ProtoReflect() protoreflect.Message

func (*UpdateWithInputRequest) Reset 

func (x *UpdateWithInputRequest) Reset()

func (*UpdateWithInputRequest) String 

func (x *UpdateWithInputRequest) String() string

type WorkflowWithInputChildOptions 

type WorkflowWithInputChildOptions struct {
	// contains filtered or unexported fields
}

WorkflowWithInputChildOptions provides configuration for a child test.option.v1.Test.WorkflowWithInput workflow operation

func NewWorkflowWithInputChildOptions 

func NewWorkflowWithInputChildOptions() *WorkflowWithInputChildOptions

NewWorkflowWithInputChildOptions initializes a new WorkflowWithInputChildOptions value

func (*WorkflowWithInputChildOptions) Build 

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

Build initializes a new go.temporal.io/sdk/workflow.ChildWorkflowOptions value with defaults and overrides applied

func (*WorkflowWithInputChildOptions) WithChildWorkflowOptions 

func (o *WorkflowWithInputChildOptions) WithChildWorkflowOptions(options workflow.ChildWorkflowOptions) *WorkflowWithInputChildOptions

WithChildWorkflowOptions sets the initial go.temporal.io/sdk/workflow.ChildWorkflowOptions

func (*WorkflowWithInputChildOptions) WithExecutionTimeout 

func (o *WorkflowWithInputChildOptions) WithExecutionTimeout(d time.Duration) *WorkflowWithInputChildOptions

WithExecutionTimeout sets the WorkflowExecutionTimeout value

func (*WorkflowWithInputChildOptions) WithID 

func (o *WorkflowWithInputChildOptions) WithID(id string) *WorkflowWithInputChildOptions

WithID sets the WorkflowID value

func (*WorkflowWithInputChildOptions) WithIDReusePolicy 

func (o *WorkflowWithInputChildOptions) WithIDReusePolicy(policy enumsv1.WorkflowIdReusePolicy) *WorkflowWithInputChildOptions

WithIDReusePolicy sets the WorkflowIDReusePolicy value

func (*WorkflowWithInputChildOptions) WithParentClosePolicy 

func (o *WorkflowWithInputChildOptions) WithParentClosePolicy(policy enumsv1.ParentClosePolicy) *WorkflowWithInputChildOptions

WithParentClosePolicy sets the WorkflowIDReusePolicy value

func (*WorkflowWithInputChildOptions) WithRetryPolicy 

func (o *WorkflowWithInputChildOptions) WithRetryPolicy(policy *temporal.RetryPolicy) *WorkflowWithInputChildOptions

WithRetryPolicy sets the RetryPolicy value

func (*WorkflowWithInputChildOptions) WithRunTimeout 

func (o *WorkflowWithInputChildOptions) WithRunTimeout(d time.Duration) *WorkflowWithInputChildOptions

WithRunTimeout sets the WorkflowRunTimeout value

func (*WorkflowWithInputChildOptions) WithSearchAttributes 

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

WithSearchAttributes sets the SearchAttributes value

func (*WorkflowWithInputChildOptions) WithTaskQueue 

func (o *WorkflowWithInputChildOptions) WithTaskQueue(tq string) *WorkflowWithInputChildOptions

WithTaskQueue sets the TaskQueue value

func (*WorkflowWithInputChildOptions) WithTaskTimeout 

func (o *WorkflowWithInputChildOptions) WithTaskTimeout(d time.Duration) *WorkflowWithInputChildOptions

WithTaskTimeout sets the WorkflowTaskTimeout value

func (*WorkflowWithInputChildOptions) WithWaitForCancellation 

func (o *WorkflowWithInputChildOptions) WithWaitForCancellation(wait bool) *WorkflowWithInputChildOptions

WithWaitForCancellation sets the WaitForCancellation value

type WorkflowWithInputChildRun 

type WorkflowWithInputChildRun struct {
	Future workflow.ChildWorkflowFuture
}

WorkflowWithInputChildRun describes a child WorkflowWithInput workflow run

func WorkflowWithInputChildAsync 

func WorkflowWithInputChildAsync(ctx workflow.Context, req *WorkflowWithInputRequest, options ...*WorkflowWithInputChildOptions) (*WorkflowWithInputChildRun, error)

WorkflowWithInputChildAsync starts a child test.option.v1.Test.WorkflowWithInput workflow and returns a handle to the child workflow run

func (*WorkflowWithInputChildRun) Get 

func (r *WorkflowWithInputChildRun) Get(ctx workflow.Context) error

Get blocks until the workflow is completed, returning the response value

func (*WorkflowWithInputChildRun) Select 

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

Select adds this completion to the selector. Callback can be nil.

func (*WorkflowWithInputChildRun) SelectStart 

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

SelectStart adds waiting for start to the selector. Callback can be nil.

func (*WorkflowWithInputChildRun) WaitStart 

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

WaitStart waits for the child workflow to start

type WorkflowWithInputOptions 

type WorkflowWithInputOptions struct {
	// contains filtered or unexported fields
}

WorkflowWithInputOptions provides configuration for a test.option.v1.Test.WorkflowWithInput workflow operation

func NewWorkflowWithInputOptions 

func NewWorkflowWithInputOptions() *WorkflowWithInputOptions

NewWorkflowWithInputOptions initializes a new WorkflowWithInputOptions value

func (*WorkflowWithInputOptions) Build 

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

Build initializes a new go.temporal.io/sdk/client.StartWorkflowOptions value with defaults and overrides applied

func (*WorkflowWithInputOptions) WithExecutionTimeout 

func (o *WorkflowWithInputOptions) WithExecutionTimeout(d time.Duration) *WorkflowWithInputOptions

WithExecutionTimeout sets the WorkflowExecutionTimeout value

func (*WorkflowWithInputOptions) WithID 

func (o *WorkflowWithInputOptions) WithID(id string) *WorkflowWithInputOptions

WithID sets the ID value

func (*WorkflowWithInputOptions) WithIDReusePolicy 

func (o *WorkflowWithInputOptions) WithIDReusePolicy(policy enumsv1.WorkflowIdReusePolicy) *WorkflowWithInputOptions

WithIDReusePolicy sets the WorkflowIDReusePolicy value

func (*WorkflowWithInputOptions) WithRetryPolicy 

func (o *WorkflowWithInputOptions) WithRetryPolicy(policy *temporal.RetryPolicy) *WorkflowWithInputOptions

WithRetryPolicy sets the RetryPolicy value

func (*WorkflowWithInputOptions) WithRunTimeout 

func (o *WorkflowWithInputOptions) WithRunTimeout(d time.Duration) *WorkflowWithInputOptions

WithRunTimeout sets the WorkflowRunTimeout value

func (*WorkflowWithInputOptions) WithSearchAttributes 

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

WithSearchAttributes sets the SearchAttributes value

func (*WorkflowWithInputOptions) WithStartWorkflowOptions 

func (o *WorkflowWithInputOptions) WithStartWorkflowOptions(options client.StartWorkflowOptions) *WorkflowWithInputOptions

WithStartWorkflowOptions sets the initial go.temporal.io/sdk/client.StartWorkflowOptions

func (*WorkflowWithInputOptions) WithTaskQueue 

func (o *WorkflowWithInputOptions) WithTaskQueue(tq string) *WorkflowWithInputOptions

WithTaskQueue sets the TaskQueue value

func (*WorkflowWithInputOptions) WithTaskTimeout 

func (o *WorkflowWithInputOptions) WithTaskTimeout(d time.Duration) *WorkflowWithInputOptions

WithTaskTimeout sets the WorkflowTaskTimeout value

type WorkflowWithInputRequest 

type WorkflowWithInputRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func UnmarshalCliFlagsToWorkflowWithInputRequest 

func UnmarshalCliFlagsToWorkflowWithInputRequest(cmd *v2.Context) (*WorkflowWithInputRequest, error)

UnmarshalCliFlagsToWorkflowWithInputRequest unmarshals a WorkflowWithInputRequest from command line flags

func (*WorkflowWithInputRequest) Descriptor deprecated 

func (*WorkflowWithInputRequest) Descriptor() ([]byte, []int)

Deprecated: Use WorkflowWithInputRequest.ProtoReflect.Descriptor instead.

func (*WorkflowWithInputRequest) GetName 

func (x *WorkflowWithInputRequest) GetName() string

func (*WorkflowWithInputRequest) ProtoMessage 

func (*WorkflowWithInputRequest) ProtoMessage()

func (*WorkflowWithInputRequest) ProtoReflect 

func (x *WorkflowWithInputRequest) ProtoReflect() protoreflect.Message

func (*WorkflowWithInputRequest) Reset 

func (x *WorkflowWithInputRequest) Reset()

func (*WorkflowWithInputRequest) String 

func (x *WorkflowWithInputRequest) String() string

type WorkflowWithInputRun 

type WorkflowWithInputRun interface {
	// ID returns the workflow ID
	ID() string

	// RunID returns the workflow instance ID
	RunID() string

	// Run returns the inner client.WorkflowRun
	Run() client.WorkflowRun

	// Get blocks until the workflow is complete and returns the result
	Get(ctx context.Context) error

	// Cancel requests cancellation of a workflow in execution, returning an error if applicable
	Cancel(ctx context.Context) error

	// Terminate terminates a workflow in execution, returning an error if applicable
	Terminate(ctx context.Context, reason string, details ...interface{}) error

	// test.option.v1.Test.UpdateWithInput executes a(n) test.option.v1.Test.UpdateWithInput update
	UpdateWithInput(ctx context.Context, req *UpdateWithInputRequest, opts ...*UpdateWithInputOptions) error

	// test.option.v1.Test.UpdateWithInputAsync sends a(n) test.option.v1.Test.UpdateWithInput update to the workflow
	UpdateWithInputAsync(ctx context.Context, req *UpdateWithInputRequest, opts ...*UpdateWithInputOptions) (UpdateWithInputHandle, error)
}

WorkflowWithInputRun describes a(n) test.option.v1.Test.WorkflowWithInput workflow run

type WorkflowWithInputWorkflow 

type WorkflowWithInputWorkflow interface {
	// Execute defines the entrypoint to a(n) test.option.v1.Test.WorkflowWithInput workflow
	Execute(ctx workflow.Context) error

	// test.option.v1.Test.UpdateWithInput implements a(n) test.option.v1.Test.UpdateWithInput update handler
	UpdateWithInput(workflow.Context, *UpdateWithInputRequest) error
}

WorkflowWithInputWorkflow describes a(n) test.option.v1.Test.WorkflowWithInput workflow implementation

workflow details: (id: "workflow-with-input:${! name.or(throw("name is required")) }")

type WorkflowWithInputWorkflowInput 

type WorkflowWithInputWorkflowInput struct {
	Req *WorkflowWithInputRequest
}

WorkflowWithInputWorkflowInput describes the input to a(n) test.option.v1.Test.WorkflowWithInput workflow constructor

Source Files

View all Source files

Directories

Path Synopsis
Code generated by protoc-gen-go_temporal.
 Code generated by protoc-gen-go_temporal.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.