v1

package
v1.15.0 Latest Latest
Warning

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

 Go to latest Published: Jan 29, 2025 License: MIT Imports: 35 Imported by: 0

Documentation

Overview

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

protoc-gen-go_temporal 1.14.6-next (0ec9655dd1130535a5c8cfbda7a326aef9ac448a)
go go1.23.4
protoc (unknown)

source: test/simple/v1/simple.proto

Index

Constants

View Source 
const (
	SomeWorkflow1WorkflowName = "mycompany.simple.SomeWorkflow1"
	SomeWorkflow2WorkflowName = "mycompany.simple.SomeWorkflow2"
	SomeWorkflow3WorkflowName = "mycompany.simple.Simple.SomeWorkflow3"
	SomeWorkflow4WorkflowName = "mycompany.simple.Simple.SomeWorkflow4"
)

mycompany.simple.Simple workflow names

View Source 
const (
	SomeActivity1ActivityName = "mycompany.simple.SomeActivity1"
	SomeActivity2ActivityName = "mycompany.simple.Simple.SomeActivity2"
	SomeActivity3ActivityName = "mycompany.simple.Simple.SomeActivity3"
	SomeActivity4ActivityName = "mycompany.simple.Simple.SomeActivity4"
	SomeSignal1ActivityName   = "mycompany.simple.Simple.SomeSignal1"
	SomeSignal2ActivityName   = "mycompany.simple.Simple.SomeSignal2"
	SomeSignal3ActivityName   = "mycompany.simple.Simple.SomeSignal3"
	SomeUpdate1ActivityName   = "mycompany.simple.Simple.SomeUpdate1"
)

mycompany.simple.Simple activity names

View Source 
const (
	SomeQuery1QueryName = "mycompany.simple.Simple.SomeQuery1"
	SomeQuery2QueryName = "mycompany.simple.Simple.SomeQuery2"
)

mycompany.simple.Simple query names

View Source 
const (
	SomeSignal1SignalName = "mycompany.simple.Simple.SomeSignal1"
	SomeSignal2SignalName = "mycompany.simple.Simple.SomeSignal2"
	SomeSignal3SignalName = "mycompany.simple.Simple.SomeSignal3"
)

mycompany.simple.Simple signal names

View Source 
const (
	SomeDeprecatedWorkflow1WorkflowName = "mycompany.simple.Deprecated.SomeDeprecatedWorkflow1"
	SomeDeprecatedWorkflow2WorkflowName = "mycompany.simple.Deprecated.SomeDeprecatedWorkflow2"
)

mycompany.simple.Deprecated workflow names

View Source 
const (
	SomeDeprecatedActivity1ActivityName = "mycompany.simple.Deprecated.SomeDeprecatedActivity1"
	SomeDeprecatedActivity2ActivityName = "mycompany.simple.Deprecated.SomeDeprecatedActivity2"
)

mycompany.simple.Deprecated activity names

View Source 
const (
	SomeDeprecatedQuery1QueryName = "mycompany.simple.Deprecated.SomeDeprecatedQuery1"
	SomeDeprecatedQuery2QueryName = "mycompany.simple.Deprecated.SomeDeprecatedQuery2"
)

mycompany.simple.Deprecated query names

View Source 
const (
	SomeDeprecatedSignal1SignalName = "mycompany.simple.Deprecated.SomeDeprecatedSignal1"
	SomeDeprecatedSignal2SignalName = "mycompany.simple.Deprecated.SomeDeprecatedSignal2"
)

mycompany.simple.Deprecated signal names

View Source 
const (
	SomeDeprecatedUpdate1UpdateName = "mycompany.simple.Deprecated.SomeDeprecatedUpdate1"
	SomeDeprecatedUpdate2UpdateName = "mycompany.simple.Deprecated.SomeDeprecatedUpdate2"
)

mycompany.simple.Deprecated update names

View Source 
const (
	LonelyActivity1ActivityName = "mycompany.simple.OnlyActivities.LonelyActivity1"
)

mycompany.simple.OnlyActivities activity names

View Source 
const (
	OtherQueryQueryName = "mycompany.simple.Other.OtherQuery"
)

mycompany.simple.Other query names

View Source 
const (
	OtherSignalSignalName = "mycompany.simple.Other.OtherSignal"
)

mycompany.simple.Other signal names

View Source 
const OtherTaskQueue = "other-task-queue"

OtherTaskQueue is the default task-queue for a mycompany.simple.Other worker

View Source 
const (
	OtherUpdateUpdateName = "mycompany.simple.Other.OtherUpdate"
)

mycompany.simple.Other update names

View Source 
const (
	OtherWorkflowActivityName = "mycompany.simple.Other.OtherWorkflow"
)

mycompany.simple.Other activity names

View Source 
const (
	OtherWorkflowWorkflowName = "mycompany.simple.Other.OtherWorkflow"
)

mycompany.simple.Other workflow names

View Source 
const SimpleTaskQueue = "my-task-queue"

SimpleTaskQueue is the default task-queue for a mycompany.simple.Simple worker

View Source 
const (
	SomeUpdate1UpdateName = "mycompany.simple.Simple.SomeUpdate1"
)

mycompany.simple.Simple update names

View Source 
const (
	WhatWorkflowName = "mycompany.simple.Ignored.What"
)

mycompany.simple.Ignored workflow names

Variables

View Source 
var (
	OtherEnum_name = map[int32]string{
		0: "OTHER_UNSPECIFIED",
		1: "OTHER_FOO",
		2: "OTHER_BAR",
	}
	OtherEnum_value = map[string]int32{
		"OTHER_UNSPECIFIED": 0,
		"OTHER_FOO":         1,
		"OTHER_BAR":         2,
	}
)

Enum value maps for OtherEnum.

View Source 
var (
	SomeWorkflow1Idexpression = expression.MustParseExpression("some-workflow-1/${! id }/${! uuid_v4() }")
	SomeWorkflow2Idexpression = expression.MustParseExpression("some-workflow-2/${! uuid_v4() }")
	SomeWorkflow3Idexpression = expression.MustParseExpression("some-workflow-3/${! id }/${! requestVal }")
	SomeWorkflow4Idexpression = expression.MustParseExpression("some-workflow-4/${! uuid_v4() }")
)

mycompany.simple.Simple workflow id expressions

View Source 
var (
	// SomeWorkflow1 does some workflow thing.
	SomeWorkflow1Function func(workflow.Context, *SomeWorkflow1Request) (*SomeWorkflow1Response, error)
	// SomeWorkflow2 does some workflow thing.
	SomeWorkflow2Function func(workflow.Context) error
	// SomeWorkflow3 does some workflow thing.
	// Deprecated: Use SomeWorkflow2 instead.
	SomeWorkflow3Function func(workflow.Context, *SomeWorkflow3Request) error
	// SomeWorkflow4 retrieves a paginated list of items
	SomeWorkflow4Function func(workflow.Context, *v1.PaginatedRequest) (*v1.PaginatedResponse, error)
)

Reference to generated workflow functions

View Source 
var (
	// SomeDeprecatedWorkflow1 does something
	//
	// Deprecated: Do not use.
	SomeDeprecatedWorkflow1Function func(workflow.Context, *SomeDeprecatedMessage) (*SomeDeprecatedMessage, error)
	// SomeDeprecatedWorkflow2 does something else
	//
	// Deprecated: a custom workflow deprecation message.
	SomeDeprecatedWorkflow2Function func(workflow.Context, *SomeDeprecatedMessage) (*SomeDeprecatedMessage, error)
)

Reference to generated workflow functions

View Source 
var File_test_simple_v1_simple_proto protoreflect.FileDescriptor
View Source 
var (
	OtherUpdateIdexpression = expression.MustParseExpression("other-update/${!uuid_v4()}")
)

mycompany.simple.Other update id expressions

View Source 
var (
	// OtherWorkflowFunction implements a "mycompany.simple.Other.OtherWorkflow" workflow
	OtherWorkflowFunction func(workflow.Context, *OtherWorkflowRequest) (*OtherWorkflowResponse, error)
)

Reference to generated workflow functions

View Source 
var (
	OtherWorkflowIdexpression = expression.MustParseExpression("other-workflow/${!uuid_v4()}")
)

mycompany.simple.Other workflow id expressions

View Source 
var (
	SomeUpdate1Idexpression = expression.MustParseExpression("some-update/${! requestVal.not_empty().catch(\"default\").slug() }")
)

mycompany.simple.Simple update id expressions

View Source 
var (
	// WhatFunction implements a "mycompany.simple.Ignored.What" workflow
	WhatFunction func(workflow.Context, *WhatRequest) error
)

Reference to generated workflow functions

View Source 
var (
	WhatIdexpression = expression.MustParseExpression("what/${!ksuid()}")
)

mycompany.simple.Ignored workflow id expressions

Functions

func NewDeprecatedCli 

func NewDeprecatedCli(options ...*DeprecatedCliOptions) (*v2.App, error)

NewDeprecatedCli initializes a cli for a(n) mycompany.simple.Deprecated service

func NewDeprecatedCliCommand 

func NewDeprecatedCliCommand(options ...*DeprecatedCliOptions) (*v2.Command, error)

NewDeprecatedCliCommand initializes a cli command for a mycompany.simple.Deprecated service with subcommands for each query, signal, update, and workflow

func NewDeprecatedClientOptions 

func NewDeprecatedClientOptions() *deprecatedClientOptions

NewDeprecatedClientOptions initializes a new deprecatedClientOptions value

func NewIgnoredClientOptions 

func NewIgnoredClientOptions() *ignoredClientOptions

NewIgnoredClientOptions initializes a new ignoredClientOptions value

func NewOnlyActivitiesCli 

func NewOnlyActivitiesCli(options ...*OnlyActivitiesCliOptions) (*v2.App, error)

NewOnlyActivitiesCli initializes a cli for a(n) mycompany.simple.OnlyActivities service

func NewOnlyActivitiesCliCommand 

func NewOnlyActivitiesCliCommand(options ...*OnlyActivitiesCliOptions) (*v2.Command, error)

NewOnlyActivitiesCliCommand initializes a cli command for a mycompany.simple.OnlyActivities service with subcommands for each query, signal, update, and workflow

func NewOnlyActivitiesClientOptions 

func NewOnlyActivitiesClientOptions() *onlyActivitiesClientOptions

NewOnlyActivitiesClientOptions initializes a new onlyActivitiesClientOptions value

func NewOtherCli 

func NewOtherCli(options ...*OtherCliOptions) (*v2.App, error)

NewOtherCli initializes a cli for a(n) mycompany.simple.Other service

func NewOtherCliCommand 

func NewOtherCliCommand(options ...*OtherCliOptions) (*v2.Command, error)

NewOtherCliCommand initializes a cli command for a mycompany.simple.Other service with subcommands for each query, signal, update, and workflow

func NewOtherClientOptions 

func NewOtherClientOptions() *otherClientOptions

NewOtherClientOptions initializes a new otherClientOptions value

func NewSimpleCli 

func NewSimpleCli(options ...*SimpleCliOptions) (*v2.App, error)

NewSimpleCli initializes a cli for a(n) mycompany.simple.Simple service

func NewSimpleCliCommand 

func NewSimpleCliCommand(options ...*SimpleCliOptions) (*v2.Command, error)

NewSimpleCliCommand initializes a cli command for a mycompany.simple.Simple service with subcommands for each query, signal, update, and workflow

func NewSimpleClientOptions 

func NewSimpleClientOptions() *simpleClientOptions

NewSimpleClientOptions initializes a new simpleClientOptions value

func OtherSignalExternal 

func OtherSignalExternal(ctx workflow.Context, workflowID string, runID string, req *OtherSignalRequest) error

OtherSignalExternal sends a(n) mycompany.simple.Other.OtherSignal signal to an existing workflow

func OtherSignalExternalAsync 

func OtherSignalExternalAsync(ctx workflow.Context, workflowID string, runID string, req *OtherSignalRequest) workflow.Future

OtherSignalExternalAsync sends a(n) mycompany.simple.Other.OtherSignal signal to an existing workflow

func RegisterDeprecatedActivities 

func RegisterDeprecatedActivities(r worker.ActivityRegistry, activities DeprecatedActivities)

RegisterDeprecatedActivities registers activities with a worker

func RegisterDeprecatedWorkflows 

func RegisterDeprecatedWorkflows(r worker.WorkflowRegistry, workflows DeprecatedWorkflows)

RegisterDeprecatedWorkflows registers mycompany.simple.Deprecated workflows with the given worker

func RegisterIgnoredActivities 

func RegisterIgnoredActivities(r worker.ActivityRegistry, activities IgnoredActivities)

RegisterIgnoredActivities registers activities with a worker

func RegisterIgnoredWorkflows 

func RegisterIgnoredWorkflows(r worker.WorkflowRegistry, workflows IgnoredWorkflows)

RegisterIgnoredWorkflows registers mycompany.simple.Ignored workflows with the given worker

func RegisterLonelyActivity1Activity 

func RegisterLonelyActivity1Activity(r worker.ActivityRegistry, fn func(context.Context, *LonelyActivity1Request) (*LonelyActivity1Response, error))

RegisterLonelyActivity1Activity registers a mycompany.simple.OnlyActivities.LonelyActivity1 activity

func RegisterOnlyActivitiesActivities 

func RegisterOnlyActivitiesActivities(r worker.ActivityRegistry, activities OnlyActivitiesActivities)

RegisterOnlyActivitiesActivities registers activities with a worker

func RegisterOnlyActivitiesWorkflows 

func RegisterOnlyActivitiesWorkflows(r worker.WorkflowRegistry, workflows OnlyActivitiesWorkflows)

RegisterOnlyActivitiesWorkflows registers mycompany.simple.OnlyActivities workflows with the given worker

func RegisterOtherActivities 

func RegisterOtherActivities(r worker.ActivityRegistry, activities OtherActivities)

RegisterOtherActivities registers activities with a worker

func RegisterOtherWorkflowActivity 

func RegisterOtherWorkflowActivity(r worker.ActivityRegistry, fn func(context.Context, *OtherWorkflowRequest) (*OtherWorkflowResponse, error))

RegisterOtherWorkflowActivity registers a mycompany.simple.Other.OtherWorkflow activity

func RegisterOtherWorkflowWorkflow 

func RegisterOtherWorkflowWorkflow(r worker.WorkflowRegistry, wf func(workflow.Context, *OtherWorkflowWorkflowInput) (OtherWorkflowWorkflow, error))

RegisterOtherWorkflowWorkflow registers a mycompany.simple.Other.OtherWorkflow workflow with the given worker

func RegisterOtherWorkflows 

func RegisterOtherWorkflows(r worker.WorkflowRegistry, workflows OtherWorkflows)

RegisterOtherWorkflows registers mycompany.simple.Other workflows with the given worker

func RegisterSimpleActivities 

func RegisterSimpleActivities(r worker.ActivityRegistry, activities SimpleActivities)

RegisterSimpleActivities registers activities with a worker

func RegisterSimpleWorkflows 

func RegisterSimpleWorkflows(r worker.WorkflowRegistry, workflows SimpleWorkflows)

RegisterSimpleWorkflows registers mycompany.simple.Simple workflows with the given worker

func RegisterSomeActivity1Activity 

func RegisterSomeActivity1Activity(r worker.ActivityRegistry, fn func(context.Context) error)

RegisterSomeActivity1Activity registers a mycompany.simple.SomeActivity1 activity

func RegisterSomeActivity2Activity 

func RegisterSomeActivity2Activity(r worker.ActivityRegistry, fn func(context.Context, *SomeActivity2Request) error)

RegisterSomeActivity2Activity registers a mycompany.simple.Simple.SomeActivity2 activity

func RegisterSomeActivity3Activity 

func RegisterSomeActivity3Activity(r worker.ActivityRegistry, fn func(context.Context, *SomeActivity3Request) (*SomeActivity3Response, error))

RegisterSomeActivity3Activity registers a mycompany.simple.Simple.SomeActivity3 activity

func RegisterSomeActivity4Activity added in v1.13.0 

func RegisterSomeActivity4Activity(r worker.ActivityRegistry, fn func(context.Context) error)

RegisterSomeActivity4Activity registers a mycompany.simple.Simple.SomeActivity4 activity

func RegisterSomeDeprecatedActivity1Activity 

func RegisterSomeDeprecatedActivity1Activity(r worker.ActivityRegistry, fn func(context.Context, *SomeDeprecatedMessage) (*SomeDeprecatedMessage, error))

RegisterSomeDeprecatedActivity1Activity registers a mycompany.simple.Deprecated.SomeDeprecatedActivity1 activity

func RegisterSomeDeprecatedActivity2Activity 

func RegisterSomeDeprecatedActivity2Activity(r worker.ActivityRegistry, fn func(context.Context, *SomeDeprecatedMessage) (*SomeDeprecatedMessage, error))

RegisterSomeDeprecatedActivity2Activity registers a mycompany.simple.Deprecated.SomeDeprecatedActivity2 activity

func RegisterSomeDeprecatedWorkflow1Workflow 

func RegisterSomeDeprecatedWorkflow1Workflow(r worker.WorkflowRegistry, wf func(workflow.Context, *SomeDeprecatedWorkflow1WorkflowInput) (SomeDeprecatedWorkflow1Workflow, error))

RegisterSomeDeprecatedWorkflow1Workflow registers a mycompany.simple.Deprecated.SomeDeprecatedWorkflow1 workflow with the given worker

func RegisterSomeDeprecatedWorkflow2Workflow 

func RegisterSomeDeprecatedWorkflow2Workflow(r worker.WorkflowRegistry, wf func(workflow.Context, *SomeDeprecatedWorkflow2WorkflowInput) (SomeDeprecatedWorkflow2Workflow, error))

RegisterSomeDeprecatedWorkflow2Workflow registers a mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow with the given worker

func RegisterSomeSignal1Activity 

func RegisterSomeSignal1Activity(r worker.ActivityRegistry, fn func(context.Context) error)

RegisterSomeSignal1Activity registers a mycompany.simple.Simple.SomeSignal1 activity

func RegisterSomeSignal2Activity 

func RegisterSomeSignal2Activity(r worker.ActivityRegistry, fn func(context.Context, *SomeSignal2Request) error)

RegisterSomeSignal2Activity registers a mycompany.simple.Simple.SomeSignal2 activity

func RegisterSomeSignal3Activity 

func RegisterSomeSignal3Activity(r worker.ActivityRegistry, fn func(context.Context, *SomeSignal3Request) (*SomeSignal3Response, error))

RegisterSomeSignal3Activity registers a mycompany.simple.Simple.SomeSignal3 activity

func RegisterSomeUpdate1Activity 

func RegisterSomeUpdate1Activity(r worker.ActivityRegistry, fn func(context.Context, *SomeUpdate1Request) (*SomeUpdate1Response, error))

RegisterSomeUpdate1Activity registers a mycompany.simple.Simple.SomeUpdate1 activity

func RegisterSomeWorkflow1Workflow 

func RegisterSomeWorkflow1Workflow(r worker.WorkflowRegistry, wf func(workflow.Context, *SomeWorkflow1WorkflowInput) (SomeWorkflow1Workflow, error))

RegisterSomeWorkflow1Workflow registers a mycompany.simple.Simple.SomeWorkflow1 workflow with the given worker

func RegisterSomeWorkflow2Workflow 

func RegisterSomeWorkflow2Workflow(r worker.WorkflowRegistry, wf func(workflow.Context, *SomeWorkflow2WorkflowInput) (SomeWorkflow2Workflow, error))

RegisterSomeWorkflow2Workflow registers a mycompany.simple.Simple.SomeWorkflow2 workflow with the given worker

func RegisterSomeWorkflow3Workflow 

func RegisterSomeWorkflow3Workflow(r worker.WorkflowRegistry, wf func(workflow.Context, *SomeWorkflow3WorkflowInput) (SomeWorkflow3Workflow, error))

RegisterSomeWorkflow3Workflow registers a mycompany.simple.Simple.SomeWorkflow3 workflow with the given worker

func RegisterSomeWorkflow4Workflow added in v1.13.2 

func RegisterSomeWorkflow4Workflow(r worker.WorkflowRegistry, wf func(workflow.Context, *SomeWorkflow4WorkflowInput) (SomeWorkflow4Workflow, error))

RegisterSomeWorkflow4Workflow registers a mycompany.simple.Simple.SomeWorkflow4 workflow with the given worker

func RegisterWhatWorkflow 

func RegisterWhatWorkflow(r worker.WorkflowRegistry, wf func(workflow.Context, *WhatWorkflowInput) (WhatWorkflow, error))

RegisterWhatWorkflow registers a mycompany.simple.Ignored.What workflow with the given worker

func SomeActivity1 

func SomeActivity1(ctx workflow.Context, options ...*SomeActivity1ActivityOptions) error

SomeActivity1 does some activity thing.

func SomeActivity1Local 

func SomeActivity1Local(ctx workflow.Context, options ...*SomeActivity1LocalActivityOptions) error

SomeActivity1 does some activity thing.

func SomeActivity2 

func SomeActivity2(ctx workflow.Context, req *SomeActivity2Request, options ...*SomeActivity2ActivityOptions) error

SomeActivity2 does some activity thing.

func SomeActivity2Local 

func SomeActivity2Local(ctx workflow.Context, req *SomeActivity2Request, options ...*SomeActivity2LocalActivityOptions) error

SomeActivity2 does some activity thing.

func SomeActivity4 added in v1.13.0 

func SomeActivity4(ctx workflow.Context, options ...*SomeActivity4ActivityOptions) error

SomeActivity4 does some activity thing.

func SomeActivity4Local added in v1.13.0 

func SomeActivity4Local(ctx workflow.Context, options ...*SomeActivity4LocalActivityOptions) error

SomeActivity4 does some activity thing.

func SomeDeprecatedSignal1External deprecated 

func SomeDeprecatedSignal1External(ctx workflow.Context, workflowID string, runID string, req *SomeDeprecatedMessage) error

SomeDeprecatedSignal1 does something else

Deprecated: Do not use.

func SomeDeprecatedSignal1ExternalAsync deprecated 

func SomeDeprecatedSignal1ExternalAsync(ctx workflow.Context, workflowID string, runID string, req *SomeDeprecatedMessage) workflow.Future

SomeDeprecatedSignal1 does something else

Deprecated: Do not use.

func SomeDeprecatedSignal2External deprecated 

func SomeDeprecatedSignal2External(ctx workflow.Context, workflowID string, runID string, req *SomeDeprecatedMessage) error

SomeDeprecatedSignal2 does something else

Deprecated: a custom signal deprecation message.

func SomeDeprecatedSignal2ExternalAsync deprecated 

func SomeDeprecatedSignal2ExternalAsync(ctx workflow.Context, workflowID string, runID string, req *SomeDeprecatedMessage) workflow.Future

SomeDeprecatedSignal2 does something else

Deprecated: a custom signal deprecation message.

func SomeSignal1 

func SomeSignal1(ctx workflow.Context, options ...*SomeSignal1ActivityOptions) error

SomeSignal1 is a signal.

func SomeSignal1External 

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

SomeSignal1 is a signal.

func SomeSignal1ExternalAsync 

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

SomeSignal1 is a signal.

func SomeSignal1Local 

func SomeSignal1Local(ctx workflow.Context, options ...*SomeSignal1LocalActivityOptions) error

SomeSignal1 is a signal.

func SomeSignal2 

func SomeSignal2(ctx workflow.Context, req *SomeSignal2Request, options ...*SomeSignal2ActivityOptions) error

SomeSignal2 is a signal.

func SomeSignal2External 

func SomeSignal2External(ctx workflow.Context, workflowID string, runID string, req *SomeSignal2Request) error

SomeSignal2 is a signal.

func SomeSignal2ExternalAsync 

func SomeSignal2ExternalAsync(ctx workflow.Context, workflowID string, runID string, req *SomeSignal2Request) workflow.Future

SomeSignal2 is a signal.

func SomeSignal2Local 

func SomeSignal2Local(ctx workflow.Context, req *SomeSignal2Request, options ...*SomeSignal2LocalActivityOptions) error

SomeSignal2 is a signal.

func SomeSignal3External 

func SomeSignal3External(ctx workflow.Context, workflowID string, runID string, req *SomeSignal3Request) error

SomeSignal3 is a signal.

func SomeSignal3ExternalAsync 

func SomeSignal3ExternalAsync(ctx workflow.Context, workflowID string, runID string, req *SomeSignal3Request) workflow.Future

SomeSignal3 is a signal.

func SomeWorkflow2Child 

func SomeWorkflow2Child(ctx workflow.Context, options ...*SomeWorkflow2ChildOptions) error

SomeWorkflow2 does some workflow thing.

func SomeWorkflow3Child 

func SomeWorkflow3Child(ctx workflow.Context, req *SomeWorkflow3Request, options ...*SomeWorkflow3ChildOptions) error

SomeWorkflow3 does some workflow thing. Deprecated: Use SomeWorkflow2 instead.

func SomeWorkflow4Child added in v1.13.2 

func SomeWorkflow4Child(ctx workflow.Context, req *v1.PaginatedRequest, options ...*SomeWorkflow4ChildOptions) (*v1.PaginatedResponse, error)

SomeWorkflow4 retrieves a paginated list of items

func UnmarshalCliFlagsToPaginatedRequest added in v1.13.2 

func UnmarshalCliFlagsToPaginatedRequest(cmd *v2.Context) (*v1.PaginatedRequest, error)

UnmarshalCliFlagsToPaginatedRequest unmarshals a PaginatedRequest from command line flags

func WhatChild 

func WhatChild(ctx workflow.Context, req *WhatRequest, options ...*WhatChildOptions) error

WhatChild executes a child mycompany.simple.Ignored.What workflow and blocks until error or response received

func WithDeprecatedSchemeTypes 

func WithDeprecatedSchemeTypes() scheme.Option

WithDeprecatedSchemeTypes registers all Deprecated protobuf types with the given scheme

func WithIgnoredSchemeTypes 

func WithIgnoredSchemeTypes() scheme.Option

WithIgnoredSchemeTypes registers all Ignored protobuf types with the given scheme

func WithOnlyActivitiesSchemeTypes 

func WithOnlyActivitiesSchemeTypes() scheme.Option

WithOnlyActivitiesSchemeTypes registers all OnlyActivities protobuf types with the given scheme

func WithOtherSchemeTypes 

func WithOtherSchemeTypes() scheme.Option

WithOtherSchemeTypes registers all Other protobuf types with the given scheme

func WithSimpleSchemeTypes 

func WithSimpleSchemeTypes() scheme.Option

WithSimpleSchemeTypes registers all Simple protobuf types with the given scheme

Types

type DeprecatedActivities 

type DeprecatedActivities interface {
	// SomeDeprecatedActivity1 does something
	//
	// Deprecated: Do not use.
	SomeDeprecatedActivity1(ctx context.Context, req *SomeDeprecatedMessage) (*SomeDeprecatedMessage, error)

	// SomeDeprecatedActivity2 does something else
	//
	// Deprecated: a custom activity deprecation message.
	SomeDeprecatedActivity2(ctx context.Context, req *SomeDeprecatedMessage) (*SomeDeprecatedMessage, error)
}

DeprecatedActivities describes available worker activities

type DeprecatedCliOptions 

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

DeprecatedCliOptions describes runtime configuration for mycompany.simple.Deprecated cli

func NewDeprecatedCliOptions 

func NewDeprecatedCliOptions() *DeprecatedCliOptions

NewDeprecatedCliOptions initializes a new DeprecatedCliOptions value

func (*DeprecatedCliOptions) WithAfter 

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

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

func (*DeprecatedCliOptions) WithBefore 

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

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

