org.apache.storm.security.auth

Interface ITransportPlugin

All Known Implementing Classes:

DigestSaslTransportPlugin, KerberosSaslTransportPlugin, PlainSaslTransportPlugin, SaslTransportPlugin, SimpleTransportPlugin, SingleUserSimpleTransport

public interface ITransportPlugin

Interface for Thrift Transport plugin

Method Summary

Modifier and Type	Method and Description
org.apache.thrift.transport.TTransport	connect(org.apache.thrift.transport.TTransport transport, String serverHost, String asUser) Connect to the specified server via framed transport
org.apache.thrift.server.TServer	getServer(org.apache.thrift.TProcessor processor) Create a server associated with a given port, service handler, and purpose
void	prepare(ThriftConnectionType type, Map storm_conf, Configuration login_conf) Invoked once immediately after construction

Method Detail

prepare

void prepare(ThriftConnectionType type,
             Map storm_conf,
             Configuration login_conf)

Invoked once immediately after construction

Parameters:

type - the type of connection this will process.

storm_conf - Storm configuration

login_conf - login configuration

getServer

org.apache.thrift.server.TServer getServer(org.apache.thrift.TProcessor processor)
                                    throws IOException,
                                           org.apache.thrift.transport.TTransportException

Create a server associated with a given port, service handler, and purpose

Parameters:

processor - service handler

Returns:

server

Throws:

IOException

org.apache.thrift.transport.TTransportException

connect

org.apache.thrift.transport.TTransport connect(org.apache.thrift.transport.TTransport transport,
                                               String serverHost,
                                               String asUser)
                                        throws IOException,
                                               org.apache.thrift.transport.TTransportException

Connect 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:

IOException

org.apache.thrift.transport.TTransportException