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
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
int
getPort()
Get port.org.apache.storm.thrift.server.TServer
getServer
(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.TTransportFactory
getServerTransportFactory
(boolean impersonationAllowed) Create the transport factory needed for serving.void
prepare
(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, wait
Methods 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:ITransportPlugin
Invoked once immediately after construction.- Specified by:
prepare
in 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:ITransportPlugin
Create a server associated with a given port, service handler, and purpose.- Specified by:
getServer
in interfaceITransportPlugin
- Parameters:
processor
- service handler- Returns:
- server
- Throws:
IOException
org.apache.storm.thrift.transport.TTransportException
-
close
public void close()- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in 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:ITransportPlugin
Get port.- Specified by:
getPort
in interfaceITransportPlugin
- Returns:
- The port this transport is using. This is not known until
ITransportPlugin.getServer(org.apache.storm.thrift.TProcessor)
has been called
-