simple

package
v1.10.3 Latest Latest
Warning

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

 Go to latest Published: Apr 5, 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.10.3-next (0ee894c9c5eb74083457f7963d880cad1a7c1a2f)
go go1.22.1
protoc (unknown)

source: simple/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_simple_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 "OtherWorkflowWorkflow" 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 "WhatWorkflow" 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 added in v1.9.0 

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

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

func NewDeprecatedCliCommand added in v1.9.0 

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 added in v1.9.0 

func NewDeprecatedClientOptions() *deprecatedClientOptions

NewDeprecatedClientOptions initializes a new deprecatedClientOptions value

func NewIgnoredClientOptions added in v1.9.0 

func NewIgnoredClientOptions() *ignoredClientOptions

NewIgnoredClientOptions initializes a new ignoredClientOptions value

func NewOnlyActivitiesCli added in v1.8.2 

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

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

func NewOnlyActivitiesCliCommand added in v1.8.2 

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 added in v1.9.0 

func NewOnlyActivitiesClientOptions() *onlyActivitiesClientOptions

NewOnlyActivitiesClientOptions initializes a new onlyActivitiesClientOptions value

func NewOtherCli added in v1.0.0 

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

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

func NewOtherCliCommand added in v1.0.0 

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 added in v1.9.0 

func NewOtherClientOptions() *otherClientOptions

NewOtherClientOptions initializes a new otherClientOptions value

func NewSimpleCli added in v1.0.0 

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

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

func NewSimpleCliCommand added in v1.0.0 

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 added in v1.9.0 

func NewSimpleClientOptions() *simpleClientOptions

NewSimpleClientOptions initializes a new simpleClientOptions value

func OtherSignalExternal added in v1.0.0 

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 added in v1.0.0 

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 added in v1.9.0 

func RegisterDeprecatedActivities(r worker.ActivityRegistry, activities DeprecatedActivities)

RegisterDeprecatedActivities registers activities with a worker

func RegisterDeprecatedWorkflows added in v1.9.0 

func RegisterDeprecatedWorkflows(r worker.WorkflowRegistry, workflows DeprecatedWorkflows)

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

func RegisterIgnoredActivities added in v1.2.0 

func RegisterIgnoredActivities(r worker.ActivityRegistry, activities IgnoredActivities)

RegisterIgnoredActivities registers activities with a worker

func RegisterIgnoredWorkflows added in v1.2.0 

func RegisterIgnoredWorkflows(r worker.WorkflowRegistry, workflows IgnoredWorkflows)

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

func RegisterLonelyActivity1Activity added in v1.8.2 

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

RegisterLonelyActivity1Activity registers a mycompany.simple.OnlyActivities.LonelyActivity1 activity

func RegisterOnlyActivitiesActivities added in v1.8.2 

func RegisterOnlyActivitiesActivities(r worker.ActivityRegistry, activities OnlyActivitiesActivities)

RegisterOnlyActivitiesActivities registers activities with a worker

func RegisterOnlyActivitiesWorkflows added in v1.8.2 

func RegisterOnlyActivitiesWorkflows(r worker.WorkflowRegistry, workflows OnlyActivitiesWorkflows)

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

func RegisterOtherActivities added in v1.0.0 

func RegisterOtherActivities(r worker.ActivityRegistry, activities OtherActivities)

RegisterOtherActivities registers activities with a worker

func RegisterOtherWorkflowActivity added in v1.0.0 

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

RegisterOtherWorkflowActivity registers a mycompany.simple.Other.OtherWorkflow activity

func RegisterOtherWorkflowWorkflow added in v1.0.0 

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 added in v1.0.0 

func RegisterOtherWorkflows(r worker.WorkflowRegistry, workflows OtherWorkflows)

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

func RegisterSimpleActivities added in v1.0.0 

func RegisterSimpleActivities(r worker.ActivityRegistry, activities SimpleActivities)

RegisterSimpleActivities registers activities with a worker

func RegisterSimpleWorkflows added in v1.0.0 

func RegisterSimpleWorkflows(r worker.WorkflowRegistry, workflows SimpleWorkflows)

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

func RegisterSomeActivity1Activity added in v0.4.0 

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

RegisterSomeActivity1Activity registers a mycompany.simple.SomeActivity1 activity

func RegisterSomeActivity2Activity added in v0.4.0 

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

RegisterSomeActivity2Activity registers a mycompany.simple.Simple.SomeActivity2 activity

func RegisterSomeActivity3Activity added in v0.4.0 

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

RegisterSomeActivity3Activity registers a mycompany.simple.Simple.SomeActivity3 activity

func RegisterSomeDeprecatedActivity1Activity added in v1.9.0 

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

RegisterSomeDeprecatedActivity1Activity registers a mycompany.simple.Deprecated.SomeDeprecatedActivity1 activity

func RegisterSomeDeprecatedActivity2Activity added in v1.9.0 

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

RegisterSomeDeprecatedActivity2Activity registers a mycompany.simple.Deprecated.SomeDeprecatedActivity2 activity

func RegisterSomeDeprecatedWorkflow1Workflow added in v1.9.0 

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

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

func RegisterSomeDeprecatedWorkflow2Workflow added in v1.9.0 

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

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

func RegisterSomeSignal1Activity added in v1.1.0 

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

RegisterSomeSignal1Activity registers a mycompany.simple.Simple.SomeSignal1 activity

func RegisterSomeSignal2Activity added in v1.1.0 

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

RegisterSomeSignal2Activity registers a mycompany.simple.Simple.SomeSignal2 activity

func RegisterSomeSignal3Activity added in v1.1.0 

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

RegisterSomeSignal3Activity registers a mycompany.simple.Simple.SomeSignal3 activity

func RegisterSomeUpdate1Activity added in v1.1.0 

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

RegisterSomeUpdate1Activity registers a mycompany.simple.Simple.SomeUpdate1 activity

func RegisterSomeWorkflow1Workflow added in v0.4.0 

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 added in v0.4.0 

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 added in v0.4.0 

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 added in v1.2.0 

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 added in v1.9.0 

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

SomeDeprecatedSignal1 does something else

Deprecated: Do not use.

func SomeDeprecatedSignal1ExternalAsync deprecated added in v1.9.0 

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

SomeDeprecatedSignal1 does something else

Deprecated: Do not use.

func SomeDeprecatedSignal2External deprecated added in v1.9.0 

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 added in v1.9.0 

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 added in v1.0.0 

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

SomeSignal1 is a signal.

func SomeSignal1Local added in v1.1.0 

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 added in v1.0.0 

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

SomeSignal2 is a signal.

func SomeSignal2Local added in v1.1.0 

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

SomeSignal2 is a signal.

func SomeSignal3External added in v1.1.0 

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

SomeSignal3 is a signal.

func SomeSignal3ExternalAsync added in v1.1.0 

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 added in v1.2.0 

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 added in v1.9.0 

func WithDeprecatedSchemeTypes() scheme.Option

WithDeprecatedSchemeTypes registers all Deprecated protobuf types with the given scheme

func WithIgnoredSchemeTypes added in v1.7.0 

func WithIgnoredSchemeTypes() scheme.Option

WithIgnoredSchemeTypes registers all Ignored protobuf types with the given scheme

func WithOnlyActivitiesSchemeTypes added in v1.8.2 

func WithOnlyActivitiesSchemeTypes() scheme.Option

WithOnlyActivitiesSchemeTypes registers all OnlyActivities protobuf types with the given scheme

func WithOtherSchemeTypes added in v1.7.0 

func WithOtherSchemeTypes() scheme.Option

WithOtherSchemeTypes registers all Other protobuf types with the given scheme

func WithSimpleSchemeTypes added in v1.7.0 

func WithSimpleSchemeTypes() scheme.Option

WithSimpleSchemeTypes registers all Simple protobuf types with the given scheme

Types

type DeprecatedActivities added in v1.9.0 

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 added in v1.9.0 

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

DeprecatedCliOptions describes runtime configuration for mycompany.simple.Deprecated cli

func NewDeprecatedCliOptions added in v1.9.0 

func NewDeprecatedCliOptions() *DeprecatedCliOptions

NewDeprecatedCliOptions initializes a new DeprecatedCliOptions value

func (*DeprecatedCliOptions) WithAfter added in v1.9.0 

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 added in v1.9.0 

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 added in v1.9.0 

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 added in v1.9.0 

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

WithWorker provides an method for initializing a worker

type DeprecatedClient added in v1.9.0 

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 added in v1.9.0 

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

NewDeprecatedClient initializes a new mycompany.simple.Deprecated client

func NewDeprecatedClientWithOptions added in v1.9.0 

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

NewDeprecatedClientWithOptions initializes a new Deprecated client with the given options

type DeprecatedWorkflows added in v1.9.0 

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 added in v1.2.0 

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

func (*Foo) Descriptor deprecated added in v1.2.0 

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

Deprecated: Use Foo.ProtoReflect.Descriptor instead.

func (*Foo) GetFoo added in v1.2.0 

func (x *Foo) GetFoo() string

func (*Foo) ProtoMessage added in v1.2.0 

func (*Foo) ProtoMessage()

func (*Foo) ProtoReflect added in v1.2.0 

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

func (*Foo) Reset added in v1.2.0 

func (x *Foo) Reset()

func (*Foo) String added in v1.2.0 

func (x *Foo) String() string

type IgnoredActivities added in v1.2.0 

type IgnoredActivities interface{}

IgnoredActivities describes available worker activities

type IgnoredClient added in v1.2.0 

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 added in v1.2.0 

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

NewIgnoredClient initializes a new mycompany.simple.Ignored client

func NewIgnoredClientWithOptions added in v1.2.0 

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

NewIgnoredClientWithOptions initializes a new Ignored client with the given options

type IgnoredWorkflows added in v1.2.0 

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 added in v1.8.2 

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

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

func NewLonelyActivity1ActivityOptions added in v1.8.2 

func NewLonelyActivity1ActivityOptions() *LonelyActivity1ActivityOptions

NewLonelyActivity1ActivityOptions sets default ActivityOptions

func (*LonelyActivity1ActivityOptions) WithActivityOptions added in v1.8.2 

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

WithActivityOptions sets default ActivityOptions

type LonelyActivity1Future added in v1.8.2 

type LonelyActivity1Future struct {
	Future workflow.Future
}

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

func LonelyActivity1Async added in v1.8.2 

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

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

func LonelyActivity1LocalAsync added in v1.8.2 

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

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

func (*LonelyActivity1Future) Get added in v1.8.2 

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

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

func (*LonelyActivity1Future) Select added in v1.8.2 

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

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

type LonelyActivity1LocalActivityOptions added in v1.8.2 

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

LonelyActivity1LocalActivityOptions provides configuration for a local mycompany.simple.OnlyActivities.LonelyActivity1 activity

func NewLonelyActivity1LocalActivityOptions added in v1.8.2 

func NewLonelyActivity1LocalActivityOptions() *LonelyActivity1LocalActivityOptions

NewLonelyActivity1LocalActivityOptions sets default LocalActivityOptions

func (*LonelyActivity1LocalActivityOptions) Local added in v1.8.2 

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

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

func (*LonelyActivity1LocalActivityOptions) WithLocalActivityOptions added in v1.8.2 

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

WithLocalActivityOptions sets default LocalActivityOptions

type LonelyActivity1Request added in v1.8.2 

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

