Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Renamed admin API from RebalanceRepair to RepairJob

  • Loading branch information...
commit 8f54d3802c811d2004eb61120aafb6a3f105407f 1 parent f3657b9
Chinmay Soman authored
View
98 clients/python/voldemort/protocol/voldemort_admin_pb2.py
@@ -10,7 +10,7 @@
DESCRIPTOR = descriptor.FileDescriptor(
name='voldemort-admin.proto',
package='voldemort',
- serialized_pb='\n\x15voldemort-admin.proto\x12\tvoldemort\x1a\x16voldemort-client.proto\"!\n\x12GetMetadataRequest\x12\x0b\n\x03key\x18\x01 \x02(\x0c\"]\n\x13GetMetadataResponse\x12%\n\x07version\x18\x01 \x01(\x0b\x32\x14.voldemort.Versioned\x12\x1f\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x10.voldemort.Error\"M\n\x15UpdateMetadataRequest\x12\x0b\n\x03key\x18\x01 \x02(\x0c\x12\'\n\tversioned\x18\x02 \x02(\x0b\x32\x14.voldemort.Versioned\"9\n\x16UpdateMetadataResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"7\n\tFileEntry\x12\x11\n\tfile_name\x18\x01 \x02(\t\x12\x17\n\x0f\x66ile_size_bytes\x18\x02 \x02(\x03\"F\n\x0ePartitionEntry\x12\x0b\n\x03key\x18\x01 \x02(\x0c\x12\'\n\tversioned\x18\x02 \x02(\x0b\x32\x14.voldemort.Versioned\"\x8e\x01\n\x1dUpdatePartitionEntriesRequest\x12\r\n\x05store\x18\x01 \x02(\t\x12\x32\n\x0fpartition_entry\x18\x02 \x02(\x0b\x32\x19.voldemort.PartitionEntry\x12*\n\x06\x66ilter\x18\x03 \x01(\x0b\x32\x1a.voldemort.VoldemortFilter\"A\n\x1eUpdatePartitionEntriesResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"-\n\x0fVoldemortFilter\x12\x0c\n\x04name\x18\x01 \x02(\t\x12\x0c\n\x04\x64\x61ta\x18\x02 \x02(\x0c\"\xaf\x01\n\x18UpdateSlopEntriesRequest\x12\r\n\x05store\x18\x01 \x02(\t\x12\x0b\n\x03key\x18\x02 \x02(\x0c\x12\'\n\x07version\x18\x03 \x02(\x0b\x32\x16.voldemort.VectorClock\x12,\n\x0crequest_type\x18\x04 \x02(\x0e\x32\x16.voldemort.RequestType\x12\r\n\x05value\x18\x05 \x01(\x0c\x12\x11\n\ttransform\x18\x06 \x01(\x0c\"<\n\x19UpdateSlopEntriesResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"d\n\x1a\x46\x65tchPartitionFilesRequest\x12\r\n\x05store\x18\x01 \x02(\t\x12\x37\n\x14replica_to_partition\x18\x02 \x03(\x0b\x32\x19.voldemort.PartitionTuple\"\xd7\x01\n\x1c\x46\x65tchPartitionEntriesRequest\x12\x37\n\x14replica_to_partition\x18\x01 \x03(\x0b\x32\x19.voldemort.PartitionTuple\x12\r\n\x05store\x18\x02 \x02(\t\x12*\n\x06\x66ilter\x18\x03 \x01(\x0b\x32\x1a.voldemort.VoldemortFilter\x12\x14\n\x0c\x66\x65tch_values\x18\x04 \x01(\x08\x12\x14\n\x0cskip_records\x18\x05 \x01(\x03\x12\x17\n\x0finitial_cluster\x18\x06 \x01(\t\"\x81\x01\n\x1d\x46\x65tchPartitionEntriesResponse\x12\x32\n\x0fpartition_entry\x18\x01 \x01(\x0b\x32\x19.voldemort.PartitionEntry\x12\x0b\n\x03key\x18\x02 \x01(\x0c\x12\x1f\n\x05\x65rror\x18\x03 \x01(\x0b\x32\x10.voldemort.Error\"\xac\x01\n\x1d\x44\x65letePartitionEntriesRequest\x12\r\n\x05store\x18\x01 \x02(\t\x12\x37\n\x14replica_to_partition\x18\x02 \x03(\x0b\x32\x19.voldemort.PartitionTuple\x12*\n\x06\x66ilter\x18\x03 \x01(\x0b\x32\x1a.voldemort.VoldemortFilter\x12\x17\n\x0finitial_cluster\x18\x04 \x01(\t\"P\n\x1e\x44\x65letePartitionEntriesResponse\x12\r\n\x05\x63ount\x18\x01 \x01(\x03\x12\x1f\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x10.voldemort.Error\"\xcf\x01\n\x1dInitiateFetchAndUpdateRequest\x12\x0f\n\x07node_id\x18\x01 \x02(\x05\x12\r\n\x05store\x18\x02 \x02(\t\x12*\n\x06\x66ilter\x18\x03 \x01(\x0b\x32\x1a.voldemort.VoldemortFilter\x12\x37\n\x14replica_to_partition\x18\x04 \x03(\x0b\x32\x19.voldemort.PartitionTuple\x12\x17\n\x0finitial_cluster\x18\x05 \x01(\t\x12\x10\n\x08optimize\x18\x06 \x01(\x08\"1\n\x1b\x41syncOperationStatusRequest\x12\x12\n\nrequest_id\x18\x01 \x02(\x05\"/\n\x19\x41syncOperationStopRequest\x12\x12\n\nrequest_id\x18\x01 \x02(\x05\"=\n\x1a\x41syncOperationStopResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"2\n\x19\x41syncOperationListRequest\x12\x15\n\rshow_complete\x18\x02 \x02(\x08\"R\n\x1a\x41syncOperationListResponse\x12\x13\n\x0brequest_ids\x18\x01 \x03(\x05\x12\x1f\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x10.voldemort.Error\":\n\x0ePartitionTuple\x12\x14\n\x0creplica_type\x18\x01 \x02(\x05\x12\x12\n\npartitions\x18\x02 \x03(\x05\"e\n\x16PerStorePartitionTuple\x12\x12\n\nstore_name\x18\x01 \x02(\t\x12\x37\n\x14replica_to_partition\x18\x02 \x03(\x0b\x32\x19.voldemort.PartitionTuple\"\xf8\x01\n\x19RebalancePartitionInfoMap\x12\x12\n\nstealer_id\x18\x01 \x02(\x05\x12\x10\n\x08\x64onor_id\x18\x02 \x02(\x05\x12\x0f\n\x07\x61ttempt\x18\x03 \x02(\x05\x12\x43\n\x18replica_to_add_partition\x18\x04 \x03(\x0b\x32!.voldemort.PerStorePartitionTuple\x12\x46\n\x1breplica_to_delete_partition\x18\x05 \x03(\x0b\x32!.voldemort.PerStorePartitionTuple\x12\x17\n\x0finitial_cluster\x18\x06 \x02(\t\"f\n\x1cInitiateRebalanceNodeRequest\x12\x46\n\x18rebalance_partition_info\x18\x01 \x02(\x0b\x32$.voldemort.RebalancePartitionInfoMap\"\x8a\x01\n\x1c\x41syncOperationStatusResponse\x12\x12\n\nrequest_id\x18\x01 \x01(\x05\x12\x13\n\x0b\x64\x65scription\x18\x02 \x01(\t\x12\x0e\n\x06status\x18\x03 \x01(\t\x12\x10\n\x08\x63omplete\x18\x04 \x01(\x08\x12\x1f\n\x05\x65rror\x18\x05 \x01(\x0b\x32\x10.voldemort.Error\"\'\n\x16TruncateEntriesRequest\x12\r\n\x05store\x18\x01 \x02(\t\":\n\x17TruncateEntriesResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"*\n\x0f\x41\x64\x64StoreRequest\x12\x17\n\x0fstoreDefinition\x18\x01 \x02(\t\"3\n\x10\x41\x64\x64StoreResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"\'\n\x12\x44\x65leteStoreRequest\x12\x11\n\tstoreName\x18\x01 \x02(\t\"6\n\x13\x44\x65leteStoreResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"P\n\x11\x46\x65tchStoreRequest\x12\x12\n\nstore_name\x18\x01 \x02(\t\x12\x11\n\tstore_dir\x18\x02 \x02(\t\x12\x14\n\x0cpush_version\x18\x03 \x01(\x03\"9\n\x10SwapStoreRequest\x12\x12\n\nstore_name\x18\x01 \x02(\t\x12\x11\n\tstore_dir\x18\x02 \x02(\t\"P\n\x11SwapStoreResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\x12\x1a\n\x12previous_store_dir\x18\x02 \x01(\t\"@\n\x14RollbackStoreRequest\x12\x12\n\nstore_name\x18\x01 \x02(\t\x12\x14\n\x0cpush_version\x18\x02 \x02(\x03\"8\n\x15RollbackStoreResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\",\n\x16RebalanceRepairRequest\x12\x12\n\nstore_name\x18\x01 \x01(\t\":\n\x17RebalanceRepairResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"=\n\x14ROStoreVersionDirMap\x12\x12\n\nstore_name\x18\x01 \x02(\t\x12\x11\n\tstore_dir\x18\x02 \x02(\t\"/\n\x19GetROMaxVersionDirRequest\x12\x12\n\nstore_name\x18\x01 \x03(\t\"y\n\x1aGetROMaxVersionDirResponse\x12:\n\x11ro_store_versions\x18\x01 \x03(\x0b\x32\x1f.voldemort.ROStoreVersionDirMap\x12\x1f\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x10.voldemort.Error\"3\n\x1dGetROCurrentVersionDirRequest\x12\x12\n\nstore_name\x18\x01 \x03(\t\"}\n\x1eGetROCurrentVersionDirResponse\x12:\n\x11ro_store_versions\x18\x01 \x03(\x0b\x32\x1f.voldemort.ROStoreVersionDirMap\x12\x1f\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x10.voldemort.Error\"/\n\x19GetROStorageFormatRequest\x12\x12\n\nstore_name\x18\x01 \x03(\t\"y\n\x1aGetROStorageFormatResponse\x12:\n\x11ro_store_versions\x18\x01 \x03(\x0b\x32\x1f.voldemort.ROStoreVersionDirMap\x12\x1f\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x10.voldemort.Error\"@\n\x17\x46\x61iledFetchStoreRequest\x12\x12\n\nstore_name\x18\x01 \x02(\t\x12\x11\n\tstore_dir\x18\x02 \x02(\t\";\n\x18\x46\x61iledFetchStoreResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"\xe6\x01\n\x1bRebalanceStateChangeRequest\x12K\n\x1drebalance_partition_info_list\x18\x01 \x03(\x0b\x32$.voldemort.RebalancePartitionInfoMap\x12\x16\n\x0e\x63luster_string\x18\x02 \x02(\t\x12\x0f\n\x07swap_ro\x18\x03 \x02(\x08\x12\x1f\n\x17\x63hange_cluster_metadata\x18\x04 \x02(\x08\x12\x1e\n\x16\x63hange_rebalance_state\x18\x05 \x02(\x08\x12\x10\n\x08rollback\x18\x06 \x02(\x08\"?\n\x1cRebalanceStateChangeResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"\xdf\x0c\n\x15VoldemortAdminRequest\x12)\n\x04type\x18\x01 \x02(\x0e\x32\x1b.voldemort.AdminRequestType\x12\x33\n\x0cget_metadata\x18\x02 \x01(\x0b\x32\x1d.voldemort.GetMetadataRequest\x12\x39\n\x0fupdate_metadata\x18\x03 \x01(\x0b\x32 .voldemort.UpdateMetadataRequest\x12J\n\x18update_partition_entries\x18\x04 \x01(\x0b\x32(.voldemort.UpdatePartitionEntriesRequest\x12H\n\x17\x66\x65tch_partition_entries\x18\x05 \x01(\x0b\x32\'.voldemort.FetchPartitionEntriesRequest\x12J\n\x18\x64\x65lete_partition_entries\x18\x06 \x01(\x0b\x32(.voldemort.DeletePartitionEntriesRequest\x12K\n\x19initiate_fetch_and_update\x18\x07 \x01(\x0b\x32(.voldemort.InitiateFetchAndUpdateRequest\x12\x46\n\x16\x61sync_operation_status\x18\x08 \x01(\x0b\x32&.voldemort.AsyncOperationStatusRequest\x12H\n\x17initiate_rebalance_node\x18\t \x01(\x0b\x32\'.voldemort.InitiateRebalanceNodeRequest\x12\x42\n\x14\x61sync_operation_stop\x18\n \x01(\x0b\x32$.voldemort.AsyncOperationStopRequest\x12\x42\n\x14\x61sync_operation_list\x18\x0b \x01(\x0b\x32$.voldemort.AsyncOperationListRequest\x12;\n\x10truncate_entries\x18\x0c \x01(\x0b\x32!.voldemort.TruncateEntriesRequest\x12-\n\tadd_store\x18\r \x01(\x0b\x32\x1a.voldemort.AddStoreRequest\x12\x33\n\x0c\x64\x65lete_store\x18\x0e \x01(\x0b\x32\x1d.voldemort.DeleteStoreRequest\x12\x31\n\x0b\x66\x65tch_store\x18\x0f \x01(\x0b\x32\x1c.voldemort.FetchStoreRequest\x12/\n\nswap_store\x18\x10 \x01(\x0b\x32\x1b.voldemort.SwapStoreRequest\x12\x37\n\x0erollback_store\x18\x11 \x01(\x0b\x32\x1f.voldemort.RollbackStoreRequest\x12\x44\n\x16get_ro_max_version_dir\x18\x12 \x01(\x0b\x32$.voldemort.GetROMaxVersionDirRequest\x12L\n\x1aget_ro_current_version_dir\x18\x13 \x01(\x0b\x32(.voldemort.GetROCurrentVersionDirRequest\x12\x44\n\x15\x66\x65tch_partition_files\x18\x14 \x01(\x0b\x32%.voldemort.FetchPartitionFilesRequest\x12@\n\x13update_slop_entries\x18\x16 \x01(\x0b\x32#.voldemort.UpdateSlopEntriesRequest\x12>\n\x12\x66\x61iled_fetch_store\x18\x18 \x01(\x0b\x32\".voldemort.FailedFetchStoreRequest\x12\x43\n\x15get_ro_storage_format\x18\x19 \x01(\x0b\x32$.voldemort.GetROStorageFormatRequest\x12\x46\n\x16rebalance_state_change\x18\x1a \x01(\x0b\x32&.voldemort.RebalanceStateChangeRequest\x12;\n\x10rebalance_repair\x18\x1b \x01(\x0b\x32!.voldemort.RebalanceRepairRequest*\xdf\x04\n\x10\x41\x64minRequestType\x12\x10\n\x0cGET_METADATA\x10\x00\x12\x13\n\x0fUPDATE_METADATA\x10\x01\x12\x1c\n\x18UPDATE_PARTITION_ENTRIES\x10\x02\x12\x1b\n\x17\x46\x45TCH_PARTITION_ENTRIES\x10\x03\x12\x1c\n\x18\x44\x45LETE_PARTITION_ENTRIES\x10\x04\x12\x1d\n\x19INITIATE_FETCH_AND_UPDATE\x10\x05\x12\x1a\n\x16\x41SYNC_OPERATION_STATUS\x10\x06\x12\x1b\n\x17INITIATE_REBALANCE_NODE\x10\x07\x12\x18\n\x14\x41SYNC_OPERATION_STOP\x10\x08\x12\x18\n\x14\x41SYNC_OPERATION_LIST\x10\t\x12\x14\n\x10TRUNCATE_ENTRIES\x10\n\x12\r\n\tADD_STORE\x10\x0b\x12\x10\n\x0c\x44\x45LETE_STORE\x10\x0c\x12\x0f\n\x0b\x46\x45TCH_STORE\x10\r\x12\x0e\n\nSWAP_STORE\x10\x0e\x12\x12\n\x0eROLLBACK_STORE\x10\x0f\x12\x1a\n\x16GET_RO_MAX_VERSION_DIR\x10\x10\x12\x1e\n\x1aGET_RO_CURRENT_VERSION_DIR\x10\x11\x12\x19\n\x15\x46\x45TCH_PARTITION_FILES\x10\x12\x12\x17\n\x13UPDATE_SLOP_ENTRIES\x10\x14\x12\x16\n\x12\x46\x41ILED_FETCH_STORE\x10\x16\x12\x19\n\x15GET_RO_STORAGE_FORMAT\x10\x17\x12\x1a\n\x16REBALANCE_STATE_CHANGE\x10\x18\x12\x14\n\x10REBALANCE_REPAIR\x10\x19\x42-\n\x1cvoldemort.client.protocol.pbB\x0bVAdminProtoH\x01')
+ serialized_pb='\n\x15voldemort-admin.proto\x12\tvoldemort\x1a\x16voldemort-client.proto\"!\n\x12GetMetadataRequest\x12\x0b\n\x03key\x18\x01 \x02(\x0c\"]\n\x13GetMetadataResponse\x12%\n\x07version\x18\x01 \x01(\x0b\x32\x14.voldemort.Versioned\x12\x1f\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x10.voldemort.Error\"M\n\x15UpdateMetadataRequest\x12\x0b\n\x03key\x18\x01 \x02(\x0c\x12\'\n\tversioned\x18\x02 \x02(\x0b\x32\x14.voldemort.Versioned\"9\n\x16UpdateMetadataResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"7\n\tFileEntry\x12\x11\n\tfile_name\x18\x01 \x02(\t\x12\x17\n\x0f\x66ile_size_bytes\x18\x02 \x02(\x03\"F\n\x0ePartitionEntry\x12\x0b\n\x03key\x18\x01 \x02(\x0c\x12\'\n\tversioned\x18\x02 \x02(\x0b\x32\x14.voldemort.Versioned\"\x8e\x01\n\x1dUpdatePartitionEntriesRequest\x12\r\n\x05store\x18\x01 \x02(\t\x12\x32\n\x0fpartition_entry\x18\x02 \x02(\x0b\x32\x19.voldemort.PartitionEntry\x12*\n\x06\x66ilter\x18\x03 \x01(\x0b\x32\x1a.voldemort.VoldemortFilter\"A\n\x1eUpdatePartitionEntriesResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"-\n\x0fVoldemortFilter\x12\x0c\n\x04name\x18\x01 \x02(\t\x12\x0c\n\x04\x64\x61ta\x18\x02 \x02(\x0c\"\xaf\x01\n\x18UpdateSlopEntriesRequest\x12\r\n\x05store\x18\x01 \x02(\t\x12\x0b\n\x03key\x18\x02 \x02(\x0c\x12\'\n\x07version\x18\x03 \x02(\x0b\x32\x16.voldemort.VectorClock\x12,\n\x0crequest_type\x18\x04 \x02(\x0e\x32\x16.voldemort.RequestType\x12\r\n\x05value\x18\x05 \x01(\x0c\x12\x11\n\ttransform\x18\x06 \x01(\x0c\"<\n\x19UpdateSlopEntriesResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"d\n\x1a\x46\x65tchPartitionFilesRequest\x12\r\n\x05store\x18\x01 \x02(\t\x12\x37\n\x14replica_to_partition\x18\x02 \x03(\x0b\x32\x19.voldemort.PartitionTuple\"\xd7\x01\n\x1c\x46\x65tchPartitionEntriesRequest\x12\x37\n\x14replica_to_partition\x18\x01 \x03(\x0b\x32\x19.voldemort.PartitionTuple\x12\r\n\x05store\x18\x02 \x02(\t\x12*\n\x06\x66ilter\x18\x03 \x01(\x0b\x32\x1a.voldemort.VoldemortFilter\x12\x14\n\x0c\x66\x65tch_values\x18\x04 \x01(\x08\x12\x14\n\x0cskip_records\x18\x05 \x01(\x03\x12\x17\n\x0finitial_cluster\x18\x06 \x01(\t\"\x81\x01\n\x1d\x46\x65tchPartitionEntriesResponse\x12\x32\n\x0fpartition_entry\x18\x01 \x01(\x0b\x32\x19.voldemort.PartitionEntry\x12\x0b\n\x03key\x18\x02 \x01(\x0c\x12\x1f\n\x05\x65rror\x18\x03 \x01(\x0b\x32\x10.voldemort.Error\"\xac\x01\n\x1d\x44\x65letePartitionEntriesRequest\x12\r\n\x05store\x18\x01 \x02(\t\x12\x37\n\x14replica_to_partition\x18\x02 \x03(\x0b\x32\x19.voldemort.PartitionTuple\x12*\n\x06\x66ilter\x18\x03 \x01(\x0b\x32\x1a.voldemort.VoldemortFilter\x12\x17\n\x0finitial_cluster\x18\x04 \x01(\t\"P\n\x1e\x44\x65letePartitionEntriesResponse\x12\r\n\x05\x63ount\x18\x01 \x01(\x03\x12\x1f\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x10.voldemort.Error\"\xcf\x01\n\x1dInitiateFetchAndUpdateRequest\x12\x0f\n\x07node_id\x18\x01 \x02(\x05\x12\r\n\x05store\x18\x02 \x02(\t\x12*\n\x06\x66ilter\x18\x03 \x01(\x0b\x32\x1a.voldemort.VoldemortFilter\x12\x37\n\x14replica_to_partition\x18\x04 \x03(\x0b\x32\x19.voldemort.PartitionTuple\x12\x17\n\x0finitial_cluster\x18\x05 \x01(\t\x12\x10\n\x08optimize\x18\x06 \x01(\x08\"1\n\x1b\x41syncOperationStatusRequest\x12\x12\n\nrequest_id\x18\x01 \x02(\x05\"/\n\x19\x41syncOperationStopRequest\x12\x12\n\nrequest_id\x18\x01 \x02(\x05\"=\n\x1a\x41syncOperationStopResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"2\n\x19\x41syncOperationListRequest\x12\x15\n\rshow_complete\x18\x02 \x02(\x08\"R\n\x1a\x41syncOperationListResponse\x12\x13\n\x0brequest_ids\x18\x01 \x03(\x05\x12\x1f\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x10.voldemort.Error\":\n\x0ePartitionTuple\x12\x14\n\x0creplica_type\x18\x01 \x02(\x05\x12\x12\n\npartitions\x18\x02 \x03(\x05\"e\n\x16PerStorePartitionTuple\x12\x12\n\nstore_name\x18\x01 \x02(\t\x12\x37\n\x14replica_to_partition\x18\x02 \x03(\x0b\x32\x19.voldemort.PartitionTuple\"\xf8\x01\n\x19RebalancePartitionInfoMap\x12\x12\n\nstealer_id\x18\x01 \x02(\x05\x12\x10\n\x08\x64onor_id\x18\x02 \x02(\x05\x12\x0f\n\x07\x61ttempt\x18\x03 \x02(\x05\x12\x43\n\x18replica_to_add_partition\x18\x04 \x03(\x0b\x32!.voldemort.PerStorePartitionTuple\x12\x46\n\x1breplica_to_delete_partition\x18\x05 \x03(\x0b\x32!.voldemort.PerStorePartitionTuple\x12\x17\n\x0finitial_cluster\x18\x06 \x02(\t\"f\n\x1cInitiateRebalanceNodeRequest\x12\x46\n\x18rebalance_partition_info\x18\x01 \x02(\x0b\x32$.voldemort.RebalancePartitionInfoMap\"\x8a\x01\n\x1c\x41syncOperationStatusResponse\x12\x12\n\nrequest_id\x18\x01 \x01(\x05\x12\x13\n\x0b\x64\x65scription\x18\x02 \x01(\t\x12\x0e\n\x06status\x18\x03 \x01(\t\x12\x10\n\x08\x63omplete\x18\x04 \x01(\x08\x12\x1f\n\x05\x65rror\x18\x05 \x01(\x0b\x32\x10.voldemort.Error\"\'\n\x16TruncateEntriesRequest\x12\r\n\x05store\x18\x01 \x02(\t\":\n\x17TruncateEntriesResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"*\n\x0f\x41\x64\x64StoreRequest\x12\x17\n\x0fstoreDefinition\x18\x01 \x02(\t\"3\n\x10\x41\x64\x64StoreResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"\'\n\x12\x44\x65leteStoreRequest\x12\x11\n\tstoreName\x18\x01 \x02(\t\"6\n\x13\x44\x65leteStoreResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"P\n\x11\x46\x65tchStoreRequest\x12\x12\n\nstore_name\x18\x01 \x02(\t\x12\x11\n\tstore_dir\x18\x02 \x02(\t\x12\x14\n\x0cpush_version\x18\x03 \x01(\x03\"9\n\x10SwapStoreRequest\x12\x12\n\nstore_name\x18\x01 \x02(\t\x12\x11\n\tstore_dir\x18\x02 \x02(\t\"P\n\x11SwapStoreResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\x12\x1a\n\x12previous_store_dir\x18\x02 \x01(\t\"@\n\x14RollbackStoreRequest\x12\x12\n\nstore_name\x18\x01 \x02(\t\x12\x14\n\x0cpush_version\x18\x02 \x02(\x03\"8\n\x15RollbackStoreResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"&\n\x10RepairJobRequest\x12\x12\n\nstore_name\x18\x01 \x01(\t\"4\n\x11RepairJobResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"=\n\x14ROStoreVersionDirMap\x12\x12\n\nstore_name\x18\x01 \x02(\t\x12\x11\n\tstore_dir\x18\x02 \x02(\t\"/\n\x19GetROMaxVersionDirRequest\x12\x12\n\nstore_name\x18\x01 \x03(\t\"y\n\x1aGetROMaxVersionDirResponse\x12:\n\x11ro_store_versions\x18\x01 \x03(\x0b\x32\x1f.voldemort.ROStoreVersionDirMap\x12\x1f\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x10.voldemort.Error\"3\n\x1dGetROCurrentVersionDirRequest\x12\x12\n\nstore_name\x18\x01 \x03(\t\"}\n\x1eGetROCurrentVersionDirResponse\x12:\n\x11ro_store_versions\x18\x01 \x03(\x0b\x32\x1f.voldemort.ROStoreVersionDirMap\x12\x1f\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x10.voldemort.Error\"/\n\x19GetROStorageFormatRequest\x12\x12\n\nstore_name\x18\x01 \x03(\t\"y\n\x1aGetROStorageFormatResponse\x12:\n\x11ro_store_versions\x18\x01 \x03(\x0b\x32\x1f.voldemort.ROStoreVersionDirMap\x12\x1f\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x10.voldemort.Error\"@\n\x17\x46\x61iledFetchStoreRequest\x12\x12\n\nstore_name\x18\x01 \x02(\t\x12\x11\n\tstore_dir\x18\x02 \x02(\t\";\n\x18\x46\x61iledFetchStoreResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"\xe6\x01\n\x1bRebalanceStateChangeRequest\x12K\n\x1drebalance_partition_info_list\x18\x01 \x03(\x0b\x32$.voldemort.RebalancePartitionInfoMap\x12\x16\n\x0e\x63luster_string\x18\x02 \x02(\t\x12\x0f\n\x07swap_ro\x18\x03 \x02(\x08\x12\x1f\n\x17\x63hange_cluster_metadata\x18\x04 \x02(\x08\x12\x1e\n\x16\x63hange_rebalance_state\x18\x05 \x02(\x08\x12\x10\n\x08rollback\x18\x06 \x02(\x08\"?\n\x1cRebalanceStateChangeResponse\x12\x1f\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x10.voldemort.Error\"\xd3\x0c\n\x15VoldemortAdminRequest\x12)\n\x04type\x18\x01 \x02(\x0e\x32\x1b.voldemort.AdminRequestType\x12\x33\n\x0cget_metadata\x18\x02 \x01(\x0b\x32\x1d.voldemort.GetMetadataRequest\x12\x39\n\x0fupdate_metadata\x18\x03 \x01(\x0b\x32 .voldemort.UpdateMetadataRequest\x12J\n\x18update_partition_entries\x18\x04 \x01(\x0b\x32(.voldemort.UpdatePartitionEntriesRequest\x12H\n\x17\x66\x65tch_partition_entries\x18\x05 \x01(\x0b\x32\'.voldemort.FetchPartitionEntriesRequest\x12J\n\x18\x64\x65lete_partition_entries\x18\x06 \x01(\x0b\x32(.voldemort.DeletePartitionEntriesRequest\x12K\n\x19initiate_fetch_and_update\x18\x07 \x01(\x0b\x32(.voldemort.InitiateFetchAndUpdateRequest\x12\x46\n\x16\x61sync_operation_status\x18\x08 \x01(\x0b\x32&.voldemort.AsyncOperationStatusRequest\x12H\n\x17initiate_rebalance_node\x18\t \x01(\x0b\x32\'.voldemort.InitiateRebalanceNodeRequest\x12\x42\n\x14\x61sync_operation_stop\x18\n \x01(\x0b\x32$.voldemort.AsyncOperationStopRequest\x12\x42\n\x14\x61sync_operation_list\x18\x0b \x01(\x0b\x32$.voldemort.AsyncOperationListRequest\x12;\n\x10truncate_entries\x18\x0c \x01(\x0b\x32!.voldemort.TruncateEntriesRequest\x12-\n\tadd_store\x18\r \x01(\x0b\x32\x1a.voldemort.AddStoreRequest\x12\x33\n\x0c\x64\x65lete_store\x18\x0e \x01(\x0b\x32\x1d.voldemort.DeleteStoreRequest\x12\x31\n\x0b\x66\x65tch_store\x18\x0f \x01(\x0b\x32\x1c.voldemort.FetchStoreRequest\x12/\n\nswap_store\x18\x10 \x01(\x0b\x32\x1b.voldemort.SwapStoreRequest\x12\x37\n\x0erollback_store\x18\x11 \x01(\x0b\x32\x1f.voldemort.RollbackStoreRequest\x12\x44\n\x16get_ro_max_version_dir\x18\x12 \x01(\x0b\x32$.voldemort.GetROMaxVersionDirRequest\x12L\n\x1aget_ro_current_version_dir\x18\x13 \x01(\x0b\x32(.voldemort.GetROCurrentVersionDirRequest\x12\x44\n\x15\x66\x65tch_partition_files\x18\x14 \x01(\x0b\x32%.voldemort.FetchPartitionFilesRequest\x12@\n\x13update_slop_entries\x18\x16 \x01(\x0b\x32#.voldemort.UpdateSlopEntriesRequest\x12>\n\x12\x66\x61iled_fetch_store\x18\x18 \x01(\x0b\x32\".voldemort.FailedFetchStoreRequest\x12\x43\n\x15get_ro_storage_format\x18\x19 \x01(\x0b\x32$.voldemort.GetROStorageFormatRequest\x12\x46\n\x16rebalance_state_change\x18\x1a \x01(\x0b\x32&.voldemort.RebalanceStateChangeRequest\x12/\n\nrepair_job\x18\x1b \x01(\x0b\x32\x1b.voldemort.RepairJobRequest*\xd9\x04\n\x10\x41\x64minRequestType\x12\x10\n\x0cGET_METADATA\x10\x00\x12\x13\n\x0fUPDATE_METADATA\x10\x01\x12\x1c\n\x18UPDATE_PARTITION_ENTRIES\x10\x02\x12\x1b\n\x17\x46\x45TCH_PARTITION_ENTRIES\x10\x03\x12\x1c\n\x18\x44\x45LETE_PARTITION_ENTRIES\x10\x04\x12\x1d\n\x19INITIATE_FETCH_AND_UPDATE\x10\x05\x12\x1a\n\x16\x41SYNC_OPERATION_STATUS\x10\x06\x12\x1b\n\x17INITIATE_REBALANCE_NODE\x10\x07\x12\x18\n\x14\x41SYNC_OPERATION_STOP\x10\x08\x12\x18\n\x14\x41SYNC_OPERATION_LIST\x10\t\x12\x14\n\x10TRUNCATE_ENTRIES\x10\n\x12\r\n\tADD_STORE\x10\x0b\x12\x10\n\x0c\x44\x45LETE_STORE\x10\x0c\x12\x0f\n\x0b\x46\x45TCH_STORE\x10\r\x12\x0e\n\nSWAP_STORE\x10\x0e\x12\x12\n\x0eROLLBACK_STORE\x10\x0f\x12\x1a\n\x16GET_RO_MAX_VERSION_DIR\x10\x10\x12\x1e\n\x1aGET_RO_CURRENT_VERSION_DIR\x10\x11\x12\x19\n\x15\x46\x45TCH_PARTITION_FILES\x10\x12\x12\x17\n\x13UPDATE_SLOP_ENTRIES\x10\x14\x12\x16\n\x12\x46\x41ILED_FETCH_STORE\x10\x16\x12\x19\n\x15GET_RO_STORAGE_FORMAT\x10\x17\x12\x1a\n\x16REBALANCE_STATE_CHANGE\x10\x18\x12\x0e\n\nREPAIR_JOB\x10\x19\x42-\n\x1cvoldemort.client.protocol.pbB\x0bVAdminProtoH\x01')
_ADMINREQUESTTYPE = descriptor.EnumDescriptor(
name='AdminRequestType',
@@ -111,14 +111,14 @@
options=None,
type=None),
descriptor.EnumValueDescriptor(
- name='REBALANCE_REPAIR', index=23, number=25,
+ name='REPAIR_JOB', index=23, number=25,
options=None,
type=None),
],
containing_type=None,
options=None,
- serialized_start=6228,
- serialized_end=6835,
+ serialized_start=6204,
+ serialized_end=6805,
)
@@ -145,7 +145,7 @@
FAILED_FETCH_STORE = 22
GET_RO_STORAGE_FORMAT = 23
REBALANCE_STATE_CHANGE = 24
-REBALANCE_REPAIR = 25
+REPAIR_JOB = 25
@@ -1535,15 +1535,15 @@
)
-_REBALANCEREPAIRREQUEST = descriptor.Descriptor(
- name='RebalanceRepairRequest',
- full_name='voldemort.RebalanceRepairRequest',
+_REPAIRJOBREQUEST = descriptor.Descriptor(
+ name='RepairJobRequest',
+ full_name='voldemort.RepairJobRequest',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
descriptor.FieldDescriptor(
- name='store_name', full_name='voldemort.RebalanceRepairRequest.store_name', index=0,
+ name='store_name', full_name='voldemort.RepairJobRequest.store_name', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=unicode("", "utf-8"),
message_type=None, enum_type=None, containing_type=None,
@@ -1559,19 +1559,19 @@
is_extendable=False,
extension_ranges=[],
serialized_start=3475,
- serialized_end=3519,
+ serialized_end=3513,
)
-_REBALANCEREPAIRRESPONSE = descriptor.Descriptor(
- name='RebalanceRepairResponse',
- full_name='voldemort.RebalanceRepairResponse',
+_REPAIRJOBRESPONSE = descriptor.Descriptor(
+ name='RepairJobResponse',
+ full_name='voldemort.RepairJobResponse',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
descriptor.FieldDescriptor(
- name='error', full_name='voldemort.RebalanceRepairResponse.error', index=0,
+ name='error', full_name='voldemort.RepairJobResponse.error', index=0,
number=1, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
@@ -1586,8 +1586,8 @@
options=None,
is_extendable=False,
extension_ranges=[],
- serialized_start=3521,
- serialized_end=3579,
+ serialized_start=3515,
+ serialized_end=3567,
)
@@ -1621,8 +1621,8 @@
options=None,
is_extendable=False,
extension_ranges=[],
- serialized_start=3581,
- serialized_end=3642,
+ serialized_start=3569,
+ serialized_end=3630,
)
@@ -1649,8 +1649,8 @@
options=None,
is_extendable=False,
extension_ranges=[],
- serialized_start=3644,
- serialized_end=3691,
+ serialized_start=3632,
+ serialized_end=3679,
)
@@ -1684,8 +1684,8 @@
options=None,
is_extendable=False,
extension_ranges=[],
- serialized_start=3693,
- serialized_end=3814,
+ serialized_start=3681,
+ serialized_end=3802,
)
@@ -1712,8 +1712,8 @@
options=None,
is_extendable=False,
extension_ranges=[],
- serialized_start=3816,
- serialized_end=3867,
+ serialized_start=3804,
+ serialized_end=3855,
)
@@ -1747,8 +1747,8 @@
options=None,
is_extendable=False,
extension_ranges=[],
- serialized_start=3869,
- serialized_end=3994,
+ serialized_start=3857,
+ serialized_end=3982,
)
@@ -1775,8 +1775,8 @@
options=None,
is_extendable=False,
extension_ranges=[],
- serialized_start=3996,
- serialized_end=4043,
+ serialized_start=3984,
+ serialized_end=4031,
)
@@ -1810,8 +1810,8 @@
options=None,
is_extendable=False,
extension_ranges=[],
- serialized_start=4045,
- serialized_end=4166,
+ serialized_start=4033,
+ serialized_end=4154,
)
@@ -1845,8 +1845,8 @@
options=None,
is_extendable=False,
extension_ranges=[],
- serialized_start=4168,
- serialized_end=4232,
+ serialized_start=4156,
+ serialized_end=4220,
)
@@ -1873,8 +1873,8 @@
options=None,
is_extendable=False,
extension_ranges=[],
- serialized_start=4234,
- serialized_end=4293,
+ serialized_start=4222,
+ serialized_end=4281,
)
@@ -1936,8 +1936,8 @@
options=None,
is_extendable=False,
extension_ranges=[],
- serialized_start=4296,
- serialized_end=4526,
+ serialized_start=4284,
+ serialized_end=4514,
)
@@ -1964,8 +1964,8 @@
options=None,
is_extendable=False,
extension_ranges=[],
- serialized_start=4528,
- serialized_end=4591,
+ serialized_start=4516,
+ serialized_end=4579,
)
@@ -2145,7 +2145,7 @@
is_extension=False, extension_scope=None,
options=None),
descriptor.FieldDescriptor(
- name='rebalance_repair', full_name='voldemort.VoldemortAdminRequest.rebalance_repair', index=24,
+ name='repair_job', full_name='voldemort.VoldemortAdminRequest.repair_job', index=24,
number=27, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
@@ -2160,8 +2160,8 @@
options=None,
is_extendable=False,
extension_ranges=[],
- serialized_start=4594,
- serialized_end=6225,
+ serialized_start=4582,
+ serialized_end=6201,
)
import voldemort_client_pb2
@@ -2199,7 +2199,7 @@
_DELETESTORERESPONSE.fields_by_name['error'].message_type = voldemort_client_pb2._ERROR
_SWAPSTORERESPONSE.fields_by_name['error'].message_type = voldemort_client_pb2._ERROR
_ROLLBACKSTORERESPONSE.fields_by_name['error'].message_type = voldemort_client_pb2._ERROR
-_REBALANCEREPAIRRESPONSE.fields_by_name['error'].message_type = voldemort_client_pb2._ERROR
+_REPAIRJOBRESPONSE.fields_by_name['error'].message_type = voldemort_client_pb2._ERROR
_GETROMAXVERSIONDIRRESPONSE.fields_by_name['ro_store_versions'].message_type = _ROSTOREVERSIONDIRMAP
_GETROMAXVERSIONDIRRESPONSE.fields_by_name['error'].message_type = voldemort_client_pb2._ERROR
_GETROCURRENTVERSIONDIRRESPONSE.fields_by_name['ro_store_versions'].message_type = _ROSTOREVERSIONDIRMAP
@@ -2233,7 +2233,7 @@
_VOLDEMORTADMINREQUEST.fields_by_name['failed_fetch_store'].message_type = _FAILEDFETCHSTOREREQUEST
_VOLDEMORTADMINREQUEST.fields_by_name['get_ro_storage_format'].message_type = _GETROSTORAGEFORMATREQUEST
_VOLDEMORTADMINREQUEST.fields_by_name['rebalance_state_change'].message_type = _REBALANCESTATECHANGEREQUEST
-_VOLDEMORTADMINREQUEST.fields_by_name['rebalance_repair'].message_type = _REBALANCEREPAIRREQUEST
+_VOLDEMORTADMINREQUEST.fields_by_name['repair_job'].message_type = _REPAIRJOBREQUEST
class GetMetadataRequest(message.Message):
__metaclass__ = reflection.GeneratedProtocolMessageType
@@ -2463,17 +2463,17 @@ class RollbackStoreResponse(message.Message):
# @@protoc_insertion_point(class_scope:voldemort.RollbackStoreResponse)
-class RebalanceRepairRequest(message.Message):
+class RepairJobRequest(message.Message):
__metaclass__ = reflection.GeneratedProtocolMessageType
- DESCRIPTOR = _REBALANCEREPAIRREQUEST
+ DESCRIPTOR = _REPAIRJOBREQUEST
- # @@protoc_insertion_point(class_scope:voldemort.RebalanceRepairRequest)
+ # @@protoc_insertion_point(class_scope:voldemort.RepairJobRequest)
-class RebalanceRepairResponse(message.Message):
+class RepairJobResponse(message.Message):
__metaclass__ = reflection.GeneratedProtocolMessageType
- DESCRIPTOR = _REBALANCEREPAIRRESPONSE
+ DESCRIPTOR = _REPAIRJOBRESPONSE
- # @@protoc_insertion_point(class_scope:voldemort.RebalanceRepairResponse)
+ # @@protoc_insertion_point(class_scope:voldemort.RepairJobResponse)
class ROStoreVersionDirMap(message.Message):
__metaclass__ = reflection.GeneratedProtocolMessageType
View
8 src/java/voldemort/VoldemortAdminTool.java
@@ -419,7 +419,7 @@ public static void main(String[] args) throws Exception {
executeAsync(nodeId, adminClient, asyncKey, asyncIds);
}
if(ops.contains("l")) {
- executeRebalanceRepair(nodeId, adminClient);
+ executeRepairJob(nodeId, adminClient);
}
} catch(Exception e) {
e.printStackTrace();
@@ -427,13 +427,13 @@ public static void main(String[] args) throws Exception {
}
}
- private static void executeRebalanceRepair(Integer nodeId, AdminClient adminClient) {
+ private static void executeRepairJob(Integer nodeId, AdminClient adminClient) {
if(nodeId < 0) {
for(Node node: adminClient.getAdminClientCluster().getNodes()) {
- adminClient.rebalanceRepair(node.getId());
+ adminClient.RepairJob(node.getId());
}
} else {
- adminClient.rebalanceRepair(nodeId);
+ adminClient.RepairJob(nodeId);
}
}
View
8 src/java/voldemort/client/protocol/admin/AdminClient.java
@@ -1585,12 +1585,12 @@ public void rollbackStore(int nodeId, String storeName, long pushVersion) {
*
* @param nodeId The id of the node on which to do the repair
*/
- public void rebalanceRepair(int nodeId) {
- VAdminProto.RebalanceRepairRequest.Builder rebalanceRepairRequest = VAdminProto.RebalanceRepairRequest.newBuilder();
+ public void RepairJob(int nodeId) {
+ VAdminProto.RepairJobRequest.Builder rebalanceRepairRequest = VAdminProto.RepairJobRequest.newBuilder();
VAdminProto.VoldemortAdminRequest adminRequest = VAdminProto.VoldemortAdminRequest.newBuilder()
- .setRebalanceRepair(rebalanceRepairRequest)
- .setType(VAdminProto.AdminRequestType.REBALANCE_REPAIR)
+ .setRepairJob(rebalanceRepairRequest)
+ .setType(VAdminProto.AdminRequestType.REPAIR_JOB)
.build();
VAdminProto.AsyncOperationStatusResponse.Builder response = sendAndReceive(nodeId,
adminRequest,
View
439 src/java/voldemort/client/protocol/pb/VAdminProto.java
@@ -33,7 +33,7 @@ public static void registerAllExtensions(
FAILED_FETCH_STORE(20, 22),
GET_RO_STORAGE_FORMAT(21, 23),
REBALANCE_STATE_CHANGE(22, 24),
- REBALANCE_REPAIR(23, 25),
+ REPAIR_JOB(23, 25),
;
@@ -64,7 +64,7 @@ public static AdminRequestType valueOf(int value) {
case 22: return FAILED_FETCH_STORE;
case 23: return GET_RO_STORAGE_FORMAT;
case 24: return REBALANCE_STATE_CHANGE;
- case 25: return REBALANCE_REPAIR;
+ case 25: return REPAIR_JOB;
default: return null;
}
}
@@ -95,7 +95,7 @@ public AdminRequestType findValueByNumber(int number) {
}
private static final AdminRequestType[] VALUES = {
- GET_METADATA, UPDATE_METADATA, UPDATE_PARTITION_ENTRIES, FETCH_PARTITION_ENTRIES, DELETE_PARTITION_ENTRIES, INITIATE_FETCH_AND_UPDATE, ASYNC_OPERATION_STATUS, INITIATE_REBALANCE_NODE, ASYNC_OPERATION_STOP, ASYNC_OPERATION_LIST, TRUNCATE_ENTRIES, ADD_STORE, DELETE_STORE, FETCH_STORE, SWAP_STORE, ROLLBACK_STORE, GET_RO_MAX_VERSION_DIR, GET_RO_CURRENT_VERSION_DIR, FETCH_PARTITION_FILES, UPDATE_SLOP_ENTRIES, FAILED_FETCH_STORE, GET_RO_STORAGE_FORMAT, REBALANCE_STATE_CHANGE, REBALANCE_REPAIR,
+ GET_METADATA, UPDATE_METADATA, UPDATE_PARTITION_ENTRIES, FETCH_PARTITION_ENTRIES, DELETE_PARTITION_ENTRIES, INITIATE_FETCH_AND_UPDATE, ASYNC_OPERATION_STATUS, INITIATE_REBALANCE_NODE, ASYNC_OPERATION_STOP, ASYNC_OPERATION_LIST, TRUNCATE_ENTRIES, ADD_STORE, DELETE_STORE, FETCH_STORE, SWAP_STORE, ROLLBACK_STORE, GET_RO_MAX_VERSION_DIR, GET_RO_CURRENT_VERSION_DIR, FETCH_PARTITION_FILES, UPDATE_SLOP_ENTRIES, FAILED_FETCH_STORE, GET_RO_STORAGE_FORMAT, REBALANCE_STATE_CHANGE, REPAIR_JOB,
};
public static AdminRequestType valueOf(
com.google.protobuf.Descriptors.EnumValueDescriptor desc) {
@@ -13974,31 +13974,31 @@ public Builder clearError() {
// @@protoc_insertion_point(class_scope:voldemort.RollbackStoreResponse)
}
- public static final class RebalanceRepairRequest extends
+ public static final class RepairJobRequest extends
com.google.protobuf.GeneratedMessage {
- // Use RebalanceRepairRequest.newBuilder() to construct.
- private RebalanceRepairRequest() {
+ // Use RepairJobRequest.newBuilder() to construct.
+ private RepairJobRequest() {
initFields();
}
- private RebalanceRepairRequest(boolean noInit) {}
+ private RepairJobRequest(boolean noInit) {}
- private static final RebalanceRepairRequest defaultInstance;
- public static RebalanceRepairRequest getDefaultInstance() {
+ private static final RepairJobRequest defaultInstance;
+ public static RepairJobRequest getDefaultInstance() {
return defaultInstance;
}
- public RebalanceRepairRequest getDefaultInstanceForType() {
+ public RepairJobRequest getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
- return voldemort.client.protocol.pb.VAdminProto.internal_static_voldemort_RebalanceRepairRequest_descriptor;
+ return voldemort.client.protocol.pb.VAdminProto.internal_static_voldemort_RepairJobRequest_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
- return voldemort.client.protocol.pb.VAdminProto.internal_static_voldemort_RebalanceRepairRequest_fieldAccessorTable;
+ return voldemort.client.protocol.pb.VAdminProto.internal_static_voldemort_RepairJobRequest_fieldAccessorTable;
}
// optional string store_name = 1;
@@ -14038,41 +14038,41 @@ public int getSerializedSize() {
return size;
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest parseFrom(
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobRequest parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest parseFrom(
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobRequest parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest parseFrom(byte[] data)
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobRequest parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest parseFrom(
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobRequest parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest parseFrom(java.io.InputStream input)
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobRequest parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest parseFrom(
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobRequest parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest parseDelimitedFrom(java.io.InputStream input)
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobRequest parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
@@ -14081,7 +14081,7 @@ public int getSerializedSize() {
return null;
}
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest parseDelimitedFrom(
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobRequest parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
@@ -14092,12 +14092,12 @@ public int getSerializedSize() {
return null;
}
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest parseFrom(
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobRequest parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest parseFrom(
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobRequest parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
@@ -14107,25 +14107,25 @@ public int getSerializedSize() {
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
- public static Builder newBuilder(voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest prototype) {
+ public static Builder newBuilder(voldemort.client.protocol.pb.VAdminProto.RepairJobRequest prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder<Builder> {
- private voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest result;
+ private voldemort.client.protocol.pb.VAdminProto.RepairJobRequest result;
- // Construct using voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest.newBuilder()
+ // Construct using voldemort.client.protocol.pb.VAdminProto.RepairJobRequest.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
- builder.result = new voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest();
+ builder.result = new voldemort.client.protocol.pb.VAdminProto.RepairJobRequest();
return builder;
}
- protected voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest internalGetResult() {
+ protected voldemort.client.protocol.pb.VAdminProto.RepairJobRequest internalGetResult() {
return result;
}
@@ -14134,7 +14134,7 @@ public Builder clear() {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
- result = new voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest();
+ result = new voldemort.client.protocol.pb.VAdminProto.RepairJobRequest();
return this;
}
@@ -14144,24 +14144,24 @@ public Builder clone() {
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
- return voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest.getDescriptor();
+ return voldemort.client.protocol.pb.VAdminProto.RepairJobRequest.getDescriptor();
}
- public voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest getDefaultInstanceForType() {
- return voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest.getDefaultInstance();
+ public voldemort.client.protocol.pb.VAdminProto.RepairJobRequest getDefaultInstanceForType() {
+ return voldemort.client.protocol.pb.VAdminProto.RepairJobRequest.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
- public voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest build() {
+ public voldemort.client.protocol.pb.VAdminProto.RepairJobRequest build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
- private voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest buildParsed()
+ private voldemort.client.protocol.pb.VAdminProto.RepairJobRequest buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
@@ -14170,27 +14170,27 @@ public boolean isInitialized() {
return buildPartial();
}
- public voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest buildPartial() {
+ public voldemort.client.protocol.pb.VAdminProto.RepairJobRequest buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
- voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest returnMe = result;
+ voldemort.client.protocol.pb.VAdminProto.RepairJobRequest returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
- if (other instanceof voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest) {
- return mergeFrom((voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest)other);
+ if (other instanceof voldemort.client.protocol.pb.VAdminProto.RepairJobRequest) {
+ return mergeFrom((voldemort.client.protocol.pb.VAdminProto.RepairJobRequest)other);
} else {
super.mergeFrom(other);
return this;
}
}
- public Builder mergeFrom(voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest other) {
- if (other == voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest.getDefaultInstance()) return this;
+ public Builder mergeFrom(voldemort.client.protocol.pb.VAdminProto.RepairJobRequest other) {
+ if (other == voldemort.client.protocol.pb.VAdminProto.RepairJobRequest.getDefaultInstance()) return this;
if (other.hasStoreName()) {
setStoreName(other.getStoreName());
}
@@ -14249,43 +14249,43 @@ public Builder clearStoreName() {
return this;
}
- // @@protoc_insertion_point(builder_scope:voldemort.RebalanceRepairRequest)
+ // @@protoc_insertion_point(builder_scope:voldemort.RepairJobRequest)
}
static {
- defaultInstance = new RebalanceRepairRequest(true);
+ defaultInstance = new RepairJobRequest(true);
voldemort.client.protocol.pb.VAdminProto.internalForceInit();
defaultInstance.initFields();
}
- // @@protoc_insertion_point(class_scope:voldemort.RebalanceRepairRequest)
+ // @@protoc_insertion_point(class_scope:voldemort.RepairJobRequest)
}
- public static final class RebalanceRepairResponse extends
+ public static final class RepairJobResponse extends
com.google.protobuf.GeneratedMessage {
- // Use RebalanceRepairResponse.newBuilder() to construct.
- private RebalanceRepairResponse() {
+ // Use RepairJobResponse.newBuilder() to construct.
+ private RepairJobResponse() {
initFields();
}
- private RebalanceRepairResponse(boolean noInit) {}
+ private RepairJobResponse(boolean noInit) {}
- private static final RebalanceRepairResponse defaultInstance;
- public static RebalanceRepairResponse getDefaultInstance() {
+ private static final RepairJobResponse defaultInstance;
+ public static RepairJobResponse getDefaultInstance() {
return defaultInstance;
}
- public RebalanceRepairResponse getDefaultInstanceForType() {
+ public RepairJobResponse getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
- return voldemort.client.protocol.pb.VAdminProto.internal_static_voldemort_RebalanceRepairResponse_descriptor;
+ return voldemort.client.protocol.pb.VAdminProto.internal_static_voldemort_RepairJobResponse_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
- return voldemort.client.protocol.pb.VAdminProto.internal_static_voldemort_RebalanceRepairResponse_fieldAccessorTable;
+ return voldemort.client.protocol.pb.VAdminProto.internal_static_voldemort_RepairJobResponse_fieldAccessorTable;
}
// optional .voldemort.Error error = 1;
@@ -14329,41 +14329,41 @@ public int getSerializedSize() {
return size;
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse parseFrom(
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobResponse parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse parseFrom(
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobResponse parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse parseFrom(byte[] data)
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobResponse parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse parseFrom(
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobResponse parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse parseFrom(java.io.InputStream input)
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobResponse parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse parseFrom(
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobResponse parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse parseDelimitedFrom(java.io.InputStream input)
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobResponse parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
@@ -14372,7 +14372,7 @@ public int getSerializedSize() {
return null;
}
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse parseDelimitedFrom(
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobResponse parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
@@ -14383,12 +14383,12 @@ public int getSerializedSize() {
return null;
}
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse parseFrom(
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobResponse parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
- public static voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse parseFrom(
+ public static voldemort.client.protocol.pb.VAdminProto.RepairJobResponse parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
@@ -14398,25 +14398,25 @@ public int getSerializedSize() {
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
- public static Builder newBuilder(voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse prototype) {
+ public static Builder newBuilder(voldemort.client.protocol.pb.VAdminProto.RepairJobResponse prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder<Builder> {
- private voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse result;
+ private voldemort.client.protocol.pb.VAdminProto.RepairJobResponse result;
- // Construct using voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse.newBuilder()
+ // Construct using voldemort.client.protocol.pb.VAdminProto.RepairJobResponse.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
- builder.result = new voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse();
+ builder.result = new voldemort.client.protocol.pb.VAdminProto.RepairJobResponse();
return builder;
}
- protected voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse internalGetResult() {
+ protected voldemort.client.protocol.pb.VAdminProto.RepairJobResponse internalGetResult() {
return result;
}
@@ -14425,7 +14425,7 @@ public Builder clear() {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
- result = new voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse();
+ result = new voldemort.client.protocol.pb.VAdminProto.RepairJobResponse();
return this;
}
@@ -14435,24 +14435,24 @@ public Builder clone() {
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
- return voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse.getDescriptor();
+ return voldemort.client.protocol.pb.VAdminProto.RepairJobResponse.getDescriptor();
}
- public voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse getDefaultInstanceForType() {
- return voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse.getDefaultInstance();
+ public voldemort.client.protocol.pb.VAdminProto.RepairJobResponse getDefaultInstanceForType() {
+ return voldemort.client.protocol.pb.VAdminProto.RepairJobResponse.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
- public voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse build() {
+ public voldemort.client.protocol.pb.VAdminProto.RepairJobResponse build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
- private voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse buildParsed()
+ private voldemort.client.protocol.pb.VAdminProto.RepairJobResponse buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
@@ -14461,27 +14461,27 @@ public boolean isInitialized() {
return buildPartial();
}
- public voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse buildPartial() {
+ public voldemort.client.protocol.pb.VAdminProto.RepairJobResponse buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
- voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse returnMe = result;
+ voldemort.client.protocol.pb.VAdminProto.RepairJobResponse returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
- if (other instanceof voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse) {
- return mergeFrom((voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse)other);
+ if (other instanceof voldemort.client.protocol.pb.VAdminProto.RepairJobResponse) {
+ return mergeFrom((voldemort.client.protocol.pb.VAdminProto.RepairJobResponse)other);
} else {
super.mergeFrom(other);
return this;
}
}
- public Builder mergeFrom(voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse other) {
- if (other == voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse.getDefaultInstance()) return this;
+ public Builder mergeFrom(voldemort.client.protocol.pb.VAdminProto.RepairJobResponse other) {
+ if (other == voldemort.client.protocol.pb.VAdminProto.RepairJobResponse.getDefaultInstance()) return this;
if (other.hasError()) {
mergeError(other.getError());
}
@@ -14561,16 +14561,16 @@ public Builder clearError() {
return this;
}
- // @@protoc_insertion_point(builder_scope:voldemort.RebalanceRepairResponse)
+ // @@protoc_insertion_point(builder_scope:voldemort.RepairJobResponse)
}
static {
- defaultInstance = new RebalanceRepairResponse(true);
+ defaultInstance = new RepairJobResponse(true);
voldemort.client.protocol.pb.VAdminProto.internalForceInit();
defaultInstance.initFields();
}
- // @@protoc_insertion_point(class_scope:voldemort.RebalanceRepairResponse)
+ // @@protoc_insertion_point(class_scope:voldemort.RepairJobResponse)
}
public static final class ROStoreVersionDirMap extends
@@ -18763,12 +18763,12 @@ public VoldemortAdminRequest getDefaultInstanceForType() {
public boolean hasRebalanceStateChange() { return hasRebalanceStateChange; }
public voldemort.client.protocol.pb.VAdminProto.RebalanceStateChangeRequest getRebalanceStateChange() { return rebalanceStateChange_; }
- // optional .voldemort.RebalanceRepairRequest rebalance_repair = 27;
- public static final int REBALANCE_REPAIR_FIELD_NUMBER = 27;
- private boolean hasRebalanceRepair;
- private voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest rebalanceRepair_;
- public boolean hasRebalanceRepair() { return hasRebalanceRepair; }
- public voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest getRebalanceRepair() { return rebalanceRepair_; }
+ // optional .voldemort.RepairJobRequest repair_job = 27;
+ public static final int REPAIR_JOB_FIELD_NUMBER = 27;
+ private boolean hasRepairJob;
+ private voldemort.client.protocol.pb.VAdminProto.RepairJobRequest repairJob_;
+ public boolean hasRepairJob() { return hasRepairJob; }
+ public voldemort.client.protocol.pb.VAdminProto.RepairJobRequest getRepairJob() { return repairJob_; }
private void initFields() {
type_ = voldemort.client.protocol.pb.VAdminProto.AdminRequestType.GET_METADATA;
@@ -18795,7 +18795,7 @@ private void initFields() {
failedFetchStore_ = voldemort.client.protocol.pb.VAdminProto.FailedFetchStoreRequest.getDefaultInstance();
getRoStorageFormat_ = voldemort.client.protocol.pb.VAdminProto.GetROStorageFormatRequest.getDefaultInstance();
rebalanceStateChange_ = voldemort.client.protocol.pb.VAdminProto.RebalanceStateChangeRequest.getDefaultInstance();
- rebalanceRepair_ = voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest.getDefaultInstance();
+ repairJob_ = voldemort.client.protocol.pb.VAdminProto.RepairJobRequest.getDefaultInstance();
}
public final boolean isInitialized() {
if (!hasType) return false;
@@ -18937,8 +18937,8 @@ public void writeTo(com.google.protobuf.CodedOutputStream output)
if (hasRebalanceStateChange()) {
output.writeMessage(26, getRebalanceStateChange());
}
- if (hasRebalanceRepair()) {
- output.writeMessage(27, getRebalanceRepair());
+ if (hasRepairJob()) {
+ output.writeMessage(27, getRepairJob());
}
getUnknownFields().writeTo(output);
}
@@ -19045,9 +19045,9 @@ public int getSerializedSize() {
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(26, getRebalanceStateChange());
}
- if (hasRebalanceRepair()) {
+ if (hasRepairJob()) {
size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(27, getRebalanceRepair());
+ .computeMessageSize(27, getRepairJob());
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
@@ -19279,8 +19279,8 @@ public Builder mergeFrom(voldemort.client.protocol.pb.VAdminProto.VoldemortAdmin
if (other.hasRebalanceStateChange()) {
mergeRebalanceStateChange(other.getRebalanceStateChange());
}
- if (other.hasRebalanceRepair()) {
- mergeRebalanceRepair(other.getRebalanceRepair());
+ if (other.hasRepairJob()) {
+ mergeRepairJob(other.getRepairJob());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
@@ -19525,12 +19525,12 @@ public Builder mergeFrom(
break;
}
case 218: {
- voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest.Builder subBuilder = voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest.newBuilder();
- if (hasRebalanceRepair()) {
- subBuilder.mergeFrom(getRebalanceRepair());
+ voldemort.client.protocol.pb.VAdminProto.RepairJobRequest.Builder subBuilder = voldemort.client.protocol.pb.VAdminProto.RepairJobRequest.newBuilder();
+ if (hasRepairJob()) {
+ subBuilder.mergeFrom(getRepairJob());
}
input.readMessage(subBuilder, extensionRegistry);
- setRebalanceRepair(subBuilder.buildPartial());
+ setRepairJob(subBuilder.buildPartial());
break;
}
}
@@ -20410,40 +20410,40 @@ public Builder clearRebalanceStateChange() {
return this;
}
- // optional .voldemort.RebalanceRepairRequest rebalance_repair = 27;
- public boolean hasRebalanceRepair() {
- return result.hasRebalanceRepair();
+ // optional .voldemort.RepairJobRequest repair_job = 27;
+ public boolean hasRepairJob() {
+ return result.hasRepairJob();
}
- public voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest getRebalanceRepair() {
- return result.getRebalanceRepair();
+ public voldemort.client.protocol.pb.VAdminProto.RepairJobRequest getRepairJob() {
+ return result.getRepairJob();
}
- public Builder setRebalanceRepair(voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest value) {
+ public Builder setRepairJob(voldemort.client.protocol.pb.VAdminProto.RepairJobRequest value) {
if (value == null) {
throw new NullPointerException();
}
- result.hasRebalanceRepair = true;
- result.rebalanceRepair_ = value;
+ result.hasRepairJob = true;
+ result.repairJob_ = value;
return this;
}
- public Builder setRebalanceRepair(voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest.Builder builderForValue) {
- result.hasRebalanceRepair = true;
- result.rebalanceRepair_ = builderForValue.build();
+ public Builder setRepairJob(voldemort.client.protocol.pb.VAdminProto.RepairJobRequest.Builder builderForValue) {
+ result.hasRepairJob = true;
+ result.repairJob_ = builderForValue.build();
return this;
}
- public Builder mergeRebalanceRepair(voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest value) {
- if (result.hasRebalanceRepair() &&
- result.rebalanceRepair_ != voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest.getDefaultInstance()) {
- result.rebalanceRepair_ =
- voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest.newBuilder(result.rebalanceRepair_).mergeFrom(value).buildPartial();
+ public Builder mergeRepairJob(voldemort.client.protocol.pb.VAdminProto.RepairJobRequest value) {
+ if (result.hasRepairJob() &&
+ result.repairJob_ != voldemort.client.protocol.pb.VAdminProto.RepairJobRequest.getDefaultInstance()) {
+ result.repairJob_ =
+ voldemort.client.protocol.pb.VAdminProto.RepairJobRequest.newBuilder(result.repairJob_).mergeFrom(value).buildPartial();
} else {
- result.rebalanceRepair_ = value;
+ result.repairJob_ = value;
}
- result.hasRebalanceRepair = true;
+ result.hasRepairJob = true;
return this;
}
- public Builder clearRebalanceRepair() {
- result.hasRebalanceRepair = false;
- result.rebalanceRepair_ = voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest.getDefaultInstance();
+ public Builder clearRepairJob() {
+ result.hasRepairJob = false;
+ result.repairJob_ = voldemort.client.protocol.pb.VAdminProto.RepairJobRequest.getDefaultInstance();
return this;
}
@@ -20650,15 +20650,15 @@ public Builder clearRebalanceRepair() {
com.google.protobuf.GeneratedMessage.FieldAccessorTable
internal_static_voldemort_RollbackStoreResponse_fieldAccessorTable;
private static com.google.protobuf.Descriptors.Descriptor
- internal_static_voldemort_RebalanceRepairRequest_descriptor;
+ internal_static_voldemort_RepairJobRequest_descriptor;
private static
com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internal_static_voldemort_RebalanceRepairRequest_fieldAccessorTable;
+ internal_static_voldemort_RepairJobRequest_fieldAccessorTable;
private static com.google.protobuf.Descriptors.Descriptor
- internal_static_voldemort_RebalanceRepairResponse_descriptor;
+ internal_static_voldemort_RepairJobResponse_descriptor;
private static
com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internal_static_voldemort_RebalanceRepairResponse_fieldAccessorTable;
+ internal_static_voldemort_RepairJobResponse_fieldAccessorTable;
private static com.google.protobuf.Descriptors.Descriptor
internal_static_voldemort_ROStoreVersionDirMap_descriptor;
private static
@@ -20814,93 +20814,92 @@ public Builder clearRebalanceRepair() {
"r\022\032\n\022previous_store_dir\030\002 \001(\t\"@\n\024Rollbac" +
"kStoreRequest\022\022\n\nstore_name\030\001 \002(\t\022\024\n\014pus" +
"h_version\030\002 \002(\003\"8\n\025RollbackStoreResponse" +
- "\022\037\n\005error\030\001 \001(\0132\020.voldemort.Error\",\n\026Reb" +
- "alanceRepairRequest\022\022\n\nstore_name\030\001 \001(\t\"" +
- ":\n\027RebalanceRepairResponse\022\037\n\005error\030\001 \001(" +
- "\0132\020.voldemort.Error\"=\n\024ROStoreVersionDir",
- "Map\022\022\n\nstore_name\030\001 \002(\t\022\021\n\tstore_dir\030\002 \002" +
- "(\t\"/\n\031GetROMaxVersionDirRequest\022\022\n\nstore" +
- "_name\030\001 \003(\t\"y\n\032GetROMaxVersionDirRespons" +
- "e\022:\n\021ro_store_versions\030\001 \003(\0132\037.voldemort" +
- ".ROStoreVersionDirMap\022\037\n\005error\030\002 \001(\0132\020.v" +
- "oldemort.Error\"3\n\035GetROCurrentVersionDir" +
- "Request\022\022\n\nstore_name\030\001 \003(\t\"}\n\036GetROCurr" +
- "entVersionDirResponse\022:\n\021ro_store_versio" +
+ "\022\037\n\005error\030\001 \001(\0132\020.voldemort.Error\"&\n\020Rep" +
+ "airJobRequest\022\022\n\nstore_name\030\001 \001(\t\"4\n\021Rep" +
+ "airJobResponse\022\037\n\005error\030\001 \001(\0132\020.voldemor" +
+ "t.Error\"=\n\024ROStoreVersionDirMap\022\022\n\nstore",
+ "_name\030\001 \002(\t\022\021\n\tstore_dir\030\002 \002(\t\"/\n\031GetROM" +
+ "axVersionDirRequest\022\022\n\nstore_name\030\001 \003(\t\"" +
+ "y\n\032GetROMaxVersionDirResponse\022:\n\021ro_stor" +
+ "e_versions\030\001 \003(\0132\037.voldemort.ROStoreVers" +
+ "ionDirMap\022\037\n\005error\030\002 \001(\0132\020.voldemort.Err" +
+ "or\"3\n\035GetROCurrentVersionDirRequest\022\022\n\ns" +
+ "tore_name\030\001 \003(\t\"}\n\036GetROCurrentVersionDi" +
+ "rResponse\022:\n\021ro_store_versions\030\001 \003(\0132\037.v" +
+ "oldemort.ROStoreVersionDirMap\022\037\n\005error\030\002" +
+ " \001(\0132\020.voldemort.Error\"/\n\031GetROStorageFo",
+ "rmatRequest\022\022\n\nstore_name\030\001 \003(\t\"y\n\032GetRO" +
+ "StorageFormatResponse\022:\n\021ro_store_versio" +
"ns\030\001 \003(\0132\037.voldemort.ROStoreVersionDirMa" +
- "p\022\037\n\005error\030\002 \001(\0132\020.voldemort.Error\"/\n\031Ge",
- "tROStorageFormatRequest\022\022\n\nstore_name\030\001 " +
- "\003(\t\"y\n\032GetROStorageFormatResponse\022:\n\021ro_" +
- "store_versions\030\001 \003(\0132\037.voldemort.ROStore" +
- "VersionDirMap\022\037\n\005error\030\002 \001(\0132\020.voldemort" +
- ".Error\"@\n\027FailedFetchStoreRequest\022\022\n\nsto" +
- "re_name\030\001 \002(\t\022\021\n\tstore_dir\030\002 \002(\t\";\n\030Fail" +
- "edFetchStoreResponse\022\037\n\005error\030\001 \001(\0132\020.vo" +
- "ldemort.Error\"\346\001\n\033RebalanceStateChangeRe" +
- "quest\022K\n\035rebalance_partition_info_list\030\001" +
- " \003(\0132$.voldemort.RebalancePartitionInfoM",
- "ap\022\026\n\016cluster_string\030\002 \002(\t\022\017\n\007swap_ro\030\003 " +
- "\002(\010\022\037\n\027change_cluster_metadata\030\004 \002(\010\022\036\n\026" +
- "change_rebalance_state\030\005 \002(\010\022\020\n\010rollback" +
- "\030\006 \002(\010\"?\n\034RebalanceStateChangeResponse\022\037" +
- "\n\005error\030\001 \001(\0132\020.voldemort.Error\"\337\014\n\025Vold" +
- "emortAdminRequest\022)\n\004type\030\001 \002(\0162\033.voldem" +
- "ort.AdminRequestType\0223\n\014get_metadata\030\002 \001" +
- "(\0132\035.voldemort.GetMetadataRequest\0229\n\017upd" +
- "ate_metadata\030\003 \001(\0132 .voldemort.UpdateMet" +
- "adataRequest\022J\n\030update_partition_entries",
- "\030\004 \001(\0132(.voldemort.UpdatePartitionEntrie" +
- "sRequest\022H\n\027fetch_partition_entries\030\005 \001(" +
- "\0132\'.voldemort.FetchPartitionEntriesReque" +
- "st\022J\n\030delete_partition_entries\030\006 \001(\0132(.v" +
- "oldemort.DeletePartitionEntriesRequest\022K" +
- "\n\031initiate_fetch_and_update\030\007 \001(\0132(.vold" +
- "emort.InitiateFetchAndUpdateRequest\022F\n\026a" +
- "sync_operation_status\030\010 \001(\0132&.voldemort." +
- "AsyncOperationStatusRequest\022H\n\027initiate_" +
- "rebalance_node\030\t \001(\0132\'.voldemort.Initiat",
- "eRebalanceNodeRequest\022B\n\024async_operation" +
- "_stop\030\n \001(\0132$.voldemort.AsyncOperationSt" +
- "opRequest\022B\n\024async_operation_list\030\013 \001(\0132" +
- "$.voldemort.AsyncOperationListRequest\022;\n" +
- "\020truncate_entries\030\014 \001(\0132!.voldemort.Trun" +
- "cateEntriesRequest\022-\n\tadd_store\030\r \001(\0132\032." +
- "voldemort.AddStoreRequest\0223\n\014delete_stor" +
- "e\030\016 \001(\0132\035.voldemort.DeleteStoreRequest\0221" +
- "\n\013fetch_store\030\017 \001(\0132\034.voldemort.FetchSto" +
- "reRequest\022/\n\nswap_store\030\020 \001(\0132\033.voldemor",
- "t.SwapStoreRequest\0227\n\016rollback_store\030\021 \001" +
- "(\0132\037.voldemort.RollbackStoreRequest\022D\n\026g" +
- "et_ro_max_version_dir\030\022 \001(\0132$.voldemort." +
- "GetROMaxVersionDirRequest\022L\n\032get_ro_curr" +
- "ent_version_dir\030\023 \001(\0132(.voldemort.GetROC" +
- "urrentVersionDirRequest\022D\n\025fetch_partiti" +
- "on_files\030\024 \001(\0132%.voldemort.FetchPartitio" +
- "nFilesRequest\022@\n\023update_slop_entries\030\026 \001" +
- "(\0132#.voldemort.UpdateSlopEntriesRequest\022" +
- ">\n\022failed_fetch_store\030\030 \001(\0132\".voldemort.",
- "FailedFetchStoreRequest\022C\n\025get_ro_storag" +
- "e_format\030\031 \001(\0132$.voldemort.GetROStorageF" +
- "ormatRequest\022F\n\026rebalance_state_change\030\032" +
- " \001(\0132&.voldemort.RebalanceStateChangeReq" +
- "uest\022;\n\020rebalance_repair\030\033 \001(\0132!.voldemo" +
- "rt.RebalanceRepairRequest*\337\004\n\020AdminReque" +
- "stType\022\020\n\014GET_METADATA\020\000\022\023\n\017UPDATE_METAD" +
- "ATA\020\001\022\034\n\030UPDATE_PARTITION_ENTRIES\020\002\022\033\n\027F" +
- "ETCH_PARTITION_ENTRIES\020\003\022\034\n\030DELETE_PARTI" +
- "TION_ENTRIES\020\004\022\035\n\031INITIATE_FETCH_AND_UPD",
- "ATE\020\005\022\032\n\026ASYNC_OPERATION_STATUS\020\006\022\033\n\027INI" +
- "TIATE_REBALANCE_NODE\020\007\022\030\n\024ASYNC_OPERATIO" +
- "N_STOP\020\010\022\030\n\024ASYNC_OPERATION_LIST\020\t\022\024\n\020TR" +
- "UNCATE_ENTRIES\020\n\022\r\n\tADD_STORE\020\013\022\020\n\014DELET" +
- "E_STORE\020\014\022\017\n\013FETCH_STORE\020\r\022\016\n\nSWAP_STORE" +
- "\020\016\022\022\n\016ROLLBACK_STORE\020\017\022\032\n\026GET_RO_MAX_VER" +
- "SION_DIR\020\020\022\036\n\032GET_RO_CURRENT_VERSION_DIR" +
- "\020\021\022\031\n\025FETCH_PARTITION_FILES\020\022\022\027\n\023UPDATE_" +
- "SLOP_ENTRIES\020\024\022\026\n\022FAILED_FETCH_STORE\020\026\022\031" +
- "\n\025GET_RO_STORAGE_FORMAT\020\027\022\032\n\026REBALANCE_S",
- "TATE_CHANGE\020\030\022\024\n\020REBALANCE_REPAIR\020\031B-\n\034v" +
- "oldemort.client.protocol.pbB\013VAdminProto" +
- "H\001"
+ "p\022\037\n\005error\030\002 \001(\0132\020.voldemort.Error\"@\n\027Fa" +
+ "iledFetchStoreRequest\022\022\n\nstore_name\030\001 \002(" +
+ "\t\022\021\n\tstore_dir\030\002 \002(\t\";\n\030FailedFetchStore" +
+ "Response\022\037\n\005error\030\001 \001(\0132\020.voldemort.Erro" +
+ "r\"\346\001\n\033RebalanceStateChangeRequest\022K\n\035reb" +
+ "alance_partition_info_list\030\001 \003(\0132$.volde" +
+ "mort.RebalancePartitionInfoMap\022\026\n\016cluste",
+ "r_string\030\002 \002(\t\022\017\n\007swap_ro\030\003 \002(\010\022\037\n\027chang" +
+ "e_cluster_metadata\030\004 \002(\010\022\036\n\026change_rebal" +
+ "ance_state\030\005 \002(\010\022\020\n\010rollback\030\006 \002(\010\"?\n\034Re" +
+ "balanceStateChangeResponse\022\037\n\005error\030\001 \001(" +
+ "\0132\020.voldemort.Error\"\323\014\n\025VoldemortAdminRe" +
+ "quest\022)\n\004type\030\001 \002(\0162\033.voldemort.AdminReq" +
+ "uestType\0223\n\014get_metadata\030\002 \001(\0132\035.voldemo" +
+ "rt.GetMetadataRequest\0229\n\017update_metadata" +
+ "\030\003 \001(\0132 .voldemort.UpdateMetadataRequest" +
+ "\022J\n\030update_partition_entries\030\004 \001(\0132(.vol",
+ "demort.UpdatePartitionEntriesRequest\022H\n\027" +
+ "fetch_partition_entries\030\005 \001(\0132\'.voldemor" +
+ "t.FetchPartitionEntriesRequest\022J\n\030delete" +
+ "_partition_entries\030\006 \001(\0132(.voldemort.Del" +
+ "etePartitionEntriesRequest\022K\n\031initiate_f" +
+ "etch_and_update\030\007 \001(\0132(.voldemort.Initia" +
+ "teFetchAndUpdateRequest\022F\n\026async_operati" +
+ "on_status\030\010 \001(\0132&.voldemort.AsyncOperati" +
+ "onStatusRequest\022H\n\027initiate_rebalance_no" +
+ "de\030\t \001(\0132\'.voldemort.InitiateRebalanceNo",
+ "deRequest\022B\n\024async_operation_stop\030\n \001(\0132" +
+ "$.voldemort.AsyncOperationStopRequest\022B\n" +
+ "\024async_operation_list\030\013 \001(\0132$.voldemort." +
+ "AsyncOperationListRequest\022;\n\020truncate_en" +
+ "tries\030\014 \001(\0132!.voldemort.TruncateEntriesR" +
+ "equest\022-\n\tadd_store\030\r \001(\0132\032.voldemort.Ad" +
+ "dStoreRequest\0223\n\014delete_store\030\016 \001(\0132\035.vo" +
+ "ldemort.DeleteStoreRequest\0221\n\013fetch_stor" +
+ "e\030\017 \001(\0132\034.voldemort.FetchStoreRequest\022/\n" +
+ "\nswap_store\030\020 \001(\0132\033.voldemort.SwapStoreR",
+ "equest\0227\n\016rollback_store\030\021 \001(\0132\037.voldemo" +
+ "rt.RollbackStoreRequest\022D\n\026get_ro_max_ve" +
+ "rsion_dir\030\022 \001(\0132$.voldemort.GetROMaxVers" +
+ "ionDirRequest\022L\n\032get_ro_current_version_" +
+ "dir\030\023 \001(\0132(.voldemort.GetROCurrentVersio" +
+ "nDirRequest\022D\n\025fetch_partition_files\030\024 \001" +
+ "(\0132%.voldemort.FetchPartitionFilesReques" +
+ "t\022@\n\023update_slop_entries\030\026 \001(\0132#.voldemo" +
+ "rt.UpdateSlopEntriesRequest\022>\n\022failed_fe" +
+ "tch_store\030\030 \001(\0132\".voldemort.FailedFetchS",
+ "toreRequest\022C\n\025get_ro_storage_format\030\031 \001" +
+ "(\0132$.voldemort.GetROStorageFormatRequest" +
+ "\022F\n\026rebalance_state_change\030\032 \001(\0132&.volde" +
+ "mort.RebalanceStateChangeRequest\022/\n\nrepa" +
+ "ir_job\030\033 \001(\0132\033.voldemort.RepairJobReques" +
+ "t*\331\004\n\020AdminRequestType\022\020\n\014GET_METADATA\020\000" +
+ "\022\023\n\017UPDATE_METADATA\020\001\022\034\n\030UPDATE_PARTITIO" +
+ "N_ENTRIES\020\002\022\033\n\027FETCH_PARTITION_ENTRIES\020\003" +
+ "\022\034\n\030DELETE_PARTITION_ENTRIES\020\004\022\035\n\031INITIA" +
+ "TE_FETCH_AND_UPDATE\020\005\022\032\n\026ASYNC_OPERATION",
+ "_STATUS\020\006\022\033\n\027INITIATE_REBALANCE_NODE\020\007\022\030" +
+ "\n\024ASYNC_OPERATION_STOP\020\010\022\030\n\024ASYNC_OPERAT" +
+ "ION_LIST\020\t\022\024\n\020TRUNCATE_ENTRIES\020\n\022\r\n\tADD_" +
+ "STORE\020\013\022\020\n\014DELETE_STORE\020\014\022\017\n\013FETCH_STORE" +
+ "\020\r\022\016\n\nSWAP_STORE\020\016\022\022\n\016ROLLBACK_STORE\020\017\022\032" +
+ "\n\026GET_RO_MAX_VERSION_DIR\020\020\022\036\n\032GET_RO_CUR" +
+ "RENT_VERSION_DIR\020\021\022\031\n\025FETCH_PARTITION_FI" +
+ "LES\020\022\022\027\n\023UPDATE_SLOP_ENTRIES\020\024\022\026\n\022FAILED" +
+ "_FETCH_STORE\020\026\022\031\n\025GET_RO_STORAGE_FORMAT\020" +
+ "\027\022\032\n\026REBALANCE_STATE_CHANGE\020\030\022\016\n\nREPAIR_",
+ "JOB\020\031B-\n\034voldemort.client.protocol.pbB\013V" +
+ "AdminProtoH\001"
};
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() {
@@ -21211,22 +21210,22 @@ public Builder clearRebalanceRepair() {
new java.lang.String[] { "Error", },
voldemort.client.protocol.pb.VAdminProto.RollbackStoreResponse.class,
voldemort.client.protocol.pb.VAdminProto.RollbackStoreResponse.Builder.class);
- internal_static_voldemort_RebalanceRepairRequest_descriptor =
+ internal_static_voldemort_RepairJobRequest_descriptor =
getDescriptor().getMessageTypes().get(38);
- internal_static_voldemort_RebalanceRepairRequest_fieldAccessorTable = new
+ internal_static_voldemort_RepairJobRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessage.FieldAccessorTable(
- internal_static_voldemort_RebalanceRepairRequest_descriptor,
+ internal_static_voldemort_RepairJobRequest_descriptor,
new java.lang.String[] { "StoreName", },
- voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest.class,
- voldemort.client.protocol.pb.VAdminProto.RebalanceRepairRequest.Builder.class);
- internal_static_voldemort_RebalanceRepairResponse_descriptor =
+ voldemort.client.protocol.pb.VAdminProto.RepairJobRequest.class,
+ voldemort.client.protocol.pb.VAdminProto.RepairJobRequest.Builder.class);
+ internal_static_voldemort_RepairJobResponse_descriptor =
getDescriptor().getMessageTypes().get(39);
- internal_static_voldemort_RebalanceRepairResponse_fieldAccessorTable = new
+ internal_static_voldemort_RepairJobResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessage.FieldAccessorTable(
- internal_static_voldemort_RebalanceRepairResponse_descriptor,
+ internal_static_voldemort_RepairJobResponse_descriptor,
new java.lang.String[] { "Error", },
- voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse.class,
- voldemort.client.protocol.pb.VAdminProto.RebalanceRepairResponse.Builder.class);
+ voldemort.client.protocol.pb.VAdminProto.RepairJobResponse.class,
+ voldemort.client.protocol.pb.VAdminProto.RepairJobResponse.Builder.class);
internal_static_voldemort_ROStoreVersionDirMap_descriptor =
getDescriptor().getMessageTypes().get(40);
internal_static_voldemort_ROStoreVersionDirMap_fieldAccessorTable = new
@@ -21320,7 +21319,7 @@ public Builder clearRebalanceRepair() {
internal_static_voldemort_VoldemortAdminRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessage.FieldAccessorTable(
internal_static_voldemort_VoldemortAdminRequest_descriptor,
- new java.lang.String[] { "Type", "GetMetadata", "UpdateMetadata", "UpdatePartitionEntries", "FetchPartitionEntries", "DeletePartitionEntries", "InitiateFetchAndUpdate", "AsyncOperationStatus", "InitiateRebalanceNode", "AsyncOperationStop", "AsyncOperationList", "TruncateEntries", "AddStore", "DeleteStore", "FetchStore", "SwapStore", "RollbackStore", "GetRoMaxVersionDir", "GetRoCurrentVersionDir", "FetchPartitionFiles", "UpdateSlopEntries", "FailedFetchStore", "GetRoStorageFormat", "RebalanceStateChange", "RebalanceRepair", },
+ new java.lang.String[] { "Type", "GetMetadata", "UpdateMetadata", "UpdatePartitionEntries", "FetchPartitionEntries", "DeletePartitionEntries", "InitiateFetchAndUpdate", "AsyncOperationStatus", "InitiateRebalanceNode", "AsyncOperationStop", "AsyncOperationList", "TruncateEntries", "AddStore", "DeleteStore", "FetchStore", "SwapStore", "RollbackStore", "GetRoMaxVersionDir", "GetRoCurrentVersionDir", "FetchPartitionFiles", "UpdateSlopEntries", "FailedFetchStore", "GetRoStorageFormat", "RebalanceStateChange", "RepairJob", },
voldemort.client.protocol.pb.VAdminProto.VoldemortAdminRequest.class,
voldemort.client.protocol.pb.VAdminProto.VoldemortAdminRequest.Builder.class);
return null;
View
14 src/java/voldemort/server/StoreRepository.java
@@ -8,6 +8,7 @@
import voldemort.VoldemortException;
import voldemort.annotations.concurrency.Threadsafe;
+import voldemort.server.scheduler.slop.RepairJob;
import voldemort.store.StorageEngine;
import voldemort.store.Store;
import voldemort.store.slop.SlopStorageEngine;
@@ -74,6 +75,11 @@
*/
private final ConcurrentMap<Pair<String, Integer>, Store<ByteArray, byte[], byte[]>> redirectingSocketStores;
+ /*
+ * Repair Job object registered with StoreRepository
+ */
+ private RepairJob _repairJob;
+
public StoreRepository() {
super();
this.localStores = new ConcurrentHashMap<String, Store<ByteArray, byte[], byte[]>>();
@@ -220,4 +226,12 @@ public void setSlopStore(SlopStorageEngine slopStore) {
public boolean hasSlopStore() {
return this.slopStore != null;
}
+
+ public RepairJob getRepairJob() {
+ return _repairJob;
+ }
+
+ public void registerRepairJob(RepairJob repairJob) {
+ _repairJob = repairJob;
+ }
}
View
13 src/java/voldemort/server/protocol/admin/AdminServiceRequestHandler.java
@@ -250,9 +250,8 @@ public StreamRequestHandler handleRequest(final DataInputStream inputStream,
ProtoUtils.writeMessage(outputStream,
handleRebalanceStateChange(request.getRebalanceStateChange()));
break;
- case REBALANCE_REPAIR:
- ProtoUtils.writeMessage(outputStream,
- handleRebalanceRepair(request.getRebalanceRepair()));
+ case REPAIR_JOB:
+ ProtoUtils.writeMessage(outputStream, handleRebalanceRepair(request.getRepairJob()));
break;
default:
throw new VoldemortException("Unkown operation " + request.getType());
@@ -548,10 +547,12 @@ public StreamRequestHandler handleUpdatePartitionEntries(VAdminProto.UpdateParti
return response.build();
}
- public VAdminProto.RebalanceRepairResponse handleRebalanceRepair(VAdminProto.RebalanceRepairRequest request) {
- VAdminProto.RebalanceRepairResponse.Builder response = VAdminProto.RebalanceRepairResponse.newBuilder();
+ public VAdminProto.RepairJobResponse handleRebalanceRepair(VAdminProto.RepairJobRequest request) {
+ VAdminProto.RepairJobResponse.Builder response = VAdminProto.RepairJobResponse.newBuilder();
try {
- RepairJob job = new RepairJob(storeRepository, metadataStore, repairSemaphore, true);
+ // RepairJob job = new RepairJob(storeRepository, metadataStore,
+ // repairSemaphore, true);
+ RepairJob job = storeRepository.getRepairJob();
logger.info("Starting the repair job now on ID : " + metadataStore.getNodeId());
job.run();
} catch(VoldemortException e) {
View
9 src/java/voldemort/server/scheduler/slop/RepairJob.java
@@ -30,7 +30,7 @@
public class RepairJob implements Runnable {
- private final int DELETE_BATCH = 20;
+ private final int DELETE_BATCH = 1000;
private final static Logger logger = Logger.getLogger(RepairJob.class.getName());
public final static List<String> blackList = Arrays.asList("mysql", "krati", "read-only");
@@ -125,6 +125,7 @@ public void run() {
metadataStore.getCluster());
long repairSlops = 0L;
long numDeletedKeys = 0;
+ long numScannedKeys = 0;
while(iterator.hasNext()) {
Pair<ByteArray, Versioned<byte[]>> keyAndVal;
keyAndVal = iterator.next();
@@ -149,9 +150,11 @@ public void run() {
}
engine.delete(keyAndVal.getFirst(), keyAndVal.getSecond().getVersion());
numDeletedKeys++;
- if(numDeletedKeys % DELETE_BATCH == 0)
- logger.info("Total keys deleted = " + numDeletedKeys);
}
+ numScannedKeys++;
+ if(numScannedKeys % DELETE_BATCH == 0)
+ logger.info("#Scanned:" + numScannedKeys + " #Deleted:"
+ + numDeletedKeys);
}
closeIterator(iterator);
localStats.put(storeDef.getName(), repairSlops);
View
14 src/java/voldemort/server/storage/StorageService.java
@@ -230,17 +230,15 @@ protected void startInner() {
voldemortConfig.getSlopFrequencyMs());
// Run the repair job only if slop pusher job is enabled
- // Also run it only once
+ // CHANGE: The repiar job is not scheduled automatically.
+ // Invoked only via JMX
if(voldemortConfig.isRepairEnabled()) {
- cal.add(Calendar.SECOND,
- (int) (voldemortConfig.getRepairStartMs() / Time.MS_PER_SECOND));
- nextRun = cal.getTime();
- logger.info("Initializing repair job " + voldemortConfig.getPusherType()
- + " at " + nextRun);
+ logger.info("Initializing repair job " + voldemortConfig.getPusherType());
RepairJob job = new RepairJob(storeRepository, metadata, scanPermits);
-
JmxUtils.registerMbean(job, JmxUtils.createObjectName(job.getClass()));
- scheduler.schedule("repair", job, nextRun);
+ storeRepository.registerRepairJob(job);
+
+ // scheduler.schedule("repair", job, nextRun);
}
}
}
View
8 src/proto/voldemort-admin.proto
@@ -203,11 +203,11 @@ message RollbackStoreResponse {
optional Error error = 1;
}
-message RebalanceRepairRequest {
+message RepairJobRequest {
optional string store_name = 1;
}
-message RebalanceRepairResponse {
+message RepairJobResponse {
optional Error error = 1;
}
@@ -289,7 +289,7 @@ enum AdminRequestType {
FAILED_FETCH_STORE = 22;
GET_RO_STORAGE_FORMAT = 23;
REBALANCE_STATE_CHANGE = 24;
- REBALANCE_REPAIR = 25;
+ REPAIR_JOB = 25;
}
message VoldemortAdminRequest {
@@ -317,5 +317,5 @@ message VoldemortAdminRequest {
optional FailedFetchStoreRequest failed_fetch_store = 24;
optional GetROStorageFormatRequest get_ro_storage_format = 25;
optional RebalanceStateChangeRequest rebalance_state_change = 26;
- optional RebalanceRepairRequest rebalance_repair = 27;
+ optional RepairJobRequest repair_job = 27;
}
View
4 test/unit/voldemort/client/rebalance/AbstractRebalanceTest.java
@@ -482,7 +482,7 @@ public void testRebalanceCleanPrimary() throws Exception {
// Do the cleanup operation
for(int i = 0; i < 3; i++) {
- _admin.rebalanceRepair(i);
+ _admin.RepairJob(i);
}
boolean cleanNode = true;
@@ -583,7 +583,7 @@ public void testRebalanceCleanSecondary() throws Exception {
// Do the cleanup operation
for(int i = 0; i < 3; i++) {
- _admin.rebalanceRepair(i);
+ _admin.RepairJob(i);
}
boolean cleanNode = true;
Please sign in to comment.
Something went wrong with that request. Please try again.