v1

package
v1.12.0 Latest Latest
Warning

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

Go to latest
Published: Apr 19, 2024 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.11.1-next (c39ba7f5af358428c18ecce12978be63d88f77f4)
go go1.22.1
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"
)

mycompany.simple.Simple workflow names

View Source
const (
	SomeActivity1ActivityName = "mycompany.simple.SomeActivity1"
	SomeActivity2ActivityName = "mycompany.simple.Simple.SomeActivity2"
	SomeActivity3ActivityName = "mycompany.simple.Simple.SomeActivity3"
	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() }")
	SomeWorkflow3Idexpression = expression.MustParseExpression("some-workflow-3/${! id }/${! requestVal }")
)

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
)

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

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

func RegisterSomeDeprecatedWorkflow2Workflow

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

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 sets default ActivityOptions

func (*LonelyActivity1ActivityOptions) WithActivityOptions

WithActivityOptions sets default ActivityOptions

type LonelyActivity1Future

type LonelyActivity1Future struct {
	Future workflow.Future
}

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

func LonelyActivity1Async

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

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

func (*LonelyActivity1Future) Select

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 local mycompany.simple.OnlyActivities.LonelyActivity1 activity

func NewLonelyActivity1LocalActivityOptions

func NewLonelyActivity1LocalActivityOptions() *LonelyActivity1LocalActivityOptions

NewLonelyActivity1LocalActivityOptions sets default LocalActivityOptions

func (*LonelyActivity1LocalActivityOptions) Local

Local provides a local mycompany.simple.OnlyActivities.LonelyActivity1 activity implementation

func (*LonelyActivity1LocalActivityOptions) WithLocalActivityOptions

WithLocalActivityOptions sets default LocalActivityOptions

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

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

func LonelyActivity1Local

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

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

WithClient provides a Temporal client factory for use by commands

func (*OnlyActivitiesCliOptions) WithWorker

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

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

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

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.UpdateWorkflowWithOptionsRequest
}

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

func NewOtherUpdateOptions

func NewOtherUpdateOptions() *OtherUpdateOptions

NewOtherUpdateOptions initializes a new OtherUpdateOptions value

func (*OtherUpdateOptions) WithUpdateWorkflowOptions

func (opts *OtherUpdateOptions) WithUpdateWorkflowOptions(options client.UpdateWorkflowWithOptionsRequest) *OtherUpdateOptions

WithUpdateWorkflowOptions sets the initial client.UpdateWorkflowWithOptionsRequest

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 sets default ActivityOptions

func (*OtherWorkflowActivityOptions) WithActivityOptions

WithActivityOptions sets default ActivityOptions

type OtherWorkflowChildOptions

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

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

func NewOtherWorkflowChildOptions

func NewOtherWorkflowChildOptions() *OtherWorkflowChildOptions

NewOtherWorkflowChildOptions initializes a new OtherWorkflowChildOptions value

func (*OtherWorkflowChildOptions) WithChildWorkflowOptions

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

WithChildWorkflowOptions sets the initial client.StartWorkflowOptions

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

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

func (*OtherWorkflowChildRun) Select

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

func (*OtherWorkflowChildRun) SelectStart

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

func (*OtherWorkflowChildRun) WaitStart

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

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

func (*OtherWorkflowFuture) Select

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 local mycompany.simple.Other.OtherWorkflow activity

func NewOtherWorkflowLocalActivityOptions

func NewOtherWorkflowLocalActivityOptions() *OtherWorkflowLocalActivityOptions

NewOtherWorkflowLocalActivityOptions sets default LocalActivityOptions

func (*OtherWorkflowLocalActivityOptions) Local

Local provides a local mycompany.simple.Other.OtherWorkflow activity implementation

func (*OtherWorkflowLocalActivityOptions) WithLocalActivityOptions

WithLocalActivityOptions sets default LocalActivityOptions

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

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

WithStartWorkflowOptions sets the initial client.StartWorkflowOptions

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 assignable 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
	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 (*OtherWorkflowRequest) GetBaz

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 (m *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_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

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

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)

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

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

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

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 sets default ActivityOptions

func (*SomeActivity1ActivityOptions) WithActivityOptions

