package baidu.bfs

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc WriteBlock (WriteBlockRequest, WriteBlockResponse)

  chunkserver.proto:57

  message WriteBlockRequest

  chunkserver.proto:7

  • optional int64 sequence_id = 1

  • optional int64 block_id = 2

  • optional int64 offset = 3

  • optional int32 packet_seq = 4

  • optional bytes databuf = 5

  • repeated string chunkservers = 6

  • optional bool is_last = 7

  • repeated string desc = 11

  • repeated int64 timestamp = 12

  • optional int32 recover_version = 13

  • optional bool sync_on_close = 14

  • optional int64 total_size = 15

  message WriteBlockResponse

  chunkserver.proto:22

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

  • optional string bad_chunkserver = 3

  • optional int64 current_size = 4

  • optional int32 current_seq = 5

  • repeated string desc = 11

  • repeated int64 timestamp = 12

• rpc ReadBlock (ReadBlockRequest, ReadBlockResponse)

  chunkserver.proto:58

  message ReadBlockRequest

  chunkserver.proto:32

  • optional int64 sequence_id = 1

  • optional int64 block_id = 2

  • optional int64 offset = 3

  • optional int32 read_len = 4

  message ReadBlockResponse

  chunkserver.proto:38

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

  • optional bytes databuf = 3

  • repeated int64 timestamp = 9

• rpc GetBlockInfo (GetBlockInfoRequest, GetBlockInfoResponse)

  chunkserver.proto:59

  message GetBlockInfoRequest

  chunkserver.proto:45

  • optional int64 sequence_id = 1

  • optional int64 block_id = 2

  message GetBlockInfoResponse

  chunkserver.proto:49

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

  • optional int64 block_size = 3

  • repeated int64 timestamp = 9

• rpc CreateFile (CreateFileRequest, CreateFileResponse)

  nameserver.proto:365

  message CreateFileRequest

  nameserver.proto:39

  • optional int64 sequence_id = 1

  • optional string file_name = 2

  • optional int32 mode = 3

  • optional int32 flags = 4

  • optional int32 replica_num = 5

  • optional string user = 7

  message CreateFileResponse

  nameserver.proto:48

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

• rpc AddBlock (AddBlockRequest, AddBlockResponse)

  nameserver.proto:366

  message AddBlockRequest

  nameserver.proto:104

  • optional int64 sequence_id = 1

  • optional string file_name = 2

  • optional string client_address = 3

  message AddBlockResponse

  nameserver.proto:109

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

  • optional LocatedBlock block = 3

• rpc GetFileLocation (FileLocationRequest, FileLocationResponse)

  nameserver.proto:367

  message FileLocationRequest

  nameserver.proto:60

  • optional int64 sequence_id = 1

  • optional string file_name = 2

  • optional int64 offset = 3

  • optional int32 block_num = 4

  • optional string user = 5

  message FileLocationResponse

  nameserver.proto:68

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

  • repeated LocatedBlock blocks = 3

• rpc ListDirectory (ListDirectoryRequest, ListDirectoryResponse)

  nameserver.proto:368

  message ListDirectoryRequest

  nameserver.proto:74

  • optional int64 sequence_id = 1

  • optional string path = 2

  message ListDirectoryResponse

  nameserver.proto:78

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

  • repeated FileInfo files = 3

• rpc Stat (StatRequest, StatResponse)

  nameserver.proto:369

  message StatRequest

  nameserver.proto:84

  • optional int64 sequence_id = 1

  • optional string path = 2

  message StatResponse

  nameserver.proto:88

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

  • optional FileInfo file_info = 3

• rpc Rename (RenameRequest, RenameResponse)

  nameserver.proto:370

  message RenameRequest

  nameserver.proto:94

  • optional int64 sequence_id = 1

  • optional string oldpath = 2

  • optional string newpath = 3

  message RenameResponse

  nameserver.proto:99

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

• rpc SyncBlock (SyncBlockRequest, SyncBlockResponse)

  nameserver.proto:371

  message SyncBlockRequest

  nameserver.proto:115

  • optional int64 sequence_id = 1

  • optional int64 block_id = 2

  • optional string file_name = 3

  • optional int64 size = 4

  message SyncBlockResponse

  nameserver.proto:122

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