func (*DeprecatedCliOptions) WithClient 

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

WithClient provides a Temporal client factory for use by commands

func (*DeprecatedCliOptions) WithWorker 

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

WithWorker provides an method for initializing a worker

type DeprecatedClient 

type DeprecatedClient interface {
	// SomeDeprecatedWorkflow1 does something
	//
	// Deprecated: Do not use.
	SomeDeprecatedWorkflow1(ctx context.Context, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow1Options) (*SomeDeprecatedMessage, error)

	// SomeDeprecatedWorkflow1Async starts a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow1 workflow and returns a handle to the workflow run
	//
	// Deprecated: Do not use.
	SomeDeprecatedWorkflow1Async(ctx context.Context, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow1Options) (SomeDeprecatedWorkflow1Run, error)

	// GetSomeDeprecatedWorkflow1 retrieves a handle to an existing mycompany.simple.Deprecated.SomeDeprecatedWorkflow1 workflow execution
	//
	// Deprecated: Do not use.
	GetSomeDeprecatedWorkflow1(ctx context.Context, workflowID string, runID string) SomeDeprecatedWorkflow1Run

	// SomeDeprecatedWorkflow1WithSomeDeprecatedSignal1 sends a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal1 signal to a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow1 workflow, starting it if necessary, and blocks until workflow completion
	//
	// Deprecated: Do not use.
	SomeDeprecatedWorkflow1WithSomeDeprecatedSignal1(ctx context.Context, req *SomeDeprecatedMessage, signal *SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow1Options) (*SomeDeprecatedMessage, error)

	// SomeDeprecatedWorkflow1WithSomeDeprecatedSignal1Async sends a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal1 signal to a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow1 workflow, starting it if necessary, and returns a handle to the workflow execution
	//
	// Deprecated: Do not use.
	SomeDeprecatedWorkflow1WithSomeDeprecatedSignal1Async(ctx context.Context, req *SomeDeprecatedMessage, signal *SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow1Options) (SomeDeprecatedWorkflow1Run, error)

	// SomeDeprecatedWorkflow2 does something else
	//
	// Deprecated: a custom workflow deprecation message.
	SomeDeprecatedWorkflow2(ctx context.Context, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow2Options) (*SomeDeprecatedMessage, error)

	// SomeDeprecatedWorkflow2Async starts a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow and returns a handle to the workflow run
	//
	// Deprecated: Do not use.
	SomeDeprecatedWorkflow2Async(ctx context.Context, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow2Options) (SomeDeprecatedWorkflow2Run, error)

	// GetSomeDeprecatedWorkflow2 retrieves a handle to an existing mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow execution
	//
	// Deprecated: Do not use.
	GetSomeDeprecatedWorkflow2(ctx context.Context, workflowID string, runID string) SomeDeprecatedWorkflow2Run

	// SomeDeprecatedWorkflow2WithSomeDeprecatedSignal2 sends a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal2 signal to a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow, starting it if necessary, and blocks until workflow completion
	//
	// Deprecated: Do not use.
	SomeDeprecatedWorkflow2WithSomeDeprecatedSignal2(ctx context.Context, req *SomeDeprecatedMessage, signal *SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow2Options) (*SomeDeprecatedMessage, error)

	// SomeDeprecatedWorkflow2WithSomeDeprecatedSignal2Async sends a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal2 signal to a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow, starting it if necessary, and returns a handle to the workflow execution
	//
	// Deprecated: Do not use.
	SomeDeprecatedWorkflow2WithSomeDeprecatedSignal2Async(ctx context.Context, req *SomeDeprecatedMessage, signal *SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow2Options) (SomeDeprecatedWorkflow2Run, error)

	// 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

	// SomeDeprecatedQuery1 does something else
	//
	// Deprecated: Do not use.
	SomeDeprecatedQuery1(ctx context.Context, workflowID string, runID string, query *SomeDeprecatedMessage) (*SomeDeprecatedMessage, error)

	// SomeDeprecatedQuery2 does something else
	//
	// Deprecated: a custom query deprecation message.
	SomeDeprecatedQuery2(ctx context.Context, workflowID string, runID string, query *SomeDeprecatedMessage) (*SomeDeprecatedMessage, error)

	// SomeDeprecatedSignal1 does something else
	//
	// Deprecated: Do not use.
	SomeDeprecatedSignal1(ctx context.Context, workflowID string, runID string, signal *SomeDeprecatedMessage) error

	// SomeDeprecatedSignal2 does something else
	//
	// Deprecated: a custom signal deprecation message.
	SomeDeprecatedSignal2(ctx context.Context, workflowID string, runID string, signal *SomeDeprecatedMessage) error

	// SomeDeprecatedUpdate1 does something else
	//
	// Deprecated: Do not use.
	SomeDeprecatedUpdate1(ctx context.Context, workflowID string, runID string, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedUpdate1Options) (*SomeDeprecatedMessage, error)

	// SomeDeprecatedUpdate1Async starts a(n) mycompany.simple.Deprecated.SomeDeprecatedUpdate1 update and returns a handle to the workflow update
	//
	// Deprecated: Do not use.
	SomeDeprecatedUpdate1Async(ctx context.Context, workflowID string, runID string, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedUpdate1Options) (SomeDeprecatedUpdate1Handle, error)

	// GetSomeDeprecatedUpdate1 retrieves a handle to an existing mycompany.simple.Deprecated.SomeDeprecatedUpdate1 update
	//
	// Deprecated: Do not use.
	GetSomeDeprecatedUpdate1(ctx context.Context, req client.GetWorkflowUpdateHandleOptions) (SomeDeprecatedUpdate1Handle, error)

	// SomeDeprecatedUpdate2 does something else
	//
	// Deprecated: a custom signal deprecation message.
	SomeDeprecatedUpdate2(ctx context.Context, workflowID string, runID string, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedUpdate2Options) (*SomeDeprecatedMessage, error)

	// SomeDeprecatedUpdate2Async starts a(n) mycompany.simple.Deprecated.SomeDeprecatedUpdate2 update and returns a handle to the workflow update
	//
	// Deprecated: Do not use.
	SomeDeprecatedUpdate2Async(ctx context.Context, workflowID string, runID string, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedUpdate2Options) (SomeDeprecatedUpdate2Handle, error)

	// GetSomeDeprecatedUpdate2 retrieves a handle to an existing mycompany.simple.Deprecated.SomeDeprecatedUpdate2 update
	//
	// Deprecated: Do not use.
	GetSomeDeprecatedUpdate2(ctx context.Context, req client.GetWorkflowUpdateHandleOptions) (SomeDeprecatedUpdate2Handle, error)
}

DeprecatedClient describes a client for a(n) mycompany.simple.Deprecated worker

func NewDeprecatedClient 

func NewDeprecatedClient(c client.Client, options ...*deprecatedClientOptions) DeprecatedClient

NewDeprecatedClient initializes a new mycompany.simple.Deprecated client

func NewDeprecatedClientWithOptions 

func NewDeprecatedClientWithOptions(c client.Client, opts client.Options, options ...*deprecatedClientOptions) (DeprecatedClient, error)

NewDeprecatedClientWithOptions initializes a new Deprecated client with the given options

type DeprecatedWorkflowFunctions added in v1.12.0 

type DeprecatedWorkflowFunctions interface {
	// SomeDeprecatedWorkflow1 does something
	//
	// Deprecated: Do not use.
	SomeDeprecatedWorkflow1(workflow.Context, *SomeDeprecatedMessage) (*SomeDeprecatedMessage, error)
	// SomeDeprecatedWorkflow2 does something else
	//
	// Deprecated: a custom workflow deprecation message.
	SomeDeprecatedWorkflow2(workflow.Context, *SomeDeprecatedMessage) (*SomeDeprecatedMessage, error)
}

DeprecatedWorkflowFunctions describes a mockable dependency for inlining workflows within other workflows

func NewDeprecatedWorkflowFunctions added in v1.12.0 

func NewDeprecatedWorkflowFunctions() DeprecatedWorkflowFunctions

type DeprecatedWorkflows 

type DeprecatedWorkflows interface {
	// SomeDeprecatedWorkflow1 does something
	//
	// Deprecated: Do not use.
	SomeDeprecatedWorkflow1(ctx workflow.Context, input *SomeDeprecatedWorkflow1WorkflowInput) (SomeDeprecatedWorkflow1Workflow, error)

	// SomeDeprecatedWorkflow2 does something else
	//
	// Deprecated: a custom workflow deprecation message.
	SomeDeprecatedWorkflow2(ctx workflow.Context, input *SomeDeprecatedWorkflow2WorkflowInput) (SomeDeprecatedWorkflow2Workflow, error)
}

DeprecatedWorkflows provides methods for initializing new mycompany.simple.Deprecated workflow values

type Foo 

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

func (*Foo) Descriptor deprecated 

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

Deprecated: Use Foo.ProtoReflect.Descriptor instead.

func (*Foo) GetFoo 

func (x *Foo) GetFoo() string

func (*Foo) ProtoMessage 

func (*Foo) ProtoMessage()

func (*Foo) ProtoReflect 

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

func (*Foo) Reset 

func (x *Foo) Reset()

func (*Foo) String 

func (x *Foo) String() string

type IgnoredActivities 

type IgnoredActivities interface{}

IgnoredActivities describes available worker activities

type IgnoredClient 

type IgnoredClient interface {
	// What executes a(n) mycompany.simple.Ignored.What workflow and blocks until error or response received
	What(ctx context.Context, req *WhatRequest, opts ...*WhatOptions) error

	// WhatAsync starts a(n) mycompany.simple.Ignored.What workflow and returns a handle to the workflow run
	WhatAsync(ctx context.Context, req *WhatRequest, opts ...*WhatOptions) (WhatRun, error)

	// GetWhat retrieves a handle to an existing mycompany.simple.Ignored.What workflow execution
	GetWhat(ctx context.Context, workflowID string, runID string) WhatRun

	// 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
}

IgnoredClient describes a client for a(n) mycompany.simple.Ignored worker

func NewIgnoredClient 

func NewIgnoredClient(c client.Client, options ...*ignoredClientOptions) IgnoredClient

NewIgnoredClient initializes a new mycompany.simple.Ignored client

func NewIgnoredClientWithOptions 

func NewIgnoredClientWithOptions(c client.Client, opts client.Options, options ...*ignoredClientOptions) (IgnoredClient, error)

NewIgnoredClientWithOptions initializes a new Ignored client with the given options

type IgnoredWorkflowFunctions added in v1.12.0 

type IgnoredWorkflowFunctions interface {
	// What executes a "mycompany.simple.Ignored.What" workflow inline
	What(workflow.Context, *WhatRequest) error
}

IgnoredWorkflowFunctions describes a mockable dependency for inlining workflows within other workflows

func NewIgnoredWorkflowFunctions added in v1.12.0 

func NewIgnoredWorkflowFunctions() IgnoredWorkflowFunctions

type IgnoredWorkflows 

type IgnoredWorkflows interface {
	// What initializes a new a(n) WhatWorkflow implementation
	What(ctx workflow.Context, input *WhatWorkflowInput) (WhatWorkflow, error)
}

IgnoredWorkflows provides methods for initializing new mycompany.simple.Ignored workflow values

type LonelyActivity1ActivityOptions 

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

LonelyActivity1ActivityOptions provides configuration for a(n) mycompany.simple.OnlyActivities.LonelyActivity1 activity

func NewLonelyActivity1ActivityOptions 

func NewLonelyActivity1ActivityOptions() *LonelyActivity1ActivityOptions

NewLonelyActivity1ActivityOptions initializes a new LonelyActivity1ActivityOptions value

func (*LonelyActivity1ActivityOptions) Build added in v1.13.0 

func (o *LonelyActivity1ActivityOptions) 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 (*LonelyActivity1ActivityOptions) WithActivityOptions 

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

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

func (*LonelyActivity1ActivityOptions) WithHeartbeatTimeout added in v1.13.0 

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

WithHeartbeatTimeout sets the HeartbeatTimeout value

func (*LonelyActivity1ActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*LonelyActivity1ActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*LonelyActivity1ActivityOptions) WithScheduleToStartTimeout added in v1.13.0 

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

WithScheduleToStartTimeout sets the ScheduleToStartTimeout value

func (*LonelyActivity1ActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

func (*LonelyActivity1ActivityOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*LonelyActivity1ActivityOptions) WithWaitForCancellation added in v1.13.0 

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

WithWaitForCancellation sets the WaitForCancellation value

type LonelyActivity1Future 

type LonelyActivity1Future struct {
	Future workflow.Future
}

LonelyActivity1Future describes a(n) mycompany.simple.OnlyActivities.LonelyActivity1 activity execution

func LonelyActivity1Async 

func LonelyActivity1Async(ctx workflow.Context, req *LonelyActivity1Request, options ...*LonelyActivity1ActivityOptions) *LonelyActivity1Future

LonelyActivity1Async executes a(n) mycompany.simple.OnlyActivities.LonelyActivity1 activity (asynchronously)

func LonelyActivity1LocalAsync 

func LonelyActivity1LocalAsync(ctx workflow.Context, req *LonelyActivity1Request, options ...*LonelyActivity1LocalActivityOptions) *LonelyActivity1Future

LonelyActivity1LocalAsync executes a(n) mycompany.simple.OnlyActivities.LonelyActivity1 activity (asynchronously, locally)

func (*LonelyActivity1Future) Get 

func (f *LonelyActivity1Future) Get(ctx workflow.Context) (*LonelyActivity1Response, error)

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

func (*LonelyActivity1Future) Select 

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

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

type LonelyActivity1LocalActivityOptions 

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

LonelyActivity1LocalActivityOptions provides configuration for a(n) mycompany.simple.OnlyActivities.LonelyActivity1 activity

func NewLonelyActivity1LocalActivityOptions 

func NewLonelyActivity1LocalActivityOptions() *LonelyActivity1LocalActivityOptions

NewLonelyActivity1LocalActivityOptions initializes a new LonelyActivity1LocalActivityOptions value

func (*LonelyActivity1LocalActivityOptions) Build added in v1.13.0 

func (o *LonelyActivity1LocalActivityOptions) 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 (*LonelyActivity1LocalActivityOptions) Local 

func (o *LonelyActivity1LocalActivityOptions) Local(fn func(context.Context, *LonelyActivity1Request) (*LonelyActivity1Response, error)) *LonelyActivity1LocalActivityOptions

Local specifies a custom mycompany.simple.OnlyActivities.LonelyActivity1 implementation

func (*LonelyActivity1LocalActivityOptions) WithLocalActivityOptions 

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

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

func (*LonelyActivity1LocalActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*LonelyActivity1LocalActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*LonelyActivity1LocalActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

type LonelyActivity1Request 

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

func (*LonelyActivity1Request) Descriptor deprecated 

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

Deprecated: Use LonelyActivity1Request.ProtoReflect.Descriptor instead.

func (*LonelyActivity1Request) ProtoMessage 

func (*LonelyActivity1Request) ProtoMessage()

func (*LonelyActivity1Request) ProtoReflect 

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

func (*LonelyActivity1Request) Reset 

func (x *LonelyActivity1Request) Reset()

func (*LonelyActivity1Request) String 

func (x *LonelyActivity1Request) String() string

type LonelyActivity1Response 

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

func LonelyActivity1 

func LonelyActivity1(ctx workflow.Context, req *LonelyActivity1Request, options ...*LonelyActivity1ActivityOptions) (*LonelyActivity1Response, error)

LonelyActivity1 executes a(n) mycompany.simple.OnlyActivities.LonelyActivity1 activity

func LonelyActivity1Local 

func LonelyActivity1Local(ctx workflow.Context, req *LonelyActivity1Request, options ...*LonelyActivity1LocalActivityOptions) (*LonelyActivity1Response, error)

LonelyActivity1Local executes a(n) mycompany.simple.OnlyActivities.LonelyActivity1 activity (locally)

func (*LonelyActivity1Response) Descriptor deprecated 

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

Deprecated: Use LonelyActivity1Response.ProtoReflect.Descriptor instead.

func (*LonelyActivity1Response) ProtoMessage 

func (*LonelyActivity1Response) ProtoMessage()

func (*LonelyActivity1Response) ProtoReflect 

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

func (*LonelyActivity1Response) Reset 

func (x *LonelyActivity1Response) Reset()

func (*LonelyActivity1Response) String 

func (x *LonelyActivity1Response) String() string

type OnlyActivitiesActivities 

type OnlyActivitiesActivities interface {
	// mycompany.simple.OnlyActivities.LonelyActivity1 implements a(n) mycompany.simple.OnlyActivities.LonelyActivity1 activity definition
	LonelyActivity1(ctx context.Context, req *LonelyActivity1Request) (*LonelyActivity1Response, error)
}

OnlyActivitiesActivities describes available worker activities

type OnlyActivitiesCliOptions 

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

OnlyActivitiesCliOptions describes runtime configuration for mycompany.simple.OnlyActivities cli

func NewOnlyActivitiesCliOptions 

func NewOnlyActivitiesCliOptions() *OnlyActivitiesCliOptions

NewOnlyActivitiesCliOptions initializes a new OnlyActivitiesCliOptions value

func (*OnlyActivitiesCliOptions) WithAfter 

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

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

func (*OnlyActivitiesCliOptions) WithBefore 

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

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

func (*OnlyActivitiesCliOptions) WithClient 

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

WithClient provides a Temporal client factory for use by commands

func (*OnlyActivitiesCliOptions) WithWorker 

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

WithWorker provides an method for initializing a worker

type OnlyActivitiesClient 

type OnlyActivitiesClient interface {
	// 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
}

OnlyActivitiesClient describes a client for a(n) mycompany.simple.OnlyActivities worker

func NewOnlyActivitiesClient 

func NewOnlyActivitiesClient(c client.Client, options ...*onlyActivitiesClientOptions) OnlyActivitiesClient

NewOnlyActivitiesClient initializes a new mycompany.simple.OnlyActivities client

func NewOnlyActivitiesClientWithOptions 

func NewOnlyActivitiesClientWithOptions(c client.Client, opts client.Options, options ...*onlyActivitiesClientOptions) (OnlyActivitiesClient, error)

NewOnlyActivitiesClientWithOptions initializes a new OnlyActivities client with the given options

type OnlyActivitiesWorkflowFunctions added in v1.12.0 

type OnlyActivitiesWorkflowFunctions interface{}

OnlyActivitiesWorkflowFunctions describes a mockable dependency for inlining workflows within other workflows

func NewOnlyActivitiesWorkflowFunctions added in v1.12.0 

func NewOnlyActivitiesWorkflowFunctions() OnlyActivitiesWorkflowFunctions

type OnlyActivitiesWorkflows 

type OnlyActivitiesWorkflows interface{}

OnlyActivitiesWorkflows provides methods for initializing new mycompany.simple.OnlyActivities workflow values

type OtherActivities 

type OtherActivities interface {
	// mycompany.simple.Other.OtherWorkflow implements a(n) mycompany.simple.Other.OtherWorkflow activity definition
	OtherWorkflow(ctx context.Context, req *OtherWorkflowRequest) (*OtherWorkflowResponse, error)
}

OtherActivities describes available worker activities

type OtherCliOptions 

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

OtherCliOptions describes runtime configuration for mycompany.simple.Other cli

func NewOtherCliOptions 

func NewOtherCliOptions() *OtherCliOptions

NewOtherCliOptions initializes a new OtherCliOptions value

func (*OtherCliOptions) WithAfter 

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

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

func (*OtherCliOptions) WithBefore 

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

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

func (*OtherCliOptions) WithClient 

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

WithClient provides a Temporal client factory for use by commands

func (*OtherCliOptions) WithWorker 

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

WithWorker provides an method for initializing a worker

type OtherClient 

type OtherClient interface {
	// OtherWorkflow executes a(n) mycompany.simple.Other.OtherWorkflow workflow and blocks until error or response received
	OtherWorkflow(ctx context.Context, req *OtherWorkflowRequest, opts ...*OtherWorkflowOptions) (*OtherWorkflowResponse, error)

	// OtherWorkflowAsync starts a(n) mycompany.simple.Other.OtherWorkflow workflow and returns a handle to the workflow run
	OtherWorkflowAsync(ctx context.Context, req *OtherWorkflowRequest, opts ...*OtherWorkflowOptions) (OtherWorkflowRun, error)

	// GetOtherWorkflow retrieves a handle to an existing mycompany.simple.Other.OtherWorkflow workflow execution
	GetOtherWorkflow(ctx context.Context, workflowID string, runID string) OtherWorkflowRun

	// 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

	// mycompany.simple.Other.OtherQuery executes a(n) mycompany.simple.Other.OtherQuery query
	OtherQuery(ctx context.Context, workflowID string, runID string) (*OtherQueryResponse, error)

	// mycompany.simple.Other.OtherSignal sends a(n) mycompany.simple.Other.OtherSignal signal
	OtherSignal(ctx context.Context, workflowID string, runID string, signal *OtherSignalRequest) error

	// OtherUpdate executes a(n) mycompany.simple.Other.OtherUpdate update and blocks until update completion
	OtherUpdate(ctx context.Context, workflowID string, runID string, req *OtherUpdateRequest, opts ...*OtherUpdateOptions) (*OtherUpdateResponse, error)

	// OtherUpdateAsync starts a(n) mycompany.simple.Other.OtherUpdate update and returns a handle to the workflow update
	OtherUpdateAsync(ctx context.Context, workflowID string, runID string, req *OtherUpdateRequest, opts ...*OtherUpdateOptions) (OtherUpdateHandle, error)

	// GetOtherUpdate retrieves a handle to an existing mycompany.simple.Other.OtherUpdate update
	GetOtherUpdate(ctx context.Context, req client.GetWorkflowUpdateHandleOptions) (OtherUpdateHandle, error)
}

OtherClient describes a client for a(n) mycompany.simple.Other worker

func NewOtherClient 

func NewOtherClient(c client.Client, options ...*otherClientOptions) OtherClient

NewOtherClient initializes a new mycompany.simple.Other client

func NewOtherClientWithOptions 

func NewOtherClientWithOptions(c client.Client, opts client.Options, options ...*otherClientOptions) (OtherClient, error)

NewOtherClientWithOptions initializes a new Other client with the given options

type OtherEnum 

type OtherEnum int32
const (
	OtherEnum_OTHER_UNSPECIFIED OtherEnum = 0
	OtherEnum_OTHER_FOO         OtherEnum = 1
	OtherEnum_OTHER_BAR         OtherEnum = 2
)

func (OtherEnum) Descriptor 

func (OtherEnum) Descriptor() protoreflect.EnumDescriptor

func (OtherEnum) Enum 

func (x OtherEnum) Enum() *OtherEnum

func (OtherEnum) EnumDescriptor deprecated 

func (OtherEnum) EnumDescriptor() ([]byte, []int)

Deprecated: Use OtherEnum.Descriptor instead.

func (OtherEnum) Number 

func (x OtherEnum) Number() protoreflect.EnumNumber

func (OtherEnum) String 

func (x OtherEnum) String() string

func (OtherEnum) Type 

func (OtherEnum) Type() protoreflect.EnumType

type OtherQueryResponse 

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

func (*OtherQueryResponse) Descriptor deprecated 

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

Deprecated: Use OtherQueryResponse.ProtoReflect.Descriptor instead.

func (*OtherQueryResponse) GetFilter 

func (x *OtherQueryResponse) GetFilter() string

func (*OtherQueryResponse) ProtoMessage 

func (*OtherQueryResponse) ProtoMessage()

func (*OtherQueryResponse) ProtoReflect 

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

func (*OtherQueryResponse) Reset 

func (x *OtherQueryResponse) Reset()

func (*OtherQueryResponse) String 

func (x *OtherQueryResponse) String() string

type OtherSignalRequest 

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

func (*OtherSignalRequest) Descriptor deprecated 

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

Deprecated: Use OtherSignalRequest.ProtoReflect.Descriptor instead.

func (*OtherSignalRequest) GetType 

func (x *OtherSignalRequest) GetType() string

func (*OtherSignalRequest) ProtoMessage 

func (*OtherSignalRequest) ProtoMessage()

func (*OtherSignalRequest) ProtoReflect 

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

func (*OtherSignalRequest) Reset 

func (x *OtherSignalRequest) Reset()

func (*OtherSignalRequest) String 

func (x *OtherSignalRequest) String() string

type OtherSignalSignal 

type OtherSignalSignal struct {
	Channel workflow.ReceiveChannel
}

OtherSignalSignal describes a(n) mycompany.simple.Other.OtherSignal signal

func NewOtherSignalSignal 

func NewOtherSignalSignal(ctx workflow.Context) *OtherSignalSignal

NewOtherSignalSignal initializes a new mycompany.simple.Other.OtherSignal signal wrapper

func (*OtherSignalSignal) Receive 

func (s *OtherSignalSignal) Receive(ctx workflow.Context) (*OtherSignalRequest, bool)

Receive blocks until a(n) mycompany.simple.Other.OtherSignal signal is received

func (*OtherSignalSignal) ReceiveAsync 

func (s *OtherSignalSignal) ReceiveAsync() *OtherSignalRequest

ReceiveAsync checks for a mycompany.simple.Other.OtherSignal signal without blocking

func (*OtherSignalSignal) ReceiveWithTimeout 

func (s *OtherSignalSignal) ReceiveWithTimeout(ctx workflow.Context, timeout time.Duration) (resp *OtherSignalRequest, ok bool, more bool)

ReceiveWithTimeout blocks until a(n) mycompany.simple.Other.OtherSignal signal is received or timeout expires. Returns more value of false when Channel is closed. Returns ok value of false when no value was found in the channel for the duration of timeout or the ctx was canceled. resp will be nil if ok is false.

func (*OtherSignalSignal) Select 

func (s *OtherSignalSignal) Select(sel workflow.Selector, fn func(*OtherSignalRequest)) workflow.Selector

Select checks for a(n) mycompany.simple.Other.OtherSignal signal without blocking

type OtherUpdateHandle 

type OtherUpdateHandle 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) (*OtherUpdateResponse, error)
}

OtherUpdateHandle describes a(n) mycompany.simple.Other.OtherUpdate update handle

type OtherUpdateOptions 

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

OtherUpdateOptions provides configuration for a mycompany.simple.Other.OtherUpdate update operation

func NewOtherUpdateOptions 

func NewOtherUpdateOptions() *OtherUpdateOptions

NewOtherUpdateOptions initializes a new OtherUpdateOptions value

func (*OtherUpdateOptions) Build added in v1.13.0 

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

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

func (*OtherUpdateOptions) WithUpdateID added in v1.13.0 

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

WithUpdateID sets the UpdateID

func (*OtherUpdateOptions) WithUpdateWorkflowOptions 

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

WithUpdateWorkflowOptions sets the initial client.UpdateWorkflowOptions

func (*OtherUpdateOptions) WithWaitPolicy added in v1.13.0 

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

WithWaitPolicy sets the WaitPolicy

type OtherUpdateRequest 

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

func UnmarshalCliFlagsToOtherUpdateRequest 

func UnmarshalCliFlagsToOtherUpdateRequest(cmd *v2.Context) (*OtherUpdateRequest, error)

UnmarshalCliFlagsToOtherUpdateRequest unmarshals a OtherUpdateRequest from command line flags

func (*OtherUpdateRequest) Descriptor deprecated 

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

Deprecated: Use OtherUpdateRequest.ProtoReflect.Descriptor instead.

func (*OtherUpdateRequest) GetMode 

func (x *OtherUpdateRequest) GetMode() string

func (*OtherUpdateRequest) ProtoMessage 

