cockroach: Index | Files

package rowflow

import ""


Package Files

input_sync.go routers.go row_based_flow.go stats.pb.go test_utils.go


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

func MakeTestRouter Uses

func MakeTestRouter(
    ctx context.Context,
    flowCtx *execinfra.FlowCtx,
    spec *execinfrapb.OutputRouterSpec,
    streams []execinfra.RowReceiver,
    types []*types.T,
    wg *sync.WaitGroup,
) (execinfra.RowReceiver, error)

MakeTestRouter creates a router to be used by tests.

func NewRowBasedFlow Uses

func NewRowBasedFlow(base *flowinfra.FlowBase) flowinfra.Flow

NewRowBasedFlow returns a row based flow using base as its FlowBase.

type RouterOutputStats Uses

type RouterOutputStats struct {
    NumRows          int64 `protobuf:"varint,1,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
    MaxAllocatedMem  int64 `protobuf:"varint,2,opt,name=max_allocated_mem,json=maxAllocatedMem,proto3" json:"max_allocated_mem,omitempty"`
    MaxAllocatedDisk int64 `protobuf:"varint,3,opt,name=max_allocated_disk,json=maxAllocatedDisk,proto3" json:"max_allocated_disk,omitempty"`

RouterOutputStats are the stats collected by a single router output stream.

func (*RouterOutputStats) Descriptor Uses

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

func (*RouterOutputStats) Marshal Uses

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

func (*RouterOutputStats) MarshalTo Uses

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

func (*RouterOutputStats) ProtoMessage Uses

func (*RouterOutputStats) ProtoMessage()

func (*RouterOutputStats) Reset Uses

func (m *RouterOutputStats) Reset()

func (*RouterOutputStats) Size Uses

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

func (*RouterOutputStats) Stats Uses

func (ros *RouterOutputStats) Stats() map[string]string

Stats implements the SpanStats interface.

func (*RouterOutputStats) StatsForQueryPlan Uses

func (ros *RouterOutputStats) StatsForQueryPlan() []string

StatsForQueryPlan implements the DistSQLSpanStats interface.

func (*RouterOutputStats) String Uses

func (m *RouterOutputStats) String() string

func (*RouterOutputStats) Unmarshal Uses

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

func (*RouterOutputStats) XXX_DiscardUnknown Uses

func (m *RouterOutputStats) XXX_DiscardUnknown()

func (*RouterOutputStats) XXX_Marshal Uses

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

func (*RouterOutputStats) XXX_Merge Uses

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

func (*RouterOutputStats) XXX_Size Uses

func (m *RouterOutputStats) XXX_Size() int

func (*RouterOutputStats) XXX_Unmarshal Uses

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

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