org.apache.ranger.services.storm.client

Class StormClient

java.lang.Object

org.apache.ranger.services.storm.client.StormClient

public class StormClient
extends Object

Constructor Summary

Constructors

Constructor and Description
StormClient(String aStormUIUrl, String aUserName, String aPassword, String lookupPrincipal, String lookupKeytab, String nameRules)

Method Summary

Modifier and Type	Method and Description
static Map<String,Object>	connectionTest(String serviceName, Map<String,String> configs)
static <T> T	executeUnderKerberos(String userName, String password, String lookupPrincipal, String lookupKeytab, String nameRules, PrivilegedExceptionAction<T> action)
static StormClient	getStormClient(String serviceName, Map<String,String> configs)
static List<String>	getStormResources(StormClient stormClient, String topologyName, List<String> stormTopologyList)
List<String>	getTopologyList(String topologyNameMatching, List<String> stormTopologyList)

Methods inherited from class java.lang.Object

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

Constructor Detail

StormClient

public StormClient(String aStormUIUrl,
                   String aUserName,
                   String aPassword,
                   String lookupPrincipal,
                   String lookupKeytab,
                   String nameRules)

Method Detail

getTopologyList

public List<String> getTopologyList(String topologyNameMatching,
                                    List<String> stormTopologyList)

executeUnderKerberos

public static <T> T executeUnderKerberos(String userName,
                                         String password,
                                         String lookupPrincipal,
                                         String lookupKeytab,
                                         String nameRules,
                                         PrivilegedExceptionAction<T> action)
                                  throws IOException

Throws:

IOException

connectionTest

public static Map<String,Object> connectionTest(String serviceName,
                                                Map<String,String> configs)

getStormClient

public static StormClient getStormClient(String serviceName,
                                         Map<String,String> configs)

getStormResources

public static List<String> getStormResources(StormClient stormClient,
                                             String topologyName,
                                             List<String> stormTopologyList)