func (*OtherUpdateRequest) ProtoMessage()

func (*OtherUpdateRequest) ProtoReflect 

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

func (*OtherUpdateRequest) Reset 

func (x *OtherUpdateRequest) Reset()

func (*OtherUpdateRequest) String 

func (x *OtherUpdateRequest) String() string

type OtherUpdateResponse 

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

func (*OtherUpdateResponse) Descriptor deprecated 

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

Deprecated: Use OtherUpdateResponse.ProtoReflect.Descriptor instead.

func (*OtherUpdateResponse) ProtoMessage 

func (*OtherUpdateResponse) ProtoMessage()

func (*OtherUpdateResponse) ProtoReflect 

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

func (*OtherUpdateResponse) Reset 

func (x *OtherUpdateResponse) Reset()

func (*OtherUpdateResponse) String 

func (x *OtherUpdateResponse) String() string

type OtherWorkflowActivityOptions 

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

OtherWorkflowActivityOptions provides configuration for a(n) mycompany.simple.Other.OtherWorkflow activity

func NewOtherWorkflowActivityOptions 

func NewOtherWorkflowActivityOptions() *OtherWorkflowActivityOptions

NewOtherWorkflowActivityOptions initializes a new OtherWorkflowActivityOptions value

func (*OtherWorkflowActivityOptions) Build added in v1.13.0 

func (o *OtherWorkflowActivityOptions) 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 (*OtherWorkflowActivityOptions) WithActivityOptions 

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

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

func (*OtherWorkflowActivityOptions) WithHeartbeatTimeout added in v1.13.0 

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

WithHeartbeatTimeout sets the HeartbeatTimeout value

func (*OtherWorkflowActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*OtherWorkflowActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*OtherWorkflowActivityOptions) WithScheduleToStartTimeout added in v1.13.0 

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

WithScheduleToStartTimeout sets the ScheduleToStartTimeout value

