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 Summary
Nested classes/interfaces inherited from class org.apache.storm.security.auth.sasl.SaslTransportPlugin
SaslTransportPlugin.User
-
Field Summary
Fields inherited from class org.apache.storm.security.auth.sasl.SaslTransportPlugin
conf, type
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionboolean
Check if worker tokens are supported by this transport.void
close()
org.apache.storm.thrift.transport.TTransport
Connect to the specified server via framed transport.protected org.apache.storm.thrift.transport.TTransportFactory
getServerTransportFactory
(boolean impersonationAllowed) Create the transport factory needed for serving.Methods inherited from class org.apache.storm.security.auth.sasl.SaslTransportPlugin
getPort, getServer, prepare
-
Field Details
-
DIGEST
- See Also:
-
-
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 classSaslTransportPlugin
- 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 hostasUser
- 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 interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Overrides:
close
in classSaslTransportPlugin
-