WithActivityOptions sets default ActivityOptions

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

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

func (*SomeActivity1Future) Select

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 local mycompany.simple.SomeActivity1 activity

func NewSomeActivity1LocalActivityOptions

func NewSomeActivity1LocalActivityOptions() *SomeActivity1LocalActivityOptions

NewSomeActivity1LocalActivityOptions sets default LocalActivityOptions

func (*SomeActivity1LocalActivityOptions) Local

Local provides a local mycompany.simple.SomeActivity1 activity implementation

func (*SomeActivity1LocalActivityOptions) WithLocalActivityOptions

WithLocalActivityOptions sets default LocalActivityOptions

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 sets default ActivityOptions

func (*SomeActivity2ActivityOptions) WithActivityOptions

WithActivityOptions sets default ActivityOptions

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

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

func (*SomeActivity2Future) Select

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 local mycompany.simple.Simple.SomeActivity2 activity

func NewSomeActivity2LocalActivityOptions

func NewSomeActivity2LocalActivityOptions() *SomeActivity2LocalActivityOptions

NewSomeActivity2LocalActivityOptions sets default LocalActivityOptions

func (*SomeActivity2LocalActivityOptions) Local

Local provides a local mycompany.simple.Simple.SomeActivity2 activity implementation

func (*SomeActivity2LocalActivityOptions) WithLocalActivityOptions

WithLocalActivityOptions sets default LocalActivityOptions

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 sets default ActivityOptions

func (*SomeActivity3ActivityOptions) WithActivityOptions

WithActivityOptions sets default ActivityOptions

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

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

func (*SomeActivity3Future) Select

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 local mycompany.simple.Simple.SomeActivity3 activity

func NewSomeActivity3LocalActivityOptions

func NewSomeActivity3LocalActivityOptions() *SomeActivity3LocalActivityOptions

NewSomeActivity3LocalActivityOptions sets default LocalActivityOptions

func (*SomeActivity3LocalActivityOptions) Local

Local provides a local mycompany.simple.Simple.SomeActivity3 activity implementation

func (*SomeActivity3LocalActivityOptions) WithLocalActivityOptions

WithLocalActivityOptions sets default LocalActivityOptions

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

SomeActivity3 does some activity thing.

func SomeActivity3Local

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 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 sets default ActivityOptions

func (*SomeDeprecatedActivity1ActivityOptions) WithActivityOptions

WithActivityOptions sets default ActivityOptions

type SomeDeprecatedActivity1Future

type SomeDeprecatedActivity1Future struct {
	Future workflow.Future
}

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

func SomeDeprecatedActivity1Async deprecated

SomeDeprecatedActivity1 does something

Deprecated: Do not use.

func SomeDeprecatedActivity1LocalAsync deprecated

SomeDeprecatedActivity1 does something

Deprecated: Do not use.

func (*SomeDeprecatedActivity1Future) Get

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

func (*SomeDeprecatedActivity1Future) Select

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 local mycompany.simple.Deprecated.SomeDeprecatedActivity1 activity

func NewSomeDeprecatedActivity1LocalActivityOptions

func NewSomeDeprecatedActivity1LocalActivityOptions() *SomeDeprecatedActivity1LocalActivityOptions

NewSomeDeprecatedActivity1LocalActivityOptions sets default LocalActivityOptions

func (*SomeDeprecatedActivity1LocalActivityOptions) Local

Local provides a local mycompany.simple.Deprecated.SomeDeprecatedActivity1 activity implementation

func (*SomeDeprecatedActivity1LocalActivityOptions) WithLocalActivityOptions

WithLocalActivityOptions sets default LocalActivityOptions

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 sets default ActivityOptions

func (*SomeDeprecatedActivity2ActivityOptions) WithActivityOptions

WithActivityOptions sets default ActivityOptions

type SomeDeprecatedActivity2Future

type SomeDeprecatedActivity2Future struct {
	Future workflow.Future
}

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

func SomeDeprecatedActivity2Async deprecated

SomeDeprecatedActivity2 does something else

Deprecated: a custom activity deprecation message.

func SomeDeprecatedActivity2LocalAsync deprecated