func (*OtherWorkflowActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

func (*OtherWorkflowActivityOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*OtherWorkflowActivityOptions) WithWaitForCancellation added in v1.13.0 

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

WithWaitForCancellation sets the WaitForCancellation value

type OtherWorkflowChildOptions 

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

OtherWorkflowChildOptions provides configuration for a child mycompany.simple.Other.OtherWorkflow workflow operation

func NewOtherWorkflowChildOptions 

func NewOtherWorkflowChildOptions() *OtherWorkflowChildOptions

NewOtherWorkflowChildOptions initializes a new OtherWorkflowChildOptions value

func (*OtherWorkflowChildOptions) Build added in v1.13.0 

func (o *OtherWorkflowChildOptions) 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 (*OtherWorkflowChildOptions) WithChildWorkflowOptions 

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

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

func (*OtherWorkflowChildOptions) WithExecutionTimeout added in v1.13.0 

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

WithExecutionTimeout sets the WorkflowExecutionTimeout value

func (*OtherWorkflowChildOptions) WithID added in v1.13.0 

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

WithID sets the WorkflowID value

func (*OtherWorkflowChildOptions) WithIDReusePolicy added in v1.13.0 

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

WithIDReusePolicy sets the WorkflowIDReusePolicy value

func (*OtherWorkflowChildOptions) WithParentClosePolicy added in v1.13.0 

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

WithParentClosePolicy sets the WorkflowIDReusePolicy value

func (*OtherWorkflowChildOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*OtherWorkflowChildOptions) WithRunTimeout added in v1.13.0 

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

WithRunTimeout sets the WorkflowRunTimeout value

func (*OtherWorkflowChildOptions) WithSearchAttributes added in v1.13.0 

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

WithSearchAttributes sets the SearchAttributes value

func (*OtherWorkflowChildOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*OtherWorkflowChildOptions) WithTaskTimeout added in v1.13.0 

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

WithTaskTimeout sets the WorkflowTaskTimeout value

func (*OtherWorkflowChildOptions) WithWaitForCancellation added in v1.13.0 

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

WithWaitForCancellation sets the WaitForCancellation value

type OtherWorkflowChildRun 

type OtherWorkflowChildRun struct {
	Future workflow.ChildWorkflowFuture
}

OtherWorkflowChildRun describes a child OtherWorkflow workflow run

func OtherWorkflowChildAsync 

func OtherWorkflowChildAsync(ctx workflow.Context, req *OtherWorkflowRequest, options ...*OtherWorkflowChildOptions) (*OtherWorkflowChildRun, error)

OtherWorkflowChildAsync starts a child mycompany.simple.Other.OtherWorkflow workflow and returns a handle to the child workflow run

func (*OtherWorkflowChildRun) Get 

func (r *OtherWorkflowChildRun) Get(ctx workflow.Context) (*OtherWorkflowResponse, error)

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

func (*OtherWorkflowChildRun) Select 

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

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

func (*OtherWorkflowChildRun) SelectStart 

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

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

func (*OtherWorkflowChildRun) WaitStart 

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

WaitStart waits for the child workflow to start

type OtherWorkflowFunctions added in v1.12.0 

type OtherWorkflowFunctions interface {
	// OtherWorkflow executes a "mycompany.simple.Other.OtherWorkflow" workflow inline
	OtherWorkflow(workflow.Context, *OtherWorkflowRequest) (*OtherWorkflowResponse, error)
}

OtherWorkflowFunctions describes a mockable dependency for inlining workflows within other workflows

func NewOtherWorkflowFunctions added in v1.12.0 

func NewOtherWorkflowFunctions() OtherWorkflowFunctions

type OtherWorkflowFuture 

type OtherWorkflowFuture struct {
	Future workflow.Future
}

OtherWorkflowFuture describes a(n) mycompany.simple.Other.OtherWorkflow activity execution

func OtherWorkflowAsync 

func OtherWorkflowAsync(ctx workflow.Context, req *OtherWorkflowRequest, options ...*OtherWorkflowActivityOptions) *OtherWorkflowFuture

OtherWorkflowAsync executes a(n) mycompany.simple.Other.OtherWorkflow activity (asynchronously)

func OtherWorkflowLocalAsync 

func OtherWorkflowLocalAsync(ctx workflow.Context, req *OtherWorkflowRequest, options ...*OtherWorkflowLocalActivityOptions) *OtherWorkflowFuture

OtherWorkflowLocalAsync executes a(n) mycompany.simple.Other.OtherWorkflow activity (asynchronously, locally)

func (*OtherWorkflowFuture) Get 

func (f *OtherWorkflowFuture) Get(ctx workflow.Context) (*OtherWorkflowResponse, error)

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

func (*OtherWorkflowFuture) Select 

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

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

type OtherWorkflowLocalActivityOptions 

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

OtherWorkflowLocalActivityOptions provides configuration for a(n) mycompany.simple.Other.OtherWorkflow activity

func NewOtherWorkflowLocalActivityOptions 

func NewOtherWorkflowLocalActivityOptions() *OtherWorkflowLocalActivityOptions

NewOtherWorkflowLocalActivityOptions initializes a new OtherWorkflowLocalActivityOptions value

func (*OtherWorkflowLocalActivityOptions) Build added in v1.13.0 

func (o *OtherWorkflowLocalActivityOptions) 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 (*OtherWorkflowLocalActivityOptions) Local 

func (o *OtherWorkflowLocalActivityOptions) Local(fn func(context.Context, *OtherWorkflowRequest) (*OtherWorkflowResponse, error)) *OtherWorkflowLocalActivityOptions

Local specifies a custom mycompany.simple.Other.OtherWorkflow implementation

func (*OtherWorkflowLocalActivityOptions) WithLocalActivityOptions 

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

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

func (*OtherWorkflowLocalActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*OtherWorkflowLocalActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*OtherWorkflowLocalActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

type OtherWorkflowOptions 

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

OtherWorkflowOptions provides configuration for a mycompany.simple.Other.OtherWorkflow workflow operation

func NewOtherWorkflowOptions 

func NewOtherWorkflowOptions() *OtherWorkflowOptions

NewOtherWorkflowOptions initializes a new OtherWorkflowOptions value

func (*OtherWorkflowOptions) Build added in v1.13.0 

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

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

func (*OtherWorkflowOptions) WithExecutionTimeout added in v1.13.0 

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

WithExecutionTimeout sets the WorkflowExecutionTimeout value

func (*OtherWorkflowOptions) WithID added in v1.13.0 

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

WithID sets the ID value

func (*OtherWorkflowOptions) WithIDReusePolicy added in v1.13.0 

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

WithIDReusePolicy sets the WorkflowIDReusePolicy value

func (*OtherWorkflowOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*OtherWorkflowOptions) WithRunTimeout added in v1.13.0 

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

WithRunTimeout sets the WorkflowRunTimeout value

func (*OtherWorkflowOptions) WithSearchAttributes added in v1.13.0 

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

WithSearchAttributes sets the SearchAttributes value

func (*OtherWorkflowOptions) WithStartWorkflowOptions 

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

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

func (*OtherWorkflowOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*OtherWorkflowOptions) WithTaskTimeout added in v1.13.0 

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

WithTaskTimeout sets the WorkflowTaskTimeout value

type OtherWorkflowRequest 

type OtherWorkflowRequest struct {
	SomeVal string                    `protobuf:"bytes,1,opt,name=some_val,json=someVal,proto3" json:"some_val,omitempty"`
	Baz     *OtherWorkflowRequest_Baz `protobuf:"bytes,2,opt,name=baz,proto3" json:"baz,omitempty"`
	Qux     *Qux                      `protobuf:"bytes,3,opt,name=qux,proto3" json:"qux,omitempty"`
	// Types that are valid to be assigned to ExampleOneof:
	//
	//	*OtherWorkflowRequest_Foo
	//	*OtherWorkflowRequest_Bar_
	//	*OtherWorkflowRequest_ExampleBytes
	//	*OtherWorkflowRequest_ExampleDouble
	//	*OtherWorkflowRequest_ExampleFloat
	//	*OtherWorkflowRequest_ExampleInt32
	//	*OtherWorkflowRequest_ExampleInt64
	//	*OtherWorkflowRequest_ExampleUint32
	//	*OtherWorkflowRequest_ExampleUint64
	//	*OtherWorkflowRequest_ExampleSint32
	//	*OtherWorkflowRequest_ExampleSint64
	//	*OtherWorkflowRequest_ExampleFixed32
	//	*OtherWorkflowRequest_ExampleFixed64
	//	*OtherWorkflowRequest_ExampleSfixed32
	//	*OtherWorkflowRequest_ExampleSfixed64
	//	*OtherWorkflowRequest_ExampleBool
	//	*OtherWorkflowRequest_Quux
	//	*OtherWorkflowRequest_ExampleDuration
	//	*OtherWorkflowRequest_ExampleEmpty
	//	*OtherWorkflowRequest_ExampleTimestamp
	//	*OtherWorkflowRequest_ExampleEnum
	//	*OtherWorkflowRequest_CommonEnum
	ExampleOneof isOtherWorkflowRequest_ExampleOneof `protobuf_oneof:"example_oneof"`
	// contains filtered or unexported fields
}

func UnmarshalCliFlagsToOtherWorkflowRequest 

func UnmarshalCliFlagsToOtherWorkflowRequest(cmd *v2.Context) (*OtherWorkflowRequest, error)

UnmarshalCliFlagsToOtherWorkflowRequest unmarshals a OtherWorkflowRequest from command line flags

func (*OtherWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use OtherWorkflowRequest.ProtoReflect.Descriptor instead.

func (*OtherWorkflowRequest) GetBar 

func (x *OtherWorkflowRequest) GetBar() *OtherWorkflowRequest_Bar

func (*OtherWorkflowRequest) GetBaz 

func (x *OtherWorkflowRequest) GetBaz() *OtherWorkflowRequest_Baz

func (*OtherWorkflowRequest) GetCommonEnum added in v1.14.2 

func (x *OtherWorkflowRequest) GetCommonEnum() v1.Example

func (*OtherWorkflowRequest) GetExampleBool 

func (x *OtherWorkflowRequest) GetExampleBool() bool

func (*OtherWorkflowRequest) GetExampleBytes 

func (x *OtherWorkflowRequest) GetExampleBytes() []byte

func (*OtherWorkflowRequest) GetExampleDouble 

func (x *OtherWorkflowRequest) GetExampleDouble() float64

func (*OtherWorkflowRequest) GetExampleDuration 

func (x *OtherWorkflowRequest) GetExampleDuration() *durationpb.Duration

func (*OtherWorkflowRequest) GetExampleEmpty 

func (x *OtherWorkflowRequest) GetExampleEmpty() *emptypb.Empty

func (*OtherWorkflowRequest) GetExampleEnum 

func (x *OtherWorkflowRequest) GetExampleEnum() OtherEnum

func (*OtherWorkflowRequest) GetExampleFixed32 

func (x *OtherWorkflowRequest) GetExampleFixed32() uint32

func (*OtherWorkflowRequest) GetExampleFixed64 

func (x *OtherWorkflowRequest) GetExampleFixed64() uint64

func (*OtherWorkflowRequest) GetExampleFloat 

func (x *OtherWorkflowRequest) GetExampleFloat() float32

func (*OtherWorkflowRequest) GetExampleInt32 

func (x *OtherWorkflowRequest) GetExampleInt32() int32

func (*OtherWorkflowRequest) GetExampleInt64 

func (x *OtherWorkflowRequest) GetExampleInt64() int64

func (*OtherWorkflowRequest) GetExampleOneof 

func (x *OtherWorkflowRequest) GetExampleOneof() isOtherWorkflowRequest_ExampleOneof

func (*OtherWorkflowRequest) GetExampleSfixed32 

func (x *OtherWorkflowRequest) GetExampleSfixed32() int32

func (*OtherWorkflowRequest) GetExampleSfixed64 

func (x *OtherWorkflowRequest) GetExampleSfixed64() int64

func (*OtherWorkflowRequest) GetExampleSint32 

func (x *OtherWorkflowRequest) GetExampleSint32() int32

func (*OtherWorkflowRequest) GetExampleSint64 

func (x *OtherWorkflowRequest) GetExampleSint64() int64

func (*OtherWorkflowRequest) GetExampleTimestamp 

func (x *OtherWorkflowRequest) GetExampleTimestamp() *timestamppb.Timestamp

func (*OtherWorkflowRequest) GetExampleUint32 

func (x *OtherWorkflowRequest) GetExampleUint32() uint32

func (*OtherWorkflowRequest) GetExampleUint64 

func (x *OtherWorkflowRequest) GetExampleUint64() uint64

func (*OtherWorkflowRequest) GetFoo 

func (x *OtherWorkflowRequest) GetFoo() *Foo

func (*OtherWorkflowRequest) GetQuux 

func (x *OtherWorkflowRequest) GetQuux() string

func (*OtherWorkflowRequest) GetQux 

func (x *OtherWorkflowRequest) GetQux() *Qux

func (*OtherWorkflowRequest) GetSomeVal 

func (x *OtherWorkflowRequest) GetSomeVal() string

func (*OtherWorkflowRequest) ProtoMessage 

func (*OtherWorkflowRequest) ProtoMessage()

func (*OtherWorkflowRequest) ProtoReflect 

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

func (*OtherWorkflowRequest) Reset 

func (x *OtherWorkflowRequest) Reset()

func (*OtherWorkflowRequest) String 

func (x *OtherWorkflowRequest) String() string

type OtherWorkflowRequest_Bar 

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

func (*OtherWorkflowRequest_Bar) Descriptor deprecated 

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

Deprecated: Use OtherWorkflowRequest_Bar.ProtoReflect.Descriptor instead.

func (*OtherWorkflowRequest_Bar) GetBar 

func (x *OtherWorkflowRequest_Bar) GetBar() string

func (*OtherWorkflowRequest_Bar) ProtoMessage 

func (*OtherWorkflowRequest_Bar) ProtoMessage()

func (*OtherWorkflowRequest_Bar) ProtoReflect 

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

func (*OtherWorkflowRequest_Bar) Reset 

func (x *OtherWorkflowRequest_Bar) Reset()

func (*OtherWorkflowRequest_Bar) String 

func (x *OtherWorkflowRequest_Bar) String() string

type OtherWorkflowRequest_Bar_ 

type OtherWorkflowRequest_Bar_ struct {
	Bar *OtherWorkflowRequest_Bar `protobuf:"bytes,5,opt,name=bar,proto3,oneof"`
}

type OtherWorkflowRequest_Baz 

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

func (*OtherWorkflowRequest_Baz) Descriptor deprecated 

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

Deprecated: Use OtherWorkflowRequest_Baz.ProtoReflect.Descriptor instead.

func (*OtherWorkflowRequest_Baz) GetBaz 

func (x *OtherWorkflowRequest_Baz) GetBaz() string

func (*OtherWorkflowRequest_Baz) ProtoMessage 

func (*OtherWorkflowRequest_Baz) ProtoMessage()

func (*OtherWorkflowRequest_Baz) ProtoReflect 

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

func (*OtherWorkflowRequest_Baz) Reset 

func (x *OtherWorkflowRequest_Baz) Reset()

func (*OtherWorkflowRequest_Baz) String 

func (x *OtherWorkflowRequest_Baz) String() string

type OtherWorkflowRequest_CommonEnum added in v1.14.2 

type OtherWorkflowRequest_CommonEnum struct {
	CommonEnum v1.Example `protobuf:"varint,25,opt,name=common_enum,json=commonEnum,proto3,enum=mycompany.simple.common.v1.Example,oneof"`
}

type OtherWorkflowRequest_ExampleBool 

type OtherWorkflowRequest_ExampleBool struct {
	ExampleBool bool `protobuf:"varint,19,opt,name=example_bool,json=exampleBool,proto3,oneof"`
}

type OtherWorkflowRequest_ExampleBytes 

type OtherWorkflowRequest_ExampleBytes struct {
	ExampleBytes []byte `protobuf:"bytes,6,opt,name=example_bytes,json=exampleBytes,proto3,oneof"`
}

type OtherWorkflowRequest_ExampleDouble 

type OtherWorkflowRequest_ExampleDouble struct {
	ExampleDouble float64 `protobuf:"fixed64,7,opt,name=example_double,json=exampleDouble,proto3,oneof"`
}

type OtherWorkflowRequest_ExampleDuration 

type OtherWorkflowRequest_ExampleDuration struct {
	ExampleDuration *durationpb.Duration `protobuf:"bytes,21,opt,name=example_duration,json=exampleDuration,proto3,oneof"`
}

type OtherWorkflowRequest_ExampleEmpty 

type OtherWorkflowRequest_ExampleEmpty struct {
	ExampleEmpty *emptypb.Empty `protobuf:"bytes,22,opt,name=example_empty,json=exampleEmpty,proto3,oneof"`
}

type OtherWorkflowRequest_ExampleEnum 

type OtherWorkflowRequest_ExampleEnum struct {
	ExampleEnum OtherEnum `protobuf:"varint,24,opt,name=example_enum,json=exampleEnum,proto3,enum=mycompany.simple.OtherEnum,oneof"`
}

type OtherWorkflowRequest_ExampleFixed32 

type OtherWorkflowRequest_ExampleFixed32 struct {
	ExampleFixed32 uint32 `protobuf:"fixed32,15,opt,name=example_fixed32,json=exampleFixed32,proto3,oneof"`
}

type OtherWorkflowRequest_ExampleFixed64 

type OtherWorkflowRequest_ExampleFixed64 struct {
	ExampleFixed64 uint64 `protobuf:"fixed64,16,opt,name=example_fixed64,json=exampleFixed64,proto3,oneof"`
}

type OtherWorkflowRequest_ExampleFloat 

type OtherWorkflowRequest_ExampleFloat struct {
	ExampleFloat float32 `protobuf:"fixed32,8,opt,name=example_float,json=exampleFloat,proto3,oneof"`
}

type OtherWorkflowRequest_ExampleInt32 

type OtherWorkflowRequest_ExampleInt32 struct {
	ExampleInt32 int32 `protobuf:"varint,9,opt,name=example_int32,json=exampleInt32,proto3,oneof"`
}

type OtherWorkflowRequest_ExampleInt64 

type OtherWorkflowRequest_ExampleInt64 struct {
	ExampleInt64 int64 `protobuf:"varint,10,opt,name=example_int64,json=exampleInt64,proto3,oneof"`
}

type OtherWorkflowRequest_ExampleSfixed32 

type OtherWorkflowRequest_ExampleSfixed32 struct {
	ExampleSfixed32 int32 `protobuf:"fixed32,17,opt,name=example_sfixed32,json=exampleSfixed32,proto3,oneof"`
}

type OtherWorkflowRequest_ExampleSfixed64 

type OtherWorkflowRequest_ExampleSfixed64 struct {
	ExampleSfixed64 int64 `protobuf:"fixed64,18,opt,name=example_sfixed64,json=exampleSfixed64,proto3,oneof"`
}

type OtherWorkflowRequest_ExampleSint32 

type OtherWorkflowRequest_ExampleSint32 struct {
	ExampleSint32 int32 `protobuf:"zigzag32,13,opt,name=example_sint32,json=exampleSint32,proto3,oneof"`
}

type OtherWorkflowRequest_ExampleSint64 

type OtherWorkflowRequest_ExampleSint64 struct {
	ExampleSint64 int64 `protobuf:"zigzag64,14,opt,name=example_sint64,json=exampleSint64,proto3,oneof"`
}

type OtherWorkflowRequest_ExampleTimestamp 

type OtherWorkflowRequest_ExampleTimestamp struct {
	ExampleTimestamp *timestamppb.Timestamp `protobuf:"bytes,23,opt,name=example_timestamp,json=exampleTimestamp,proto3,oneof"`
}

type OtherWorkflowRequest_ExampleUint32 

type OtherWorkflowRequest_ExampleUint32 struct {
	ExampleUint32 uint32 `protobuf:"varint,11,opt,name=example_uint32,json=exampleUint32,proto3,oneof"`
}

type OtherWorkflowRequest_ExampleUint64 

type OtherWorkflowRequest_ExampleUint64 struct {
	ExampleUint64 uint64 `protobuf:"varint,12,opt,name=example_uint64,json=exampleUint64,proto3,oneof"`
}

type OtherWorkflowRequest_Foo 

type OtherWorkflowRequest_Foo struct {
	Foo *Foo `protobuf:"bytes,4,opt,name=foo,proto3,oneof"`
}

type OtherWorkflowRequest_Quux 

type OtherWorkflowRequest_Quux struct {
	Quux string `protobuf:"bytes,20,opt,name=quux,proto3,oneof"`
}

type OtherWorkflowResponse 

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

func OtherWorkflow 

func OtherWorkflow(ctx workflow.Context, req *OtherWorkflowRequest, options ...*OtherWorkflowActivityOptions) (*OtherWorkflowResponse, error)

OtherWorkflow executes a(n) mycompany.simple.Other.OtherWorkflow activity

func OtherWorkflowChild 

func OtherWorkflowChild(ctx workflow.Context, req *OtherWorkflowRequest, options ...*OtherWorkflowChildOptions) (*OtherWorkflowResponse, error)

OtherWorkflowChild executes a child mycompany.simple.Other.OtherWorkflow workflow and blocks until error or response received

func OtherWorkflowLocal 

func OtherWorkflowLocal(ctx workflow.Context, req *OtherWorkflowRequest, options ...*OtherWorkflowLocalActivityOptions) (*OtherWorkflowResponse, error)

OtherWorkflowLocal executes a(n) mycompany.simple.Other.OtherWorkflow activity (locally)

func (*OtherWorkflowResponse) Descriptor deprecated 

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

Deprecated: Use OtherWorkflowResponse.ProtoReflect.Descriptor instead.

func (*OtherWorkflowResponse) ProtoMessage 

func (*OtherWorkflowResponse) ProtoMessage()

func (*OtherWorkflowResponse) ProtoReflect 

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

func (*OtherWorkflowResponse) Reset 

func (x *OtherWorkflowResponse) Reset()

func (*OtherWorkflowResponse) String 

func (x *OtherWorkflowResponse) String() string

type OtherWorkflowRun 

type OtherWorkflowRun 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) (*OtherWorkflowResponse, 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
}

OtherWorkflowRun describes a(n) mycompany.simple.Other.OtherWorkflow workflow run

type OtherWorkflowWorkflow 

type OtherWorkflowWorkflow interface {
	// Execute defines the entrypoint to a(n) mycompany.simple.Other.OtherWorkflow workflow
	Execute(ctx workflow.Context) (*OtherWorkflowResponse, error)
}

OtherWorkflowWorkflow describes a(n) mycompany.simple.Other.OtherWorkflow workflow implementation

workflow details: (id: "other-workflow/${!uuid_v4()}")

type OtherWorkflowWorkflowInput 

type OtherWorkflowWorkflowInput struct {
	Req *OtherWorkflowRequest
}

OtherWorkflowWorkflowInput describes the input to a(n) mycompany.simple.Other.OtherWorkflow workflow constructor

type OtherWorkflows 

type OtherWorkflows interface {
	// OtherWorkflow initializes a new a(n) OtherWorkflowWorkflow implementation
	OtherWorkflow(ctx workflow.Context, input *OtherWorkflowWorkflowInput) (OtherWorkflowWorkflow, error)
}

OtherWorkflows provides methods for initializing new mycompany.simple.Other workflow values

type Qux 

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

func (*Qux) Descriptor deprecated 

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

Deprecated: Use Qux.ProtoReflect.Descriptor instead.

func (*Qux) GetQux 

func (x *Qux) GetQux() string

func (*Qux) ProtoMessage 

func (*Qux) ProtoMessage()

func (*Qux) ProtoReflect 

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

func (*Qux) Reset 

func (x *Qux) Reset()

func (*Qux) String 

func (x *Qux) String() string

type SimpleActivities 

type SimpleActivities interface {
	// SomeActivity1 does some activity thing.
	SomeActivity1(ctx context.Context) error

	// SomeActivity2 does some activity thing.
	SomeActivity2(ctx context.Context, req *SomeActivity2Request) error

	// SomeActivity3 does some activity thing.
	SomeActivity3(ctx context.Context, req *SomeActivity3Request) (*SomeActivity3Response, error)

	// SomeActivity4 does some activity thing.
	SomeActivity4(ctx context.Context) error

	// SomeSignal1 is a signal.
	SomeSignal1(ctx context.Context) error

	// SomeSignal2 is a signal.
	SomeSignal2(ctx context.Context, req *SomeSignal2Request) error

	// SomeSignal3 is a signal.
	SomeSignal3(ctx context.Context, req *SomeSignal3Request) (*SomeSignal3Response, error)

	// SomeUpdate1 updates a SomeWorkflow2
	SomeUpdate1(ctx context.Context, req *SomeUpdate1Request) (*SomeUpdate1Response, error)
}

SimpleActivities describes available worker activities

type SimpleCliOptions 

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

SimpleCliOptions describes runtime configuration for mycompany.simple.Simple cli

func NewSimpleCliOptions 

func NewSimpleCliOptions() *SimpleCliOptions

NewSimpleCliOptions initializes a new SimpleCliOptions value

func (*SimpleCliOptions) WithAfter 

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

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

func (*SimpleCliOptions) WithBefore 

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

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

func (*SimpleCliOptions) WithClient 

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

WithClient provides a Temporal client factory for use by commands

func (*SimpleCliOptions) WithWorker 

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

WithWorker provides an method for initializing a worker

type SimpleClient 

type SimpleClient interface {
	// SomeWorkflow1 does some workflow thing.
	SomeWorkflow1(ctx context.Context, req *SomeWorkflow1Request, opts ...*SomeWorkflow1Options) (*SomeWorkflow1Response, error)

	// SomeWorkflow1Async starts a(n) mycompany.simple.SomeWorkflow1 workflow and returns a handle to the workflow run
	SomeWorkflow1Async(ctx context.Context, req *SomeWorkflow1Request, opts ...*SomeWorkflow1Options) (SomeWorkflow1Run, error)

	// GetSomeWorkflow1 retrieves a handle to an existing mycompany.simple.SomeWorkflow1 workflow execution
	GetSomeWorkflow1(ctx context.Context, workflowID string, runID string) SomeWorkflow1Run

	// SomeWorkflow2 does some workflow thing.
	SomeWorkflow2(ctx context.Context, opts ...*SomeWorkflow2Options) error

	// SomeWorkflow2Async starts a(n) mycompany.simple.SomeWorkflow2 workflow and returns a handle to the workflow run
	SomeWorkflow2Async(ctx context.Context, opts ...*SomeWorkflow2Options) (SomeWorkflow2Run, error)

	// GetSomeWorkflow2 retrieves a handle to an existing mycompany.simple.SomeWorkflow2 workflow execution
	GetSomeWorkflow2(ctx context.Context, workflowID string, runID string) SomeWorkflow2Run

	// SomeWorkflow2WithSomeSignal1 sends a(n) mycompany.simple.Simple.SomeSignal1 signal to a(n) mycompany.simple.SomeWorkflow2 workflow, starting it if necessary, and blocks until workflow completion
	SomeWorkflow2WithSomeSignal1(ctx context.Context, opts ...*SomeWorkflow2Options) error

	// SomeWorkflow2WithSomeSignal1Async sends a(n) mycompany.simple.Simple.SomeSignal1 signal to a(n) mycompany.simple.SomeWorkflow2 workflow, starting it if necessary, and returns a handle to the workflow execution
	SomeWorkflow2WithSomeSignal1Async(ctx context.Context, opts ...*SomeWorkflow2Options) (SomeWorkflow2Run, error)

	// SomeWorkflow3 does some workflow thing.
	// Deprecated: Use SomeWorkflow2 instead.
	SomeWorkflow3(ctx context.Context, req *SomeWorkflow3Request, opts ...*SomeWorkflow3Options) error

	// SomeWorkflow3Async starts a(n) mycompany.simple.Simple.SomeWorkflow3 workflow and returns a handle to the workflow run
	//
	// Deprecated: Do not use.
	SomeWorkflow3Async(ctx context.Context, req *SomeWorkflow3Request, opts ...*SomeWorkflow3Options) (SomeWorkflow3Run, error)

	// GetSomeWorkflow3 retrieves a handle to an existing mycompany.simple.Simple.SomeWorkflow3 workflow execution
	//
	// Deprecated: Do not use.
	GetSomeWorkflow3(ctx context.Context, workflowID string, runID string) SomeWorkflow3Run

	// SomeWorkflow3WithSomeSignal2 sends a(n) mycompany.simple.Simple.SomeSignal2 signal to a(n) mycompany.simple.Simple.SomeWorkflow3 workflow, starting it if necessary, and blocks until workflow completion
	//
	// Deprecated: Do not use.
	SomeWorkflow3WithSomeSignal2(ctx context.Context, req *SomeWorkflow3Request, signal *SomeSignal2Request, opts ...*SomeWorkflow3Options) error

	// SomeWorkflow3WithSomeSignal2Async sends a(n) mycompany.simple.Simple.SomeSignal2 signal to a(n) mycompany.simple.Simple.SomeWorkflow3 workflow, starting it if necessary, and returns a handle to the workflow execution
	//
	// Deprecated: Do not use.
	SomeWorkflow3WithSomeSignal2Async(ctx context.Context, req *SomeWorkflow3Request, signal *SomeSignal2Request, opts ...*SomeWorkflow3Options) (SomeWorkflow3Run, error)

	// SomeWorkflow4 retrieves a paginated list of items
	SomeWorkflow4(ctx context.Context, req *v1.PaginatedRequest, opts ...*SomeWorkflow4Options) (*v1.PaginatedResponse, error)

	// SomeWorkflow4Async starts a(n) mycompany.simple.Simple.SomeWorkflow4 workflow and returns a handle to the workflow run
	SomeWorkflow4Async(ctx context.Context, req *v1.PaginatedRequest, opts ...*SomeWorkflow4Options) (SomeWorkflow4Run, error)

	// GetSomeWorkflow4 retrieves a handle to an existing mycompany.simple.Simple.SomeWorkflow4 workflow execution
	GetSomeWorkflow4(ctx context.Context, workflowID string, runID string) SomeWorkflow4Run

	// 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

	// SomeQuery1 queries some thing.
	SomeQuery1(ctx context.Context, workflowID string, runID string) (*SomeQuery1Response, error)

	// SomeQuery2 queries some thing.
	SomeQuery2(ctx context.Context, workflowID string, runID string, query *SomeQuery2Request) (*SomeQuery2Response, error)

	// SomeSignal1 is a signal.
	SomeSignal1(ctx context.Context, workflowID string, runID string) error

	// SomeSignal2 is a signal.
	SomeSignal2(ctx context.Context, workflowID string, runID string, signal *SomeSignal2Request) error

	// SomeSignal3 is a signal.
	SomeSignal3(ctx context.Context, workflowID string, runID string, signal *SomeSignal3Request) error

	// SomeUpdate1 updates a SomeWorkflow2
	SomeUpdate1(ctx context.Context, workflowID string, runID string, req *SomeUpdate1Request, opts ...*SomeUpdate1Options) (*SomeUpdate1Response, error)

	// SomeUpdate1Async starts a(n) mycompany.simple.Simple.SomeUpdate1 update and returns a handle to the workflow update
	SomeUpdate1Async(ctx context.Context, workflowID string, runID string, req *SomeUpdate1Request, opts ...*SomeUpdate1Options) (SomeUpdate1Handle, error)

	// GetSomeUpdate1 retrieves a handle to an existing mycompany.simple.Simple.SomeUpdate1 update
	GetSomeUpdate1(ctx context.Context, req client.GetWorkflowUpdateHandleOptions) (SomeUpdate1Handle, error)
}

SimpleClient describes a client for a(n) mycompany.simple.Simple worker

func NewSimpleClient 

func NewSimpleClient(c client.Client, options ...*simpleClientOptions) SimpleClient

NewSimpleClient initializes a new mycompany.simple.Simple client

func NewSimpleClientWithOptions 

func NewSimpleClientWithOptions(c client.Client, opts client.Options, options ...*simpleClientOptions) (SimpleClient, error)

NewSimpleClientWithOptions initializes a new Simple client with the given options

type SimpleWorkflowFunctions added in v1.12.0 

type SimpleWorkflowFunctions interface {
	// SomeWorkflow1 does some workflow thing.
	SomeWorkflow1(workflow.Context, *SomeWorkflow1Request) (*SomeWorkflow1Response, error)
	// SomeWorkflow2 does some workflow thing.
	SomeWorkflow2(workflow.Context) error
	// SomeWorkflow3 does some workflow thing.
	// Deprecated: Use SomeWorkflow2 instead.
	SomeWorkflow3(workflow.Context, *SomeWorkflow3Request) error
	// SomeWorkflow4 retrieves a paginated list of items
	SomeWorkflow4(workflow.Context, *v1.PaginatedRequest) (*v1.PaginatedResponse, error)
}

SimpleWorkflowFunctions describes a mockable dependency for inlining workflows within other workflows

func NewSimpleWorkflowFunctions added in v1.12.0 

func NewSimpleWorkflowFunctions() SimpleWorkflowFunctions

type SimpleWorkflows 

type SimpleWorkflows interface {
	// SomeWorkflow1 does some workflow thing.
	SomeWorkflow1(ctx workflow.Context, input *SomeWorkflow1WorkflowInput) (SomeWorkflow1Workflow, error)

	// SomeWorkflow2 does some workflow thing.
	SomeWorkflow2(ctx workflow.Context, input *SomeWorkflow2WorkflowInput) (SomeWorkflow2Workflow, error)

	// SomeWorkflow3 does some workflow thing.
	// Deprecated: Use SomeWorkflow2 instead.
	SomeWorkflow3(ctx workflow.Context, input *SomeWorkflow3WorkflowInput) (SomeWorkflow3Workflow, error)

	// SomeWorkflow4 retrieves a paginated list of items
	SomeWorkflow4(ctx workflow.Context, input *SomeWorkflow4WorkflowInput) (SomeWorkflow4Workflow, error)
}

SimpleWorkflows provides methods for initializing new mycompany.simple.Simple workflow values

type SomeActivity1ActivityOptions 

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

SomeActivity1ActivityOptions provides configuration for a(n) mycompany.simple.SomeActivity1 activity

func NewSomeActivity1ActivityOptions 

func NewSomeActivity1ActivityOptions() *SomeActivity1ActivityOptions

NewSomeActivity1ActivityOptions initializes a new SomeActivity1ActivityOptions value

func (*SomeActivity1ActivityOptions) Build added in v1.13.0 

func (o *SomeActivity1ActivityOptions) 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 (*SomeActivity1ActivityOptions) WithActivityOptions 

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

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

func (*SomeActivity1ActivityOptions) WithHeartbeatTimeout added in v1.13.0 

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

WithHeartbeatTimeout sets the HeartbeatTimeout value

func (*SomeActivity1ActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeActivity1ActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeActivity1ActivityOptions) WithScheduleToStartTimeout added in v1.13.0 

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

WithScheduleToStartTimeout sets the ScheduleToStartTimeout value

func (*SomeActivity1ActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

func (*SomeActivity1ActivityOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeActivity1ActivityOptions) WithWaitForCancellation added in v1.13.0 

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

WithWaitForCancellation sets the WaitForCancellation value

type SomeActivity1Future 

type SomeActivity1Future struct {
	Future workflow.Future
}

SomeActivity1Future describes a(n) mycompany.simple.SomeActivity1 activity execution

func SomeActivity1Async 

func SomeActivity1Async(ctx workflow.Context, options ...*SomeActivity1ActivityOptions) *SomeActivity1Future

SomeActivity1 does some activity thing.

func SomeActivity1LocalAsync 

func SomeActivity1LocalAsync(ctx workflow.Context, options ...*SomeActivity1LocalActivityOptions) *SomeActivity1Future

SomeActivity1 does some activity thing.

func (*SomeActivity1Future) Get 

func (f *SomeActivity1Future) Get(ctx workflow.Context) error

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

func (*SomeActivity1Future) Select 

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

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

type SomeActivity1LocalActivityOptions 

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

SomeActivity1LocalActivityOptions provides configuration for a(n) mycompany.simple.SomeActivity1 activity

func NewSomeActivity1LocalActivityOptions 

func NewSomeActivity1LocalActivityOptions() *SomeActivity1LocalActivityOptions

NewSomeActivity1LocalActivityOptions initializes a new SomeActivity1LocalActivityOptions value

func (*SomeActivity1LocalActivityOptions) Build added in v1.13.0 

func (o *SomeActivity1LocalActivityOptions) 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 (*SomeActivity1LocalActivityOptions) Local 

func (o *SomeActivity1LocalActivityOptions) Local(fn func(context.Context) error) *SomeActivity1LocalActivityOptions

Local specifies a custom mycompany.simple.SomeActivity1 implementation

func (*SomeActivity1LocalActivityOptions) WithLocalActivityOptions 

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

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

func (*SomeActivity1LocalActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeActivity1LocalActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeActivity1LocalActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

type SomeActivity2ActivityOptions 

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

SomeActivity2ActivityOptions provides configuration for a(n) mycompany.simple.Simple.SomeActivity2 activity

func NewSomeActivity2ActivityOptions 

func NewSomeActivity2ActivityOptions() *SomeActivity2ActivityOptions

NewSomeActivity2ActivityOptions initializes a new SomeActivity2ActivityOptions value

func (*SomeActivity2ActivityOptions) Build added in v1.13.0 

func (o *SomeActivity2ActivityOptions) 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 (*SomeActivity2ActivityOptions) WithActivityOptions 

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

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

func (*SomeActivity2ActivityOptions) WithHeartbeatTimeout added in v1.13.0 

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

WithHeartbeatTimeout sets the HeartbeatTimeout value

func (*SomeActivity2ActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeActivity2ActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeActivity2ActivityOptions) WithScheduleToStartTimeout added in v1.13.0 

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

WithScheduleToStartTimeout sets the ScheduleToStartTimeout value

func (*SomeActivity2ActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

func (*SomeActivity2ActivityOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeActivity2ActivityOptions) WithWaitForCancellation added in v1.13.0 

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

WithWaitForCancellation sets the WaitForCancellation value

type SomeActivity2Future 

type SomeActivity2Future struct {
	Future workflow.Future
}

SomeActivity2Future describes a(n) mycompany.simple.Simple.SomeActivity2 activity execution

func SomeActivity2Async 

func SomeActivity2Async(ctx workflow.Context, req *SomeActivity2Request, options ...*SomeActivity2ActivityOptions) *SomeActivity2Future

SomeActivity2 does some activity thing.

func SomeActivity2LocalAsync 

func SomeActivity2LocalAsync(ctx workflow.Context, req *SomeActivity2Request, options ...*SomeActivity2LocalActivityOptions) *SomeActivity2Future

SomeActivity2 does some activity thing.

func (*SomeActivity2Future) Get 

func (f *SomeActivity2Future) Get(ctx workflow.Context) error

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

func (*SomeActivity2Future) Select 

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

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

type SomeActivity2LocalActivityOptions 

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

SomeActivity2LocalActivityOptions provides configuration for a(n) mycompany.simple.Simple.SomeActivity2 activity

func NewSomeActivity2LocalActivityOptions 

func NewSomeActivity2LocalActivityOptions() *SomeActivity2LocalActivityOptions

NewSomeActivity2LocalActivityOptions initializes a new SomeActivity2LocalActivityOptions value

func (*SomeActivity2LocalActivityOptions) Build added in v1.13.0 

func (o *SomeActivity2LocalActivityOptions) 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 (*SomeActivity2LocalActivityOptions) Local 

func (o *SomeActivity2LocalActivityOptions) Local(fn func(context.Context, *SomeActivity2Request) error) *SomeActivity2LocalActivityOptions

Local specifies a custom mycompany.simple.Simple.SomeActivity2 implementation

func (*SomeActivity2LocalActivityOptions) WithLocalActivityOptions 

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

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

func (*SomeActivity2LocalActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeActivity2LocalActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeActivity2LocalActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

type SomeActivity2Request 

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

func (*SomeActivity2Request) Descriptor deprecated 

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

Deprecated: Use SomeActivity2Request.ProtoReflect.Descriptor instead.

func (*SomeActivity2Request) GetRequestVal 

func (x *SomeActivity2Request) GetRequestVal() string

func (*SomeActivity2Request) ProtoMessage 

func (*SomeActivity2Request) ProtoMessage()

func (*SomeActivity2Request) ProtoReflect 

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

func (*SomeActivity2Request) Reset 

func (x *SomeActivity2Request) Reset()

func (*SomeActivity2Request) String 

func (x *SomeActivity2Request) String() string

type SomeActivity3ActivityOptions 

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

SomeActivity3ActivityOptions provides configuration for a(n) mycompany.simple.Simple.SomeActivity3 activity

func NewSomeActivity3ActivityOptions 

func NewSomeActivity3ActivityOptions() *SomeActivity3ActivityOptions

NewSomeActivity3ActivityOptions initializes a new SomeActivity3ActivityOptions value

func (*SomeActivity3ActivityOptions) Build added in v1.13.0 

func (o *SomeActivity3ActivityOptions) 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 (*SomeActivity3ActivityOptions) WithActivityOptions 

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

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

func (*SomeActivity3ActivityOptions) WithHeartbeatTimeout added in v1.13.0 

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

WithHeartbeatTimeout sets the HeartbeatTimeout value

func (*SomeActivity3ActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeActivity3ActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeActivity3ActivityOptions) WithScheduleToStartTimeout added in v1.13.0 

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

WithScheduleToStartTimeout sets the ScheduleToStartTimeout value

func (*SomeActivity3ActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

func (*SomeActivity3ActivityOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeActivity3ActivityOptions) WithWaitForCancellation added in v1.13.0 

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

WithWaitForCancellation sets the WaitForCancellation value

type SomeActivity3Future 

type SomeActivity3Future struct {
	Future workflow.Future
}

SomeActivity3Future describes a(n) mycompany.simple.Simple.SomeActivity3 activity execution

func SomeActivity3Async 

func SomeActivity3Async(ctx workflow.Context, req *SomeActivity3Request, options ...*SomeActivity3ActivityOptions) *SomeActivity3Future

SomeActivity3 does some activity thing.

func SomeActivity3LocalAsync 

func SomeActivity3LocalAsync(ctx workflow.Context, req *SomeActivity3Request, options ...*SomeActivity3LocalActivityOptions) *SomeActivity3Future

SomeActivity3 does some activity thing.

func (*SomeActivity3Future) Get 

func (f *SomeActivity3Future) Get(ctx workflow.Context) (*SomeActivity3Response, error)

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

func (*SomeActivity3Future) Select 

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

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

type SomeActivity3LocalActivityOptions 

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

SomeActivity3LocalActivityOptions provides configuration for a(n) mycompany.simple.Simple.SomeActivity3 activity

func NewSomeActivity3LocalActivityOptions 

func NewSomeActivity3LocalActivityOptions() *SomeActivity3LocalActivityOptions

NewSomeActivity3LocalActivityOptions initializes a new SomeActivity3LocalActivityOptions value

func (*SomeActivity3LocalActivityOptions) Build added in v1.13.0 

func (o *SomeActivity3LocalActivityOptions) 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 (*SomeActivity3LocalActivityOptions) Local 

func (o *SomeActivity3LocalActivityOptions) Local(fn func(context.Context, *SomeActivity3Request) (*SomeActivity3Response, error)) *SomeActivity3LocalActivityOptions

Local specifies a custom mycompany.simple.Simple.SomeActivity3 implementation

func (*SomeActivity3LocalActivityOptions) WithLocalActivityOptions 

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

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

func (*SomeActivity3LocalActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeActivity3LocalActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeActivity3LocalActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

type SomeActivity3Request 

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

func (*SomeActivity3Request) Descriptor deprecated 

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

Deprecated: Use SomeActivity3Request.ProtoReflect.Descriptor instead.

func (*SomeActivity3Request) GetRequestVal 

func (x *SomeActivity3Request) GetRequestVal() string

func (*SomeActivity3Request) ProtoMessage 

func (*SomeActivity3Request) ProtoMessage()

func (*SomeActivity3Request) ProtoReflect 

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

func (*SomeActivity3Request) Reset 

func (x *SomeActivity3Request) Reset()

func (*SomeActivity3Request) String 

func (x *SomeActivity3Request) String() string

type SomeActivity3Response 

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

func SomeActivity3 

func SomeActivity3(ctx workflow.Context, req *SomeActivity3Request, options ...*SomeActivity3ActivityOptions) (*SomeActivity3Response, error)

SomeActivity3 does some activity thing.

func SomeActivity3Local 

func SomeActivity3Local(ctx workflow.Context, req *SomeActivity3Request, options ...*SomeActivity3LocalActivityOptions) (*SomeActivity3Response, error)

SomeActivity3 does some activity thing.

func (*SomeActivity3Response) Descriptor deprecated 

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

Deprecated: Use SomeActivity3Response.ProtoReflect.Descriptor instead.

func (*SomeActivity3Response) GetResponseVal 

func (x *SomeActivity3Response) GetResponseVal() string

func (*SomeActivity3Response) ProtoMessage 

func (*SomeActivity3Response) ProtoMessage()

func (*SomeActivity3Response) ProtoReflect 

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

func (*SomeActivity3Response) Reset 

func (x *SomeActivity3Response) Reset()

func (*SomeActivity3Response) String 

func (x *SomeActivity3Response) String() string

type SomeActivity4ActivityOptions added in v1.13.0 

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

SomeActivity4ActivityOptions provides configuration for a(n) mycompany.simple.Simple.SomeActivity4 activity

func NewSomeActivity4ActivityOptions added in v1.13.0 

func NewSomeActivity4ActivityOptions() *SomeActivity4ActivityOptions

NewSomeActivity4ActivityOptions initializes a new SomeActivity4ActivityOptions value

func (*SomeActivity4ActivityOptions) Build added in v1.13.0 

func (o *SomeActivity4ActivityOptions) 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 (*SomeActivity4ActivityOptions) WithActivityOptions added in v1.13.0 

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

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

func (*SomeActivity4ActivityOptions) WithHeartbeatTimeout added in v1.13.0 

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

WithHeartbeatTimeout sets the HeartbeatTimeout value

func (*SomeActivity4ActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeActivity4ActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeActivity4ActivityOptions) WithScheduleToStartTimeout added in v1.13.0 

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

WithScheduleToStartTimeout sets the ScheduleToStartTimeout value

func (*SomeActivity4ActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

func (*SomeActivity4ActivityOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeActivity4ActivityOptions) WithWaitForCancellation added in v1.13.0 

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

WithWaitForCancellation sets the WaitForCancellation value

type SomeActivity4Future added in v1.13.0 

type SomeActivity4Future struct {
	Future workflow.Future
}

SomeActivity4Future describes a(n) mycompany.simple.Simple.SomeActivity4 activity execution

func SomeActivity4Async added in v1.13.0 

func SomeActivity4Async(ctx workflow.Context, options ...*SomeActivity4ActivityOptions) *SomeActivity4Future

SomeActivity4 does some activity thing.

func SomeActivity4LocalAsync added in v1.13.0 

func SomeActivity4LocalAsync(ctx workflow.Context, options ...*SomeActivity4LocalActivityOptions) *SomeActivity4Future

SomeActivity4 does some activity thing.

func (*SomeActivity4Future) Get added in v1.13.0 

func (f *SomeActivity4Future) Get(ctx workflow.Context) error

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

func (*SomeActivity4Future) Select added in v1.13.0 

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

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

type SomeActivity4LocalActivityOptions added in v1.13.0 

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

SomeActivity4LocalActivityOptions provides configuration for a(n) mycompany.simple.Simple.SomeActivity4 activity

func NewSomeActivity4LocalActivityOptions added in v1.13.0 

func NewSomeActivity4LocalActivityOptions() *SomeActivity4LocalActivityOptions

NewSomeActivity4LocalActivityOptions initializes a new SomeActivity4LocalActivityOptions value

func (*SomeActivity4LocalActivityOptions) Build added in v1.13.0 

func (o *SomeActivity4LocalActivityOptions) 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 (*SomeActivity4LocalActivityOptions) Local added in v1.13.0 

func (o *SomeActivity4LocalActivityOptions) Local(fn func(context.Context) error) *SomeActivity4LocalActivityOptions

Local specifies a custom mycompany.simple.Simple.SomeActivity4 implementation

func (*SomeActivity4LocalActivityOptions) WithLocalActivityOptions added in v1.13.0 

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

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

func (*SomeActivity4LocalActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeActivity4LocalActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeActivity4LocalActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

type SomeDeprecatedActivity1ActivityOptions 

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

SomeDeprecatedActivity1ActivityOptions provides configuration for a(n) mycompany.simple.Deprecated.SomeDeprecatedActivity1 activity

func NewSomeDeprecatedActivity1ActivityOptions 

func NewSomeDeprecatedActivity1ActivityOptions() *SomeDeprecatedActivity1ActivityOptions

NewSomeDeprecatedActivity1ActivityOptions initializes a new SomeDeprecatedActivity1ActivityOptions value

func (*SomeDeprecatedActivity1ActivityOptions) Build added in v1.13.0 

func (o *SomeDeprecatedActivity1ActivityOptions) 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 (*SomeDeprecatedActivity1ActivityOptions) WithActivityOptions 

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

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

func (*SomeDeprecatedActivity1ActivityOptions) WithHeartbeatTimeout added in v1.13.0 

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

WithHeartbeatTimeout sets the HeartbeatTimeout value

func (*SomeDeprecatedActivity1ActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeDeprecatedActivity1ActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeDeprecatedActivity1ActivityOptions) WithScheduleToStartTimeout added in v1.13.0 

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

WithScheduleToStartTimeout sets the ScheduleToStartTimeout value

func (*SomeDeprecatedActivity1ActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

func (*SomeDeprecatedActivity1ActivityOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeDeprecatedActivity1ActivityOptions) WithWaitForCancellation added in v1.13.0 

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

WithWaitForCancellation sets the WaitForCancellation value

type SomeDeprecatedActivity1Future 

type SomeDeprecatedActivity1Future struct {
	Future workflow.Future
}

SomeDeprecatedActivity1Future describes a(n) mycompany.simple.Deprecated.SomeDeprecatedActivity1 activity execution

func SomeDeprecatedActivity1Async deprecated 

func SomeDeprecatedActivity1Async(ctx workflow.Context, req *SomeDeprecatedMessage, options ...*SomeDeprecatedActivity1ActivityOptions) *SomeDeprecatedActivity1Future

SomeDeprecatedActivity1 does something

Deprecated: Do not use.

func SomeDeprecatedActivity1LocalAsync deprecated 

func SomeDeprecatedActivity1LocalAsync(ctx workflow.Context, req *SomeDeprecatedMessage, options ...*SomeDeprecatedActivity1LocalActivityOptions) *SomeDeprecatedActivity1Future

SomeDeprecatedActivity1 does something

Deprecated: Do not use.

func (*SomeDeprecatedActivity1Future) Get 

func (f *SomeDeprecatedActivity1Future) Get(ctx workflow.Context) (*SomeDeprecatedMessage, error)

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

func (*SomeDeprecatedActivity1Future) Select 

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

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

type SomeDeprecatedActivity1LocalActivityOptions 

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

SomeDeprecatedActivity1LocalActivityOptions provides configuration for a(n) mycompany.simple.Deprecated.SomeDeprecatedActivity1 activity

func NewSomeDeprecatedActivity1LocalActivityOptions 

func NewSomeDeprecatedActivity1LocalActivityOptions() *SomeDeprecatedActivity1LocalActivityOptions

NewSomeDeprecatedActivity1LocalActivityOptions initializes a new SomeDeprecatedActivity1LocalActivityOptions value

func (*SomeDeprecatedActivity1LocalActivityOptions) Build added in v1.13.0 

func (o *SomeDeprecatedActivity1LocalActivityOptions) 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 (*SomeDeprecatedActivity1LocalActivityOptions) Local 

func (o *SomeDeprecatedActivity1LocalActivityOptions) Local(fn func(context.Context, *SomeDeprecatedMessage) (*SomeDeprecatedMessage, error)) *SomeDeprecatedActivity1LocalActivityOptions

Local specifies a custom mycompany.simple.Deprecated.SomeDeprecatedActivity1 implementation

func (*SomeDeprecatedActivity1LocalActivityOptions) WithLocalActivityOptions 

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

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

func (*SomeDeprecatedActivity1LocalActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeDeprecatedActivity1LocalActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeDeprecatedActivity1LocalActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

type SomeDeprecatedActivity2ActivityOptions 

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

SomeDeprecatedActivity2ActivityOptions provides configuration for a(n) mycompany.simple.Deprecated.SomeDeprecatedActivity2 activity

func NewSomeDeprecatedActivity2ActivityOptions 

func NewSomeDeprecatedActivity2ActivityOptions() *SomeDeprecatedActivity2ActivityOptions

NewSomeDeprecatedActivity2ActivityOptions initializes a new SomeDeprecatedActivity2ActivityOptions value

func (*SomeDeprecatedActivity2ActivityOptions) Build added in v1.13.0 

func (o *SomeDeprecatedActivity2ActivityOptions) 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 (*SomeDeprecatedActivity2ActivityOptions) WithActivityOptions 

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

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

func (*SomeDeprecatedActivity2ActivityOptions) WithHeartbeatTimeout added in v1.13.0 

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

WithHeartbeatTimeout sets the HeartbeatTimeout value

func (*SomeDeprecatedActivity2ActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeDeprecatedActivity2ActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeDeprecatedActivity2ActivityOptions) WithScheduleToStartTimeout added in v1.13.0 

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

WithScheduleToStartTimeout sets the ScheduleToStartTimeout value

func (*SomeDeprecatedActivity2ActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

func (*SomeDeprecatedActivity2ActivityOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeDeprecatedActivity2ActivityOptions) WithWaitForCancellation added in v1.13.0 

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

WithWaitForCancellation sets the WaitForCancellation value

type SomeDeprecatedActivity2Future 

type SomeDeprecatedActivity2Future struct {
	Future workflow.Future
}

SomeDeprecatedActivity2Future describes a(n) mycompany.simple.Deprecated.SomeDeprecatedActivity2 activity execution

func SomeDeprecatedActivity2Async deprecated 

func SomeDeprecatedActivity2Async(ctx workflow.Context, req *SomeDeprecatedMessage, options ...*SomeDeprecatedActivity2ActivityOptions) *SomeDeprecatedActivity2Future

SomeDeprecatedActivity2 does something else

Deprecated: a custom activity deprecation message.

func SomeDeprecatedActivity2LocalAsync deprecated 

func SomeDeprecatedActivity2LocalAsync(ctx workflow.Context, req *SomeDeprecatedMessage, options ...*SomeDeprecatedActivity2LocalActivityOptions) *SomeDeprecatedActivity2Future

SomeDeprecatedActivity2 does something else

Deprecated: a custom activity deprecation message.

func (*SomeDeprecatedActivity2Future) Get 

func (f *SomeDeprecatedActivity2Future) Get(ctx workflow.Context) (*SomeDeprecatedMessage, error)

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

func (*SomeDeprecatedActivity2Future) Select 

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

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

type SomeDeprecatedActivity2LocalActivityOptions 

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

SomeDeprecatedActivity2LocalActivityOptions provides configuration for a(n) mycompany.simple.Deprecated.SomeDeprecatedActivity2 activity

func NewSomeDeprecatedActivity2LocalActivityOptions 

func NewSomeDeprecatedActivity2LocalActivityOptions() *SomeDeprecatedActivity2LocalActivityOptions

NewSomeDeprecatedActivity2LocalActivityOptions initializes a new SomeDeprecatedActivity2LocalActivityOptions value

func (*SomeDeprecatedActivity2LocalActivityOptions) Build added in v1.13.0 

func (o *SomeDeprecatedActivity2LocalActivityOptions) 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 (*SomeDeprecatedActivity2LocalActivityOptions) Local 

func (o *SomeDeprecatedActivity2LocalActivityOptions) Local(fn func(context.Context, *SomeDeprecatedMessage) (*SomeDeprecatedMessage, error)) *SomeDeprecatedActivity2LocalActivityOptions

Local specifies a custom mycompany.simple.Deprecated.SomeDeprecatedActivity2 implementation

func (*SomeDeprecatedActivity2LocalActivityOptions) WithLocalActivityOptions 

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

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

func (*SomeDeprecatedActivity2LocalActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeDeprecatedActivity2LocalActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeDeprecatedActivity2LocalActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

type SomeDeprecatedMessage 

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

func SomeDeprecatedActivity1 deprecated 

func SomeDeprecatedActivity1(ctx workflow.Context, req *SomeDeprecatedMessage, options ...*SomeDeprecatedActivity1ActivityOptions) (*SomeDeprecatedMessage, error)

SomeDeprecatedActivity1 does something

Deprecated: Do not use.

func SomeDeprecatedActivity1Local deprecated 

func SomeDeprecatedActivity1Local(ctx workflow.Context, req *SomeDeprecatedMessage, options ...*SomeDeprecatedActivity1LocalActivityOptions) (*SomeDeprecatedMessage, error)

SomeDeprecatedActivity1 does something

Deprecated: Do not use.

func SomeDeprecatedActivity2 deprecated 

func SomeDeprecatedActivity2(ctx workflow.Context, req *SomeDeprecatedMessage, options ...*SomeDeprecatedActivity2ActivityOptions) (*SomeDeprecatedMessage, error)

SomeDeprecatedActivity2 does something else

Deprecated: a custom activity deprecation message.

func SomeDeprecatedActivity2Local deprecated 

func SomeDeprecatedActivity2Local(ctx workflow.Context, req *SomeDeprecatedMessage, options ...*SomeDeprecatedActivity2LocalActivityOptions) (*SomeDeprecatedMessage, error)

SomeDeprecatedActivity2 does something else

Deprecated: a custom activity deprecation message.

func SomeDeprecatedWorkflow1Child deprecated 

func SomeDeprecatedWorkflow1Child(ctx workflow.Context, req *SomeDeprecatedMessage, options ...*SomeDeprecatedWorkflow1ChildOptions) (*SomeDeprecatedMessage, error)

SomeDeprecatedWorkflow1 does something

Deprecated: Do not use.

func SomeDeprecatedWorkflow2Child deprecated 

func SomeDeprecatedWorkflow2Child(ctx workflow.Context, req *SomeDeprecatedMessage, options ...*SomeDeprecatedWorkflow2ChildOptions) (*SomeDeprecatedMessage, error)

SomeDeprecatedWorkflow2 does something else

Deprecated: a custom workflow deprecation message.

func UnmarshalCliFlagsToSomeDeprecatedMessage 

func UnmarshalCliFlagsToSomeDeprecatedMessage(cmd *v2.Context) (*SomeDeprecatedMessage, error)

UnmarshalCliFlagsToSomeDeprecatedMessage unmarshals a SomeDeprecatedMessage from command line flags

func (*SomeDeprecatedMessage) Descriptor deprecated 

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

Deprecated: Use SomeDeprecatedMessage.ProtoReflect.Descriptor instead.

func (*SomeDeprecatedMessage) ProtoMessage 

func (*SomeDeprecatedMessage) ProtoMessage()

func (*SomeDeprecatedMessage) ProtoReflect 

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

func (*SomeDeprecatedMessage) Reset 

func (x *SomeDeprecatedMessage) Reset()

func (*SomeDeprecatedMessage) String 

func (x *SomeDeprecatedMessage) String() string

type SomeDeprecatedSignal1Signal 

type SomeDeprecatedSignal1Signal struct {
	Channel workflow.ReceiveChannel
}

SomeDeprecatedSignal1Signal describes a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal1 signal

func NewSomeDeprecatedSignal1Signal 

func NewSomeDeprecatedSignal1Signal(ctx workflow.Context) *SomeDeprecatedSignal1Signal

NewSomeDeprecatedSignal1Signal initializes a new mycompany.simple.Deprecated.SomeDeprecatedSignal1 signal wrapper

func (*SomeDeprecatedSignal1Signal) Receive 

func (s *SomeDeprecatedSignal1Signal) Receive(ctx workflow.Context) (*SomeDeprecatedMessage, bool)

Receive blocks until a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal1 signal is received

func (*SomeDeprecatedSignal1Signal) ReceiveAsync 

func (s *SomeDeprecatedSignal1Signal) ReceiveAsync() *SomeDeprecatedMessage

ReceiveAsync checks for a mycompany.simple.Deprecated.SomeDeprecatedSignal1 signal without blocking

func (*SomeDeprecatedSignal1Signal) ReceiveWithTimeout 

func (s *SomeDeprecatedSignal1Signal) ReceiveWithTimeout(ctx workflow.Context, timeout time.Duration) (resp *SomeDeprecatedMessage, ok bool, more bool)

ReceiveWithTimeout blocks until a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal1 signal is received or timeout expires. Returns more value of false when Channel is closed. Returns ok value of false when no value was found in the channel for the duration of timeout or the ctx was canceled. resp will be nil if ok is false.

func (*SomeDeprecatedSignal1Signal) Select 

func (s *SomeDeprecatedSignal1Signal) Select(sel workflow.Selector, fn func(*SomeDeprecatedMessage)) workflow.Selector

Select checks for a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal1 signal without blocking

type SomeDeprecatedSignal2Signal 

type SomeDeprecatedSignal2Signal struct {
	Channel workflow.ReceiveChannel
}

SomeDeprecatedSignal2Signal describes a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal2 signal

func NewSomeDeprecatedSignal2Signal 

func NewSomeDeprecatedSignal2Signal(ctx workflow.Context) *SomeDeprecatedSignal2Signal

NewSomeDeprecatedSignal2Signal initializes a new mycompany.simple.Deprecated.SomeDeprecatedSignal2 signal wrapper

func (*SomeDeprecatedSignal2Signal) Receive 

func (s *SomeDeprecatedSignal2Signal) Receive(ctx workflow.Context) (*SomeDeprecatedMessage, bool)

Receive blocks until a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal2 signal is received

func (*SomeDeprecatedSignal2Signal) ReceiveAsync 

func (s *SomeDeprecatedSignal2Signal) ReceiveAsync() *SomeDeprecatedMessage

ReceiveAsync checks for a mycompany.simple.Deprecated.SomeDeprecatedSignal2 signal without blocking

func (*SomeDeprecatedSignal2Signal) ReceiveWithTimeout 

func (s *SomeDeprecatedSignal2Signal) ReceiveWithTimeout(ctx workflow.Context, timeout time.Duration) (resp *SomeDeprecatedMessage, ok bool, more bool)

ReceiveWithTimeout blocks until a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal2 signal is received or timeout expires. Returns more value of false when Channel is closed. Returns ok value of false when no value was found in the channel for the duration of timeout or the ctx was canceled. resp will be nil if ok is false.

func (*SomeDeprecatedSignal2Signal) Select 

func (s *SomeDeprecatedSignal2Signal) Select(sel workflow.Selector, fn func(*SomeDeprecatedMessage)) workflow.Selector

Select checks for a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal2 signal without blocking

type SomeDeprecatedUpdate1Handle 

type SomeDeprecatedUpdate1Handle 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) (*SomeDeprecatedMessage, error)
}

SomeDeprecatedUpdate1Handle describes a(n) mycompany.simple.Deprecated.SomeDeprecatedUpdate1 update handle

type SomeDeprecatedUpdate1Options 

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

SomeDeprecatedUpdate1Options provides configuration for a mycompany.simple.Deprecated.SomeDeprecatedUpdate1 update operation

func NewSomeDeprecatedUpdate1Options 

func NewSomeDeprecatedUpdate1Options() *SomeDeprecatedUpdate1Options

NewSomeDeprecatedUpdate1Options initializes a new SomeDeprecatedUpdate1Options value

func (*SomeDeprecatedUpdate1Options) Build added in v1.13.0 

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

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

func (*SomeDeprecatedUpdate1Options) WithUpdateID added in v1.13.0 

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

WithUpdateID sets the UpdateID

func (*SomeDeprecatedUpdate1Options) WithUpdateWorkflowOptions 

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

WithUpdateWorkflowOptions sets the initial client.UpdateWorkflowOptions

func (*SomeDeprecatedUpdate1Options) WithWaitPolicy added in v1.13.0 

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

WithWaitPolicy sets the WaitPolicy

type SomeDeprecatedUpdate2Handle 

type SomeDeprecatedUpdate2Handle 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) (*SomeDeprecatedMessage, error)
}

SomeDeprecatedUpdate2Handle describes a(n) mycompany.simple.Deprecated.SomeDeprecatedUpdate2 update handle

type SomeDeprecatedUpdate2Options 

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

SomeDeprecatedUpdate2Options provides configuration for a mycompany.simple.Deprecated.SomeDeprecatedUpdate2 update operation

func NewSomeDeprecatedUpdate2Options 

func NewSomeDeprecatedUpdate2Options() *SomeDeprecatedUpdate2Options

NewSomeDeprecatedUpdate2Options initializes a new SomeDeprecatedUpdate2Options value

func (*SomeDeprecatedUpdate2Options) Build added in v1.13.0 

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

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

func (*SomeDeprecatedUpdate2Options) WithUpdateID added in v1.13.0 

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

WithUpdateID sets the UpdateID

func (*SomeDeprecatedUpdate2Options) WithUpdateWorkflowOptions 

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

WithUpdateWorkflowOptions sets the initial client.UpdateWorkflowOptions

func (*SomeDeprecatedUpdate2Options) WithWaitPolicy added in v1.13.0 

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

WithWaitPolicy sets the WaitPolicy

type SomeDeprecatedWorkflow1ChildOptions 

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

SomeDeprecatedWorkflow1ChildOptions provides configuration for a child mycompany.simple.Deprecated.SomeDeprecatedWorkflow1 workflow operation

func NewSomeDeprecatedWorkflow1ChildOptions 

func NewSomeDeprecatedWorkflow1ChildOptions() *SomeDeprecatedWorkflow1ChildOptions

NewSomeDeprecatedWorkflow1ChildOptions initializes a new SomeDeprecatedWorkflow1ChildOptions value

func (*SomeDeprecatedWorkflow1ChildOptions) Build added in v1.13.0 

func (o *SomeDeprecatedWorkflow1ChildOptions) 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 (*SomeDeprecatedWorkflow1ChildOptions) WithChildWorkflowOptions 

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

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

func (*SomeDeprecatedWorkflow1ChildOptions) WithExecutionTimeout added in v1.13.0 

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

WithExecutionTimeout sets the WorkflowExecutionTimeout value

func (*SomeDeprecatedWorkflow1ChildOptions) WithID added in v1.13.0 

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

WithID sets the WorkflowID value

func (*SomeDeprecatedWorkflow1ChildOptions) WithIDReusePolicy added in v1.13.0 

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

WithIDReusePolicy sets the WorkflowIDReusePolicy value

func (*SomeDeprecatedWorkflow1ChildOptions) WithParentClosePolicy added in v1.13.0 

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

WithParentClosePolicy sets the WorkflowIDReusePolicy value

func (*SomeDeprecatedWorkflow1ChildOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeDeprecatedWorkflow1ChildOptions) WithRunTimeout added in v1.13.0 

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

WithRunTimeout sets the WorkflowRunTimeout value

func (*SomeDeprecatedWorkflow1ChildOptions) WithSearchAttributes added in v1.13.0 

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

WithSearchAttributes sets the SearchAttributes value

func (*SomeDeprecatedWorkflow1ChildOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeDeprecatedWorkflow1ChildOptions) WithTaskTimeout added in v1.13.0 

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

WithTaskTimeout sets the WorkflowTaskTimeout value

func (*SomeDeprecatedWorkflow1ChildOptions) WithWaitForCancellation added in v1.13.0 

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

WithWaitForCancellation sets the WaitForCancellation value

type SomeDeprecatedWorkflow1ChildRun 

type SomeDeprecatedWorkflow1ChildRun struct {
	Future workflow.ChildWorkflowFuture
}

SomeDeprecatedWorkflow1ChildRun describes a child SomeDeprecatedWorkflow1 workflow run

func SomeDeprecatedWorkflow1ChildAsync deprecated 

func SomeDeprecatedWorkflow1ChildAsync(ctx workflow.Context, req *SomeDeprecatedMessage, options ...*SomeDeprecatedWorkflow1ChildOptions) (*SomeDeprecatedWorkflow1ChildRun, error)

SomeDeprecatedWorkflow1 does something

Deprecated: Do not use.

func (*SomeDeprecatedWorkflow1ChildRun) Get 

func (r *SomeDeprecatedWorkflow1ChildRun) Get(ctx workflow.Context) (*SomeDeprecatedMessage, error)

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

func (*SomeDeprecatedWorkflow1ChildRun) Select 

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

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

func (*SomeDeprecatedWorkflow1ChildRun) SelectStart 

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

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

func (*SomeDeprecatedWorkflow1ChildRun) SomeDeprecatedSignal1 

func (r *SomeDeprecatedWorkflow1ChildRun) SomeDeprecatedSignal1(ctx workflow.Context, input *SomeDeprecatedMessage) error

SomeDeprecatedSignal1 sends a(n) "mycompany.simple.Deprecated.SomeDeprecatedSignal1" signal request to the child workflow

func (*SomeDeprecatedWorkflow1ChildRun) SomeDeprecatedSignal1Async 

func (r *SomeDeprecatedWorkflow1ChildRun) SomeDeprecatedSignal1Async(ctx workflow.Context, input *SomeDeprecatedMessage) workflow.Future

SomeDeprecatedSignal1Async sends a(n) "mycompany.simple.Deprecated.SomeDeprecatedSignal1" signal request to the child workflow

func (*SomeDeprecatedWorkflow1ChildRun) WaitStart 

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

WaitStart waits for the child workflow to start

type SomeDeprecatedWorkflow1Options 

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

SomeDeprecatedWorkflow1Options provides configuration for a mycompany.simple.Deprecated.SomeDeprecatedWorkflow1 workflow operation

func NewSomeDeprecatedWorkflow1Options 

func NewSomeDeprecatedWorkflow1Options() *SomeDeprecatedWorkflow1Options

NewSomeDeprecatedWorkflow1Options initializes a new SomeDeprecatedWorkflow1Options value

func (*SomeDeprecatedWorkflow1Options) Build added in v1.13.0 

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

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

func (*SomeDeprecatedWorkflow1Options) WithExecutionTimeout added in v1.13.0 

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

WithExecutionTimeout sets the WorkflowExecutionTimeout value

func (*SomeDeprecatedWorkflow1Options) WithID added in v1.13.0 

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

WithID sets the ID value

func (*SomeDeprecatedWorkflow1Options) WithIDReusePolicy added in v1.13.0 

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

WithIDReusePolicy sets the WorkflowIDReusePolicy value

func (*SomeDeprecatedWorkflow1Options) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeDeprecatedWorkflow1Options) WithRunTimeout added in v1.13.0 

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

WithRunTimeout sets the WorkflowRunTimeout value

func (*SomeDeprecatedWorkflow1Options) WithSearchAttributes added in v1.13.0 

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

WithSearchAttributes sets the SearchAttributes value

func (*SomeDeprecatedWorkflow1Options) WithStartWorkflowOptions 

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

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

func (*SomeDeprecatedWorkflow1Options) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeDeprecatedWorkflow1Options) WithTaskTimeout added in v1.13.0 

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

WithTaskTimeout sets the WorkflowTaskTimeout value

type SomeDeprecatedWorkflow1Run 

type SomeDeprecatedWorkflow1Run 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) (*SomeDeprecatedMessage, 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

	// SomeDeprecatedQuery1 does something else
	//
	// Deprecated: Do not use.
	SomeDeprecatedQuery1(ctx context.Context, req *SomeDeprecatedMessage) (*SomeDeprecatedMessage, error)

	// SomeDeprecatedSignal1 does something else
	//
	// Deprecated: Do not use.
	SomeDeprecatedSignal1(ctx context.Context, req *SomeDeprecatedMessage) error

	// SomeDeprecatedUpdate1 does something else
	//
	// Deprecated: Do not use.
	SomeDeprecatedUpdate1(ctx context.Context, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedUpdate1Options) (*SomeDeprecatedMessage, error)

	// SomeDeprecatedUpdate1 does something else
	//
	// Deprecated: Do not use.
	SomeDeprecatedUpdate1Async(ctx context.Context, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedUpdate1Options) (SomeDeprecatedUpdate1Handle, error)
}

SomeDeprecatedWorkflow1Run describes a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow1 workflow run

type SomeDeprecatedWorkflow1Workflow deprecated 

type SomeDeprecatedWorkflow1Workflow interface {
	// Execute defines the entrypoint to a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow1 workflow
	//
	// Deprecated: Do not use.
	Execute(ctx workflow.Context) (*SomeDeprecatedMessage, error)

	// SomeDeprecatedQuery1 does something else
	//
	// Deprecated: Do not use.
	SomeDeprecatedQuery1(*SomeDeprecatedMessage) (*SomeDeprecatedMessage, error)

	// SomeDeprecatedUpdate1 does something else
	//
	// Deprecated: Do not use.
	SomeDeprecatedUpdate1(workflow.Context, *SomeDeprecatedMessage) (*SomeDeprecatedMessage, error)
}

SomeDeprecatedWorkflow1 does something

Deprecated: Do not use.

workflow details: (name: "mycompany.simple.Deprecated.SomeDeprecatedWorkflow1")

type SomeDeprecatedWorkflow1WorkflowInput 

type SomeDeprecatedWorkflow1WorkflowInput struct {
	Req                   *SomeDeprecatedMessage
	SomeDeprecatedSignal1 *SomeDeprecatedSignal1Signal
}

SomeDeprecatedWorkflow1WorkflowInput describes the input to a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow1 workflow constructor

type SomeDeprecatedWorkflow2ChildOptions 

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

SomeDeprecatedWorkflow2ChildOptions provides configuration for a child mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow operation

func NewSomeDeprecatedWorkflow2ChildOptions 

func NewSomeDeprecatedWorkflow2ChildOptions() *SomeDeprecatedWorkflow2ChildOptions

NewSomeDeprecatedWorkflow2ChildOptions initializes a new SomeDeprecatedWorkflow2ChildOptions value

func (*SomeDeprecatedWorkflow2ChildOptions) Build added in v1.13.0 

func (o *SomeDeprecatedWorkflow2ChildOptions) 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 (*SomeDeprecatedWorkflow2ChildOptions) WithChildWorkflowOptions 

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

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

func (*SomeDeprecatedWorkflow2ChildOptions) WithExecutionTimeout added in v1.13.0 

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

WithExecutionTimeout sets the WorkflowExecutionTimeout value

func (*SomeDeprecatedWorkflow2ChildOptions) WithID added in v1.13.0 

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

WithID sets the WorkflowID value

func (*SomeDeprecatedWorkflow2ChildOptions) WithIDReusePolicy added in v1.13.0 

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

WithIDReusePolicy sets the WorkflowIDReusePolicy value

func (*SomeDeprecatedWorkflow2ChildOptions) WithParentClosePolicy added in v1.13.0 

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

WithParentClosePolicy sets the WorkflowIDReusePolicy value

func (*SomeDeprecatedWorkflow2ChildOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeDeprecatedWorkflow2ChildOptions) WithRunTimeout added in v1.13.0 

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

WithRunTimeout sets the WorkflowRunTimeout value

func (*SomeDeprecatedWorkflow2ChildOptions) WithSearchAttributes added in v1.13.0 

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

WithSearchAttributes sets the SearchAttributes value

func (*SomeDeprecatedWorkflow2ChildOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeDeprecatedWorkflow2ChildOptions) WithTaskTimeout added in v1.13.0 

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

WithTaskTimeout sets the WorkflowTaskTimeout value

func (*SomeDeprecatedWorkflow2ChildOptions) WithWaitForCancellation added in v1.13.0 

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

WithWaitForCancellation sets the WaitForCancellation value

type SomeDeprecatedWorkflow2ChildRun 

type SomeDeprecatedWorkflow2ChildRun struct {
	Future workflow.ChildWorkflowFuture
}

SomeDeprecatedWorkflow2ChildRun describes a child SomeDeprecatedWorkflow2 workflow run

func SomeDeprecatedWorkflow2ChildAsync deprecated 

func SomeDeprecatedWorkflow2ChildAsync(ctx workflow.Context, req *SomeDeprecatedMessage, options ...*SomeDeprecatedWorkflow2ChildOptions) (*SomeDeprecatedWorkflow2ChildRun, error)

SomeDeprecatedWorkflow2 does something else

Deprecated: a custom workflow deprecation message.

func (*SomeDeprecatedWorkflow2ChildRun) Get 

func (r *SomeDeprecatedWorkflow2ChildRun) Get(ctx workflow.Context) (*SomeDeprecatedMessage, error)

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

func (*SomeDeprecatedWorkflow2ChildRun) Select 

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

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

func (*SomeDeprecatedWorkflow2ChildRun) SelectStart 

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

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

func (*SomeDeprecatedWorkflow2ChildRun) SomeDeprecatedSignal2 

func (r *SomeDeprecatedWorkflow2ChildRun) SomeDeprecatedSignal2(ctx workflow.Context, input *SomeDeprecatedMessage) error

SomeDeprecatedSignal2 sends a(n) "mycompany.simple.Deprecated.SomeDeprecatedSignal2" signal request to the child workflow

func (*SomeDeprecatedWorkflow2ChildRun) SomeDeprecatedSignal2Async 

func (r *SomeDeprecatedWorkflow2ChildRun) SomeDeprecatedSignal2Async(ctx workflow.Context, input *SomeDeprecatedMessage) workflow.Future

SomeDeprecatedSignal2Async sends a(n) "mycompany.simple.Deprecated.SomeDeprecatedSignal2" signal request to the child workflow

func (*SomeDeprecatedWorkflow2ChildRun) WaitStart 

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

WaitStart waits for the child workflow to start

type SomeDeprecatedWorkflow2Options 

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

SomeDeprecatedWorkflow2Options provides configuration for a mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow operation

func NewSomeDeprecatedWorkflow2Options 

func NewSomeDeprecatedWorkflow2Options() *SomeDeprecatedWorkflow2Options

NewSomeDeprecatedWorkflow2Options initializes a new SomeDeprecatedWorkflow2Options value

func (*SomeDeprecatedWorkflow2Options) Build added in v1.13.0 

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

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

func (*SomeDeprecatedWorkflow2Options) WithExecutionTimeout added in v1.13.0 

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

WithExecutionTimeout sets the WorkflowExecutionTimeout value

func (*SomeDeprecatedWorkflow2Options) WithID added in v1.13.0 

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

WithID sets the ID value

func (*SomeDeprecatedWorkflow2Options) WithIDReusePolicy added in v1.13.0 

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

WithIDReusePolicy sets the WorkflowIDReusePolicy value

func (*SomeDeprecatedWorkflow2Options) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeDeprecatedWorkflow2Options) WithRunTimeout added in v1.13.0 

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

WithRunTimeout sets the WorkflowRunTimeout value

func (*SomeDeprecatedWorkflow2Options) WithSearchAttributes added in v1.13.0 

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

WithSearchAttributes sets the SearchAttributes value

func (*SomeDeprecatedWorkflow2Options) WithStartWorkflowOptions 

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

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

func (*SomeDeprecatedWorkflow2Options) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeDeprecatedWorkflow2Options) WithTaskTimeout added in v1.13.0 

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

WithTaskTimeout sets the WorkflowTaskTimeout value

type SomeDeprecatedWorkflow2Run 

type SomeDeprecatedWorkflow2Run 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) (*SomeDeprecatedMessage, 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

	// SomeDeprecatedQuery2 does something else
	//
	// Deprecated: a custom query deprecation message.
	SomeDeprecatedQuery2(ctx context.Context, req *SomeDeprecatedMessage) (*SomeDeprecatedMessage, error)

	// SomeDeprecatedSignal2 does something else
	//
	// Deprecated: a custom signal deprecation message.
	SomeDeprecatedSignal2(ctx context.Context, req *SomeDeprecatedMessage) error

	// SomeDeprecatedUpdate2 does something else
	//
	// Deprecated: a custom signal deprecation message.
	SomeDeprecatedUpdate2(ctx context.Context, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedUpdate2Options) (*SomeDeprecatedMessage, error)

	// SomeDeprecatedUpdate2 does something else
	//
	// Deprecated: a custom signal deprecation message.
	SomeDeprecatedUpdate2Async(ctx context.Context, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedUpdate2Options) (SomeDeprecatedUpdate2Handle, error)
}

SomeDeprecatedWorkflow2Run describes a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow run

type SomeDeprecatedWorkflow2Workflow deprecated 

type SomeDeprecatedWorkflow2Workflow interface {
	// Execute defines the entrypoint to a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow
	//
	// Deprecated: Do not use.
	Execute(ctx workflow.Context) (*SomeDeprecatedMessage, error)

	// SomeDeprecatedQuery2 does something else
	//
	// Deprecated: a custom query deprecation message.
	SomeDeprecatedQuery2(*SomeDeprecatedMessage) (*SomeDeprecatedMessage, error)

	// SomeDeprecatedUpdate2 does something else
	//
	// Deprecated: a custom signal deprecation message.
	SomeDeprecatedUpdate2(workflow.Context, *SomeDeprecatedMessage) (*SomeDeprecatedMessage, error)
}

SomeDeprecatedWorkflow2 does something else

Deprecated: a custom workflow deprecation message.

workflow details: (name: "mycompany.simple.Deprecated.SomeDeprecatedWorkflow2")

type SomeDeprecatedWorkflow2WorkflowInput 

type SomeDeprecatedWorkflow2WorkflowInput struct {
	Req                   *SomeDeprecatedMessage
	SomeDeprecatedSignal2 *SomeDeprecatedSignal2Signal
}

SomeDeprecatedWorkflow2WorkflowInput describes the input to a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow constructor

type SomeQuery1Response 

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

func (*SomeQuery1Response) Descriptor deprecated 

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

Deprecated: Use SomeQuery1Response.ProtoReflect.Descriptor instead.

func (*SomeQuery1Response) GetResponseVal 

func (x *SomeQuery1Response) GetResponseVal() string

func (*SomeQuery1Response) ProtoMessage 

func (*SomeQuery1Response) ProtoMessage()

func (*SomeQuery1Response) ProtoReflect 

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

func (*SomeQuery1Response) Reset 

func (x *SomeQuery1Response) Reset()

func (*SomeQuery1Response) String 

func (x *SomeQuery1Response) String() string

type SomeQuery2Request 

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

func UnmarshalCliFlagsToSomeQuery2Request 

func UnmarshalCliFlagsToSomeQuery2Request(cmd *v2.Context) (*SomeQuery2Request, error)

UnmarshalCliFlagsToSomeQuery2Request unmarshals a SomeQuery2Request from command line flags

func (*SomeQuery2Request) Descriptor deprecated 

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

Deprecated: Use SomeQuery2Request.ProtoReflect.Descriptor instead.

func (*SomeQuery2Request) GetRequestVal 

func (x *SomeQuery2Request) GetRequestVal() string

func (*SomeQuery2Request) ProtoMessage 

func (*SomeQuery2Request) ProtoMessage()

func (*SomeQuery2Request) ProtoReflect 

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

func (*SomeQuery2Request) Reset 

func (x *SomeQuery2Request) Reset()

func (*SomeQuery2Request) String 

func (x *SomeQuery2Request) String() string

type SomeQuery2Response 

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

func (*SomeQuery2Response) Descriptor deprecated 

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

Deprecated: Use SomeQuery2Response.ProtoReflect.Descriptor instead.

func (*SomeQuery2Response) GetResponseVal 

func (x *SomeQuery2Response) GetResponseVal() string

func (*SomeQuery2Response) ProtoMessage 

func (*SomeQuery2Response) ProtoMessage()

func (*SomeQuery2Response) ProtoReflect 

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

func (*SomeQuery2Response) Reset 

func (x *SomeQuery2Response) Reset()

func (*SomeQuery2Response) String 

func (x *SomeQuery2Response) String() string

type SomeSignal1ActivityOptions 

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

SomeSignal1ActivityOptions provides configuration for a(n) mycompany.simple.Simple.SomeSignal1 activity

func NewSomeSignal1ActivityOptions 

func NewSomeSignal1ActivityOptions() *SomeSignal1ActivityOptions

NewSomeSignal1ActivityOptions initializes a new SomeSignal1ActivityOptions value

func (*SomeSignal1ActivityOptions) Build added in v1.13.0 

func (o *SomeSignal1ActivityOptions) 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 (*SomeSignal1ActivityOptions) WithActivityOptions 

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

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

func (*SomeSignal1ActivityOptions) WithHeartbeatTimeout added in v1.13.0 

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

WithHeartbeatTimeout sets the HeartbeatTimeout value

func (*SomeSignal1ActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeSignal1ActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeSignal1ActivityOptions) WithScheduleToStartTimeout added in v1.13.0 

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

WithScheduleToStartTimeout sets the ScheduleToStartTimeout value

func (*SomeSignal1ActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

func (*SomeSignal1ActivityOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeSignal1ActivityOptions) WithWaitForCancellation added in v1.13.0 

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

WithWaitForCancellation sets the WaitForCancellation value

type SomeSignal1Future 

type SomeSignal1Future struct {
	Future workflow.Future
}

SomeSignal1Future describes a(n) mycompany.simple.Simple.SomeSignal1 activity execution

func SomeSignal1Async 

func SomeSignal1Async(ctx workflow.Context, options ...*SomeSignal1ActivityOptions) *SomeSignal1Future

SomeSignal1 is a signal.

func SomeSignal1LocalAsync 

func SomeSignal1LocalAsync(ctx workflow.Context, options ...*SomeSignal1LocalActivityOptions) *SomeSignal1Future

SomeSignal1 is a signal.

func (*SomeSignal1Future) Get 

func (f *SomeSignal1Future) Get(ctx workflow.Context) error

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

func (*SomeSignal1Future) Select 

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

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

type SomeSignal1LocalActivityOptions 

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

SomeSignal1LocalActivityOptions provides configuration for a(n) mycompany.simple.Simple.SomeSignal1 activity

func NewSomeSignal1LocalActivityOptions 

func NewSomeSignal1LocalActivityOptions() *SomeSignal1LocalActivityOptions

NewSomeSignal1LocalActivityOptions initializes a new SomeSignal1LocalActivityOptions value

func (*SomeSignal1LocalActivityOptions) Build added in v1.13.0 

func (o *SomeSignal1LocalActivityOptions) 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 (*SomeSignal1LocalActivityOptions) Local 

func (o *SomeSignal1LocalActivityOptions) Local(fn func(context.Context) error) *SomeSignal1LocalActivityOptions

Local specifies a custom mycompany.simple.Simple.SomeSignal1 implementation

func (*SomeSignal1LocalActivityOptions) WithLocalActivityOptions 

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

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

func (*SomeSignal1LocalActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeSignal1LocalActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeSignal1LocalActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

type SomeSignal1Signal 

type SomeSignal1Signal struct {
	Channel workflow.ReceiveChannel
}

SomeSignal1Signal describes a(n) mycompany.simple.Simple.SomeSignal1 signal

func NewSomeSignal1Signal 

func NewSomeSignal1Signal(ctx workflow.Context) *SomeSignal1Signal

NewSomeSignal1Signal initializes a new mycompany.simple.Simple.SomeSignal1 signal wrapper

func (*SomeSignal1Signal) Receive 

func (s *SomeSignal1Signal) Receive(ctx workflow.Context) bool

Receive blocks until a(n) mycompany.simple.Simple.SomeSignal1 signal is received

func (*SomeSignal1Signal) ReceiveAsync 

func (s *SomeSignal1Signal) ReceiveAsync() bool

ReceiveAsync checks for a mycompany.simple.Simple.SomeSignal1 signal without blocking

func (*SomeSignal1Signal) ReceiveWithTimeout 

func (s *SomeSignal1Signal) ReceiveWithTimeout(ctx workflow.Context, timeout time.Duration) (ok bool, more bool)

ReceiveWithTimeout blocks until a(n) mycompany.simple.Simple.SomeSignal1 signal is received or timeout expires. Returns more value of false when Channel is closed. Returns ok value of false when no value was found in the channel for the duration of timeout or the ctx was canceled.

func (*SomeSignal1Signal) Select 

func (s *SomeSignal1Signal) Select(sel workflow.Selector, fn func()) workflow.Selector

Select checks for a(n) mycompany.simple.Simple.SomeSignal1 signal without blocking

type SomeSignal2ActivityOptions 

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

SomeSignal2ActivityOptions provides configuration for a(n) mycompany.simple.Simple.SomeSignal2 activity

func NewSomeSignal2ActivityOptions 

func NewSomeSignal2ActivityOptions() *SomeSignal2ActivityOptions

NewSomeSignal2ActivityOptions initializes a new SomeSignal2ActivityOptions value

func (*SomeSignal2ActivityOptions) Build added in v1.13.0 

func (o *SomeSignal2ActivityOptions) 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 (*SomeSignal2ActivityOptions) WithActivityOptions 

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

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

func (*SomeSignal2ActivityOptions) WithHeartbeatTimeout added in v1.13.0 

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

WithHeartbeatTimeout sets the HeartbeatTimeout value

func (*SomeSignal2ActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeSignal2ActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeSignal2ActivityOptions) WithScheduleToStartTimeout added in v1.13.0 

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

WithScheduleToStartTimeout sets the ScheduleToStartTimeout value

func (*SomeSignal2ActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

func (*SomeSignal2ActivityOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeSignal2ActivityOptions) WithWaitForCancellation added in v1.13.0 

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

WithWaitForCancellation sets the WaitForCancellation value

type SomeSignal2Future 

type SomeSignal2Future struct {
	Future workflow.Future
}

SomeSignal2Future describes a(n) mycompany.simple.Simple.SomeSignal2 activity execution

func SomeSignal2Async 

func SomeSignal2Async(ctx workflow.Context, req *SomeSignal2Request, options ...*SomeSignal2ActivityOptions) *SomeSignal2Future

SomeSignal2 is a signal.

func SomeSignal2LocalAsync 

func SomeSignal2LocalAsync(ctx workflow.Context, req *SomeSignal2Request, options ...*SomeSignal2LocalActivityOptions) *SomeSignal2Future

SomeSignal2 is a signal.

func (*SomeSignal2Future) Get 

func (f *SomeSignal2Future) Get(ctx workflow.Context) error

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

func (*SomeSignal2Future) Select 

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

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

type SomeSignal2LocalActivityOptions 

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

SomeSignal2LocalActivityOptions provides configuration for a(n) mycompany.simple.Simple.SomeSignal2 activity

func NewSomeSignal2LocalActivityOptions 

func NewSomeSignal2LocalActivityOptions() *SomeSignal2LocalActivityOptions

NewSomeSignal2LocalActivityOptions initializes a new SomeSignal2LocalActivityOptions value

func (*SomeSignal2LocalActivityOptions) Build added in v1.13.0 

func (o *SomeSignal2LocalActivityOptions) 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 (*SomeSignal2LocalActivityOptions) Local 

func (o *SomeSignal2LocalActivityOptions) Local(fn func(context.Context, *SomeSignal2Request) error) *SomeSignal2LocalActivityOptions

Local specifies a custom mycompany.simple.Simple.SomeSignal2 implementation

func (*SomeSignal2LocalActivityOptions) WithLocalActivityOptions 

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

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

func (*SomeSignal2LocalActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeSignal2LocalActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeSignal2LocalActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

type SomeSignal2Request 

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

func UnmarshalCliFlagsToSomeSignal2Request 

func UnmarshalCliFlagsToSomeSignal2Request(cmd *v2.Context) (*SomeSignal2Request, error)

UnmarshalCliFlagsToSomeSignal2Request unmarshals a SomeSignal2Request from command line flags

func (*SomeSignal2Request) Descriptor deprecated 

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

Deprecated: Use SomeSignal2Request.ProtoReflect.Descriptor instead.

func (*SomeSignal2Request) GetRequestVal 

func (x *SomeSignal2Request) GetRequestVal() string

func (*SomeSignal2Request) ProtoMessage 

func (*SomeSignal2Request) ProtoMessage()

func (*SomeSignal2Request) ProtoReflect 

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

func (*SomeSignal2Request) Reset 

func (x *SomeSignal2Request) Reset()

func (*SomeSignal2Request) String 

func (x *SomeSignal2Request) String() string

type SomeSignal2Signal 

type SomeSignal2Signal struct {
	Channel workflow.ReceiveChannel
}

SomeSignal2Signal describes a(n) mycompany.simple.Simple.SomeSignal2 signal

func NewSomeSignal2Signal 

func NewSomeSignal2Signal(ctx workflow.Context) *SomeSignal2Signal

NewSomeSignal2Signal initializes a new mycompany.simple.Simple.SomeSignal2 signal wrapper

func (*SomeSignal2Signal) Receive 

func (s *SomeSignal2Signal) Receive(ctx workflow.Context) (*SomeSignal2Request, bool)

Receive blocks until a(n) mycompany.simple.Simple.SomeSignal2 signal is received

func (*SomeSignal2Signal) ReceiveAsync 

func (s *SomeSignal2Signal) ReceiveAsync() *SomeSignal2Request

ReceiveAsync checks for a mycompany.simple.Simple.SomeSignal2 signal without blocking

func (*SomeSignal2Signal) ReceiveWithTimeout 

func (s *SomeSignal2Signal) ReceiveWithTimeout(ctx workflow.Context, timeout time.Duration) (resp *SomeSignal2Request, ok bool, more bool)

ReceiveWithTimeout blocks until a(n) mycompany.simple.Simple.SomeSignal2 signal is received or timeout expires. Returns more value of false when Channel is closed. Returns ok value of false when no value was found in the channel for the duration of timeout or the ctx was canceled. resp will be nil if ok is false.

func (*SomeSignal2Signal) Select 

func (s *SomeSignal2Signal) Select(sel workflow.Selector, fn func(*SomeSignal2Request)) workflow.Selector

Select checks for a(n) mycompany.simple.Simple.SomeSignal2 signal without blocking

type SomeSignal3ActivityOptions 

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

SomeSignal3ActivityOptions provides configuration for a(n) mycompany.simple.Simple.SomeSignal3 activity

func NewSomeSignal3ActivityOptions 

func NewSomeSignal3ActivityOptions() *SomeSignal3ActivityOptions

NewSomeSignal3ActivityOptions initializes a new SomeSignal3ActivityOptions value

func (*SomeSignal3ActivityOptions) Build added in v1.13.0 

func (o *SomeSignal3ActivityOptions) 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 (*SomeSignal3ActivityOptions) WithActivityOptions 

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

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

func (*SomeSignal3ActivityOptions) WithHeartbeatTimeout added in v1.13.0 

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

WithHeartbeatTimeout sets the HeartbeatTimeout value

func (*SomeSignal3ActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeSignal3ActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeSignal3ActivityOptions) WithScheduleToStartTimeout added in v1.13.0 

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

WithScheduleToStartTimeout sets the ScheduleToStartTimeout value

func (*SomeSignal3ActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

func (*SomeSignal3ActivityOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeSignal3ActivityOptions) WithWaitForCancellation added in v1.13.0 

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

WithWaitForCancellation sets the WaitForCancellation value

type SomeSignal3Future 

type SomeSignal3Future struct {
	Future workflow.Future
}

SomeSignal3Future describes a(n) mycompany.simple.Simple.SomeSignal3 activity execution

func SomeSignal3Async 

func SomeSignal3Async(ctx workflow.Context, req *SomeSignal3Request, options ...*SomeSignal3ActivityOptions) *SomeSignal3Future

SomeSignal3 is a signal.

func SomeSignal3LocalAsync 

func SomeSignal3LocalAsync(ctx workflow.Context, req *SomeSignal3Request, options ...*SomeSignal3LocalActivityOptions) *SomeSignal3Future

SomeSignal3 is a signal.

func (*SomeSignal3Future) Get 

func (f *SomeSignal3Future) Get(ctx workflow.Context) (*SomeSignal3Response, error)

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

func (*SomeSignal3Future) Select 

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

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

type SomeSignal3LocalActivityOptions 

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

SomeSignal3LocalActivityOptions provides configuration for a(n) mycompany.simple.Simple.SomeSignal3 activity

func NewSomeSignal3LocalActivityOptions 

func NewSomeSignal3LocalActivityOptions() *SomeSignal3LocalActivityOptions

NewSomeSignal3LocalActivityOptions initializes a new SomeSignal3LocalActivityOptions value

func (*SomeSignal3LocalActivityOptions) Build added in v1.13.0 

func (o *SomeSignal3LocalActivityOptions) 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 (*SomeSignal3LocalActivityOptions) Local 

func (o *SomeSignal3LocalActivityOptions) Local(fn func(context.Context, *SomeSignal3Request) (*SomeSignal3Response, error)) *SomeSignal3LocalActivityOptions

Local specifies a custom mycompany.simple.Simple.SomeSignal3 implementation

func (*SomeSignal3LocalActivityOptions) WithLocalActivityOptions 

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

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

func (*SomeSignal3LocalActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeSignal3LocalActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeSignal3LocalActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

type SomeSignal3Request 

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

func UnmarshalCliFlagsToSomeSignal3Request 

func UnmarshalCliFlagsToSomeSignal3Request(cmd *v2.Context) (*SomeSignal3Request, error)

UnmarshalCliFlagsToSomeSignal3Request unmarshals a SomeSignal3Request from command line flags

func (*SomeSignal3Request) Descriptor deprecated 

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

Deprecated: Use SomeSignal3Request.ProtoReflect.Descriptor instead.

func (*SomeSignal3Request) GetRequestVal 

func (x *SomeSignal3Request) GetRequestVal() string

func (*SomeSignal3Request) ProtoMessage 

func (*SomeSignal3Request) ProtoMessage()

func (*SomeSignal3Request) ProtoReflect 

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

func (*SomeSignal3Request) Reset 

func (x *SomeSignal3Request) Reset()

func (*SomeSignal3Request) String 

func (x *SomeSignal3Request) String() string

type SomeSignal3Response 

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

func SomeSignal3 

func SomeSignal3(ctx workflow.Context, req *SomeSignal3Request, options ...*SomeSignal3ActivityOptions) (*SomeSignal3Response, error)

SomeSignal3 is a signal.

func SomeSignal3Local 

func SomeSignal3Local(ctx workflow.Context, req *SomeSignal3Request, options ...*SomeSignal3LocalActivityOptions) (*SomeSignal3Response, error)

SomeSignal3 is a signal.

func (*SomeSignal3Response) Descriptor deprecated 

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

Deprecated: Use SomeSignal3Response.ProtoReflect.Descriptor instead.

func (*SomeSignal3Response) GetResponseVal 

func (x *SomeSignal3Response) GetResponseVal() string

func (*SomeSignal3Response) ProtoMessage 

func (*SomeSignal3Response) ProtoMessage()

func (*SomeSignal3Response) ProtoReflect 

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

func (*SomeSignal3Response) Reset 

func (x *SomeSignal3Response) Reset()

func (*SomeSignal3Response) String 

func (x *SomeSignal3Response) String() string

type SomeSignal3Signal 

type SomeSignal3Signal struct {
	Channel workflow.ReceiveChannel
}

SomeSignal3Signal describes a(n) mycompany.simple.Simple.SomeSignal3 signal

func NewSomeSignal3Signal 

func NewSomeSignal3Signal(ctx workflow.Context) *SomeSignal3Signal

NewSomeSignal3Signal initializes a new mycompany.simple.Simple.SomeSignal3 signal wrapper

func (*SomeSignal3Signal) Receive 

func (s *SomeSignal3Signal) Receive(ctx workflow.Context) (*SomeSignal3Request, bool)

Receive blocks until a(n) mycompany.simple.Simple.SomeSignal3 signal is received

func (*SomeSignal3Signal) ReceiveAsync 

func (s *SomeSignal3Signal) ReceiveAsync() *SomeSignal3Request

ReceiveAsync checks for a mycompany.simple.Simple.SomeSignal3 signal without blocking

func (*SomeSignal3Signal) ReceiveWithTimeout 

func (s *SomeSignal3Signal) ReceiveWithTimeout(ctx workflow.Context, timeout time.Duration) (resp *SomeSignal3Request, ok bool, more bool)

ReceiveWithTimeout blocks until a(n) mycompany.simple.Simple.SomeSignal3 signal is received or timeout expires. Returns more value of false when Channel is closed. Returns ok value of false when no value was found in the channel for the duration of timeout or the ctx was canceled. resp will be nil if ok is false.

func (*SomeSignal3Signal) Select 

func (s *SomeSignal3Signal) Select(sel workflow.Selector, fn func(*SomeSignal3Request)) workflow.Selector

Select checks for a(n) mycompany.simple.Simple.SomeSignal3 signal without blocking

type SomeUpdate1ActivityOptions 

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

SomeUpdate1ActivityOptions provides configuration for a(n) mycompany.simple.Simple.SomeUpdate1 activity

func NewSomeUpdate1ActivityOptions 

func NewSomeUpdate1ActivityOptions() *SomeUpdate1ActivityOptions

NewSomeUpdate1ActivityOptions initializes a new SomeUpdate1ActivityOptions value

func (*SomeUpdate1ActivityOptions) Build added in v1.13.0 

func (o *SomeUpdate1ActivityOptions) 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 (*SomeUpdate1ActivityOptions) WithActivityOptions 

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

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

func (*SomeUpdate1ActivityOptions) WithHeartbeatTimeout added in v1.13.0 

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

WithHeartbeatTimeout sets the HeartbeatTimeout value

func (*SomeUpdate1ActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeUpdate1ActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeUpdate1ActivityOptions) WithScheduleToStartTimeout added in v1.13.0 

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

WithScheduleToStartTimeout sets the ScheduleToStartTimeout value

func (*SomeUpdate1ActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

func (*SomeUpdate1ActivityOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeUpdate1ActivityOptions) WithWaitForCancellation added in v1.13.0 

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

WithWaitForCancellation sets the WaitForCancellation value

type SomeUpdate1Future 

type SomeUpdate1Future struct {
	Future workflow.Future
}

SomeUpdate1Future describes a(n) mycompany.simple.Simple.SomeUpdate1 activity execution

func SomeUpdate1Async 

func SomeUpdate1Async(ctx workflow.Context, req *SomeUpdate1Request, options ...*SomeUpdate1ActivityOptions) *SomeUpdate1Future

SomeUpdate1 updates a SomeWorkflow2

func SomeUpdate1LocalAsync 

func SomeUpdate1LocalAsync(ctx workflow.Context, req *SomeUpdate1Request, options ...*SomeUpdate1LocalActivityOptions) *SomeUpdate1Future

SomeUpdate1 updates a SomeWorkflow2

func (*SomeUpdate1Future) Get 

func (f *SomeUpdate1Future) Get(ctx workflow.Context) (*SomeUpdate1Response, error)

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

func (*SomeUpdate1Future) Select 

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

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

type SomeUpdate1Handle 

type SomeUpdate1Handle 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) (*SomeUpdate1Response, error)
}

SomeUpdate1Handle describes a(n) mycompany.simple.Simple.SomeUpdate1 update handle

type SomeUpdate1LocalActivityOptions 

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

SomeUpdate1LocalActivityOptions provides configuration for a(n) mycompany.simple.Simple.SomeUpdate1 activity

func NewSomeUpdate1LocalActivityOptions 

func NewSomeUpdate1LocalActivityOptions() *SomeUpdate1LocalActivityOptions

NewSomeUpdate1LocalActivityOptions initializes a new SomeUpdate1LocalActivityOptions value

func (*SomeUpdate1LocalActivityOptions) Build added in v1.13.0 

func (o *SomeUpdate1LocalActivityOptions) 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 (*SomeUpdate1LocalActivityOptions) Local 

func (o *SomeUpdate1LocalActivityOptions) Local(fn func(context.Context, *SomeUpdate1Request) (*SomeUpdate1Response, error)) *SomeUpdate1LocalActivityOptions

Local specifies a custom mycompany.simple.Simple.SomeUpdate1 implementation

func (*SomeUpdate1LocalActivityOptions) WithLocalActivityOptions 

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

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

func (*SomeUpdate1LocalActivityOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeUpdate1LocalActivityOptions) WithScheduleToCloseTimeout added in v1.13.0 

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

WithScheduleToCloseTimeout sets the ScheduleToCloseTimeout value

func (*SomeUpdate1LocalActivityOptions) WithStartToCloseTimeout added in v1.13.0 

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

WithStartToCloseTimeout sets the StartToCloseTimeout value

type SomeUpdate1Options 

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

SomeUpdate1Options provides configuration for a mycompany.simple.Simple.SomeUpdate1 update operation

func NewSomeUpdate1Options 

func NewSomeUpdate1Options() *SomeUpdate1Options

NewSomeUpdate1Options initializes a new SomeUpdate1Options value

func (*SomeUpdate1Options) Build added in v1.13.0 

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

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

func (*SomeUpdate1Options) WithUpdateID added in v1.13.0 

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

WithUpdateID sets the UpdateID

func (*SomeUpdate1Options) WithUpdateWorkflowOptions 

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

WithUpdateWorkflowOptions sets the initial client.UpdateWorkflowOptions

func (*SomeUpdate1Options) WithWaitPolicy added in v1.13.0 

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

WithWaitPolicy sets the WaitPolicy

type SomeUpdate1Request 

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

func UnmarshalCliFlagsToSomeUpdate1Request 

func UnmarshalCliFlagsToSomeUpdate1Request(cmd *v2.Context) (*SomeUpdate1Request, error)

UnmarshalCliFlagsToSomeUpdate1Request unmarshals a SomeUpdate1Request from command line flags

func (*SomeUpdate1Request) Descriptor deprecated 

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

Deprecated: Use SomeUpdate1Request.ProtoReflect.Descriptor instead.

func (*SomeUpdate1Request) GetRequestVal 

func (x *SomeUpdate1Request) GetRequestVal() string

func (*SomeUpdate1Request) ProtoMessage 

func (*SomeUpdate1Request) ProtoMessage()

func (*SomeUpdate1Request) ProtoReflect 

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

func (*SomeUpdate1Request) Reset 

func (x *SomeUpdate1Request) Reset()

func (*SomeUpdate1Request) String 

func (x *SomeUpdate1Request) String() string

type SomeUpdate1Response 

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

func SomeUpdate1 

func SomeUpdate1(ctx workflow.Context, req *SomeUpdate1Request, options ...*SomeUpdate1ActivityOptions) (*SomeUpdate1Response, error)

SomeUpdate1 updates a SomeWorkflow2

func SomeUpdate1Local 

func SomeUpdate1Local(ctx workflow.Context, req *SomeUpdate1Request, options ...*SomeUpdate1LocalActivityOptions) (*SomeUpdate1Response, error)

SomeUpdate1 updates a SomeWorkflow2

func (*SomeUpdate1Response) Descriptor deprecated 

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

Deprecated: Use SomeUpdate1Response.ProtoReflect.Descriptor instead.

func (*SomeUpdate1Response) GetResponseVal 

func (x *SomeUpdate1Response) GetResponseVal() string

func (*SomeUpdate1Response) ProtoMessage 

func (*SomeUpdate1Response) ProtoMessage()

func (*SomeUpdate1Response) ProtoReflect 

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

func (*SomeUpdate1Response) Reset 

func (x *SomeUpdate1Response) Reset()

func (*SomeUpdate1Response) String 

func (x *SomeUpdate1Response) String() string

type SomeWorkflow1ChildOptions 

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

SomeWorkflow1ChildOptions provides configuration for a child mycompany.simple.SomeWorkflow1 workflow operation

func NewSomeWorkflow1ChildOptions 

func NewSomeWorkflow1ChildOptions() *SomeWorkflow1ChildOptions

NewSomeWorkflow1ChildOptions initializes a new SomeWorkflow1ChildOptions value

func (*SomeWorkflow1ChildOptions) Build added in v1.13.0 

func (o *SomeWorkflow1ChildOptions) 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 (*SomeWorkflow1ChildOptions) WithChildWorkflowOptions 

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

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

func (*SomeWorkflow1ChildOptions) WithExecutionTimeout added in v1.13.0 

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

WithExecutionTimeout sets the WorkflowExecutionTimeout value

func (*SomeWorkflow1ChildOptions) WithID added in v1.13.0 

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

WithID sets the WorkflowID value

func (*SomeWorkflow1ChildOptions) WithIDReusePolicy added in v1.13.0 

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

WithIDReusePolicy sets the WorkflowIDReusePolicy value

func (*SomeWorkflow1ChildOptions) WithParentClosePolicy added in v1.13.0 

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

WithParentClosePolicy sets the WorkflowIDReusePolicy value

func (*SomeWorkflow1ChildOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeWorkflow1ChildOptions) WithRunTimeout added in v1.13.0 

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

WithRunTimeout sets the WorkflowRunTimeout value

func (*SomeWorkflow1ChildOptions) WithSearchAttributes added in v1.13.0 

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

WithSearchAttributes sets the SearchAttributes value

func (*SomeWorkflow1ChildOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeWorkflow1ChildOptions) WithTaskTimeout added in v1.13.0 

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

WithTaskTimeout sets the WorkflowTaskTimeout value

func (*SomeWorkflow1ChildOptions) WithWaitForCancellation added in v1.13.0 

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

WithWaitForCancellation sets the WaitForCancellation value

type SomeWorkflow1ChildRun 

type SomeWorkflow1ChildRun struct {
	Future workflow.ChildWorkflowFuture
}

SomeWorkflow1ChildRun describes a child SomeWorkflow1 workflow run

func SomeWorkflow1ChildAsync 

func SomeWorkflow1ChildAsync(ctx workflow.Context, req *SomeWorkflow1Request, options ...*SomeWorkflow1ChildOptions) (*SomeWorkflow1ChildRun, error)

SomeWorkflow1 does some workflow thing.

func (*SomeWorkflow1ChildRun) Get 

func (r *SomeWorkflow1ChildRun) Get(ctx workflow.Context) (*SomeWorkflow1Response, error)

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

func (*SomeWorkflow1ChildRun) Select 

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

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

func (*SomeWorkflow1ChildRun) SelectStart 

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

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

func (*SomeWorkflow1ChildRun) SomeSignal1 

func (r *SomeWorkflow1ChildRun) SomeSignal1(ctx workflow.Context) error

SomeSignal1 sends a(n) "mycompany.simple.Simple.SomeSignal1" signal request to the child workflow

func (*SomeWorkflow1ChildRun) SomeSignal1Async 

func (r *SomeWorkflow1ChildRun) SomeSignal1Async(ctx workflow.Context) workflow.Future

SomeSignal1Async sends a(n) "mycompany.simple.Simple.SomeSignal1" signal request to the child workflow

func (*SomeWorkflow1ChildRun) SomeSignal2 

func (r *SomeWorkflow1ChildRun) SomeSignal2(ctx workflow.Context, input *SomeSignal2Request) error

SomeSignal2 sends a(n) "mycompany.simple.Simple.SomeSignal2" signal request to the child workflow

func (*SomeWorkflow1ChildRun) SomeSignal2Async 

func (r *SomeWorkflow1ChildRun) SomeSignal2Async(ctx workflow.Context, input *SomeSignal2Request) workflow.Future

SomeSignal2Async sends a(n) "mycompany.simple.Simple.SomeSignal2" signal request to the child workflow

func (*SomeWorkflow1ChildRun) WaitStart 

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

WaitStart waits for the child workflow to start

type SomeWorkflow1Options 

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

SomeWorkflow1Options provides configuration for a mycompany.simple.SomeWorkflow1 workflow operation

func NewSomeWorkflow1Options 

func NewSomeWorkflow1Options() *SomeWorkflow1Options

NewSomeWorkflow1Options initializes a new SomeWorkflow1Options value

func (*SomeWorkflow1Options) Build added in v1.13.0 

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

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

func (*SomeWorkflow1Options) WithExecutionTimeout added in v1.13.0 

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

WithExecutionTimeout sets the WorkflowExecutionTimeout value

func (*SomeWorkflow1Options) WithID added in v1.13.0 

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

WithID sets the ID value

func (*SomeWorkflow1Options) WithIDReusePolicy added in v1.13.0 

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

WithIDReusePolicy sets the WorkflowIDReusePolicy value

func (*SomeWorkflow1Options) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeWorkflow1Options) WithRunTimeout added in v1.13.0 

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

WithRunTimeout sets the WorkflowRunTimeout value

func (*SomeWorkflow1Options) WithSearchAttributes added in v1.13.0 

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

WithSearchAttributes sets the SearchAttributes value

func (*SomeWorkflow1Options) WithStartWorkflowOptions 

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

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

func (*SomeWorkflow1Options) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeWorkflow1Options) WithTaskTimeout added in v1.13.0 

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

WithTaskTimeout sets the WorkflowTaskTimeout value

type SomeWorkflow1Request 

type SomeWorkflow1Request struct {
	RequestVal string `protobuf:"bytes,1,opt,name=request_val,json=requestVal,proto3" json:"request_val,omitempty"`
	Id         string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func UnmarshalCliFlagsToSomeWorkflow1Request 

func UnmarshalCliFlagsToSomeWorkflow1Request(cmd *v2.Context) (*SomeWorkflow1Request, error)

UnmarshalCliFlagsToSomeWorkflow1Request unmarshals a SomeWorkflow1Request from command line flags

func (*SomeWorkflow1Request) Descriptor deprecated 

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

Deprecated: Use SomeWorkflow1Request.ProtoReflect.Descriptor instead.

func (*SomeWorkflow1Request) GetId 

func (x *SomeWorkflow1Request) GetId() string

func (*SomeWorkflow1Request) GetRequestVal 

func (x *SomeWorkflow1Request) GetRequestVal() string

func (*SomeWorkflow1Request) ProtoMessage 

func (*SomeWorkflow1Request) ProtoMessage()

func (*SomeWorkflow1Request) ProtoReflect 

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

func (*SomeWorkflow1Request) Reset 

func (x *SomeWorkflow1Request) Reset()

func (*SomeWorkflow1Request) String 

func (x *SomeWorkflow1Request) String() string

type SomeWorkflow1Response 

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

func SomeWorkflow1Child 

func SomeWorkflow1Child(ctx workflow.Context, req *SomeWorkflow1Request, options ...*SomeWorkflow1ChildOptions) (*SomeWorkflow1Response, error)

SomeWorkflow1 does some workflow thing.

func (*SomeWorkflow1Response) Descriptor deprecated 

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

Deprecated: Use SomeWorkflow1Response.ProtoReflect.Descriptor instead.

func (*SomeWorkflow1Response) GetResponseVal 

func (x *SomeWorkflow1Response) GetResponseVal() string

func (*SomeWorkflow1Response) ProtoMessage 

func (*SomeWorkflow1Response) ProtoMessage()

func (*SomeWorkflow1Response) ProtoReflect 

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

func (*SomeWorkflow1Response) Reset 

func (x *SomeWorkflow1Response) Reset()

func (*SomeWorkflow1Response) String 

func (x *SomeWorkflow1Response) String() string

type SomeWorkflow1Run 

type SomeWorkflow1Run 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) (*SomeWorkflow1Response, 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

	// SomeQuery1 queries some thing.
	SomeQuery1(ctx context.Context) (*SomeQuery1Response, error)

	// SomeQuery2 queries some thing.
	SomeQuery2(ctx context.Context, req *SomeQuery2Request) (*SomeQuery2Response, error)

	// SomeSignal1 is a signal.
	SomeSignal1(ctx context.Context) error

	// SomeSignal2 is a signal.
	SomeSignal2(ctx context.Context, req *SomeSignal2Request) error
}

SomeWorkflow1Run describes a(n) mycompany.simple.SomeWorkflow1 workflow run

type SomeWorkflow1Workflow 

type SomeWorkflow1Workflow interface {
	// Execute defines the entrypoint to a(n) mycompany.simple.SomeWorkflow1 workflow
	Execute(ctx workflow.Context) (*SomeWorkflow1Response, error)

	// SomeQuery1 queries some thing.
	SomeQuery1() (*SomeQuery1Response, error)

	// SomeQuery2 queries some thing.
	SomeQuery2(*SomeQuery2Request) (*SomeQuery2Response, error)
}

SomeWorkflow1 does some workflow thing.

workflow details: (name: "mycompany.simple.SomeWorkflow1", id: "some-workflow-1/${! id }/${! uuid_v4() }")

type SomeWorkflow1WorkflowInput 

type SomeWorkflow1WorkflowInput struct {
	Req         *SomeWorkflow1Request
	SomeSignal1 *SomeSignal1Signal
	SomeSignal2 *SomeSignal2Signal
}

SomeWorkflow1WorkflowInput describes the input to a(n) mycompany.simple.SomeWorkflow1 workflow constructor

type SomeWorkflow2ChildOptions 

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

SomeWorkflow2ChildOptions provides configuration for a child mycompany.simple.SomeWorkflow2 workflow operation

func NewSomeWorkflow2ChildOptions 

func NewSomeWorkflow2ChildOptions() *SomeWorkflow2ChildOptions

NewSomeWorkflow2ChildOptions initializes a new SomeWorkflow2ChildOptions value

func (*SomeWorkflow2ChildOptions) Build added in v1.13.0 

func (o *SomeWorkflow2ChildOptions) 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 (*SomeWorkflow2ChildOptions) WithChildWorkflowOptions 

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

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

func (*SomeWorkflow2ChildOptions) WithExecutionTimeout added in v1.13.0 

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

WithExecutionTimeout sets the WorkflowExecutionTimeout value

func (*SomeWorkflow2ChildOptions) WithID added in v1.13.0 

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

WithID sets the WorkflowID value

func (*SomeWorkflow2ChildOptions) WithIDReusePolicy added in v1.13.0 

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

WithIDReusePolicy sets the WorkflowIDReusePolicy value

func (*SomeWorkflow2ChildOptions) WithParentClosePolicy added in v1.13.0 

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

WithParentClosePolicy sets the WorkflowIDReusePolicy value

func (*SomeWorkflow2ChildOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeWorkflow2ChildOptions) WithRunTimeout added in v1.13.0 

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

WithRunTimeout sets the WorkflowRunTimeout value

func (*SomeWorkflow2ChildOptions) WithSearchAttributes added in v1.13.0 

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

WithSearchAttributes sets the SearchAttributes value

func (*SomeWorkflow2ChildOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeWorkflow2ChildOptions) WithTaskTimeout added in v1.13.0 

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

WithTaskTimeout sets the WorkflowTaskTimeout value

func (*SomeWorkflow2ChildOptions) WithWaitForCancellation added in v1.13.0 

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

WithWaitForCancellation sets the WaitForCancellation value

type SomeWorkflow2ChildRun 

type SomeWorkflow2ChildRun struct {
	Future workflow.ChildWorkflowFuture
}

SomeWorkflow2ChildRun describes a child SomeWorkflow2 workflow run

func SomeWorkflow2ChildAsync 

func SomeWorkflow2ChildAsync(ctx workflow.Context, options ...*SomeWorkflow2ChildOptions) (*SomeWorkflow2ChildRun, error)

SomeWorkflow2 does some workflow thing.

func (*SomeWorkflow2ChildRun) Get 

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

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

func (*SomeWorkflow2ChildRun) Select 

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

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

func (*SomeWorkflow2ChildRun) SelectStart 

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

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

func (*SomeWorkflow2ChildRun) SomeSignal1 

func (r *SomeWorkflow2ChildRun) SomeSignal1(ctx workflow.Context) error

SomeSignal1 sends a(n) "mycompany.simple.Simple.SomeSignal1" signal request to the child workflow

func (*SomeWorkflow2ChildRun) SomeSignal1Async 

func (r *SomeWorkflow2ChildRun) SomeSignal1Async(ctx workflow.Context) workflow.Future

SomeSignal1Async sends a(n) "mycompany.simple.Simple.SomeSignal1" signal request to the child workflow

func (*SomeWorkflow2ChildRun) WaitStart 

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

WaitStart waits for the child workflow to start

type SomeWorkflow2Options 

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

SomeWorkflow2Options provides configuration for a mycompany.simple.SomeWorkflow2 workflow operation

func NewSomeWorkflow2Options 

func NewSomeWorkflow2Options() *SomeWorkflow2Options

NewSomeWorkflow2Options initializes a new SomeWorkflow2Options value

func (*SomeWorkflow2Options) Build added in v1.13.0 

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

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

func (*SomeWorkflow2Options) WithExecutionTimeout added in v1.13.0 

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

WithExecutionTimeout sets the WorkflowExecutionTimeout value

func (*SomeWorkflow2Options) WithID added in v1.13.0 

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

WithID sets the ID value

func (*SomeWorkflow2Options) WithIDReusePolicy added in v1.13.0 

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

WithIDReusePolicy sets the WorkflowIDReusePolicy value

func (*SomeWorkflow2Options) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeWorkflow2Options) WithRunTimeout added in v1.13.0 

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

WithRunTimeout sets the WorkflowRunTimeout value

func (*SomeWorkflow2Options) WithSearchAttributes added in v1.13.0 

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

WithSearchAttributes sets the SearchAttributes value

func (*SomeWorkflow2Options) WithStartWorkflowOptions 

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

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

func (*SomeWorkflow2Options) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeWorkflow2Options) WithTaskTimeout added in v1.13.0 

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

WithTaskTimeout sets the WorkflowTaskTimeout value

type SomeWorkflow2Run 

type SomeWorkflow2Run 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

	// SomeSignal1 is a signal.
	SomeSignal1(ctx context.Context) error

	// SomeUpdate1 updates a SomeWorkflow2
	SomeUpdate1(ctx context.Context, req *SomeUpdate1Request, opts ...*SomeUpdate1Options) (*SomeUpdate1Response, error)

	// SomeUpdate1 updates a SomeWorkflow2
	SomeUpdate1Async(ctx context.Context, req *SomeUpdate1Request, opts ...*SomeUpdate1Options) (SomeUpdate1Handle, error)
}

SomeWorkflow2Run describes a(n) mycompany.simple.SomeWorkflow2 workflow run

type SomeWorkflow2Workflow 

type SomeWorkflow2Workflow interface {
	// Execute defines the entrypoint to a(n) mycompany.simple.SomeWorkflow2 workflow
	Execute(ctx workflow.Context) error

	// ValidateSomeUpdate1 validates a(n) mycompany.simple.Simple.SomeUpdate1 update
	ValidateSomeUpdate1(workflow.Context, *SomeUpdate1Request) error

	// SomeUpdate1 updates a SomeWorkflow2
	SomeUpdate1(workflow.Context, *SomeUpdate1Request) (*SomeUpdate1Response, error)
}

SomeWorkflow2 does some workflow thing.

workflow details: (name: "mycompany.simple.SomeWorkflow2", id: "some-workflow-2/${! uuid_v4() }")

type SomeWorkflow2WorkflowInput 

type SomeWorkflow2WorkflowInput struct {
	SomeSignal1 *SomeSignal1Signal
}

SomeWorkflow2WorkflowInput describes the input to a(n) mycompany.simple.SomeWorkflow2 workflow constructor

type SomeWorkflow3ChildOptions 

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

SomeWorkflow3ChildOptions provides configuration for a child mycompany.simple.Simple.SomeWorkflow3 workflow operation

func NewSomeWorkflow3ChildOptions 

func NewSomeWorkflow3ChildOptions() *SomeWorkflow3ChildOptions

NewSomeWorkflow3ChildOptions initializes a new SomeWorkflow3ChildOptions value

func (*SomeWorkflow3ChildOptions) Build added in v1.13.0 

func (o *SomeWorkflow3ChildOptions) 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 (*SomeWorkflow3ChildOptions) WithChildWorkflowOptions 

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

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

func (*SomeWorkflow3ChildOptions) WithExecutionTimeout added in v1.13.0 

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

WithExecutionTimeout sets the WorkflowExecutionTimeout value

func (*SomeWorkflow3ChildOptions) WithID added in v1.13.0 

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

WithID sets the WorkflowID value

func (*SomeWorkflow3ChildOptions) WithIDReusePolicy added in v1.13.0 

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

WithIDReusePolicy sets the WorkflowIDReusePolicy value

func (*SomeWorkflow3ChildOptions) WithParentClosePolicy added in v1.13.0 

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

WithParentClosePolicy sets the WorkflowIDReusePolicy value

func (*SomeWorkflow3ChildOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeWorkflow3ChildOptions) WithRunTimeout added in v1.13.0 

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

WithRunTimeout sets the WorkflowRunTimeout value

func (*SomeWorkflow3ChildOptions) WithSearchAttributes added in v1.13.0 

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

WithSearchAttributes sets the SearchAttributes value

func (*SomeWorkflow3ChildOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeWorkflow3ChildOptions) WithTaskTimeout added in v1.13.0 

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

WithTaskTimeout sets the WorkflowTaskTimeout value

func (*SomeWorkflow3ChildOptions) WithWaitForCancellation added in v1.13.0 

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

WithWaitForCancellation sets the WaitForCancellation value

type SomeWorkflow3ChildRun 

type SomeWorkflow3ChildRun struct {
	Future workflow.ChildWorkflowFuture
}

SomeWorkflow3ChildRun describes a child SomeWorkflow3 workflow run

func SomeWorkflow3ChildAsync 

func SomeWorkflow3ChildAsync(ctx workflow.Context, req *SomeWorkflow3Request, options ...*SomeWorkflow3ChildOptions) (*SomeWorkflow3ChildRun, error)

SomeWorkflow3 does some workflow thing. Deprecated: Use SomeWorkflow2 instead.

func (*SomeWorkflow3ChildRun) Get 

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

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

func (*SomeWorkflow3ChildRun) Select 

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

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

func (*SomeWorkflow3ChildRun) SelectStart 

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

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

func (*SomeWorkflow3ChildRun) SomeSignal2 

func (r *SomeWorkflow3ChildRun) SomeSignal2(ctx workflow.Context, input *SomeSignal2Request) error

SomeSignal2 sends a(n) "mycompany.simple.Simple.SomeSignal2" signal request to the child workflow

func (*SomeWorkflow3ChildRun) SomeSignal2Async 

func (r *SomeWorkflow3ChildRun) SomeSignal2Async(ctx workflow.Context, input *SomeSignal2Request) workflow.Future

SomeSignal2Async sends a(n) "mycompany.simple.Simple.SomeSignal2" signal request to the child workflow

func (*SomeWorkflow3ChildRun) WaitStart 

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

WaitStart waits for the child workflow to start

type SomeWorkflow3Options 

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

SomeWorkflow3Options provides configuration for a mycompany.simple.Simple.SomeWorkflow3 workflow operation

func NewSomeWorkflow3Options 

func NewSomeWorkflow3Options() *SomeWorkflow3Options

NewSomeWorkflow3Options initializes a new SomeWorkflow3Options value

func (*SomeWorkflow3Options) Build added in v1.13.0 

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

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

func (*SomeWorkflow3Options) WithExecutionTimeout added in v1.13.0 

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

WithExecutionTimeout sets the WorkflowExecutionTimeout value

func (*SomeWorkflow3Options) WithID added in v1.13.0 

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

WithID sets the ID value

func (*SomeWorkflow3Options) WithIDReusePolicy added in v1.13.0 

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

WithIDReusePolicy sets the WorkflowIDReusePolicy value

func (*SomeWorkflow3Options) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeWorkflow3Options) WithRunTimeout added in v1.13.0 

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

WithRunTimeout sets the WorkflowRunTimeout value

func (*SomeWorkflow3Options) WithSearchAttributes added in v1.13.0 

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

WithSearchAttributes sets the SearchAttributes value

func (*SomeWorkflow3Options) WithStartWorkflowOptions 

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

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

func (*SomeWorkflow3Options) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*SomeWorkflow3Options) WithTaskTimeout added in v1.13.0 

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

WithTaskTimeout sets the WorkflowTaskTimeout value

type SomeWorkflow3Request 

type SomeWorkflow3Request struct {
	Id         string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	RequestVal string `protobuf:"bytes,2,opt,name=request_val,json=requestVal,proto3" json:"request_val,omitempty"`
	// contains filtered or unexported fields
}

func UnmarshalCliFlagsToSomeWorkflow3Request 

func UnmarshalCliFlagsToSomeWorkflow3Request(cmd *v2.Context) (*SomeWorkflow3Request, error)

UnmarshalCliFlagsToSomeWorkflow3Request unmarshals a SomeWorkflow3Request from command line flags

func (*SomeWorkflow3Request) Descriptor deprecated 

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

Deprecated: Use SomeWorkflow3Request.ProtoReflect.Descriptor instead.

func (*SomeWorkflow3Request) GetId 

func (x *SomeWorkflow3Request) GetId() string

func (*SomeWorkflow3Request) GetRequestVal 

func (x *SomeWorkflow3Request) GetRequestVal() string

func (*SomeWorkflow3Request) ProtoMessage 

func (*SomeWorkflow3Request) ProtoMessage()

func (*SomeWorkflow3Request) ProtoReflect 

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

func (*SomeWorkflow3Request) Reset 

func (x *SomeWorkflow3Request) Reset()

func (*SomeWorkflow3Request) String 

func (x *SomeWorkflow3Request) String() string

type SomeWorkflow3Run 

type SomeWorkflow3Run 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

	// SomeSignal2 is a signal.
	SomeSignal2(ctx context.Context, req *SomeSignal2Request) error
}

SomeWorkflow3Run describes a(n) mycompany.simple.Simple.SomeWorkflow3 workflow run

type SomeWorkflow3Workflow 

type SomeWorkflow3Workflow interface {
	// Execute defines the entrypoint to a(n) mycompany.simple.Simple.SomeWorkflow3 workflow
	//
	// Deprecated: Do not use.
	Execute(ctx workflow.Context) error
}

SomeWorkflow3 does some workflow thing. Deprecated: Use SomeWorkflow2 instead.

workflow details: (name: "mycompany.simple.Simple.SomeWorkflow3", id: "some-workflow-3/${! id }/${! requestVal }")

type SomeWorkflow3WorkflowInput 

type SomeWorkflow3WorkflowInput struct {
	Req         *SomeWorkflow3Request
	SomeSignal2 *SomeSignal2Signal
}

SomeWorkflow3WorkflowInput describes the input to a(n) mycompany.simple.Simple.SomeWorkflow3 workflow constructor

type SomeWorkflow4ChildOptions added in v1.13.2 

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

SomeWorkflow4ChildOptions provides configuration for a child mycompany.simple.Simple.SomeWorkflow4 workflow operation

func NewSomeWorkflow4ChildOptions added in v1.13.2 

func NewSomeWorkflow4ChildOptions() *SomeWorkflow4ChildOptions

NewSomeWorkflow4ChildOptions initializes a new SomeWorkflow4ChildOptions value

func (*SomeWorkflow4ChildOptions) Build added in v1.13.2 

func (o *SomeWorkflow4ChildOptions) 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 (*SomeWorkflow4ChildOptions) WithChildWorkflowOptions added in v1.13.2 

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

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

func (*SomeWorkflow4ChildOptions) WithExecutionTimeout added in v1.13.2 

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

WithExecutionTimeout sets the WorkflowExecutionTimeout value

func (*SomeWorkflow4ChildOptions) WithID added in v1.13.2 

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

WithID sets the WorkflowID value

func (*SomeWorkflow4ChildOptions) WithIDReusePolicy added in v1.13.2 

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

WithIDReusePolicy sets the WorkflowIDReusePolicy value

func (*SomeWorkflow4ChildOptions) WithParentClosePolicy added in v1.13.2 

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

WithParentClosePolicy sets the WorkflowIDReusePolicy value

func (*SomeWorkflow4ChildOptions) WithRetryPolicy added in v1.13.2 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeWorkflow4ChildOptions) WithRunTimeout added in v1.13.2 

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

