voldemort.server.protocol.admin
Class AdminServiceRequestHandler

java.lang.Object
  extended by voldemort.server.protocol.admin.AdminServiceRequestHandler
All Implemented Interfaces:
RequestHandler

public class AdminServiceRequestHandler
extends java.lang.Object
implements RequestHandler

Protocol buffers implementation of a RequestHandler


Constructor Summary
AdminServiceRequestHandler(ErrorCodeMapper errorCodeMapper, StorageService storageService, StoreRepository storeRepository, MetadataStore metadataStore, VoldemortConfig voldemortConfig, AsyncOperationService asyncService, Rebalancer rebalancer)
           
 
Method Summary
 VAdminProto.AddStoreResponse handleAddStore(VAdminProto.AddStoreRequest request)
           
 VAdminProto.AsyncOperationListResponse handleAsyncOperationList(VAdminProto.AsyncOperationListRequest request)
           
 VAdminProto.AsyncOperationStopResponse handleAsyncOperationStop(VAdminProto.AsyncOperationStopRequest request)
           
 VAdminProto.AsyncOperationStatusResponse handleAsyncStatus(VAdminProto.AsyncOperationStatusRequest request)
           
 VAdminProto.DeletePartitionEntriesResponse handleDeletePartitionEntries(VAdminProto.DeletePartitionEntriesRequest request)
           
 VAdminProto.DeleteStoreResponse handleDeleteStore(VAdminProto.DeleteStoreRequest request)
           
 VAdminProto.FailedFetchStoreResponse handleFailedROFetch(VAdminProto.FailedFetchStoreRequest request)
           
 VAdminProto.AsyncOperationStatusResponse handleFetchAndUpdate(VAdminProto.InitiateFetchAndUpdateRequest request)
           
 StreamRequestHandler handleFetchPartitionEntries(VAdminProto.FetchPartitionEntriesRequest request)
           
 StreamRequestHandler handleFetchROPartitionFiles(VAdminProto.FetchPartitionFilesRequest request)
           
 VAdminProto.AsyncOperationStatusResponse handleFetchROStore(VAdminProto.FetchStoreRequest request)
           
 VAdminProto.GetMetadataResponse handleGetMetadata(VAdminProto.GetMetadataRequest request)
           
 VAdminProto.GetROCurrentVersionDirResponse handleGetROCurrentVersionDir(VAdminProto.GetROCurrentVersionDirRequest request)
           
 VAdminProto.GetROMaxVersionDirResponse handleGetROMaxVersionDir(VAdminProto.GetROMaxVersionDirRequest request)
           
 VAdminProto.GetROStorageFormatResponse handleGetROStorageFormat(VAdminProto.GetROStorageFormatRequest request)
           
 VAdminProto.AsyncOperationStatusResponse handleNativeBackup(VAdminProto.NativeBackupRequest request)
           
 VAdminProto.AsyncOperationStatusResponse handleRebalanceNode(VAdminProto.InitiateRebalanceNodeRequest request)
           
 VAdminProto.RebalanceStateChangeResponse handleRebalanceStateChange(VAdminProto.RebalanceStateChangeRequest request)
           
 VAdminProto.RepairJobResponse handleRepairJob(VAdminProto.RepairJobRequest request)
           
 StreamRequestHandler handleRequest(java.io.DataInputStream inputStream, java.io.DataOutputStream outputStream)
          Handles the request as determined by the protocol and command provided as input.
 VAdminProto.ReserveMemoryResponse handleReserveMemory(VAdminProto.ReserveMemoryRequest request)
           
 VAdminProto.RollbackStoreResponse handleRollbackStore(VAdminProto.RollbackStoreRequest request)
           
 VAdminProto.SwapStoreResponse handleSwapROStore(VAdminProto.SwapStoreRequest request)
           
 VAdminProto.TruncateEntriesResponse handleTruncateEntries(VAdminProto.TruncateEntriesRequest request)
           
 VAdminProto.UpdateMetadataResponse handleUpdateMetadata(VAdminProto.UpdateMetadataRequest request)
           
 StreamRequestHandler handleUpdatePartitionEntries(VAdminProto.UpdatePartitionEntriesRequest request)
           
 StreamRequestHandler handleUpdateSlopEntries(VAdminProto.UpdateSlopEntriesRequest request)
           
 boolean isCompleteRequest(java.nio.ByteBuffer buffer)
          This method is used by non-blocking code to determine if the give buffer represents a complete request.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AdminServiceRequestHandler

public AdminServiceRequestHandler(ErrorCodeMapper errorCodeMapper,
                                  StorageService storageService,
                                  StoreRepository storeRepository,
                                  MetadataStore metadataStore,
                                  VoldemortConfig voldemortConfig,
                                  AsyncOperationService asyncService,
                                  Rebalancer rebalancer)
Method Detail

handleRequest