• rpc FinishBlock (FinishBlockRequest, FinishBlockResponse)

  nameserver.proto:372

  message FinishBlockRequest

  nameserver.proto:127

  • optional int64 sequence_id = 1

  • optional int64 block_id = 2

  • optional int64 block_version = 3

  • optional string file_name = 4

  • optional int64 block_size = 5

  • optional bool close_with_error = 6

  message FinishBlockResponse

  nameserver.proto:135

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

• rpc Unlink (UnlinkRequest, UnlinkResponse)

  nameserver.proto:373

  message UnlinkRequest

  nameserver.proto:140

  • optional int64 sequence_id = 1

  • optional string path = 2

  message UnlinkResponse

  nameserver.proto:144

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

• rpc DeleteDirectory (DeleteDirectoryRequest, DeleteDirectoryResponse)

  nameserver.proto:374

  message DeleteDirectoryRequest

  nameserver.proto:149

  • optional int64 sequence_id = 1

  • optional string path = 2

  • optional bool recursive = 3

  message DeleteDirectoryResponse

  nameserver.proto:154

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

• rpc ChangeReplicaNum (ChangeReplicaNumRequest, ChangeReplicaNumResponse)

  nameserver.proto:375

  message ChangeReplicaNumRequest

  nameserver.proto:159

  • optional int64 sequence_id = 1

  • optional string file_name = 2

  • optional int32 replica_num = 3

  message ChangeReplicaNumResponse

  nameserver.proto:164

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

• rpc ShutdownChunkServer (ShutdownChunkServerRequest, ShutdownChunkServerResponse)

  nameserver.proto:376

  message ShutdownChunkServerRequest

  nameserver.proto:288

  • optional int64 sequence_id = 1

  • repeated string chunkserver_address = 2

  message ShutdownChunkServerResponse

  nameserver.proto:293

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

• rpc ShutdownChunkServerStat (ShutdownChunkServerStatRequest, ShutdownChunkServerStatResponse)

  nameserver.proto:377

  message ShutdownChunkServerStatRequest

  nameserver.proto:298

  • optional int64 sequence_id = 1

  message ShutdownChunkServerStatResponse

  nameserver.proto:302

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

  • optional bool in_offline_progress = 3

• rpc DiskUsage (DiskUsageRequest, DiskUsageResponse)

  nameserver.proto:378

  message DiskUsageRequest

  nameserver.proto:308

  • optional int64 sequence_id = 1

  • optional string path = 2

  message DiskUsageResponse

  nameserver.proto:313

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

  • optional uint64 du_size = 3

• rpc Register (RegisterRequest, RegisterResponse)

  nameserver.proto:380

  message RegisterRequest

  nameserver.proto:209

  • optional int64 sequence_id = 1

  • optional string chunkserver_addr = 3

  • optional int64 namespace_version = 4

  • optional string tag = 5

  • optional int64 disk_quota = 7

  message RegisterResponse

  nameserver.proto:216

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

  • optional int32 chunkserver_id = 5

  • optional int64 namespace_version = 6

  • optional int32 report_interval = 7

  • optional int32 report_size = 8

  • optional int64 report_id = 9

• rpc HeartBeat (HeartBeatRequest, HeartBeatResponse)

  nameserver.proto:381

  message HeartBeatRequest

  nameserver.proto:169

  • optional int64 sequence_id = 1

  • optional string chunkserver_addr = 2

  • optional int32 chunkserver_id = 3

  • optional int64 namespace_version = 4

  • optional int32 block_num = 5

  • optional int64 data_size = 6

  • optional int32 buffers = 7

  • optional int32 pending_buf = 13

  • optional int32 pending_recover = 14

  • optional int32 w_qps = 8

  • optional int64 w_speed = 9

  • optional int32 r_qps = 10

  • optional int64 r_speed = 11

  • optional int64 recover_speed = 12

  message HeartBeatResponse

  nameserver.proto:185

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

  • optional int64 namespace_version = 3

  • optional bool kick = 4

  • optional int32 report_interval = 5

  • optional int32 report_size = 6

• rpc BlockReport (BlockReportRequest, BlockReportResponse)

  nameserver.proto:382

  message BlockReportRequest

  nameserver.proto:226

  • optional int64 sequence_id = 1

  • optional int32 chunkserver_id = 2

  • optional string chunkserver_addr = 3

  • optional int64 start = 4

  • optional int64 end = 5

  • repeated ReportBlockInfo blocks = 6

  • optional int64 report_id = 7

  message BlockReportResponse

  nameserver.proto:235

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

  • repeated int64 obsolete_blocks = 3

  • repeated int64 close_blocks = 4

  • repeated ReplicaInfo new_replicas = 5

  • optional int64 report_id = 6