WithRunTimeout sets the WorkflowRunTimeout value

func (*SomeWorkflow4ChildOptions) WithSearchAttributes added in v1.13.2 

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

WithSearchAttributes sets the SearchAttributes value

func (*SomeWorkflow4ChildOptions) WithTaskQueue added in v1.13.2 

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

WithTaskQueue sets the TaskQueue value

func (*SomeWorkflow4ChildOptions) WithTaskTimeout added in v1.13.2 

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

WithTaskTimeout sets the WorkflowTaskTimeout value

func (*SomeWorkflow4ChildOptions) WithWaitForCancellation added in v1.13.2 

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

WithWaitForCancellation sets the WaitForCancellation value

type SomeWorkflow4ChildRun added in v1.13.2 

type SomeWorkflow4ChildRun struct {
	Future workflow.ChildWorkflowFuture
}

SomeWorkflow4ChildRun describes a child SomeWorkflow4 workflow run

func SomeWorkflow4ChildAsync added in v1.13.2 

func SomeWorkflow4ChildAsync(ctx workflow.Context, req *v1.PaginatedRequest, options ...*SomeWorkflow4ChildOptions) (*SomeWorkflow4ChildRun, error)

SomeWorkflow4 retrieves a paginated list of items

func (*SomeWorkflow4ChildRun) Get added in v1.13.2 

