Documentation ¶
Index ¶
- Variables
- type QueryRejected
- type WorkflowQuery
- func (*WorkflowQuery) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowQuery) GetHeader() *v1.Header
- func (x *WorkflowQuery) GetQueryArgs() *v1.Payloads
- func (x *WorkflowQuery) GetQueryType() string
- func (*WorkflowQuery) ProtoMessage()
- func (x *WorkflowQuery) ProtoReflect() protoreflect.Message
- func (x *WorkflowQuery) Reset()
- func (x *WorkflowQuery) String() string
- type WorkflowQueryResult
- func (*WorkflowQueryResult) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowQueryResult) GetAnswer() *v1.Payloads
- func (x *WorkflowQueryResult) GetErrorMessage() string
- func (x *WorkflowQueryResult) GetResultType() v11.QueryResultType
- func (*WorkflowQueryResult) ProtoMessage()
- func (x *WorkflowQueryResult) ProtoReflect() protoreflect.Message
- func (x *WorkflowQueryResult) Reset()
- func (x *WorkflowQueryResult) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_temporal_api_query_v1_message_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type QueryRejected ¶
type QueryRejected struct { Status v11.WorkflowExecutionStatus `protobuf:"varint,1,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkflowExecutionStatus" json:"status,omitempty"` // contains filtered or unexported fields }
func (*QueryRejected) Descriptor
deprecated
func (*QueryRejected) Descriptor() ([]byte, []int)
Deprecated: Use QueryRejected.ProtoReflect.Descriptor instead.
func (*QueryRejected) GetStatus ¶
func (x *QueryRejected) GetStatus() v11.WorkflowExecutionStatus
func (*QueryRejected) ProtoMessage ¶
func (*QueryRejected) ProtoMessage()
func (*QueryRejected) ProtoReflect ¶
func (x *QueryRejected) ProtoReflect() protoreflect.Message
func (*QueryRejected) Reset ¶
func (x *QueryRejected) Reset()
func (*QueryRejected) String ¶
func (x *QueryRejected) String() string
type WorkflowQuery ¶
type WorkflowQuery struct { // The workflow-author-defined identifier of the query. Typically a function name. QueryType string `protobuf:"bytes,1,opt,name=query_type,json=queryType,proto3" json:"query_type,omitempty"` // Serialized arguments that will be provided to the query handler. QueryArgs *v1.Payloads `protobuf:"bytes,2,opt,name=query_args,json=queryArgs,proto3" json:"query_args,omitempty"` // Headers that were passed by the caller of the query and copied by temporal // server into the workflow task. Header *v1.Header `protobuf:"bytes,3,opt,name=header,proto3" json:"header,omitempty"` // contains filtered or unexported fields }
See https://docs.temporal.io/docs/concepts/queries/
func (*WorkflowQuery) Descriptor
deprecated
func (*WorkflowQuery) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowQuery.ProtoReflect.Descriptor instead.
func (*WorkflowQuery) GetHeader ¶
func (x *WorkflowQuery) GetHeader() *v1.Header
func (*WorkflowQuery) GetQueryArgs ¶
func (x *WorkflowQuery) GetQueryArgs() *v1.Payloads
func (*WorkflowQuery) GetQueryType ¶
func (x *WorkflowQuery) GetQueryType() string
func (*WorkflowQuery) ProtoMessage ¶
func (*WorkflowQuery) ProtoMessage()
func (*WorkflowQuery) ProtoReflect ¶
func (x *WorkflowQuery) ProtoReflect() protoreflect.Message
func (*WorkflowQuery) Reset ¶
func (x *WorkflowQuery) Reset()
func (*WorkflowQuery) String ¶
func (x *WorkflowQuery) String() string
type WorkflowQueryResult ¶
type WorkflowQueryResult struct { // Did the query succeed or fail? ResultType v11.QueryResultType `` /* 135-byte string literal not displayed */ // Set when the query succeeds with the results Answer *v1.Payloads `protobuf:"bytes,2,opt,name=answer,proto3" json:"answer,omitempty"` // Mutually exclusive with `answer`. Set when the query fails. ErrorMessage string `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` // contains filtered or unexported fields }
Answer to a `WorkflowQuery`
func (*WorkflowQueryResult) Descriptor
deprecated
func (*WorkflowQueryResult) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowQueryResult.ProtoReflect.Descriptor instead.
func (*WorkflowQueryResult) GetAnswer ¶
func (x *WorkflowQueryResult) GetAnswer() *v1.Payloads
func (*WorkflowQueryResult) GetErrorMessage ¶
func (x *WorkflowQueryResult) GetErrorMessage() string
func (*WorkflowQueryResult) GetResultType ¶
func (x *WorkflowQueryResult) GetResultType() v11.QueryResultType
func (*WorkflowQueryResult) ProtoMessage ¶
func (*WorkflowQueryResult) ProtoMessage()
func (*WorkflowQueryResult) ProtoReflect ¶
func (x *WorkflowQueryResult) ProtoReflect() protoreflect.Message
func (*WorkflowQueryResult) Reset ¶
func (x *WorkflowQueryResult) Reset()
func (*WorkflowQueryResult) String ¶
func (x *WorkflowQueryResult) String() string
Click to show internal directories.
Click to hide internal directories.