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
- 
Nested Class SummaryNested classes/interfaces inherited from class org.apache.storm.security.auth.sasl.SaslTransportPluginSaslTransportPlugin.User
- 
Field SummaryFieldsFields inherited from class org.apache.storm.security.auth.sasl.SaslTransportPluginconf, type
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionbooleanCheck if worker tokens are supported by this transport.voidclose()org.apache.storm.thrift.transport.TTransportConnect to the specified server via framed transport.protected org.apache.storm.thrift.transport.TTransportFactorygetServerTransportFactory(boolean impersonationAllowed) Create the transport factory needed for serving.Methods inherited from class org.apache.storm.security.auth.sasl.SaslTransportPlugingetPort, getServer, prepare
- 
Field Details- 
DIGEST- See Also:
 
 
- 
- 
Constructor Details- 
DigestSaslTransportPluginpublic DigestSaslTransportPlugin()
 
- 
- 
Method Details- 
getServerTransportFactoryprotected org.apache.storm.thrift.transport.TTransportFactory getServerTransportFactory(boolean impersonationAllowed) throws IOException Description copied from class:SaslTransportPluginCreate the transport factory needed for serving. All subclass must implement this method.- Specified by:
- getServerTransportFactoryin class- SaslTransportPlugin
- Parameters:
- impersonationAllowed- true if SASL impersonation should be allowed, else false.
- Returns:
- server transport factory
- Throws:
- IOException- on any error.
 
- 
connectpublic 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:ITransportPluginConnect 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
 
- 
areWorkerTokensSupportedpublic boolean areWorkerTokensSupported()Description copied from interface:ITransportPluginCheck if worker tokens are supported by this transport.- Returns:
- true if they are else false.
 
- 
closepublic void close()- Specified by:
- closein interface- AutoCloseable
- Specified by:
- closein interface- Closeable
- Overrides:
- closein class- SaslTransportPlugin
 
 
-