func (r *SomeWorkflow4ChildRun) Get(ctx workflow.Context) (*v1.PaginatedResponse, error)

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

func (*SomeWorkflow4ChildRun) Select added in v1.13.2 

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

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

func (*SomeWorkflow4ChildRun) SelectStart added in v1.13.2 

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

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

func (*SomeWorkflow4ChildRun) WaitStart added in v1.13.2 

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

WaitStart waits for the child workflow to start

type SomeWorkflow4Options added in v1.13.2 

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

SomeWorkflow4Options provides configuration for a mycompany.simple.Simple.SomeWorkflow4 workflow operation

func NewSomeWorkflow4Options added in v1.13.2 

func NewSomeWorkflow4Options() *SomeWorkflow4Options

NewSomeWorkflow4Options initializes a new SomeWorkflow4Options value

func (*SomeWorkflow4Options) Build added in v1.13.2 

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

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

func (*SomeWorkflow4Options) WithExecutionTimeout added in v1.13.2 

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

WithExecutionTimeout sets the WorkflowExecutionTimeout value

func (*SomeWorkflow4Options) WithID added in v1.13.2 

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

WithID sets the ID value

func (*SomeWorkflow4Options) WithIDReusePolicy added in v1.13.2 

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

WithIDReusePolicy sets the WorkflowIDReusePolicy value

