Package | Description |
---|---|
org.apache.storm.cluster | |
org.apache.storm.generated | |
org.apache.storm.security.auth | |
org.apache.storm.security.auth.workertoken |
Modifier and Type | Method and Description |
---|---|
void |
StormClusterStateImpl.addPrivateWorkerKey(WorkerTokenServiceType type,
String topologyId,
long keyVersion,
PrivateWorkerKey key) |
void |
IStormClusterState.addPrivateWorkerKey(WorkerTokenServiceType type,
String topologyId,
long keyVersion,
PrivateWorkerKey key)
Store a new version of a private key.
|
long |
StormClusterStateImpl.getNextPrivateWorkerKeyVersion(WorkerTokenServiceType type,
String topologyId) |
long |
IStormClusterState.getNextPrivateWorkerKeyVersion(WorkerTokenServiceType type,
String topologyId)
Get the next key version number that should be used for this topology id.
|
PrivateWorkerKey |
StormClusterStateImpl.getPrivateWorkerKey(WorkerTokenServiceType type,
String topologyId,
long keyVersion) |
PrivateWorkerKey |
IStormClusterState.getPrivateWorkerKey(WorkerTokenServiceType type,
String topologyId,
long keyVersion)
Get a private key used to validate a token is correct.
|
List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> |
ClusterStateContext.getZkSecretAcls(WorkerTokenServiceType type) |
List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> |
DaemonType.getZkSecretAcls(WorkerTokenServiceType type,
Map<String,Object> conf)
Get the ACLs to store a secret for a given service.
|
static String |
ClusterUtils.secretKeysPath(WorkerTokenServiceType type)
Get the base path where secret keys are stored for a given service.
|
static String |
ClusterUtils.secretKeysPath(WorkerTokenServiceType type,
String topologyId)
Get the path to secret keys for a specific topology.
|
static String |
ClusterUtils.secretKeysPath(WorkerTokenServiceType type,
String topologyId,
long version)
Get the path to a specific secret key.
|
Modifier and Type | Method and Description |
---|---|
static WorkerTokenServiceType |
WorkerTokenServiceType.findByValue(int value)
Find a the enum type by its integer value, as defined in the Thrift IDL.
|
WorkerTokenServiceType |
WorkerToken.get_serviceType() |
static WorkerTokenServiceType |
WorkerTokenServiceType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static WorkerTokenServiceType[] |
WorkerTokenServiceType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
void |
WorkerToken.set_serviceType(WorkerTokenServiceType serviceType) |
Constructor and Description |
---|
WorkerToken(WorkerTokenServiceType serviceType,
ByteBuffer info,
ByteBuffer signature) |
Modifier and Type | Method and Description |
---|---|
WorkerTokenServiceType |
ThriftConnectionType.getWtType()
Get the corresponding worker token type for this thrift connection.
|
Modifier and Type | Method and Description |
---|---|
static WorkerToken |
ClientAuthUtils.findWorkerToken(Subject subject,
WorkerTokenServiceType type)
Find a worker token in a given subject with a given token type.
|
static WorkerToken |
ClientAuthUtils.readWorkerToken(Map<String,String> credentials,
WorkerTokenServiceType type)
Read a WorkerToken out of credentials for the given type.
|
static String |
ClientAuthUtils.workerTokenCredentialsKey(WorkerTokenServiceType type)
Get the key used to store a WorkerToken in the credentials map.
|
Modifier and Type | Method and Description |
---|---|
WorkerToken |
WorkerTokenManager.createOrUpdateTokenFor(WorkerTokenServiceType serviceType,
String user,
String topologyId)
Create or update an existing key.
|
boolean |
WorkerTokenManager.shouldRenewWorkerToken(Map<String,String> creds,
WorkerTokenServiceType type) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.