SomeDeprecatedActivity2 does something else

Deprecated: a custom activity deprecation message.

func (*SomeDeprecatedActivity2Future) Get

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

func (*SomeDeprecatedActivity2Future) Select

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 local mycompany.simple.Deprecated.SomeDeprecatedActivity2 activity

func NewSomeDeprecatedActivity2LocalActivityOptions

func NewSomeDeprecatedActivity2LocalActivityOptions() *SomeDeprecatedActivity2LocalActivityOptions

NewSomeDeprecatedActivity2LocalActivityOptions sets default LocalActivityOptions

func (*SomeDeprecatedActivity2LocalActivityOptions) Local

Local provides a local mycompany.simple.Deprecated.SomeDeprecatedActivity2 activity implementation

func (*SomeDeprecatedActivity2LocalActivityOptions) WithLocalActivityOptions

WithLocalActivityOptions sets default LocalActivityOptions

type SomeDeprecatedMessage

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

func SomeDeprecatedActivity1 deprecated

SomeDeprecatedActivity1 does something

Deprecated: Do not use.

func SomeDeprecatedActivity1Local deprecated

SomeDeprecatedActivity1 does something

Deprecated: Do not use.

func SomeDeprecatedActivity2 deprecated

SomeDeprecatedActivity2 does something else

Deprecated: a custom activity deprecation message.

func SomeDeprecatedActivity2Local deprecated

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

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

func (*SomeDeprecatedSignal1Signal) ReceiveAsync

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

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

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

func (*SomeDeprecatedSignal2Signal) ReceiveAsync

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

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.UpdateWorkflowWithOptionsRequest
}

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

func NewSomeDeprecatedUpdate1Options

func NewSomeDeprecatedUpdate1Options() *SomeDeprecatedUpdate1Options

NewSomeDeprecatedUpdate1Options initializes a new SomeDeprecatedUpdate1Options value

func (*SomeDeprecatedUpdate1Options) WithUpdateWorkflowOptions

WithUpdateWorkflowOptions sets the initial client.UpdateWorkflowWithOptionsRequest

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.UpdateWorkflowWithOptionsRequest
}

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

func NewSomeDeprecatedUpdate2Options

func NewSomeDeprecatedUpdate2Options() *SomeDeprecatedUpdate2Options

NewSomeDeprecatedUpdate2Options initializes a new SomeDeprecatedUpdate2Options value

func (*SomeDeprecatedUpdate2Options) WithUpdateWorkflowOptions

WithUpdateWorkflowOptions sets the initial client.UpdateWorkflowWithOptionsRequest

type SomeDeprecatedWorkflow1ChildOptions

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

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

func NewSomeDeprecatedWorkflow1ChildOptions

func NewSomeDeprecatedWorkflow1ChildOptions() *SomeDeprecatedWorkflow1ChildOptions

NewSomeDeprecatedWorkflow1ChildOptions initializes a new SomeDeprecatedWorkflow1ChildOptions value

func (*SomeDeprecatedWorkflow1ChildOptions) WithChildWorkflowOptions

WithChildWorkflowOptions sets the initial client.StartWorkflowOptions

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

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

func (*SomeDeprecatedWorkflow1ChildRun) Select

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

func (*SomeDeprecatedWorkflow1ChildRun) SelectStart

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

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

WithStartWorkflowOptions sets the initial client.StartWorkflowOptions

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 mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow operation

func NewSomeDeprecatedWorkflow2ChildOptions

func NewSomeDeprecatedWorkflow2ChildOptions() *SomeDeprecatedWorkflow2ChildOptions

NewSomeDeprecatedWorkflow2ChildOptions initializes a new SomeDeprecatedWorkflow2ChildOptions value

func (*SomeDeprecatedWorkflow2ChildOptions) WithChildWorkflowOptions

WithChildWorkflowOptions sets the initial client.StartWorkflowOptions

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

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

func (*SomeDeprecatedWorkflow2ChildRun) Select

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

func (*SomeDeprecatedWorkflow2ChildRun) SelectStart

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

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

WithStartWorkflowOptions sets the initial client.StartWorkflowOptions

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 sets default ActivityOptions