public StreamRequestHandler handleRequest(java.io.DataInputStream inputStream,
                                          java.io.DataOutputStream outputStream)
                                   throws java.io.IOException
Description copied from interface: RequestHandler
Handles the request as determined by the protocol and command provided as input.

Specified by:
handleRequest in interface RequestHandler
Returns:
StreamRequestHandler if this is the beginning of a streaming request, null if self-contained
Throws:
java.io.IOException

handleRebalanceStateChange

public VAdminProto.RebalanceStateChangeResponse handleRebalanceStateChange(VAdminProto.RebalanceStateChangeRequest request)

handleRebalanceNode

public VAdminProto.AsyncOperationStatusResponse handleRebalanceNode(VAdminProto.InitiateRebalanceNodeRequest request)

handleGetROCurrentVersionDir

public VAdminProto.GetROCurrentVersionDirResponse handleGetROCurrentVersionDir(VAdminProto.GetROCurrentVersionDirRequest request)

handleGetROMaxVersionDir

public VAdminProto.GetROMaxVersionDirResponse handleGetROMaxVersionDir(VAdminProto.GetROMaxVersionDirRequest request)

handleGetROStorageFormat

public VAdminProto.GetROStorageFormatResponse handleGetROStorageFormat(VAdminProto.GetROStorageFormatRequest request)

handleFailedROFetch

public VAdminProto.FailedFetchStoreResponse handleFailedROFetch(VAdminProto.FailedFetchStoreRequest request)

handleFetchROPartitionFiles

public StreamRequestHandler handleFetchROPartitionFiles(VAdminProto.FetchPartitionFilesRequest request)

handleUpdateSlopEntries

public StreamRequestHandler handleUpdateSlopEntries(VAdminProto.UpdateSlopEntriesRequest request)

handleFetchPartitionEntries

public StreamRequestHandler handleFetchPartitionEntries(VAdminProto.FetchPartitionEntriesRequest request)

handleUpdatePartitionEntries

public StreamRequestHandler handleUpdatePartitionEntries(VAdminProto.UpdatePartitionEntriesRequest request)

handleAsyncOperationList

public VAdminProto.AsyncOperationListResponse handleAsyncOperationList(VAdminProto.AsyncOperationListRequest request)

handleAsyncOperationStop

public VAdminProto.AsyncOperationStopResponse handleAsyncOperationStop(VAdminProto.AsyncOperationStopRequest request)

handleRollbackStore

public VAdminProto.RollbackStoreResponse handleRollbackStore(VAdminProto.RollbackStoreRequest request)

handleRepairJob

public VAdminProto.RepairJobResponse handleRepairJob(VAdminProto.RepairJobRequest request)

handleSwapROStore

public VAdminProto.SwapStoreResponse handleSwapROStore(VAdminProto.SwapStoreRequest request)

handleFetchROStore

public VAdminProto.AsyncOperationStatusResponse handleFetchROStore(VAdminProto.FetchStoreRequest request)

handleFetchAndUpdate

public VAdminProto.AsyncOperationStatusResponse handleFetchAndUpdate(VAdminProto.InitiateFetchAndUpdateRequest request)

handleAsyncStatus

public VAdminProto.AsyncOperationStatusResponse handleAsyncStatus(VAdminProto.AsyncOperationStatusRequest request)

handleDeletePartitionEntries

public VAdminProto.DeletePartitionEntriesResponse handleDeletePartitionEntries(VAdminProto.DeletePartitionEntriesRequest request)

handleUpdateMetadata

public VAdminProto.UpdateMetadataResponse handleUpdateMetadata(VAdminProto.UpdateMetadataRequest request)

handleGetMetadata

public VAdminProto.GetMetadataResponse handleGetMetadata(VAdminProto.GetMetadataRequest request)

handleTruncateEntries

public VAdminProto.TruncateEntriesResponse handleTruncateEntries(VAdminProto.TruncateEntriesRequest request)

handleDeleteStore

public VAdminProto.DeleteStoreResponse handleDeleteStore(VAdminProto.DeleteStoreRequest request)

handleAddStore

public VAdminProto.AddStoreResponse handleAddStore(VAdminProto.AddStoreRequest request)

isCompleteRequest

public boolean isCompleteRequest(java.nio.ByteBuffer buffer)
This method is used by non-blocking code to determine if the give buffer represents a complete request. Because the non-blocking code can by definition not just block waiting for more data, it's possible to get partial reads, and this identifies that case.

Specified by:
isCompleteRequest in interface RequestHandler
Parameters:
buffer - Buffer to check; the buffer is reset to position 0 before calling this method and the caller must reset it after the call returns
Returns:
True if the buffer holds a complete request, false otherwise

handleNativeBackup

public VAdminProto.AsyncOperationStatusResponse handleNativeBackup(VAdminProto.NativeBackupRequest request)

handleReserveMemory

public VAdminProto.ReserveMemoryResponse handleReserveMemory(VAdminProto.ReserveMemoryRequest request)


Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu