Class DigestSaslTransportPlugin

java.lang.Object
org.apache.storm.security.auth.sasl.SaslTransportPlugin
org.apache.storm.security.auth.digest.DigestSaslTransportPlugin
All Implemented Interfaces:
Closeable, AutoCloseable, ITransportPlugin

public class DigestSaslTransportPlugin extends SaslTransportPlugin
  • Field Details

  • Constructor Details

    • DigestSaslTransportPlugin

      public DigestSaslTransportPlugin()
  • Method Details

    • getServerTransportFactory

      protected org.apache.storm.thrift.transport.TTransportFactory getServerTransportFactory(boolean impersonationAllowed) throws IOException
      Description copied from class: SaslTransportPlugin
      Create the transport factory needed for serving. All subclass must implement this method.
      Specified by:
      getServerTransportFactory in class SaslTransportPlugin
      Parameters:
      impersonationAllowed - true if SASL impersonation should be allowed, else false.
      Returns:
      server transport factory
      Throws:
      IOException - on any error.
    • connect

      public org.apache.storm.thrift.transport.TTransport connect(org.apache.storm.thrift.transport.TTransport transport, String serverHost, String asUser) throws org.apache.storm.thrift.transport.TTransportException, IOException
      Description copied from interface: ITransportPlugin
      Connect to the specified server via framed transport.
      Parameters:
      transport - The underlying Thrift transport.
      serverHost - server host
      asUser - the user as which the connection should be established, and all the subsequent actions should be executed. Only applicable when using secure storm cluster. A null/blank value here will just indicate to use the logged in user.
      Throws:
      org.apache.storm.thrift.transport.TTransportException
      IOException
    • areWorkerTokensSupported

      public boolean areWorkerTokensSupported()
      Description copied from interface: ITransportPlugin
      Check if worker tokens are supported by this transport.
      Returns:
      true if they are else false.
    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Overrides:
      close in class SaslTransportPlugin