query

Documentation

Index

• Variables
• type QueryRejected
  • func (*QueryRejected) Descriptor() ([]byte, []int)
  • func (this *QueryRejected) Equal(that interface{}) bool
  • func (m *QueryRejected) GetStatus() v11.WorkflowExecutionStatus
  • func (this *QueryRejected) GoString() string
  • func (m *QueryRejected) Marshal() (dAtA []byte, err error)
  • func (m *QueryRejected) MarshalTo(dAtA []byte) (int, error)
  • func (m *QueryRejected) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*QueryRejected) ProtoMessage()
  • func (m *QueryRejected) Reset()
  • func (m *QueryRejected) Size() (n int)
  • func (this *QueryRejected) String() string
  • func (m *QueryRejected) Unmarshal(dAtA []byte) error
  • func (m *QueryRejected) XXX_DiscardUnknown()
  • func (m *QueryRejected) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *QueryRejected) XXX_Merge(src proto.Message)
  • func (m *QueryRejected) XXX_Size() int
  • func (m *QueryRejected) XXX_Unmarshal(b []byte) error
• type WorkflowQuery
  • func (*WorkflowQuery) Descriptor() ([]byte, []int)
  • func (this *WorkflowQuery) Equal(that interface{}) bool
  • func (m *WorkflowQuery) GetQueryArgs() *v1.Payloads
  • func (m *WorkflowQuery) GetQueryType() string
  • func (this *WorkflowQuery) GoString() string
  • func (m *WorkflowQuery) Marshal() (dAtA []byte, err error)
  • func (m *WorkflowQuery) MarshalTo(dAtA []byte) (int, error)
  • func (m *WorkflowQuery) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*WorkflowQuery) ProtoMessage()
  • func (m *WorkflowQuery) Reset()
  • func (m *WorkflowQuery) Size() (n int)
  • func (this *WorkflowQuery) String() string
  • func (m *WorkflowQuery) Unmarshal(dAtA []byte) error
  • func (m *WorkflowQuery) XXX_DiscardUnknown()
  • func (m *WorkflowQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *WorkflowQuery) XXX_Merge(src proto.Message)
  • func (m *WorkflowQuery) XXX_Size() int
  • func (m *WorkflowQuery) XXX_Unmarshal(b []byte) error
• type WorkflowQueryResult
  • func (*WorkflowQueryResult) Descriptor() ([]byte, []int)
  • func (this *WorkflowQueryResult) Equal(that interface{}) bool
  • func (m *WorkflowQueryResult) GetAnswer() *v1.Payloads
  • func (m *WorkflowQueryResult) GetErrorMessage() string
  • func (m *WorkflowQueryResult) GetResultType() v11.QueryResultType
  • func (this *WorkflowQueryResult) GoString() string
  • func (m *WorkflowQueryResult) Marshal() (dAtA []byte, err error)
  • func (m *WorkflowQueryResult) MarshalTo(dAtA []byte) (int, error)
  • func (m *WorkflowQueryResult) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*WorkflowQueryResult) ProtoMessage()
  • func (m *WorkflowQueryResult) Reset()
  • func (m *WorkflowQueryResult) Size() (n int)
  • func (this *WorkflowQueryResult) String() string
  • func (m *WorkflowQueryResult) Unmarshal(dAtA []byte) error
  • func (m *WorkflowQueryResult) XXX_DiscardUnknown()
  • func (m *WorkflowQueryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *WorkflowQueryResult) XXX_Merge(src proto.Message)
  • func (m *WorkflowQueryResult) XXX_Size() int
  • func (m *WorkflowQueryResult) XXX_Unmarshal(b []byte) error

Variables

var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)

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"`
}

func (*QueryRejected) Descriptor

func (*QueryRejected) Descriptor() ([]byte, []int)

func (*QueryRejected) Equal

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

func (*QueryRejected) GetStatus

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

func (*QueryRejected) GoString

func (this *QueryRejected) GoString() string

func (*QueryRejected) Marshal

func (m *QueryRejected) Marshal() (dAtA []byte, err error)

func (*QueryRejected) MarshalTo

func (m *QueryRejected) MarshalTo(dAtA []byte) (int, error)

func (*QueryRejected) MarshalToSizedBuffer

func (m *QueryRejected) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryRejected) ProtoMessage

func (*QueryRejected) ProtoMessage()

func (*QueryRejected) Reset

func (m *QueryRejected) Reset()

func (*QueryRejected) Size

func (m *QueryRejected) Size() (n int)

func (*QueryRejected) String

func (this *QueryRejected) String() string

func (*QueryRejected) Unmarshal

func (m *QueryRejected) Unmarshal(dAtA []byte) error

func (*QueryRejected) XXX_DiscardUnknown

func (m *QueryRejected) XXX_DiscardUnknown()

func (*QueryRejected) XXX_Marshal

func (m *QueryRejected) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryRejected) XXX_Merge

func (m *QueryRejected) XXX_Merge(src proto.Message)

func (*QueryRejected) XXX_Size

func (m *QueryRejected) XXX_Size() int

func (*QueryRejected) XXX_Unmarshal

func (m *QueryRejected) XXX_Unmarshal(b []byte) error

type WorkflowQuery

type WorkflowQuery struct {
	QueryType string       `protobuf:"bytes,1,opt,name=query_type,json=queryType,proto3" json:"query_type,omitempty"`
	QueryArgs *v1.Payloads `protobuf:"bytes,2,opt,name=query_args,json=queryArgs,proto3" json:"query_args,omitempty"`
}

func (*WorkflowQuery) Descriptor

func (*WorkflowQuery) Descriptor() ([]byte, []int)

func (*WorkflowQuery) Equal

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

func (*WorkflowQuery) GetQueryArgs

func (m *WorkflowQuery) GetQueryArgs() *v1.Payloads

func (*WorkflowQuery) GetQueryType

func (m *WorkflowQuery) GetQueryType() string

func (*WorkflowQuery) GoString

func (this *WorkflowQuery) GoString() string

func (*WorkflowQuery) Marshal

func (m *WorkflowQuery) Marshal() (dAtA []byte, err error)

func (*WorkflowQuery) MarshalTo

func (m *WorkflowQuery) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowQuery) MarshalToSizedBuffer

func (m *WorkflowQuery) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowQuery) ProtoMessage

func (*WorkflowQuery) ProtoMessage()

func (*WorkflowQuery) Reset

func (m *WorkflowQuery) Reset()

func (*WorkflowQuery) Size

func (m *WorkflowQuery) Size() (n int)

func (*WorkflowQuery) String

func (this *WorkflowQuery) String() string

func (*WorkflowQuery) Unmarshal

func (m *WorkflowQuery) Unmarshal(dAtA []byte) error

func (*WorkflowQuery) XXX_DiscardUnknown

func (m *WorkflowQuery) XXX_DiscardUnknown()

func (*WorkflowQuery) XXX_Marshal

func (m *WorkflowQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowQuery) XXX_Merge

func (m *WorkflowQuery) XXX_Merge(src proto.Message)

func (*WorkflowQuery) XXX_Size

func (m *WorkflowQuery) XXX_Size() int

func (*WorkflowQuery) XXX_Unmarshal

func (m *WorkflowQuery) XXX_Unmarshal(b []byte) error

type WorkflowQueryResult

type WorkflowQueryResult struct {
	ResultType   v11.QueryResultType `` /* 135-byte string literal not displayed */
	Answer       *v1.Payloads        `protobuf:"bytes,2,opt,name=answer,proto3" json:"answer,omitempty"`
	ErrorMessage string              `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
}

func (*WorkflowQueryResult) Descriptor

func (*WorkflowQueryResult) Descriptor() ([]byte, []int)

func (*WorkflowQueryResult) Equal

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

func (*WorkflowQueryResult) GetAnswer

func (m *WorkflowQueryResult) GetAnswer() *v1.Payloads

func (*WorkflowQueryResult) GetErrorMessage

func (m *WorkflowQueryResult) GetErrorMessage() string

func (*WorkflowQueryResult) GetResultType

func (m *WorkflowQueryResult) GetResultType() v11.QueryResultType

func (*WorkflowQueryResult) GoString

func (this *WorkflowQueryResult) GoString() string

func (*WorkflowQueryResult) Marshal

func (m *WorkflowQueryResult) Marshal() (dAtA []byte, err error)

func (*WorkflowQueryResult) MarshalTo

func (m *WorkflowQueryResult) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowQueryResult) MarshalToSizedBuffer

func (m *WorkflowQueryResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowQueryResult) ProtoMessage

func (*WorkflowQueryResult) ProtoMessage()

func (*WorkflowQueryResult) Reset

func (m *WorkflowQueryResult) Reset()

func (*WorkflowQueryResult) Size

func (m *WorkflowQueryResult) Size() (n int)

func (*WorkflowQueryResult) String

func (this *WorkflowQueryResult) String() string

func (*WorkflowQueryResult) Unmarshal

func (m *WorkflowQueryResult) Unmarshal(dAtA []byte) error

func (*WorkflowQueryResult) XXX_DiscardUnknown

func (m *WorkflowQueryResult) XXX_DiscardUnknown()

func (*WorkflowQueryResult) XXX_Marshal

func (m *WorkflowQueryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowQueryResult) XXX_Merge

func (m *WorkflowQueryResult) XXX_Merge(src proto.Message)

func (*WorkflowQueryResult) XXX_Size

func (m *WorkflowQueryResult) XXX_Size() int

func (*WorkflowQueryResult) XXX_Unmarshal

func (m *WorkflowQueryResult) XXX_Unmarshal(b []byte) error