cockroach: Index | Files

package execpb

import ""


Package Files

stats.go stats.pb.go


var (
    ErrInvalidLengthStats = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowStats   = fmt.Errorf("proto: integer overflow")

type VectorizedStats Uses

type VectorizedStats struct {
    ID  int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
    // num_batches is the number of batches that this stats collector observed its
    // operator to output.
    NumBatches int64 `protobuf:"varint,2,opt,name=num_batches,json=numBatches,proto3" json:"num_batches,omitempty"`
    // num_tuples is the number of tuples that this stats collector received
    // from its input.
    NumTuples int64         `protobuf:"varint,3,opt,name=num_tuples,json=numTuples,proto3" json:"num_tuples,omitempty"`
    Time      time.Duration `protobuf:"bytes,4,opt,name=time,proto3,stdduration" json:"time"`
    // stall indicates whether stall time or execution time is being tracked.
    Stall            bool  `protobuf:"varint,5,opt,name=stall,proto3" json:"stall,omitempty"`
    MaxAllocatedMem  int64 `protobuf:"varint,6,opt,name=max_allocated_mem,json=maxAllocatedMem,proto3" json:"max_allocated_mem,omitempty"`
    MaxAllocatedDisk int64 `protobuf:"varint,7,opt,name=max_allocated_disk,json=maxAllocatedDisk,proto3" json:"max_allocated_disk,omitempty"`

VectorizedStats represents the stats collected from an operator.

func (*VectorizedStats) Descriptor Uses

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

func (*VectorizedStats) Marshal Uses

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

func (*VectorizedStats) MarshalTo Uses

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

func (*VectorizedStats) ProtoMessage Uses

func (*VectorizedStats) ProtoMessage()

func (*VectorizedStats) Reset Uses

func (m *VectorizedStats) Reset()

func (*VectorizedStats) Size Uses

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

func (*VectorizedStats) Stats Uses

func (vs *VectorizedStats) Stats() map[string]string

Stats is part of SpanStats interface.

func (*VectorizedStats) StatsForQueryPlan Uses

func (vs *VectorizedStats) StatsForQueryPlan() []string

StatsForQueryPlan is part of DistSQLSpanStats interface.

func (*VectorizedStats) String Uses

func (m *VectorizedStats) String() string

func (*VectorizedStats) Unmarshal Uses

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

func (*VectorizedStats) XXX_DiscardUnknown Uses

func (m *VectorizedStats) XXX_DiscardUnknown()

func (*VectorizedStats) XXX_Marshal Uses

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

func (*VectorizedStats) XXX_Merge Uses

func (dst *VectorizedStats) XXX_Merge(src proto.Message)

func (*VectorizedStats) XXX_Size Uses

func (m *VectorizedStats) XXX_Size() int

func (*VectorizedStats) XXX_Unmarshal Uses

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

Package execpb imports 10 packages (graph) and is imported by 2 packages. Updated 2020-08-12. Refresh now. Tools for package owners.