func (*SomeSignal1ActivityOptions) WithActivityOptions

WithActivityOptions sets default ActivityOptions

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

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

func (*SomeSignal1Future) Select

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 local mycompany.simple.Simple.SomeSignal1 activity

func NewSomeSignal1LocalActivityOptions

func NewSomeSignal1LocalActivityOptions() *SomeSignal1LocalActivityOptions

NewSomeSignal1LocalActivityOptions sets default LocalActivityOptions

func (*SomeSignal1LocalActivityOptions) Local

Local provides a local mycompany.simple.Simple.SomeSignal1 activity implementation

func (*SomeSignal1LocalActivityOptions) WithLocalActivityOptions

WithLocalActivityOptions sets default LocalActivityOptions

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 sets default ActivityOptions

func (*SomeSignal2ActivityOptions) WithActivityOptions

WithActivityOptions sets default ActivityOptions

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

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

func (*SomeSignal2Future) Select

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 local mycompany.simple.Simple.SomeSignal2 activity

func NewSomeSignal2LocalActivityOptions

func NewSomeSignal2LocalActivityOptions() *SomeSignal2LocalActivityOptions

NewSomeSignal2LocalActivityOptions sets default LocalActivityOptions

func (*SomeSignal2LocalActivityOptions) Local

Local provides a local mycompany.simple.Simple.SomeSignal2 activity implementation

func (*SomeSignal2LocalActivityOptions) WithLocalActivityOptions

WithLocalActivityOptions sets default LocalActivityOptions

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

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

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 sets default ActivityOptions

func (*SomeSignal3ActivityOptions) WithActivityOptions

WithActivityOptions sets default ActivityOptions

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

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

func (*SomeSignal3Future) Select

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 local mycompany.simple.Simple.SomeSignal3 activity

func NewSomeSignal3LocalActivityOptions

func NewSomeSignal3LocalActivityOptions() *SomeSignal3LocalActivityOptions

NewSomeSignal3LocalActivityOptions sets default LocalActivityOptions

func (*SomeSignal3LocalActivityOptions) Local

Local provides a local mycompany.simple.Simple.SomeSignal3 activity implementation

func (*SomeSignal3LocalActivityOptions) WithLocalActivityOptions

WithLocalActivityOptions sets default LocalActivityOptions

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

SomeSignal3 is a signal.

func SomeSignal3Local

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

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

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 sets default ActivityOptions

func (*SomeUpdate1ActivityOptions) WithActivityOptions

WithActivityOptions sets default ActivityOptions

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

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

func (*SomeUpdate1Future) Select

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 local mycompany.simple.Simple.SomeUpdate1 activity

func NewSomeUpdate1LocalActivityOptions

func NewSomeUpdate1LocalActivityOptions() *SomeUpdate1LocalActivityOptions

NewSomeUpdate1LocalActivityOptions sets default LocalActivityOptions

func (*SomeUpdate1LocalActivityOptions) Local

Local provides a local mycompany.simple.Simple.SomeUpdate1 activity implementation

func (*SomeUpdate1LocalActivityOptions) WithLocalActivityOptions

WithLocalActivityOptions sets default LocalActivityOptions

type SomeUpdate1Options

type SomeUpdate1Options struct {
	Options *client.UpdateWorkflowWithOptionsRequest
}

SomeUpdate1Options provides configuration for a mycompany.simple.Simple.SomeUpdate1 update operation

func NewSomeUpdate1Options

func NewSomeUpdate1Options() *SomeUpdate1Options

NewSomeUpdate1Options initializes a new SomeUpdate1Options value

func (*SomeUpdate1Options) WithUpdateWorkflowOptions

func (opts *SomeUpdate1Options) WithUpdateWorkflowOptions(options client.UpdateWorkflowWithOptionsRequest) *SomeUpdate1Options

WithUpdateWorkflowOptions sets the initial client.UpdateWorkflowWithOptionsRequest

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

SomeUpdate1 updates a SomeWorkflow2

func SomeUpdate1Local

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 mycompany.simple.SomeWorkflow1 workflow operation

func NewSomeWorkflow1ChildOptions

func NewSomeWorkflow1ChildOptions() *SomeWorkflow1ChildOptions

