c
org.apache.kyuubi.service.authentication
KyuubiDelegationTokenManager
Companion object KyuubiDelegationTokenManager
case class KyuubiDelegationTokenManager(keyUpdateInterval: Long, tokenMaxLifetime: Long, tokenRenewInterval: Long, tokenRemoverScanInterval: Long) extends AbstractDelegationTokenSecretManager[KyuubiDelegationTokenIdentifier] with Product with Serializable
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- KyuubiDelegationTokenManager
- Serializable
- Serializable
- Product
- Equals
- AbstractDelegationTokenSecretManager
- SecretManager
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new KyuubiDelegationTokenManager(keyUpdateInterval: Long, tokenMaxLifetime: Long, tokenRenewInterval: Long, tokenRemoverScanInterval: Long)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
addKey(arg0: DelegationKey): Unit
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( classOf[java.io.IOException] )
-
def
addPersistedDelegationToken(arg0: KyuubiDelegationTokenIdentifier, arg1: Long): Unit
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( classOf[java.io.IOException] )
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
cancelToken(arg0: Token[KyuubiDelegationTokenIdentifier], arg1: String): KyuubiDelegationTokenIdentifier
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( classOf[java.io.IOException] )
-
def
checkAvailableForRead(): Unit
- Definition Classes
- SecretManager
- Annotations
- @throws( ... )
-
def
checkToken(arg0: KyuubiDelegationTokenIdentifier): DelegationTokenInformation
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( ... )
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
def
createIdentifier(): KyuubiDelegationTokenIdentifier
- Definition Classes
- KyuubiDelegationTokenManager → SecretManager
-
def
createPassword(arg0: KyuubiDelegationTokenIdentifier): Array[Byte]
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager → SecretManager
-
def
decodeTokenIdentifier(arg0: Token[KyuubiDelegationTokenIdentifier]): KyuubiDelegationTokenIdentifier
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( classOf[java.io.IOException] )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
generateSecret(): SecretKey
- Attributes
- protected[token]
- Definition Classes
- SecretManager
-
def
getAllKeys(): Array[DelegationKey]
- Definition Classes
- AbstractDelegationTokenSecretManager
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
getCurrentKeyId(): Int
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
-
def
getCurrentTokensSize(): Long
- Definition Classes
- AbstractDelegationTokenSecretManager
-
def
getDelegationKey(arg0: Int): DelegationKey
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
-
def
getDelegationTokenSeqNum(): Int
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
-
def
getMetrics(): DelegationTokenSecretManagerMetrics
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
-
def
getTokenInfo(arg0: KyuubiDelegationTokenIdentifier): DelegationTokenInformation
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
-
def
getTokenTrackingId(arg0: KyuubiDelegationTokenIdentifier): String
- Definition Classes
- AbstractDelegationTokenSecretManager
-
def
getTrackingIdIfEnabled(arg0: KyuubiDelegationTokenIdentifier): String
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
-
def
incrementCurrentKeyId(): Int
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
-
def
incrementDelegationTokenSeqNum(): Int
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
isRunning(): Boolean
- Definition Classes
- AbstractDelegationTokenSecretManager
- val keyUpdateInterval: Long
-
def
logExpireToken(arg0: KyuubiDelegationTokenIdentifier): Unit
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( classOf[java.io.IOException] )
-
def
logExpireTokens(arg0: Collection[KyuubiDelegationTokenIdentifier]): Unit
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( classOf[java.io.IOException] )
-
def
logUpdateMasterKey(arg0: DelegationKey): Unit
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( classOf[java.io.IOException] )
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
removeStoredMasterKey(arg0: DelegationKey): Unit
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
-
def
removeStoredToken(arg0: KyuubiDelegationTokenIdentifier): Unit
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( classOf[java.io.IOException] )
-
def
renewToken(arg0: Token[KyuubiDelegationTokenIdentifier], arg1: String): Long
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( ... ) @throws( classOf[java.io.IOException] )
-
def
reset(): Unit
- Definition Classes
- AbstractDelegationTokenSecretManager
-
def
retriableRetrievePassword(arg0: KyuubiDelegationTokenIdentifier): Array[Byte]
- Definition Classes
- SecretManager
- Annotations
- @throws( ... ) @throws( ... ) @throws( ... ) @throws( classOf[java.io.IOException] )
-
def
retrievePassword(arg0: KyuubiDelegationTokenIdentifier): Array[Byte]
- Definition Classes
- AbstractDelegationTokenSecretManager → SecretManager
- Annotations
- @throws( ... )
-
def
rollMasterKey(): Unit
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( classOf[java.io.IOException] )
-
def
setCurrentKeyId(arg0: Int): Unit
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
-
def
setDelegationTokenSeqNum(arg0: Int): Unit
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
-
def
startThreads(): Unit
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( classOf[java.io.IOException] )
-
def
stopThreads(): Unit
- Definition Classes
- AbstractDelegationTokenSecretManager
-
def
storeDelegationKey(arg0: DelegationKey): Unit
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( classOf[java.io.IOException] )
-
def
storeNewMasterKey(arg0: DelegationKey): Unit
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( classOf[java.io.IOException] )
-
def
storeNewToken(arg0: KyuubiDelegationTokenIdentifier, arg1: Long): Unit
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( classOf[java.io.IOException] )
-
def
storeToken(arg0: KyuubiDelegationTokenIdentifier, arg1: DelegationTokenInformation): Unit
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( classOf[java.io.IOException] )
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
- val tokenMaxLifetime: Long
- val tokenRemoverScanInterval: Long
- val tokenRenewInterval: Long
-
def
updateDelegationKey(arg0: DelegationKey): Unit
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( classOf[java.io.IOException] )
-
def
updateStoredToken(arg0: KyuubiDelegationTokenIdentifier, arg1: Long): Unit
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( classOf[java.io.IOException] )
-
def
updateToken(arg0: KyuubiDelegationTokenIdentifier, arg1: DelegationTokenInformation): Unit
- Attributes
- protected[delegation]
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( classOf[java.io.IOException] )
-
def
verifyToken(arg0: KyuubiDelegationTokenIdentifier, arg1: Array[Byte]): Unit
- Definition Classes
- AbstractDelegationTokenSecretManager
- Annotations
- @throws( ... )
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()