func (*LonelyActivity1Request) Descriptor deprecated added in v1.8.2 

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

Deprecated: Use LonelyActivity1Request.ProtoReflect.Descriptor instead.

func (*LonelyActivity1Request) ProtoMessage added in v1.8.2 

func (*LonelyActivity1Request) ProtoMessage()

func (*LonelyActivity1Request) ProtoReflect added in v1.8.2 

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

func (*LonelyActivity1Request) Reset added in v1.8.2 

func (x *LonelyActivity1Request) Reset()

func (*LonelyActivity1Request) String added in v1.8.2 

func (x *LonelyActivity1Request) String() string

type LonelyActivity1Response added in v1.8.2 

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

func LonelyActivity1 added in v1.8.2 

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

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

func LonelyActivity1Local added in v1.8.2 

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

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

func (*LonelyActivity1Response) Descriptor deprecated added in v1.8.2 

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

Deprecated: Use LonelyActivity1Response.ProtoReflect.Descriptor instead.

func (*LonelyActivity1Response) ProtoMessage added in v1.8.2 

func (*LonelyActivity1Response) ProtoMessage()

func (*LonelyActivity1Response) ProtoReflect added in v1.8.2 

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

func (*LonelyActivity1Response) Reset added in v1.8.2 

func (x *LonelyActivity1Response) Reset()

func (*LonelyActivity1Response) String added in v1.8.2 

func (x *LonelyActivity1Response) String() string

type OnlyActivitiesActivities added in v1.8.2 

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 added in v1.8.2 

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

OnlyActivitiesCliOptions describes runtime configuration for mycompany.simple.OnlyActivities cli

func NewOnlyActivitiesCliOptions added in v1.8.2 

func NewOnlyActivitiesCliOptions() *OnlyActivitiesCliOptions

NewOnlyActivitiesCliOptions initializes a new OnlyActivitiesCliOptions value

func (*OnlyActivitiesCliOptions) WithAfter added in v1.8.2 

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

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

func (*OnlyActivitiesCliOptions) WithBefore added in v1.8.2 

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 added in v1.8.2 

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

WithClient provides a Temporal client factory for use by commands

func (*OnlyActivitiesCliOptions) WithWorker added in v1.8.2 

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

WithWorker provides an method for initializing a worker

type OnlyActivitiesClient added in v1.8.2 

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 added in v1.8.2 

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

NewOnlyActivitiesClient initializes a new mycompany.simple.OnlyActivities client

func NewOnlyActivitiesClientWithOptions added in v1.8.2 

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

NewOnlyActivitiesClientWithOptions initializes a new OnlyActivities client with the given options

type OnlyActivitiesWorkflows added in v1.8.2 

type OnlyActivitiesWorkflows interface{}

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

type OtherActivities added in v1.0.0 

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 added in v1.0.0 

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

OtherCliOptions describes runtime configuration for mycompany.simple.Other cli

func NewOtherCliOptions added in v1.0.0 

func NewOtherCliOptions() *OtherCliOptions

NewOtherCliOptions initializes a new OtherCliOptions value

func (*OtherCliOptions) WithAfter added in v1.0.0 

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 added in v1.0.0 

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 added in v1.0.0 

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 added in v1.0.0 

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

WithWorker provides an method for initializing a worker

type OtherClient added in v1.0.0 

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 added in v1.0.0 

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

NewOtherClient initializes a new mycompany.simple.Other client

func NewOtherClientWithOptions added in v1.0.0 

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

NewOtherClientWithOptions initializes a new Other client with the given options

type OtherEnum added in v1.7.0 

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

func (OtherEnum) Descriptor added in v1.7.0 

func (OtherEnum) Descriptor() protoreflect.EnumDescriptor

func (OtherEnum) Enum added in v1.7.0 

func (x OtherEnum) Enum() *OtherEnum

func (OtherEnum) EnumDescriptor deprecated added in v1.7.0 

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

Deprecated: Use OtherEnum.Descriptor instead.

func (OtherEnum) Number added in v1.7.0 

func (x OtherEnum) Number() protoreflect.EnumNumber

func (OtherEnum) String added in v1.7.0 

func (x OtherEnum) String() string

func (OtherEnum) Type added in v1.7.0 

func (OtherEnum) Type() protoreflect.EnumType

type OtherQueryResponse added in v1.0.0 

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

func (*OtherQueryResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use OtherQueryResponse.ProtoReflect.Descriptor instead.

func (*OtherQueryResponse) GetFilter added in v1.0.0 

func (x *OtherQueryResponse) GetFilter() string

func (*OtherQueryResponse) ProtoMessage added in v1.0.0 

func (*OtherQueryResponse) ProtoMessage()

func (*OtherQueryResponse) ProtoReflect added in v1.0.0 

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

func (*OtherQueryResponse) Reset added in v1.0.0 

func (x *OtherQueryResponse) Reset()

func (*OtherQueryResponse) String added in v1.0.0 

func (x *OtherQueryResponse) String() string

type OtherSignalRequest added in v1.0.0 

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

func (*OtherSignalRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use OtherSignalRequest.ProtoReflect.Descriptor instead.

func (*OtherSignalRequest) GetType added in v1.0.0 

func (x *OtherSignalRequest) GetType() string

func (*OtherSignalRequest) ProtoMessage added in v1.0.0 

func (*OtherSignalRequest) ProtoMessage()

func (*OtherSignalRequest) ProtoReflect added in v1.0.0 

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

func (*OtherSignalRequest) Reset added in v1.0.0 

func (x *OtherSignalRequest) Reset()

func (*OtherSignalRequest) String added in v1.0.0 

func (x *OtherSignalRequest) String() string

type OtherSignalSignal added in v1.0.0 

type OtherSignalSignal struct {
	Channel workflow.ReceiveChannel
}

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

func NewOtherSignalSignal added in v1.10.2 

func NewOtherSignalSignal(ctx workflow.Context) *OtherSignalSignal

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

func (*OtherSignalSignal) Receive added in v1.0.0 

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

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

func (*OtherSignalSignal) ReceiveAsync added in v1.0.0 

func (s *OtherSignalSignal) ReceiveAsync() *OtherSignalRequest

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

func (*OtherSignalSignal) ReceiveWithTimeout added in v1.6.0 

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 added in v1.0.0 

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

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

type OtherUpdateHandle added in v1.0.0 

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 added in v1.0.0 

type OtherUpdateOptions struct {
	Options *client.UpdateWorkflowWithOptionsRequest
}

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

func NewOtherUpdateOptions added in v1.0.0 

func NewOtherUpdateOptions() *OtherUpdateOptions

NewOtherUpdateOptions initializes a new OtherUpdateOptions value

func (*OtherUpdateOptions) WithUpdateWorkflowOptions added in v1.0.0 

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

WithUpdateWorkflowOptions sets the initial client.UpdateWorkflowWithOptionsRequest

type OtherUpdateRequest added in v1.0.0 

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

func UnmarshalCliFlagsToOtherUpdateRequest added in v1.2.0 

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

UnmarshalCliFlagsToOtherUpdateRequest unmarshals a OtherUpdateRequest from command line flags

func (*OtherUpdateRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use OtherUpdateRequest.ProtoReflect.Descriptor instead.

func (*OtherUpdateRequest) GetMode added in v1.0.0 

func (x *OtherUpdateRequest) GetMode() string

func (*OtherUpdateRequest) ProtoMessage added in v1.0.0 

func (*OtherUpdateRequest) ProtoMessage()

func (*OtherUpdateRequest) ProtoReflect added in v1.0.0 

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

func (*OtherUpdateRequest) Reset added in v1.0.0 

func (x *OtherUpdateRequest) Reset()

func (*OtherUpdateRequest) String added in v1.0.0 

func (x *OtherUpdateRequest) String() string

type OtherUpdateResponse added in v1.0.0 

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

func (*OtherUpdateResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use OtherUpdateResponse.ProtoReflect.Descriptor instead.

func (*OtherUpdateResponse) ProtoMessage added in v1.0.0 

func (*OtherUpdateResponse) ProtoMessage()

func (*OtherUpdateResponse) ProtoReflect added in v1.0.0 

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

func (*OtherUpdateResponse) Reset added in v1.0.0 

func (x *OtherUpdateResponse) Reset()

func (*OtherUpdateResponse) String added in v1.0.0 

func (x *OtherUpdateResponse) String() string

type OtherWorkflowActivityOptions added in v1.0.0 

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

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

func NewOtherWorkflowActivityOptions added in v1.0.0 

func NewOtherWorkflowActivityOptions() *OtherWorkflowActivityOptions

NewOtherWorkflowActivityOptions sets default ActivityOptions

func (*OtherWorkflowActivityOptions) WithActivityOptions added in v1.0.0 

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

WithActivityOptions sets default ActivityOptions

type OtherWorkflowChildOptions added in v1.0.0 

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

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

func NewOtherWorkflowChildOptions added in v1.0.0 

func NewOtherWorkflowChildOptions() *OtherWorkflowChildOptions

NewOtherWorkflowChildOptions initializes a new OtherWorkflowChildOptions value

func (*OtherWorkflowChildOptions) WithChildWorkflowOptions added in v1.0.0 

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

WithChildWorkflowOptions sets the initial client.StartWorkflowOptions

type OtherWorkflowChildRun added in v1.0.0 

type OtherWorkflowChildRun struct {
	Future workflow.ChildWorkflowFuture
}

OtherWorkflowChildRun describes a child OtherWorkflow workflow run

func OtherWorkflowChildAsync added in v1.0.0 

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 added in v1.0.0 

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

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

func (*OtherWorkflowChildRun) Select added in v1.0.0 

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

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

func (*OtherWorkflowChildRun) SelectStart added in v1.0.0 

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

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

func (*OtherWorkflowChildRun) WaitStart added in v1.0.0 

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

WaitStart waits for the child workflow to start

type OtherWorkflowFuture added in v1.0.0 

type OtherWorkflowFuture struct {
	Future workflow.Future
}

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

func OtherWorkflowAsync added in v1.0.0 

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

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

func OtherWorkflowLocalAsync added in v1.0.0 

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

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

func (*OtherWorkflowFuture) Get added in v1.0.0 

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

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

func (*OtherWorkflowFuture) Select added in v1.0.0 

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

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

type OtherWorkflowLocalActivityOptions added in v1.0.0 

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

OtherWorkflowLocalActivityOptions provides configuration for a local mycompany.simple.Other.OtherWorkflow activity

func NewOtherWorkflowLocalActivityOptions added in v1.0.0 

func NewOtherWorkflowLocalActivityOptions() *OtherWorkflowLocalActivityOptions

NewOtherWorkflowLocalActivityOptions sets default LocalActivityOptions

func (*OtherWorkflowLocalActivityOptions) Local added in v1.0.0 

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

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

func (*OtherWorkflowLocalActivityOptions) WithLocalActivityOptions added in v1.0.0 

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

WithLocalActivityOptions sets default LocalActivityOptions

type OtherWorkflowOptions added in v1.0.0 

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

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

func NewOtherWorkflowOptions added in v1.0.0 

func NewOtherWorkflowOptions() *OtherWorkflowOptions

NewOtherWorkflowOptions initializes a new OtherWorkflowOptions value

func (*OtherWorkflowOptions) WithStartWorkflowOptions added in v1.0.0 

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

WithStartWorkflowOptions sets the initial client.StartWorkflowOptions

type OtherWorkflowRequest added in v1.0.0 

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 added in v1.2.0 

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

UnmarshalCliFlagsToOtherWorkflowRequest unmarshals a OtherWorkflowRequest from command line flags

func (*OtherWorkflowRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use OtherWorkflowRequest.ProtoReflect.Descriptor instead.

func (*OtherWorkflowRequest) GetBar added in v1.2.0 

func (x *OtherWorkflowRequest) GetBar() *OtherWorkflowRequest_Bar

func (*OtherWorkflowRequest) GetBaz added in v1.2.0 

func (x *OtherWorkflowRequest) GetBaz() *OtherWorkflowRequest_Baz

func (*OtherWorkflowRequest) GetExampleBool added in v1.2.0 

func (x *OtherWorkflowRequest) GetExampleBool() bool

func (*OtherWorkflowRequest) GetExampleBytes added in v1.2.0 

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

func (*OtherWorkflowRequest) GetExampleDouble added in v1.2.0 

func (x *OtherWorkflowRequest) GetExampleDouble() float64

func (*OtherWorkflowRequest) GetExampleDuration added in v1.2.0 

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

func (*OtherWorkflowRequest) GetExampleEmpty added in v1.2.0 

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

func (*OtherWorkflowRequest) GetExampleEnum added in v1.7.0 

func (x *OtherWorkflowRequest) GetExampleEnum() OtherEnum

func (*OtherWorkflowRequest) GetExampleFixed32 added in v1.2.0 

func (x *OtherWorkflowRequest) GetExampleFixed32() uint32

func (*OtherWorkflowRequest) GetExampleFixed64 added in v1.2.0 

func (x *OtherWorkflowRequest) GetExampleFixed64() uint64

func (*OtherWorkflowRequest) GetExampleFloat added in v1.2.0 

func (x *OtherWorkflowRequest) GetExampleFloat() float32

func (*OtherWorkflowRequest) GetExampleInt32 added in v1.2.0 

func (x *OtherWorkflowRequest) GetExampleInt32() int32

func (*OtherWorkflowRequest) GetExampleInt64 added in v1.2.0 

func (x *OtherWorkflowRequest) GetExampleInt64() int64

func (*OtherWorkflowRequest) GetExampleOneof added in v1.2.0 

func (m *OtherWorkflowRequest) GetExampleOneof() isOtherWorkflowRequest_ExampleOneof

func (*OtherWorkflowRequest) GetExampleSfixed32 added in v1.2.0 

func (x *OtherWorkflowRequest) GetExampleSfixed32() int32

func (*OtherWorkflowRequest) GetExampleSfixed64 added in v1.2.0 

func (x *OtherWorkflowRequest) GetExampleSfixed64() int64

func (*OtherWorkflowRequest) GetExampleSint32 added in v1.2.0 

func (x *OtherWorkflowRequest) GetExampleSint32() int32

func (*OtherWorkflowRequest) GetExampleSint64 added in v1.2.0 

func (x *OtherWorkflowRequest) GetExampleSint64() int64

func (*OtherWorkflowRequest) GetExampleTimestamp added in v1.2.0 

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

func (*OtherWorkflowRequest) GetExampleUint32 added in v1.2.0 

func (x *OtherWorkflowRequest) GetExampleUint32() uint32

func (*OtherWorkflowRequest) GetExampleUint64 added in v1.2.0 

func (x *OtherWorkflowRequest) GetExampleUint64() uint64

func (*OtherWorkflowRequest) GetFoo added in v1.2.0 

func (x *OtherWorkflowRequest) GetFoo() *Foo

func (*OtherWorkflowRequest) GetQuux added in v1.2.0 

func (x *OtherWorkflowRequest) GetQuux() string

func (*OtherWorkflowRequest) GetQux added in v1.2.0 

func (x *OtherWorkflowRequest) GetQux() *Qux

func (*OtherWorkflowRequest) GetSomeVal added in v1.0.0 

func (x *OtherWorkflowRequest) GetSomeVal() string

func (*OtherWorkflowRequest) ProtoMessage added in v1.0.0 

func (*OtherWorkflowRequest) ProtoMessage()

func (*OtherWorkflowRequest) ProtoReflect added in v1.0.0 

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

func (*OtherWorkflowRequest) Reset added in v1.0.0 

func (x *OtherWorkflowRequest) Reset()

func (*OtherWorkflowRequest) String added in v1.0.0 

func (x *OtherWorkflowRequest) String() string

type OtherWorkflowRequest_Bar added in v1.2.0 

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 added in v1.2.0 

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

Deprecated: Use OtherWorkflowRequest_Bar.ProtoReflect.Descriptor instead.

func (*OtherWorkflowRequest_Bar) GetBar added in v1.2.0 

func (x *OtherWorkflowRequest_Bar) GetBar() string

func (*OtherWorkflowRequest_Bar) ProtoMessage added in v1.2.0 

func (*OtherWorkflowRequest_Bar) ProtoMessage()

func (*OtherWorkflowRequest_Bar) ProtoReflect added in v1.2.0 

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

func (*OtherWorkflowRequest_Bar) Reset added in v1.2.0 

func (x *OtherWorkflowRequest_Bar) Reset()

func (*OtherWorkflowRequest_Bar) String added in v1.2.0 

func (x *OtherWorkflowRequest_Bar) String() string

type OtherWorkflowRequest_Bar_ added in v1.2.0 

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

type OtherWorkflowRequest_Baz added in v1.2.0 

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 added in v1.2.0 

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

Deprecated: Use OtherWorkflowRequest_Baz.ProtoReflect.Descriptor instead.

func (*OtherWorkflowRequest_Baz) GetBaz added in v1.2.0 

func (x *OtherWorkflowRequest_Baz) GetBaz() string

func (*OtherWorkflowRequest_Baz) ProtoMessage added in v1.2.0 

func (*OtherWorkflowRequest_Baz) ProtoMessage()

func (*OtherWorkflowRequest_Baz) ProtoReflect added in v1.2.0 

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

func (*OtherWorkflowRequest_Baz) Reset added in v1.2.0 

func (x *OtherWorkflowRequest_Baz) Reset()

func (*OtherWorkflowRequest_Baz) String added in v1.2.0 

func (x *OtherWorkflowRequest_Baz) String() string

type OtherWorkflowRequest_ExampleBool added in v1.2.0 

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

type OtherWorkflowRequest_ExampleBytes added in v1.2.0 

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

type OtherWorkflowRequest_ExampleDouble added in v1.2.0 

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

type OtherWorkflowRequest_ExampleDuration added in v1.2.0 

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

type OtherWorkflowRequest_ExampleEmpty added in v1.2.0 

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

type OtherWorkflowRequest_ExampleEnum added in v1.7.0 

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

type OtherWorkflowRequest_ExampleFixed32 added in v1.2.0 

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

type OtherWorkflowRequest_ExampleFixed64 added in v1.2.0 

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

type OtherWorkflowRequest_ExampleFloat added in v1.2.0 

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

type OtherWorkflowRequest_ExampleInt32 added in v1.2.0 

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

type OtherWorkflowRequest_ExampleInt64 added in v1.2.0 

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

type OtherWorkflowRequest_ExampleSfixed32 added in v1.2.0 

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

type OtherWorkflowRequest_ExampleSfixed64 added in v1.2.0 

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

type OtherWorkflowRequest_ExampleSint32 added in v1.2.0 

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

type OtherWorkflowRequest_ExampleSint64 added in v1.2.0 

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

type OtherWorkflowRequest_ExampleTimestamp added in v1.2.0 

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

type OtherWorkflowRequest_ExampleUint32 added in v1.2.0 

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

type OtherWorkflowRequest_ExampleUint64 added in v1.2.0 

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

type OtherWorkflowRequest_Foo added in v1.2.0 

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

type OtherWorkflowRequest_Quux added in v1.2.0 

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

type OtherWorkflowResponse added in v1.0.0 

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

func OtherWorkflow added in v1.0.0 

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

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

func OtherWorkflowChild added in v1.0.0 

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 added in v1.0.0 

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

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

func (*OtherWorkflowResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use OtherWorkflowResponse.ProtoReflect.Descriptor instead.

func (*OtherWorkflowResponse) ProtoMessage added in v1.0.0 

func (*OtherWorkflowResponse) ProtoMessage()

func (*OtherWorkflowResponse) ProtoReflect added in v1.0.0 

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

func (*OtherWorkflowResponse) Reset added in v1.0.0 

func (x *OtherWorkflowResponse) Reset()

func (*OtherWorkflowResponse) String added in v1.0.0 

func (x *OtherWorkflowResponse) String() string

type OtherWorkflowRun added in v1.0.0 

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 added in v1.0.0 

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 added in v1.3.0 

type OtherWorkflowWorkflowInput struct {
	Req *OtherWorkflowRequest
}

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

type OtherWorkflows added in v1.0.0 

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 added in v1.2.0 

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

func (*Qux) Descriptor deprecated added in v1.2.0 

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

Deprecated: Use Qux.ProtoReflect.Descriptor instead.

func (*Qux) GetQux added in v1.2.0 

func (x *Qux) GetQux() string

func (*Qux) ProtoMessage added in v1.2.0 

func (*Qux) ProtoMessage()

func (*Qux) ProtoReflect added in v1.2.0 

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

func (*Qux) Reset added in v1.2.0 

func (x *Qux) Reset()

func (*Qux) String added in v1.2.0 

func (x *Qux) String() string

type SimpleActivities added in v1.0.0 

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 added in v1.0.0 

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

SimpleCliOptions describes runtime configuration for mycompany.simple.Simple cli

func NewSimpleCliOptions added in v1.0.0 

func NewSimpleCliOptions() *SimpleCliOptions

NewSimpleCliOptions initializes a new SimpleCliOptions value

func (*SimpleCliOptions) WithAfter added in v1.0.0 

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 added in v1.0.0 

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 added in v1.0.0 

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 added in v1.0.0 

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

WithWorker provides an method for initializing a worker

type SimpleClient added in v1.0.0 

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 added in v1.0.0 

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

NewSimpleClient initializes a new mycompany.simple.Simple client

func NewSimpleClientWithOptions added in v1.0.0 

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

NewSimpleClientWithOptions initializes a new Simple client with the given options

type SimpleWorkflows added in v1.0.0 

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 added in v1.0.0 

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

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

func NewSomeActivity1ActivityOptions added in v1.0.0 

func NewSomeActivity1ActivityOptions() *SomeActivity1ActivityOptions

NewSomeActivity1ActivityOptions sets default ActivityOptions

func (*SomeActivity1ActivityOptions) WithActivityOptions added in v1.0.0 

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

WithActivityOptions sets default ActivityOptions

type SomeActivity1Future 

type SomeActivity1Future struct {
	Future workflow.Future
}

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

func SomeActivity1Async added in v1.0.0 

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

SomeActivity1 does some activity thing.

func SomeActivity1LocalAsync added in v1.0.0 

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

SomeActivity1 does some activity thing.

func (*SomeActivity1Future) Get 

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

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

func (*SomeActivity1Future) Select 

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

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

type SomeActivity1LocalActivityOptions added in v1.0.0 

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

SomeActivity1LocalActivityOptions provides configuration for a local mycompany.simple.SomeActivity1 activity

func NewSomeActivity1LocalActivityOptions added in v1.0.0 

func NewSomeActivity1LocalActivityOptions() *SomeActivity1LocalActivityOptions

NewSomeActivity1LocalActivityOptions sets default LocalActivityOptions

func (*SomeActivity1LocalActivityOptions) Local added in v1.0.0 

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

Local provides a local mycompany.simple.SomeActivity1 activity implementation

func (*SomeActivity1LocalActivityOptions) WithLocalActivityOptions added in v1.0.0 

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

WithLocalActivityOptions sets default LocalActivityOptions

type SomeActivity2ActivityOptions added in v1.0.0 

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

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

func NewSomeActivity2ActivityOptions added in v1.0.0 

func NewSomeActivity2ActivityOptions() *SomeActivity2ActivityOptions

NewSomeActivity2ActivityOptions sets default ActivityOptions

func (*SomeActivity2ActivityOptions) WithActivityOptions added in v1.0.0 

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

WithActivityOptions sets default ActivityOptions

type SomeActivity2Future 

type SomeActivity2Future struct {
	Future workflow.Future
}

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

func SomeActivity2Async added in v1.0.0 

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

SomeActivity2 does some activity thing.

func SomeActivity2LocalAsync added in v1.0.0 

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

SomeActivity2 does some activity thing.

func (*SomeActivity2Future) Get 

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

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

func (*SomeActivity2Future) Select 

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

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

type SomeActivity2LocalActivityOptions added in v1.0.0 

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

SomeActivity2LocalActivityOptions provides configuration for a local mycompany.simple.Simple.SomeActivity2 activity

func NewSomeActivity2LocalActivityOptions added in v1.0.0 

func NewSomeActivity2LocalActivityOptions() *SomeActivity2LocalActivityOptions

NewSomeActivity2LocalActivityOptions sets default LocalActivityOptions

func (*SomeActivity2LocalActivityOptions) Local added in v1.0.0 

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

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

func (*SomeActivity2LocalActivityOptions) WithLocalActivityOptions added in v1.0.0 

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

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 added in v1.0.0 

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

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

func NewSomeActivity3ActivityOptions added in v1.0.0 

func NewSomeActivity3ActivityOptions() *SomeActivity3ActivityOptions

NewSomeActivity3ActivityOptions sets default ActivityOptions

func (*SomeActivity3ActivityOptions) WithActivityOptions added in v1.0.0 

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

WithActivityOptions sets default ActivityOptions

type SomeActivity3Future 

type SomeActivity3Future struct {
	Future workflow.Future
}

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

func SomeActivity3Async added in v1.0.0 

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

SomeActivity3 does some activity thing.

func SomeActivity3LocalAsync added in v1.0.0 

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

SomeActivity3 does some activity thing.

func (*SomeActivity3Future) Get 

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

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

func (*SomeActivity3Future) Select 

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

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

type SomeActivity3LocalActivityOptions added in v1.0.0 

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

SomeActivity3LocalActivityOptions provides configuration for a local mycompany.simple.Simple.SomeActivity3 activity

func NewSomeActivity3LocalActivityOptions added in v1.0.0 

func NewSomeActivity3LocalActivityOptions() *SomeActivity3LocalActivityOptions

NewSomeActivity3LocalActivityOptions sets default LocalActivityOptions

func (*SomeActivity3LocalActivityOptions) Local added in v1.0.0 

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

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

func (*SomeActivity3LocalActivityOptions) WithLocalActivityOptions added in v1.0.0 

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

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 

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

SomeActivity3 does some activity thing.

func SomeActivity3Local 

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

SomeActivity3 does some activity thing.

func (*SomeActivity3Response) Descriptor deprecated 

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

Deprecated: Use SomeActivity3Response.ProtoReflect.Descriptor instead.

func (*SomeActivity3Response) GetResponseVal 

func (x *SomeActivity3Response) GetResponseVal() string

func (*SomeActivity3Response) ProtoMessage 

func (*SomeActivity3Response) ProtoMessage()

func (*SomeActivity3Response) ProtoReflect 

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

func (*SomeActivity3Response) Reset 

func (x *SomeActivity3Response) Reset()

func (*SomeActivity3Response) String 

func (x *SomeActivity3Response) String() string

type SomeDeprecatedActivity1ActivityOptions added in v1.9.0 

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

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

func NewSomeDeprecatedActivity1ActivityOptions added in v1.9.0 

func NewSomeDeprecatedActivity1ActivityOptions() *SomeDeprecatedActivity1ActivityOptions

NewSomeDeprecatedActivity1ActivityOptions sets default ActivityOptions

func (*SomeDeprecatedActivity1ActivityOptions) WithActivityOptions added in v1.9.0 

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

WithActivityOptions sets default ActivityOptions

type SomeDeprecatedActivity1Future added in v1.9.0 

type SomeDeprecatedActivity1Future struct {
	Future workflow.Future
}

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

func SomeDeprecatedActivity1Async deprecated added in v1.9.0 

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

SomeDeprecatedActivity1 does something

Deprecated: Do not use.

func SomeDeprecatedActivity1LocalAsync deprecated added in v1.9.0 

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

SomeDeprecatedActivity1 does something

Deprecated: Do not use.

func (*SomeDeprecatedActivity1Future) Get added in v1.9.0 

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

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

func (*SomeDeprecatedActivity1Future) Select added in v1.9.0 

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

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

type SomeDeprecatedActivity1LocalActivityOptions added in v1.9.0 

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

SomeDeprecatedActivity1LocalActivityOptions provides configuration for a local mycompany.simple.Deprecated.SomeDeprecatedActivity1 activity

func NewSomeDeprecatedActivity1LocalActivityOptions added in v1.9.0 

func NewSomeDeprecatedActivity1LocalActivityOptions() *SomeDeprecatedActivity1LocalActivityOptions

NewSomeDeprecatedActivity1LocalActivityOptions sets default LocalActivityOptions

func (*SomeDeprecatedActivity1LocalActivityOptions) Local added in v1.9.0 

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

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

func (*SomeDeprecatedActivity1LocalActivityOptions) WithLocalActivityOptions added in v1.9.0 

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

WithLocalActivityOptions sets default LocalActivityOptions

type SomeDeprecatedActivity2ActivityOptions added in v1.9.0 

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

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

func NewSomeDeprecatedActivity2ActivityOptions added in v1.9.0 

func NewSomeDeprecatedActivity2ActivityOptions() *SomeDeprecatedActivity2ActivityOptions

NewSomeDeprecatedActivity2ActivityOptions sets default ActivityOptions

func (*SomeDeprecatedActivity2ActivityOptions) WithActivityOptions added in v1.9.0 

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

WithActivityOptions sets default ActivityOptions

type SomeDeprecatedActivity2Future added in v1.9.0 

type SomeDeprecatedActivity2Future struct {
	Future workflow.Future
}

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

func SomeDeprecatedActivity2Async deprecated added in v1.9.0 

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

SomeDeprecatedActivity2 does something else

Deprecated: a custom activity deprecation message.

func SomeDeprecatedActivity2LocalAsync deprecated added in v1.9.0 

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

SomeDeprecatedActivity2 does something else

Deprecated: a custom activity deprecation message.

func (*SomeDeprecatedActivity2Future) Get added in v1.9.0 

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

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

func (*SomeDeprecatedActivity2Future) Select added in v1.9.0 

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

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

type SomeDeprecatedActivity2LocalActivityOptions added in v1.9.0 

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

SomeDeprecatedActivity2LocalActivityOptions provides configuration for a local mycompany.simple.Deprecated.SomeDeprecatedActivity2 activity

func NewSomeDeprecatedActivity2LocalActivityOptions added in v1.9.0 

func NewSomeDeprecatedActivity2LocalActivityOptions() *SomeDeprecatedActivity2LocalActivityOptions

NewSomeDeprecatedActivity2LocalActivityOptions sets default LocalActivityOptions

func (*SomeDeprecatedActivity2LocalActivityOptions) Local added in v1.9.0 

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

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

func (*SomeDeprecatedActivity2LocalActivityOptions) WithLocalActivityOptions added in v1.9.0 

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

WithLocalActivityOptions sets default LocalActivityOptions

type SomeDeprecatedMessage added in v1.9.0 

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

func SomeDeprecatedActivity1 deprecated added in v1.9.0 

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

SomeDeprecatedActivity1 does something

Deprecated: Do not use.

func SomeDeprecatedActivity1Local deprecated added in v1.9.0 

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

SomeDeprecatedActivity1 does something

Deprecated: Do not use.

func SomeDeprecatedActivity2 deprecated added in v1.9.0 

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

SomeDeprecatedActivity2 does something else

Deprecated: a custom activity deprecation message.

func SomeDeprecatedActivity2Local deprecated added in v1.9.0 

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

SomeDeprecatedActivity2 does something else

Deprecated: a custom activity deprecation message.

func SomeDeprecatedWorkflow1Child deprecated added in v1.9.0 

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

SomeDeprecatedWorkflow1 does something

Deprecated: Do not use.

func SomeDeprecatedWorkflow2Child deprecated added in v1.9.0 

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

SomeDeprecatedWorkflow2 does something else

Deprecated: a custom workflow deprecation message.

func UnmarshalCliFlagsToSomeDeprecatedMessage added in v1.9.0 

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

UnmarshalCliFlagsToSomeDeprecatedMessage unmarshals a SomeDeprecatedMessage from command line flags

func (*SomeDeprecatedMessage) Descriptor deprecated added in v1.9.0 

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

Deprecated: Use SomeDeprecatedMessage.ProtoReflect.Descriptor instead.

func (*SomeDeprecatedMessage) ProtoMessage added in v1.9.0 

func (*SomeDeprecatedMessage) ProtoMessage()

func (*SomeDeprecatedMessage) ProtoReflect added in v1.9.0 

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

func (*SomeDeprecatedMessage) Reset added in v1.9.0 

func (x *SomeDeprecatedMessage) Reset()

func (*SomeDeprecatedMessage) String added in v1.9.0 

func (x *SomeDeprecatedMessage) String() string

type SomeDeprecatedSignal1Signal added in v1.9.0 

type SomeDeprecatedSignal1Signal struct {
	Channel workflow.ReceiveChannel
}

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

func NewSomeDeprecatedSignal1Signal added in v1.10.2 

func NewSomeDeprecatedSignal1Signal(ctx workflow.Context) *SomeDeprecatedSignal1Signal

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

func (*SomeDeprecatedSignal1Signal) Receive added in v1.9.0 

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

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

func (*SomeDeprecatedSignal1Signal) ReceiveAsync added in v1.9.0 

func (s *SomeDeprecatedSignal1Signal) ReceiveAsync() *SomeDeprecatedMessage

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

func (*SomeDeprecatedSignal1Signal) ReceiveWithTimeout added in v1.9.0 

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 added in v1.9.0 

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

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

type SomeDeprecatedSignal2Signal added in v1.9.0 

type SomeDeprecatedSignal2Signal struct {
	Channel workflow.ReceiveChannel
}

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

func NewSomeDeprecatedSignal2Signal added in v1.10.2 

func NewSomeDeprecatedSignal2Signal(ctx workflow.Context) *SomeDeprecatedSignal2Signal

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

func (*SomeDeprecatedSignal2Signal) Receive added in v1.9.0 

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

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

func (*SomeDeprecatedSignal2Signal) ReceiveAsync added in v1.9.0 

func (s *SomeDeprecatedSignal2Signal) ReceiveAsync() *SomeDeprecatedMessage

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

func (*SomeDeprecatedSignal2Signal) ReceiveWithTimeout added in v1.9.0 

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 added in v1.9.0 

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

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

type SomeDeprecatedUpdate1Handle added in v1.9.0 

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 added in v1.9.0 

type SomeDeprecatedUpdate1Options struct {
	Options *client.UpdateWorkflowWithOptionsRequest
}

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

func NewSomeDeprecatedUpdate1Options added in v1.9.0 

func NewSomeDeprecatedUpdate1Options() *SomeDeprecatedUpdate1Options

NewSomeDeprecatedUpdate1Options initializes a new SomeDeprecatedUpdate1Options value

func (*SomeDeprecatedUpdate1Options) WithUpdateWorkflowOptions added in v1.9.0 

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

WithUpdateWorkflowOptions sets the initial client.UpdateWorkflowWithOptionsRequest

type SomeDeprecatedUpdate2Handle added in v1.9.0 

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 added in v1.9.0 

type SomeDeprecatedUpdate2Options struct {
	Options *client.UpdateWorkflowWithOptionsRequest
}

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

func NewSomeDeprecatedUpdate2Options added in v1.9.0 

func NewSomeDeprecatedUpdate2Options() *SomeDeprecatedUpdate2Options

NewSomeDeprecatedUpdate2Options initializes a new SomeDeprecatedUpdate2Options value

func (*SomeDeprecatedUpdate2Options) WithUpdateWorkflowOptions added in v1.9.0 

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

WithUpdateWorkflowOptions sets the initial client.UpdateWorkflowWithOptionsRequest

type SomeDeprecatedWorkflow1ChildOptions added in v1.9.0 

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

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

func NewSomeDeprecatedWorkflow1ChildOptions added in v1.9.0 

func NewSomeDeprecatedWorkflow1ChildOptions() *SomeDeprecatedWorkflow1ChildOptions

NewSomeDeprecatedWorkflow1ChildOptions initializes a new SomeDeprecatedWorkflow1ChildOptions value

func (*SomeDeprecatedWorkflow1ChildOptions) WithChildWorkflowOptions added in v1.9.0 

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

WithChildWorkflowOptions sets the initial client.StartWorkflowOptions

type SomeDeprecatedWorkflow1ChildRun added in v1.9.0 

type SomeDeprecatedWorkflow1ChildRun struct {
	Future workflow.ChildWorkflowFuture
}

SomeDeprecatedWorkflow1ChildRun describes a child SomeDeprecatedWorkflow1 workflow run

func SomeDeprecatedWorkflow1ChildAsync deprecated added in v1.9.0 

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

SomeDeprecatedWorkflow1 does something

Deprecated: Do not use.

func (*SomeDeprecatedWorkflow1ChildRun) Get added in v1.9.0 

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

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

func (*SomeDeprecatedWorkflow1ChildRun) Select added in v1.9.0 

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

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

func (*SomeDeprecatedWorkflow1ChildRun) SelectStart added in v1.9.0 

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

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

func (*SomeDeprecatedWorkflow1ChildRun) SomeDeprecatedSignal1 added in v1.9.0 

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 added in v1.9.0 

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 added in v1.9.0 

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

WaitStart waits for the child workflow to start

type SomeDeprecatedWorkflow1Options added in v1.9.0 

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

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

func NewSomeDeprecatedWorkflow1Options added in v1.9.0 

func NewSomeDeprecatedWorkflow1Options() *SomeDeprecatedWorkflow1Options

NewSomeDeprecatedWorkflow1Options initializes a new SomeDeprecatedWorkflow1Options value

func (*SomeDeprecatedWorkflow1Options) WithStartWorkflowOptions added in v1.9.0 

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

WithStartWorkflowOptions sets the initial client.StartWorkflowOptions

type SomeDeprecatedWorkflow1Run added in v1.9.0 

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 added in v1.9.0 

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 added in v1.9.0 

type SomeDeprecatedWorkflow1WorkflowInput struct {
	Req                   *SomeDeprecatedMessage
	SomeDeprecatedSignal1 *SomeDeprecatedSignal1Signal
}

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

type SomeDeprecatedWorkflow2ChildOptions added in v1.9.0 

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

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

func NewSomeDeprecatedWorkflow2ChildOptions added in v1.9.0 

func NewSomeDeprecatedWorkflow2ChildOptions() *SomeDeprecatedWorkflow2ChildOptions

NewSomeDeprecatedWorkflow2ChildOptions initializes a new SomeDeprecatedWorkflow2ChildOptions value

func (*SomeDeprecatedWorkflow2ChildOptions) WithChildWorkflowOptions added in v1.9.0 

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

WithChildWorkflowOptions sets the initial client.StartWorkflowOptions

type SomeDeprecatedWorkflow2ChildRun added in v1.9.0 

type SomeDeprecatedWorkflow2ChildRun struct {
	Future workflow.ChildWorkflowFuture
}

SomeDeprecatedWorkflow2ChildRun describes a child SomeDeprecatedWorkflow2 workflow run

func SomeDeprecatedWorkflow2ChildAsync deprecated added in v1.9.0 

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

SomeDeprecatedWorkflow2 does something else

Deprecated: a custom workflow deprecation message.

func (*SomeDeprecatedWorkflow2ChildRun) Get added in v1.9.0 

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

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

func (*SomeDeprecatedWorkflow2ChildRun) Select added in v1.9.0 

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

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

func (*SomeDeprecatedWorkflow2ChildRun) SelectStart added in v1.9.0 

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

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

func (*SomeDeprecatedWorkflow2ChildRun) SomeDeprecatedSignal2 added in v1.9.0 

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 added in v1.9.0 

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 added in v1.9.0 

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

WaitStart waits for the child workflow to start

type SomeDeprecatedWorkflow2Options added in v1.9.0 

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

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

func NewSomeDeprecatedWorkflow2Options added in v1.9.0 

func NewSomeDeprecatedWorkflow2Options() *SomeDeprecatedWorkflow2Options

NewSomeDeprecatedWorkflow2Options initializes a new SomeDeprecatedWorkflow2Options value

func (*SomeDeprecatedWorkflow2Options) WithStartWorkflowOptions added in v1.9.0 

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

WithStartWorkflowOptions sets the initial client.StartWorkflowOptions

type SomeDeprecatedWorkflow2Run added in v1.9.0 

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 added in v1.9.0 

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 added in v1.9.0 

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 added in v1.2.0 

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 added in v1.1.0 

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

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

func NewSomeSignal1ActivityOptions added in v1.1.0 

func NewSomeSignal1ActivityOptions() *SomeSignal1ActivityOptions

NewSomeSignal1ActivityOptions sets default ActivityOptions

func (*SomeSignal1ActivityOptions) WithActivityOptions added in v1.1.0 

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

WithActivityOptions sets default ActivityOptions

type SomeSignal1Future added in v1.1.0 

type SomeSignal1Future struct {
	Future workflow.Future
}

SomeSignal1Future describes a(n) mycompany.simple.Simple.SomeSignal1 activity execution

func SomeSignal1Async added in v1.1.0 

func SomeSignal1Async(ctx workflow.Context, options ...*SomeSignal1ActivityOptions) *SomeSignal1Future

SomeSignal1 is a signal.

func SomeSignal1LocalAsync added in v1.1.0 

func SomeSignal1LocalAsync(ctx workflow.Context, options ...*SomeSignal1LocalActivityOptions) *SomeSignal1Future

SomeSignal1 is a signal.

func (*SomeSignal1Future) Get added in v1.1.0 

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

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

func (*SomeSignal1Future) Select added in v1.1.0 

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

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

type SomeSignal1LocalActivityOptions added in v1.1.0 

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

SomeSignal1LocalActivityOptions provides configuration for a local mycompany.simple.Simple.SomeSignal1 activity

func NewSomeSignal1LocalActivityOptions added in v1.1.0 

func NewSomeSignal1LocalActivityOptions() *SomeSignal1LocalActivityOptions

NewSomeSignal1LocalActivityOptions sets default LocalActivityOptions

func (*SomeSignal1LocalActivityOptions) Local added in v1.1.0 

func (opts *SomeSignal1LocalActivityOptions) Local(fn func(context.Context) error) *SomeSignal1LocalActivityOptions

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

func (*SomeSignal1LocalActivityOptions) WithLocalActivityOptions added in v1.1.0 

func (opts *SomeSignal1LocalActivityOptions) WithLocalActivityOptions(options workflow.LocalActivityOptions) *SomeSignal1LocalActivityOptions

WithLocalActivityOptions sets default LocalActivityOptions

type SomeSignal1Signal added in v0.7.1 

type SomeSignal1Signal struct {
	Channel workflow.ReceiveChannel
}

SomeSignal1Signal describes a(n) mycompany.simple.Simple.SomeSignal1 signal

func NewSomeSignal1Signal added in v1.10.2 

func NewSomeSignal1Signal(ctx workflow.Context) *SomeSignal1Signal

NewSomeSignal1Signal initializes a new mycompany.simple.Simple.SomeSignal1 signal wrapper

func (*SomeSignal1Signal) Receive added in v0.7.1 

func (s *SomeSignal1Signal) Receive(ctx workflow.Context) bool

Receive blocks until a(n) mycompany.simple.Simple.SomeSignal1 signal is received

func (*SomeSignal1Signal) ReceiveAsync added in v0.7.1 

func (s *SomeSignal1Signal) ReceiveAsync() bool

ReceiveAsync checks for a mycompany.simple.Simple.SomeSignal1 signal without blocking

func (*SomeSignal1Signal) ReceiveWithTimeout added in v1.6.0 

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 added in v0.7.1 

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 added in v1.1.0 

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

SomeSignal2ActivityOptions provides configuration for a(n) mycompany.simple.Simple.SomeSignal2 activity

func NewSomeSignal2ActivityOptions added in v1.1.0 

func NewSomeSignal2ActivityOptions() *SomeSignal2ActivityOptions

NewSomeSignal2ActivityOptions sets default ActivityOptions

func (*SomeSignal2ActivityOptions) WithActivityOptions added in v1.1.0 

func (opts *SomeSignal2ActivityOptions) WithActivityOptions(options workflow.ActivityOptions) *SomeSignal2ActivityOptions

WithActivityOptions sets default ActivityOptions

type SomeSignal2Future added in v1.1.0 

type SomeSignal2Future struct {
	Future workflow.Future
}

SomeSignal2Future describes a(n) mycompany.simple.Simple.SomeSignal2 activity execution

func SomeSignal2Async added in v1.1.0 

func SomeSignal2Async(ctx workflow.Context, req *SomeSignal2Request, options ...*SomeSignal2ActivityOptions) *SomeSignal2Future

SomeSignal2 is a signal.

func SomeSignal2LocalAsync added in v1.1.0 

func SomeSignal2LocalAsync(ctx workflow.Context, req *SomeSignal2Request, options ...*SomeSignal2LocalActivityOptions) *SomeSignal2Future

SomeSignal2 is a signal.

func (*SomeSignal2Future) Get added in v1.1.0 

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

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

func (*SomeSignal2Future) Select added in v1.1.0 

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

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

type SomeSignal2LocalActivityOptions added in v1.1.0 

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

SomeSignal2LocalActivityOptions provides configuration for a local mycompany.simple.Simple.SomeSignal2 activity

func NewSomeSignal2LocalActivityOptions added in v1.1.0 

func NewSomeSignal2LocalActivityOptions() *SomeSignal2LocalActivityOptions

NewSomeSignal2LocalActivityOptions sets default LocalActivityOptions

func (*SomeSignal2LocalActivityOptions) Local added in v1.1.0 

func (opts *SomeSignal2LocalActivityOptions) Local(fn func(context.Context, *SomeSignal2Request) error) *SomeSignal2LocalActivityOptions

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

func (*SomeSignal2LocalActivityOptions) WithLocalActivityOptions added in v1.1.0 

func (opts *SomeSignal2LocalActivityOptions) WithLocalActivityOptions(options workflow.LocalActivityOptions) *SomeSignal2LocalActivityOptions

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 added in v1.2.0 

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 added in v0.7.1 

type SomeSignal2Signal struct {
	Channel workflow.ReceiveChannel
}

SomeSignal2Signal describes a(n) mycompany.simple.Simple.SomeSignal2 signal

func NewSomeSignal2Signal added in v1.10.2 

func NewSomeSignal2Signal(ctx workflow.Context) *SomeSignal2Signal

NewSomeSignal2Signal initializes a new mycompany.simple.Simple.SomeSignal2 signal wrapper

func (*SomeSignal2Signal) Receive added in v0.7.1 

func (s *SomeSignal2Signal) Receive(ctx workflow.Context) (*SomeSignal2Request, bool)

Receive blocks until a(n) mycompany.simple.Simple.SomeSignal2 signal is received

func (*SomeSignal2Signal) ReceiveAsync added in v0.7.1 

func (s *SomeSignal2Signal) ReceiveAsync() *SomeSignal2Request

ReceiveAsync checks for a mycompany.simple.Simple.SomeSignal2 signal without blocking

func (*SomeSignal2Signal) ReceiveWithTimeout added in v1.6.0 

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 added in v0.7.1 

func (s *SomeSignal2Signal) Select(sel workflow.Selector, fn func(*SomeSignal2Request)) workflow.Selector

Select checks for a(n) mycompany.simple.Simple.SomeSignal2 signal without blocking

type SomeSignal3ActivityOptions added in v1.1.0 

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

SomeSignal3ActivityOptions provides configuration for a(n) mycompany.simple.Simple.SomeSignal3 activity

func NewSomeSignal3ActivityOptions added in v1.1.0 

func NewSomeSignal3ActivityOptions() *SomeSignal3ActivityOptions

NewSomeSignal3ActivityOptions sets default ActivityOptions

func (*SomeSignal3ActivityOptions) WithActivityOptions added in v1.1.0 

func (opts *SomeSignal3ActivityOptions) WithActivityOptions(options workflow.ActivityOptions) *SomeSignal3ActivityOptions

WithActivityOptions sets default ActivityOptions

type SomeSignal3Future added in v1.1.0 

type SomeSignal3Future struct {
	Future workflow.Future
}

SomeSignal3Future describes a(n) mycompany.simple.Simple.SomeSignal3 activity execution

func SomeSignal3Async added in v1.1.0 

func SomeSignal3Async(ctx workflow.Context, req *SomeSignal3Request, options ...*SomeSignal3ActivityOptions) *SomeSignal3Future

SomeSignal3 is a signal.

func SomeSignal3LocalAsync added in v1.1.0 

func SomeSignal3LocalAsync(ctx workflow.Context, req *SomeSignal3Request, options ...*SomeSignal3LocalActivityOptions) *SomeSignal3Future

SomeSignal3 is a signal.

func (*SomeSignal3Future) Get added in v1.1.0 

func (f *SomeSignal3Future) Get(ctx workflow.Context) (*SomeSignal3Response, error)

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

func (*SomeSignal3Future) Select added in v1.1.0 

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

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

type SomeSignal3LocalActivityOptions added in v1.1.0 

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

SomeSignal3LocalActivityOptions provides configuration for a local mycompany.simple.Simple.SomeSignal3 activity

func NewSomeSignal3LocalActivityOptions added in v1.1.0 

func NewSomeSignal3LocalActivityOptions() *SomeSignal3LocalActivityOptions

NewSomeSignal3LocalActivityOptions sets default LocalActivityOptions

func (*SomeSignal3LocalActivityOptions) Local added in v1.1.0 

func (opts *SomeSignal3LocalActivityOptions) Local(fn func(context.Context, *SomeSignal3Request) (*SomeSignal3Response, error)) *SomeSignal3LocalActivityOptions

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

func (*SomeSignal3LocalActivityOptions) WithLocalActivityOptions added in v1.1.0 

func (opts *SomeSignal3LocalActivityOptions) WithLocalActivityOptions(options workflow.LocalActivityOptions) *SomeSignal3LocalActivityOptions

WithLocalActivityOptions sets default LocalActivityOptions

type SomeSignal3Request added in v1.1.0 

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 added in v1.2.0 

func UnmarshalCliFlagsToSomeSignal3Request(cmd *v2.Context) (*SomeSignal3Request, error)

UnmarshalCliFlagsToSomeSignal3Request unmarshals a SomeSignal3Request from command line flags

func (*SomeSignal3Request) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use SomeSignal3Request.ProtoReflect.Descriptor instead.

func (*SomeSignal3Request) GetRequestVal added in v1.1.0 

func (x *SomeSignal3Request) GetRequestVal() string

func (*SomeSignal3Request) ProtoMessage added in v1.1.0 

func (*SomeSignal3Request) ProtoMessage()

func (*SomeSignal3Request) ProtoReflect added in v1.1.0 

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

func (*SomeSignal3Request) Reset added in v1.1.0 

func (x *SomeSignal3Request) Reset()

func (*SomeSignal3Request) String added in v1.1.0 

func (x *SomeSignal3Request) String() string

type SomeSignal3Response added in v1.1.0 

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 added in v1.1.0 

func SomeSignal3(ctx workflow.Context, req *SomeSignal3Request, options ...*SomeSignal3ActivityOptions) (*SomeSignal3Response, error)

SomeSignal3 is a signal.

func SomeSignal3Local added in v1.1.0 

func SomeSignal3Local(ctx workflow.Context, req *SomeSignal3Request, options ...*SomeSignal3LocalActivityOptions) (*SomeSignal3Response, error)

SomeSignal3 is a signal.

func (*SomeSignal3Response) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use SomeSignal3Response.ProtoReflect.Descriptor instead.

func (*SomeSignal3Response) GetResponseVal added in v1.1.0 

func (x *SomeSignal3Response) GetResponseVal() string

func (*SomeSignal3Response) ProtoMessage added in v1.1.0 

func (*SomeSignal3Response) ProtoMessage()

func (*SomeSignal3Response) ProtoReflect added in v1.1.0 

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

func (*SomeSignal3Response) Reset added in v1.1.0 

func (x *SomeSignal3Response) Reset()

func (*SomeSignal3Response) String added in v1.1.0 

func (x *SomeSignal3Response) String() string

type SomeSignal3Signal added in v1.1.0 

type SomeSignal3Signal struct {
	Channel workflow.ReceiveChannel
}

SomeSignal3Signal describes a(n) mycompany.simple.Simple.SomeSignal3 signal

func NewSomeSignal3Signal added in v1.10.2 

func NewSomeSignal3Signal(ctx workflow.Context) *SomeSignal3Signal

NewSomeSignal3Signal initializes a new mycompany.simple.Simple.SomeSignal3 signal wrapper

func (*SomeSignal3Signal) Receive added in v1.1.0 

func (s *SomeSignal3Signal) Receive(ctx workflow.Context) (*SomeSignal3Request, bool)

Receive blocks until a(n) mycompany.simple.Simple.SomeSignal3 signal is received

func (*SomeSignal3Signal) ReceiveAsync added in v1.1.0 

func (s *SomeSignal3Signal) ReceiveAsync() *SomeSignal3Request

ReceiveAsync checks for a mycompany.simple.Simple.SomeSignal3 signal without blocking

func (*SomeSignal3Signal) ReceiveWithTimeout added in v1.6.0 

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 added in v1.1.0 

func (s *SomeSignal3Signal) Select(sel workflow.Selector, fn func(*SomeSignal3Request)) workflow.Selector

Select checks for a(n) mycompany.simple.Simple.SomeSignal3 signal without blocking

type SomeUpdate1ActivityOptions added in v1.1.0 

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

SomeUpdate1ActivityOptions provides configuration for a(n) mycompany.simple.Simple.SomeUpdate1 activity

func NewSomeUpdate1ActivityOptions added in v1.1.0 

func NewSomeUpdate1ActivityOptions() *SomeUpdate1ActivityOptions

NewSomeUpdate1ActivityOptions sets default ActivityOptions

func (*SomeUpdate1ActivityOptions) WithActivityOptions added in v1.1.0 

func (opts *SomeUpdate1ActivityOptions) WithActivityOptions(options workflow.ActivityOptions) *SomeUpdate1ActivityOptions

WithActivityOptions sets default ActivityOptions

type SomeUpdate1Future added in v1.1.0 

type SomeUpdate1Future struct {
	Future workflow.Future
}

SomeUpdate1Future describes a(n) mycompany.simple.Simple.SomeUpdate1 activity execution

func SomeUpdate1Async added in v1.1.0 

func SomeUpdate1Async(ctx workflow.Context, req *SomeUpdate1Request, options ...*SomeUpdate1ActivityOptions) *SomeUpdate1Future

SomeUpdate1 updates a SomeWorkflow2

func SomeUpdate1LocalAsync added in v1.1.0 

func SomeUpdate1LocalAsync(ctx workflow.Context, req *SomeUpdate1Request, options ...*SomeUpdate1LocalActivityOptions) *SomeUpdate1Future

SomeUpdate1 updates a SomeWorkflow2

func (*SomeUpdate1Future) Get added in v1.1.0 

func (f *SomeUpdate1Future) Get(ctx workflow.Context) (*SomeUpdate1Response, error)

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

func (*SomeUpdate1Future) Select added in v1.1.0 

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

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

type SomeUpdate1Handle added in v1.0.0 

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 added in v1.1.0 

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

SomeUpdate1LocalActivityOptions provides configuration for a local mycompany.simple.Simple.SomeUpdate1 activity

func NewSomeUpdate1LocalActivityOptions added in v1.1.0 

func NewSomeUpdate1LocalActivityOptions() *SomeUpdate1LocalActivityOptions

NewSomeUpdate1LocalActivityOptions sets default LocalActivityOptions

func (*SomeUpdate1LocalActivityOptions) Local added in v1.1.0 

func (opts *SomeUpdate1LocalActivityOptions) Local(fn func(context.Context, *SomeUpdate1Request) (*SomeUpdate1Response, error)) *SomeUpdate1LocalActivityOptions

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

func (*SomeUpdate1LocalActivityOptions) WithLocalActivityOptions added in v1.1.0 

func (opts *SomeUpdate1LocalActivityOptions) WithLocalActivityOptions(options workflow.LocalActivityOptions) *SomeUpdate1LocalActivityOptions

WithLocalActivityOptions sets default LocalActivityOptions

type SomeUpdate1Options added in v1.0.0 

type SomeUpdate1Options struct {
	Options *client.UpdateWorkflowWithOptionsRequest
}

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

func NewSomeUpdate1Options added in v1.0.0 

func NewSomeUpdate1Options() *SomeUpdate1Options

NewSomeUpdate1Options initializes a new SomeUpdate1Options value

func (*SomeUpdate1Options) WithUpdateWorkflowOptions added in v1.0.0 

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

WithUpdateWorkflowOptions sets the initial client.UpdateWorkflowWithOptionsRequest

type SomeUpdate1Request added in v1.0.0 

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 added in v1.2.0 

func UnmarshalCliFlagsToSomeUpdate1Request(cmd *v2.Context) (*SomeUpdate1Request, error)

UnmarshalCliFlagsToSomeUpdate1Request unmarshals a SomeUpdate1Request from command line flags

func (*SomeUpdate1Request) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use SomeUpdate1Request.ProtoReflect.Descriptor instead.

func (*SomeUpdate1Request) GetRequestVal added in v1.0.0 

func (x *SomeUpdate1Request) GetRequestVal() string

func (*SomeUpdate1Request) ProtoMessage added in v1.0.0 

func (*SomeUpdate1Request) ProtoMessage()

func (*SomeUpdate1Request) ProtoReflect added in v1.0.0 

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

func (*SomeUpdate1Request) Reset added in v1.0.0 

func (x *SomeUpdate1Request) Reset()

func (*SomeUpdate1Request) String added in v1.0.0 

func (x *SomeUpdate1Request) String() string

type SomeUpdate1Response added in v1.0.0 

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 added in v1.1.0 

func SomeUpdate1(ctx workflow.Context, req *SomeUpdate1Request, options ...*SomeUpdate1ActivityOptions) (*SomeUpdate1Response, error)

SomeUpdate1 updates a SomeWorkflow2

func SomeUpdate1Local added in v1.1.0 

func SomeUpdate1Local(ctx workflow.Context, req *SomeUpdate1Request, options ...*SomeUpdate1LocalActivityOptions) (*SomeUpdate1Response, error)

SomeUpdate1 updates a SomeWorkflow2

func (*SomeUpdate1Response) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use SomeUpdate1Response.ProtoReflect.Descriptor instead.

func (*SomeUpdate1Response) GetResponseVal added in v1.0.0 

func (x *SomeUpdate1Response) GetResponseVal() string

func (*SomeUpdate1Response) ProtoMessage added in v1.0.0 

func (*SomeUpdate1Response) ProtoMessage()

func (*SomeUpdate1Response) ProtoReflect added in v1.0.0 

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

func (*SomeUpdate1Response) Reset added in v1.0.0 

func (x *SomeUpdate1Response) Reset()

func (*SomeUpdate1Response) String added in v1.0.0 

func (x *SomeUpdate1Response) String() string

type SomeWorkflow1ChildOptions added in v1.0.0 

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

SomeWorkflow1ChildOptions provides configuration for a mycompany.simple.SomeWorkflow1 workflow operation

func NewSomeWorkflow1ChildOptions added in v1.0.0 

func NewSomeWorkflow1ChildOptions() *SomeWorkflow1ChildOptions

NewSomeWorkflow1ChildOptions initializes a new SomeWorkflow1ChildOptions value

func (*SomeWorkflow1ChildOptions) WithChildWorkflowOptions added in v1.0.0 

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 added in v1.0.0 

func SomeWorkflow1ChildAsync(ctx workflow.Context, req *SomeWorkflow1Request, options ...*SomeWorkflow1ChildOptions) (*SomeWorkflow1ChildRun, error)

SomeWorkflow1 does some workflow thing.

func (*SomeWorkflow1ChildRun) Get 

func (r *SomeWorkflow1ChildRun) Get(ctx workflow.Context) (*SomeWorkflow1Response, error)

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

func (*SomeWorkflow1ChildRun) Select 

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

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

func (*SomeWorkflow1ChildRun) SelectStart 

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

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

func (*SomeWorkflow1ChildRun) SomeSignal1 

func (r *SomeWorkflow1ChildRun) SomeSignal1(ctx workflow.Context) error

SomeSignal1 sends a(n) "mycompany.simple.Simple.SomeSignal1" signal request to the child workflow

func (*SomeWorkflow1ChildRun) SomeSignal1Async added in v1.0.0 

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 added in v1.0.0 

func (r *SomeWorkflow1ChildRun) SomeSignal2Async(ctx workflow.Context, input *SomeSignal2Request) workflow.Future

SomeSignal2Async sends a(n) "mycompany.simple.Simple.SomeSignal2" signal request to the child workflow

func (*SomeWorkflow1ChildRun) WaitStart 

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

WaitStart waits for the child workflow to start

type SomeWorkflow1Options added in v1.0.0 

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

SomeWorkflow1Options provides configuration for a mycompany.simple.SomeWorkflow1 workflow operation

func NewSomeWorkflow1Options added in v1.0.0 

func NewSomeWorkflow1Options() *SomeWorkflow1Options

NewSomeWorkflow1Options initializes a new SomeWorkflow1Options value

func (*SomeWorkflow1Options) WithStartWorkflowOptions added in v1.0.0 

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 added in v1.2.0 

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 added in v0.4.0 

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 added in v1.3.0 

type SomeWorkflow1WorkflowInput struct {
	Req         *SomeWorkflow1Request
	SomeSignal1 *SomeSignal1Signal
	SomeSignal2 *SomeSignal2Signal
}

SomeWorkflow1WorkflowInput describes the input to a(n) mycompany.simple.SomeWorkflow1 workflow constructor

type SomeWorkflow2ChildOptions added in v1.0.0 

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

SomeWorkflow2ChildOptions provides configuration for a mycompany.simple.SomeWorkflow2 workflow operation

func NewSomeWorkflow2ChildOptions added in v1.0.0 

func NewSomeWorkflow2ChildOptions() *SomeWorkflow2ChildOptions

NewSomeWorkflow2ChildOptions initializes a new SomeWorkflow2ChildOptions value

func (*SomeWorkflow2ChildOptions) WithChildWorkflowOptions added in v1.0.0 

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 added in v1.0.0 

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

SomeWorkflow2 does some workflow thing.

func (*SomeWorkflow2ChildRun) Get 

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

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

func (*SomeWorkflow2ChildRun) Select 

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

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

func (*SomeWorkflow2ChildRun) SelectStart 

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

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

func (*SomeWorkflow2ChildRun) SomeSignal1 

func (r *SomeWorkflow2ChildRun) SomeSignal1(ctx workflow.Context) error

SomeSignal1 sends a(n) "mycompany.simple.Simple.SomeSignal1" signal request to the child workflow

func (*SomeWorkflow2ChildRun) SomeSignal1Async added in v1.0.0 

func (r *SomeWorkflow2ChildRun) SomeSignal1Async(ctx workflow.Context) workflow.Future

SomeSignal1Async sends a(n) "mycompany.simple.Simple.SomeSignal1" signal request to the child workflow

func (*SomeWorkflow2ChildRun) WaitStart 

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

WaitStart waits for the child workflow to start

type SomeWorkflow2Options added in v1.0.0 

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

SomeWorkflow2Options provides configuration for a mycompany.simple.SomeWorkflow2 workflow operation

func NewSomeWorkflow2Options added in v1.0.0 

func NewSomeWorkflow2Options() *SomeWorkflow2Options

NewSomeWorkflow2Options initializes a new SomeWorkflow2Options value

func (*SomeWorkflow2Options) WithStartWorkflowOptions added in v1.0.0 

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 added in v0.4.0 

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 added in v1.3.0 

type SomeWorkflow2WorkflowInput struct {
	SomeSignal1 *SomeSignal1Signal
}

SomeWorkflow2WorkflowInput describes the input to a(n) mycompany.simple.SomeWorkflow2 workflow constructor

type SomeWorkflow3ChildOptions added in v1.0.0 

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

SomeWorkflow3ChildOptions provides configuration for a mycompany.simple.Simple.SomeWorkflow3 workflow operation

func NewSomeWorkflow3ChildOptions added in v1.0.0 

func NewSomeWorkflow3ChildOptions() *SomeWorkflow3ChildOptions

NewSomeWorkflow3ChildOptions initializes a new SomeWorkflow3ChildOptions value

func (*SomeWorkflow3ChildOptions) WithChildWorkflowOptions added in v1.0.0 

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 added in v1.0.0 

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

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

func (*SomeWorkflow3ChildRun) Get 

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

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

func (*SomeWorkflow3ChildRun) Select 

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

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

func (*SomeWorkflow3ChildRun) SelectStart 

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

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

func (*SomeWorkflow3ChildRun) SomeSignal2 

func (r *SomeWorkflow3ChildRun) SomeSignal2(ctx workflow.Context, input *SomeSignal2Request) error

SomeSignal2 sends a(n) "mycompany.simple.Simple.SomeSignal2" signal request to the child workflow

func (*SomeWorkflow3ChildRun) SomeSignal2Async added in v1.0.0 

func (r *SomeWorkflow3ChildRun) SomeSignal2Async(ctx workflow.Context, input *SomeSignal2Request) workflow.Future

SomeSignal2Async sends a(n) "mycompany.simple.Simple.SomeSignal2" signal request to the child workflow

func (*SomeWorkflow3ChildRun) WaitStart 

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

WaitStart waits for the child workflow to start

type SomeWorkflow3Options added in v1.0.0 

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

SomeWorkflow3Options provides configuration for a mycompany.simple.Simple.SomeWorkflow3 workflow operation

func NewSomeWorkflow3Options added in v1.0.0 

func NewSomeWorkflow3Options() *SomeWorkflow3Options

NewSomeWorkflow3Options initializes a new SomeWorkflow3Options value

func (*SomeWorkflow3Options) WithStartWorkflowOptions added in v1.0.0 

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 added in v1.2.0 

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 added in v0.4.0 

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 added in v1.3.0 

type SomeWorkflow3WorkflowInput struct {
	Req         *SomeWorkflow3Request
	SomeSignal2 *SomeSignal2Signal
}

SomeWorkflow3WorkflowInput describes the input to a(n) mycompany.simple.Simple.SomeWorkflow3 workflow constructor

type TestDeprecatedClient added in v1.9.0 

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

TestClient provides a testsuite-compatible Client

func NewTestDeprecatedClient added in v1.9.0 

func NewTestDeprecatedClient(env *testsuite.TestWorkflowEnvironment, workflows DeprecatedWorkflows, activities DeprecatedActivities) *TestDeprecatedClient

NewTestDeprecatedClient initializes a new TestDeprecatedClient value

func (*TestDeprecatedClient) CancelWorkflow added in v1.9.0 

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

CancelWorkflow requests cancellation of an existing workflow execution

func (*TestDeprecatedClient) GetSomeDeprecatedUpdate1 added in v1.9.0 

func (c *TestDeprecatedClient) GetSomeDeprecatedUpdate1(ctx context.Context, req client.GetWorkflowUpdateHandleOptions) (SomeDeprecatedUpdate1Handle, error)

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

func (*TestDeprecatedClient) GetSomeDeprecatedUpdate2 added in v1.9.0 

func (c *TestDeprecatedClient) GetSomeDeprecatedUpdate2(ctx context.Context, req client.GetWorkflowUpdateHandleOptions) (SomeDeprecatedUpdate2Handle, error)

GetSomeDeprecatedUpdate2 retrieves a handle to an existing mycompany.simple.Deprecated.SomeDeprecatedUpdate2 update

func (*TestDeprecatedClient) GetSomeDeprecatedWorkflow1 added in v1.9.0 

func (c *TestDeprecatedClient) GetSomeDeprecatedWorkflow1(ctx context.Context, workflowID string, runID string) SomeDeprecatedWorkflow1Run

GetSomeDeprecatedWorkflow1 is a noop

func (*TestDeprecatedClient) GetSomeDeprecatedWorkflow2 added in v1.9.0 

func (c *TestDeprecatedClient) GetSomeDeprecatedWorkflow2(ctx context.Context, workflowID string, runID string) SomeDeprecatedWorkflow2Run

GetSomeDeprecatedWorkflow2 is a noop

func (*TestDeprecatedClient) SomeDeprecatedQuery1 added in v1.9.0 

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 added in v1.9.0 

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 added in v1.9.0 

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 added in v1.9.0 

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 added in v1.9.0 

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 added in v1.9.0 

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 added in v1.9.0 

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 added in v1.9.0 

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 added in v1.9.0 

func (c *TestDeprecatedClient) SomeDeprecatedWorkflow1(ctx context.Context, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow1Options) (*SomeDeprecatedMessage, error)

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

func (*TestDeprecatedClient) SomeDeprecatedWorkflow1Async added in v1.9.0 

func (c *TestDeprecatedClient) SomeDeprecatedWorkflow1Async(ctx context.Context, req *SomeDeprecatedMessage, options ...*SomeDeprecatedWorkflow1Options) (SomeDeprecatedWorkflow1Run, error)

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

func (*TestDeprecatedClient) SomeDeprecatedWorkflow1WithSomeDeprecatedSignal1 added in v1.9.0 

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 added in v1.9.0 

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 added in v1.9.0 

func (c *TestDeprecatedClient) SomeDeprecatedWorkflow2(ctx context.Context, req *SomeDeprecatedMessage, opts ...*SomeDeprecatedWorkflow2Options) (*SomeDeprecatedMessage, error)

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

func (*TestDeprecatedClient) SomeDeprecatedWorkflow2Async added in v1.9.0 

func (c *TestDeprecatedClient) SomeDeprecatedWorkflow2Async(ctx context.Context, req *SomeDeprecatedMessage, options ...*SomeDeprecatedWorkflow2Options) (SomeDeprecatedWorkflow2Run, error)

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

func (*TestDeprecatedClient) SomeDeprecatedWorkflow2WithSomeDeprecatedSignal2 added in v1.9.0 

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 added in v1.9.0 

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 added in v1.9.0 

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

TerminateWorkflow terminates an existing workflow execution

type TestIgnoredClient added in v1.2.0 

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

TestClient provides a testsuite-compatible Client

func NewTestIgnoredClient added in v1.2.0 

func NewTestIgnoredClient(env *testsuite.TestWorkflowEnvironment, workflows IgnoredWorkflows, activities IgnoredActivities) *TestIgnoredClient

NewTestIgnoredClient initializes a new TestIgnoredClient value

func (*TestIgnoredClient) CancelWorkflow added in v1.2.0 

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

CancelWorkflow requests cancellation of an existing workflow execution

func (*TestIgnoredClient) GetWhat added in v1.2.0 

func (c *TestIgnoredClient) GetWhat(ctx context.Context, workflowID string, runID string) WhatRun

GetWhat is a noop

func (*TestIgnoredClient) TerminateWorkflow added in v1.2.0 

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 added in v1.2.0 

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 added in v1.2.0 

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 added in v1.8.2 

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

TestClient provides a testsuite-compatible Client

func NewTestOnlyActivitiesClient added in v1.8.2 

func NewTestOnlyActivitiesClient(env *testsuite.TestWorkflowEnvironment, workflows OnlyActivitiesWorkflows, activities OnlyActivitiesActivities) *TestOnlyActivitiesClient

NewTestOnlyActivitiesClient initializes a new TestOnlyActivitiesClient value

func (*TestOnlyActivitiesClient) CancelWorkflow added in v1.8.2 

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

CancelWorkflow requests cancellation of an existing workflow execution

func (*TestOnlyActivitiesClient) TerminateWorkflow added in v1.8.2 

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

TerminateWorkflow terminates an existing workflow execution

type TestOtherClient added in v1.0.0 

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

TestClient provides a testsuite-compatible Client

func NewTestOtherClient added in v1.0.0 

func NewTestOtherClient(env *testsuite.TestWorkflowEnvironment, workflows OtherWorkflows, activities OtherActivities) *TestOtherClient

NewTestOtherClient initializes a new TestOtherClient value

func (*TestOtherClient) CancelWorkflow added in v1.0.0 

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

CancelWorkflow requests cancellation of an existing workflow execution

func (*TestOtherClient) GetOtherUpdate added in v1.5.0 

func (c *TestOtherClient) GetOtherUpdate(ctx context.Context, req client.GetWorkflowUpdateHandleOptions) (OtherUpdateHandle, error)

GetOtherUpdate retrieves a handle to an existing mycompany.simple.Other.OtherUpdate update

func (*TestOtherClient) GetOtherWorkflow added in v1.0.0 

func (c *TestOtherClient) GetOtherWorkflow(ctx context.Context, workflowID string, runID string) OtherWorkflowRun

GetOtherWorkflow is a noop

func (*TestOtherClient) OtherQuery added in v1.0.0 

func (c *TestOtherClient) OtherQuery(ctx context.Context, workflowID string, runID string) (*OtherQueryResponse, error)

OtherQuery executes a mycompany.simple.Other.OtherQuery query

func (*TestOtherClient) OtherSignal added in v1.0.0 

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 added in v1.0.0 

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 added in v1.0.0 

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 added in v1.0.0 

func (c *TestOtherClient) OtherWorkflow(ctx context.Context, req *OtherWorkflowRequest, opts ...*OtherWorkflowOptions) (*OtherWorkflowResponse, error)

OtherWorkflow executes a(n) mycompany.simple.Other.OtherWorkflow workflow in the test environment

func (*TestOtherClient) OtherWorkflowAsync added in v1.0.0 

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 added in v1.0.0 

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

TerminateWorkflow terminates an existing workflow execution

type TestSimpleClient added in v1.0.0 

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

TestClient provides a testsuite-compatible Client

func NewTestSimpleClient added in v1.0.0 

func NewTestSimpleClient(env *testsuite.TestWorkflowEnvironment, workflows SimpleWorkflows, activities SimpleActivities) *TestSimpleClient

NewTestSimpleClient initializes a new TestSimpleClient value

func (*TestSimpleClient) CancelWorkflow added in v1.0.0 

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

CancelWorkflow requests cancellation of an existing workflow execution

func (*TestSimpleClient) GetSomeUpdate1 added in v1.5.0 

func (c *TestSimpleClient) GetSomeUpdate1(ctx context.Context, req client.GetWorkflowUpdateHandleOptions) (SomeUpdate1Handle, error)

GetSomeUpdate1 retrieves a handle to an existing mycompany.simple.Simple.SomeUpdate1 update

func (*TestSimpleClient) GetSomeWorkflow1 added in v1.0.0 

func (c *TestSimpleClient) GetSomeWorkflow1(ctx context.Context, workflowID string, runID string) SomeWorkflow1Run

GetSomeWorkflow1 is a noop

func (*TestSimpleClient) GetSomeWorkflow2 added in v1.0.0 

func (c *TestSimpleClient) GetSomeWorkflow2(ctx context.Context, workflowID string, runID string) SomeWorkflow2Run

GetSomeWorkflow2 is a noop

func (*TestSimpleClient) GetSomeWorkflow3 added in v1.0.0 

func (c *TestSimpleClient) GetSomeWorkflow3(ctx context.Context, workflowID string, runID string) SomeWorkflow3Run

GetSomeWorkflow3 is a noop

func (*TestSimpleClient) SomeQuery1 added in v1.0.0 

func (c *TestSimpleClient) SomeQuery1(ctx context.Context, workflowID string, runID string) (*SomeQuery1Response, error)

SomeQuery1 executes a mycompany.simple.Simple.SomeQuery1 query

func (*TestSimpleClient) SomeQuery2 added in v1.0.0 

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 added in v1.0.0 

func (c *TestSimpleClient) SomeSignal1(ctx context.Context, workflowID string, runID string) error

SomeSignal1 executes a mycompany.simple.Simple.SomeSignal1 signal

func (*TestSimpleClient) SomeSignal2 added in v1.0.0 

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 added in v1.1.0 

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 added in v1.0.0 

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 added in v1.0.0 

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 added in v1.0.0 

func (c *TestSimpleClient) SomeWorkflow1(ctx context.Context, req *SomeWorkflow1Request, opts ...*SomeWorkflow1Options) (*SomeWorkflow1Response, error)

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

func (*TestSimpleClient) SomeWorkflow1Async added in v1.0.0 

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 added in v1.0.0 

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 added in v1.0.0 

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 added in v1.0.0 

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 added in v1.0.0 

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 added in v1.0.0 

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 added in v1.0.0 

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 added in v1.0.0 

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 added in v1.0.0 

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 added in v1.0.0 

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

TerminateWorkflow terminates an existing workflow execution

type WhatChildOptions added in v1.2.0 

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

WhatChildOptions provides configuration for a mycompany.simple.Ignored.What workflow operation

func NewWhatChildOptions added in v1.2.0 

func NewWhatChildOptions() *WhatChildOptions

NewWhatChildOptions initializes a new WhatChildOptions value

func (*WhatChildOptions) WithChildWorkflowOptions added in v1.2.0 

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

WithChildWorkflowOptions sets the initial client.StartWorkflowOptions

type WhatChildRun added in v1.2.0 

type WhatChildRun struct {
	Future workflow.ChildWorkflowFuture
}

WhatChildRun describes a child What workflow run

func WhatChildAsync added in v1.2.0 

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 added in v1.2.0 

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

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

func (*WhatChildRun) Select added in v1.2.0 

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 added in v1.2.0 

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 added in v1.2.0 

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

WaitStart waits for the child workflow to start

type WhatOptions added in v1.2.0 

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

WhatOptions provides configuration for a mycompany.simple.Ignored.What workflow operation

func NewWhatOptions added in v1.2.0 

func NewWhatOptions() *WhatOptions

NewWhatOptions initializes a new WhatOptions value

func (*WhatOptions) WithStartWorkflowOptions added in v1.2.0 

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

WithStartWorkflowOptions sets the initial client.StartWorkflowOptions

type WhatRequest added in v1.2.0 

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

func (*WhatRequest) Descriptor deprecated added in v1.2.0 

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

Deprecated: Use WhatRequest.ProtoReflect.Descriptor instead.

func (*WhatRequest) GetBlah added in v1.2.0 

func (x *WhatRequest) GetBlah() string

func (*WhatRequest) ProtoMessage added in v1.2.0 

func (*WhatRequest) ProtoMessage()

func (*WhatRequest) ProtoReflect added in v1.2.0 

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

func (*WhatRequest) Reset added in v1.2.0 

func (x *WhatRequest) Reset()

func (*WhatRequest) String added in v1.2.0 

func (x *WhatRequest) String() string

type WhatRun added in v1.2.0 

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 added in v1.2.0 

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 added in v1.3.0 

type WhatWorkflowInput struct {
	Req *WhatRequest
}

WhatWorkflowInput describes the input to a(n) mycompany.simple.Ignored.What workflow constructor

Source Files

View all Source files

Directories

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

Jump to

Keyboard shortcuts

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