simplexns

package
v1.7.0 Latest Latest
Warning

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

Go to latest
Published: Jan 12, 2024 License: MIT Imports: 16 Imported by: 0

Documentation

Overview

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

protoc-gen-go_temporal 1.6.1-next (d4aa571c65defba7c1853c6d86735fadf40a4cf8)
go go1.21.5
protoc (unknown)

source: simple/simple.proto

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CancelIgnoredWorkflow

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

CancelIgnoredWorkflow cancels an existing workflow

func CancelIgnoredWorkflowAsync

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

CancelIgnoredWorkflowAsync cancels an existing workflow

func CancelOtherWorkflow

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

CancelOtherWorkflow cancels an existing workflow

func CancelOtherWorkflowAsync

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

CancelOtherWorkflowAsync cancels an existing workflow

func CancelSimpleWorkflow

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

CancelSimpleWorkflow cancels an existing workflow

func CancelSimpleWorkflowAsync

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

CancelSimpleWorkflowAsync cancels an existing workflow

func OtherQuery

func OtherQuery(ctx workflow.Context, workflowID string, runID string, opts ...*OtherQueryQueryOptions) (*simple.OtherQueryResponse, error)

OtherQuery executes a(n) mycompany.simple.Other.OtherQuery query and blocks until error or response received

func OtherSignal

func OtherSignal(ctx workflow.Context, workflowID string, runID string, req *simple.OtherSignalRequest, opts ...*OtherSignalSignalOptions) error

OtherSignal executes a(n) mycompany.simple.Other.OtherSignal signal

func OtherUpdate

func OtherUpdate(ctx workflow.Context, workflowID string, runID string, req *simple.OtherUpdateRequest, opts ...*OtherUpdateUpdateOptions) (*simple.OtherUpdateResponse, error)

OtherUpdate executes a(n) mycompany.simple.Other.OtherUpdate update and blocks until error or response received

func OtherWorkflow

OtherWorkflow executes a(n) mycompany.simple.Other.OtherWorkflow workflow and blocks until error or response received

func RegisterIgnoredActivities

func RegisterIgnoredActivities(r worker.ActivityRegistry, c simple.IgnoredClient, opts ...IgnoredOptions)

RegisterIgnoredActivities registers mycompany.simple.Ignored cross-namespace activities

func RegisterOtherActivities

func RegisterOtherActivities(r worker.ActivityRegistry, c simple.OtherClient, opts ...OtherOptions)

RegisterOtherActivities registers mycompany.simple.Other cross-namespace activities

func RegisterSimpleActivities

func RegisterSimpleActivities(r worker.ActivityRegistry, c simple.SimpleClient, opts ...SimpleOptions)

RegisterSimpleActivities registers mycompany.simple.Simple cross-namespace activities

func SomeQuery1

func SomeQuery1(ctx workflow.Context, workflowID string, runID string, opts ...*SomeQuery1QueryOptions) (*simple.SomeQuery1Response, error)

SomeQuery1 queries some thing.

func SomeQuery2

func SomeQuery2(ctx workflow.Context, workflowID string, runID string, req *simple.SomeQuery2Request, opts ...*SomeQuery2QueryOptions) (*simple.SomeQuery2Response, error)

SomeQuery2 queries some thing.

func SomeSignal1

func SomeSignal1(ctx workflow.Context, workflowID string, runID string, opts ...*SomeSignal1SignalOptions) error

SomeSignal1 is a signal.

func SomeSignal2

func SomeSignal2(ctx workflow.Context, workflowID string, runID string, req *simple.SomeSignal2Request, opts ...*SomeSignal2SignalOptions) error

SomeSignal2 is a signal.

func SomeSignal3

func SomeSignal3(ctx workflow.Context, workflowID string, runID string, req *simple.SomeSignal3Request, opts ...*SomeSignal3SignalOptions) error

SomeSignal3 is a signal.

func SomeUpdate1

func SomeUpdate1(ctx workflow.Context, workflowID string, runID string, req *simple.SomeUpdate1Request, opts ...*SomeUpdate1UpdateOptions) (*simple.SomeUpdate1Response, error)

SomeUpdate1 updates a SomeWorkflow2

func SomeWorkflow1

