queryv1

Documentation

Index

• Variables
• type QueryRejected
  • func (*QueryRejected) Descriptor() ([]byte, []int)
  • func (x *QueryRejected) GetStatus() v11.WorkflowExecutionStatus
  • func (*QueryRejected) ProtoMessage()
  • func (x *QueryRejected) ProtoReflect() protoreflect.Message
  • func (x *QueryRejected) Reset()
  • func (x *QueryRejected) String() string
• type WorkflowQuery
  • func (*WorkflowQuery) Descriptor() ([]byte, []int)
  • 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)
  • 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

Variables

var File_temporal_api_query_v1_message_proto protoreflect.FileDescriptor

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

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

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

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