api

package
v0.0.0-debug-20260702 Latest Latest
Warning

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

 Go to latest Published: Jul 2, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Copyright 2021 - 2022 Matrix Origin

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

View Source 
const NoTransfer = uint8(0xFF)

NoTransfer is the sentinel ObjIdx value that marks a deleted (non-transferred) row.

Variables

View Source 
var (
	ErrInvalidLengthApi        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupApi = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var AlterKind_name = map[int32]string{
	0: "Invalid",
	1: "AddColumn",
	2: "DropColumn",
	3: "RenameTable",
	4: "UpdateComment",
	5: "UpdateConstraint",
	6: "UpdatePolicy",
	7: "AddPartition",
	8: "RenameColumn",
	9: "ReplaceDef",
}
View Source 
var AlterKind_value = map[string]int32{
	"Invalid":          0,
	"AddColumn":        1,
	"DropColumn":       2,
	"RenameTable":      3,
	"UpdateComment":    4,
	"UpdateConstraint": 5,
	"UpdatePolicy":     6,
	"AddPartition":     7,
	"RenameColumn":     8,
	"ReplaceDef":       9,
}
View Source 
var Entry_EntryType_name = map[int32]string{
	0: "Insert",
	1: "Delete",
	2: "Update",
	3: "Alter",
	4: "SpecialDelete",
	5: "DataObject",
	6: "TombstoneObject",
}
View Source 
var Entry_EntryType_value = map[string]int32{
	"Insert":          0,
	"Delete":          1,
	"Update":          2,
	"Alter":           3,
	"SpecialDelete":   4,
	"DataObject":      5,
	"TombstoneObject": 6,
}
View Source 
var MergeHint_name = map[int32]string{
	0: "Auto",
	1: "NoDeletes",
	2: "BigTable",
	3: "ContinuousWrite",
}
View Source 
var MergeHint_value = map[string]int32{
	"Auto":            0,
	"NoDeletes":       1,
	"BigTable":        2,
	"ContinuousWrite": 3,
}
View Source 
var OpCode_name = map[int32]string{
	0:    "Nop",
	1000: "OpGetLogTail",
	1001: "OpPreCommit",
	2000: "OpPing",
	2001: "OpFlush",
	2003: "OpCheckpoint",
	2004: "OpInspect",
	2005: "OpAddFaultPoint",
	2006: "OpBackup",
	2007: "OpTraceSpan",
	2008: "OpStorageUsage",
	2009: "OpGlobalCheckpoint",
	2010: "OpInterceptCommit",
	2011: "OpCommitMerge",
	2012: "OpDiskDiskCleaner",
	2013: "OpReader",
	2014: "OpGetLatestCheckpoint",
	2015: "OpSnapshotRead",
	2016: "OpGetChangedTableList",
	2017: "OpFaultInject",
}
View Source 
var OpCode_value = map[string]int32{
	"Nop":                   0,
	"OpGetLogTail":          1000,
	"OpPreCommit":           1001,
	"OpPing":                2000,
	"OpFlush":               2001,
	"OpCheckpoint":          2003,
	"OpInspect":             2004,
	"OpAddFaultPoint":       2005,
	"OpBackup":              2006,
	"OpTraceSpan":           2007,
	"OpStorageUsage":        2008,
	"OpGlobalCheckpoint":    2009,
	"OpInterceptCommit":     2010,
	"OpCommitMerge":         2011,
	"OpDiskDiskCleaner":     2012,
	"OpReader":              2013,
	"OpGetLatestCheckpoint": 2014,
	"OpSnapshotRead":        2015,
	"OpGetChangedTableList": 2016,
	"OpFaultInject":         2017,
}
View Source 
var (
	OpMethodName = map[OpCode]string{
		OpCode_OpPing:             "Ping",
		OpCode_OpFlush:            "Flush",
		OpCode_OpCheckpoint:       "Checkpoint",
		OpCode_OpInspect:          "Inspect",
		OpCode_OpAddFaultPoint:    "AddFaultPoint",
		OpCode_OpBackup:           "Backup",
		OpCode_OpTraceSpan:        "TraceSpan",
		OpCode_OpGlobalCheckpoint: "GlobalCheckpoint",
		OpCode_OpInterceptCommit:  "InterceptCommit",
		OpCode_OpCommitMerge:      "CommitMerge",
		OpCode_OpDiskDiskCleaner:  "DiskCleaner",
	}
)

Functions

func MustMarshalTblExtra 

func MustMarshalTblExtra(info *SchemaExtra) []byte

Types

type AlterKind added in v0.8.0 

type AlterKind int32
const (
	AlterKind_Invalid          AlterKind = 0
	AlterKind_AddColumn        AlterKind = 1
	AlterKind_DropColumn       AlterKind = 2
	AlterKind_RenameTable      AlterKind = 3
	AlterKind_UpdateComment    AlterKind = 4
	AlterKind_UpdateConstraint AlterKind = 5
	AlterKind_UpdatePolicy     AlterKind = 6
	AlterKind_AddPartition     AlterKind = 7
	AlterKind_RenameColumn     AlterKind = 8
	AlterKind_ReplaceDef       AlterKind = 9
)

func (AlterKind) EnumDescriptor added in v0.8.0 

func (AlterKind) EnumDescriptor() ([]byte, []int)

func (AlterKind) String added in v0.8.0 

func (x AlterKind) String() string

type AlterTableAddColumn added in v0.8.0 

type AlterTableAddColumn struct {
	Column               *plan.ColDef `protobuf:"bytes,1,opt,name=column,proto3" json:"column,omitempty"`
	InsertPosition       int32        `protobuf:"varint,2,opt,name=insert_position,json=insertPosition,proto3" json:"insert_position,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*AlterTableAddColumn) Descriptor added in v0.8.0 

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

func (*AlterTableAddColumn) GetColumn added in v0.8.0 

func (m *AlterTableAddColumn) GetColumn() *plan.ColDef

func (*AlterTableAddColumn) GetInsertPosition added in v0.8.0 

func (m *AlterTableAddColumn) GetInsertPosition() int32

func (*AlterTableAddColumn) Marshal added in v0.8.0 

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

func (*AlterTableAddColumn) MarshalTo added in v0.8.0 

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

func (*AlterTableAddColumn) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableAddColumn) ProtoMessage added in v0.8.0 

func (*AlterTableAddColumn) ProtoMessage()

func (*AlterTableAddColumn) ProtoSize added in v0.8.0 

func (m *AlterTableAddColumn) ProtoSize() (n int)

func (*AlterTableAddColumn) Reset added in v0.8.0 

func (m *AlterTableAddColumn) Reset()

func (*AlterTableAddColumn) String added in v0.8.0 

func (m *AlterTableAddColumn) String() string

func (*AlterTableAddColumn) Unmarshal added in v0.8.0 

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

func (*AlterTableAddColumn) XXX_DiscardUnknown added in v0.8.0 

func (m *AlterTableAddColumn) XXX_DiscardUnknown()

func (*AlterTableAddColumn) XXX_Marshal added in v0.8.0 

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

func (*AlterTableAddColumn) XXX_Merge added in v0.8.0 

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

func (*AlterTableAddColumn) XXX_Size added in v0.8.0 

func (m *AlterTableAddColumn) XXX_Size() int

func (*AlterTableAddColumn) XXX_Unmarshal added in v0.8.0 

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

type AlterTableComment added in v0.8.0 

type AlterTableComment struct {
	Comment              string   `protobuf:"bytes,1,opt,name=comment,proto3" json:"comment,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AlterTableComment) Descriptor added in v0.8.0 

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

func (*AlterTableComment) GetComment added in v0.8.0 

func (m *AlterTableComment) GetComment() string

func (*AlterTableComment) Marshal added in v0.8.0 

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

func (*AlterTableComment) MarshalTo added in v0.8.0 

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

func (*AlterTableComment) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableComment) ProtoMessage added in v0.8.0 

func (*AlterTableComment) ProtoMessage()

func (*AlterTableComment) ProtoSize added in v0.8.0 

func (m *AlterTableComment) ProtoSize() (n int)

func (*AlterTableComment) Reset added in v0.8.0 

func (m *AlterTableComment) Reset()

func (*AlterTableComment) String added in v0.8.0 

func (m *AlterTableComment) String() string

func (*AlterTableComment) Unmarshal added in v0.8.0 

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

func (*AlterTableComment) XXX_DiscardUnknown added in v0.8.0 

func (m *AlterTableComment) XXX_DiscardUnknown()

func (*AlterTableComment) XXX_Marshal added in v0.8.0 

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

func (*AlterTableComment) XXX_Merge added in v0.8.0 

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

func (*AlterTableComment) XXX_Size added in v0.8.0 

func (m *AlterTableComment) XXX_Size() int

func (*AlterTableComment) XXX_Unmarshal added in v0.8.0 

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

type AlterTableConstraint added in v0.8.0 

type AlterTableConstraint struct {
	Constraints          []byte   `protobuf:"bytes,1,opt,name=constraints,proto3" json:"constraints,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AlterTableConstraint) Descriptor added in v0.8.0 

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

func (*AlterTableConstraint) GetConstraints added in v0.8.0 

func (m *AlterTableConstraint) GetConstraints() []byte

func (*AlterTableConstraint) Marshal added in v0.8.0 

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

func (*AlterTableConstraint) MarshalTo added in v0.8.0 

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

func (*AlterTableConstraint) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableConstraint) ProtoMessage added in v0.8.0 

func (*AlterTableConstraint) ProtoMessage()

func (*AlterTableConstraint) ProtoSize added in v0.8.0 

func (m *AlterTableConstraint) ProtoSize() (n int)

func (*AlterTableConstraint) Reset added in v0.8.0 

func (m *AlterTableConstraint) Reset()

func (*AlterTableConstraint) String added in v0.8.0 

func (m *AlterTableConstraint) String() string

func (*AlterTableConstraint) Unmarshal added in v0.8.0 

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

func (*AlterTableConstraint) XXX_DiscardUnknown added in v0.8.0 

func (m *AlterTableConstraint) XXX_DiscardUnknown()

func (*AlterTableConstraint) XXX_Marshal added in v0.8.0 

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

func (*AlterTableConstraint) XXX_Merge added in v0.8.0 

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

func (*AlterTableConstraint) XXX_Size added in v0.8.0 

func (m *AlterTableConstraint) XXX_Size() int

func (*AlterTableConstraint) XXX_Unmarshal added in v0.8.0 

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

type AlterTableDropColumn added in v0.8.0 

type AlterTableDropColumn struct {
	LogicalIdx           uint32   `protobuf:"varint,1,opt,name=logical_idx,json=logicalIdx,proto3" json:"logical_idx,omitempty"`
	SequenceNum          uint32   `protobuf:"varint,2,opt,name=sequence_num,json=sequenceNum,proto3" json:"sequence_num,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AlterTableDropColumn) Descriptor added in v0.8.0 

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

func (*AlterTableDropColumn) GetLogicalIdx added in v0.8.0 

func (m *AlterTableDropColumn) GetLogicalIdx() uint32

func (*AlterTableDropColumn) GetSequenceNum added in v0.8.0 

func (m *AlterTableDropColumn) GetSequenceNum() uint32

func (*AlterTableDropColumn) Marshal added in v0.8.0 

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

func (*AlterTableDropColumn) MarshalTo added in v0.8.0 

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

func (*AlterTableDropColumn) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableDropColumn) ProtoMessage added in v0.8.0 

func (*AlterTableDropColumn) ProtoMessage()

func (*AlterTableDropColumn) ProtoSize added in v0.8.0 

func (m *AlterTableDropColumn) ProtoSize() (n int)

func (*AlterTableDropColumn) Reset added in v0.8.0 

func (m *AlterTableDropColumn) Reset()

func (*AlterTableDropColumn) String added in v0.8.0 

func (m *AlterTableDropColumn) String() string

func (*AlterTableDropColumn) Unmarshal added in v0.8.0 

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

func (*AlterTableDropColumn) XXX_DiscardUnknown added in v0.8.0 

func (m *AlterTableDropColumn) XXX_DiscardUnknown()

func (*AlterTableDropColumn) XXX_Marshal added in v0.8.0 

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

func (*AlterTableDropColumn) XXX_Merge added in v0.8.0 

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

func (*AlterTableDropColumn) XXX_Size added in v0.8.0 

func (m *AlterTableDropColumn) XXX_Size() int

func (*AlterTableDropColumn) XXX_Unmarshal added in v0.8.0 

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

type AlterTablePolicy added in v1.0.1 

type AlterTablePolicy struct {
	MinOsizeQuailifed    uint32      `protobuf:"varint,1,opt,name=min_osize_quailifed,json=minOsizeQuailifed,proto3" json:"min_osize_quailifed,omitempty"`
	MaxObjOnerun         uint32      `protobuf:"varint,2,opt,name=max_obj_onerun,json=maxObjOnerun,proto3" json:"max_obj_onerun,omitempty"`
	MaxOsizeMergedObj    uint32      `protobuf:"varint,3,opt,name=max_osize_merged_obj,json=maxOsizeMergedObj,proto3" json:"max_osize_merged_obj,omitempty"`
	Hints                []MergeHint `protobuf:"varint,4,rep,packed,name=hints,proto3,enum=api.MergeHint" json:"hints,omitempty"`
	MinCnMergeSize       uint64      `protobuf:"varint,5,opt,name=min_cn_merge_size,json=minCnMergeSize,proto3" json:"min_cn_merge_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*AlterTablePolicy) Descriptor added in v1.0.1 

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

func (*AlterTablePolicy) GetHints added in v1.0.1 

func (m *AlterTablePolicy) GetHints() []MergeHint

func (*AlterTablePolicy) GetMaxObjOnerun added in v1.0.1 

func (m *AlterTablePolicy) GetMaxObjOnerun() uint32

func (*AlterTablePolicy) GetMaxOsizeMergedObj added in v1.2.0 

func (m *AlterTablePolicy) GetMaxOsizeMergedObj() uint32

func (*AlterTablePolicy) GetMinCnMergeSize added in v1.2.0 

func (m *AlterTablePolicy) GetMinCnMergeSize() uint64

func (*AlterTablePolicy) GetMinOsizeQuailifed added in v1.2.0 

func (m *AlterTablePolicy) GetMinOsizeQuailifed() uint32

func (*AlterTablePolicy) Marshal added in v1.0.1 

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

func (*AlterTablePolicy) MarshalTo added in v1.0.1 

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

func (*AlterTablePolicy) MarshalToSizedBuffer added in v1.0.1 

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

func (*AlterTablePolicy) ProtoMessage added in v1.0.1 

func (*AlterTablePolicy) ProtoMessage()

func (*AlterTablePolicy) ProtoSize added in v1.0.1 

func (m *AlterTablePolicy) ProtoSize() (n int)

func (*AlterTablePolicy) Reset added in v1.0.1 

func (m *AlterTablePolicy) Reset()

func (*AlterTablePolicy) String added in v1.0.1 

func (m *AlterTablePolicy) String() string

func (*AlterTablePolicy) Unmarshal added in v1.0.1 

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

func (*AlterTablePolicy) XXX_DiscardUnknown added in v1.0.1 

func (m *AlterTablePolicy) XXX_DiscardUnknown()

func (*AlterTablePolicy) XXX_Marshal added in v1.0.1 

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

func (*AlterTablePolicy) XXX_Merge added in v1.0.1 

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

func (*AlterTablePolicy) XXX_Size added in v1.0.1 

func (m *AlterTablePolicy) XXX_Size() int

func (*AlterTablePolicy) XXX_Unmarshal added in v1.0.1 

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

type AlterTableRenameCol added in v1.2.0 

type AlterTableRenameCol struct {
	OldName              string   `protobuf:"bytes,1,opt,name=old_name,json=oldName,proto3" json:"old_name,omitempty"`
	NewName              string   `protobuf:"bytes,2,opt,name=new_name,json=newName,proto3" json:"new_name,omitempty"`
	SequenceNum          uint32   `protobuf:"varint,3,opt,name=sequence_num,json=sequenceNum,proto3" json:"sequence_num,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AlterTableRenameCol) Descriptor added in v1.2.0 

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

func (*AlterTableRenameCol) GetNewName added in v1.2.0 

func (m *AlterTableRenameCol) GetNewName() string

func (*AlterTableRenameCol) GetOldName added in v1.2.0 

func (m *AlterTableRenameCol) GetOldName() string

func (*AlterTableRenameCol) GetSequenceNum added in v1.2.0 

func (m *AlterTableRenameCol) GetSequenceNum() uint32

func (*AlterTableRenameCol) Marshal added in v1.2.0 

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

func (*AlterTableRenameCol) MarshalTo added in v1.2.0 

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

func (*AlterTableRenameCol) MarshalToSizedBuffer added in v1.2.0 

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

func (*AlterTableRenameCol) ProtoMessage added in v1.2.0 

func (*AlterTableRenameCol) ProtoMessage()

func (*AlterTableRenameCol) ProtoSize added in v1.2.0 

func (m *AlterTableRenameCol) ProtoSize() (n int)

func (*AlterTableRenameCol) Reset added in v1.2.0 

func (m *AlterTableRenameCol) Reset()

func (*AlterTableRenameCol) String added in v1.2.0 

func (m *AlterTableRenameCol) String() string

func (*AlterTableRenameCol) Unmarshal added in v1.2.0 

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

func (*AlterTableRenameCol) XXX_DiscardUnknown added in v1.2.0 

func (m *AlterTableRenameCol) XXX_DiscardUnknown()

func (*AlterTableRenameCol) XXX_Marshal added in v1.2.0 

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

func (*AlterTableRenameCol) XXX_Merge added in v1.2.0 

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

func (*AlterTableRenameCol) XXX_Size added in v1.2.0 

func (m *AlterTableRenameCol) XXX_Size() int

func (*AlterTableRenameCol) XXX_Unmarshal added in v1.2.0 

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

type AlterTableRenameTable added in v0.8.0 

type AlterTableRenameTable struct {
	OldName              string   `protobuf:"bytes,1,opt,name=old_name,json=oldName,proto3" json:"old_name,omitempty"`
	NewName              string   `protobuf:"bytes,2,opt,name=new_name,json=newName,proto3" json:"new_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AlterTableRenameTable) Descriptor added in v0.8.0 

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

func (*AlterTableRenameTable) GetNewName added in v0.8.0 

func (m *AlterTableRenameTable) GetNewName() string

func (*AlterTableRenameTable) GetOldName added in v0.8.0 

func (m *AlterTableRenameTable) GetOldName() string

func (*AlterTableRenameTable) Marshal added in v0.8.0 

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

func (*AlterTableRenameTable) MarshalTo added in v0.8.0 

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

func (*AlterTableRenameTable) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableRenameTable) ProtoMessage added in v0.8.0 

func (*AlterTableRenameTable) ProtoMessage()

func (*AlterTableRenameTable) ProtoSize added in v0.8.0 

func (m *AlterTableRenameTable) ProtoSize() (n int)

func (*AlterTableRenameTable) Reset added in v0.8.0 

func (m *AlterTableRenameTable) Reset()

func (*AlterTableRenameTable) String added in v0.8.0 

func (m *AlterTableRenameTable) String() string

func (*AlterTableRenameTable) Unmarshal added in v0.8.0 

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

func (*AlterTableRenameTable) XXX_DiscardUnknown added in v0.8.0 

func (m *AlterTableRenameTable) XXX_DiscardUnknown()

func (*AlterTableRenameTable) XXX_Marshal added in v0.8.0 

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

func (*AlterTableRenameTable) XXX_Merge added in v0.8.0 

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

func (*AlterTableRenameTable) XXX_Size added in v0.8.0 

func (m *AlterTableRenameTable) XXX_Size() int

func (*AlterTableRenameTable) XXX_Unmarshal added in v0.8.0 

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

type AlterTableReplaceDef 

type AlterTableReplaceDef struct {
	Def                  *plan.TableDef `protobuf:"bytes,1,opt,name=def,proto3" json:"def,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*AlterTableReplaceDef) Descriptor 

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

func (*AlterTableReplaceDef) GetDef 

func (m *AlterTableReplaceDef) GetDef() *plan.TableDef

func (*AlterTableReplaceDef) Marshal 

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

func (*AlterTableReplaceDef) MarshalTo 

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

func (*AlterTableReplaceDef) MarshalToSizedBuffer 

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

func (*AlterTableReplaceDef) ProtoMessage 

func (*AlterTableReplaceDef) ProtoMessage()

func (*AlterTableReplaceDef) ProtoSize 

func (m *AlterTableReplaceDef) ProtoSize() (n int)

func (*AlterTableReplaceDef) Reset 

func (m *AlterTableReplaceDef) Reset()

func (*AlterTableReplaceDef) String 

func (m *AlterTableReplaceDef) String() string

func (*AlterTableReplaceDef) Unmarshal 

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

func (*AlterTableReplaceDef) XXX_DiscardUnknown 

func (m *AlterTableReplaceDef) XXX_DiscardUnknown()

func (*AlterTableReplaceDef) XXX_Marshal 

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

func (*AlterTableReplaceDef) XXX_Merge 

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

func (*AlterTableReplaceDef) XXX_Size 

func (m *AlterTableReplaceDef) XXX_Size() int

func (*AlterTableReplaceDef) XXX_Unmarshal 

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

type AlterTableReq added in v0.8.0 

type AlterTableReq struct {
	TableId uint64    `protobuf:"varint,1,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	DbId    uint64    `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	Kind    AlterKind `protobuf:"varint,3,opt,name=kind,proto3,enum=api.AlterKind" json:"kind,omitempty"`
	// Types that are valid to be assigned to Operation:
	//	*AlterTableReq_AddColumn
	//	*AlterTableReq_DropColumn
	//	*AlterTableReq_RenameTable
	//	*AlterTableReq_UpdateComment
	//	*AlterTableReq_UpdateCstr
	//	*AlterTableReq_UpdatePolicy
	//	*AlterTableReq_RenameCol
	//	*AlterTableReq_ReplaceDef
	Operation            isAlterTableReq_Operation `protobuf_oneof:"operation"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func NewAddColumnReq added in v0.8.0 

func NewAddColumnReq(did, tid uint64, name string, typ plan.Type, insertAt int32) *AlterTableReq

func NewRemoveColumnReq added in v0.8.0 

func NewRemoveColumnReq(did, tid uint64, idx, seqnum uint32) *AlterTableReq

func NewRenameColumnReq added in v1.2.0 

func NewRenameColumnReq(did, tid uint64, oldname, newname string, seqnum uint32) *AlterTableReq

func NewRenameTableReq added in v0.8.0 

func NewRenameTableReq(did, tid uint64, old, new string) *AlterTableReq

func NewReplaceDefReq 

func NewReplaceDefReq(did, tid uint64, planDef *plan.TableDef) *AlterTableReq

func NewUpdateCommentReq added in v0.8.0 

func NewUpdateCommentReq(did, tid uint64, comment string) *AlterTableReq

func NewUpdateConstraintReq added in v0.8.0 

func NewUpdateConstraintReq(did, tid uint64, cstr string) *AlterTableReq

func (*AlterTableReq) Descriptor added in v0.8.0 

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

func (*AlterTableReq) GetAddColumn added in v0.8.0 

func (m *AlterTableReq) GetAddColumn() *AlterTableAddColumn

func (*AlterTableReq) GetDbId added in v0.8.0 

func (m *AlterTableReq) GetDbId() uint64

func (*AlterTableReq) GetDropColumn added in v0.8.0 

func (m *AlterTableReq) GetDropColumn() *AlterTableDropColumn

func (*AlterTableReq) GetKind added in v0.8.0 

func (m *AlterTableReq) GetKind() AlterKind

func (*AlterTableReq) GetOperation added in v0.8.0 

func (m *AlterTableReq) GetOperation() isAlterTableReq_Operation

func (*AlterTableReq) GetRenameCol added in v1.2.0 

func (m *AlterTableReq) GetRenameCol() *AlterTableRenameCol

func (*AlterTableReq) GetRenameTable added in v0.8.0 

func (m *AlterTableReq) GetRenameTable() *AlterTableRenameTable

func (*AlterTableReq) GetReplaceDef 

func (m *AlterTableReq) GetReplaceDef() *AlterTableReplaceDef

func (*AlterTableReq) GetTableId added in v0.8.0 

func (m *AlterTableReq) GetTableId() uint64

func (*AlterTableReq) GetUpdateComment added in v0.8.0 

func (m *AlterTableReq) GetUpdateComment() *AlterTableComment

func (*AlterTableReq) GetUpdateCstr added in v0.8.0 

func (m *AlterTableReq) GetUpdateCstr() *AlterTableConstraint

func (*AlterTableReq) GetUpdatePolicy added in v1.0.1 

func (m *AlterTableReq) GetUpdatePolicy() *AlterTablePolicy

func (*AlterTableReq) Marshal added in v0.8.0 

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

func (*AlterTableReq) MarshalTo added in v0.8.0 

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

func (*AlterTableReq) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableReq) ProtoMessage added in v0.8.0 

func (*AlterTableReq) ProtoMessage()

func (*AlterTableReq) ProtoSize added in v0.8.0 

func (m *AlterTableReq) ProtoSize() (n int)

func (*AlterTableReq) Reset added in v0.8.0 

func (m *AlterTableReq) Reset()

func (*AlterTableReq) String added in v0.8.0 

func (m *AlterTableReq) String() string

func (*AlterTableReq) Unmarshal added in v0.8.0 

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

func (*AlterTableReq) XXX_DiscardUnknown added in v0.8.0 

func (m *AlterTableReq) XXX_DiscardUnknown()

func (*AlterTableReq) XXX_Marshal added in v0.8.0 

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

func (*AlterTableReq) XXX_Merge added in v0.8.0 

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

func (*AlterTableReq) XXX_OneofWrappers added in v0.8.0 

func (*AlterTableReq) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*AlterTableReq) XXX_Size added in v0.8.0 

func (m *AlterTableReq) XXX_Size() int

func (*AlterTableReq) XXX_Unmarshal added in v0.8.0 

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

type AlterTableReq_AddColumn added in v0.8.0 

type AlterTableReq_AddColumn struct {
	AddColumn *AlterTableAddColumn `protobuf:"bytes,4,opt,name=add_column,json=addColumn,proto3,oneof" json:"add_column,omitempty"`
}

func (*AlterTableReq_AddColumn) MarshalTo added in v0.8.0 

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

func (*AlterTableReq_AddColumn) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableReq_AddColumn) ProtoSize added in v0.8.0 

func (m *AlterTableReq_AddColumn) ProtoSize() (n int)

type AlterTableReq_DropColumn added in v0.8.0 

type AlterTableReq_DropColumn struct {
	DropColumn *AlterTableDropColumn `protobuf:"bytes,5,opt,name=drop_column,json=dropColumn,proto3,oneof" json:"drop_column,omitempty"`
}

func (*AlterTableReq_DropColumn) MarshalTo added in v0.8.0 

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

func (*AlterTableReq_DropColumn) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableReq_DropColumn) ProtoSize added in v0.8.0 

func (m *AlterTableReq_DropColumn) ProtoSize() (n int)

type AlterTableReq_RenameCol added in v1.2.0 

type AlterTableReq_RenameCol struct {
	RenameCol *AlterTableRenameCol `protobuf:"bytes,11,opt,name=rename_col,json=renameCol,proto3,oneof" json:"rename_col,omitempty"`
}

func (*AlterTableReq_RenameCol) MarshalTo added in v1.2.0 

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

func (*AlterTableReq_RenameCol) MarshalToSizedBuffer added in v1.2.0 

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

func (*AlterTableReq_RenameCol) ProtoSize added in v1.2.0 

func (m *AlterTableReq_RenameCol) ProtoSize() (n int)

type AlterTableReq_RenameTable added in v0.8.0 

type AlterTableReq_RenameTable struct {
	RenameTable *AlterTableRenameTable `protobuf:"bytes,6,opt,name=rename_table,json=renameTable,proto3,oneof" json:"rename_table,omitempty"`
}

func (*AlterTableReq_RenameTable) MarshalTo added in v0.8.0 

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

func (*AlterTableReq_RenameTable) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableReq_RenameTable) ProtoSize added in v0.8.0 

func (m *AlterTableReq_RenameTable) ProtoSize() (n int)

type AlterTableReq_ReplaceDef 

type AlterTableReq_ReplaceDef struct {
	ReplaceDef *AlterTableReplaceDef `protobuf:"bytes,12,opt,name=replace_def,json=replaceDef,proto3,oneof" json:"replace_def,omitempty"`
}

func (*AlterTableReq_ReplaceDef) MarshalTo 

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

func (*AlterTableReq_ReplaceDef) MarshalToSizedBuffer 

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

func (*AlterTableReq_ReplaceDef) ProtoSize 

func (m *AlterTableReq_ReplaceDef) ProtoSize() (n int)

type AlterTableReq_UpdateComment added in v0.8.0 

type AlterTableReq_UpdateComment struct {
	UpdateComment *AlterTableComment `protobuf:"bytes,7,opt,name=update_comment,json=updateComment,proto3,oneof" json:"update_comment,omitempty"`
}

func (*AlterTableReq_UpdateComment) MarshalTo added in v0.8.0 

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

func (*AlterTableReq_UpdateComment) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableReq_UpdateComment) ProtoSize added in v0.8.0 

func (m *AlterTableReq_UpdateComment) ProtoSize() (n int)

type AlterTableReq_UpdateCstr added in v0.8.0 

type AlterTableReq_UpdateCstr struct {
	UpdateCstr *AlterTableConstraint `protobuf:"bytes,8,opt,name=update_cstr,json=updateCstr,proto3,oneof" json:"update_cstr,omitempty"`
}

func (*AlterTableReq_UpdateCstr) MarshalTo added in v0.8.0 

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

func (*AlterTableReq_UpdateCstr) MarshalToSizedBuffer added in v0.8.0 

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

func (*AlterTableReq_UpdateCstr) ProtoSize added in v0.8.0 

func (m *AlterTableReq_UpdateCstr) ProtoSize() (n int)

type AlterTableReq_UpdatePolicy added in v1.0.1 

type AlterTableReq_UpdatePolicy struct {
	UpdatePolicy *AlterTablePolicy `protobuf:"bytes,9,opt,name=update_policy,json=updatePolicy,proto3,oneof" json:"update_policy,omitempty"`
}

func (*AlterTableReq_UpdatePolicy) MarshalTo added in v1.0.1 

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

func (*AlterTableReq_UpdatePolicy) MarshalToSizedBuffer added in v1.0.1 

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

func (*AlterTableReq_UpdatePolicy) ProtoSize added in v1.0.1 

func (m *AlterTableReq_UpdatePolicy) ProtoSize() (n int)

type Batch 

type Batch struct {
	Attrs                []string `protobuf:"bytes,1,rep,name=attrs,proto3" json:"attrs,omitempty"`
	Vecs                 []Vector `protobuf:"bytes,2,rep,name=vecs,proto3" json:"vecs"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Batch) Descriptor 

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

func (*Batch) GetAttrs 

func (m *Batch) GetAttrs() []string

func (*Batch) GetVecs 

func (m *Batch) GetVecs() []Vector

func (*Batch) Marshal 

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

func (*Batch) MarshalTo 

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

func (*Batch) MarshalToSizedBuffer 

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

func (*Batch) ProtoMessage 

func (*Batch) ProtoMessage()

func (*Batch) ProtoSize 

func (m *Batch) ProtoSize() (n int)

func (*Batch) Reset 

func (m *Batch) Reset()

func (*Batch) String 

func (m *Batch) String() string

func (*Batch) Unmarshal 

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

func (*Batch) XXX_DiscardUnknown 

func (m *Batch) XXX_DiscardUnknown()

func (*Batch) XXX_Marshal 

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

func (*Batch) XXX_Merge 

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

func (*Batch) XXX_Size 

func (m *Batch) XXX_Size() int

func (*Batch) XXX_Unmarshal 

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

type BlkTransMap added in v1.2.0 

type BlkTransMap struct {
	M                    map[int32]TransDestPos `` /* 134-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*BlkTransMap) Descriptor added in v1.2.0 

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

func (*BlkTransMap) GetM added in v1.2.0 

func (m *BlkTransMap) GetM() map[int32]TransDestPos

func (*BlkTransMap) Marshal added in v1.2.0 

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

func (*BlkTransMap) MarshalTo added in v1.2.0 

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

func (*BlkTransMap) MarshalToSizedBuffer added in v1.2.0 

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

func (*BlkTransMap) ProtoMessage added in v1.2.0 

func (*BlkTransMap) ProtoMessage()

func (*BlkTransMap) ProtoSize added in v1.2.0 

func (m *BlkTransMap) ProtoSize() (n int)

func (*BlkTransMap) Reset added in v1.2.0 

func (m *BlkTransMap) Reset()

func (*BlkTransMap) String added in v1.2.0 

func (m *BlkTransMap) String() string

func (*BlkTransMap) Unmarshal added in v1.2.0 

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

func (*BlkTransMap) XXX_DiscardUnknown added in v1.2.0 

func (m *BlkTransMap) XXX_DiscardUnknown()

func (*BlkTransMap) XXX_Marshal added in v1.2.0 

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

func (*BlkTransMap) XXX_Merge added in v1.2.0 

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

func (*BlkTransMap) XXX_Size added in v1.2.0 

func (m *BlkTransMap) XXX_Size() int

func (*BlkTransMap) XXX_Unmarshal added in v1.2.0 

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

type BlkTransferBooking added in v1.2.0 

type BlkTransferBooking struct {
	Mappings             []BlkTransMap `protobuf:"bytes,1,rep,name=mappings,proto3" json:"mappings"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*BlkTransferBooking) Descriptor added in v1.2.0 

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

func (*BlkTransferBooking) GetMappings added in v1.2.0 

func (m *BlkTransferBooking) GetMappings() []BlkTransMap

func (*BlkTransferBooking) Marshal added in v1.2.0 

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

func (*BlkTransferBooking) MarshalTo added in v1.2.0 

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

func (*BlkTransferBooking) MarshalToSizedBuffer added in v1.2.0 

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

func (*BlkTransferBooking) ProtoMessage added in v1.2.0 

func (*BlkTransferBooking) ProtoMessage()

func (*BlkTransferBooking) ProtoSize added in v1.2.0 

func (m *BlkTransferBooking) ProtoSize() (n int)

func (*BlkTransferBooking) Reset added in v1.2.0 

func (m *BlkTransferBooking) Reset()

func (*BlkTransferBooking) String added in v1.2.0 

func (m *BlkTransferBooking) String() string

func (*BlkTransferBooking) Unmarshal added in v1.2.0 

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

func (*BlkTransferBooking) XXX_DiscardUnknown added in v1.2.0 

func (m *BlkTransferBooking) XXX_DiscardUnknown()

func (*BlkTransferBooking) XXX_Marshal added in v1.2.0 

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

func (*BlkTransferBooking) XXX_Merge added in v1.2.0 

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

func (*BlkTransferBooking) XXX_Size added in v1.2.0 

func (m *BlkTransferBooking) XXX_Size() int

func (*BlkTransferBooking) XXX_Unmarshal added in v1.2.0 

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

type CatalogCkp 

type CatalogCkp struct {
	MinTs                *timestamp.Timestamp `protobuf:"bytes,1,opt,name=min_ts,json=minTs,proto3" json:"min_ts,omitempty"`
	MaxTs                *timestamp.Timestamp `protobuf:"bytes,2,opt,name=max_ts,json=maxTs,proto3" json:"max_ts,omitempty"`
	Bat                  *Batch               `protobuf:"bytes,3,opt,name=bat,proto3" json:"bat,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

catalog checkpoint: one Batch represents a table, such as : mo_databases, mo_tables, mo_columns,... etc. knowing more about system tables, pls ref to pkg/vm/engine/tae/catalog/model.go

func (*CatalogCkp) Descriptor 

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

func (*CatalogCkp) GetBat 

func (m *CatalogCkp) GetBat() *Batch

func (*CatalogCkp) GetMaxTs 

func (m *CatalogCkp) GetMaxTs() *timestamp.Timestamp

func (*CatalogCkp) GetMinTs 

func (m *CatalogCkp) GetMinTs() *timestamp.Timestamp

func (*CatalogCkp) Marshal 

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

func (*CatalogCkp) MarshalTo 

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

func (*CatalogCkp) MarshalToSizedBuffer 

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

func (*CatalogCkp) ProtoMessage 

func (*CatalogCkp) ProtoMessage()

func (*CatalogCkp) ProtoSize 

func (m *CatalogCkp) ProtoSize() (n int)

func (*CatalogCkp) Reset 

func (m *CatalogCkp) Reset()

func (*CatalogCkp) String 

func (m *CatalogCkp) String() string

func (*CatalogCkp) Unmarshal 

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

func (*CatalogCkp) XXX_DiscardUnknown 

func (m *CatalogCkp) XXX_DiscardUnknown()

func (*CatalogCkp) XXX_Marshal 

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

func (*CatalogCkp) XXX_Merge 

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

func (*CatalogCkp) XXX_Size 

func (m *CatalogCkp) XXX_Size() int

func (*CatalogCkp) XXX_Unmarshal 

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

type Checkpoint 

type Checkpoint struct {
	// min_ts TN is the lower bounds of the checkpoint
	//  CN maybe don't care about it.
	MinTs *timestamp.Timestamp `protobuf:"bytes,1,opt,name=min_ts,json=minTs,proto3" json:"min_ts,omitempty"`
	// max_ts is the upper bounds of the checkpoint.
	//  CN maybe don't care about it.
	MaxTs                *timestamp.Timestamp `protobuf:"bytes,2,opt,name=max_ts,json=maxTs,proto3" json:"max_ts,omitempty"`
	Bat                  *Batch               `protobuf:"bytes,3,opt,name=bat,proto3" json:"bat,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

CatalogCkp contains information about database and tables in the system,and MetadataCkp contains information about blocks.

func (*Checkpoint) Descriptor 

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

func (*Checkpoint) GetBat 

func (m *Checkpoint) GetBat() *Batch

func (*Checkpoint) GetMaxTs 

func (m *Checkpoint) GetMaxTs() *timestamp.Timestamp

func (*Checkpoint) GetMinTs 

func (m *Checkpoint) GetMinTs() *timestamp.Timestamp

func (*Checkpoint) Marshal 

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

func (*Checkpoint) MarshalTo 

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

func (*Checkpoint) MarshalToSizedBuffer 

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

func (*Checkpoint) ProtoMessage 

func (*Checkpoint) ProtoMessage()

func (*Checkpoint) ProtoSize 

func (m *Checkpoint) ProtoSize() (n int)

func (*Checkpoint) Reset 

func (m *Checkpoint) Reset()

func (*Checkpoint) String 

func (m *Checkpoint) String() string

func (*Checkpoint) Unmarshal 

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

func (*Checkpoint) XXX_DiscardUnknown 

func (m *Checkpoint) XXX_DiscardUnknown()

func (*Checkpoint) XXX_Marshal 

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

func (*Checkpoint) XXX_Merge 

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

func (*Checkpoint) XXX_Size 

func (m *Checkpoint) XXX_Size() int

func (*Checkpoint) XXX_Unmarshal 

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

type CheckpointResp 

type CheckpointResp struct {
	Location             string   `protobuf:"bytes,1,opt,name=Location,proto3" json:"Location,omitempty"`
	TruncateLsn          uint64   `protobuf:"varint,2,opt,name=truncateLsn,proto3" json:"truncateLsn,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CheckpointResp) Descriptor 

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

func (*CheckpointResp) GetLocation 

func (m *CheckpointResp) GetLocation() string

func (*CheckpointResp) GetTruncateLsn 

func (m *CheckpointResp) GetTruncateLsn() uint64

func (*CheckpointResp) Marshal 

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

func (*CheckpointResp) MarshalBinary 

func (m *CheckpointResp) MarshalBinary() ([]byte, error)

func (*CheckpointResp) MarshalTo 

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

func (*CheckpointResp) MarshalToSizedBuffer 

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

func (*CheckpointResp) ProtoMessage 

func (*CheckpointResp) ProtoMessage()

func (*CheckpointResp) ProtoSize 

func (m *CheckpointResp) ProtoSize() (n int)

func (*CheckpointResp) Reset 

func (m *CheckpointResp) Reset()

func (*CheckpointResp) String 

func (m *CheckpointResp) String() string

func (*CheckpointResp) Unmarshal 

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

func (*CheckpointResp) UnmarshalBinary 

func (m *CheckpointResp) UnmarshalBinary(data []byte) error

func (*CheckpointResp) XXX_DiscardUnknown 

func (m *CheckpointResp) XXX_DiscardUnknown()

func (*CheckpointResp) XXX_Marshal 

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

func (*CheckpointResp) XXX_Merge 

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

func (*CheckpointResp) XXX_Size 

func (m *CheckpointResp) XXX_Size() int

func (*CheckpointResp) XXX_Unmarshal 

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

type Entry 

type Entry struct {
	EntryType    Entry_EntryType `protobuf:"varint,1,opt,name=entry_type,json=entryType,proto3,enum=api.Entry_EntryType" json:"entry_type,omitempty"`
	TableId      uint64          `protobuf:"varint,2,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	DatabaseId   uint64          `protobuf:"varint,3,opt,name=database_id,json=databaseId,proto3" json:"database_id,omitempty"`
	TableName    string          `protobuf:"bytes,4,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	DatabaseName string          `protobuf:"bytes,5,opt,name=database_name,json=databaseName,proto3" json:"database_name,omitempty"`
	FileName     string          `protobuf:"bytes,6,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	Bat          *Batch          `protobuf:"bytes,7,opt,name=bat,proto3" json:"bat,omitempty"`
	// whether TN do the PK uniqueness check against txn's workspace or not.
	PkCheckByTn          int32    `protobuf:"varint,8,opt,name=pk_check_by_tn,json=pkCheckByTn,proto3" json:"pk_check_by_tn,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Entry) Descriptor 

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

func (*Entry) GetBat 

func (m *Entry) GetBat() *Batch

func (*Entry) GetDatabaseId 

func (m *Entry) GetDatabaseId() uint64

func (*Entry) GetDatabaseName 

func (m *Entry) GetDatabaseName() string

func (*Entry) GetEntryType 

func (m *Entry) GetEntryType() Entry_EntryType

func (*Entry) GetFileName 

func (m *Entry) GetFileName() string

func (*Entry) GetPkCheckByTn added in v1.0.0 

func (m *Entry) GetPkCheckByTn() int32

func (*Entry) GetTableId 

func (m *Entry) GetTableId() uint64

func (*Entry) GetTableName 

func (m *Entry) GetTableName() string

func (*Entry) Marshal 

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

func (*Entry) MarshalTo 

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

func (*Entry) MarshalToSizedBuffer 

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

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) ProtoSize 

func (m *Entry) ProtoSize() (n int)

func (*Entry) Reset 

func (m *Entry) Reset()

func (*Entry) String 

func (m *Entry) String() string

func (*Entry) Unmarshal 

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

func (*Entry) XXX_DiscardUnknown 

func (m *Entry) XXX_DiscardUnknown()

func (*Entry) XXX_Marshal 

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

func (*Entry) XXX_Merge 

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

func (*Entry) XXX_Size 

func (m *Entry) XXX_Size() int

func (*Entry) XXX_Unmarshal 

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

type Entry_EntryType 

type Entry_EntryType int32
const (
	Entry_Insert          Entry_EntryType = 0
	Entry_Delete          Entry_EntryType = 1
	Entry_Update          Entry_EntryType = 2
	Entry_Alter           Entry_EntryType = 3
	Entry_SpecialDelete   Entry_EntryType = 4
	Entry_DataObject      Entry_EntryType = 5
	Entry_TombstoneObject Entry_EntryType = 6
)

func (Entry_EntryType) EnumDescriptor 

func (Entry_EntryType) EnumDescriptor() ([]byte, []int)

func (Entry_EntryType) String 

func (x Entry_EntryType) String() string

type Int64Map added in v0.8.0 

type Int64Map struct {
	M                    map[int64]int64 `` /* 145-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Int64Map mainly used in unit test

func (*Int64Map) Descriptor added in v0.8.0 

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

func (*Int64Map) GetM added in v0.8.0 

func (m *Int64Map) GetM() map[int64]int64

func (*Int64Map) Marshal added in v0.8.0 

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

func (*Int64Map) MarshalTo added in v0.8.0 

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

func (*Int64Map) MarshalToSizedBuffer added in v0.8.0 

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

func (*Int64Map) ProtoMessage added in v0.8.0 

func (*Int64Map) ProtoMessage()

func (*Int64Map) ProtoSize added in v0.8.0 

func (m *Int64Map) ProtoSize() (n int)

func (*Int64Map) Reset added in v0.8.0 

func (m *Int64Map) Reset()

func (*Int64Map) String added in v0.8.0 

func (m *Int64Map) String() string

func (*Int64Map) Unmarshal added in v0.8.0 

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

func (*Int64Map) XXX_DiscardUnknown added in v0.8.0 

func (m *Int64Map) XXX_DiscardUnknown()

func (*Int64Map) XXX_Marshal added in v0.8.0 

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

func (*Int64Map) XXX_Merge added in v0.8.0 

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

func (*Int64Map) XXX_Size added in v0.8.0 

func (m *Int64Map) XXX_Size() int

func (*Int64Map) XXX_Unmarshal added in v0.8.0 

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

type MergeCommitEntry added in v1.2.0 

type MergeCommitEntry struct {
	DbId                 uint64              `protobuf:"varint,1,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TblId                uint64              `protobuf:"varint,2,opt,name=tbl_id,json=tblId,proto3" json:"tbl_id,omitempty"`
	TableName            string              `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	StartTs              timestamp.Timestamp `protobuf:"bytes,4,opt,name=start_ts,json=startTs,proto3" json:"start_ts"`
	MergedObjs           [][]byte            `protobuf:"bytes,5,rep,name=merged_objs,json=mergedObjs,proto3" json:"merged_objs,omitempty"`
	CreatedObjs          [][]byte            `protobuf:"bytes,6,rep,name=created_objs,json=createdObjs,proto3" json:"created_objs,omitempty"`
	Booking              *BlkTransferBooking `protobuf:"bytes,7,opt,name=booking,proto3" json:"booking,omitempty"`
	BookingLoc           []string            `protobuf:"bytes,8,rep,name=booking_loc,json=bookingLoc,proto3" json:"booking_loc,omitempty"`
	Err                  string              `protobuf:"bytes,9,opt,name=err,proto3" json:"err,omitempty"`
	Level                int32               `protobuf:"varint,10,opt,name=level,proto3" json:"level,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*MergeCommitEntry) Descriptor added in v1.2.0 

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

func (*MergeCommitEntry) GetBooking added in v1.2.0 

func (m *MergeCommitEntry) GetBooking() *BlkTransferBooking

func (*MergeCommitEntry) GetBookingLoc added in v1.2.0 

func (m *MergeCommitEntry) GetBookingLoc() []string

func (*MergeCommitEntry) GetCreatedObjs added in v1.2.0 

func (m *MergeCommitEntry) GetCreatedObjs() [][]byte

func (*MergeCommitEntry) GetDbId added in v1.2.0 

func (m *MergeCommitEntry) GetDbId() uint64

func (*MergeCommitEntry) GetErr added in v1.2.0 

func (m *MergeCommitEntry) GetErr() string

func (*MergeCommitEntry) GetLevel 

func (m *MergeCommitEntry) GetLevel() int32

func (*MergeCommitEntry) GetMergedObjs added in v1.2.0 

func (m *MergeCommitEntry) GetMergedObjs() [][]byte

func (*MergeCommitEntry) GetStartTs added in v1.2.0 

func (m *MergeCommitEntry) GetStartTs() timestamp.Timestamp

func (*MergeCommitEntry) GetTableName added in v1.2.0 

func (m *MergeCommitEntry) GetTableName() string

func (*MergeCommitEntry) GetTblId added in v1.2.0 

func (m *MergeCommitEntry) GetTblId() uint64

func (*MergeCommitEntry) Marshal added in v1.2.0 

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

func (*MergeCommitEntry) MarshalBinary added in v1.2.0 

func (m *MergeCommitEntry) MarshalBinary() ([]byte, error)

func (*MergeCommitEntry) MarshalTo added in v1.2.0 

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

func (*MergeCommitEntry) MarshalToSizedBuffer added in v1.2.0 

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

func (*MergeCommitEntry) ProtoMessage added in v1.2.0 

func (*MergeCommitEntry) ProtoMessage()

func (*MergeCommitEntry) ProtoSize added in v1.2.0 

func (m *MergeCommitEntry) ProtoSize() (n int)

func (*MergeCommitEntry) Reset added in v1.2.0 

func (m *MergeCommitEntry) Reset()

func (*MergeCommitEntry) String added in v1.2.0 

func (m *MergeCommitEntry) String() string

func (*MergeCommitEntry) Unmarshal added in v1.2.0 

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

func (*MergeCommitEntry) UnmarshalBinary added in v1.2.0 

func (m *MergeCommitEntry) UnmarshalBinary(data []byte) error

func (*MergeCommitEntry) XXX_DiscardUnknown added in v1.2.0 

func (m *MergeCommitEntry) XXX_DiscardUnknown()

func (*MergeCommitEntry) XXX_Marshal added in v1.2.0 

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

func (*MergeCommitEntry) XXX_Merge added in v1.2.0 

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

func (*MergeCommitEntry) XXX_Size added in v1.2.0 

func (m *MergeCommitEntry) XXX_Size() int

func (*MergeCommitEntry) XXX_Unmarshal added in v1.2.0 

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

type MergeHint added in v1.0.1 

type MergeHint int32
const (
	MergeHint_Auto            MergeHint = 0
	MergeHint_NoDeletes       MergeHint = 1
	MergeHint_BigTable        MergeHint = 2
	MergeHint_ContinuousWrite MergeHint = 3
)

func (MergeHint) EnumDescriptor added in v1.0.1 

func (MergeHint) EnumDescriptor() ([]byte, []int)

func (MergeHint) String added in v1.0.1 

func (x MergeHint) String() string

type MergeTaskEntry added in v1.2.0 

type MergeTaskEntry struct {
	DbId      uint64 `protobuf:"varint,1,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TblId     uint64 `protobuf:"varint,2,opt,name=tbl_id,json=tblId,proto3" json:"tbl_id,omitempty"`
	TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	DbName    string `protobuf:"bytes,4,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// ObjectStats
	ToMergeObjs          [][]byte `protobuf:"bytes,5,rep,name=to_merge_objs,json=toMergeObjs,proto3" json:"to_merge_objs,omitempty"`
	EstimatedMemUsage    uint64   `protobuf:"varint,6,opt,name=estimated_mem_usage,json=estimatedMemUsage,proto3" json:"estimated_mem_usage,omitempty"`
	AccountId            uint32   `protobuf:"varint,7,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	UserId               uint32   `protobuf:"varint,8,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	RoleId               uint32   `protobuf:"varint,9,opt,name=role_id,json=roleId,proto3" json:"role_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MergeTaskEntry) Descriptor added in v1.2.0 

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

func (*MergeTaskEntry) GetAccountId added in v1.2.0 

func (m *MergeTaskEntry) GetAccountId() uint32

func (*MergeTaskEntry) GetDbId added in v1.2.0 

func (m *MergeTaskEntry) GetDbId() uint64

func (*MergeTaskEntry) GetDbName added in v1.2.0 

func (m *MergeTaskEntry) GetDbName() string

func (*MergeTaskEntry) GetEstimatedMemUsage added in v1.2.0 

func (m *MergeTaskEntry) GetEstimatedMemUsage() uint64

func (*MergeTaskEntry) GetRoleId added in v1.2.0 

func (m *MergeTaskEntry) GetRoleId() uint32

func (*MergeTaskEntry) GetTableName added in v1.2.0 

func (m *MergeTaskEntry) GetTableName() string

func (*MergeTaskEntry) GetTblId added in v1.2.0 

func (m *MergeTaskEntry) GetTblId() uint64

func (*MergeTaskEntry) GetToMergeObjs added in v1.2.0 

func (m *MergeTaskEntry) GetToMergeObjs() [][]byte

func (*MergeTaskEntry) GetUserId added in v1.2.0 

func (m *MergeTaskEntry) GetUserId() uint32

func (*MergeTaskEntry) Marshal added in v1.2.0 

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

func (*MergeTaskEntry) MarshalTo added in v1.2.0 

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

func (*MergeTaskEntry) MarshalToSizedBuffer added in v1.2.0 

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

func (*MergeTaskEntry) ProtoMessage added in v1.2.0 

func (*MergeTaskEntry) ProtoMessage()

func (*MergeTaskEntry) ProtoSize added in v1.2.0 

func (m *MergeTaskEntry) ProtoSize() (n int)

func (*MergeTaskEntry) Reset added in v1.2.0 

func (m *MergeTaskEntry) Reset()

func (*MergeTaskEntry) String added in v1.2.0 

func (m *MergeTaskEntry) String() string

func (*MergeTaskEntry) Unmarshal added in v1.2.0 

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

func (*MergeTaskEntry) XXX_DiscardUnknown added in v1.2.0 

func (m *MergeTaskEntry) XXX_DiscardUnknown()

func (*MergeTaskEntry) XXX_Marshal added in v1.2.0 

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

func (*MergeTaskEntry) XXX_Merge added in v1.2.0 

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

func (*MergeTaskEntry) XXX_Size added in v1.2.0 

func (m *MergeTaskEntry) XXX_Size() int

func (*MergeTaskEntry) XXX_Unmarshal added in v1.2.0 

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

type MetadataCkp 

type MetadataCkp struct {
	MinTs *timestamp.Timestamp `protobuf:"bytes,1,opt,name=min_ts,json=minTs,proto3" json:"min_ts,omitempty"`
	MaxTs *timestamp.Timestamp `protobuf:"bytes,2,opt,name=max_ts,json=maxTs,proto3" json:"max_ts,omitempty"`
	// block meta data for a table;
	Bat                  *Batch   `protobuf:"bytes,3,opt,name=bat,proto3" json:"bat,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

metadata checkpoint: 

Batch is a batch of block metadata for a table,
one row of Batch represents a block meta data.
TODO::
knowing more about block meta data , pls ref to ...

func (*MetadataCkp) Descriptor 

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

func (*MetadataCkp) GetBat 

func (m *MetadataCkp) GetBat() *Batch

func (*MetadataCkp) GetMaxTs 

func (m *MetadataCkp) GetMaxTs() *timestamp.Timestamp

func (*MetadataCkp) GetMinTs 

func (m *MetadataCkp) GetMinTs() *timestamp.Timestamp

func (*MetadataCkp) Marshal 

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

func (*MetadataCkp) MarshalTo 

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

func (*MetadataCkp) MarshalToSizedBuffer 

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

func (*MetadataCkp) ProtoMessage 

func (*MetadataCkp) ProtoMessage()

func (*MetadataCkp) ProtoSize 

func (m *MetadataCkp) ProtoSize() (n int)

func (*MetadataCkp) Reset 

func (m *MetadataCkp) Reset()

func (*MetadataCkp) String 

func (m *MetadataCkp) String() string

func (*MetadataCkp) Unmarshal 

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

func (*MetadataCkp) XXX_DiscardUnknown 

func (m *MetadataCkp) XXX_DiscardUnknown()

func (*MetadataCkp) XXX_Marshal 

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

func (*MetadataCkp) XXX_Merge 

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

func (*MetadataCkp) XXX_Size 

func (m *MetadataCkp) XXX_Size() int

func (*MetadataCkp) XXX_Unmarshal 

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

type OpCode 

type OpCode int32
const (
	OpCode_Nop                   OpCode = 0
	OpCode_OpGetLogTail          OpCode = 1000
	OpCode_OpPreCommit           OpCode = 1001
	OpCode_OpPing                OpCode = 2000
	OpCode_OpFlush               OpCode = 2001
	OpCode_OpCheckpoint          OpCode = 2003
	OpCode_OpInspect             OpCode = 2004
	OpCode_OpAddFaultPoint       OpCode = 2005
	OpCode_OpBackup              OpCode = 2006
	OpCode_OpTraceSpan           OpCode = 2007
	OpCode_OpStorageUsage        OpCode = 2008
	OpCode_OpGlobalCheckpoint    OpCode = 2009
	OpCode_OpInterceptCommit     OpCode = 2010
	OpCode_OpCommitMerge         OpCode = 2011
	OpCode_OpDiskDiskCleaner     OpCode = 2012
	OpCode_OpReader              OpCode = 2013
	OpCode_OpGetLatestCheckpoint OpCode = 2014
	OpCode_OpSnapshotRead        OpCode = 2015
	OpCode_OpGetChangedTableList OpCode = 2016
	OpCode_OpFaultInject         OpCode = 2017
)

func (OpCode) EnumDescriptor 

func (OpCode) EnumDescriptor() ([]byte, []int)

func (OpCode) String 

func (x OpCode) String() string

type PrecommitWriteCmd 

type PrecommitWriteCmd struct {
	EntryList []*Entry `protobuf:"bytes,1,rep,name=entry_list,json=entryList,proto3" json:"entry_list,omitempty"`
	// Job ID for sync protection validation during CCPR commits.
	// When non-empty, TN validates the sync protection is still valid at prepareTS.
	SyncProtectionJobId  string   `protobuf:"bytes,2,opt,name=sync_protection_job_id,json=syncProtectionJobId,proto3" json:"sync_protection_job_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

How to parse and handle PrecommiWriteCmd , pls ref to tae/rpc/handle.go/HandlePreCommit function

func (*PrecommitWriteCmd) Descriptor 

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

func (*PrecommitWriteCmd) GetEntryList 

func (m *PrecommitWriteCmd) GetEntryList() []*Entry

func (*PrecommitWriteCmd) GetSyncProtectionJobId 

func (m *PrecommitWriteCmd) GetSyncProtectionJobId() string

func (*PrecommitWriteCmd) Marshal 

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

func (*PrecommitWriteCmd) MarshalBinary added in v0.8.0 

func (m *PrecommitWriteCmd) MarshalBinary() ([]byte, error)

func (*PrecommitWriteCmd) MarshalTo 

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

func (*PrecommitWriteCmd) MarshalToSizedBuffer 

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

func (*PrecommitWriteCmd) ProtoMessage 

func (*PrecommitWriteCmd) ProtoMessage()

func (*PrecommitWriteCmd) ProtoSize 

func (m *PrecommitWriteCmd) ProtoSize() (n int)

func (*PrecommitWriteCmd) Reset 

func (m *PrecommitWriteCmd) Reset()

func (*PrecommitWriteCmd) String 

func (m *PrecommitWriteCmd) String() string

func (*PrecommitWriteCmd) Unmarshal 

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

func (*PrecommitWriteCmd) UnmarshalBinary added in v0.8.0 

func (m *PrecommitWriteCmd) UnmarshalBinary(data []byte) error

func (*PrecommitWriteCmd) XXX_DiscardUnknown 

func (m *PrecommitWriteCmd) XXX_DiscardUnknown()

func (*PrecommitWriteCmd) XXX_Marshal 

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

func (*PrecommitWriteCmd) XXX_Merge 

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

func (*PrecommitWriteCmd) XXX_Size 

func (m *PrecommitWriteCmd) XXX_Size() int

func (*PrecommitWriteCmd) XXX_Unmarshal 

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

type SchemaExtra added in v0.8.0 

type SchemaExtra struct {
	NextColSeqnum uint32 `protobuf:"varint,1,opt,name=next_col_seqnum,json=nextColSeqnum,proto3" json:"next_col_seqnum,omitempty"`
	// sending mo_columns deletes according to this.
	DroppedAttrs  []string `protobuf:"bytes,2,rep,name=dropped_attrs,json=droppedAttrs,proto3" json:"dropped_attrs,omitempty"`
	ColumnChanged bool     `protobuf:"varint,3,opt,name=column_changed,json=columnChanged,proto3" json:"column_changed,omitempty"`
	// sending mo_tables deletes by this.
	OldName           string      `protobuf:"bytes,4,opt,name=old_name,json=oldName,proto3" json:"old_name,omitempty"`
	MinOsizeQuailifed uint32      `protobuf:"varint,5,opt,name=min_osize_quailifed,json=minOsizeQuailifed,proto3" json:"min_osize_quailifed,omitempty"`
	MaxObjOnerun      uint32      `protobuf:"varint,6,opt,name=max_obj_onerun,json=maxObjOnerun,proto3" json:"max_obj_onerun,omitempty"`
	MaxOsizeMergedObj uint32      `protobuf:"varint,7,opt,name=max_osize_merged_obj,json=maxOsizeMergedObj,proto3" json:"max_osize_merged_obj,omitempty"`
	Hints             []MergeHint `protobuf:"varint,8,rep,packed,name=hints,proto3,enum=api.MergeHint" json:"hints,omitempty"`
	MinCnMergeSize    uint64      `protobuf:"varint,9,opt,name=min_cn_merge_size,json=minCnMergeSize,proto3" json:"min_cn_merge_size,omitempty"`
	BlockMaxRows      uint32      `protobuf:"varint,10,opt,name=block_max_rows,json=blockMaxRows,proto3" json:"block_max_rows,omitempty"`
	ObjectMaxBlocks   uint32      `protobuf:"varint,11,opt,name=object_max_blocks,json=objectMaxBlocks,proto3" json:"object_max_blocks,omitempty"`
	FeatureFlag       uint64      `protobuf:"varint,12,opt,name=FeatureFlag,proto3" json:"FeatureFlag,omitempty"`
	IndexTables       []uint64    `protobuf:"varint,13,rep,packed,name=IndexTables,proto3" json:"IndexTables,omitempty"`
	ParentTableID     uint64      `protobuf:"varint,14,opt,name=ParentTableID,proto3" json:"ParentTableID,omitempty"`
	// mark if table is created by publication (CCPR), should skip merge
	FromPublication      bool     `protobuf:"varint,15,opt,name=FromPublication,proto3" json:"FromPublication,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func CloneExtra 

func CloneExtra(info *SchemaExtra) *SchemaExtra

func MustUnmarshalTblExtra 

func MustUnmarshalTblExtra(data []byte) *SchemaExtra

func (*SchemaExtra) Descriptor added in v0.8.0 

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

func (*SchemaExtra) GetBlockMaxRows 

func (m *SchemaExtra) GetBlockMaxRows() uint32

func (*SchemaExtra) GetColumnChanged added in v0.8.0 

func (m *SchemaExtra) GetColumnChanged() bool

func (*SchemaExtra) GetDroppedAttrs added in v0.8.0 

func (m *SchemaExtra) GetDroppedAttrs() []string

func (*SchemaExtra) GetFeatureFlag 

func (m *SchemaExtra) GetFeatureFlag() uint64

func (*SchemaExtra) GetFromPublication 

func (m *SchemaExtra) GetFromPublication() bool

func (*SchemaExtra) GetHints added in v1.0.1 

func (m *SchemaExtra) GetHints() []MergeHint

func (*SchemaExtra) GetIndexTables 

func (m *SchemaExtra) GetIndexTables() []uint64

func (*SchemaExtra) GetMaxObjOnerun added in v1.0.1 

func (m *SchemaExtra) GetMaxObjOnerun() uint32

func (*SchemaExtra) GetMaxOsizeMergedObj added in v1.2.0 

func (m *SchemaExtra) GetMaxOsizeMergedObj() uint32

func (*SchemaExtra) GetMinCnMergeSize added in v1.2.0 

func (m *SchemaExtra) GetMinCnMergeSize() uint64

func (*SchemaExtra) GetMinOsizeQuailifed added in v1.2.0 

func (m *SchemaExtra) GetMinOsizeQuailifed() uint32

func (*SchemaExtra) GetNextColSeqnum added in v0.8.0 

func (m *SchemaExtra) GetNextColSeqnum() uint32

func (*SchemaExtra) GetObjectMaxBlocks 

func (m *SchemaExtra) GetObjectMaxBlocks() uint32

func (*SchemaExtra) GetOldName added in v0.8.0 

func (m *SchemaExtra) GetOldName() string

func (*SchemaExtra) GetParentTableID 

func (m *SchemaExtra) GetParentTableID() uint64

func (*SchemaExtra) Marshal added in v0.8.0 

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

func (*SchemaExtra) MarshalTo added in v0.8.0 

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

func (*SchemaExtra) MarshalToSizedBuffer added in v0.8.0 

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

func (*SchemaExtra) ProtoMessage added in v0.8.0 

func (*SchemaExtra) ProtoMessage()

func (*SchemaExtra) ProtoSize added in v0.8.0 

func (m *SchemaExtra) ProtoSize() (n int)

func (*SchemaExtra) Reset added in v0.8.0 

func (m *SchemaExtra) Reset()

func (*SchemaExtra) String added in v0.8.0 

func (m *SchemaExtra) String() string

func (*SchemaExtra) Unmarshal added in v0.8.0 

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

func (*SchemaExtra) XXX_DiscardUnknown added in v0.8.0 

func (m *SchemaExtra) XXX_DiscardUnknown()

func (*SchemaExtra) XXX_Marshal added in v0.8.0 

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

func (*SchemaExtra) XXX_Merge added in v0.8.0 

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

func (*SchemaExtra) XXX_Size added in v0.8.0 

func (m *SchemaExtra) XXX_Size() int

func (*SchemaExtra) XXX_Unmarshal added in v0.8.0 

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

type SyncLogTailReq 

type SyncLogTailReq struct {
	CnHave               *timestamp.Timestamp `protobuf:"bytes,1,opt,name=cn_have,json=cnHave,proto3" json:"cn_have,omitempty"`
	CnWant               *timestamp.Timestamp `protobuf:"bytes,2,opt,name=cn_want,json=cnWant,proto3" json:"cn_want,omitempty"`
	Table                *TableID             `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

CN pull the log tail of table from TN.

func (*SyncLogTailReq) Descriptor 

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

func (*SyncLogTailReq) GetCnHave 

func (m *SyncLogTailReq) GetCnHave() *timestamp.Timestamp

func (*SyncLogTailReq) GetCnWant 

func (m *SyncLogTailReq) GetCnWant() *timestamp.Timestamp

func (*SyncLogTailReq) GetTable 

func (m *SyncLogTailReq) GetTable() *TableID

func (*SyncLogTailReq) Marshal 

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

func (*SyncLogTailReq) MarshalBinary added in v0.8.0 

func (m *SyncLogTailReq) MarshalBinary() ([]byte, error)

func (*SyncLogTailReq) MarshalTo 

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

func (*SyncLogTailReq) MarshalToSizedBuffer 

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

func (*SyncLogTailReq) ProtoMessage 

func (*SyncLogTailReq) ProtoMessage()

func (*SyncLogTailReq) ProtoSize 

func (m *SyncLogTailReq) ProtoSize() (n int)

func (*SyncLogTailReq) Reset 

func (m *SyncLogTailReq) Reset()

func (*SyncLogTailReq) String 

func (m *SyncLogTailReq) String() string

func (*SyncLogTailReq) Unmarshal 

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

func (*SyncLogTailReq) UnmarshalBinary added in v0.8.0 

func (m *SyncLogTailReq) UnmarshalBinary(data []byte) error

func (*SyncLogTailReq) XXX_DiscardUnknown 

func (m *SyncLogTailReq) XXX_DiscardUnknown()

func (*SyncLogTailReq) XXX_Marshal 

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

func (*SyncLogTailReq) XXX_Merge 

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

func (*SyncLogTailReq) XXX_Size 

func (m *SyncLogTailReq) XXX_Size() int

func (*SyncLogTailReq) XXX_Unmarshal 

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

type SyncLogTailResp 

type SyncLogTailResp struct {
	// ckp_location is a checkpoint location list.
	// How to get checkpoint data on S3 by the ckp_location ,
	// pls ref to disttae/logtail.go/consumeLogTail function.
	CkpLocation string `protobuf:"bytes,1,opt,name=ckp_location,json=ckpLocation,proto3" json:"ckp_location,omitempty"`
	// commands is log tail for a system or user table,
	// pls ref to tae/logtail/handle.go/HandleSyncLogTailReq function.
	Commands             []*Entry `protobuf:"bytes,2,rep,name=commands,proto3" json:"commands,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SyncLogTailResp) Descriptor 

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

func (*SyncLogTailResp) GetCkpLocation 

func (m *SyncLogTailResp) GetCkpLocation() string

func (*SyncLogTailResp) GetCommands 

func (m *SyncLogTailResp) GetCommands() []*Entry

func (*SyncLogTailResp) Marshal 

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

func (*SyncLogTailResp) MarshalBinary added in v0.8.0 

func (m *SyncLogTailResp) MarshalBinary() ([]byte, error)

func (*SyncLogTailResp) MarshalTo 

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

func (*SyncLogTailResp) MarshalToSizedBuffer 

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

func (*SyncLogTailResp) ProtoMessage 

func (*SyncLogTailResp) ProtoMessage()

func (*SyncLogTailResp) ProtoSize 

func (m *SyncLogTailResp) ProtoSize() (n int)

func (*SyncLogTailResp) Reset 

func (m *SyncLogTailResp) Reset()

func (*SyncLogTailResp) String 

func (m *SyncLogTailResp) String() string

func (*SyncLogTailResp) Unmarshal 

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

func (*SyncLogTailResp) UnmarshalBinary added in v0.8.0 

func (m *SyncLogTailResp) UnmarshalBinary(data []byte) error

func (*SyncLogTailResp) XXX_DiscardUnknown 

func (m *SyncLogTailResp) XXX_DiscardUnknown()

func (*SyncLogTailResp) XXX_Marshal 

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

func (*SyncLogTailResp) XXX_Merge 

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

func (*SyncLogTailResp) XXX_Size 

func (m *SyncLogTailResp) XXX_Size() int

func (*SyncLogTailResp) XXX_Unmarshal 

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

type TNPingRequest added in v1.1.0 

type TNPingRequest struct {
	Parameter            string   `protobuf:"bytes,1,opt,name=parameter,proto3" json:"parameter,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TNPingRequest ping request

func (*TNPingRequest) Descriptor added in v1.1.0 

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

func (*TNPingRequest) GetParameter added in v1.1.0 

func (m *TNPingRequest) GetParameter() string

func (*TNPingRequest) Marshal added in v1.1.0 

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

func (*TNPingRequest) MarshalTo added in v1.1.0 

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

func (*TNPingRequest) MarshalToSizedBuffer added in v1.1.0 

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

func (*TNPingRequest) ProtoMessage added in v1.1.0 

func (*TNPingRequest) ProtoMessage()

func (*TNPingRequest) Reset added in v1.1.0 

func (m *TNPingRequest) Reset()

func (*TNPingRequest) Size added in v1.1.0 

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

func (*TNPingRequest) String added in v1.1.0 

func (m *TNPingRequest) String() string

func (*TNPingRequest) Unmarshal added in v1.1.0 

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

func (*TNPingRequest) XXX_DiscardUnknown added in v1.1.0 

func (m *TNPingRequest) XXX_DiscardUnknown()

func (*TNPingRequest) XXX_Marshal added in v1.1.0 

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

func (*TNPingRequest) XXX_Merge added in v1.1.0 

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

func (*TNPingRequest) XXX_Size added in v1.1.0 

func (m *TNPingRequest) XXX_Size() int

func (*TNPingRequest) XXX_Unmarshal added in v1.1.0 

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

type TNPingResponse added in v1.1.0 

type TNPingResponse struct {
	StoreID              string   `protobuf:"bytes,1,opt,name=storeID,proto3" json:"storeID,omitempty"`
	ServiceAddress       string   `protobuf:"bytes,2,opt,name=serviceAddress,proto3" json:"serviceAddress,omitempty"`
	ShardID              uint64   `protobuf:"varint,3,opt,name=shardID,proto3" json:"shardID,omitempty"`
	ReplicaID            uint64   `protobuf:"varint,4,opt,name=replicaID,proto3" json:"replicaID,omitempty"`
	LogShardID           uint64   `protobuf:"varint,5,opt,name=logShardID,proto3" json:"logShardID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TNPingResponse ping response

func (*TNPingResponse) Descriptor added in v1.1.0 

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

func (*TNPingResponse) GetLogShardID added in v1.1.0 

func (m *TNPingResponse) GetLogShardID() uint64

func (*TNPingResponse) GetReplicaID added in v1.1.0 

func (m *TNPingResponse) GetReplicaID() uint64

func (*TNPingResponse) GetServiceAddress added in v1.1.0 

func (m *TNPingResponse) GetServiceAddress() string

func (*TNPingResponse) GetShardID added in v1.1.0 

func (m *TNPingResponse) GetShardID() uint64

func (*TNPingResponse) GetStoreID added in v1.1.0 

func (m *TNPingResponse) GetStoreID() string

func (*TNPingResponse) Marshal added in v1.1.0 

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

func (*TNPingResponse) MarshalTo added in v1.1.0 

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

func (*TNPingResponse) MarshalToSizedBuffer added in v1.1.0 

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

func (*TNPingResponse) ProtoMessage added in v1.1.0 

func (*TNPingResponse) ProtoMessage()

func (*TNPingResponse) Reset added in v1.1.0 

func (m *TNPingResponse) Reset()

func (*TNPingResponse) Size added in v1.1.0 

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

func (*TNPingResponse) String added in v1.1.0 

func (m *TNPingResponse) String() string

func (*TNPingResponse) Unmarshal added in v1.1.0 

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

func (*TNPingResponse) XXX_DiscardUnknown added in v1.1.0 

func (m *TNPingResponse) XXX_DiscardUnknown()

func (*TNPingResponse) XXX_Marshal added in v1.1.0 

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

func (*TNPingResponse) XXX_Merge added in v1.1.0 

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

func (*TNPingResponse) XXX_Size added in v1.1.0 

func (m *TNPingResponse) XXX_Size() int

func (*TNPingResponse) XXX_Unmarshal added in v1.1.0 

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

type TNStringResponse added in v1.1.0 

type TNStringResponse struct {
	ReturnStr            string   `protobuf:"bytes,1,opt,name=returnStr,proto3" json:"returnStr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TNStringResponse string type response

func (*TNStringResponse) Descriptor added in v1.1.0 

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

func (*TNStringResponse) GetReturnStr added in v1.1.0 

func (m *TNStringResponse) GetReturnStr() string

func (*TNStringResponse) Marshal added in v1.1.0 

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

func (*TNStringResponse) MarshalBinary added in v1.2.1 

func (m *TNStringResponse) MarshalBinary() ([]byte, error)

func (*TNStringResponse) MarshalTo added in v1.1.0 

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

func (*TNStringResponse) MarshalToSizedBuffer added in v1.1.0 

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

func (*TNStringResponse) ProtoMessage added in v1.1.0 

func (*TNStringResponse) ProtoMessage()

func (*TNStringResponse) Reset added in v1.1.0 

func (m *TNStringResponse) Reset()

func (*TNStringResponse) Size added in v1.1.0 

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

func (*TNStringResponse) String added in v1.1.0 

func (m *TNStringResponse) String() string

func (*TNStringResponse) Unmarshal added in v1.1.0 

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

func (*TNStringResponse) UnmarshalBinary added in v1.2.1 

func (m *TNStringResponse) UnmarshalBinary(data []byte) error

func (*TNStringResponse) XXX_DiscardUnknown added in v1.1.0 

func (m *TNStringResponse) XXX_DiscardUnknown()

func (*TNStringResponse) XXX_Marshal added in v1.1.0 

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

func (*TNStringResponse) XXX_Merge added in v1.1.0 

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

func (*TNStringResponse) XXX_Size added in v1.1.0 

func (m *TNStringResponse) XXX_Size() int

func (*TNStringResponse) XXX_Unmarshal added in v1.1.0 

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

type TableID 

type TableID struct {
	DbId                 uint64   `protobuf:"varint,1,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TbId                 uint64   `protobuf:"varint,2,opt,name=tb_id,json=tbId,proto3" json:"tb_id,omitempty"`
	PartitionId          uint64   `protobuf:"varint,3,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	AccId                uint32   `protobuf:"varint,4,opt,name=acc_id,json=accId,proto3" json:"acc_id,omitempty"`
	DbName               string   `protobuf:"bytes,5,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	TbName               string   `protobuf:"bytes,6,opt,name=tb_name,json=tbName,proto3" json:"tb_name,omitempty"`
	PrimarySeqnum        uint32   `protobuf:"varint,7,opt,name=primary_seqnum,json=primarySeqnum,proto3" json:"primary_seqnum,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TableID) Descriptor 

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

func (*TableID) GetAccId 

func (m *TableID) GetAccId() uint32

func (*TableID) GetDbId 

func (m *TableID) GetDbId() uint64

func (*TableID) GetDbName 

func (m *TableID) GetDbName() string

func (*TableID) GetPartitionId added in v0.7.0 

func (m *TableID) GetPartitionId() uint64

func (*TableID) GetPrimarySeqnum 

func (m *TableID) GetPrimarySeqnum() uint32

func (*TableID) GetTbId 

func (m *TableID) GetTbId() uint64

func (*TableID) GetTbName 

func (m *TableID) GetTbName() string

func (*TableID) Marshal 

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

func (*TableID) MarshalTo 

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

func (*TableID) MarshalToSizedBuffer 

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

func (*TableID) ProtoMessage 

func (*TableID) ProtoMessage()

func (*TableID) ProtoSize 

func (m *TableID) ProtoSize() (n int)

func (*TableID) Reset 

func (m *TableID) Reset()

func (*TableID) String 

func (m *TableID) String() string

func (*TableID) Unmarshal 

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

func (*TableID) XXX_DiscardUnknown 

func (m *TableID) XXX_DiscardUnknown()

func (*TableID) XXX_Marshal 

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

func (*TableID) XXX_Merge 

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

func (*TableID) XXX_Size 

func (m *TableID) XXX_Size() int

func (*TableID) XXX_Unmarshal 

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

type TransDestPos added in v1.2.0 

type TransDestPos struct {
	ObjIdx               int32    `protobuf:"varint,1,opt,name=objIdx,proto3" json:"objIdx,omitempty"`
	BlkIdx               int32    `protobuf:"varint,2,opt,name=blkIdx,proto3" json:"blkIdx,omitempty"`
	RowIdx               int32    `protobuf:"varint,3,opt,name=rowIdx,proto3" json:"rowIdx,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TransDestPos) Descriptor added in v1.2.0 

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

func (*TransDestPos) GetBlkIdx added in v1.2.0 

func (m *TransDestPos) GetBlkIdx() int32

func (*TransDestPos) GetObjIdx added in v1.2.0 

func (m *TransDestPos) GetObjIdx() int32

func (*TransDestPos) GetRowIdx added in v1.2.0 

func (m *TransDestPos) GetRowIdx() int32

func (*TransDestPos) Marshal added in v1.2.0 

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

func (*TransDestPos) MarshalTo added in v1.2.0 

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

func (*TransDestPos) MarshalToSizedBuffer added in v1.2.0 

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

func (*TransDestPos) ProtoMessage added in v1.2.0 

func (*TransDestPos) ProtoMessage()

func (*TransDestPos) ProtoSize added in v1.2.0 

func (m *TransDestPos) ProtoSize() (n int)

func (*TransDestPos) Reset added in v1.2.0 

func (m *TransDestPos) Reset()

func (*TransDestPos) String added in v1.2.0 

func (m *TransDestPos) String() string

func (*TransDestPos) Unmarshal added in v1.2.0 

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

func (*TransDestPos) XXX_DiscardUnknown added in v1.2.0 

func (m *TransDestPos) XXX_DiscardUnknown()

func (*TransDestPos) XXX_Marshal added in v1.2.0 

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

func (*TransDestPos) XXX_Merge added in v1.2.0 

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

func (*TransDestPos) XXX_Size added in v1.2.0 

func (m *TransDestPos) XXX_Size() int

func (*TransDestPos) XXX_Unmarshal added in v1.2.0 

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

type TransferDestPos added in v1.2.3 

type TransferDestPos struct {
	ObjIdx uint8
	BlkIdx uint16
	RowIdx uint32
}

type TransferMap added in v1.2.3 

type TransferMap []TransferDestPos

TransferMap is a dense slice indexed by the original row index within its source block. Entries where ObjIdx == NoTransfer are sentinel values meaning the row was deleted and has no transfer destination. Valid ObjIdx values are always < NoTransfer because the number of output objects produced by a single merge is far below 255.

type TransferMaps added in v1.2.3 

type TransferMaps []TransferMap

type Vector 

type Vector struct {
	Data                 []byte    `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Type                 plan.Type `protobuf:"bytes,2,opt,name=type,proto3" json:"type"`
	Nullable             bool      `protobuf:"varint,3,opt,name=nullable,proto3" json:"nullable,omitempty"`
	Nsp                  []byte    `protobuf:"bytes,4,opt,name=nsp,proto3" json:"nsp,omitempty"`
	IsConst              bool      `protobuf:"varint,5,opt,name=is_const,json=isConst,proto3" json:"is_const,omitempty"`
	Len                  uint32    `protobuf:"varint,6,opt,name=len,proto3" json:"len,omitempty"`
	Area                 []byte    `protobuf:"bytes,7,opt,name=area,proto3" json:"area,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Vector) Descriptor 

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

func (*Vector) GetArea 

func (m *Vector) GetArea() []byte

func (*Vector) GetData 

func (m *Vector) GetData() []byte

func (*Vector) GetIsConst 

func (m *Vector) GetIsConst() bool

func (*Vector) GetLen 

func (m *Vector) GetLen() uint32

func (*Vector) GetNsp 

func (m *Vector) GetNsp() []byte

func (*Vector) GetNullable 

func (m *Vector) GetNullable() bool

func (*Vector) GetType 

func (m *Vector) GetType() plan.Type

func (*Vector) Marshal 

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

func (*Vector) MarshalTo 

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

func (*Vector) MarshalToSizedBuffer 

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

func (*Vector) ProtoMessage 

func (*Vector) ProtoMessage()

func (*Vector) ProtoSize 

func (m *Vector) ProtoSize() (n int)

func (*Vector) Reset 

func (m *Vector) Reset()

func (*Vector) String 

func (m *Vector) String() string

func (*Vector) Unmarshal 

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

func (*Vector) XXX_DiscardUnknown 

func (m *Vector) XXX_DiscardUnknown()

func (*Vector) XXX_Marshal 

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

func (*Vector) XXX_Merge 

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

func (*Vector) XXX_Size 

func (m *Vector) XXX_Size() int

func (*Vector) XXX_Unmarshal 

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