io.druid.security.basic.authentication.db.cache

Class CoordinatorPollingBasicAuthenticatorCacheManager

java.lang.Object

io.druid.security.basic.authentication.db.cache.CoordinatorPollingBasicAuthenticatorCacheManager

All Implemented Interfaces:

BasicAuthenticatorCacheManager

public class CoordinatorPollingBasicAuthenticatorCacheManager
extends Object
implements BasicAuthenticatorCacheManager

Cache manager for non-coordinator services that polls the coordinator for authentication database state.

Constructor Summary

Constructors

Constructor and Description
CoordinatorPollingBasicAuthenticatorCacheManager(com.google.inject.Injector injector, BasicAuthCommonCacheConfig commonCacheConfig, com.fasterxml.jackson.databind.ObjectMapper objectMapper, DruidLeaderClient druidLeaderClient)

Method Summary

Modifier and Type	Method and Description
Map<String,BasicAuthenticatorUser>	getUserMap(String authenticatorPrefix) Return the cache manager's local view of the user map for the authenticator named `authenticatorPrefix`.
void	handleAuthenticatorUpdate(String authenticatorPrefix, byte[] serializedUserMap) Update this cache manager's local state with fresh information pushed by the coordinator.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

CoordinatorPollingBasicAuthenticatorCacheManager

@Inject
public CoordinatorPollingBasicAuthenticatorCacheManager(com.google.inject.Injector injector,
                                                                BasicAuthCommonCacheConfig commonCacheConfig,
                                                                com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                                                DruidLeaderClient druidLeaderClient)

Method Detail

start

public void start()

stop

public void stop()

handleAuthenticatorUpdate

public void handleAuthenticatorUpdate(String authenticatorPrefix,
                                      byte[] serializedUserMap)

Description copied from interface: BasicAuthenticatorCacheManager

Update this cache manager's local state with fresh information pushed by the coordinator.

Specified by:

handleAuthenticatorUpdate in interface BasicAuthenticatorCacheManager

Parameters:

authenticatorPrefix - The name of the authenticator this update applies to.

serializedUserMap - The updated, serialized user map

getUserMap

public Map<String,BasicAuthenticatorUser> getUserMap(String authenticatorPrefix)

Description copied from interface: BasicAuthenticatorCacheManager

Return the cache manager's local view of the user map for the authenticator named `authenticatorPrefix`.

Specified by:

getUserMap in interface BasicAuthenticatorCacheManager

Parameters:

authenticatorPrefix - The name of the authenticator

Returns:

User map