func (*SomeWorkflow4Options) WithRetryPolicy added in v1.13.2 

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

WithRetryPolicy sets the RetryPolicy value

func (*SomeWorkflow4Options) WithRunTimeout added in v1.13.2 

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

WithRunTimeout sets the WorkflowRunTimeout value

func (*SomeWorkflow4Options) WithSearchAttributes added in v1.13.2 

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

WithSearchAttributes sets the SearchAttributes value

func (*SomeWorkflow4Options) WithStartWorkflowOptions added in v1.13.2 

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

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

func (*SomeWorkflow4Options) WithTaskQueue added in v1.13.2 

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

WithTaskQueue sets the TaskQueue value

func (*SomeWorkflow4Options) WithTaskTimeout added in v1.13.2 

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

WithTaskTimeout sets the WorkflowTaskTimeout value

type SomeWorkflow4Run added in v1.13.2 

type SomeWorkflow4Run 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) (*v1.PaginatedResponse, 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
}

SomeWorkflow4Run describes a(n) mycompany.simple.Simple.SomeWorkflow4 workflow run

type SomeWorkflow4Workflow added in v1.13.2 

type SomeWorkflow4Workflow interface {
	// Execute defines the entrypoint to a(n) mycompany.simple.Simple.SomeWorkflow4 workflow
	Execute(ctx workflow.Context) (*v1.PaginatedResponse, error)
}

SomeWorkflow4 retrieves a paginated list of items

workflow details: (name: "mycompany.simple.Simple.SomeWorkflow4", id: "some-workflow-4/${! uuid_v4() }")

type SomeWorkflow4WorkflowInput added in v1.13.2 

type SomeWorkflow4WorkflowInput struct {
	Req *v1.PaginatedRequest
}

SomeWorkflow4WorkflowInput describes the input to a(n) mycompany.simple.Simple.SomeWorkflow4 workflow constructor

type TestDeprecatedClient 

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

TestClient provides a testsuite-compatible Client

func NewTestDeprecatedClient 

func NewTestDeprecatedClient(env *testsuite.TestWorkflowEnvironment, workflows DeprecatedWorkflows, activities DeprecatedActivities) *TestDeprecatedClient

NewTestDeprecatedClient initializes a new TestDeprecatedClient value

func (*TestDeprecatedClient) CancelWorkflow 

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

CancelWorkflow requests cancellation of an existing workflow execution

func (*TestDeprecatedClient) GetSomeDeprecatedUpdate1 

func (c *TestDeprecatedClient) GetSomeDeprecatedUpdate1(ctx context.Context, req client.GetWorkflowUpdateHandleOptions) (SomeDeprecatedUpdate1Handle, error)

GetSomeDeprecatedUpdate1 retrieves a handle to an existing mycompany.simple.Deprecated.SomeDeprecatedUpdate1 update

func (*TestDeprecatedClient) GetSomeDeprecatedUpdate2 

func (c *TestDeprecatedClient) GetSomeDeprecatedUpdate2(ctx context.Context, req client.GetWorkflowUpdateHandleOptions) (SomeDeprecatedUpdate2Handle, error)

GetSomeDeprecatedUpdate2 retrieves a handle to an existing mycompany.simple.Deprecated.SomeDeprecatedUpdate2 update

func (*TestDeprecatedClient) GetSomeDeprecatedWorkflow1 

func (c *TestDeprecatedClient) GetSomeDeprecatedWorkflow1(ctx context.Context, workflowID string, runID string) SomeDeprecatedWorkflow1Run

GetSomeDeprecatedWorkflow1 is a noop

func (*TestDeprecatedClient) GetSomeDeprecatedWorkflow2 

func (c *TestDeprecatedClient) GetSomeDeprecatedWorkflow2(ctx context.Context, workflowID string, runID string) SomeDeprecatedWorkflow2Run

GetSomeDeprecatedWorkflow2 is a noop

func (*TestDeprecatedClient) SomeDeprecatedQuery1 

func (c *TestDeprecatedClient) SomeDeprecatedQuery1(ctx context.Context, workflowID string, runID string, req *SomeDeprecatedMessage) (*SomeDeprecatedMessage, error)

SomeDeprecatedQuery1 executes a mycompany.simple.Deprecated.SomeDeprecatedQuery1 query

func (*TestDeprecatedClient) SomeDeprecatedQuery2 

func (c *TestDeprecatedClient) SomeDeprecatedQuery2(ctx context.Context, workflowID string, runID string, req *SomeDeprecatedMessage) (*SomeDeprecatedMessage, error)

SomeDeprecatedQuery2 executes a mycompany.simple.Deprecated.SomeDeprecatedQuery2 query

func (*TestDeprecatedClient) SomeDeprecatedSignal1 

func (c *TestDeprecatedClient) SomeDeprecatedSignal1(ctx context.Context, workflowID string, runID string, req *SomeDeprecatedMessage) error

SomeDeprecatedSignal1 executes a mycompany.simple.Deprecated.SomeDeprecatedSignal1 signal

func (*TestDeprecatedClient) SomeDeprecatedSignal2 

func (c *TestDeprecatedClient) SomeDeprecatedSignal2(ctx context.Context, workflowID string, runID string, req *SomeDeprecatedMessage) error

SomeDeprecatedSignal2 executes a mycompany.simple.Deprecated.SomeDeprecatedSignal2 signal

func (*TestDeprecatedClient) SomeDeprecatedUpdate1 

func (c *TestDeprecatedClient) SomeDeprecatedUpdate1(ctx context.Context, workflowID string, runID string, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedUpdate1Options) (*SomeDeprecatedMessage, error)

SomeDeprecatedUpdate1 executes a(n) mycompany.simple.Deprecated.SomeDeprecatedUpdate1 update in the test environment

func (*TestDeprecatedClient) SomeDeprecatedUpdate1Async 

func (c *TestDeprecatedClient) SomeDeprecatedUpdate1Async(ctx context.Context, workflowID string, runID string, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedUpdate1Options) (SomeDeprecatedUpdate1Handle, error)

SomeDeprecatedUpdate1Async executes a(n) mycompany.simple.Deprecated.SomeDeprecatedUpdate1 update in the test environment

func (*TestDeprecatedClient) SomeDeprecatedUpdate2 

func (c *TestDeprecatedClient) SomeDeprecatedUpdate2(ctx context.Context, workflowID string, runID string, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedUpdate2Options) (*SomeDeprecatedMessage, error)

SomeDeprecatedUpdate2 executes a(n) mycompany.simple.Deprecated.SomeDeprecatedUpdate2 update in the test environment

func (*TestDeprecatedClient) SomeDeprecatedUpdate2Async 

func (c *TestDeprecatedClient) SomeDeprecatedUpdate2Async(ctx context.Context, workflowID string, runID string, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedUpdate2Options) (SomeDeprecatedUpdate2Handle, error)

SomeDeprecatedUpdate2Async executes a(n) mycompany.simple.Deprecated.SomeDeprecatedUpdate2 update in the test environment

func (*TestDeprecatedClient) SomeDeprecatedWorkflow1 

func (c *TestDeprecatedClient) SomeDeprecatedWorkflow1(ctx context.Context, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow1Options) (*SomeDeprecatedMessage, error)

SomeDeprecatedWorkflow1 executes a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow1 workflow in the test environment

func (*TestDeprecatedClient) SomeDeprecatedWorkflow1Async 

func (c *TestDeprecatedClient) SomeDeprecatedWorkflow1Async(ctx context.Context, req *SomeDeprecatedMessage, options ...*SomeDeprecatedWorkflow1Options) (SomeDeprecatedWorkflow1Run, error)

SomeDeprecatedWorkflow1Async executes a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow1 workflow in the test environment

func (*TestDeprecatedClient) SomeDeprecatedWorkflow1WithSomeDeprecatedSignal1 

func (c *TestDeprecatedClient) SomeDeprecatedWorkflow1WithSomeDeprecatedSignal1(ctx context.Context, req *SomeDeprecatedMessage, signal *SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow1Options) (*SomeDeprecatedMessage, error)

SomeDeprecatedWorkflow1WithSomeDeprecatedSignal1 sends a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal1 signal to a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow1 workflow, starting it if necessary

func (*TestDeprecatedClient) SomeDeprecatedWorkflow1WithSomeDeprecatedSignal1Async 

func (c *TestDeprecatedClient) SomeDeprecatedWorkflow1WithSomeDeprecatedSignal1Async(ctx context.Context, req *SomeDeprecatedMessage, signal *SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow1Options) (SomeDeprecatedWorkflow1Run, error)

SomeDeprecatedWorkflow1WithSomeDeprecatedSignal1Async sends a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal1 signal to a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow1 workflow, starting it if necessary

func (*TestDeprecatedClient) SomeDeprecatedWorkflow2 

func (c *TestDeprecatedClient) SomeDeprecatedWorkflow2(ctx context.Context, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow2Options) (*SomeDeprecatedMessage, error)

SomeDeprecatedWorkflow2 executes a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow in the test environment

func (*TestDeprecatedClient) SomeDeprecatedWorkflow2Async 

func (c *TestDeprecatedClient) SomeDeprecatedWorkflow2Async(ctx context.Context, req *SomeDeprecatedMessage, options ...*SomeDeprecatedWorkflow2Options) (SomeDeprecatedWorkflow2Run, error)

SomeDeprecatedWorkflow2Async executes a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow in the test environment

func (*TestDeprecatedClient) SomeDeprecatedWorkflow2WithSomeDeprecatedSignal2 

func (c *TestDeprecatedClient) SomeDeprecatedWorkflow2WithSomeDeprecatedSignal2(ctx context.Context, req *SomeDeprecatedMessage, signal *SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow2Options) (*SomeDeprecatedMessage, error)

SomeDeprecatedWorkflow2WithSomeDeprecatedSignal2 sends a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal2 signal to a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow, starting it if necessary

func (*TestDeprecatedClient) SomeDeprecatedWorkflow2WithSomeDeprecatedSignal2Async 

func (c *TestDeprecatedClient) SomeDeprecatedWorkflow2WithSomeDeprecatedSignal2Async(ctx context.Context, req *SomeDeprecatedMessage, signal *SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow2Options) (SomeDeprecatedWorkflow2Run, error)

SomeDeprecatedWorkflow2WithSomeDeprecatedSignal2Async sends a(n) mycompany.simple.Deprecated.SomeDeprecatedSignal2 signal to a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow, starting it if necessary

func (*TestDeprecatedClient) TerminateWorkflow 

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

TerminateWorkflow terminates an existing workflow execution

type TestIgnoredClient 

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

TestClient provides a testsuite-compatible Client

func NewTestIgnoredClient 

func NewTestIgnoredClient(env *testsuite.TestWorkflowEnvironment, workflows IgnoredWorkflows, activities IgnoredActivities) *TestIgnoredClient

NewTestIgnoredClient initializes a new TestIgnoredClient value

func (*TestIgnoredClient) CancelWorkflow 

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

CancelWorkflow requests cancellation of an existing workflow execution

func (*TestIgnoredClient) GetWhat 

func (c *TestIgnoredClient) GetWhat(ctx context.Context, workflowID string, runID string) WhatRun

GetWhat is a noop

func (*TestIgnoredClient) TerminateWorkflow 

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

TerminateWorkflow terminates an existing workflow execution

func (*TestIgnoredClient) What 

func (c *TestIgnoredClient) What(ctx context.Context, req *WhatRequest, opts ...*WhatOptions) error

What executes a(n) mycompany.simple.Ignored.What workflow in the test environment

func (*TestIgnoredClient) WhatAsync 

func (c *TestIgnoredClient) WhatAsync(ctx context.Context, req *WhatRequest, options ...*WhatOptions) (WhatRun, error)

WhatAsync executes a(n) mycompany.simple.Ignored.What workflow in the test environment

type TestOnlyActivitiesClient 

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

TestClient provides a testsuite-compatible Client

func NewTestOnlyActivitiesClient 

func NewTestOnlyActivitiesClient(env *testsuite.TestWorkflowEnvironment, workflows OnlyActivitiesWorkflows, activities OnlyActivitiesActivities) *TestOnlyActivitiesClient

NewTestOnlyActivitiesClient initializes a new TestOnlyActivitiesClient value

func (*TestOnlyActivitiesClient) CancelWorkflow 

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

CancelWorkflow requests cancellation of an existing workflow execution

func (*TestOnlyActivitiesClient) TerminateWorkflow 

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

TerminateWorkflow terminates an existing workflow execution

type TestOtherClient 

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

TestClient provides a testsuite-compatible Client

func NewTestOtherClient 

func NewTestOtherClient(env *testsuite.TestWorkflowEnvironment, workflows OtherWorkflows, activities OtherActivities) *TestOtherClient

NewTestOtherClient initializes a new TestOtherClient value

func (*TestOtherClient) CancelWorkflow 

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

CancelWorkflow requests cancellation of an existing workflow execution

func (*TestOtherClient) GetOtherUpdate 

func (c *TestOtherClient) GetOtherUpdate(ctx context.Context, req client.GetWorkflowUpdateHandleOptions) (OtherUpdateHandle, error)

GetOtherUpdate retrieves a handle to an existing mycompany.simple.Other.OtherUpdate update

func (*TestOtherClient) GetOtherWorkflow 

func (c *TestOtherClient) GetOtherWorkflow(ctx context.Context, workflowID string, runID string) OtherWorkflowRun

GetOtherWorkflow is a noop

func (*TestOtherClient) OtherQuery 

func (c *TestOtherClient) OtherQuery(ctx context.Context, workflowID string, runID string) (*OtherQueryResponse, error)

OtherQuery executes a mycompany.simple.Other.OtherQuery query

func (*TestOtherClient) OtherSignal 

func (c *TestOtherClient) OtherSignal(ctx context.Context, workflowID string, runID string, req *OtherSignalRequest) error

OtherSignal executes a mycompany.simple.Other.OtherSignal signal

func (*TestOtherClient) OtherUpdate 

func (c *TestOtherClient) OtherUpdate(ctx context.Context, workflowID string, runID string, req *OtherUpdateRequest, opts ...*OtherUpdateOptions) (*OtherUpdateResponse, error)

OtherUpdate executes a(n) mycompany.simple.Other.OtherUpdate update in the test environment

func (*TestOtherClient) OtherUpdateAsync 

func (c *TestOtherClient) OtherUpdateAsync(ctx context.Context, workflowID string, runID string, req *OtherUpdateRequest, opts ...*OtherUpdateOptions) (OtherUpdateHandle, error)

OtherUpdateAsync executes a(n) mycompany.simple.Other.OtherUpdate update in the test environment

func (*TestOtherClient) OtherWorkflow 

func (c *TestOtherClient) OtherWorkflow(ctx context.Context, req *OtherWorkflowRequest, opts ...*OtherWorkflowOptions) (*OtherWorkflowResponse, error)

OtherWorkflow executes a(n) mycompany.simple.Other.OtherWorkflow workflow in the test environment

func (*TestOtherClient) OtherWorkflowAsync 

func (c *TestOtherClient) OtherWorkflowAsync(ctx context.Context, req *OtherWorkflowRequest, options ...*OtherWorkflowOptions) (OtherWorkflowRun, error)

OtherWorkflowAsync executes a(n) mycompany.simple.Other.OtherWorkflow workflow in the test environment

func (*TestOtherClient) TerminateWorkflow 

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

TerminateWorkflow terminates an existing workflow execution

type TestSimpleClient 

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

TestClient provides a testsuite-compatible Client

func NewTestSimpleClient 

func NewTestSimpleClient(env *testsuite.TestWorkflowEnvironment, workflows SimpleWorkflows, activities SimpleActivities) *TestSimpleClient

NewTestSimpleClient initializes a new TestSimpleClient value

func (*TestSimpleClient) CancelWorkflow 

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

CancelWorkflow requests cancellation of an existing workflow execution

func (*TestSimpleClient) GetSomeUpdate1 

func (c *TestSimpleClient) GetSomeUpdate1(ctx context.Context, req client.GetWorkflowUpdateHandleOptions) (SomeUpdate1Handle, error)

GetSomeUpdate1 retrieves a handle to an existing mycompany.simple.Simple.SomeUpdate1 update

func (*TestSimpleClient) GetSomeWorkflow1 

func (c *TestSimpleClient) GetSomeWorkflow1(ctx context.Context, workflowID string, runID string) SomeWorkflow1Run

GetSomeWorkflow1 is a noop

func (*TestSimpleClient) GetSomeWorkflow2 

func (c *TestSimpleClient) GetSomeWorkflow2(ctx context.Context, workflowID string, runID string) SomeWorkflow2Run

GetSomeWorkflow2 is a noop

func (*TestSimpleClient) GetSomeWorkflow3 

func (c *TestSimpleClient) GetSomeWorkflow3(ctx context.Context, workflowID string, runID string) SomeWorkflow3Run

GetSomeWorkflow3 is a noop

func (*TestSimpleClient) GetSomeWorkflow4 added in v1.13.2 

func (c *TestSimpleClient) GetSomeWorkflow4(ctx context.Context, workflowID string, runID string) SomeWorkflow4Run

GetSomeWorkflow4 is a noop

func (*TestSimpleClient) SomeQuery1 

func (c *TestSimpleClient) SomeQuery1(ctx context.Context, workflowID string, runID string) (*SomeQuery1Response, error)

SomeQuery1 executes a mycompany.simple.Simple.SomeQuery1 query

func (*TestSimpleClient) SomeQuery2 

func (c *TestSimpleClient) SomeQuery2(ctx context.Context, workflowID string, runID string, req *SomeQuery2Request) (*SomeQuery2Response, error)

SomeQuery2 executes a mycompany.simple.Simple.SomeQuery2 query

func (*TestSimpleClient) SomeSignal1 

func (c *TestSimpleClient) SomeSignal1(ctx context.Context, workflowID string, runID string) error

SomeSignal1 executes a mycompany.simple.Simple.SomeSignal1 signal

func (*TestSimpleClient) SomeSignal2 

func (c *TestSimpleClient) SomeSignal2(ctx context.Context, workflowID string, runID string, req *SomeSignal2Request) error

SomeSignal2 executes a mycompany.simple.Simple.SomeSignal2 signal

func (*TestSimpleClient) SomeSignal3 

func (c *TestSimpleClient) SomeSignal3(ctx context.Context, workflowID string, runID string, req *SomeSignal3Request) error

SomeSignal3 executes a mycompany.simple.Simple.SomeSignal3 signal

func (*TestSimpleClient) SomeUpdate1 

func (c *TestSimpleClient) SomeUpdate1(ctx context.Context, workflowID string, runID string, req *SomeUpdate1Request, opts ...*SomeUpdate1Options) (*SomeUpdate1Response, error)

SomeUpdate1 executes a(n) mycompany.simple.Simple.SomeUpdate1 update in the test environment

func (*TestSimpleClient) SomeUpdate1Async 

func (c *TestSimpleClient) SomeUpdate1Async(ctx context.Context, workflowID string, runID string, req *SomeUpdate1Request, opts ...*SomeUpdate1Options) (SomeUpdate1Handle, error)

SomeUpdate1Async executes a(n) mycompany.simple.Simple.SomeUpdate1 update in the test environment

func (*TestSimpleClient) SomeWorkflow1 

func (c *TestSimpleClient) SomeWorkflow1(ctx context.Context, req *SomeWorkflow1Request, opts ...*SomeWorkflow1Options) (*SomeWorkflow1Response, error)

SomeWorkflow1 executes a(n) mycompany.simple.SomeWorkflow1 workflow in the test environment

func (*TestSimpleClient) SomeWorkflow1Async 

func (c *TestSimpleClient) SomeWorkflow1Async(ctx context.Context, req *SomeWorkflow1Request, options ...*SomeWorkflow1Options) (SomeWorkflow1Run, error)

SomeWorkflow1Async executes a(n) mycompany.simple.SomeWorkflow1 workflow in the test environment

func (*TestSimpleClient) SomeWorkflow2 

func (c *TestSimpleClient) SomeWorkflow2(ctx context.Context, opts ...*SomeWorkflow2Options) error

SomeWorkflow2 executes a(n) mycompany.simple.SomeWorkflow2 workflow in the test environment

func (*TestSimpleClient) SomeWorkflow2Async 

func (c *TestSimpleClient) SomeWorkflow2Async(ctx context.Context, options ...*SomeWorkflow2Options) (SomeWorkflow2Run, error)

SomeWorkflow2Async executes a(n) mycompany.simple.SomeWorkflow2 workflow in the test environment

func (*TestSimpleClient) SomeWorkflow2WithSomeSignal1 

func (c *TestSimpleClient) SomeWorkflow2WithSomeSignal1(ctx context.Context, opts ...*SomeWorkflow2Options) error

SomeWorkflow2WithSomeSignal1 sends a(n) mycompany.simple.Simple.SomeSignal1 signal to a(n) mycompany.simple.SomeWorkflow2 workflow, starting it if necessary

func (*TestSimpleClient) SomeWorkflow2WithSomeSignal1Async 

func (c *TestSimpleClient) SomeWorkflow2WithSomeSignal1Async(ctx context.Context, opts ...*SomeWorkflow2Options) (SomeWorkflow2Run, error)

SomeWorkflow2WithSomeSignal1Async sends a(n) mycompany.simple.Simple.SomeSignal1 signal to a(n) mycompany.simple.SomeWorkflow2 workflow, starting it if necessary

func (*TestSimpleClient) SomeWorkflow3 

func (c *TestSimpleClient) SomeWorkflow3(ctx context.Context, req *SomeWorkflow3Request, opts ...*SomeWorkflow3Options) error

SomeWorkflow3 executes a(n) mycompany.simple.Simple.SomeWorkflow3 workflow in the test environment

func (*TestSimpleClient) SomeWorkflow3Async 

func (c *TestSimpleClient) SomeWorkflow3Async(ctx context.Context, req *SomeWorkflow3Request, options ...*SomeWorkflow3Options) (SomeWorkflow3Run, error)

SomeWorkflow3Async executes a(n) mycompany.simple.Simple.SomeWorkflow3 workflow in the test environment

func (*TestSimpleClient) SomeWorkflow3WithSomeSignal2 

func (c *TestSimpleClient) SomeWorkflow3WithSomeSignal2(ctx context.Context, req *SomeWorkflow3Request, signal *SomeSignal2Request, opts ...*SomeWorkflow3Options) error

SomeWorkflow3WithSomeSignal2 sends a(n) mycompany.simple.Simple.SomeSignal2 signal to a(n) mycompany.simple.Simple.SomeWorkflow3 workflow, starting it if necessary

func (*TestSimpleClient) SomeWorkflow3WithSomeSignal2Async 

func (c *TestSimpleClient) SomeWorkflow3WithSomeSignal2Async(ctx context.Context, req *SomeWorkflow3Request, signal *SomeSignal2Request, opts ...*SomeWorkflow3Options) (SomeWorkflow3Run, error)

SomeWorkflow3WithSomeSignal2Async sends a(n) mycompany.simple.Simple.SomeSignal2 signal to a(n) mycompany.simple.Simple.SomeWorkflow3 workflow, starting it if necessary

func (*TestSimpleClient) SomeWorkflow4 added in v1.13.2 

func (c *TestSimpleClient) SomeWorkflow4(ctx context.Context, req *v1.PaginatedRequest, opts ...*SomeWorkflow4Options) (*v1.PaginatedResponse, error)

SomeWorkflow4 executes a(n) mycompany.simple.Simple.SomeWorkflow4 workflow in the test environment

func (*TestSimpleClient) SomeWorkflow4Async added in v1.13.2 

func (c *TestSimpleClient) SomeWorkflow4Async(ctx context.Context, req *v1.PaginatedRequest, options ...*SomeWorkflow4Options) (SomeWorkflow4Run, error)

SomeWorkflow4Async executes a(n) mycompany.simple.Simple.SomeWorkflow4 workflow in the test environment

func (*TestSimpleClient) TerminateWorkflow 

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

TerminateWorkflow terminates an existing workflow execution

type WhatChildOptions 

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

WhatChildOptions provides configuration for a child mycompany.simple.Ignored.What workflow operation

func NewWhatChildOptions 

func NewWhatChildOptions() *WhatChildOptions

NewWhatChildOptions initializes a new WhatChildOptions value

func (*WhatChildOptions) Build added in v1.13.0 

func (o *WhatChildOptions) 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 (*WhatChildOptions) WithChildWorkflowOptions 

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

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

func (*WhatChildOptions) WithExecutionTimeout added in v1.13.0 

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

WithExecutionTimeout sets the WorkflowExecutionTimeout value

func (*WhatChildOptions) WithID added in v1.13.0 

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

WithID sets the WorkflowID value

func (*WhatChildOptions) WithIDReusePolicy added in v1.13.0 

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

WithIDReusePolicy sets the WorkflowIDReusePolicy value

func (*WhatChildOptions) WithParentClosePolicy added in v1.13.0 

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

WithParentClosePolicy sets the WorkflowIDReusePolicy value

func (*WhatChildOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*WhatChildOptions) WithRunTimeout added in v1.13.0 

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

WithRunTimeout sets the WorkflowRunTimeout value

func (*WhatChildOptions) WithSearchAttributes added in v1.13.0 

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

WithSearchAttributes sets the SearchAttributes value

func (*WhatChildOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*WhatChildOptions) WithTaskTimeout added in v1.13.0 

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

WithTaskTimeout sets the WorkflowTaskTimeout value

func (*WhatChildOptions) WithWaitForCancellation added in v1.13.0 

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

WithWaitForCancellation sets the WaitForCancellation value

type WhatChildRun 

type WhatChildRun struct {
	Future workflow.ChildWorkflowFuture
}

WhatChildRun describes a child What workflow run

func WhatChildAsync 

func WhatChildAsync(ctx workflow.Context, req *WhatRequest, options ...*WhatChildOptions) (*WhatChildRun, error)

WhatChildAsync starts a child mycompany.simple.Ignored.What workflow and returns a handle to the child workflow run

func (*WhatChildRun) Get 

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

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

func (*WhatChildRun) Select 

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

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

func (*WhatChildRun) SelectStart 

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

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

func (*WhatChildRun) WaitStart 

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

WaitStart waits for the child workflow to start

type WhatOptions 

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

WhatOptions provides configuration for a mycompany.simple.Ignored.What workflow operation

func NewWhatOptions 

func NewWhatOptions() *WhatOptions

NewWhatOptions initializes a new WhatOptions value

func (*WhatOptions) Build added in v1.13.0 

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

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

func (*WhatOptions) WithExecutionTimeout added in v1.13.0 

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

WithExecutionTimeout sets the WorkflowExecutionTimeout value

func (*WhatOptions) WithID added in v1.13.0 

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

WithID sets the ID value

func (*WhatOptions) WithIDReusePolicy added in v1.13.0 

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

WithIDReusePolicy sets the WorkflowIDReusePolicy value

func (*WhatOptions) WithRetryPolicy added in v1.13.0 

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

WithRetryPolicy sets the RetryPolicy value

func (*WhatOptions) WithRunTimeout added in v1.13.0 

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

WithRunTimeout sets the WorkflowRunTimeout value

func (*WhatOptions) WithSearchAttributes added in v1.13.0 

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

WithSearchAttributes sets the SearchAttributes value

func (*WhatOptions) WithStartWorkflowOptions 

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

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

func (*WhatOptions) WithTaskQueue added in v1.13.0 

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

WithTaskQueue sets the TaskQueue value

func (*WhatOptions) WithTaskTimeout added in v1.13.0 

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

WithTaskTimeout sets the WorkflowTaskTimeout value

type WhatRequest 

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

func (*WhatRequest) Descriptor deprecated 

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

Deprecated: Use WhatRequest.ProtoReflect.Descriptor instead.

func (*WhatRequest) GetBlah 

func (x *WhatRequest) GetBlah() string

func (*WhatRequest) ProtoMessage 

func (*WhatRequest) ProtoMessage()

func (*WhatRequest) ProtoReflect 

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

func (*WhatRequest) Reset 

func (x *WhatRequest) Reset()

func (*WhatRequest) String 

func (x *WhatRequest) String() string

type WhatRun 

type WhatRun 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
}

WhatRun describes a(n) mycompany.simple.Ignored.What workflow run

type WhatWorkflow 

type WhatWorkflow interface {
	// Execute defines the entrypoint to a(n) mycompany.simple.Ignored.What workflow
	Execute(ctx workflow.Context) error
}

WhatWorkflow describes a(n) mycompany.simple.Ignored.What workflow implementation

workflow details: (id: "what/${!ksuid()}")

type WhatWorkflowInput 

type WhatWorkflowInput struct {
	Req *WhatRequest
}

WhatWorkflowInput describes the input to a(n) mycompany.simple.Ignored.What 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.