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 SummaryNested Classes
- 
Field SummaryFields
- 
Constructor SummaryConstructors
- 
Method SummaryModifier 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.Objectclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.storm.security.auth.ITransportPluginareWorkerTokensSupported, connect
- 
Field Details- 
type
- 
conf
 
- 
- 
Constructor Details- 
SaslTransportPluginpublic SaslTransportPlugin()
 
- 
- 
Method Details- 
prepareDescription copied from interface:ITransportPluginInvoked once immediately after construction.- Specified by:
- preparein interface- ITransportPlugin
- Parameters:
- type- the type of connection this will process.
- conf- Storm configuration
 
- 
getServerpublic 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 interface- ITransportPlugin
- Parameters:
- processor- service handler
- Returns:
- server
- Throws:
- IOException
- org.apache.storm.thrift.transport.TTransportException
 
- 
closepublic void close()- Specified by:
- closein interface- AutoCloseable
- Specified by:
- closein interface- Closeable
 
- 
getServerTransportFactoryprotected 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.
 
- 
getPortpublic int getPort()Description copied from interface:ITransportPluginGet port.- Specified by:
- getPortin interface- ITransportPlugin
- Returns:
- The port this transport is using. This is not known until
 ITransportPlugin.getServer(org.apache.storm.thrift.TProcessor)has been called
 
 
-