SomeWorkflow1 does some workflow thing.

func SomeWorkflow2

func SomeWorkflow2(ctx workflow.Context, opts ...*SomeWorkflow2WorkflowOptions) error

SomeWorkflow2 does some workflow thing.

func SomeWorkflow2WithSomeSignal1

func SomeWorkflow2WithSomeSignal1(ctx workflow.Context, opts ...*SomeWorkflow2WorkflowOptions) error

SomeWorkflow2 does some workflow thing.

func SomeWorkflow3

SomeWorkflow3 does some workflow thing.

func SomeWorkflow3WithSomeSignal2

func SomeWorkflow3WithSomeSignal2(ctx workflow.Context, req *simple.SomeWorkflow3Request, signal *simple.SomeSignal2Request, opts ...*SomeWorkflow3WorkflowOptions) error

SomeWorkflow3 does some workflow thing.

func What

func What(ctx workflow.Context, req *simple.WhatRequest, opts ...*WhatWorkflowOptions) error

What executes a(n) mycompany.simple.Ignored.What workflow and blocks until error or response received

Types

type IgnoredOptions added in v1.5.2

type IgnoredOptions struct {
	// Filter is used to filter xns activity registrations. It receives as
	// input the original activity name, and should return one of the following:
	// 1. the original activity name, for no changes
	// 2. a modified activity name, to override the original activity name
	// 3. an empty string, to skip registration
	Filter func(string) string
}

IgnoredOptions is used to configure mycompany.simple.Ignored xns activity registration

type OtherOptions added in v1.5.2

type OtherOptions struct {
	// Filter is used to filter xns activity registrations. It receives as
	// input the original activity name, and should return one of the following:
	// 1. the original activity name, for no changes
	// 2. a modified activity name, to override the original activity name
	// 3. an empty string, to skip registration
	Filter func(string) string
}

OtherOptions is used to configure mycompany.simple.Other xns activity registration

type OtherQueryQueryHandle

type OtherQueryQueryHandle interface {
	// Cancel cancels the workflow
	Cancel(workflow.Context) error
	// Future returns the inner workflow.Future
	Future() workflow.Future
	// Get returns the inner workflow.Future
	Get(workflow.Context) (*simple.OtherQueryResponse, error)
}

OtherQueryQueryHandle provides a handle for a OtherQuery query activity

func OtherQueryAsync

func OtherQueryAsync(ctx workflow.Context, workflowID string, runID string, opts ...*OtherQueryQueryOptions) (OtherQueryQueryHandle, error)

OtherQueryAsync executes a(n) mycompany.simple.Other.OtherQuery query and blocks until error or response received

type OtherQueryQueryOptions

type OtherQueryQueryOptions struct {
	ActivityOptions   *workflow.ActivityOptions
	HeartbeatInterval time.Duration
}

OtherQueryQueryOptions are used to configure a(n) mycompany.simple.Other.OtherQuery query execution

func NewOtherQueryQueryOptions

func NewOtherQueryQueryOptions() *OtherQueryQueryOptions

NewOtherQueryQueryOptions initializes a new OtherQueryQueryOptions value

func (*OtherQueryQueryOptions) WithActivityOptions

WithActivityOptions can be used to customize the activity options

func (*OtherQueryQueryOptions) WithHeartbeatInterval

func (opts *OtherQueryQueryOptions) WithHeartbeatInterval(d time.Duration) *OtherQueryQueryOptions

WithHeartbeatInterval can be used to customize the activity heartbeat interval

type OtherSignalSignalHandle

type OtherSignalSignalHandle interface {
	// Cancel cancels the workflow
	Cancel(workflow.Context) error
	// Future returns the inner workflow.Future
	Future() workflow.Future
	// Get returns the inner workflow.Future
	Get(workflow.Context) error
}

OtherSignalSignalHandle provides a handle for a OtherSignal signal activity

func OtherSignalAsync

func OtherSignalAsync(ctx workflow.Context, workflowID string, runID string, req *simple.OtherSignalRequest, opts ...*OtherSignalSignalOptions) (OtherSignalSignalHandle, error)

OtherSignalAsync executes a(n) mycompany.simple.Other.OtherSignal query

type OtherSignalSignalOptions

type OtherSignalSignalOptions struct {
	ActivityOptions   *workflow.ActivityOptions
	HeartbeatInterval time.Duration
}

OtherSignalSignalOptions are used to configure a(n) mycompany.simple.Other.OtherSignal signal execution

func NewOtherSignalSignalOptions

func NewOtherSignalSignalOptions() *OtherSignalSignalOptions

NewOtherSignalSignalOptions initializes a new OtherSignalSignalOptions value

func (*OtherSignalSignalOptions) WithActivityOptions

WithActivityOptions can be used to customize the activity options

func (*OtherSignalSignalOptions) WithHeartbeatInterval

func (opts *OtherSignalSignalOptions) WithHeartbeatInterval(d time.Duration) *OtherSignalSignalOptions

WithHeartbeatInterval can be used to customize the activity heartbeat interval

type OtherUpdateHandle

type OtherUpdateHandle interface {
	// Cancel cancels the update activity
	Cancel(workflow.Context) error
	// Future returns the inner workflow.Future
	Future() workflow.Future
	// Get blocks on update completion and returns the result
	Get(workflow.Context) (*simple.OtherUpdateResponse, error)
	// ID returns the update id
	ID() string
}

OtherUpdateHandle provides a handle to a OtherUpdate workflow update

func OtherUpdateAsync

func OtherUpdateAsync(ctx workflow.Context, workflowID string, runID string, req *simple.OtherUpdateRequest, opts ...*OtherUpdateUpdateOptions) (OtherUpdateHandle, error)

OtherUpdateAsync executes a(n) mycompany.simple.Other.OtherUpdate update and blocks until error or response received

type OtherUpdateUpdateOptions

type OtherUpdateUpdateOptions struct {
	ActivityOptions       *workflow.ActivityOptions
	HeartbeatInterval     time.Duration
	UpdateWorkflowOptions *client.UpdateWorkflowWithOptionsRequest
}

OtherUpdateUpdateOptions are used to configure a(n) OtherUpdate update execution

func NewOtherUpdateUpdateOptions

func NewOtherUpdateUpdateOptions() *OtherUpdateUpdateOptions

NewOtherUpdateUpdateOptions initializes a new OtherUpdateUpdateOptions value

func (*OtherUpdateUpdateOptions) WithActivityOptions

WithActivityOptions can be used to customize the activity options

func (*OtherUpdateUpdateOptions) WithHeartbeatInterval

func (opts *OtherUpdateUpdateOptions) WithHeartbeatInterval(d time.Duration) *OtherUpdateUpdateOptions

WithHeartbeatInterval can be used to customize the activity heartbeat interval

func (*OtherUpdateUpdateOptions) WithUpdateWorkflowOptions

WithUpdateWorkflowOptions can be used to customize the update workflow options

type OtherWorkflowRun

type OtherWorkflowRun interface {
	// Cancel cancels the workflow
	Cancel(workflow.Context) error
	// Future returns the inner workflow.Future
	Future() workflow.Future
	// Get returns the inner workflow.Future
	Get(workflow.Context) (*simple.OtherWorkflowResponse, error)
	// ID returns the workflow id
	ID() string
}

OtherWorkflowRun provides a handle to a OtherWorkflow workflow execution

func OtherWorkflowAsync

OtherWorkflowAsync executes a(n) mycompany.simple.Other.OtherWorkflow workflow and blocks until error or response received

type OtherWorkflowWorkflowOptions

type OtherWorkflowWorkflowOptions struct {
	ActivityOptions      *workflow.ActivityOptions
	Detached             bool
	HeartbeatInterval    time.Duration
	StartWorkflowOptions *client.StartWorkflowOptions
}

OtherWorkflowWorkflowOptions are used to configure a(n) OtherWorkflow workflow execution

func NewOtherWorkflowWorkflowOptions

func NewOtherWorkflowWorkflowOptions() *OtherWorkflowWorkflowOptions

NewOtherWorkflowWorkflowOptions initializes a new OtherWorkflowWorkflowOptions value

func (*OtherWorkflowWorkflowOptions) WithActivityOptions

WithActivityOptions can be used to customize the activity options

func (*OtherWorkflowWorkflowOptions) WithDetached

