Package org.apache.hadoop.hbase

Class ShellExecEndpointCoprocessor

java.lang.Object
org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecService
org.apache.hadoop.hbase.ShellExecEndpointCoprocessor
All Implemented Interfaces:
com.google.protobuf.Service, org.apache.hadoop.hbase.Coprocessor, org.apache.hadoop.hbase.coprocessor.MasterCoprocessor, org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessor
@Private public class ShellExecEndpointCoprocessor extends org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecService implements org.apache.hadoop.hbase.coprocessor.MasterCoprocessor, org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessor
Receives shell commands from the client and executes them blindly. Intended only for use by ChaosMonkey via CoprocClusterManager

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecService

    org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecService.BlockingInterface, org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecService.Interface, org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecService.Stub

    Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.Coprocessor

    org.apache.hadoop.hbase.Coprocessor.State

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final String
    BACKGROUND_DELAY_MS_KEY
     
    private final ExecutorService
    backgroundExecutor
     
    private org.apache.hadoop.conf.Configuration
    conf
     
    static final long
    DEFAULT_BACKGROUND_DELAY_MS
     
    private static final org.slf4j.Logger
    LOG
     

    Fields inherited from interface org.apache.hadoop.hbase.Coprocessor

    PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

  • Constructor Summary

    Constructors
    Constructor
    Description
    ShellExecEndpointCoprocessor()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    private void
    doExec(org.apache.hadoop.util.Shell.ShellCommandExecutor shell, org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecResponse.Builder builder)
    Execute shell and collect results into builder as side-effects.
    Iterable<com.google.protobuf.Service>
    getServices()
     
    private void
    runBackgroundTask(org.apache.hadoop.util.Shell.ShellCommandExecutor shell, com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecResponse> done)
     
    private void
    runForegroundTask(org.apache.hadoop.util.Shell.ShellCommandExecutor shell, com.google.protobuf.RpcController controller, com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecResponse> done)
     
    void
    shellExec(com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecRequest request, com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecResponse> done)
     
    void
    start(org.apache.hadoop.hbase.CoprocessorEnvironment env)
     

    Methods inherited from class org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecService

    callMethod, getDescriptor, getDescriptorForType, getRequestPrototype, getResponsePrototype, newBlockingStub, newReflectiveBlockingService, newReflectiveService, newStub

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.apache.hadoop.hbase.Coprocessor

    stop

    Methods inherited from interface org.apache.hadoop.hbase.coprocessor.MasterCoprocessor

    getMasterObserver

    Methods inherited from interface org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessor

    getRegionServerObserver

  • Field Details

  • Constructor Details

  • Method Details

    • getServices

      public Iterable<com.google.protobuf.Service> getServices()
      Specified by:
      getServices in interface org.apache.hadoop.hbase.Coprocessor

    • start

      public void start(org.apache.hadoop.hbase.CoprocessorEnvironment env)
      Specified by:
      start in interface org.apache.hadoop.hbase.Coprocessor

    • shellExec

      public void shellExec(com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecRequest request, com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecResponse> done)
      Specified by:
      shellExec in class org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecService

    • runForegroundTask

      private void runForegroundTask(org.apache.hadoop.util.Shell.ShellCommandExecutor shell, com.google.protobuf.RpcController controller, com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecResponse> done)

    • runBackgroundTask

      private void runBackgroundTask(org.apache.hadoop.util.Shell.ShellCommandExecutor shell, com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecResponse> done)

    • doExec

      private void doExec(org.apache.hadoop.util.Shell.ShellCommandExecutor shell, org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecResponse.Builder builder) throws IOException
      Execute shell and collect results into builder as side-effects.
      Throws:
      IOException