NewSomeWorkflow1ChildOptions initializes a new SomeWorkflow1ChildOptions value

func (*SomeWorkflow1ChildOptions) WithChildWorkflowOptions

func (opts *SomeWorkflow1ChildOptions) WithChildWorkflowOptions(options workflow.ChildWorkflowOptions) *SomeWorkflow1ChildOptions

WithChildWorkflowOptions sets the initial client.StartWorkflowOptions

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

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

func (*SomeWorkflow1ChildRun) Select

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

func (*SomeWorkflow1ChildRun) SelectStart

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

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

func (opts *SomeWorkflow1Options) WithStartWorkflowOptions(options client.StartWorkflowOptions) *SomeWorkflow1Options

WithStartWorkflowOptions sets the initial client.StartWorkflowOptions

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 mycompany.simple.SomeWorkflow2 workflow operation

func NewSomeWorkflow2ChildOptions

func NewSomeWorkflow2ChildOptions() *SomeWorkflow2ChildOptions

NewSomeWorkflow2ChildOptions initializes a new SomeWorkflow2ChildOptions value

func (*SomeWorkflow2ChildOptions) WithChildWorkflowOptions

func (opts *SomeWorkflow2ChildOptions) WithChildWorkflowOptions(options workflow.ChildWorkflowOptions) *SomeWorkflow2ChildOptions

WithChildWorkflowOptions sets the initial client.StartWorkflowOptions

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

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

func (*SomeWorkflow2ChildRun) Select

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

func (*SomeWorkflow2ChildRun) SelectStart

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

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

func (opts *SomeWorkflow2Options) WithStartWorkflowOptions(options client.StartWorkflowOptions) *SomeWorkflow2Options

WithStartWorkflowOptions sets the initial client.StartWorkflowOptions

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

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 mycompany.simple.Simple.SomeWorkflow3 workflow operation

func NewSomeWorkflow3ChildOptions

func NewSomeWorkflow3ChildOptions() *SomeWorkflow3ChildOptions

NewSomeWorkflow3ChildOptions initializes a new SomeWorkflow3ChildOptions value

func (*SomeWorkflow3ChildOptions) WithChildWorkflowOptions

func (opts *SomeWorkflow3ChildOptions) WithChildWorkflowOptions(options workflow.ChildWorkflowOptions) *SomeWorkflow3ChildOptions

WithChildWorkflowOptions sets the initial client.StartWorkflowOptions

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

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

func (*SomeWorkflow3ChildRun) Select

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

func (*SomeWorkflow3ChildRun) SelectStart

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

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

func (opts *SomeWorkflow3Options) WithStartWorkflowOptions(options client.StartWorkflowOptions) *SomeWorkflow3Options

WithStartWorkflowOptions sets the initial client.StartWorkflowOptions

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

GetSomeDeprecatedUpdate1 retrieves a handle to an existing mycompany.simple.Deprecated.SomeDeprecatedUpdate1 update

func (*TestDeprecatedClient) GetSomeDeprecatedUpdate2

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

SomeDeprecatedWorkflow1 executes a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow1 workflow in the test environment

func (*TestDeprecatedClient) SomeDeprecatedWorkflow1Async

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

SomeDeprecatedWorkflow2 executes a(n) mycompany.simple.Deprecated.SomeDeprecatedWorkflow2 workflow in the test environment

func (*TestDeprecatedClient) SomeDeprecatedWorkflow2Async

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

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

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

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

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) 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 mycompany.simple.Ignored.What workflow operation

func NewWhatChildOptions

func NewWhatChildOptions() *WhatChildOptions

NewWhatChildOptions initializes a new WhatChildOptions value

func (*WhatChildOptions) WithChildWorkflowOptions

func (opts *WhatChildOptions) WithChildWorkflowOptions(options workflow.ChildWorkflowOptions) *WhatChildOptions

WithChildWorkflowOptions sets the initial client.StartWorkflowOptions

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

func (opts *WhatOptions) WithStartWorkflowOptions(options client.StartWorkflowOptions) *WhatOptions

WithStartWorkflowOptions sets the initial client.StartWorkflowOptions

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

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