public class AutoElasticsearch extends Object implements org.apache.storm.security.auth.IAutoCredentials, org.apache.storm.security.auth.ICredentialsRenewer, org.apache.storm.security.INimbusCredentialPlugin
| Modifier and Type | Field and Description |
|---|---|
static String |
USER_KEYTAB |
static String |
USER_PRINCIPAL |
| Constructor and Description |
|---|
AutoElasticsearch() |
| Modifier and Type | Method and Description |
|---|---|
void |
populateCredentials(Map<String,String> credentials) |
void |
populateCredentials(Map<String,String> credentials,
Map topologyConfiguration)
Deprecated.
This is available for any storm cluster that operates against the older method of obtaining credentials
|
void |
populateCredentials(Map<String,String> credentials,
Map<String,Object> topologyConfiguration,
String topologyOwnerPrincipal) |
void |
populateSubject(Subject subject,
Map<String,String> credentials) |
void |
prepare(Map stormClusterConfiguration) |
void |
renew(Map<String,String> credentials,
Map topologyConf)
Deprecated.
This is available for any storm cluster that operates against the older method of credential renewal
|
void |
renew(Map<String,String> credentials,
Map<String,Object> topologyConf,
String topologyOwnerPrincipal) |
void |
shutdown() |
void |
updateSubject(Subject subject,
Map<String,String> credentials) |
public static final String USER_PRINCIPAL
public static final String USER_KEYTAB
public void prepare(Map stormClusterConfiguration)
prepare in interface org.apache.storm.security.auth.IAutoCredentialsprepare in interface org.apache.storm.security.auth.ICredentialsRenewerprepare in interface org.apache.storm.security.INimbusCredentialPluginpublic void populateCredentials(Map<String,String> credentials, Map topologyConfiguration)
populateCredentials in interface org.apache.storm.security.INimbusCredentialPluginpublic void populateCredentials(Map<String,String> credentials, Map<String,Object> topologyConfiguration, String topologyOwnerPrincipal)
populateCredentials in interface org.apache.storm.security.INimbusCredentialPluginpublic void shutdown()
shutdown in interface org.apache.storm.daemon.Shutdownablepublic void renew(Map<String,String> credentials, Map topologyConf)
renew in interface org.apache.storm.security.auth.ICredentialsRenewerpublic void renew(Map<String,String> credentials, Map<String,Object> topologyConf, String topologyOwnerPrincipal)
renew in interface org.apache.storm.security.auth.ICredentialsRenewerpublic void populateCredentials(Map<String,String> credentials)
populateCredentials in interface org.apache.storm.security.auth.IAutoCredentialspublic void populateSubject(Subject subject, Map<String,String> credentials)
populateSubject in interface org.apache.storm.security.auth.IAutoCredentials