• rpc BlockReceived (BlockReceivedRequest, BlockReceivedResponse)

  nameserver.proto:383

  message BlockReceivedRequest

  nameserver.proto:244

  • optional int64 sequence_id = 1

  • optional int32 chunkserver_id = 2

  • optional string chunkserver_addr = 3

  • repeated ReportBlockInfo blocks = 6

  message BlockReceivedResponse

  nameserver.proto:251

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

• rpc PushBlockReport (PushBlockReportRequest, PushBlockReportResponse)

  nameserver.proto:384

  message PushBlockReportRequest

  nameserver.proto:256

  • optional int64 sequence_id = 1

  • optional int32 chunkserver_id = 2

  • repeated int64 blocks = 3

  • repeated StatusCode status = 4

  message PushBlockReportResponse

  nameserver.proto:262

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

• rpc SysStat (SysStatRequest, SysStatResponse)

  nameserver.proto:386

  message SysStatRequest

  nameserver.proto:267

  • optional string stat_name = 2

  message SysStatResponse

  nameserver.proto:271

  • optional StatusCode status = 2

  • repeated ChunkServerInfo chunkservers = 3

  • optional int64 block_num = 4

  • optional int64 data_size = 5

• rpc Chmod (ChmodRequest, ChmodResponse)

  nameserver.proto:387

  message ChmodRequest

  nameserver.proto:319

  • optional int64 sequence_id = 1

  • optional int32 mode = 2

  • optional string path = 3

  message ChmodResponse

  nameserver.proto:325

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

• rpc Symlink (SymlinkRequest, SymlinkResponse)

  nameserver.proto:388

  message SymlinkRequest

  nameserver.proto:330

  • optional int64 sequence_id = 1

  • optional string src = 2

  • optional string dst = 3

  • optional string user = 4

  message SymlinkResponse

  nameserver.proto:337

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

• rpc LockDir (LockDirRequest, LockDirResponse)

  nameserver.proto:389

  message LockDirRequest

  nameserver.proto:342

  • optional int64 sequence_id = 1

  • optional string dir_path = 2

  • optional string uuid = 3

  message LockDirResponse

  nameserver.proto:348

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

• rpc UnlockDir (UnlockDirRequest, UnlockDirResponse)

  nameserver.proto:390

  message UnlockDirRequest

  nameserver.proto:353

  • optional int64 sequence_id = 1

  • optional string dir_path = 2

  • optional string uuid = 3

  message UnlockDirResponse

  nameserver.proto:359

  • optional int64 sequence_id = 1

  • optional StatusCode status = 2

• rpc Vote (VoteRequest, VoteResponse)

  raft.proto:42

  message VoteRequest

  raft.proto:6

  • optional int64 term = 2

  • optional string candidate = 3

  • optional int64 last_log_index = 4

  • optional int64 last_log_term = 5

  message VoteResponse

  raft.proto:12

  • optional int64 term = 2

  • optional bool vote_granted = 3

• rpc AppendEntries (AppendEntriesRequest, AppendEntriesResponse)

  raft.proto:43

  message AppendEntriesRequest

  raft.proto:28

  • optional int64 term = 2

  • optional string leader = 3

  • optional int64 prev_log_index = 4

  • optional int64 prev_log_term = 5

  • repeated LogEntry entries = 6

  • optional int64 leader_commit = 7

  message AppendEntriesResponse

  raft.proto:36

  • optional int64 term = 2

  • optional bool success = 3

• optional int64 block_id = 1

• optional int64 block_size = 2

• optional int64 checksum = 3

• optional int64 version = 4

• optional string store_path = 5

Used in: LocatedBlock, SysStatResponse

• optional int32 id = 1

• optional string address = 2

• optional string ipaddress = 18

• optional string start_time = 17

• optional int32 last_heartbeat = 3

• optional int64 data_size = 4

• optional int64 disk_quota = 5

• optional int32 block_num = 7

• optional bool is_dead = 8

• optional ChunkServerStatus status = 9

• optional int32 ip = 10

• optional int32 buffers = 11

• optional int32 pending_buf = 28

• optional int32 pending_recover = 29

• optional bool kick = 12

