vermeer/apps/protos/metapb.proto

syntax = "proto3"; package metapb; option go_package = "/hugegraph-pd-grpc/metapb"; import "google/protobuf/any.proto"; enum ClusterState{ // 集群健康 Cluster_OK = 0; // 分区警告，存在部分故障节点，短时间不影响读写 Cluster_Warn = 2; // 分区下线，可以读，无法写 Cluster_Offline = 10; // 分区故障，无法读写,需要尽快修复故障节点。 Cluster_Fault = 11; Cluster_Not_Ready = -1; } // 集群状态 message ClusterStats{ ClusterState state = 1; string message = 2; uint64 timestamp = 16; } enum StoreState { Unknown = 0; // 未激活 Pending = 4; // 在线 Up = 1; // 离线 Offline = 2; // 下线中 Exiting = 5; // 已下线 Tombstone = 3; } // Store label for Storage grouping. message StoreLabel { string key = 1; string value = 2; } message Store { uint64 id = 1; // Address to handle client requests string address = 2; string raft_address = 3; repeated StoreLabel labels = 4; // Store软件版本号 string version = 5; StoreState state = 6; // The start timestamp of the current store int64 start_timestamp = 7; string deploy_path = 8; // The last heartbeat timestamp of the store. int64 last_heartbeat = 9; StoreStats stats = 10; // 数据格式版本号 int32 data_version = 11; int32 cores = 12; string data_path = 13; } enum ShardRole { None = 0; Leader = 1; Follower = 2; // Learner/None -> Learner Learner = 3; } message Shard { uint64 store_id = 2; ShardRole role = 3; } message ShardGroup{ uint32 id = 1; uint64 version = 2; uint64 conf_ver = 3; repeated Shard shards = 6; PartitionState state = 10; string message = 11; } message Graph { string graph_name = 2; // 分区数量，0表示无效，不能大于raft分组总数 int32 partition_count = 3; // 当前工作状态 PartitionState state = 10; string message = 11; GraphState graph_state = 12; } // 分区工作状态 enum PartitionState{ PState_None = 0; // PState_Normal = 1; // 分区警告，存在部分故障节点，短时间不影响读写 PState_Warn = 2; // 分区下线，可以读，无法写 PState_Offline = 10; // 分区故障，无法读写,需要尽快修复故障节点。 PState_Fault = 11; } message PartitionV36 { uint32 id = 1; string graph_name = 3; // 分区范围 [start_key, end_key). uint64 start_key = 4; uint64 end_key = 5; repeated Shard shards = 6; // Leader任期，leader切换后递增 uint64 version = 7; // shards版本号，每次改变后递增 uint64 conf_ver = 8; // 当前工作状态 PartitionState state = 10; string message = 11; } message Partition { uint32 id = 1; string graph_name = 3; // 分区范围 [start_key, end_key). uint64 start_key = 4; uint64 end_key = 5; // Partition 对象不在保存 shard list（根据对应的shard group 去查询), version 和 conf version不再有实际的意义 // repeated Shard shards = 6; // key range 每次改变后递增 uint64 version = 7; // shards版本号，每次改变后递增 // uint64 conf_ver = 8; // 当前工作状态 PartitionState state = 10; string message = 11; } message PartitionShard { metapb.Partition partition = 1; metapb.Shard leader = 2; // 离线的Shard repeated metapb.Shard offline_shards = 3; } // 记录分区所在的存储位置 message PartitionStore { uint32 partition_id = 1; string graph_name = 3; // 存储位置 string store_location = 4; } message PartitionRaft { uint32 partition_id = 1; string graph_name = 3; // 存储位置 string raft_location = 4; } message ShardStats{ uint64 store_id = 2; ShardRole role = 3; ShardState state = 4; // 安装快照的进度 uint32 progress = 5; } message PartitionStats{ uint32 id = 1; // raft分组的任期. uint64 leader_term = 2; repeated string graph_name = 3; metapb.Shard leader = 4; // 离线 shards repeated metapb.Shard shard = 5; repeated metapb.Shard learner = 6; uint64 conf_ver = 7; // 分区状态 PartitionState state = 8; repeated ShardStats shardStats = 9; // 分区近似大小 uint64 approximate_size = 10; // 分区key的近似数量 uint64 approximate_keys = 13; // heartbeat timestamp int64 timestamp = 16; } message GraphStats{ // 图名 string graph_name = 1; // 分区近似大小 uint64 approximate_size = 2; // 分区key的近似数量 uint64 approximate_keys = 3; // // committed index // uint64 committed_index = 4; uint32 partition_id = 5; ShardRole role = 6; // 当前工作状态 PartitionState work_state = 8; } message RaftStats { // partition id uint32 partition_id = 1; // committed index uint64 committed_index = 2; } message TimeInterval { // The unix timestamp in seconds of the start of this period. uint64 start_timestamp = 1; // The unix timestamp in seconds of the end of this period. uint64 end_timestamp = 2; } message RecordPair { string key = 1; uint64 value = 2; } message QueryStats { uint64 GC = 1; uint64 Get = 2; uint64 Scan = 3; uint64 Coprocessor = 4; uint64 Delete = 5; uint64 DeleteRange = 6; uint64 Put = 7; } enum ShardState{ SState_None = 0; // 正常 SState_Normal = 1; // 安装快照 SState_Snapshot = 2; // 离线 SState_Offline = 10; } message StoreStats { uint64 store_id = 1; // Capacity for the store. uint64 capacity = 2; // Available size for the store. uint64 available = 3; // Total partition count in this store. uint32 partition_count = 4; // Current sending snapshot count. uint32 sending_snap_count = 5; // Current receiving snapshot count. uint32 receiving_snap_count = 6; // When the store is started (unix timestamp in seconds). uint32 start_time = 7; // How many partition is applying snapshot. uint32 applying_snap_count = 8; // If the store is busy bool is_busy = 9; // Actually used space by db uint64 used_size = 10; // Bytes written for the store during this period. uint64 bytes_written = 11; // Keys written for the store during this period. uint64 keys_written = 12; // Bytes read for the store during this period. uint64 bytes_read = 13; // Keys read for the store during this period. uint64 keys_read = 14; // Actually reported time interval TimeInterval interval = 15; // Threads' CPU usages in the store repeated RecordPair cpu_usages = 16; // Threads' read disk I/O rates in the store repeated RecordPair read_io_rates = 17; // Threads' write disk I/O rates in the store repeated RecordPair write_io_rates = 18; // Operations' latencies in the store repeated RecordPair op_latencies = 19; // Store query stats QueryStats query_stats = 21; // graph stats repeated GraphStats graph_stats = 22; // raft stats repeated RaftStats raft_stats = 23; int32 cores = 24; // system metrics repeated RecordPair system_metrics = 25; } // 分区查询条件 message PartitionQuery{ optional uint64 store_id = 1; // 0 表示查询条件不包含store_id optional string graph_name = 2; optional uint32 partition_id = 4; } //PD 节点信息 message Member { uint64 cluster_id = 1; string raft_url = 3; string grpc_url = 4; string rest_url = 5; string data_path = 6; StoreState state = 7; } // 图空间配置 message GraphSpace{ string name = 1; // 最大占用存储 uint64 storage_limit = 2; // 已使用空间 uint64 used_size = 3; // 修改时间 uint64 timestamp = 10; } // PD 配置 message PDConfig{ uint64 version = 1; // 分区数量, 初始化根据Store数量动态计算，分裂后进行修改 int32 partition_count = 2; // 每分区副本数量 int32 shard_count = 3; // pd集群列表 string peers_list = 4; // 集群中最少store数量 int32 min_store_count = 6; // 每个store最大副本数 int32 max_Shards_Per_Store = 7; // 修改时间 uint64 timestamp = 10; } //消息持久化 message QueueItem{ string item_id=1; string item_class=2; bytes item_content=3; int64 timestamp=10; } message LogRecord{ string action = 1; int64 timestamp = 2; map<string, string> labels = 3; google.protobuf.Any object = 4; string message = 5; } message GraphState{ GraphMode mode = 1; GraphModeReason reason = 2; } enum GraphMode{ ReadWrite = 0; ReadOnly = 1; WriteOnly = 2; } enum GraphModeReason{ Empty = 0; // 空 Initiative = 1; // 主动的状态设置 Quota = 2; // 达到限额条件 }

vermeer/apps/protos/metapb.proto (355 lines of code) (raw):