Package org.apache.hadoop.yarn.csi.adaptor

Class CsiAdaptorProtocolService

java.lang.Object
org.apache.hadoop.service.AbstractService
org.apache.hadoop.yarn.csi.adaptor.CsiAdaptorProtocolService
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.service.Service, org.apache.hadoop.yarn.api.CsiAdaptorProtocol
public class CsiAdaptorProtocolService extends org.apache.hadoop.service.AbstractService implements org.apache.hadoop.yarn.api.CsiAdaptorProtocol
This is a Hadoop RPC server, we uses the Hadoop RPC framework here because we need to stick to the security model current Hadoop supports.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

    org.apache.hadoop.service.Service.STATE

  • Constructor Summary

    Constructors
    Constructor
    Description
    CsiAdaptorProtocolService(org.apache.hadoop.yarn.api.CsiAdaptorPlugin adaptorImpl)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.hadoop.yarn.api.protocolrecords.GetPluginInfoResponse
    getPluginInfo(org.apache.hadoop.yarn.api.protocolrecords.GetPluginInfoRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.NodePublishVolumeResponse
    nodePublishVolume(org.apache.hadoop.yarn.api.protocolrecords.NodePublishVolumeRequest request)
     
    org.apache.hadoop.yarn.api.protocolrecords.NodeUnpublishVolumeResponse
    nodeUnpublishVolume(org.apache.hadoop.yarn.api.protocolrecords.NodeUnpublishVolumeRequest request)
     
    protected void
    serviceInit(org.apache.hadoop.conf.Configuration conf)
     
    protected void
    serviceStart()
     
    protected void
    serviceStop()
     
    org.apache.hadoop.yarn.api.protocolrecords.ValidateVolumeCapabilitiesResponse
    validateVolumeCapacity(org.apache.hadoop.yarn.api.protocolrecords.ValidateVolumeCapabilitiesRequest request)
     

    Methods inherited from class org.apache.hadoop.service.AbstractService

    close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • CsiAdaptorProtocolService

      public CsiAdaptorProtocolService(org.apache.hadoop.yarn.api.CsiAdaptorPlugin adaptorImpl)

  • Method Details

    • serviceInit

      protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
      Overrides:
      serviceInit in class org.apache.hadoop.service.AbstractService
      Throws:
      Exception

    • serviceStart

      protected void serviceStart() throws Exception
      Overrides:
      serviceStart in class org.apache.hadoop.service.AbstractService
      Throws:
      Exception

    • serviceStop

      protected void serviceStop() throws Exception
      Overrides:
      serviceStop in class org.apache.hadoop.service.AbstractService
      Throws:
      Exception

    • getPluginInfo

      public org.apache.hadoop.yarn.api.protocolrecords.GetPluginInfoResponse getPluginInfo(org.apache.hadoop.yarn.api.protocolrecords.GetPluginInfoRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      getPluginInfo in interface org.apache.hadoop.yarn.api.CsiAdaptorProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • validateVolumeCapacity

      public org.apache.hadoop.yarn.api.protocolrecords.ValidateVolumeCapabilitiesResponse validateVolumeCapacity(org.apache.hadoop.yarn.api.protocolrecords.ValidateVolumeCapabilitiesRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      validateVolumeCapacity in interface org.apache.hadoop.yarn.api.CsiAdaptorProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • nodePublishVolume

      public org.apache.hadoop.yarn.api.protocolrecords.NodePublishVolumeResponse nodePublishVolume(org.apache.hadoop.yarn.api.protocolrecords.NodePublishVolumeRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      nodePublishVolume in interface org.apache.hadoop.yarn.api.CsiAdaptorProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • nodeUnpublishVolume

      public org.apache.hadoop.yarn.api.protocolrecords.NodeUnpublishVolumeResponse nodeUnpublishVolume(org.apache.hadoop.yarn.api.protocolrecords.NodeUnpublishVolumeRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      nodeUnpublishVolume in interface org.apache.hadoop.yarn.api.CsiAdaptorProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException