simple

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: Mar 9, 2023 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	SomeWorkflow2Name = "mycompany.simple.Simple.SomeWorkflow2"
	SomeWorkflow3Name = "mycompany.simple.Simple.SomeWorkflow3"
	SomeWorkflow1Name = "mycompany.simple.Simple.SomeWorkflow1"
)

Simple workflow names

View Source
const (
	SomeQuery1Name = "mycompany.simple.Simple.SomeQuery1"
	SomeQuery2Name = "mycompany.simple.Simple.SomeQuery2"
)

Simple query names

View Source
const (
	SomeSignal2Name = "mycompany.simple.Simple.SomeSignal2"
	SomeSignal1Name = "mycompany.simple.Simple.SomeSignal1"
)

Simple signal names

View Source
const (
	SomeActivity1Name = "mycompany.simple.Simple.SomeActivity1"
	SomeActivity2Name = "mycompany.simple.Simple.SomeActivity2"
	SomeActivity3Name = "mycompany.simple.Simple.SomeActivity3"
)

Simple activity names

View Source
const (
	SomeWorkflow3IDPrefix = "some-workflow-3"
)

Simple id prefixes

Variables

View Source
var File_simple_simple_proto protoreflect.FileDescriptor

Functions

func RegisterActivities

func RegisterActivities(r worker.Registry, activities Activities)

RegisterActivities registers activities with a worker

func RegisterSomeActivity1

func RegisterSomeActivity1(r worker.Registry, fn func(context.Context) error)

RegisterSomeActivity1 registers a SomeActivity1 activity

func RegisterSomeActivity2

func RegisterSomeActivity2(r worker.Registry, fn func(context.Context, *SomeActivity2Request) error)

RegisterSomeActivity2 registers a SomeActivity2 activity

func RegisterSomeActivity3

func RegisterSomeActivity3(r worker.Registry, fn func(context.Context, *SomeActivity3Request) (*SomeActivity3Response, error))

RegisterSomeActivity3 registers a SomeActivity3 activity

func RegisterSomeWorkflow1

func RegisterSomeWorkflow1(r worker.Registry, wf func(workflow.Context, *SomeWorkflow1Input) (SomeWorkflow1, error))

RegisterSomeWorkflow1 registers a SomeWorkflow1 workflow with the given worker

func RegisterSomeWorkflow2

func RegisterSomeWorkflow2(r worker.Registry, wf func(workflow.Context, *SomeWorkflow2Input) (SomeWorkflow2, error))

RegisterSomeWorkflow2 registers a SomeWorkflow2 workflow with the given worker

func RegisterSomeWorkflow3

func RegisterSomeWorkflow3(r worker.Registry, wf func(workflow.Context, *SomeWorkflow3Input) (SomeWorkflow3, error))

RegisterSomeWorkflow3 registers a SomeWorkflow3 workflow with the given worker

func RegisterWorkflows

func RegisterWorkflows(r worker.Registry, workflows Workflows)

RegisterWorkflows registers Simple workflows with the given worker

func SomeSignal1External

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

SomeSignal1External sends a SomeSignal1 signal to an existing workflow

func SomeSignal2External

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

SomeSignal2External sends a SomeSignal2 signal to an existing workflow

Types

type Activities

type Activities interface {
	// 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)
	// SomeActivity1 does some activity thing.
	SomeActivity1(ctx context.Context) error
}

Activities describes available worker activites

type Client

type Client interface {
	// ExecuteSomeWorkflow1 executes a SomeWorkflow1 workflow
	ExecuteSomeWorkflow1(ctx context.Context, opts *client.StartWorkflowOptions, req *SomeWorkflow1Request) (SomeWorkflow1Run, error)
	// GetSomeWorkflow1 retrieves a SomeWorkflow1 workflow execution
	GetSomeWorkflow1(ctx context.Context, workflowID string, runID string) (SomeWorkflow1Run, error)
	// ExecuteSomeWorkflow2 executes a SomeWorkflow2 workflow
	ExecuteSomeWorkflow2(ctx context.Context, opts *client.StartWorkflowOptions) (SomeWorkflow2Run, error)
	// GetSomeWorkflow2 retrieves a SomeWorkflow2 workflow execution
	GetSomeWorkflow2(ctx context.Context, workflowID string, runID string) (SomeWorkflow2Run, error)
	// StartSomeWorkflow2WithSomeSignal1 sends a SomeSignal1 signal to a SomeWorkflow2 workflow, starting it if not present
	StartSomeWorkflow2WithSomeSignal1(ctx context.Context, opts *client.StartWorkflowOptions) (SomeWorkflow2Run, error)
	// ExecuteSomeWorkflow3 executes a SomeWorkflow3 workflow
	ExecuteSomeWorkflow3(ctx context.Context, opts *client.StartWorkflowOptions, req *SomeWorkflow3Request) (SomeWorkflow3Run, error)
	// GetSomeWorkflow3 retrieves a SomeWorkflow3 workflow execution
	GetSomeWorkflow3(ctx context.Context, workflowID string, runID string) (SomeWorkflow3Run, error)
	// StartSomeWorkflow3WithSomeSignal2 sends a SomeSignal2 signal to a SomeWorkflow3 workflow, starting it if not present
	StartSomeWorkflow3WithSomeSignal2(ctx context.Context, opts *client.StartWorkflowOptions, req *SomeWorkflow3Request, signal *SomeSignal2Request) (SomeWorkflow3Run, error)
	// SomeQuery1ends a SomeQuery1 query to an existing workflow
	SomeQuery1(ctx context.Context, workflowID string, runID string) (*SomeQuery1Response, error)
	// SomeQuery2ends a SomeQuery2 query to an existing workflow
	SomeQuery2(ctx context.Context, workflowID string, runID string, query *SomeQuery2Request) (*SomeQuery2Response, error)
	// SomeSignal1ends a SomeSignal1 signal to an existing workflow
	SomeSignal1(ctx context.Context, workflowID string, runID string) error
	// SomeSignal2ends a SomeSignal2 signal to an existing workflow
	SomeSignal2(ctx context.Context, workflowID string, runID string, signal *SomeSignal2Request) error
}

Client describes a client for a Simple worker

func NewClient

func NewClient(c client.Client) Client

NewClient initializes a new Simple client

type SomeActivity1Future

type SomeActivity1Future struct {
	Future workflow.Future
}

SomeActivity1Future describes a SomeActivity1 activity execution

func SomeActivity1

func SomeActivity1(ctx workflow.Context, opts *workflow.ActivityOptions) *SomeActivity1Future

SomeActivity1 does some activity thing.

func SomeActivity1Local

func SomeActivity1Local(ctx workflow.Context, opts *workflow.LocalActivityOptions, fn func(context.Context) error) *SomeActivity1Future

SomeActivity1 does some activity thing.

func (*SomeActivity1Future) Get

Get blocks on a SomeActivity1 execution, returning the response

func (*SomeActivity1Future) Select

Select adds the SomeActivity1 completion to the selector, callback can be nil

type SomeActivity2Future

type SomeActivity2Future struct {
	Future workflow.Future
}

SomeActivity2Future describes a SomeActivity2 activity execution

func SomeActivity2

SomeActivity2 does some activity thing.

func SomeActivity2Local

SomeActivity2 does some activity thing.

func (*SomeActivity2Future) Get

Get blocks on a SomeActivity2 execution, returning the response

func (*SomeActivity2Future) Select

Select adds the SomeActivity2 completion to the selector, callback can be nil

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 SomeActivity3Future

type SomeActivity3Future struct {
	Future workflow.Future
}

SomeActivity3Future describes a SomeActivity3 activity execution

func SomeActivity3

SomeActivity3 does some activity thing.

func SomeActivity3Local

SomeActivity3 does some activity thing.

func (*SomeActivity3Future) Get

Get blocks on a SomeActivity3 execution, returning the response

func (*SomeActivity3Future) Select

Select adds the SomeActivity3 completion to the selector, callback can be nil

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 (*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 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 (*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 SomeSignal1

type SomeSignal1 struct {
	Channel workflow.ReceiveChannel
}

SomeSignal1 describes a SomeSignal1 signal

func (*SomeSignal1) Receive

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

Receive blocks until a SomeSignal1 signal is received

func (*SomeSignal1) ReceiveAsync

func (s *SomeSignal1) ReceiveAsync() bool

ReceiveAsync checks for a SomeSignal1 signal without blocking

func (*SomeSignal1) Select

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

Select checks for a SomeSignal1 signal without blocking

type SomeSignal2

type SomeSignal2 struct {
	Channel workflow.ReceiveChannel
}

SomeSignal2 describes a SomeSignal2 signal

func (*SomeSignal2) Receive

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

Receive blocks until a SomeSignal2 signal is received

func (*SomeSignal2) ReceiveAsync

func (s *SomeSignal2) ReceiveAsync() *SomeSignal2Request

ReceiveAsync checks for a SomeSignal2 signal without blocking

func (*SomeSignal2) Select

Select checks for a SomeSignal2 signal without blocking

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 (*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 SomeWorkflow1

type SomeWorkflow1 interface {
	// Execute a SomeWorkflow1 workflow
	Execute(ctx workflow.Context) (*SomeWorkflow1Response, error)
	// SomeQuery1 query handler
	SomeQuery1() (*SomeQuery1Response, error)
	// SomeQuery2 query handler
	SomeQuery2(*SomeQuery2Request) (*SomeQuery2Response, error)
}

SomeWorkflow1 describes a SomeWorkflow1 workflow implementation

type SomeWorkflow1ChildRun

type SomeWorkflow1ChildRun struct {
	Future workflow.ChildWorkflowFuture
}

SomeWorkflow1ChildRun describes a child SomeWorkflow1 workflow run

func SomeWorkflow1Child

SomeWorkflow1Child executes a child SomeWorkflow1 workflow

func (*SomeWorkflow1ChildRun) Get

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

func (*SomeWorkflow1ChildRun) Select

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

func (*SomeWorkflow1ChildRun) SelectStart

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

func (*SomeWorkflow1ChildRun) SomeSignal1

SomeSignal1 sends the corresponding signal request to the child workflow

func (*SomeWorkflow1ChildRun) SomeSignal2

SomeSignal2 sends the corresponding signal request to the child workflow

func (*SomeWorkflow1ChildRun) WaitStart

WaitStart waits for the child workflow to start

type SomeWorkflow1Input

type SomeWorkflow1Input struct {
	Req         *SomeWorkflow1Request
	SomeSignal1 *SomeSignal1
	SomeSignal2 *SomeSignal2
}

SomeWorkflow1Input describes the input to a SomeWorkflow1 workflow constructor

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 (*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 (*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
	// Get blocks until the workflow is complete and returns the result
	Get(ctx context.Context) (*SomeWorkflow1Response, error)
	// SomeQuery1 runs the SomeQuery1 query against the workflow
	SomeQuery1(ctx context.Context) (*SomeQuery1Response, error)
	// SomeQuery2 runs the SomeQuery2 query against the workflow
	SomeQuery2(ctx context.Context, req *SomeQuery2Request) (*SomeQuery2Response, error)
	// SomeSignal1 sends a SomeSignal1 signal to the workflow
	SomeSignal1(ctx context.Context) error
	// SomeSignal2 sends a SomeSignal2 signal to the workflow
	SomeSignal2(ctx context.Context, req *SomeSignal2Request) error
}

SomeWorkflow1Run describes a SomeWorkflow1 workflow run

type SomeWorkflow2

type SomeWorkflow2 interface {
	// Execute a SomeWorkflow2 workflow
	Execute(ctx workflow.Context) error
}

SomeWorkflow2 describes a SomeWorkflow2 workflow implementation

type SomeWorkflow2ChildRun

type SomeWorkflow2ChildRun struct {
	Future workflow.ChildWorkflowFuture
}

SomeWorkflow2ChildRun describes a child SomeWorkflow2 workflow run

func SomeWorkflow2Child

SomeWorkflow2Child executes a child SomeWorkflow2 workflow

func (*SomeWorkflow2ChildRun) Get

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

func (*SomeWorkflow2ChildRun) Select

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

func (*SomeWorkflow2ChildRun) SelectStart

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

func (*SomeWorkflow2ChildRun) SomeSignal1

SomeSignal1 sends the corresponding signal request to the child workflow

func (*SomeWorkflow2ChildRun) WaitStart

WaitStart waits for the child workflow to start

type SomeWorkflow2Input

type SomeWorkflow2Input struct {
	SomeSignal1 *SomeSignal1
}

SomeWorkflow2Input describes the input to a SomeWorkflow2 workflow constructor

type SomeWorkflow2Run

type SomeWorkflow2Run interface {
	// ID returns the workflow ID
	ID() string
	// RunID returns the workflow instance ID
	RunID() string
	// Get blocks until the workflow is complete and returns the result
	Get(ctx context.Context) error
	// SomeSignal1 sends a SomeSignal1 signal to the workflow
	SomeSignal1(ctx context.Context) error
}

SomeWorkflow2Run describes a SomeWorkflow2 workflow run

type SomeWorkflow3

type SomeWorkflow3 interface {
	// Execute a SomeWorkflow3 workflow
	Execute(ctx workflow.Context) error
}

SomeWorkflow3 describes a SomeWorkflow3 workflow implementation

type SomeWorkflow3ChildRun

type SomeWorkflow3ChildRun struct {
	Future workflow.ChildWorkflowFuture
}

SomeWorkflow3ChildRun describes a child SomeWorkflow3 workflow run

func SomeWorkflow3Child

SomeWorkflow3Child executes a child SomeWorkflow3 workflow

func (*SomeWorkflow3ChildRun) Get

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

func (*SomeWorkflow3ChildRun) Select

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

func (*SomeWorkflow3ChildRun) SelectStart

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

func (*SomeWorkflow3ChildRun) SomeSignal2

SomeSignal2 sends the corresponding signal request to the child workflow

func (*SomeWorkflow3ChildRun) WaitStart

WaitStart waits for the child workflow to start

type SomeWorkflow3Input

type SomeWorkflow3Input struct {
	Req         *SomeWorkflow3Request
	SomeSignal2 *SomeSignal2
}

SomeWorkflow3Input describes the input to a SomeWorkflow3 workflow constructor

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 (*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
	// Get blocks until the workflow is complete and returns the result
	Get(ctx context.Context) error
	// SomeSignal2 sends a SomeSignal2 signal to the workflow
	SomeSignal2(ctx context.Context, req *SomeSignal2Request) error
}

SomeWorkflow3Run describes a SomeWorkflow3 workflow run

type Workflows

type Workflows interface {
	// SomeWorkflow1 initializes a new SomeWorkflow1Workflow value
	SomeWorkflow1(ctx workflow.Context, input *SomeWorkflow1Input) (SomeWorkflow1, error)
	// SomeWorkflow2 initializes a new SomeWorkflow2Workflow value
	SomeWorkflow2(ctx workflow.Context, input *SomeWorkflow2Input) (SomeWorkflow2, error)
	// SomeWorkflow3 initializes a new SomeWorkflow3Workflow value
	SomeWorkflow3(ctx workflow.Context, input *SomeWorkflow3Input) (SomeWorkflow3, error)
}

Workflows provides methods for initializing new Simple workflow values

Jump to

Keyboard shortcuts

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