Versions in this module Expand all Collapse all v1 v1.0.1 May 18, 2017 Changes in this version + const FlowFinished + const FlowNotStarted + const FlowRunning + const MinAcceptedVersion + const Version + var AggregatorSpec_Func_name = map[int32]string + var AggregatorSpec_Func_value = map[string]int32 + var AlgebraicSetOpSpec_SetOpType_name = map[int32]string + var AlgebraicSetOpSpec_SetOpType_value = map[string]int32 + var BackfillerSpec_Type_name = map[int32]string + var BackfillerSpec_Type_value = map[string]int32 + var ErrIntOverflowApi = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowData = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowProcessors = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthData = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthProcessors = fmt.Errorf("proto: negative length found during unmarshaling") + var InputSyncSpec_Type_name = map[int32]string + var InputSyncSpec_Type_value = map[string]int32 + var JoinType_name = map[int32]string + var JoinType_value = map[string]int32 + var Ordering_Column_Direction_name = map[int32]string + var Ordering_Column_Direction_value = map[string]int32 + var OutputRouterSpec_Type_name = map[int32]string + var OutputRouterSpec_Type_value = map[string]int32 + var StreamEndpointSpec_Type_name = map[int32]string + var StreamEndpointSpec_Type_value = map[string]int32 + func ColumnMutationFilter(m sqlbase.DescriptorMutation) bool + func CompareEncDatumRowForMerge(lhs, rhs sqlbase.EncDatumRow, ...) (int, error) + func ConvertBackfillError(tableDesc *sqlbase.TableDescriptor, b *client.Batch) error + func DrainAndClose(ctx context.Context, dst RowReceiver, cause error, srcs ...RowSource) + func DrainAndForwardMetadata(ctx context.Context, src RowSource, dst RowReceiver) + func GeneratePlanDiagram(flows map[roachpb.NodeID]FlowSpec, w io.Writer) error + func GeneratePlanDiagramWithURL(flows map[roachpb.NodeID]FlowSpec) (string, url.URL, error) + func GetAggregateInfo(fn AggregatorSpec_Func, inputType sqlbase.ColumnType) (aggregateConstructor func(*parser.EvalContext) parser.AggregateFunc, ...) + func IndexMutationFilter(m sqlbase.DescriptorMutation) bool + func ProcessInboundStream(ctx context.Context, stream DistSQL_FlowStreamServer, ...) error + func RegisterDistSQLServer(s *grpc.Server, srv DistSQLServer) + func SetFlowRequestTrace(ctx context.Context, req *SetupFlowRequest) error + func WriteResumeSpan(ctx context.Context, db *client.DB, id sqlbase.ID, origSpan roachpb.Span, ...) error + type AggregatorSpec struct + Aggregations []AggregatorSpec_Aggregation + GroupCols []uint32 + func (*AggregatorSpec) Descriptor() ([]byte, []int) + func (*AggregatorSpec) ProtoMessage() + func (m *AggregatorSpec) Marshal() (dAtA []byte, err error) + func (m *AggregatorSpec) MarshalTo(dAtA []byte) (int, error) + func (m *AggregatorSpec) Reset() + func (m *AggregatorSpec) Size() (n int) + func (m *AggregatorSpec) String() string + func (m *AggregatorSpec) Unmarshal(dAtA []byte) error + type AggregatorSpec_Aggregation struct + ColIdx uint32 + Distinct bool + Func AggregatorSpec_Func + func (*AggregatorSpec_Aggregation) Descriptor() ([]byte, []int) + func (*AggregatorSpec_Aggregation) ProtoMessage() + func (m *AggregatorSpec_Aggregation) Marshal() (dAtA []byte, err error) + func (m *AggregatorSpec_Aggregation) MarshalTo(dAtA []byte) (int, error) + func (m *AggregatorSpec_Aggregation) Reset() + func (m *AggregatorSpec_Aggregation) Size() (n int) + func (m *AggregatorSpec_Aggregation) String() string + func (m *AggregatorSpec_Aggregation) Unmarshal(dAtA []byte) error + type AggregatorSpec_Func int32 + const AggregatorSpec_AVG + const AggregatorSpec_BOOL_AND + const AggregatorSpec_BOOL_OR + const AggregatorSpec_CONCAT_AGG + const AggregatorSpec_COUNT + const AggregatorSpec_IDENT + const AggregatorSpec_MAX + const AggregatorSpec_MIN + const AggregatorSpec_STDDEV + const AggregatorSpec_SUM + const AggregatorSpec_SUM_INT + const AggregatorSpec_VARIANCE + func (AggregatorSpec_Func) EnumDescriptor() ([]byte, []int) + func (x *AggregatorSpec_Func) UnmarshalJSON(data []byte) error + func (x AggregatorSpec_Func) Enum() *AggregatorSpec_Func + func (x AggregatorSpec_Func) String() string + type AlgebraicSetOpSpec struct + OpType AlgebraicSetOpSpec_SetOpType + Ordering Ordering + func (*AlgebraicSetOpSpec) Descriptor() ([]byte, []int) + func (*AlgebraicSetOpSpec) ProtoMessage() + func (m *AlgebraicSetOpSpec) Marshal() (dAtA []byte, err error) + func (m *AlgebraicSetOpSpec) MarshalTo(dAtA []byte) (int, error) + func (m *AlgebraicSetOpSpec) Reset() + func (m *AlgebraicSetOpSpec) Size() (n int) + func (m *AlgebraicSetOpSpec) String() string + func (m *AlgebraicSetOpSpec) Unmarshal(dAtA []byte) error + type AlgebraicSetOpSpec_SetOpType int32 + const AlgebraicSetOpSpec_Except_all + func (AlgebraicSetOpSpec_SetOpType) EnumDescriptor() ([]byte, []int) + func (x *AlgebraicSetOpSpec_SetOpType) UnmarshalJSON(data []byte) error + func (x AlgebraicSetOpSpec_SetOpType) Enum() *AlgebraicSetOpSpec_SetOpType + func (x AlgebraicSetOpSpec_SetOpType) String() string + type BackfillerSpec struct + ChunkSize int64 + Duration time.Duration + OtherTables []cockroach_sql_sqlbase1.TableDescriptor + Spans []TableReaderSpan + Table cockroach_sql_sqlbase1.TableDescriptor + Type BackfillerSpec_Type + func (*BackfillerSpec) Descriptor() ([]byte, []int) + func (*BackfillerSpec) ProtoMessage() + func (m *BackfillerSpec) Marshal() (dAtA []byte, err error) + func (m *BackfillerSpec) MarshalTo(dAtA []byte) (int, error) + func (m *BackfillerSpec) Reset() + func (m *BackfillerSpec) Size() (n int) + func (m *BackfillerSpec) String() string + func (m *BackfillerSpec) Unmarshal(dAtA []byte) error + type BackfillerSpec_Type int32 + const BackfillerSpec_Column + const BackfillerSpec_Index + const BackfillerSpec_Invalid + func (BackfillerSpec_Type) EnumDescriptor() ([]byte, []int) + func (x *BackfillerSpec_Type) UnmarshalJSON(data []byte) error + func (x BackfillerSpec_Type) Enum() *BackfillerSpec_Type + func (x BackfillerSpec_Type) String() string + type BufferedRecord struct + Meta ProducerMetadata + Row sqlbase.EncDatumRow + type ConsumerSignal struct + DrainRequest *DrainRequest + SetupFlowRequest *SetupFlowRequest + func (*ConsumerSignal) Descriptor() ([]byte, []int) + func (*ConsumerSignal) ProtoMessage() + func (m *ConsumerSignal) Marshal() (dAtA []byte, err error) + func (m *ConsumerSignal) MarshalTo(dAtA []byte) (int, error) + func (m *ConsumerSignal) Reset() + func (m *ConsumerSignal) Size() (n int) + func (m *ConsumerSignal) String() string + func (m *ConsumerSignal) Unmarshal(dAtA []byte) error + func (this *ConsumerSignal) GetValue() interface{} + func (this *ConsumerSignal) SetValue(value interface{}) bool + type ConsumerStatus uint32 + const ConsumerClosed + const DrainRequested + const NeedMoreRows + type DatumInfo struct + Encoding cockroach_sql_sqlbase2.DatumEncoding + Type cockroach_sql_sqlbase1.ColumnType + func (*DatumInfo) Descriptor() ([]byte, []int) + func (*DatumInfo) ProtoMessage() + func (m *DatumInfo) Marshal() (dAtA []byte, err error) + func (m *DatumInfo) MarshalTo(dAtA []byte) (int, error) + func (m *DatumInfo) Reset() + func (m *DatumInfo) Size() (n int) + func (m *DatumInfo) String() string + func (m *DatumInfo) Unmarshal(dAtA []byte) error + type DistSQLClient interface + FlowStream func(ctx context.Context, opts ...grpc.CallOption) (DistSQL_FlowStreamClient, error) + RunSyncFlow func(ctx context.Context, opts ...grpc.CallOption) (DistSQL_RunSyncFlowClient, error) + SetupFlow func(ctx context.Context, in *SetupFlowRequest, opts ...grpc.CallOption) (*SimpleResponse, error) + func NewDistSQLClient(cc *grpc.ClientConn) DistSQLClient + type DistSQLServer interface + FlowStream func(DistSQL_FlowStreamServer) error + RunSyncFlow func(DistSQL_RunSyncFlowServer) error + SetupFlow func(context.Context, *SetupFlowRequest) (*SimpleResponse, error) + type DistSQL_FlowStreamClient interface + Recv func() (*ConsumerSignal, error) + Send func(*ProducerMessage) error + type DistSQL_FlowStreamServer interface + Recv func() (*ProducerMessage, error) + Send func(*ConsumerSignal) error + type DistSQL_RunSyncFlowClient interface + Recv func() (*ProducerMessage, error) + Send func(*ConsumerSignal) error + type DistSQL_RunSyncFlowServer interface + Recv func() (*ConsumerSignal, error) + Send func(*ProducerMessage) error + type DistinctSpec struct + DistinctColumns []uint32 + OrderedColumns []uint32 + func (*DistinctSpec) Descriptor() ([]byte, []int) + func (*DistinctSpec) ProtoMessage() + func (m *DistinctSpec) Marshal() (dAtA []byte, err error) + func (m *DistinctSpec) MarshalTo(dAtA []byte) (int, error) + func (m *DistinctSpec) Reset() + func (m *DistinctSpec) Size() (n int) + func (m *DistinctSpec) String() string + func (m *DistinctSpec) Unmarshal(dAtA []byte) error + type DrainRequest struct + func (*DrainRequest) Descriptor() ([]byte, []int) + func (*DrainRequest) ProtoMessage() + func (m *DrainRequest) Marshal() (dAtA []byte, err error) + func (m *DrainRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DrainRequest) Reset() + func (m *DrainRequest) Size() (n int) + func (m *DrainRequest) String() string + func (m *DrainRequest) Unmarshal(dAtA []byte) error + type Error struct + Detail isError_Detail + func NewError(err error) *Error + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (*Error) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (e *Error) ErrorDetail() error + func (e *Error) String() string + func (m *Error) GetDetail() isError_Detail + func (m *Error) GetPGError() *cockroach_pgerror.Error + func (m *Error) GetRetryableTxnError() *cockroach_roachpb2.UnhandledRetryableError + func (m *Error) Marshal() (dAtA []byte, err error) + func (m *Error) MarshalTo(dAtA []byte) (int, error) + func (m *Error) Reset() + func (m *Error) Size() (n int) + func (m *Error) Unmarshal(dAtA []byte) error + type Error_PGError struct + PGError *cockroach_pgerror.Error + func (m *Error_PGError) MarshalTo(dAtA []byte) (int, error) + func (m *Error_PGError) Size() (n int) + type Error_RetryableTxnError struct + RetryableTxnError *cockroach_roachpb2.UnhandledRetryableError + func (m *Error_RetryableTxnError) MarshalTo(dAtA []byte) (int, error) + func (m *Error_RetryableTxnError) Size() (n int) + type EvalContext struct + ClusterTimestamp cockroach_util_hlc.Timestamp + Database string + Location string + SearchPath []string + StmtTimestampNanos int64 + TxnTimestampNanos int64 + func MakeEvalContext(evalCtx parser.EvalContext) EvalContext + func (*EvalContext) Descriptor() ([]byte, []int) + func (*EvalContext) ProtoMessage() + func (m *EvalContext) Marshal() (dAtA []byte, err error) + func (m *EvalContext) MarshalTo(dAtA []byte) (int, error) + func (m *EvalContext) Reset() + func (m *EvalContext) Size() (n int) + func (m *EvalContext) String() string + func (m *EvalContext) Unmarshal(dAtA []byte) error + type Expression struct + Expr string + Version string + func (*Expression) Descriptor() ([]byte, []int) + func (*Expression) ProtoMessage() + func (m *Expression) Marshal() (dAtA []byte, err error) + func (m *Expression) MarshalTo(dAtA []byte) (int, error) + func (m *Expression) Reset() + func (m *Expression) Size() (n int) + func (m *Expression) String() string + func (m *Expression) Unmarshal(dAtA []byte) error + type Flow struct + func (f *Flow) Cleanup(ctx context.Context) + func (f *Flow) RunSync(ctx context.Context) + func (f *Flow) Start(ctx context.Context, doneFn func()) + func (f *Flow) Wait() + type FlowCtx struct + type FlowID struct + type FlowSpec struct + FlowID FlowID + Processors []ProcessorSpec + func (*FlowSpec) Descriptor() ([]byte, []int) + func (*FlowSpec) ProtoMessage() + func (m *FlowSpec) Marshal() (dAtA []byte, err error) + func (m *FlowSpec) MarshalTo(dAtA []byte) (int, error) + func (m *FlowSpec) Reset() + func (m *FlowSpec) Size() (n int) + func (m *FlowSpec) String() string + func (m *FlowSpec) Unmarshal(dAtA []byte) error + type HashJoinerSpec struct + LeftEqColumns []uint32 + OnExpr Expression + RightEqColumns []uint32 + Type JoinType + func (*HashJoinerSpec) Descriptor() ([]byte, []int) + func (*HashJoinerSpec) ProtoMessage() + func (m *HashJoinerSpec) Marshal() (dAtA []byte, err error) + func (m *HashJoinerSpec) MarshalTo(dAtA []byte) (int, error) + func (m *HashJoinerSpec) Reset() + func (m *HashJoinerSpec) Size() (n int) + func (m *HashJoinerSpec) String() string + func (m *HashJoinerSpec) Unmarshal(dAtA []byte) error + type InputSyncSpec struct + ColumnTypes []cockroach_sql_sqlbase1.ColumnType + Ordering Ordering + Streams []StreamEndpointSpec + Type InputSyncSpec_Type + func (*InputSyncSpec) Descriptor() ([]byte, []int) + func (*InputSyncSpec) ProtoMessage() + func (m *InputSyncSpec) Marshal() (dAtA []byte, err error) + func (m *InputSyncSpec) MarshalTo(dAtA []byte) (int, error) + func (m *InputSyncSpec) Reset() + func (m *InputSyncSpec) Size() (n int) + func (m *InputSyncSpec) String() string + func (m *InputSyncSpec) Unmarshal(dAtA []byte) error + type InputSyncSpec_Type int32 + const InputSyncSpec_ORDERED + const InputSyncSpec_UNORDERED + func (InputSyncSpec_Type) EnumDescriptor() ([]byte, []int) + func (x *InputSyncSpec_Type) UnmarshalJSON(data []byte) error + func (x InputSyncSpec_Type) Enum() *InputSyncSpec_Type + func (x InputSyncSpec_Type) String() string + type JoinReaderSpec struct + IndexIdx uint32 + Table cockroach_sql_sqlbase1.TableDescriptor + func (*JoinReaderSpec) Descriptor() ([]byte, []int) + func (*JoinReaderSpec) ProtoMessage() + func (m *JoinReaderSpec) Marshal() (dAtA []byte, err error) + func (m *JoinReaderSpec) MarshalTo(dAtA []byte) (int, error) + func (m *JoinReaderSpec) Reset() + func (m *JoinReaderSpec) Size() (n int) + func (m *JoinReaderSpec) String() string + func (m *JoinReaderSpec) Unmarshal(dAtA []byte) error + type JoinType int32 + const JoinType_FULL_OUTER + const JoinType_INNER + const JoinType_LEFT_OUTER + const JoinType_RIGHT_OUTER + func (JoinType) EnumDescriptor() ([]byte, []int) + func (x *JoinType) UnmarshalJSON(data []byte) error + func (x JoinType) Enum() *JoinType + func (x JoinType) String() string + type MergeJoinerSpec struct + LeftOrdering Ordering + OnExpr Expression + RightOrdering Ordering + Type JoinType + func (*MergeJoinerSpec) Descriptor() ([]byte, []int) + func (*MergeJoinerSpec) ProtoMessage() + func (m *MergeJoinerSpec) Marshal() (dAtA []byte, err error) + func (m *MergeJoinerSpec) MarshalTo(dAtA []byte) (int, error) + func (m *MergeJoinerSpec) Reset() + func (m *MergeJoinerSpec) Size() (n int) + func (m *MergeJoinerSpec) String() string + func (m *MergeJoinerSpec) Unmarshal(dAtA []byte) error + type MultiplexedRowChannel struct + func (mrc *MultiplexedRowChannel) ConsumerClosed() + func (mrc *MultiplexedRowChannel) ConsumerDone() + func (mrc *MultiplexedRowChannel) Init(numSenders int, types []sqlbase.ColumnType) + func (mrc *MultiplexedRowChannel) Next() (row sqlbase.EncDatumRow, meta ProducerMetadata) + func (mrc *MultiplexedRowChannel) ProducerDone() + func (mrc *MultiplexedRowChannel) Push(row sqlbase.EncDatumRow, meta ProducerMetadata) ConsumerStatus + func (mrc *MultiplexedRowChannel) Types() []sqlbase.ColumnType + type MutationFilter func(sqlbase.DescriptorMutation) bool + type NoMetadataRowSource struct + func MakeNoMetadataRowSource(src RowSource, sink RowReceiver) NoMetadataRowSource + func (rs *NoMetadataRowSource) NextRow() (sqlbase.EncDatumRow, error) + type NoopCoreSpec struct + func (*NoopCoreSpec) Descriptor() ([]byte, []int) + func (*NoopCoreSpec) ProtoMessage() + func (m *NoopCoreSpec) Marshal() (dAtA []byte, err error) + func (m *NoopCoreSpec) MarshalTo(dAtA []byte) (int, error) + func (m *NoopCoreSpec) Reset() + func (m *NoopCoreSpec) Size() (n int) + func (m *NoopCoreSpec) String() string + func (m *NoopCoreSpec) Unmarshal(dAtA []byte) error + type Ordering struct + Columns []Ordering_Column + func (*Ordering) Descriptor() ([]byte, []int) + func (*Ordering) ProtoMessage() + func (m *Ordering) Marshal() (dAtA []byte, err error) + func (m *Ordering) MarshalTo(dAtA []byte) (int, error) + func (m *Ordering) Reset() + func (m *Ordering) Size() (n int) + func (m *Ordering) String() string + func (m *Ordering) Unmarshal(dAtA []byte) error + type Ordering_Column struct + ColIdx uint32 + Direction Ordering_Column_Direction + func (*Ordering_Column) Descriptor() ([]byte, []int) + func (*Ordering_Column) ProtoMessage() + func (m *Ordering_Column) Marshal() (dAtA []byte, err error) + func (m *Ordering_Column) MarshalTo(dAtA []byte) (int, error) + func (m *Ordering_Column) Reset() + func (m *Ordering_Column) Size() (n int) + func (m *Ordering_Column) String() string + func (m *Ordering_Column) Unmarshal(dAtA []byte) error + type Ordering_Column_Direction int32 + const Ordering_Column_ASC + const Ordering_Column_DESC + func (Ordering_Column_Direction) EnumDescriptor() ([]byte, []int) + func (x *Ordering_Column_Direction) UnmarshalJSON(data []byte) error + func (x Ordering_Column_Direction) Enum() *Ordering_Column_Direction + func (x Ordering_Column_Direction) String() string + type OutputRouterSpec struct + HashColumns []uint32 + Streams []StreamEndpointSpec + Type OutputRouterSpec_Type + func (*OutputRouterSpec) Descriptor() ([]byte, []int) + func (*OutputRouterSpec) ProtoMessage() + func (m *OutputRouterSpec) Marshal() (dAtA []byte, err error) + func (m *OutputRouterSpec) MarshalTo(dAtA []byte) (int, error) + func (m *OutputRouterSpec) Reset() + func (m *OutputRouterSpec) Size() (n int) + func (m *OutputRouterSpec) String() string + func (m *OutputRouterSpec) Unmarshal(dAtA []byte) error + type OutputRouterSpec_Type int32 + const OutputRouterSpec_BY_HASH + const OutputRouterSpec_BY_RANGE + const OutputRouterSpec_MIRROR + const OutputRouterSpec_PASS_THROUGH + func (OutputRouterSpec_Type) EnumDescriptor() ([]byte, []int) + func (x *OutputRouterSpec_Type) UnmarshalJSON(data []byte) error + func (x OutputRouterSpec_Type) Enum() *OutputRouterSpec_Type + func (x OutputRouterSpec_Type) String() string + type PostProcessSpec struct + Filter Expression + Limit uint64 + Offset uint64 + OutputColumns []uint32 + Projection bool + RenderExprs []Expression + func (*PostProcessSpec) Descriptor() ([]byte, []int) + func (*PostProcessSpec) ProtoMessage() + func (m *PostProcessSpec) Marshal() (dAtA []byte, err error) + func (m *PostProcessSpec) MarshalTo(dAtA []byte) (int, error) + func (m *PostProcessSpec) Reset() + func (m *PostProcessSpec) Size() (n int) + func (m *PostProcessSpec) String() string + func (m *PostProcessSpec) Unmarshal(dAtA []byte) error + type ProcessorCoreUnion struct + Aggregator *AggregatorSpec + Backfiller *BackfillerSpec + Distinct *DistinctSpec + HashJoiner *HashJoinerSpec + JoinReader *JoinReaderSpec + MergeJoiner *MergeJoinerSpec + Noop *NoopCoreSpec + SetOp *AlgebraicSetOpSpec + Sorter *SorterSpec + TableReader *TableReaderSpec + Values *ValuesCoreSpec + func (*ProcessorCoreUnion) Descriptor() ([]byte, []int) + func (*ProcessorCoreUnion) ProtoMessage() + func (m *ProcessorCoreUnion) Marshal() (dAtA []byte, err error) + func (m *ProcessorCoreUnion) MarshalTo(dAtA []byte) (int, error) + func (m *ProcessorCoreUnion) Reset() + func (m *ProcessorCoreUnion) Size() (n int) + func (m *ProcessorCoreUnion) String() string + func (m *ProcessorCoreUnion) Unmarshal(dAtA []byte) error + func (this *ProcessorCoreUnion) GetValue() interface{} + func (this *ProcessorCoreUnion) SetValue(value interface{}) bool + type ProcessorSpec struct + Core ProcessorCoreUnion + Input []InputSyncSpec + Output []OutputRouterSpec + Post PostProcessSpec + func (*ProcessorSpec) Descriptor() ([]byte, []int) + func (*ProcessorSpec) ProtoMessage() + func (m *ProcessorSpec) Marshal() (dAtA []byte, err error) + func (m *ProcessorSpec) MarshalTo(dAtA []byte) (int, error) + func (m *ProcessorSpec) Reset() + func (m *ProcessorSpec) Size() (n int) + func (m *ProcessorSpec) String() string + func (m *ProcessorSpec) Unmarshal(dAtA []byte) error + type ProducerData struct + Metadata []RemoteProducerMetadata + NumEmptyRows int32 + RawBytes []byte + func (*ProducerData) Descriptor() ([]byte, []int) + func (*ProducerData) ProtoMessage() + func (m *ProducerData) Marshal() (dAtA []byte, err error) + func (m *ProducerData) MarshalTo(dAtA []byte) (int, error) + func (m *ProducerData) Reset() + func (m *ProducerData) Size() (n int) + func (m *ProducerData) String() string + func (m *ProducerData) Unmarshal(dAtA []byte) error + type ProducerHeader struct + FlowID FlowID + StreamID StreamID + func (*ProducerHeader) Descriptor() ([]byte, []int) + func (*ProducerHeader) ProtoMessage() + func (m *ProducerHeader) Marshal() (dAtA []byte, err error) + func (m *ProducerHeader) MarshalTo(dAtA []byte) (int, error) + func (m *ProducerHeader) Reset() + func (m *ProducerHeader) Size() (n int) + func (m *ProducerHeader) String() string + func (m *ProducerHeader) Unmarshal(dAtA []byte) error + type ProducerMessage struct + Data ProducerData + Header *ProducerHeader + Typing []DatumInfo + func (*ProducerMessage) Descriptor() ([]byte, []int) + func (*ProducerMessage) ProtoMessage() + func (m *ProducerMessage) Marshal() (dAtA []byte, err error) + func (m *ProducerMessage) MarshalTo(dAtA []byte) (int, error) + func (m *ProducerMessage) Reset() + func (m *ProducerMessage) Size() (n int) + func (m *ProducerMessage) String() string + func (m *ProducerMessage) Unmarshal(dAtA []byte) error + type ProducerMetadata struct + Err error + Ranges []roachpb.RangeInfo + func (meta ProducerMetadata) Empty() bool + type RemoteProducerMetadata struct + Value isRemoteProducerMetadata_Value + func (*RemoteProducerMetadata) Descriptor() ([]byte, []int) + func (*RemoteProducerMetadata) ProtoMessage() + func (*RemoteProducerMetadata) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *RemoteProducerMetadata) GetError() *Error + func (m *RemoteProducerMetadata) GetRangeInfo() *RemoteProducerMetadata_RangeInfos + func (m *RemoteProducerMetadata) GetValue() isRemoteProducerMetadata_Value + func (m *RemoteProducerMetadata) Marshal() (dAtA []byte, err error) + func (m *RemoteProducerMetadata) MarshalTo(dAtA []byte) (int, error) + func (m *RemoteProducerMetadata) Reset() + func (m *RemoteProducerMetadata) Size() (n int) + func (m *RemoteProducerMetadata) String() string + func (m *RemoteProducerMetadata) Unmarshal(dAtA []byte) error + type RemoteProducerMetadata_Error struct + Error *Error + func (m *RemoteProducerMetadata_Error) MarshalTo(dAtA []byte) (int, error) + func (m *RemoteProducerMetadata_Error) Size() (n int) + type RemoteProducerMetadata_RangeInfo struct + RangeInfo *RemoteProducerMetadata_RangeInfos + func (m *RemoteProducerMetadata_RangeInfo) MarshalTo(dAtA []byte) (int, error) + func (m *RemoteProducerMetadata_RangeInfo) Size() (n int) + type RemoteProducerMetadata_RangeInfos struct + RangeInfo []cockroach_roachpb3.RangeInfo + func (*RemoteProducerMetadata_RangeInfos) Descriptor() ([]byte, []int) + func (*RemoteProducerMetadata_RangeInfos) ProtoMessage() + func (m *RemoteProducerMetadata_RangeInfos) Marshal() (dAtA []byte, err error) + func (m *RemoteProducerMetadata_RangeInfos) MarshalTo(dAtA []byte) (int, error) + func (m *RemoteProducerMetadata_RangeInfos) Reset() + func (m *RemoteProducerMetadata_RangeInfos) Size() (n int) + func (m *RemoteProducerMetadata_RangeInfos) String() string + func (m *RemoteProducerMetadata_RangeInfos) Unmarshal(dAtA []byte) error + type RowBuffer struct + ConsumerStatus ConsumerStatus + Done bool + ProducerClosed bool + func NewRowBuffer(types []sqlbase.ColumnType, rows sqlbase.EncDatumRows, hooks RowBufferArgs) *RowBuffer + func (rb *RowBuffer) ConsumerClosed() + func (rb *RowBuffer) ConsumerDone() + func (rb *RowBuffer) Next() (sqlbase.EncDatumRow, ProducerMetadata) + func (rb *RowBuffer) ProducerDone() + func (rb *RowBuffer) Push(row sqlbase.EncDatumRow, meta ProducerMetadata) ConsumerStatus + func (rb *RowBuffer) Types() []sqlbase.ColumnType + type RowBufferArgs struct + AccumulateRowsWhileDraining bool + OnConsumerClosed func(*RowBuffer) + OnConsumerDone func(*RowBuffer) + OnNext func(*RowBuffer) (sqlbase.EncDatumRow, ProducerMetadata) + type RowChannel struct + C <-chan RowChannelMsg + func (rc *RowChannel) ConsumerClosed() + func (rc *RowChannel) ConsumerDone() + func (rc *RowChannel) Init(types []sqlbase.ColumnType) + func (rc *RowChannel) InitWithBufSize(types []sqlbase.ColumnType, chanBufSize int) + func (rc *RowChannel) Next() (sqlbase.EncDatumRow, ProducerMetadata) + func (rc *RowChannel) ProducerDone() + func (rc *RowChannel) Push(row sqlbase.EncDatumRow, meta ProducerMetadata) ConsumerStatus + func (rc *RowChannel) Types() []sqlbase.ColumnType + type RowChannelMsg struct + Meta ProducerMetadata + Row sqlbase.EncDatumRow + type RowReceiver interface + ProducerDone func() + Push func(row sqlbase.EncDatumRow, meta ProducerMetadata) ConsumerStatus + type RowSource interface + ConsumerClosed func() + ConsumerDone func() + Next func() (sqlbase.EncDatumRow, ProducerMetadata) + Types func() []sqlbase.ColumnType + type ServerConfig struct + Counter *metric.Counter + DB *client.DB + FlowDB *client.DB + Hist *metric.Histogram + NodeID *base.NodeIDContainer + ParentMemoryMonitor *mon.MemoryMonitor + RPCContext *rpc.Context + Stopper *stop.Stopper + TestingKnobs TestingKnobs + type ServerImpl struct + func NewServer(ctx context.Context, cfg ServerConfig) *ServerImpl + func (ds *ServerImpl) FlowStream(stream DistSQL_FlowStreamServer) error + func (ds *ServerImpl) RunSyncFlow(stream DistSQL_RunSyncFlowServer) error + func (ds *ServerImpl) SetupFlow(_ context.Context, req *SetupFlowRequest) (*SimpleResponse, error) + func (ds *ServerImpl) SetupSyncFlow(ctx context.Context, req *SetupFlowRequest, output RowReceiver) (context.Context, *Flow, error) + func (ds *ServerImpl) Start() + type SetupFlowRequest struct + EvalContext EvalContext + Flow FlowSpec + TraceContext *cockroach_util_tracing.SpanContextCarrier + Txn cockroach_roachpb1.Transaction + Version uint32 + func (*SetupFlowRequest) Descriptor() ([]byte, []int) + func (*SetupFlowRequest) ProtoMessage() + func (m *SetupFlowRequest) Marshal() (dAtA []byte, err error) + func (m *SetupFlowRequest) MarshalTo(dAtA []byte) (int, error) + func (m *SetupFlowRequest) Reset() + func (m *SetupFlowRequest) Size() (n int) + func (m *SetupFlowRequest) String() string + func (m *SetupFlowRequest) Unmarshal(dAtA []byte) error + type SimpleResponse struct + Error *Error + func (*SimpleResponse) Descriptor() ([]byte, []int) + func (*SimpleResponse) ProtoMessage() + func (m *SimpleResponse) Marshal() (dAtA []byte, err error) + func (m *SimpleResponse) MarshalTo(dAtA []byte) (int, error) + func (m *SimpleResponse) Reset() + func (m *SimpleResponse) Size() (n int) + func (m *SimpleResponse) String() string + func (m *SimpleResponse) Unmarshal(dAtA []byte) error + type SorterSpec struct + OrderingMatchLen uint32 + OutputOrdering Ordering + func (*SorterSpec) Descriptor() ([]byte, []int) + func (*SorterSpec) ProtoMessage() + func (m *SorterSpec) Marshal() (dAtA []byte, err error) + func (m *SorterSpec) MarshalTo(dAtA []byte) (int, error) + func (m *SorterSpec) Reset() + func (m *SorterSpec) Size() (n int) + func (m *SorterSpec) String() string + func (m *SorterSpec) Unmarshal(dAtA []byte) error + type StreamDecoder struct + func (sd *StreamDecoder) AddMessage(msg *ProducerMessage) error + func (sd *StreamDecoder) GetRow(rowBuf sqlbase.EncDatumRow) (sqlbase.EncDatumRow, ProducerMetadata, error) + type StreamEncoder struct + func (se *StreamEncoder) AddMetadata(meta ProducerMetadata) + func (se *StreamEncoder) AddRow(row sqlbase.EncDatumRow) error + func (se *StreamEncoder) FormMessage(ctx context.Context) *ProducerMessage + type StreamEndpointSpec struct + StreamID StreamID + TargetAddr string + Type StreamEndpointSpec_Type + func (*StreamEndpointSpec) Descriptor() ([]byte, []int) + func (*StreamEndpointSpec) ProtoMessage() + func (m *StreamEndpointSpec) Marshal() (dAtA []byte, err error) + func (m *StreamEndpointSpec) MarshalTo(dAtA []byte) (int, error) + func (m *StreamEndpointSpec) Reset() + func (m *StreamEndpointSpec) Size() (n int) + func (m *StreamEndpointSpec) String() string + func (m *StreamEndpointSpec) Unmarshal(dAtA []byte) error + type StreamEndpointSpec_Type int32 + const StreamEndpointSpec_LOCAL + const StreamEndpointSpec_REMOTE + const StreamEndpointSpec_SYNC_RESPONSE + func (StreamEndpointSpec_Type) EnumDescriptor() ([]byte, []int) + func (x *StreamEndpointSpec_Type) UnmarshalJSON(data []byte) error + func (x StreamEndpointSpec_Type) Enum() *StreamEndpointSpec_Type + func (x StreamEndpointSpec_Type) String() string + type StreamID int + type TableReaderSpan struct + Span cockroach_roachpb1.Span + func (*TableReaderSpan) Descriptor() ([]byte, []int) + func (*TableReaderSpan) ProtoMessage() + func (m *TableReaderSpan) Marshal() (dAtA []byte, err error) + func (m *TableReaderSpan) MarshalTo(dAtA []byte) (int, error) + func (m *TableReaderSpan) Reset() + func (m *TableReaderSpan) Size() (n int) + func (m *TableReaderSpan) String() string + func (m *TableReaderSpan) Unmarshal(dAtA []byte) error + type TableReaderSpec struct + IndexIdx uint32 + LimitHint int64 + Reverse bool + Spans []TableReaderSpan + Table cockroach_sql_sqlbase1.TableDescriptor + func (*TableReaderSpec) Descriptor() ([]byte, []int) + func (*TableReaderSpec) ProtoMessage() + func (m *TableReaderSpec) Marshal() (dAtA []byte, err error) + func (m *TableReaderSpec) MarshalTo(dAtA []byte) (int, error) + func (m *TableReaderSpec) Reset() + func (m *TableReaderSpec) Size() (n int) + func (m *TableReaderSpec) String() string + func (m *TableReaderSpec) Unmarshal(dAtA []byte) error + type TestingKnobs struct + RunAfterBackfillChunk func() + RunBeforeBackfillChunk func(sp roachpb.Span) error + func (*TestingKnobs) ModuleTestingKnobs() + type ValuesCoreSpec struct + Columns []DatumInfo + RawBytes [][]byte + func (*ValuesCoreSpec) Descriptor() ([]byte, []int) + func (*ValuesCoreSpec) ProtoMessage() + func (m *ValuesCoreSpec) Marshal() (dAtA []byte, err error) + func (m *ValuesCoreSpec) MarshalTo(dAtA []byte) (int, error) + func (m *ValuesCoreSpec) Reset() + func (m *ValuesCoreSpec) Size() (n int) + func (m *ValuesCoreSpec) String() string + func (m *ValuesCoreSpec) Unmarshal(dAtA []byte) error