mspb

type AddColumnRequest struct {
	Header  *RequestHeader   `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	DbId    uint64           `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId uint64           `protobuf:"varint,3,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	Columns []*metapb.Column `protobuf:"bytes,4,rep,name=columns" json:"columns,omitempty"`
}

type AddColumnResponse struct {
	Header  *ResponseHeader  `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Columns []*metapb.Column `protobuf:"bytes,2,rep,name=columns" json:"columns,omitempty"`
}

type AskSplitRequest struct {
	Header   *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Range    *metapb.Range  `protobuf:"bytes,2,opt,name=range" json:"range,omitempty"`
	SplitKey []byte         `protobuf:"bytes,3,opt,name=split_key,json=splitKey,proto3" json:"split_key,omitempty"`
}

type AskSplitResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// set AskSplitRequest::range
	Range *metapb.Range `protobuf:"bytes,2,opt,name=range" json:"range,omitempty"`
	// We split the region into two, first uses the origin
	// parent region id, and the second uses the new_region_id.
	// We must guarantee that the new_region_id is global unique.
	NewRangeId uint64 `protobuf:"varint,3,opt,name=new_range_id,json=newRangeId,proto3" json:"new_range_id,omitempty"`
	// The peer ids for the new split region.
	NewPeerIds []uint64 `protobuf:"varint,4,rep,packed,name=new_peer_ids,json=newPeerIds" json:"new_peer_ids,omitempty"`
	SplitKey   []byte   `protobuf:"bytes,5,opt,name=split_key,json=splitKey,proto3" json:"split_key,omitempty"`
}

type CreateDatabaseRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	DbName string         `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
}

type CreateDatabaseResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

type CreateTableRequest struct {
	Header     *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	DbName     string         `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	TableName  string         `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	Properties string         `protobuf:"bytes,4,opt,name=properties,proto3" json:"properties,omitempty"`
}

type CreateTableResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

type Error struct {
	NewLeader *LeaderHint `protobuf:"bytes,2,opt,name=new_leader,json=newLeader" json:"new_leader,omitempty"`
	NoLeader  *NoLeader   `protobuf:"bytes,3,opt,name=no_leader,json=noLeader" json:"no_leader,omitempty"`
}

type GetColumnByIdRequest struct {
	Header  *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	DbId    uint64         `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId uint64         `protobuf:"varint,3,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	ColId   uint64         `protobuf:"varint,4,opt,name=col_id,json=colId,proto3" json:"col_id,omitempty"`
}

type GetColumnByIdResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Column *metapb.Column  `protobuf:"bytes,2,opt,name=column" json:"column,omitempty"`
}

type GetColumnByNameRequest struct {
	Header  *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	DbId    uint64         `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId uint64         `protobuf:"varint,3,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	ColName string         `protobuf:"bytes,4,opt,name=col_name,json=colName,proto3" json:"col_name,omitempty"`
}

type GetColumnByNameResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Column *metapb.Column  `protobuf:"bytes,2,opt,name=column" json:"column,omitempty"`
}

type GetColumnsRequest struct {
	Header  *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	DbId    uint64         `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId uint64         `protobuf:"varint,3,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
}

type GetColumnsResponse struct {
	Header  *ResponseHeader  `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Columns []*metapb.Column `protobuf:"bytes,2,rep,name=columns" json:"columns,omitempty"`
}

type GetDBRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Name   string         `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
}

type GetDBResponse struct {
	Header *ResponseHeader  `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Db     *metapb.DataBase `protobuf:"bytes,2,opt,name=db" json:"db,omitempty"`
}

type GetMSLeaderRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

type GetMSLeaderResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Leader *MSLeader       `protobuf:"bytes,2,opt,name=leader" json:"leader,omitempty"`
}

type GetNodeIdRequest struct {
	Header     *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	ServerPort uint32         `protobuf:"varint,2,opt,name=server_port,json=serverPort,proto3" json:"server_port,omitempty"`
	RaftPort   uint32         `protobuf:"varint,3,opt,name=raft_port,json=raftPort,proto3" json:"raft_port,omitempty"`
	HttpPort   uint32         `protobuf:"varint,4,opt,name=http_port,json=httpPort,proto3" json:"http_port,omitempty"`
	Version    string         `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
}

type GetNodeIdResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	NodeId uint64          `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// 是否需要节点清理所有数据
	Clearup bool `protobuf:"varint,3,opt,name=clearup,proto3" json:"clearup,omitempty"`
}

type GetNodeRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Id     uint64         `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
}

type GetNodeResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Node   *metapb.Node    `protobuf:"bytes,2,opt,name=node" json:"node,omitempty"`
}

type GetRouteRequest struct {
	Header  *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	DbId    uint64         `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId uint64         `protobuf:"varint,3,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	Key     []byte         `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
}

type GetRouteResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Routes []*metapb.Route `protobuf:"bytes,2,rep,name=routes" json:"routes,omitempty"`
}

type GetTableByIdRequest struct {
	Header  *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	DbId    uint64         `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId uint64         `protobuf:"varint,3,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
}

type GetTableByIdResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Table  *metapb.Table   `protobuf:"bytes,2,opt,name=table" json:"table,omitempty"`
}

type GetTableRequest struct {
	Header    *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	DbName    string         `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	TableName string         `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
}

type GetTableResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Table  *metapb.Table   `protobuf:"bytes,2,opt,name=table" json:"table,omitempty"`
}

type LeaderHint struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Term    uint64 `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
}

type MSLeader struct {
	Id      uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Term    uint64 `protobuf:"varint,3,opt,name=term,proto3" json:"term,omitempty"`
}

type MsServerClient interface {
	NodeHeartbeat(ctx context.Context, in *NodeHeartbeatRequest, opts ...grpc.CallOption) (*NodeHeartbeatResponse, error)
	RangeHeartbeat(ctx context.Context, in *RangeHeartbeatRequest, opts ...grpc.CallOption) (*RangeHeartbeatResponse, error)
	AskSplit(ctx context.Context, in *AskSplitRequest, opts ...grpc.CallOption) (*AskSplitResponse, error)
	ReportSplit(ctx context.Context, in *ReportSplitRequest, opts ...grpc.CallOption) (*ReportSplitResponse, error)
	NodeLogin(ctx context.Context, in *NodeLoginRequest, opts ...grpc.CallOption) (*NodeLoginResponse, error)
	GetNodeId(ctx context.Context, in *GetNodeIdRequest, opts ...grpc.CallOption) (*GetNodeIdResponse, error)
	GetMSLeader(ctx context.Context, in *GetMSLeaderRequest, opts ...grpc.CallOption) (*GetMSLeaderResponse, error)
	GetRoute(ctx context.Context, in *GetRouteRequest, opts ...grpc.CallOption) (*GetRouteResponse, error)
	GetNode(ctx context.Context, in *GetNodeRequest, opts ...grpc.CallOption) (*GetNodeResponse, error)
	GetDB(ctx context.Context, in *GetDBRequest, opts ...grpc.CallOption) (*GetDBResponse, error)
	GetTable(ctx context.Context, in *GetTableRequest, opts ...grpc.CallOption) (*GetTableResponse, error)
	GetTableById(ctx context.Context, in *GetTableByIdRequest, opts ...grpc.CallOption) (*GetTableByIdResponse, error)
	GetColumns(ctx context.Context, in *GetColumnsRequest, opts ...grpc.CallOption) (*GetColumnsResponse, error)
	GetColumnByName(ctx context.Context, in *GetColumnByNameRequest, opts ...grpc.CallOption) (*GetColumnByNameResponse, error)
	GetColumnById(ctx context.Context, in *GetColumnByIdRequest, opts ...grpc.CallOption) (*GetColumnByIdResponse, error)
	TruncateTable(ctx context.Context, in *TruncateTableRequest, opts ...grpc.CallOption) (*TruncateTableResponse, error)
	AddColumn(ctx context.Context, in *AddColumnRequest, opts ...grpc.CallOption) (*AddColumnResponse, error)
	CreateDatabase(ctx context.Context, in *CreateDatabaseRequest, opts ...grpc.CallOption) (*CreateDatabaseResponse, error)
	CreateTable(ctx context.Context, in *CreateTableRequest, opts ...grpc.CallOption) (*CreateTableResponse, error)
}

type MsServerServer interface {
	NodeHeartbeat(context.Context, *NodeHeartbeatRequest) (*NodeHeartbeatResponse, error)
	RangeHeartbeat(context.Context, *RangeHeartbeatRequest) (*RangeHeartbeatResponse, error)
	AskSplit(context.Context, *AskSplitRequest) (*AskSplitResponse, error)
	ReportSplit(context.Context, *ReportSplitRequest) (*ReportSplitResponse, error)
	NodeLogin(context.Context, *NodeLoginRequest) (*NodeLoginResponse, error)
	GetNodeId(context.Context, *GetNodeIdRequest) (*GetNodeIdResponse, error)
	GetMSLeader(context.Context, *GetMSLeaderRequest) (*GetMSLeaderResponse, error)
	GetRoute(context.Context, *GetRouteRequest) (*GetRouteResponse, error)
	GetNode(context.Context, *GetNodeRequest) (*GetNodeResponse, error)
	GetDB(context.Context, *GetDBRequest) (*GetDBResponse, error)
	GetTable(context.Context, *GetTableRequest) (*GetTableResponse, error)
	GetTableById(context.Context, *GetTableByIdRequest) (*GetTableByIdResponse, error)
	GetColumns(context.Context, *GetColumnsRequest) (*GetColumnsResponse, error)
	GetColumnByName(context.Context, *GetColumnByNameRequest) (*GetColumnByNameResponse, error)
	GetColumnById(context.Context, *GetColumnByIdRequest) (*GetColumnByIdResponse, error)
	TruncateTable(context.Context, *TruncateTableRequest) (*TruncateTableResponse, error)
	AddColumn(context.Context, *AddColumnRequest) (*AddColumnResponse, error)
	CreateDatabase(context.Context, *CreateDatabaseRequest) (*CreateDatabaseResponse, error)
	CreateTable(context.Context, *CreateTableRequest) (*CreateTableResponse, error)
}

type NoLeader struct {
}

type NodeHeartbeatRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	NodeId uint64         `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Stats  *NodeStats     `protobuf:"bytes,3,opt,name=stats" json:"stats,omitempty"`
	// 孤立的副本列表, 超过一个小时都没有收到leader心跳
	IsolatedReplicas []uint64 `protobuf:"varint,4,rep,packed,name=isolated_replicas,json=isolatedReplicas" json:"isolated_replicas,omitempty"`
}

type NodeHeartbeatResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	NodeId uint64          `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// 需要清理的副本列表
	DeleteReplicas []uint64 `protobuf:"varint,3,rep,packed,name=delete_replicas,json=deleteReplicas" json:"delete_replicas,omitempty"`
}

type NodeLoginRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	NodeId uint64         `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

type NodeLoginResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

type NodeStats struct {
	// Total range count in this node.
	RangeCount uint32 `protobuf:"varint,1,opt,name=range_count,json=rangeCount,proto3" json:"range_count,omitempty"`
	// Current range split count.
	RangeSplitCount uint32 `protobuf:"varint,2,opt,name=range_split_count,json=rangeSplitCount,proto3" json:"range_split_count,omitempty"`
	// Current sending snapshot count.
	SendingSnapCount uint32 `protobuf:"varint,3,opt,name=sending_snap_count,json=sendingSnapCount,proto3" json:"sending_snap_count,omitempty"`
	// Current receiving snapshot count.
	ReceivingSnapCount uint32 `protobuf:"varint,4,opt,name=receiving_snap_count,json=receivingSnapCount,proto3" json:"receiving_snap_count,omitempty"`
	// Current receiving snapshot count.
	ApplyingSnapCount uint32 `protobuf:"varint,5,opt,name=applying_snap_count,json=applyingSnapCount,proto3" json:"applying_snap_count,omitempty"`
	RangeLeaderCount  uint32 `protobuf:"varint,6,opt,name=range_leader_count,json=rangeLeaderCount,proto3" json:"range_leader_count,omitempty"`
	// Capacity for the DS.
	Capacity uint64 `protobuf:"varint,7,opt,name=capacity,proto3" json:"capacity,omitempty"`
	// Actually used for the DS.
	UsedSize uint64 `protobuf:"varint,8,opt,name=used_size,json=usedSize,proto3" json:"used_size,omitempty"`
	// Available size for the node.
	Available uint64 `protobuf:"varint,9,opt,name=available,proto3" json:"available,omitempty"`
	// Bytes written for the DS.
	BytesWritten uint64 `protobuf:"varint,10,opt,name=bytes_written,json=bytesWritten,proto3" json:"bytes_written,omitempty"`
	// Keys written for the DS.
	KeysWritten uint64 `protobuf:"varint,11,opt,name=keys_written,json=keysWritten,proto3" json:"keys_written,omitempty"`
	// Bytes read for the DS.
	BytesRead uint64 `protobuf:"varint,12,opt,name=bytes_read,json=bytesRead,proto3" json:"bytes_read,omitempty"`
	// Keys read for the DS.
	KeysRead uint64 `protobuf:"varint,13,opt,name=keys_read,json=keysRead,proto3" json:"keys_read,omitempty"`
	// If the node is busy
	IsBusy bool `protobuf:"varint,14,opt,name=is_busy,json=isBusy,proto3" json:"is_busy,omitempty"`
	// When the node is started (unix timestamp in seconds).
	Start uint32 `protobuf:"varint,15,opt,name=start,proto3" json:"start,omitempty"`
}

