Documentation
¶
Overview ¶
Code generated by protoc-gen-go_temporal. DO NOT EDIT. versions:
protoc-gen-go_temporal go go1.19.5 protoc (unknown)
source: simple/simple.proto
Index ¶
- Constants
- Variables
- func RegisterActivities(r worker.Registry, activities Activities)
- func RegisterSomeActivity1(r worker.Registry, fn func(context.Context) error)
- func RegisterSomeActivity2(r worker.Registry, fn func(context.Context, *SomeActivity2Request) error)
- func RegisterSomeActivity3(r worker.Registry, ...)
- func RegisterSomeWorkflow1(r worker.Registry, ...)
- func RegisterSomeWorkflow2(r worker.Registry, ...)
- func RegisterSomeWorkflow3(r worker.Registry, ...)
- func RegisterWorkflows(r worker.Registry, workflows Workflows)
- func SomeSignal1External(ctx workflow.Context, workflowID string, runID string) workflow.Future
- func SomeSignal2External(ctx workflow.Context, workflowID string, runID string, req *SomeSignal2Request) workflow.Future
- type Activities
- type Client
- type SomeActivity1Future
- type SomeActivity2Future
- type SomeActivity2Request
- func (*SomeActivity2Request) Descriptor() ([]byte, []int)deprecated
- func (x *SomeActivity2Request) GetRequestVal() string
- func (*SomeActivity2Request) ProtoMessage()
- func (x *SomeActivity2Request) ProtoReflect() protoreflect.Message
- func (x *SomeActivity2Request) Reset()
- func (x *SomeActivity2Request) String() string
- type SomeActivity3Future
- type SomeActivity3Request
- func (*SomeActivity3Request) Descriptor() ([]byte, []int)deprecated
- func (x *SomeActivity3Request) GetRequestVal() string
- func (*SomeActivity3Request) ProtoMessage()
- func (x *SomeActivity3Request) ProtoReflect() protoreflect.Message
- func (x *SomeActivity3Request) Reset()
- func (x *SomeActivity3Request) String() string
- type SomeActivity3Response
- func (*SomeActivity3Response) Descriptor() ([]byte, []int)deprecated
- func (x *SomeActivity3Response) GetResponseVal() string
- func (*SomeActivity3Response) ProtoMessage()
- func (x *SomeActivity3Response) ProtoReflect() protoreflect.Message
- func (x *SomeActivity3Response) Reset()
- func (x *SomeActivity3Response) String() string
- type SomeQuery1Response
- func (*SomeQuery1Response) Descriptor() ([]byte, []int)deprecated
- func (x *SomeQuery1Response) GetResponseVal() string
- func (*SomeQuery1Response) ProtoMessage()
- func (x *SomeQuery1Response) ProtoReflect() protoreflect.Message
- func (x *SomeQuery1Response) Reset()
- func (x *SomeQuery1Response) String() string
- type SomeQuery2Request
- func (*SomeQuery2Request) Descriptor() ([]byte, []int)deprecated
- func (x *SomeQuery2Request) GetRequestVal() string
- func (*SomeQuery2Request) ProtoMessage()
- func (x *SomeQuery2Request) ProtoReflect() protoreflect.Message
- func (x *SomeQuery2Request) Reset()
- func (x *SomeQuery2Request) String() string
- type SomeQuery2Response
- func (*SomeQuery2Response) Descriptor() ([]byte, []int)deprecated
- func (x *SomeQuery2Response) GetResponseVal() string
- func (*SomeQuery2Response) ProtoMessage()
- func (x *SomeQuery2Response) ProtoReflect() protoreflect.Message
- func (x *SomeQuery2Response) Reset()
- func (x *SomeQuery2Response) String() string
- type SomeSignal1
- type SomeSignal2
- type SomeSignal2Request
- func (*SomeSignal2Request) Descriptor() ([]byte, []int)deprecated
- func (x *SomeSignal2Request) GetRequestVal() string
- func (*SomeSignal2Request) ProtoMessage()
- func (x *SomeSignal2Request) ProtoReflect() protoreflect.Message
- func (x *SomeSignal2Request) Reset()
- func (x *SomeSignal2Request) String() string
- type SomeWorkflow1
- type SomeWorkflow1ChildRun
- func (r *SomeWorkflow1ChildRun) Get(ctx workflow.Context) (*SomeWorkflow1Response, error)
- func (r *SomeWorkflow1ChildRun) Select(sel workflow.Selector, fn func(SomeWorkflow1ChildRun)) workflow.Selector
- func (r *SomeWorkflow1ChildRun) SelectStart(sel workflow.Selector, fn func(SomeWorkflow1ChildRun)) workflow.Selector
- func (r *SomeWorkflow1ChildRun) SomeSignal1(ctx workflow.Context) workflow.Future
- func (r *SomeWorkflow1ChildRun) SomeSignal2(ctx workflow.Context, input *SomeSignal2Request) workflow.Future
- func (r *SomeWorkflow1ChildRun) WaitStart(ctx workflow.Context) (*workflow.Execution, error)
- type SomeWorkflow1Input
- type SomeWorkflow1Request
- func (*SomeWorkflow1Request) Descriptor() ([]byte, []int)deprecated
- func (x *SomeWorkflow1Request) GetId() string
- func (x *SomeWorkflow1Request) GetRequestVal() string
- func (*SomeWorkflow1Request) ProtoMessage()
- func (x *SomeWorkflow1Request) ProtoReflect() protoreflect.Message
- func (x *SomeWorkflow1Request) Reset()
- func (x *SomeWorkflow1Request) String() string
- type SomeWorkflow1Response
- func (*SomeWorkflow1Response) Descriptor() ([]byte, []int)deprecated
- func (x *SomeWorkflow1Response) GetResponseVal() string
- func (*SomeWorkflow1Response) ProtoMessage()
- func (x *SomeWorkflow1Response) ProtoReflect() protoreflect.Message
- func (x *SomeWorkflow1Response) Reset()
- func (x *SomeWorkflow1Response) String() string
- type SomeWorkflow1Run
- type SomeWorkflow2
- type SomeWorkflow2ChildRun
- func (r *SomeWorkflow2ChildRun) Get(ctx workflow.Context) error
- func (r *SomeWorkflow2ChildRun) Select(sel workflow.Selector, fn func(SomeWorkflow2ChildRun)) workflow.Selector
- func (r *SomeWorkflow2ChildRun) SelectStart(sel workflow.Selector, fn func(SomeWorkflow2ChildRun)) workflow.Selector
- func (r *SomeWorkflow2ChildRun) SomeSignal1(ctx workflow.Context) workflow.Future
- func (r *SomeWorkflow2ChildRun) WaitStart(ctx workflow.Context) (*workflow.Execution, error)
- type SomeWorkflow2Input
- type SomeWorkflow2Run
- type SomeWorkflow3
- type SomeWorkflow3ChildRun
- func (r *SomeWorkflow3ChildRun) Get(ctx workflow.Context) error
- func (r *SomeWorkflow3ChildRun) Select(sel workflow.Selector, fn func(SomeWorkflow3ChildRun)) workflow.Selector
- func (r *SomeWorkflow3ChildRun) SelectStart(sel workflow.Selector, fn func(SomeWorkflow3ChildRun)) workflow.Selector
- func (r *SomeWorkflow3ChildRun) SomeSignal2(ctx workflow.Context, input *SomeSignal2Request) workflow.Future
- func (r *SomeWorkflow3ChildRun) WaitStart(ctx workflow.Context) (*workflow.Execution, error)
- type SomeWorkflow3Input
- type SomeWorkflow3Request
- func (*SomeWorkflow3Request) Descriptor() ([]byte, []int)deprecated
- func (x *SomeWorkflow3Request) GetId() string
- func (x *SomeWorkflow3Request) GetRequestVal() string
- func (*SomeWorkflow3Request) ProtoMessage()
- func (x *SomeWorkflow3Request) ProtoReflect() protoreflect.Message
- func (x *SomeWorkflow3Request) Reset()
- func (x *SomeWorkflow3Request) String() string
- type SomeWorkflow3Run
- type Workflows
Constants ¶
const ( SomeWorkflow1Name = "mycompany.simple.Simple.SomeWorkflow1" SomeWorkflow2Name = "mycompany.simple.Simple.SomeWorkflow2" SomeWorkflow3Name = "mycompany.simple.Simple.SomeWorkflow3" )
Simple workflow names
const ( SomeQuery1Name = "mycompany.simple.Simple.SomeQuery1" SomeQuery2Name = "mycompany.simple.Simple.SomeQuery2" )
Simple query names
const ( SomeSignal1Name = "mycompany.simple.Simple.SomeSignal1" SomeSignal2Name = "mycompany.simple.Simple.SomeSignal2" )
Simple signal names
const ( SomeActivity1Name = "mycompany.simple.Simple.SomeActivity1" SomeActivity2Name = "mycompany.simple.Simple.SomeActivity2" SomeActivity3Name = "mycompany.simple.Simple.SomeActivity3" )
Simple activity names
const (
SomeWorkflow3IDPrefix = "some-workflow-3"
)
Simple id prefixes
Variables ¶
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 ¶
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 ¶
RegisterWorkflows registers Simple workflows with the given worker
func SomeSignal1External ¶
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 {
// 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
type SomeActivity1Future ¶
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 ¶
func (f *SomeActivity1Future) Get(ctx workflow.Context) error
Get blocks on a SomeActivity1 execution, returning the response
func (*SomeActivity1Future) Select ¶
func (f *SomeActivity1Future) Select(sel workflow.Selector, fn func(*SomeActivity1Future)) workflow.Selector
Select adds the SomeActivity1 completion to the selector, callback can be nil
type SomeActivity2Future ¶
SomeActivity2Future describes a SomeActivity2 activity execution
func SomeActivity2 ¶
func SomeActivity2(ctx workflow.Context, opts *workflow.ActivityOptions, req *SomeActivity2Request) *SomeActivity2Future
SomeActivity2 does some activity thing.
func SomeActivity2Local ¶
func SomeActivity2Local(ctx workflow.Context, opts *workflow.LocalActivityOptions, fn func(context.Context, *SomeActivity2Request) error, req *SomeActivity2Request) *SomeActivity2Future
SomeActivity2 does some activity thing.
func (*SomeActivity2Future) Get ¶
func (f *SomeActivity2Future) Get(ctx workflow.Context) error
Get blocks on a SomeActivity2 execution, returning the response
func (*SomeActivity2Future) Select ¶
func (f *SomeActivity2Future) Select(sel workflow.Selector, fn func(*SomeActivity2Future)) workflow.Selector
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 ¶
SomeActivity3Future describes a SomeActivity3 activity execution
func SomeActivity3 ¶
func SomeActivity3(ctx workflow.Context, opts *workflow.ActivityOptions, req *SomeActivity3Request) *SomeActivity3Future
SomeActivity3 does some activity thing.
func SomeActivity3Local ¶
func SomeActivity3Local(ctx workflow.Context, opts *workflow.LocalActivityOptions, fn func(context.Context, *SomeActivity3Request) (*SomeActivity3Response, error), req *SomeActivity3Request) *SomeActivity3Future
SomeActivity3 does some activity thing.
func (*SomeActivity3Future) Get ¶
func (f *SomeActivity3Future) Get(ctx workflow.Context) (*SomeActivity3Response, error)
Get blocks on a SomeActivity3 execution, returning the response
func (*SomeActivity3Future) Select ¶
func (f *SomeActivity3Future) Select(sel workflow.Selector, fn func(*SomeActivity3Future)) workflow.Selector
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
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 ¶
func (s *SomeSignal2) Select(sel workflow.Selector, fn func(*SomeSignal2Request)) workflow.Selector
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 ¶
func SomeWorkflow1Child(ctx workflow.Context, opts *workflow.ChildWorkflowOptions, req *SomeWorkflow1Request) SomeWorkflow1ChildRun
SomeWorkflow1Child executes a child SomeWorkflow1 workflow
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) workflow.Future
SomeSignal1 sends the corresponding signal request to the child workflow
func (*SomeWorkflow1ChildRun) SomeSignal2 ¶
func (r *SomeWorkflow1ChildRun) SomeSignal2(ctx workflow.Context, input *SomeSignal2Request) workflow.Future
SomeSignal2 sends the corresponding signal request to the child workflow
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 ¶
func SomeWorkflow2Child(ctx workflow.Context, opts *workflow.ChildWorkflowOptions) SomeWorkflow2ChildRun
SomeWorkflow2Child executes a child SomeWorkflow2 workflow
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) workflow.Future
SomeSignal1 sends the corresponding signal request to the child workflow
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 ¶
func SomeWorkflow3Child(ctx workflow.Context, opts *workflow.ChildWorkflowOptions, req *SomeWorkflow3Request) SomeWorkflow3ChildRun
SomeWorkflow3Child executes a child SomeWorkflow3 workflow
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) workflow.Future
SomeSignal2 sends the corresponding signal request to the child workflow
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