query

Documentation

Overview

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Index

• Variables
• type QueryRejected
  • func (*QueryRejected) Descriptor() ([]byte, []int)
  • func (this *QueryRejected) Equal(that interface{}) bool
  • func (x *QueryRejected) GetStatus() v11.WorkflowExecutionStatus
  • func (val *QueryRejected) Marshal() ([]byte, error)
  • func (*QueryRejected) ProtoMessage()
  • func (x *QueryRejected) ProtoReflect() protoreflect.Message
  • func (x *QueryRejected) Reset()
  • func (val *QueryRejected) Size() int
  • func (x *QueryRejected) String() string
  • func (val *QueryRejected) Unmarshal(buf []byte) error
• type WorkflowQuery
  • func (*WorkflowQuery) Descriptor() ([]byte, []int)
  • func (this *WorkflowQuery) Equal(that interface{}) bool
  • func (x *WorkflowQuery) GetHeader() *v1.Header
  • func (x *WorkflowQuery) GetQueryArgs() *v1.Payloads
  • func (x *WorkflowQuery) GetQueryType() string
  • func (val *WorkflowQuery) Marshal() ([]byte, error)
  • func (*WorkflowQuery) ProtoMessage()
  • func (x *WorkflowQuery) ProtoReflect() protoreflect.Message
  • func (x *WorkflowQuery) Reset()
  • func (val *WorkflowQuery) Size() int
  • func (x *WorkflowQuery) String() string
  • func (val *WorkflowQuery) Unmarshal(buf []byte) error
• type WorkflowQueryResult
  • func (*WorkflowQueryResult) Descriptor() ([]byte, []int)
  • func (this *WorkflowQueryResult) Equal(that interface{}) bool
  • func (x *WorkflowQueryResult) GetAnswer() *v1.Payloads
  • func (x *WorkflowQueryResult) GetErrorMessage() string
  • func (x *WorkflowQueryResult) GetResultType() v11.QueryResultType
  • func (val *WorkflowQueryResult) Marshal() ([]byte, error)
  • func (*WorkflowQueryResult) ProtoMessage()
  • func (x *WorkflowQueryResult) ProtoReflect() protoreflect.Message
  • func (x *WorkflowQueryResult) Reset()
  • func (val *WorkflowQueryResult) Size() int
  • func (x *WorkflowQueryResult) String() string
  • func (val *WorkflowQueryResult) Unmarshal(buf []byte) error

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) Equal

func (this *QueryRejected) Equal(that interface{}) bool

Equal returns whether two QueryRejected values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*QueryRejected) GetStatus

func (x *QueryRejected) GetStatus() v11.WorkflowExecutionStatus

func (*QueryRejected) Marshal

func (val *QueryRejected) Marshal() ([]byte, error)

Marshal an object of type QueryRejected to the protobuf v3 wire format

func (*QueryRejected) ProtoMessage

func (*QueryRejected) ProtoMessage()

func (*QueryRejected) ProtoReflect

func (x *QueryRejected) ProtoReflect() protoreflect.Message

func (*QueryRejected) Reset

func (x *QueryRejected) Reset()

func (*QueryRejected) Size

func (val *QueryRejected) Size() int

Size returns the size of the object, in bytes, once serialized

func (*QueryRejected) String

func (x *QueryRejected) String() string

func (*QueryRejected) Unmarshal

func (val *QueryRejected) Unmarshal(buf []byte) error

Unmarshal an object of type QueryRejected from the protobuf v3 wire format

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) Equal

func (this *WorkflowQuery) Equal(that interface{}) bool

Equal returns whether two WorkflowQuery values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

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) Marshal

func (val *WorkflowQuery) Marshal() ([]byte, error)

Marshal an object of type WorkflowQuery to the protobuf v3 wire format

func (*WorkflowQuery) ProtoMessage

func (*WorkflowQuery) ProtoMessage()

func (*WorkflowQuery) ProtoReflect

func (x *WorkflowQuery) ProtoReflect() protoreflect.Message

func (*WorkflowQuery) Reset

func (x *WorkflowQuery) Reset()

func (*WorkflowQuery) Size

func (val *WorkflowQuery) Size() int

Size returns the size of the object, in bytes, once serialized

func (*WorkflowQuery) String

func (x *WorkflowQuery) String() string

func (*WorkflowQuery) Unmarshal

func (val *WorkflowQuery) Unmarshal(buf []byte) error

Unmarshal an object of type WorkflowQuery from the protobuf v3 wire format

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) Equal

func (this *WorkflowQueryResult) Equal(that interface{}) bool

Equal returns whether two WorkflowQueryResult values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

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) Marshal

func (val *WorkflowQueryResult) Marshal() ([]byte, error)

Marshal an object of type WorkflowQueryResult to the protobuf v3 wire format

func (*WorkflowQueryResult) ProtoMessage

func (*WorkflowQueryResult) ProtoMessage()

func (*WorkflowQueryResult) ProtoReflect

func (x *WorkflowQueryResult) ProtoReflect() protoreflect.Message

func (*WorkflowQueryResult) Reset

func (x *WorkflowQueryResult) Reset()

func (*WorkflowQueryResult) Size

func (val *WorkflowQueryResult) Size() int

Size returns the size of the object, in bytes, once serialized

func (*WorkflowQueryResult) String

func (x *WorkflowQueryResult) String() string

func (*WorkflowQueryResult) Unmarshal

func (val *WorkflowQueryResult) Unmarshal(buf []byte) error

Unmarshal an object of type WorkflowQueryResult from the protobuf v3 wire format