type PeerStatus struct {
	Peer         *metapb.Peer `protobuf:"bytes,1,opt,name=peer" 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"`
}

type RangeHeartbeatRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Range  *metapb.Range  `protobuf:"bytes,2,opt,name=range" json:"range,omitempty"`
	// leader
	Leader *metapb.Peer `protobuf:"bytes,3,opt,name=leader" json:"leader,omitempty"`
	// range metric stats
	Stats *RangeStats `protobuf:"bytes,6,opt,name=stats" json:"stats,omitempty"`
	// leader term
	Term uint64 `protobuf:"varint,7,opt,name=term,proto3" json:"term,omitempty"`
	// replica status
	PeersStatus []*PeerStatus `protobuf:"bytes,8,rep,name=peers_status,json=peersStatus" json:"peers_status,omitempty"`
}

type RangeHeartbeatResponse struct {
	Header  *ResponseHeader    `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	RangeId uint64             `protobuf:"varint,2,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	Epoch   *metapb.RangeEpoch `protobuf:"bytes,3,opt,name=epoch" json:"epoch,omitempty"`
	// target leader for task
	TargetPeer *metapb.Peer `protobuf:"bytes,4,opt,name=target_peer,json=targetPeer" json:"target_peer,omitempty"`
	Task       *taskpb.Task `protobuf:"bytes,5,opt,name=task" json:"task,omitempty"`
}

type RangeStats struct {
	// Bytes read/written during this period.
	BytesWritten uint64 `protobuf:"varint,1,opt,name=bytes_written,json=bytesWritten,proto3" json:"bytes_written,omitempty"`
	BytesRead    uint64 `protobuf:"varint,2,opt,name=bytes_read,json=bytesRead,proto3" json:"bytes_read,omitempty"`
	// Keys read/written during this period.
	KeysWritten uint64 `protobuf:"varint,3,opt,name=keys_written,json=keysWritten,proto3" json:"keys_written,omitempty"`
	KeysRead    uint64 `protobuf:"varint,4,opt,name=keys_read,json=keysRead,proto3" json:"keys_read,omitempty"`
	// Approximate range size.
	ApproximateSize uint64 `protobuf:"varint,5,opt,name=approximate_size,json=approximateSize,proto3" json:"approximate_size,omitempty"`
}

type ReportSplitRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Left   *metapb.Range  `protobuf:"bytes,2,opt,name=left" json:"left,omitempty"`
	Right  *metapb.Range  `protobuf:"bytes,3,opt,name=right" json:"right,omitempty"`
}

type ReportSplitResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

type RequestHeader struct {
	ClusterId uint64 `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
}

type ResponseHeader struct {
	ClusterId uint64 `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Error     *Error `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
}

type TruncateTableRequest struct {
	Header  *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	DbId    uint64         `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId uint64         `protobuf:"varint,3,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
}

type TruncateTableResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}