WithDetached can be used to start a workflow execution and exit immediately

func (*OtherWorkflowWorkflowOptions) WithHeartbeatInterval

WithHeartbeatInterval can be used to customize the activity heartbeat interval

func (*OtherWorkflowWorkflowOptions) WithStartWorkflow

WithStartWorkflowOptions can be used to customize the start workflow options

type SimpleOptions added in v1.5.2

type SimpleOptions struct {
	// Filter is used to filter xns activity registrations. It receives as
	// input the original activity name, and should return one of the following:
	// 1. the original activity name, for no changes
	// 2. a modified activity name, to override the original activity name
	// 3. an empty string, to skip registration
	Filter func(string) string
}

SimpleOptions is used to configure mycompany.simple.Simple xns activity registration

type SomeQuery1QueryHandle

type SomeQuery1QueryHandle interface {
	// Cancel cancels the workflow
	Cancel(workflow.Context) error
	// Future returns the inner workflow.Future
	Future() workflow.Future
	// Get returns the inner workflow.Future
	Get(workflow.Context) (*simple.SomeQuery1Response, error)
}

SomeQuery1QueryHandle provides a handle for a SomeQuery1 query activity

func SomeQuery1Async

func SomeQuery1Async(ctx workflow.Context, workflowID string, runID string, opts ...*SomeQuery1QueryOptions) (SomeQuery1QueryHandle, error)

SomeQuery1 queries some thing.

type SomeQuery1QueryOptions

type SomeQuery1QueryOptions struct {
	ActivityOptions   *workflow.ActivityOptions
	HeartbeatInterval time.Duration
}

SomeQuery1QueryOptions are used to configure a(n) mycompany.simple.Simple.SomeQuery1 query execution

func NewSomeQuery1QueryOptions

func NewSomeQuery1QueryOptions() *SomeQuery1QueryOptions

NewSomeQuery1QueryOptions initializes a new SomeQuery1QueryOptions value

func (*SomeQuery1QueryOptions) WithActivityOptions

WithActivityOptions can be used to customize the activity options

func (*SomeQuery1QueryOptions) WithHeartbeatInterval

func (opts *SomeQuery1QueryOptions) WithHeartbeatInterval(d time.Duration) *SomeQuery1QueryOptions

WithHeartbeatInterval can be used to customize the activity heartbeat interval

type SomeQuery2QueryHandle

type SomeQuery2QueryHandle interface {
	// Cancel cancels the workflow
	Cancel(workflow.Context) error
	// Future returns the inner workflow.Future
	Future() workflow.Future
	// Get returns the inner workflow.Future
	Get(workflow.Context) (*simple.SomeQuery2Response, error)
}

SomeQuery2QueryHandle provides a handle for a SomeQuery2 query activity

func SomeQuery2Async

func SomeQuery2Async(ctx workflow.Context, workflowID string, runID string, req *simple.SomeQuery2Request, opts ...*SomeQuery2QueryOptions) (SomeQuery2QueryHandle, error)

SomeQuery2 queries some thing.

type SomeQuery2QueryOptions

type SomeQuery2QueryOptions struct {
	ActivityOptions   *workflow.ActivityOptions
	HeartbeatInterval time.Duration
}

SomeQuery2QueryOptions are used to configure a(n) mycompany.simple.Simple.SomeQuery2 query execution

func NewSomeQuery2QueryOptions

func NewSomeQuery2QueryOptions() *SomeQuery2QueryOptions

NewSomeQuery2QueryOptions initializes a new SomeQuery2QueryOptions value

func (*SomeQuery2QueryOptions) WithActivityOptions

WithActivityOptions can be used to customize the activity options

func (*SomeQuery2QueryOptions) WithHeartbeatInterval

func (opts *SomeQuery2QueryOptions) WithHeartbeatInterval(d time.Duration) *SomeQuery2QueryOptions

WithHeartbeatInterval can be used to customize the activity heartbeat interval

type SomeSignal1SignalHandle

type SomeSignal1SignalHandle interface {
	// Cancel cancels the workflow
	Cancel(workflow.Context) error
	// Future returns the inner workflow.Future
	Future() workflow.Future
	// Get returns the inner workflow.Future
	Get(workflow.Context) error
}

SomeSignal1SignalHandle provides a handle for a SomeSignal1 signal activity

func SomeSignal1Async

func SomeSignal1Async(ctx workflow.Context, workflowID string, runID string, opts ...*SomeSignal1SignalOptions) (SomeSignal1SignalHandle, error)

SomeSignal1 is a signal.

type SomeSignal1SignalOptions

type SomeSignal1SignalOptions struct {
	ActivityOptions   *workflow.ActivityOptions
	HeartbeatInterval time.Duration
}

SomeSignal1SignalOptions are used to configure a(n) mycompany.simple.Simple.SomeSignal1 signal execution

func NewSomeSignal1SignalOptions

func NewSomeSignal1SignalOptions() *SomeSignal1SignalOptions

NewSomeSignal1SignalOptions initializes a new SomeSignal1SignalOptions value

func (*SomeSignal1SignalOptions) WithActivityOptions

WithActivityOptions can be used to customize the activity options

func (*SomeSignal1SignalOptions) WithHeartbeatInterval

func (opts *SomeSignal1SignalOptions) WithHeartbeatInterval(d time.Duration) *SomeSignal1SignalOptions

WithHeartbeatInterval can be used to customize the activity heartbeat interval

type SomeSignal2SignalHandle

type SomeSignal2SignalHandle interface {
	// Cancel cancels the workflow
	Cancel(workflow.Context) error
	// Future returns the inner workflow.Future
	Future() workflow.Future
	// Get returns the inner workflow.Future
	Get(workflow.Context) error
}

SomeSignal2SignalHandle provides a handle for a SomeSignal2 signal activity

func SomeSignal2Async

func SomeSignal2Async(ctx workflow.Context, workflowID string, runID string, req *simple.SomeSignal2Request, opts ...*SomeSignal2SignalOptions) (SomeSignal2SignalHandle, error)

SomeSignal2 is a signal.

type SomeSignal2SignalOptions

type SomeSignal2SignalOptions struct {
	ActivityOptions   *workflow.ActivityOptions
	HeartbeatInterval time.Duration
}

SomeSignal2SignalOptions are used to configure a(n) mycompany.simple.Simple.SomeSignal2 signal execution

func NewSomeSignal2SignalOptions

func NewSomeSignal2SignalOptions() *SomeSignal2SignalOptions

NewSomeSignal2SignalOptions initializes a new SomeSignal2SignalOptions value

func (*SomeSignal2SignalOptions) WithActivityOptions

WithActivityOptions can be used to customize the activity options

func (*SomeSignal2SignalOptions) WithHeartbeatInterval

func (opts *SomeSignal2SignalOptions) WithHeartbeatInterval(d time.Duration) *SomeSignal2SignalOptions

WithHeartbeatInterval can be used to customize the activity heartbeat interval

type SomeSignal3SignalHandle

type SomeSignal3SignalHandle interface {
	// Cancel cancels the workflow
	Cancel(workflow.Context) error
	// Future returns the inner workflow.Future
	Future() workflow.Future
	// Get returns the inner workflow.Future
	Get(workflow.Context) error
}

SomeSignal3SignalHandle provides a handle for a SomeSignal3 signal activity

func SomeSignal3Async

func SomeSignal3Async(ctx workflow.Context, workflowID string, runID string, req *simple.SomeSignal3Request, opts ...*SomeSignal3SignalOptions) (SomeSignal3SignalHandle, error)

SomeSignal3 is a signal.

type SomeSignal3SignalOptions

type SomeSignal3SignalOptions struct {
	ActivityOptions   *workflow.ActivityOptions
	HeartbeatInterval time.Duration
}

SomeSignal3SignalOptions are used to configure a(n) mycompany.simple.Simple.SomeSignal3 signal execution

func NewSomeSignal3SignalOptions

func NewSomeSignal3SignalOptions() *SomeSignal3SignalOptions

NewSomeSignal3SignalOptions initializes a new SomeSignal3SignalOptions value

func (*SomeSignal3SignalOptions) WithActivityOptions

WithActivityOptions can be used to customize the activity options

func (*SomeSignal3SignalOptions) WithHeartbeatInterval

func (opts *SomeSignal3SignalOptions) WithHeartbeatInterval(d time.Duration) *SomeSignal3SignalOptions

WithHeartbeatInterval can be used to customize the activity heartbeat interval

type SomeUpdate1Handle

type SomeUpdate1Handle interface {
	// Cancel cancels the update activity
	Cancel(workflow.Context) error
	// Future returns the inner workflow.Future
	Future() workflow.Future
	// Get blocks on update completion and returns the result
	Get(workflow.Context) (*simple.SomeUpdate1Response, error)
	// ID returns the update id
	ID() string
}

SomeUpdate1Handle provides a handle to a SomeUpdate1 workflow update

func SomeUpdate1Async

func SomeUpdate1Async(ctx workflow.Context, workflowID string, runID string, req *simple.SomeUpdate1Request, opts ...*SomeUpdate1UpdateOptions) (SomeUpdate1Handle, error)

SomeUpdate1 updates a SomeWorkflow2

type SomeUpdate1UpdateOptions

type SomeUpdate1UpdateOptions struct {
	ActivityOptions       *workflow.ActivityOptions
	HeartbeatInterval     time.Duration
	UpdateWorkflowOptions *client.UpdateWorkflowWithOptionsRequest
}

SomeUpdate1UpdateOptions are used to configure a(n) SomeUpdate1 update execution

func NewSomeUpdate1UpdateOptions

func NewSomeUpdate1UpdateOptions() *SomeUpdate1UpdateOptions

NewSomeUpdate1UpdateOptions initializes a new SomeUpdate1UpdateOptions value

func (*SomeUpdate1UpdateOptions) WithActivityOptions

WithActivityOptions can be used to customize the activity options

func (*SomeUpdate1UpdateOptions) WithHeartbeatInterval

func (opts *SomeUpdate1UpdateOptions) WithHeartbeatInterval(d time.Duration) *SomeUpdate1UpdateOptions

WithHeartbeatInterval can be used to customize the activity heartbeat interval

func (*SomeUpdate1UpdateOptions) WithUpdateWorkflowOptions

WithUpdateWorkflowOptions can be used to customize the update workflow options

type SomeWorkflow1Run

type SomeWorkflow1Run interface {
	// Cancel cancels the workflow
	Cancel(workflow.Context) error
	// Future returns the inner workflow.Future
	Future() workflow.Future
	// Get returns the inner workflow.Future
	Get(workflow.Context) (*simple.SomeWorkflow1Response, error)
	// ID returns the workflow id
	ID() string
	// SomeQuery1 queries some thing.
	SomeQuery1(workflow.Context, ...*SomeQuery1QueryOptions) (*simple.SomeQuery1Response, error)
	// SomeQuery1 queries some thing.
	SomeQuery1Async(workflow.Context, ...*SomeQuery1QueryOptions) (SomeQuery1QueryHandle, error)
	// SomeQuery2 queries some thing.
	SomeQuery2(workflow.Context, *simple.SomeQuery2Request, ...*SomeQuery2QueryOptions) (*simple.SomeQuery2Response, error)
	// SomeQuery2 queries some thing.
	SomeQuery2Async(workflow.Context, *simple.SomeQuery2Request, ...*SomeQuery2QueryOptions) (SomeQuery2QueryHandle, error)
	// SomeSignal1 is a signal.
	SomeSignal1(workflow.Context, ...*SomeSignal1SignalOptions) error
	// SomeSignal1 is a signal.
	SomeSignal1Async(workflow.Context, ...*SomeSignal1SignalOptions) (SomeSignal1SignalHandle, error)
	// SomeSignal2 is a signal.
	SomeSignal2(workflow.Context, *simple.SomeSignal2Request, ...*SomeSignal2SignalOptions) error
	// SomeSignal2 is a signal.
	SomeSignal2Async(workflow.Context, *simple.SomeSignal2Request, ...*SomeSignal2SignalOptions) (SomeSignal2SignalHandle, error)
}

SomeWorkflow1Run provides a handle to a SomeWorkflow1 workflow execution

func SomeWorkflow1Async

SomeWorkflow1 does some workflow thing.

type SomeWorkflow1WorkflowOptions