• optional string zone = 13

• optional string datacenter = 14

• optional string rack = 15

• optional string tag = 16

• optional double load = 20

  running status

• optional int32 w_qps = 21

• optional int64 w_speed = 22

• optional int32 r_qps = 23

• optional int64 r_speed = 24

• optional int64 writing_buffers = 25

• optional int64 active_blocks = 26

• optional int64 recover_speed = 27

Used in: ChunkServerInfo

• kCsActive = 101

• kCsWaitClean = 102

• kCsCleaning = 103

• kCsOffLine = 104

• kCsStandby = 105

• kCsReadonly = 106

Used in: ListDirectoryResponse, StatResponse

• optional int64 entry_id = 1

• optional int64 version = 2

• optional int32 type = 3

• repeated int64 blocks = 4

• optional uint32 ctime = 5

• optional string name = 6

• optional int64 size = 7

• optional int32 replicas = 8

• optional int64 parent_entry_id = 9

• optional int32 owner = 10

• repeated string cs_addrs = 11

• optional string sym_link = 12

Used in: AddBlockResponse, FileLocationResponse

• optional int64 block_id = 1

• optional int64 block_size = 2

• repeated ChunkServerInfo chains = 3

• optional int32 status = 4

Used in: AppendEntriesRequest

• optional int64 index = 2

• optional int64 term = 3

• optional bytes log_data = 4

• optional LogType type = 5

Used in: LogEntry

• kUserLog = 0

• kRaftCmd = 1

• repeated NsLogEntry entries = 1

Used in: NameServerLog

• optional int32 type = 1

• optional bytes key = 2

• optional bytes value = 3

• optional int32 report_interval = 1

• optional int32 report_size = 2

• optional int32 recover_size = 3

• optional int32 keepalive_timeout = 4

• kHigh = 0

• kLow = 1

• kNotInRecover = 0

• kLoRecover = 1

• kHiRecover = 2

• kCheck = 3

• kIncomplete = 4

• kLost = 5

• kBlockWriting = 6

• kAny = 20

Used in: BlockReportResponse

• optional int64 block_id = 1

• repeated string chunkserver_address = 2

• optional bool priority = 5

  optional int64 block_size = 3; optional int64 block_version = 4;

• optional int32 recover_timeout = 6

Used in: BlockReceivedRequest, BlockReportRequest

• optional int64 block_id = 1

• optional int64 version = 2

• optional int64 block_size = 3

• optional bool is_recover = 4

Used in: AddBlockResponse, BlockReceivedResponse, BlockReportResponse, ChangeReplicaNumResponse, ChmodResponse, CreateFileResponse, DeleteDirectoryResponse, DiskUsageResponse, FileLocationResponse, FinishBlockResponse, GetBlockInfoResponse, HeartBeatResponse, ListDirectoryResponse, LockDirResponse, PushBlockReportRequest, PushBlockReportResponse, ReadBlockResponse, RegisterResponse, RenameResponse, ShutdownChunkServerResponse, ShutdownChunkServerStatResponse, StatResponse, SymlinkResponse, SyncBlockResponse, SysStatResponse, UnlinkResponse, UnlockDirResponse, WriteBlockResponse, metaserver.AddBlockResponse, metaserver.FinishBlockResponse, metaserver.RemoveBlockResponse, metaserver.SyncBlockResponse

• kOK = 0

• kNotOK = 1

• kUnknownCs = 2

• kVersionError = 3

• kIsFollower = 4

• kInShutdownProgress = 5

• kBadParameter = 100

• kDirNotEmpty = 101

• kTargetDirExists = 102

• kFileExists = 103

• kBlockClosed = 104

• kBlockExist = 105

• kReadOnly = 106

• kNsNotFound = 107

• kCsNotFound = 108

• kNoPermission = 200

• kNotEnoughQuota = 300

• kNetworkUnavailable = 400

• kTimeout = 500

• kWriteError = 501

• kReadError = 502

• kNoEnoughSpace = 600

• kCsTooMuchUnfinishedWrite = 700

• kCsTooMuchPendingBuffer = 701

• kGetChunkServerError = 702

• kUpdateError = 800

• kSyncMetaFailed = 801

• kSafeMode = 802

• kServiceStop = 803

• kDirLocked = 804

• kDirUnlock = 805

• kDirLockCleaning = 806

• kSyncWrite = 0

• kSyncDelete = 1