Class SaslTransportPlugin
java.lang.Object
org.apache.storm.security.auth.sasl.SaslTransportPlugin
- All Implemented Interfaces:
Closeable,AutoCloseable,ITransportPlugin
- Direct Known Subclasses:
DigestSaslTransportPlugin,KerberosSaslTransportPlugin,PlainSaslTransportPlugin
Base class for SASL authentication plugin.
-
Nested Class Summary
Nested Classes -
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()intgetPort()Get port.org.apache.storm.thrift.server.TServergetServer(org.apache.storm.thrift.TProcessor processor) Create a server associated with a given port, service handler, and purpose.protected abstract org.apache.storm.thrift.transport.TTransportFactorygetServerTransportFactory(boolean impersonationAllowed) Create the transport factory needed for serving.voidprepare(ThriftConnectionType type, Map<String, Object> conf) Invoked once immediately after construction.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.storm.security.auth.ITransportPlugin
areWorkerTokensSupported, connect
-
Field Details
-
type
-
conf
-
-
Constructor Details
-
SaslTransportPlugin
public SaslTransportPlugin()
-
-
Method Details
-
prepare
Description copied from interface:ITransportPluginInvoked once immediately after construction.- Specified by:
preparein interfaceITransportPlugin- Parameters:
type- the type of connection this will process.conf- Storm configuration
-
getServer
public org.apache.storm.thrift.server.TServer getServer(org.apache.storm.thrift.TProcessor processor) throws IOException, org.apache.storm.thrift.transport.TTransportException Description copied from interface:ITransportPluginCreate a server associated with a given port, service handler, and purpose.- Specified by:
getServerin interfaceITransportPlugin- Parameters:
processor- service handler- Returns:
- server
- Throws:
IOExceptionorg.apache.storm.thrift.transport.TTransportException
-
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable
-
getServerTransportFactory
protected abstract org.apache.storm.thrift.transport.TTransportFactory getServerTransportFactory(boolean impersonationAllowed) throws IOException Create the transport factory needed for serving. All subclass must implement this method.- Parameters:
impersonationAllowed- true if SASL impersonation should be allowed, else false.- Returns:
- server transport factory
- Throws:
IOException- on any error.
-
getPort
public int getPort()Description copied from interface:ITransportPluginGet port.- Specified by:
getPortin interfaceITransportPlugin- Returns:
- The port this transport is using. This is not known until
ITransportPlugin.getServer(org.apache.storm.thrift.TProcessor)has been called
-