simple

package
v0.7.2 Latest Latest
Warning

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

Go to latest
Published: Apr 21, 2023 License: MIT Imports: 15 Imported by: 0

Documentation

Overview

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

protoc-gen-go_temporal 0.7.2-next (564471dd04a8cc92670f5b5a5e23e5f935cb8b8b)
go go1.19.5
protoc (unknown)

source: simple/simple.proto

Index

Constants

View Source
const (
	SomeWorkflow1WorkflowName = "mycompany.simple.Simple.SomeWorkflow1Workflow"
	SomeWorkflow2WorkflowName = "mycompany.simple.Simple.SomeWorkflow2Workflow"
	SomeWorkflow3WorkflowName = "mycompany.simple.Simple.SomeWorkflow3Workflow"
)

Simple workflow names

View Source
const (
	SomeQuery1QueryName = "mycompany.simple.Simple.SomeQuery1Query"
	SomeQuery2QueryName = "mycompany.simple.Simple.SomeQuery2Query"
)

Simple query names

View Source
const (
	SomeSignal1SignalName = "mycompany.simple.Simple.SomeSignal1Signal"
	SomeSignal2SignalName = "mycompany.simple.Simple.SomeSignal2Signal"
)

Simple signal names

View Source
const (
	SomeActivity1ActivityName = "mycompany.simple.Simple.SomeActivity1Activity"
	SomeActivity2ActivityName = "mycompany.simple.Simple.SomeActivity2Activity"
	SomeActivity3ActivityName = "mycompany.simple.Simple.SomeActivity3Activity"
)

Simple activity names

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

SimpleTaskQueue is the default task-queue for a Simple worker

Variables

View Source
var (
	SomeWorkflow1IDExpression = expression.MustParseExpression("some-workflow-1/${!id}/${!uuid_v4()}")
	SomeWorkflow3IDExpression = expression.MustParseExpression("some-workflow-3/${!id}/${!request_val}")
)

Simple id expressions

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

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

RegisterSomeActivity1Activity registers a SomeActivity1 activity

func RegisterSomeActivity2Activity added in v0.4.0

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

RegisterSomeActivity2Activity registers a SomeActivity2 activity

func RegisterSomeActivity3Activity added in v0.4.0

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

RegisterSomeActivity3Activity registers a SomeActivity3 activity

func RegisterSomeWorkflow1Workflow added in v0.4.0

func RegisterSomeWorkflow1Workflow(r worker.Registry, wf func(workflow.Context, *SomeWorkflow1Input) (SomeWorkflow1Workflow, error))

RegisterSomeWorkflow1Workflow registers a SomeWorkflow1 workflow with the given worker

func RegisterSomeWorkflow2Workflow added in v0.4.0

func RegisterSomeWorkflow2Workflow(r worker.Registry, wf func(workflow.Context, *SomeWorkflow2Input) (SomeWorkflow2Workflow, error))

RegisterSomeWorkflow2Workflow registers a SomeWorkflow2 workflow with the given worker

func RegisterSomeWorkflow3Workflow added in v0.4.0

func RegisterSomeWorkflow3Workflow(r worker.Registry, wf func(workflow.Context, *SomeWorkflow3Input) (SomeWorkflow3Workflow, error))

RegisterSomeWorkflow3Workflow 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 {
	// 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)
}

Activities describes available worker activites

type Client

type Client interface {
	// SomeWorkflow1 does some workflow thing.
	SomeWorkflow1(ctx context.Context, opts *client.StartWorkflowOptions, req *SomeWorkflow1Request) (*SomeWorkflow1Response, error)
	// 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)
	// SomeWorkflow2 does some workflow thing.
	SomeWorkflow2(ctx context.Context, opts *client.StartWorkflowOptions) 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)
	// SomeWorkflow3 does some workflow thing.
	SomeWorkflow3(ctx context.Context, opts *client.StartWorkflowOptions, req *SomeWorkflow3Request) 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)
	// QuerySomeQuery1 sends a SomeQuery1 query to an existing workflow
	QuerySomeQuery1(ctx context.Context, workflowID string, runID string) (*SomeQuery1Response, error)
	// QuerySomeQuery2 sends a SomeQuery2 query to an existing workflow
	QuerySomeQuery2(ctx context.Context, workflowID string, runID string, query *SomeQuery2Request) (*SomeQuery2Response, error)
	// SignalSomeSignal1 sends a SomeSignal1 signal to an existing workflow
	SignalSomeSignal1(ctx context.Context, workflowID string, runID string) error
	// SignalSomeSignal2 sends a SomeSignal2 signal to an existing workflow
	SignalSomeSignal2(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

func NewClientWithOptions added in v0.6.0

func NewClientWithOptions(c client.Client, opts client.Options) (Client, error)

NewClientWithOptions initializes a new Simple client with the given options

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

type SomeSignal1Signal struct {
	Channel workflow.ReceiveChannel
}

SomeSignal1Signal describes a SomeSignal1 signal

func (*SomeSignal1Signal) Receive added in v0.7.1

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

Receive blocks until a SomeSignal1 signal is received

func (*SomeSignal1Signal) ReceiveAsync added in v0.7.1

func (s *SomeSignal1Signal) ReceiveAsync() bool

ReceiveAsync checks for a SomeSignal1 signal without blocking

func (*SomeSignal1Signal) Select added in v0.7.1

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

Select checks for a SomeSignal1 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 SomeSignal2Signal added in v0.7.1

type SomeSignal2Signal struct {
	Channel workflow.ReceiveChannel
}

SomeSignal2Signal describes a SomeSignal2 signal

func (*SomeSignal2Signal) Receive added in v0.7.1

Receive blocks until a SomeSignal2 signal is received

func (*SomeSignal2Signal) ReceiveAsync added in v0.7.1

func (s *SomeSignal2Signal) ReceiveAsync() *SomeSignal2Request

ReceiveAsync checks for a SomeSignal2 signal without blocking

func (*SomeSignal2Signal) Select added in v0.7.1

Select checks for a SomeSignal2 signal without blocking

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 *SomeSignal1Signal
	SomeSignal2 *SomeSignal2Signal
}

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"`
	IntField    int32                               `protobuf:"varint,3,opt,name=int_field,json=intField,proto3" json:"int_field,omitempty"`
	BoolField   bool                                `protobuf:"varint,4,opt,name=bool_field,json=boolField,proto3" json:"bool_field,omitempty"`
	BytesField  []byte                              `protobuf:"bytes,5,opt,name=bytes_field,json=bytesField,proto3" json:"bytes_field,omitempty"`
	DoubleField float64                             `protobuf:"fixed64,6,opt,name=double_field,json=doubleField,proto3" json:"double_field,omitempty"`
	OuterSingle *SomeWorkflow1Request_OuterNested   `protobuf:"bytes,7,opt,name=outer_single,json=outerSingle,proto3" json:"outer_single,omitempty"`
	OuterList   []*SomeWorkflow1Request_OuterNested `protobuf:"bytes,8,rep,name=outer_list,json=outerList,proto3" json:"outer_list,omitempty"`
	// contains filtered or unexported fields
}

func (*SomeWorkflow1Request) Descriptor deprecated

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

Deprecated: Use SomeWorkflow1Request.ProtoReflect.Descriptor instead.

func (*SomeWorkflow1Request) GetBoolField added in v0.7.0

func (x *SomeWorkflow1Request) GetBoolField() bool

func (*SomeWorkflow1Request) GetBytesField added in v0.7.0

func (x *SomeWorkflow1Request) GetBytesField() []byte

func (*SomeWorkflow1Request) GetDoubleField added in v0.7.0

func (x *SomeWorkflow1Request) GetDoubleField() float64

func (*SomeWorkflow1Request) GetId

func (x *SomeWorkflow1Request) GetId() string

func (*SomeWorkflow1Request) GetIntField added in v0.7.0

func (x *SomeWorkflow1Request) GetIntField() int32

func (*SomeWorkflow1Request) GetOuterList added in v0.7.0

func (*SomeWorkflow1Request) GetOuterSingle added in v0.7.0

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

type SomeWorkflow1Request_OuterNested struct {
	Foo         string                                          `protobuf:"bytes,1,opt,name=foo,proto3" json:"foo,omitempty"`
	InnerSingle *SomeWorkflow1Request_OuterNested_InnerNested   `protobuf:"bytes,2,opt,name=inner_single,json=innerSingle,proto3" json:"inner_single,omitempty"`
	InnerList   []*SomeWorkflow1Request_OuterNested_InnerNested `protobuf:"bytes,3,rep,name=inner_list,json=innerList,proto3" json:"inner_list,omitempty"`
	// contains filtered or unexported fields
}

func (*SomeWorkflow1Request_OuterNested) Descriptor deprecated added in v0.7.0

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

Deprecated: Use SomeWorkflow1Request_OuterNested.ProtoReflect.Descriptor instead.

func (*SomeWorkflow1Request_OuterNested) GetFoo added in v0.7.0

func (*SomeWorkflow1Request_OuterNested) GetInnerList added in v0.7.0

func (*SomeWorkflow1Request_OuterNested) GetInnerSingle added in v0.7.0

func (*SomeWorkflow1Request_OuterNested) ProtoMessage added in v0.7.0

func (*SomeWorkflow1Request_OuterNested) ProtoMessage()

func (*SomeWorkflow1Request_OuterNested) ProtoReflect added in v0.7.0

func (*SomeWorkflow1Request_OuterNested) Reset added in v0.7.0

func (*SomeWorkflow1Request_OuterNested) String added in v0.7.0

type SomeWorkflow1Request_OuterNested_InnerNested added in v0.7.0

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

func (*SomeWorkflow1Request_OuterNested_InnerNested) Descriptor deprecated added in v0.7.0

Deprecated: Use SomeWorkflow1Request_OuterNested_InnerNested.ProtoReflect.Descriptor instead.

func (*SomeWorkflow1Request_OuterNested_InnerNested) GetBar added in v0.7.0

func (*SomeWorkflow1Request_OuterNested_InnerNested) ProtoMessage added in v0.7.0

func (*SomeWorkflow1Request_OuterNested_InnerNested) ProtoReflect added in v0.7.0

func (*SomeWorkflow1Request_OuterNested_InnerNested) Reset added in v0.7.0

func (*SomeWorkflow1Request_OuterNested_InnerNested) String added in v0.7.0

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

type SomeWorkflow1Workflow 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 does some workflow thing.

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 *SomeSignal1Signal
}

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

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

SomeWorkflow2 does some workflow thing.

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 *SomeSignal2Signal
}

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

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

SomeWorkflow3 does some workflow thing.

type Workflows

type Workflows interface {
	// SomeWorkflow1 initializes a new SomeWorkflow1Workflow value
	SomeWorkflow1(ctx workflow.Context, input *SomeWorkflow1Input) (SomeWorkflow1Workflow, error)
	// SomeWorkflow2 initializes a new SomeWorkflow2Workflow value
	SomeWorkflow2(ctx workflow.Context, input *SomeWorkflow2Input) (SomeWorkflow2Workflow, error)
	// SomeWorkflow3 initializes a new SomeWorkflow3Workflow value
	SomeWorkflow3(ctx workflow.Context, input *SomeWorkflow3Input) (SomeWorkflow3Workflow, 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