org.apache.storm.utils

Class NimbusClient

java.lang.Object

org.apache.storm.security.auth.ThriftClient

org.apache.storm.utils.NimbusClient

All Implemented Interfaces:

AutoCloseable

public class NimbusClient
extends ThriftClient

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	NimbusClient.WithNimbus

Field Summary

Fields inherited from class org.apache.storm.security.auth.ThriftClient

_protocol, _retryForever

Constructor Summary

Constructors

Constructor and Description
NimbusClient(Map conf, String host)
NimbusClient(Map conf, String host, int port)
NimbusClient(Map conf, String host, Integer port, Integer timeout, String asUser)
NimbusClient(Map conf, String host, int port, Integer timeout)

Method Summary

Modifier and Type	Method and Description
Nimbus.Client	getClient()
static NimbusClient	getConfiguredClient(Map conf)
static NimbusClient	getConfiguredClient(Map conf, Integer timeout)
static NimbusClient	getConfiguredClientAs(Map conf, String asUser)
static NimbusClient	getConfiguredClientAs(Map conf, String asUser, Integer timeout)
static void	withConfiguredClient(NimbusClient.WithNimbus cb)
static void	withConfiguredClient(NimbusClient.WithNimbus cb, Map conf)

Methods inherited from class org.apache.storm.security.auth.ThriftClient

close, reconnect, transport

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NimbusClient

public NimbusClient(Map conf,
                    String host,
                    int port)
             throws org.apache.thrift.transport.TTransportException

Throws:

org.apache.thrift.transport.TTransportException

NimbusClient

public NimbusClient(Map conf,
                    String host,
                    int port,
                    Integer timeout)
             throws org.apache.thrift.transport.TTransportException

Throws:

org.apache.thrift.transport.TTransportException

NimbusClient

public NimbusClient(Map conf,
                    String host,
                    Integer port,
                    Integer timeout,
                    String asUser)
             throws org.apache.thrift.transport.TTransportException

Throws:

org.apache.thrift.transport.TTransportException

NimbusClient

public NimbusClient(Map conf,
                    String host)
             throws org.apache.thrift.transport.TTransportException

Throws:

org.apache.thrift.transport.TTransportException

Method Detail

withConfiguredClient

public static void withConfiguredClient(NimbusClient.WithNimbus cb)
                                 throws Exception

Throws:

Exception

withConfiguredClient

public static void withConfiguredClient(NimbusClient.WithNimbus cb,
                                        Map conf)
                                 throws Exception

Throws:

Exception

getConfiguredClient

public static NimbusClient getConfiguredClient(Map conf)

getConfiguredClient

public static NimbusClient getConfiguredClient(Map conf,
                                               Integer timeout)

getConfiguredClientAs

public static NimbusClient getConfiguredClientAs(Map conf,
                                                 String asUser)

getConfiguredClientAs

public static NimbusClient getConfiguredClientAs(Map conf,
                                                 String asUser,
                                                 Integer timeout)

getClient

public Nimbus.Client getClient()