queryresultspb

package
v0.0.0-...-73c8340 Latest Latest
Warning

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

 Go to latest Published: Dec 23, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthQueryResults        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQueryResults          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQueryResults = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type AgentExecutionStats 

type AgentExecutionStats struct {
	AgentID                *uuidpb.UUID              `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	OperatorExecutionStats []*OperatorExecutionStats `` /* 129-byte string literal not displayed */
	ExecutionTimeNs        int64                     `protobuf:"varint,3,opt,name=execution_time_ns,json=executionTimeNs,proto3" json:"execution_time_ns,omitempty"`
	BytesProcessed         int64                     `protobuf:"varint,4,opt,name=bytes_processed,json=bytesProcessed,proto3" json:"bytes_processed,omitempty"`
	RecordsProcessed       int64                     `protobuf:"varint,5,opt,name=records_processed,json=recordsProcessed,proto3" json:"records_processed,omitempty"`
}

func (*AgentExecutionStats) Descriptor 

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

func (*AgentExecutionStats) Equal 

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

func (*AgentExecutionStats) GetAgentID 

func (m *AgentExecutionStats) GetAgentID() *uuidpb.UUID

func (*AgentExecutionStats) GetBytesProcessed 

func (m *AgentExecutionStats) GetBytesProcessed() int64

func (*AgentExecutionStats) GetExecutionTimeNs 

func (m *AgentExecutionStats) GetExecutionTimeNs() int64

func (*AgentExecutionStats) GetOperatorExecutionStats 

func (m *AgentExecutionStats) GetOperatorExecutionStats() []*OperatorExecutionStats

func (*AgentExecutionStats) GetRecordsProcessed 

func (m *AgentExecutionStats) GetRecordsProcessed() int64

func (*AgentExecutionStats) GoString 

func (this *AgentExecutionStats) GoString() string

func (*AgentExecutionStats) Marshal 

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

func (*AgentExecutionStats) MarshalTo 

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

func (*AgentExecutionStats) MarshalToSizedBuffer 

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

func (*AgentExecutionStats) ProtoMessage 

func (*AgentExecutionStats) ProtoMessage()

func (*AgentExecutionStats) Reset 

func (m *AgentExecutionStats) Reset()

func (*AgentExecutionStats) Size 

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

func (*AgentExecutionStats) String 

func (this *AgentExecutionStats) String() string

func (*AgentExecutionStats) Unmarshal 

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

func (*AgentExecutionStats) XXX_DiscardUnknown 

func (m *AgentExecutionStats) XXX_DiscardUnknown()

func (*AgentExecutionStats) XXX_Marshal 

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

func (*AgentExecutionStats) XXX_Merge 

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

func (*AgentExecutionStats) XXX_Size 

func (m *AgentExecutionStats) XXX_Size() int

func (*AgentExecutionStats) XXX_Unmarshal 

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

type OperatorExecutionStats 

type OperatorExecutionStats struct {
	PlanFragmentId       int64              `protobuf:"varint,1,opt,name=plan_fragment_id,json=planFragmentId,proto3" json:"plan_fragment_id,omitempty"`
	NodeId               int64              `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	BytesOutput          int64              `protobuf:"varint,3,opt,name=bytes_output,json=bytesOutput,proto3" json:"bytes_output,omitempty"`
	RecordsOutput        int64              `protobuf:"varint,4,opt,name=records_output,json=recordsOutput,proto3" json:"records_output,omitempty"`
	TotalExecutionTimeNs int64              `` /* 126-byte string literal not displayed */
	SelfExecutionTimeNs  int64              `protobuf:"varint,6,opt,name=self_execution_time_ns,json=selfExecutionTimeNs,proto3" json:"self_execution_time_ns,omitempty"`
	OperatorStats        *types.Any         `protobuf:"bytes,7,opt,name=operator_stats,json=operatorStats,proto3" json:"operator_stats,omitempty"`
	ExtraMetrics         map[string]float64 `` /* 187-byte string literal not displayed */
	ExtraInfo            map[string]string  `` /* 176-byte string literal not displayed */
}

func (*OperatorExecutionStats) Descriptor 

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

func (*OperatorExecutionStats) Equal 

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

func (*OperatorExecutionStats) GetBytesOutput 

func (m *OperatorExecutionStats) GetBytesOutput() int64

func (*OperatorExecutionStats) GetExtraInfo 

func (m *OperatorExecutionStats) GetExtraInfo() map[string]string

func (*OperatorExecutionStats) GetExtraMetrics 

func (m *OperatorExecutionStats) GetExtraMetrics() map[string]float64

func (*OperatorExecutionStats) GetNodeId 

func (m *OperatorExecutionStats) GetNodeId() int64

func (*OperatorExecutionStats) GetOperatorStats 

func (m *OperatorExecutionStats) GetOperatorStats() *types.Any

func (*OperatorExecutionStats) GetPlanFragmentId 

func (m *OperatorExecutionStats) GetPlanFragmentId() int64

func (*OperatorExecutionStats) GetRecordsOutput 

func (m *OperatorExecutionStats) GetRecordsOutput() int64

func (*OperatorExecutionStats) GetSelfExecutionTimeNs 

func (m *OperatorExecutionStats) GetSelfExecutionTimeNs() int64

func (*OperatorExecutionStats) GetTotalExecutionTimeNs 