type SomeWorkflow1WorkflowOptions struct {
	ActivityOptions      *workflow.ActivityOptions
	Detached             bool
	HeartbeatInterval    time.Duration
	StartWorkflowOptions *client.StartWorkflowOptions
}

SomeWorkflow1WorkflowOptions are used to configure a(n) SomeWorkflow1 workflow execution

func NewSomeWorkflow1WorkflowOptions

func NewSomeWorkflow1WorkflowOptions() *SomeWorkflow1WorkflowOptions

NewSomeWorkflow1WorkflowOptions initializes a new SomeWorkflow1WorkflowOptions value

func (*SomeWorkflow1WorkflowOptions) WithActivityOptions

WithActivityOptions can be used to customize the activity options

func (*SomeWorkflow1WorkflowOptions) WithDetached

WithDetached can be used to start a workflow execution and exit immediately

func (*SomeWorkflow1WorkflowOptions) WithHeartbeatInterval

WithHeartbeatInterval can be used to customize the activity heartbeat interval

func (*SomeWorkflow1WorkflowOptions) WithStartWorkflow

WithStartWorkflowOptions can be used to customize the start workflow options

type SomeWorkflow2Run

type SomeWorkflow2Run interface {
	// Cancel cancels the workflow
	Cancel(workflow.Context) error
	// Future returns the inner workflow.Future
	Future() workflow.Future
	// Get returns the inner workflow.Future
	Get(workflow.Context) error
	// ID returns the workflow id
	ID() string
	// SomeSignal1 is a signal.
	SomeSignal1(workflow.Context, ...*SomeSignal1SignalOptions) error
	// SomeSignal1 is a signal.
	SomeSignal1Async(workflow.Context, ...*SomeSignal1SignalOptions) (SomeSignal1SignalHandle, error)
	// SomeUpdate1 updates a SomeWorkflow2
	SomeUpdate1(workflow.Context, *simple.SomeUpdate1Request, ...*SomeUpdate1UpdateOptions) (*simple.SomeUpdate1Response, error)
	// SomeUpdate1 updates a SomeWorkflow2
	SomeUpdate1Async(workflow.Context, *simple.SomeUpdate1Request, ...*SomeUpdate1UpdateOptions) (SomeUpdate1Handle, error)
}

SomeWorkflow2Run provides a handle to a SomeWorkflow2 workflow execution

func SomeWorkflow2Async

func SomeWorkflow2Async(ctx workflow.Context, opts ...*SomeWorkflow2WorkflowOptions) (SomeWorkflow2Run, error)

SomeWorkflow2 does some workflow thing.

func SomeWorkflow2WithSomeSignal1Async

func SomeWorkflow2WithSomeSignal1Async(ctx workflow.Context, opts ...*SomeWorkflow2WorkflowOptions) (SomeWorkflow2Run, error)

SomeWorkflow2 does some workflow thing.

type SomeWorkflow2WorkflowOptions

type SomeWorkflow2WorkflowOptions struct {
	ActivityOptions      *workflow.ActivityOptions
	Detached             bool
	HeartbeatInterval    time.Duration
	StartWorkflowOptions *client.StartWorkflowOptions
}

SomeWorkflow2WorkflowOptions are used to configure a(n) SomeWorkflow2 workflow execution

func NewSomeWorkflow2WorkflowOptions

func NewSomeWorkflow2WorkflowOptions() *SomeWorkflow2WorkflowOptions

NewSomeWorkflow2WorkflowOptions initializes a new SomeWorkflow2WorkflowOptions value

func (*SomeWorkflow2WorkflowOptions) WithActivityOptions

WithActivityOptions can be used to customize the activity options

func (*SomeWorkflow2WorkflowOptions) WithDetached

WithDetached can be used to start a workflow execution and exit immediately

func (*SomeWorkflow2WorkflowOptions) WithHeartbeatInterval

WithHeartbeatInterval can be used to customize the activity heartbeat interval

func (*SomeWorkflow2WorkflowOptions) WithStartWorkflow

WithStartWorkflowOptions can be used to customize the start workflow options

type SomeWorkflow3Run

