query

package
v0.12.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 4, 2022 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

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

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

See https://docs.temporal.io/docs/concepts/queries/

func (*WorkflowQuery) Descriptor 

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

func (*WorkflowQuery) Equal 

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

func (*WorkflowQuery) GetHeader added in v0.8.0 

func (m *WorkflowQuery) GetHeader() *v1.Header

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

Answer to a `WorkflowQuery`

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.