func (m *OperatorExecutionStats) GetTotalExecutionTimeNs() int64

func (*OperatorExecutionStats) GoString 

func (this *OperatorExecutionStats) GoString() string

func (*OperatorExecutionStats) Marshal 

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

func (*OperatorExecutionStats) MarshalTo 

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

func (*OperatorExecutionStats) MarshalToSizedBuffer 

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

func (*OperatorExecutionStats) ProtoMessage 

func (*OperatorExecutionStats) ProtoMessage()

func (*OperatorExecutionStats) Reset 

func (m *OperatorExecutionStats) Reset()

func (*OperatorExecutionStats) Size 

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

func (*OperatorExecutionStats) String 

func (this *OperatorExecutionStats) String() string

func (*OperatorExecutionStats) Unmarshal 

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

func (*OperatorExecutionStats) XXX_DiscardUnknown 

func (m *OperatorExecutionStats) XXX_DiscardUnknown()

func (*OperatorExecutionStats) XXX_Marshal 

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

func (*OperatorExecutionStats) XXX_Merge 

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

func (*OperatorExecutionStats) XXX_Size 

func (m *OperatorExecutionStats) XXX_Size() int

func (*OperatorExecutionStats) XXX_Unmarshal 

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

type QueryExecutionStats 

type QueryExecutionStats struct {
	Timing           *QueryTimingInfo `protobuf:"bytes,1,opt,name=timing,proto3" json:"timing,omitempty"`
	BytesProcessed   int64            `protobuf:"varint,2,opt,name=bytes_processed,json=bytesProcessed,proto3" json:"bytes_processed,omitempty"`
	RecordsProcessed int64            `protobuf:"varint,3,opt,name=records_processed,json=recordsProcessed,proto3" json:"records_processed,omitempty"`
}

func (*QueryExecutionStats) Descriptor 

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

func (*QueryExecutionStats) Equal 

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

func (*QueryExecutionStats) GetBytesProcessed 

func (m *QueryExecutionStats) GetBytesProcessed() int64

func (*QueryExecutionStats) GetRecordsProcessed 

func (m *QueryExecutionStats) GetRecordsProcessed() int64

func (*QueryExecutionStats) GetTiming 

func (m *QueryExecutionStats) GetTiming() *QueryTimingInfo

func (*QueryExecutionStats) GoString 

func (this *QueryExecutionStats) GoString() string

func (*QueryExecutionStats) Marshal 

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

func (*QueryExecutionStats) MarshalTo 

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

func (*QueryExecutionStats) MarshalToSizedBuffer 

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

func (*QueryExecutionStats) ProtoMessage 

func (*QueryExecutionStats) ProtoMessage()

func (*QueryExecutionStats) Reset 

func (m *QueryExecutionStats) Reset()

func (*QueryExecutionStats) Size 

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

func (*QueryExecutionStats) String 

func (this *QueryExecutionStats) String() string

func (*QueryExecutionStats) Unmarshal 

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

func (*QueryExecutionStats) XXX_DiscardUnknown 

func (m *QueryExecutionStats) XXX_DiscardUnknown()

func (*QueryExecutionStats) XXX_Marshal 

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

func (*QueryExecutionStats) XXX_Merge 

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

func (*QueryExecutionStats) XXX_Size 

func (m *QueryExecutionStats) XXX_Size() int

func (*QueryExecutionStats) XXX_Unmarshal 

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

type QueryTimingInfo 

type QueryTimingInfo struct {
	ExecutionTimeNs   int64 `protobuf:"varint,1,opt,name=execution_time_ns,json=executionTimeNs,proto3" json:"execution_time_ns,omitempty"`
	CompilationTimeNs int64 `protobuf:"varint,2,opt,name=compilation_time_ns,json=compilationTimeNs,proto3" json:"compilation_time_ns,omitempty"`
}

func (*QueryTimingInfo) Descriptor 

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

func (*QueryTimingInfo) Equal 

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

func (*QueryTimingInfo) GetCompilationTimeNs 

func (m *QueryTimingInfo) GetCompilationTimeNs() int64

func (*QueryTimingInfo) GetExecutionTimeNs 

func (m *QueryTimingInfo) GetExecutionTimeNs() int64

func (*QueryTimingInfo) GoString 

func (this *QueryTimingInfo) GoString() string

func (*QueryTimingInfo) Marshal 

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

func (*QueryTimingInfo) MarshalTo 

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

func (*QueryTimingInfo) MarshalToSizedBuffer 

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

func (*QueryTimingInfo) ProtoMessage 

func (*QueryTimingInfo) ProtoMessage()

func (*QueryTimingInfo) Reset 

func (m *QueryTimingInfo) Reset()

func (*QueryTimingInfo) Size 

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

func (*QueryTimingInfo) String 

func (this *QueryTimingInfo) String() string

func (*QueryTimingInfo) Unmarshal 

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

func (*QueryTimingInfo) XXX_DiscardUnknown 

func (m *QueryTimingInfo) XXX_DiscardUnknown()

func (*QueryTimingInfo) XXX_Marshal 

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

func (*QueryTimingInfo) XXX_Merge 

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

func (*QueryTimingInfo) XXX_Size 

func (m *QueryTimingInfo) XXX_Size() int

func (*QueryTimingInfo) XXX_Unmarshal 

func (m *QueryTimingInfo) 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.