type SomeWorkflow3Run interface {
	// Cancel cancels the workflow
	Cancel(workflow.Context) error
	// Future returns the inner workflow.Future
	Future() workflow.Future
	// Get returns the inner workflow.Future
	Get(workflow.Context) error
	// ID returns the workflow id
	ID() string
	// SomeSignal2 is a signal.
	SomeSignal2(workflow.Context, *simple.SomeSignal2Request, ...*SomeSignal2SignalOptions) error
	// SomeSignal2 is a signal.
	SomeSignal2Async(workflow.Context, *simple.SomeSignal2Request, ...*SomeSignal2SignalOptions) (SomeSignal2SignalHandle, error)
}

SomeWorkflow3Run provides a handle to a SomeWorkflow3 workflow execution

func SomeWorkflow3Async

SomeWorkflow3 does some workflow thing.

func SomeWorkflow3WithSomeSignal2Async

func SomeWorkflow3WithSomeSignal2Async(ctx workflow.Context, req *simple.SomeWorkflow3Request, signal *simple.SomeSignal2Request, opts ...*SomeWorkflow3WorkflowOptions) (SomeWorkflow3Run, error)

SomeWorkflow3 does some workflow thing.

type SomeWorkflow3WorkflowOptions

type SomeWorkflow3WorkflowOptions struct {
	ActivityOptions      *workflow.ActivityOptions
	Detached             bool
	HeartbeatInterval    time.Duration
	StartWorkflowOptions *client.StartWorkflowOptions
}

SomeWorkflow3WorkflowOptions are used to configure a(n) SomeWorkflow3 workflow execution

func NewSomeWorkflow3WorkflowOptions

func NewSomeWorkflow3WorkflowOptions() *SomeWorkflow3WorkflowOptions

NewSomeWorkflow3WorkflowOptions initializes a new SomeWorkflow3WorkflowOptions value

func (*SomeWorkflow3WorkflowOptions) WithActivityOptions

WithActivityOptions can be used to customize the activity options

func (*SomeWorkflow3WorkflowOptions) WithDetached

WithDetached can be used to start a workflow execution and exit immediately

func (*SomeWorkflow3WorkflowOptions) WithHeartbeatInterval

WithHeartbeatInterval can be used to customize the activity heartbeat interval

func (*SomeWorkflow3WorkflowOptions) WithStartWorkflow

WithStartWorkflowOptions can be used to customize the start workflow options

type WhatRun

type WhatRun interface {
	// Cancel cancels the workflow
	Cancel(workflow.Context) error
	// Future returns the inner workflow.Future
	Future() workflow.Future
	// Get returns the inner workflow.Future
	Get(workflow.Context) error
	// ID returns the workflow id
	ID() string
}

WhatRun provides a handle to a What workflow execution

func WhatAsync

func WhatAsync(ctx workflow.Context, req *simple.WhatRequest, opts ...*WhatWorkflowOptions) (WhatRun, error)

WhatAsync executes a(n) mycompany.simple.Ignored.What workflow and blocks until error or response received

type WhatWorkflowOptions

type WhatWorkflowOptions struct {
	ActivityOptions      *workflow.ActivityOptions
	Detached             bool
	HeartbeatInterval    time.Duration
	StartWorkflowOptions *client.StartWorkflowOptions
}

WhatWorkflowOptions are used to configure a(n) What workflow execution

func NewWhatWorkflowOptions

func NewWhatWorkflowOptions() *WhatWorkflowOptions

NewWhatWorkflowOptions initializes a new WhatWorkflowOptions value

func (*WhatWorkflowOptions) WithActivityOptions

func (opts *WhatWorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *WhatWorkflowOptions

WithActivityOptions can be used to customize the activity options

func (*WhatWorkflowOptions) WithDetached

func (opts *WhatWorkflowOptions) WithDetached(d bool) *WhatWorkflowOptions

WithDetached can be used to start a workflow execution and exit immediately

func (*WhatWorkflowOptions) WithHeartbeatInterval

func (opts *WhatWorkflowOptions) WithHeartbeatInterval(d time.Duration) *WhatWorkflowOptions

WithHeartbeatInterval can be used to customize the activity heartbeat interval

func (*WhatWorkflowOptions) WithStartWorkflow

WithStartWorkflowOptions can be used to customize the start workflow options

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL