basepb

package
v0.0.0-...-e215c4f Latest Latest
Warning

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

 Go to latest Published: Dec 31, 2019 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBasepb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBasepb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBasepb = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ColumnType_name = map[int32]string{
	0: "COL_Common",
	1: "COL_System",
}
View Source 
var ColumnType_value = map[string]int32{
	"COL_Common": 0,
	"COL_System": 1,
}
View Source 
var DataType_name = map[int32]string{
	0:  "Invalid",
	1:  "TinyInt",
	2:  "SmallInt",
	3:  "MediumInt",
	4:  "Int",
	5:  "BigInt",
	6:  "Bit",
	10: "Float",
	11: "Double",
	12: "Decimal",
	20: "Date",
	21: "TimeStamp",
	22: "DateTime",
	23: "Time",
	24: "Year",
	30: "Varchar",
	31: "Binary",
	32: "Char",
	33: "NChar",
	34: "Text",
	35: "VarBinary",
	40: "Json",
	50: "Null",
}
View Source 
var DataType_value = map[string]int32{
	"Invalid":   0,
	"TinyInt":   1,
	"SmallInt":  2,
	"MediumInt": 3,
	"Int":       4,
	"BigInt":    5,
	"Bit":       6,
	"Float":     10,
	"Double":    11,
	"Decimal":   12,
	"Date":      20,
	"TimeStamp": 21,
	"DateTime":  22,
	"Time":      23,
	"Year":      24,
	"Varchar":   30,
	"Binary":    31,
	"Char":      32,
	"NChar":     33,
	"Text":      34,
	"VarBinary": 35,
	"Json":      40,
	"Null":      50,
}
View Source 
var EventType_name = map[int32]string{
	0: "Event_Type_Invalid",
	1: "Event_Type_PUT",
	2: "Event_Type_DELETE",
}
View Source 
var EventType_value = map[string]int32{
	"Event_Type_Invalid": 0,
	"Event_Type_PUT":     1,
	"Event_Type_DELETE":  2,
}
View Source 
var IndexType_name = map[int32]string{
	0: "I_Invalid",
	1: "I_Btree",
	2: "I_Hash",
}
View Source 
var IndexType_value = map[string]int32{
	"I_Invalid": 0,
	"I_Btree":   1,
	"I_Hash":    2,
}
View Source 
var NodeState_name = map[int32]string{
	0: "N_Invalid",
	1: "N_Online",
	2: "N_Offline",
	3: "N_Updating",
	4: "N_Offlining",
}
View Source 
var NodeState_value = map[string]int32{
	"N_Invalid":   0,
	"N_Online":    1,
	"N_Offline":   2,
	"N_Updating":  3,
	"N_Offlining": 4,
}
View Source 
var PeerType_name = map[int32]string{
	0: "PeerType_Invalid",
	1: "PeerType_Normal",
	2: "PeerType_Learner",
}
View Source 
var PeerType_value = map[string]int32{
	"PeerType_Invalid": 0,
	"PeerType_Normal":  1,
	"PeerType_Learner": 2,
}
View Source 
var RangePeerState_name = map[int32]string{
	0: "RPS_Invalid",
	1: "RPS_NoLeader",
	2: "RPS_Follower",
	3: "RPS_Leader",
}
View Source 
var RangePeerState_value = map[string]int32{
	"RPS_Invalid":  0,
	"RPS_NoLeader": 1,
	"RPS_Follower": 2,
	"RPS_Leader":   3,
}
View Source 
var RangeType_name = map[int32]string{
	0: "RNG_Invalid",
	1: "RNG_Index",
	2: "RNG_Data",
}
View Source 
var RangeType_value = map[string]int32{
	"RNG_Invalid": 0,
	"RNG_Index":   1,
	"RNG_Data":    2,
}
View Source 
var StoreType_name = map[int32]string{
	0: "Store_Invalid",
	1: "Store_Hot",
	2: "Store_Warm",
	3: "Store_Mix",
}
View Source 
var StoreType_value = map[string]int32{
	"Store_Invalid": 0,
	"Store_Hot":     1,
	"Store_Warm":    2,
	"Store_Mix":     3,
}
View Source 
var TableStatus_name = map[int32]string{
	0: "TableInvalid",
	1: "TableRunning",
}
View Source 
var TableStatus_value = map[string]int32{
	"TableInvalid": 0,
	"TableRunning": 1,
}
View Source 
var WatcherType_name = map[int32]string{
	0: "Watcher_Type_Invalid",
	1: "Watcher_Type_Node",
	2: "Watcher_Type_Database",
	3: "Watcher_Type_Table",
	4: "Watcher_Type_Range",
}
View Source 
var WatcherType_value = map[string]int32{
	"Watcher_Type_Invalid":  0,
	"Watcher_Type_Node":     1,
	"Watcher_Type_Database": 2,
	"Watcher_Type_Table":    3,
	"Watcher_Type_Range":    4,
}

Functions

This section is empty.

Types

type Column 

type Column struct {
	// max size 128 bytes
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// colID
	Id       uint64   `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	DataType DataType `protobuf:"varint,3,opt,name=data_type,json=dataType,proto3,enum=basepb.DataType" json:"data_type,omitempty"`
	Unsigned bool     `protobuf:"varint,4,opt,name=unsigned,proto3" json:"unsigned,omitempty"`
	//for float
	Scale int32 `protobuf:"varint,5,opt,name=scale,proto3" json:"scale,omitempty"`
	// for float and varchar type
	Precision  int32  `protobuf:"varint,6,opt,name=precision,proto3" json:"precision,omitempty"`
	Nullable   bool   `protobuf:"varint,7,opt,name=nullable,proto3" json:"nullable,omitempty"`
	PrimaryKey uint64 `protobuf:"varint,8,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	// col order type
	Ordinal int32 `protobuf:"varint,9,opt,name=ordinal,proto3" json:"ordinal,omitempty"`
	// index type , binary can not index
	Index                bool       `protobuf:"varint,10,opt,name=index,proto3" json:"index,omitempty"`
	DefaultValue         []byte     `protobuf:"bytes,11,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"`
	Properties           string     `protobuf:"bytes,12,opt,name=properties,proto3" json:"properties,omitempty"`
	AutoIncrement        bool       `protobuf:"varint,13,opt,name=auto_increment,json=autoIncrement,proto3" json:"auto_increment,omitempty"`
	Unique               bool       `protobuf:"varint,14,opt,name=unique,proto3" json:"unique,omitempty"`
	ColType              ColumnType `protobuf:"varint,15,opt,name=col_type,json=colType,proto3,enum=basepb.ColumnType" json:"col_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Column) Descriptor 

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

func (*Column) GetAutoIncrement 

func (m *Column) GetAutoIncrement() bool

func (*Column) GetColType 

func (m *Column) GetColType() ColumnType

func (*Column) GetDataType 

func (m *Column) GetDataType() DataType

func (*Column) GetDefaultValue 

func (m *Column) GetDefaultValue() []byte

func (*Column) GetId 

func (m *Column) GetId() uint64

func (*Column) GetIndex 

func (m *Column) GetIndex() bool

func (*Column) GetName 

func (m *Column) GetName() string

func (*Column) GetNullable 

func (m *Column) GetNullable() bool

func (*Column) GetOrdinal 

func (m *Column) GetOrdinal() int32

func (*Column) GetPrecision 

func (m *Column) GetPrecision() int32

func (*Column) GetPrimaryKey 

func (m *Column) GetPrimaryKey() uint64

func (*Column) GetProperties 

func (m *Column) GetProperties() string

func (*Column) GetScale 

func (m *Column) GetScale() int32

func (*Column) GetUnique 

func (m *Column) GetUnique() bool

func (*Column) GetUnsigned 

func (m *Column) GetUnsigned() bool

func (*Column) Marshal 

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

func (*Column) MarshalTo 

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

func (*Column) MarshalToSizedBuffer 

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

func (*Column) ProtoMessage 

func (*Column) ProtoMessage()

func (*Column) Reset 

func (m *Column) Reset()

func (*Column) Size 

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

func (*Column) String 

func (m *Column) String() string

func (*Column) Unmarshal 

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

func (*Column) XXX_DiscardUnknown 

func (m *Column) XXX_DiscardUnknown()

func (*Column) XXX_Marshal 

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

func (*Column) XXX_Merge 

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

func (*Column) XXX_Size 

func (m *Column) XXX_Size() int

func (*Column) XXX_Unmarshal 

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

type ColumnType 

type ColumnType int32
const (
	ColumnType_COL_Common ColumnType = 0
	ColumnType_COL_System ColumnType = 1
)

func (ColumnType) EnumDescriptor 

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

func (ColumnType) String 

func (x ColumnType) String() string

type DataBase 

type DataBase struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Id                   uint64   `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Version              uint64   `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	CreateTime           int64    `protobuf:"varint,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DataBase) Descriptor 

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

func (*DataBase) GetCreateTime 

func (m *DataBase) GetCreateTime() int64

func (*DataBase) GetId 

func (m *DataBase) GetId() uint64

func (*DataBase) GetName 

func (m *DataBase) GetName() string

func (*DataBase) GetVersion 

func (m *DataBase) GetVersion() uint64

func (*DataBase) Marshal 

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

func (*DataBase) MarshalTo 

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

func (*DataBase) MarshalToSizedBuffer 

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

func (*DataBase) ProtoMessage 

func (*DataBase) ProtoMessage()

func (*DataBase) Reset 

func (m *DataBase) Reset()

func (*DataBase) Size 

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

func (*DataBase) String 

func (m *DataBase) String() string

func (*DataBase) Unmarshal 

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

func (*DataBase) XXX_DiscardUnknown 

func (m *DataBase) XXX_DiscardUnknown()

func (*DataBase) XXX_Marshal 

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

func (*DataBase) XXX_Merge 

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

func (*DataBase) XXX_Size 

func (m *DataBase) XXX_Size() int

func (*DataBase) XXX_Unmarshal 

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

type DataType 

type DataType int32
const (
	DataType_Invalid DataType = 0
	// 8 bit interger
	DataType_TinyInt DataType = 1
	// 16 bit interger
	DataType_SmallInt DataType = 2
	// 24 bit integer
	DataType_MediumInt DataType = 3
	// 32 bit interger
	DataType_Int DataType = 4
	// 64 bit interger
	DataType_BigInt DataType = 5
	DataType_Bit    DataType = 6
	// 32 bit float
	DataType_Float DataType = 10
	// 64 bit float
	DataType_Double    DataType = 11
	DataType_Decimal   DataType = 12
	DataType_Date      DataType = 20
	DataType_TimeStamp DataType = 21
	DataType_DateTime  DataType = 22
	DataType_Time      DataType = 23
	DataType_Year      DataType = 24
	// string UTF-8 max size 64 KB
	DataType_Varchar DataType = 30
	// Blob max size 64 KB
	DataType_Binary    DataType = 31
	DataType_Char      DataType = 32
	DataType_NChar     DataType = 33
	DataType_Text      DataType = 34
	DataType_VarBinary DataType = 35
	DataType_Json      DataType = 40
	DataType_Null      DataType = 50
)

func (DataType) EnumDescriptor 

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

func (DataType) String 

func (x DataType) String() string

type EventType 

type EventType int32
const (
	EventType_Event_Type_Invalid EventType = 0
	EventType_Event_Type_PUT     EventType = 1
	EventType_Event_Type_DELETE  EventType = 2
)

func (EventType) EnumDescriptor 

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

func (EventType) String 

func (x EventType) String() string

type Index 

type Index struct {
	Id                   uint64    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	ColNames             []string  `protobuf:"bytes,3,rep,name=col_names,json=colNames,proto3" json:"col_names,omitempty"`
	Unique               bool      `protobuf:"varint,4,opt,name=unique,proto3" json:"unique,omitempty"`
	Comment              string    `protobuf:"bytes,5,opt,name=comment,proto3" json:"comment,omitempty"`
	IndexType            IndexType `protobuf:"varint,6,opt,name=index_type,json=indexType,proto3,enum=basepb.IndexType" json:"index_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Index) Descriptor 

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

func (*Index) GetColNames 

func (m *Index) GetColNames() []string

func (*Index) GetComment 

func (m *Index) GetComment() string

func (*Index) GetId 

func (m *Index) GetId() uint64

func (*Index) GetIndexType 

func (m *Index) GetIndexType() IndexType

func (*Index) GetName 

func (m *Index) GetName() string

func (*Index) GetUnique 

func (m *Index) GetUnique() bool

func (*Index) Marshal 

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

func (*Index) MarshalTo 

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

func (*Index) MarshalToSizedBuffer 

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

func (*Index) ProtoMessage 

func (*Index) ProtoMessage()

func (*Index) Reset 

func (m *Index) Reset()

func (*Index) Size 

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

func (*Index) String 

func (m *Index) String() string

func (*Index) Unmarshal 

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

func (*Index) XXX_DiscardUnknown 

func (m *Index) XXX_DiscardUnknown()

func (*Index) XXX_Marshal 

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

func (*Index) XXX_Merge 

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

func (*Index) XXX_Size 

func (m *Index) XXX_Size() int

func (*Index) XXX_Unmarshal 

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

type IndexType 

type IndexType int32
const (
	IndexType_I_Invalid IndexType = 0
	IndexType_I_Btree   IndexType = 1
	IndexType_I_Hash    IndexType = 2
)

func (IndexType) EnumDescriptor 

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

func (IndexType) String 

func (x IndexType) String() string

type Leader 

type Leader struct {
	RangeId              uint64   `protobuf:"varint,1,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	NodeId               uint64   `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	NodeAddr             string   `protobuf:"bytes,3,opt,name=node_addr,json=nodeAddr,proto3" json:"node_addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Leader) Descriptor 

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

func (*Leader) GetNodeAddr 

func (m *Leader) GetNodeAddr() string

func (*Leader) GetNodeId 

func (m *Leader) GetNodeId() uint64

func (*Leader) GetRangeId 

func (m *Leader) GetRangeId() uint64

func (*Leader) Marshal 

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

func (*Leader) MarshalTo 

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

func (*Leader) MarshalToSizedBuffer 

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

func (*Leader) ProtoMessage 

func (*Leader) ProtoMessage()

func (*Leader) Reset 

func (m *Leader) Reset()

func (*Leader) Size 

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

func (*Leader) String 

func (m *Leader) String() string

func (*Leader) Unmarshal 

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

func (*Leader) XXX_DiscardUnknown 

func (m *Leader) XXX_DiscardUnknown()

func (*Leader) XXX_Marshal 

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

func (*Leader) XXX_Merge 

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

func (*Leader) XXX_Size 

func (m *Leader) XXX_Size() int

func (*Leader) XXX_Unmarshal 

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

type Node 

type Node struct {
	Id                   uint64       `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Ip                   string       `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	ServerPort           uint32       `protobuf:"varint,3,opt,name=server_port,json=serverPort,proto3" json:"server_port,omitempty"`
	RaftPort             uint32       `protobuf:"varint,4,opt,name=raft_port,json=raftPort,proto3" json:"raft_port,omitempty"`
	AdminPort            uint32       `protobuf:"varint,5,opt,name=admin_port,json=adminPort,proto3" json:"admin_port,omitempty"`
	State                NodeState    `protobuf:"varint,6,opt,name=state,proto3,enum=basepb.NodeState" json:"state,omitempty"`
	Version              int64        `protobuf:"varint,7,opt,name=version,proto3" json:"version,omitempty"`
	RangePeers           []*RangePeer `protobuf:"bytes,8,rep,name=range_peers,json=rangePeers,proto3" json:"range_peers,omitempty"`
	LastUpdateTime       int64        `protobuf:"varint,9,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
	Type                 StoreType    `protobuf:"varint,10,opt,name=type,proto3,enum=basepb.StoreType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Node) Descriptor 

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

func (*Node) GetAdminPort 

func (m *Node) GetAdminPort() uint32

func (*Node) GetId 

func (m *Node) GetId() uint64

func (*Node) GetIp 

func (m *Node) GetIp() string

func (*Node) GetLastUpdateTime 

func (m *Node) GetLastUpdateTime() int64

func (*Node) GetRaftPort 

func (m *Node) GetRaftPort() uint32

func (*Node) GetRangePeers 

func (m *Node) GetRangePeers() []*RangePeer

func (*Node) GetServerPort 

func (m *Node) GetServerPort() uint32

func (*Node) GetState 

func (m *Node) GetState() NodeState

func (*Node) GetType 

func (m *Node) GetType() StoreType

func (*Node) GetVersion 

func (m *Node) GetVersion() int64

func (*Node) Marshal 

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

func (*Node) MarshalTo 

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

func (*Node) MarshalToSizedBuffer 

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

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) Size 

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

func (*Node) String 

func (m *Node) String() string

func (*Node) Unmarshal 

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

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

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

func (*Node) XXX_Merge 

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

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

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

type NodeState 

type NodeState int32

1. Under any conditions, ms should initialize the new and old ds nodes into an Initial state after they are added to the cluster, except for the nodes that have been Logout. after ds self-inspection is completed, the data read-write service is officially launched via NodeLogin report Logout node，need to Initial by person 

const (
	NodeState_N_Invalid   NodeState = 0
	NodeState_N_Online    NodeState = 1
	NodeState_N_Offline   NodeState = 2
	NodeState_N_Updating  NodeState = 3
	NodeState_N_Offlining NodeState = 4
)

func (NodeState) EnumDescriptor 

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

func (NodeState) String 

func (x NodeState) String() string

type Peer 

type Peer struct {
	Id                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	NodeId               uint64   `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Type                 PeerType `protobuf:"varint,3,opt,name=type,proto3,enum=basepb.PeerType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Peer) Descriptor 

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

func (*Peer) GetId 

func (m *Peer) GetId() uint64

func (*Peer) GetNodeId 

func (m *Peer) GetNodeId() uint64

func (*Peer) GetType 

func (m *Peer) GetType() PeerType

func (*Peer) Marshal 

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

func (*Peer) MarshalTo 

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

func (*Peer) MarshalToSizedBuffer 

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

func (*Peer) ProtoMessage 

func (*Peer) ProtoMessage()

func (*Peer) Reset 

func (m *Peer) Reset()

func (*Peer) Size 

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

func (*Peer) String 

func (m *Peer) String() string

func (*Peer) Unmarshal 

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

func (*Peer) XXX_DiscardUnknown 

func (m *Peer) XXX_DiscardUnknown()

func (*Peer) XXX_Marshal 

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

func (*Peer) XXX_Merge 

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

func (*Peer) XXX_Size 

func (m *Peer) XXX_Size() int

func (*Peer) XXX_Unmarshal 

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

type PeerStatus 

type PeerStatus struct {
	Peer                 *Peer    `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer,omitempty"`
	Index                uint64   `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Commit               uint64   `protobuf:"varint,3,opt,name=commit,proto3" json:"commit,omitempty"`
	DownSeconds          uint64   `protobuf:"varint,4,opt,name=down_seconds,json=downSeconds,proto3" json:"down_seconds,omitempty"`
	Snapshotting         bool     `protobuf:"varint,5,opt,name=snapshotting,proto3" json:"snapshotting,omitempty"`
	Applied              uint64   `protobuf:"varint,6,opt,name=applied,proto3" json:"applied,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerStatus) Descriptor 

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

func (*PeerStatus) GetApplied 

func (m *PeerStatus) GetApplied() uint64

func (*PeerStatus) GetCommit 

func (m *PeerStatus) GetCommit() uint64

func (*PeerStatus) GetDownSeconds 

func (m *PeerStatus) GetDownSeconds() uint64

func (*PeerStatus) GetIndex 

func (m *PeerStatus) GetIndex() uint64

func (*PeerStatus) GetPeer 

func (m *PeerStatus) GetPeer() *Peer

func (*PeerStatus) GetSnapshotting 

func (m *PeerStatus) GetSnapshotting() bool

func (*PeerStatus) Marshal 

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

func (*PeerStatus) MarshalTo 

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

func (*PeerStatus) MarshalToSizedBuffer 

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

func (*PeerStatus) ProtoMessage 

func (*PeerStatus) ProtoMessage()

func (*PeerStatus) Reset 

func (m *PeerStatus) Reset()

func (*PeerStatus) Size 

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

func (*PeerStatus) String 

func (m *PeerStatus) String() string

func (*PeerStatus) Unmarshal 

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

func (*PeerStatus) XXX_DiscardUnknown 

func (m *PeerStatus) XXX_DiscardUnknown()

func (*PeerStatus) XXX_Marshal 

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

func (*PeerStatus) XXX_Merge 

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

func (*PeerStatus) XXX_Size 

func (m *PeerStatus) XXX_Size() int

func (*PeerStatus) XXX_Unmarshal 

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

type PeerType 

type PeerType int32
const (
	PeerType_PeerType_Invalid PeerType = 0
	PeerType_PeerType_Normal  PeerType = 1
	PeerType_PeerType_Learner PeerType = 2
)

func (PeerType) EnumDescriptor 

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

func (PeerType) String 

func (x PeerType) String() string

type Primary 

type Primary struct {
	ColumnName           string   `protobuf:"bytes,1,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	Next                 *Primary `protobuf:"bytes,2,opt,name=next,proto3" json:"next,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Primary) Descriptor 

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

func (*Primary) GetColumnName 

func (m *Primary) GetColumnName() string

func (*Primary) GetNext 

func (m *Primary) GetNext() *Primary

func (*Primary) Marshal 

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

func (*Primary) MarshalTo 

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

func (*Primary) MarshalToSizedBuffer 

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

func (*Primary) ProtoMessage 

func (*Primary) ProtoMessage()

func (*Primary) Reset 

func (m *Primary) Reset()

func (*Primary) Size 

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

func (*Primary) String 

func (m *Primary) String() string

func (*Primary) Unmarshal 

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

func (*Primary) XXX_DiscardUnknown 

func (m *Primary) XXX_DiscardUnknown()

func (*Primary) XXX_Marshal 

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

func (*Primary) XXX_Merge 

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

func (*Primary) XXX_Size 

func (m *Primary) XXX_Size() int

func (*Primary) XXX_Unmarshal 

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

type Range 

type Range struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Range key range [start_key, end_key).
	// key by: prefix + table_id + real key
	StartKey   []byte      `protobuf:"bytes,2,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey     []byte      `protobuf:"bytes,3,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	RangeEpoch *RangeEpoch `protobuf:"bytes,4,opt,name=range_epoch,json=rangeEpoch,proto3" json:"range_epoch,omitempty"`
	//default first peer is leader
	Peers                []*Peer   `protobuf:"bytes,5,rep,name=peers,proto3" json:"peers,omitempty"`
	DbId                 uint64    `protobuf:"varint,6,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId              uint64    `protobuf:"varint,7,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	PrimaryKeys          []*Column `protobuf:"bytes,8,rep,name=primary_keys,json=primaryKeys,proto3" json:"primary_keys,omitempty"`
	Leader               uint64    `protobuf:"varint,9,opt,name=leader,proto3" json:"leader,omitempty"`
	RangeType            RangeType `protobuf:"varint,10,opt,name=range_type,json=rangeType,proto3,enum=basepb.RangeType" json:"range_type,omitempty"`
	StoreType            StoreType `protobuf:"varint,11,opt,name=store_type,json=storeType,proto3,enum=basepb.StoreType" json:"store_type,omitempty"`
	Term                 uint64    `protobuf:"varint,12,opt,name=term,proto3" json:"term,omitempty"`
	ParentRangeId        uint64    `protobuf:"varint,13,opt,name=parent_range_id,json=parentRangeId,proto3" json:"parent_range_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Range) Descriptor 

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

func (*Range) GetDbId 

func (m *Range) GetDbId() uint64

func (*Range) GetEndKey 

func (m *Range) GetEndKey() []byte

func (*Range) GetId 

func (m *Range) GetId() uint64

func (*Range) GetLeader 

func (m *Range) GetLeader() uint64

func (*Range) GetParentRangeId 

func (m *Range) GetParentRangeId() uint64

func (*Range) GetPeers 

func (m *Range) GetPeers() []*Peer

func (*Range) GetPrimaryKeys 

func (m *Range) GetPrimaryKeys() []*Column

func (*Range) GetRangeEpoch 

func (m *Range) GetRangeEpoch() *RangeEpoch

func (*Range) GetRangeType 

func (m *Range) GetRangeType() RangeType

func (*Range) GetStartKey 

func (m *Range) GetStartKey() []byte

func (*Range) GetStoreType 

func (m *Range) GetStoreType() StoreType

func (*Range) GetTableId 

func (m *Range) GetTableId() uint64

func (*Range) GetTerm 

func (m *Range) GetTerm() uint64

func (*Range) Marshal 

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

func (*Range) MarshalTo 

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

func (*Range) MarshalToSizedBuffer 

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

func (*Range) ProtoMessage 

func (*Range) ProtoMessage()

func (*Range) Reset 

func (m *Range) Reset()

func (*Range) Size 

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

func (*Range) String 

func (m *Range) String() string

func (*Range) Unmarshal 

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

func (*Range) XXX_DiscardUnknown 

func (m *Range) XXX_DiscardUnknown()

func (*Range) XXX_Marshal 

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

func (*Range) XXX_Merge 

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

func (*Range) XXX_Size 

func (m *Range) XXX_Size() int

func (*Range) XXX_Unmarshal 

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

type RangeEpoch 

type RangeEpoch struct {
	// Conf change version, auto increment when add or remove peer
	ConfVer uint64 `protobuf:"varint,1,opt,name=conf_ver,json=confVer,proto3" json:"conf_ver,omitempty"`
	// Range version, auto increment when split or merge
	Version              uint64   `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RegionEpoch is from tidb, and is and is licensed under the Apache Public License v2. Source code can be found here: https://github.com/pingcap/pd

func (*RangeEpoch) Descriptor 

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

func (*RangeEpoch) GetConfVer 

func (m *RangeEpoch) GetConfVer() uint64

func (*RangeEpoch) GetVersion 

func (m *RangeEpoch) GetVersion() uint64

func (*RangeEpoch) Marshal 

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

func (*RangeEpoch) MarshalTo 

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

func (*RangeEpoch) MarshalToSizedBuffer 

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

func (*RangeEpoch) ProtoMessage 

func (*RangeEpoch) ProtoMessage()

func (*RangeEpoch) Reset 

func (m *RangeEpoch) Reset()

func (*RangeEpoch) Size 

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

func (*RangeEpoch) String 

func (m *RangeEpoch) String() string

func (*RangeEpoch) Unmarshal 

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

func (*RangeEpoch) XXX_DiscardUnknown 

func (m *RangeEpoch) XXX_DiscardUnknown()

func (*RangeEpoch) XXX_Marshal 

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

func (*RangeEpoch) XXX_Merge 

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

func (*RangeEpoch) XXX_Size 

func (m *RangeEpoch) XXX_Size() int

func (*RangeEpoch) XXX_Unmarshal 

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

type RangePeer 

type RangePeer struct {
	RangeId              uint64         `protobuf:"varint,1,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	PeerId               uint64         `protobuf:"varint,2,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	State                RangePeerState `protobuf:"varint,3,opt,name=state,proto3,enum=basepb.RangePeerState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RangePeer) Descriptor 

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

func (*RangePeer) GetPeerId 

func (m *RangePeer) GetPeerId() uint64

func (*RangePeer) GetRangeId 

func (m *RangePeer) GetRangeId() uint64

func (*RangePeer) GetState 

func (m *RangePeer) GetState() RangePeerState

func (*RangePeer) Marshal 

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

func (*RangePeer) MarshalTo 

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

func (*RangePeer) MarshalToSizedBuffer 

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

func (*RangePeer) ProtoMessage 

func (*RangePeer) ProtoMessage()

func (*RangePeer) Reset 

func (m *RangePeer) Reset()

func (*RangePeer) Size 

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

func (*RangePeer) String 

func (m *RangePeer) String() string

func (*RangePeer) Unmarshal 

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

func (*RangePeer) XXX_DiscardUnknown 

func (m *RangePeer) XXX_DiscardUnknown()

func (*RangePeer) XXX_Marshal 

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

func (*RangePeer) XXX_Merge 

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

func (*RangePeer) XXX_Size 

func (m *RangePeer) XXX_Size() int

func (*RangePeer) XXX_Unmarshal 

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

type RangePeerState 

type RangePeerState int32
const (
	RangePeerState_RPS_Invalid  RangePeerState = 0
	RangePeerState_RPS_NoLeader RangePeerState = 1
	RangePeerState_RPS_Follower RangePeerState = 2
	RangePeerState_RPS_Leader   RangePeerState = 3
)

func (RangePeerState) EnumDescriptor 

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

func (RangePeerState) String 

func (x RangePeerState) String() string

type RangeType 

type RangeType int32
const (
	RangeType_RNG_Invalid RangeType = 0
	RangeType_RNG_Index   RangeType = 1
	RangeType_RNG_Data    RangeType = 2
)

func (RangeType) EnumDescriptor 

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

func (RangeType) String 

func (x RangeType) String() string

type Replica 

type Replica struct {
	RangeId              uint64   `protobuf:"varint,1,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	Peer                 *Peer    `protobuf:"bytes,2,opt,name=peer,proto3" json:"peer,omitempty"`
	StartKey             []byte   `protobuf:"bytes,3,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey               []byte   `protobuf:"bytes,4,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Replica) Descriptor 

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

func (*Replica) GetEndKey 

func (m *Replica) GetEndKey() []byte

func (*Replica) GetPeer 

func (m *Replica) GetPeer() *Peer

func (*Replica) GetRangeId 

func (m *Replica) GetRangeId() uint64

func (*Replica) GetStartKey 

func (m *Replica) GetStartKey() []byte

func (*Replica) Marshal 

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

func (*Replica) MarshalTo 

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

func (*Replica) MarshalToSizedBuffer 

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

func (*Replica) ProtoMessage 

func (*Replica) ProtoMessage()

func (*Replica) Reset 

func (m *Replica) Reset()

func (*Replica) Size 

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

func (*Replica) String 

func (m *Replica) String() string

func (*Replica) Unmarshal 

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

func (*Replica) XXX_DiscardUnknown 

func (m *Replica) XXX_DiscardUnknown()

func (*Replica) XXX_Marshal 

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

func (*Replica) XXX_Merge 

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

func (*Replica) XXX_Size 

func (m *Replica) XXX_Size() int

func (*Replica) XXX_Unmarshal 

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

type StoreType 

type StoreType int32
const (
	StoreType_Store_Invalid StoreType = 0
	StoreType_Store_Hot     StoreType = 1
	StoreType_Store_Warm    StoreType = 2
	StoreType_Store_Mix     StoreType = 3
)

func (StoreType) EnumDescriptor 

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

func (StoreType) String 

func (x StoreType) String() string

type Table 

type Table struct {
	Name       string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	DbName     string      `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	DbId       uint64      `protobuf:"varint,3,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	Id         uint64      `protobuf:"varint,4,opt,name=id,proto3" json:"id,omitempty"`
	Properties string      `protobuf:"bytes,5,opt,name=properties,proto3" json:"properties,omitempty"`
	Columns    []*Column   `protobuf:"bytes,6,rep,name=columns,proto3" json:"columns,omitempty"`
	Epoch      *TableEpoch `protobuf:"bytes,7,opt,name=epoch,proto3" json:"epoch,omitempty"`
	CreateTime int64       `protobuf:"varint,8,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// table status
	Status TableStatus `protobuf:"varint,9,opt,name=status,proto3,enum=basepb.TableStatus" json:"status,omitempty"`
	// table expand area
	// now when status is TableDelete, expand is the delete flag time
	Expand  []byte   `protobuf:"bytes,10,opt,name=expand,proto3" json:"expand,omitempty"`
	Indexes []*Index `protobuf:"bytes,11,rep,name=indexes,proto3" json:"indexes,omitempty"`
	//3 type of table，warm hot mix
	Type       StoreType `protobuf:"varint,12,opt,name=type,proto3,enum=basepb.StoreType" json:"type,omitempty"`
	ReplicaNum uint64    `protobuf:"varint,13,opt,name=replica_num,json=replicaNum,proto3" json:"replica_num,omitempty"`
	// how many date range live default 2
	DataRangeNum         uint64   `protobuf:"varint,14,opt,name=data_range_num,json=dataRangeNum,proto3" json:"data_range_num,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Table) Descriptor 

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

func (*Table) GetColumns 

func (m *Table) GetColumns() []*Column

func (*Table) GetCreateTime 

func (m *Table) GetCreateTime() int64

func (*Table) GetDataRangeNum 

func (m *Table) GetDataRangeNum() uint64

func (*Table) GetDbId 

func (m *Table) GetDbId() uint64

func (*Table) GetDbName 

func (m *Table) GetDbName() string

func (*Table) GetEpoch 

func (m *Table) GetEpoch() *TableEpoch

func (*Table) GetExpand 

func (m *Table) GetExpand() []byte

func (*Table) GetId 

func (m *Table) GetId() uint64

func (*Table) GetIndexes 

func (m *Table) GetIndexes() []*Index

func (*Table) GetName 

func (m *Table) GetName() string

func (*Table) GetProperties 

func (m *Table) GetProperties() string

func (*Table) GetReplicaNum 

func (m *Table) GetReplicaNum() uint64

func (*Table) GetStatus 

func (m *Table) GetStatus() TableStatus

func (*Table) GetType 

func (m *Table) GetType() StoreType

func (*Table) Marshal 

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

func (*Table) MarshalTo 

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

func (*Table) MarshalToSizedBuffer 

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

func (*Table) ProtoMessage 

func (*Table) ProtoMessage()

func (*Table) Reset 

func (m *Table) Reset()

func (*Table) Size 

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

func (*Table) String 

func (m *Table) String() string

func (*Table) Unmarshal 

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

func (*Table) XXX_DiscardUnknown 

func (m *Table) XXX_DiscardUnknown()

func (*Table) XXX_Marshal 

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

func (*Table) XXX_Merge 

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

func (*Table) XXX_Size 

func (m *Table) XXX_Size() int

func (*Table) XXX_Unmarshal 

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

type TableEpoch 

type TableEpoch struct {
	// Conf change version, auto increment when add or remove column
	ConfVer uint64 `protobuf:"varint,1,opt,name=conf_ver,json=confVer,proto3" json:"conf_ver,omitempty"`
	// Route version, auto increment when split or merge
	Version              uint64   `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TableEpoch) Descriptor 

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

func (*TableEpoch) GetConfVer 

func (m *TableEpoch) GetConfVer() uint64

func (*TableEpoch) GetVersion 

func (m *TableEpoch) GetVersion() uint64

func (*TableEpoch) Marshal 

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

func (*TableEpoch) MarshalTo 

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

func (*TableEpoch) MarshalToSizedBuffer 

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

func (*TableEpoch) ProtoMessage 

func (*TableEpoch) ProtoMessage()

func (*TableEpoch) Reset 

func (m *TableEpoch) Reset()

func (*TableEpoch) Size 

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

func (*TableEpoch) String 

func (m *TableEpoch) String() string

func (*TableEpoch) Unmarshal 

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

func (*TableEpoch) XXX_DiscardUnknown 

func (m *TableEpoch) XXX_DiscardUnknown()

func (*TableEpoch) XXX_Marshal 

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

func (*TableEpoch) XXX_Merge 

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

func (*TableEpoch) XXX_Size 

func (m *TableEpoch) XXX_Size() int

func (*TableEpoch) XXX_Unmarshal 

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

type TableStatus 

type TableStatus int32
const (
	TableStatus_TableInvalid TableStatus = 0
	TableStatus_TableRunning TableStatus = 1
)

func (TableStatus) EnumDescriptor 

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

func (TableStatus) String 

func (x TableStatus) String() string

type WatcherEvent 

type WatcherEvent struct {
	WatcherType          WatcherType `protobuf:"varint,1,opt,name=watcher_type,json=watcherType,proto3,enum=basepb.WatcherType" json:"watcher_type,omitempty"`
	EventType            EventType   `protobuf:"varint,2,opt,name=event_type,json=eventType,proto3,enum=basepb.EventType" json:"event_type,omitempty"`
	NodeId               uint64      `protobuf:"varint,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	DbId                 uint64      `protobuf:"varint,4,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId              uint64      `protobuf:"varint,5,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	RangeId              uint64      `protobuf:"varint,6,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	Value                []byte      `protobuf:"bytes,7,opt,name=value,proto3" json:"value,omitempty"`
	Version              uint64      `protobuf:"varint,8,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

node event has nodeID db event has dbID table event has dbID,tableID range event has tableID, rangeID

func (*WatcherEvent) Descriptor 

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

func (*WatcherEvent) GetDbId 

func (m *WatcherEvent) GetDbId() uint64

func (*WatcherEvent) GetEventType 

func (m *WatcherEvent) GetEventType() EventType

func (*WatcherEvent) GetNodeId 

func (m *WatcherEvent) GetNodeId() uint64

func (*WatcherEvent) GetRangeId 

func (m *WatcherEvent) GetRangeId() uint64

func (*WatcherEvent) GetTableId 

func (m *WatcherEvent) GetTableId() uint64

func (*WatcherEvent) GetValue 

func (m *WatcherEvent) GetValue() []byte

func (*WatcherEvent) GetVersion 

func (m *WatcherEvent) GetVersion() uint64

func (*WatcherEvent) GetWatcherType 

func (m *WatcherEvent) GetWatcherType() WatcherType

func (*WatcherEvent) Marshal 

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

func (*WatcherEvent) MarshalTo 

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

func (*WatcherEvent) MarshalToSizedBuffer 

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

func (*WatcherEvent) ProtoMessage 

func (*WatcherEvent) ProtoMessage()

func (*WatcherEvent) Reset 

func (m *WatcherEvent) Reset()

func (*WatcherEvent) Size 

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

func (*WatcherEvent) String 

func (m *WatcherEvent) String() string

func (*WatcherEvent) Unmarshal 

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

func (*WatcherEvent) XXX_DiscardUnknown 

func (m *WatcherEvent) XXX_DiscardUnknown()

func (*WatcherEvent) XXX_Marshal 

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

func (*WatcherEvent) XXX_Merge 

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

func (*WatcherEvent) XXX_Size 

func (m *WatcherEvent) XXX_Size() int

func (*WatcherEvent) XXX_Unmarshal 

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

type WatcherType 

type WatcherType int32
const (
	WatcherType_Watcher_Type_Invalid  WatcherType = 0
	WatcherType_Watcher_Type_Node     WatcherType = 1
	WatcherType_Watcher_Type_Database WatcherType = 2
	WatcherType_Watcher_Type_Table    WatcherType = 3
	WatcherType_Watcher_Type_Range    WatcherType = 4
)

func (WatcherType) EnumDescriptor 

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

func (WatcherType) String 

func (x WatcherType) String() string

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.