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
- Variables
- func RegisterActivities(r worker.Registry, activities Activities)
- func RegisterSomeActivity1Activity(r worker.Registry, fn func(context.Context) error)
- func RegisterSomeActivity2Activity(r worker.Registry, fn func(context.Context, *SomeActivity2Request) error)
- func RegisterSomeActivity3Activity(r worker.Registry, ...)
- func RegisterSomeWorkflow1Workflow(r worker.Registry, ...)
- func RegisterSomeWorkflow2Workflow(r worker.Registry, ...)
- func RegisterSomeWorkflow3Workflow(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 SomeSignal1Signal
- 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 SomeSignal2Signal
- 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) GetBoolField() bool
- func (x *SomeWorkflow1Request) GetBytesField() []byte
- func (x *SomeWorkflow1Request) GetDoubleField() float64
- func (x *SomeWorkflow1Request) GetId() string
- func (x *SomeWorkflow1Request) GetIntField() int32
- func (x *SomeWorkflow1Request) GetOuterList() []*SomeWorkflow1Request_OuterNested
- func (x *SomeWorkflow1Request) GetOuterSingle() *SomeWorkflow1Request_OuterNested
- func (x *SomeWorkflow1Request) GetRequestVal() string
- func (*SomeWorkflow1Request) ProtoMessage()
- func (x *SomeWorkflow1Request) ProtoReflect() protoreflect.Message
- func (x *SomeWorkflow1Request) Reset()
- func (x *SomeWorkflow1Request) String() string
- type SomeWorkflow1Request_OuterNested
- func (*SomeWorkflow1Request_OuterNested) Descriptor() ([]byte, []int)deprecated
- func (x *SomeWorkflow1Request_OuterNested) GetFoo() string
- func (x *SomeWorkflow1Request_OuterNested) GetInnerList() []*SomeWorkflow1Request_OuterNested_InnerNested
- func (x *SomeWorkflow1Request_OuterNested) GetInnerSingle() *SomeWorkflow1Request_OuterNested_InnerNested
- func (*SomeWorkflow1Request_OuterNested) ProtoMessage()
- func (x *SomeWorkflow1Request_OuterNested) ProtoReflect() protoreflect.Message
- func (x *SomeWorkflow1Request_OuterNested) Reset()
- func (x *SomeWorkflow1Request_OuterNested) String() string
- type SomeWorkflow1Request_OuterNested_InnerNested
- func (*SomeWorkflow1Request_OuterNested_InnerNested) Descriptor() ([]byte, []int)deprecated
- func (x *SomeWorkflow1Request_OuterNested_InnerNested) GetBar() string
- func (*SomeWorkflow1Request_OuterNested_InnerNested) ProtoMessage()
- func (x *SomeWorkflow1Request_OuterNested_InnerNested) ProtoReflect() protoreflect.Message
- func (x *SomeWorkflow1Request_OuterNested_InnerNested) Reset()
- func (x *SomeWorkflow1Request_OuterNested_InnerNested) 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 SomeWorkflow1Workflow
- 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 SomeWorkflow2Workflow
- 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 SomeWorkflow3Workflow
- type Workflows
Constants ¶
const ( SomeWorkflow1WorkflowName = "mycompany.simple.Simple.SomeWorkflow1Workflow" SomeWorkflow2WorkflowName = "mycompany.simple.Simple.SomeWorkflow2Workflow" SomeWorkflow3WorkflowName = "mycompany.simple.Simple.SomeWorkflow3Workflow" )
Simple workflow names
const ( SomeQuery1QueryName = "mycompany.simple.Simple.SomeQuery1Query" SomeQuery2QueryName = "mycompany.simple.Simple.SomeQuery2Query" )
Simple query names
const ( SomeSignal1SignalName = "mycompany.simple.Simple.SomeSignal1Signal" SomeSignal2SignalName = "mycompany.simple.Simple.SomeSignal2Signal" )
Simple signal names
const ( SomeActivity1ActivityName = "mycompany.simple.Simple.SomeActivity1Activity" SomeActivity2ActivityName = "mycompany.simple.Simple.SomeActivity2Activity" SomeActivity3ActivityName = "mycompany.simple.Simple.SomeActivity3Activity" )
Simple activity names
const SimpleTaskQueue = "my-task-queue"
SimpleTaskQueue is the default task-queue for a Simple worker
Variables ¶
var ( SomeWorkflow1IDExpression = expression.MustParseExpression("some-workflow-1/${!id}/${!uuid_v4()}") SomeWorkflow3IDExpression = expression.MustParseExpression("some-workflow-3/${!id}/${!request_val}") )
Simple id expressions
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
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 ¶
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 {
// 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
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 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
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
func (s *SomeSignal2Signal) Receive(ctx workflow.Context) (*SomeSignal2Request, bool)
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
func (s *SomeSignal2Signal) Select(sel workflow.Selector, fn func(*SomeSignal2Request)) workflow.Selector
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 ¶
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 *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 (x *SomeWorkflow1Request) GetOuterList() []*SomeWorkflow1Request_OuterNested
func (*SomeWorkflow1Request) GetOuterSingle ¶ added in v0.7.0
func (x *SomeWorkflow1Request) GetOuterSingle() *SomeWorkflow1Request_OuterNested
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 (x *SomeWorkflow1Request_OuterNested) GetFoo() string
func (*SomeWorkflow1Request_OuterNested) GetInnerList ¶ added in v0.7.0
func (x *SomeWorkflow1Request_OuterNested) GetInnerList() []*SomeWorkflow1Request_OuterNested_InnerNested
func (*SomeWorkflow1Request_OuterNested) GetInnerSingle ¶ added in v0.7.0
func (x *SomeWorkflow1Request_OuterNested) GetInnerSingle() *SomeWorkflow1Request_OuterNested_InnerNested
func (*SomeWorkflow1Request_OuterNested) ProtoMessage ¶ added in v0.7.0
func (*SomeWorkflow1Request_OuterNested) ProtoMessage()
func (*SomeWorkflow1Request_OuterNested) ProtoReflect ¶ added in v0.7.0
func (x *SomeWorkflow1Request_OuterNested) ProtoReflect() protoreflect.Message
func (*SomeWorkflow1Request_OuterNested) Reset ¶ added in v0.7.0
func (x *SomeWorkflow1Request_OuterNested) Reset()
func (*SomeWorkflow1Request_OuterNested) String ¶ added in v0.7.0
func (x *SomeWorkflow1Request_OuterNested) String() string
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
func (*SomeWorkflow1Request_OuterNested_InnerNested) Descriptor() ([]byte, []int)
Deprecated: Use SomeWorkflow1Request_OuterNested_InnerNested.ProtoReflect.Descriptor instead.
func (*SomeWorkflow1Request_OuterNested_InnerNested) GetBar ¶ added in v0.7.0
func (x *SomeWorkflow1Request_OuterNested_InnerNested) GetBar() string
func (*SomeWorkflow1Request_OuterNested_InnerNested) ProtoMessage ¶ added in v0.7.0
func (*SomeWorkflow1Request_OuterNested_InnerNested) ProtoMessage()
func (*SomeWorkflow1Request_OuterNested_InnerNested) ProtoReflect ¶ added in v0.7.0
func (x *SomeWorkflow1Request_OuterNested_InnerNested) ProtoReflect() protoreflect.Message
func (*SomeWorkflow1Request_OuterNested_InnerNested) Reset ¶ added in v0.7.0
func (x *SomeWorkflow1Request_OuterNested_InnerNested) Reset()
func (*SomeWorkflow1Request_OuterNested_InnerNested) String ¶ added in v0.7.0
func (x *SomeWorkflow1Request_OuterNested_InnerNested) 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 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 ¶
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 *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 ¶
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 *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