org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProviderFactory クラス

org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProviderFactory の継承関係図

org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProviderFactory 連携図

クラス
class	SessionAndKeyHolder

公開メンバ関数
PublicKeyStorageProvider	create (KeycloakSession session)
void	init (Config.Scope config)
void	postInit (KeycloakSessionFactory factory)
void	close ()
String	getId ()
default int	order ()

静的公開変数類
static final String	PROVIDER_ID = "infinispan"
static final String	KEYS_CLEAR_CACHE_EVENTS = "KEYS_CLEAR_CACHE_EVENTS"
static final String	PUBLIC_KEY_STORAGE_INVALIDATION_EVENT = "PUBLIC_KEY_STORAGE_INVALIDATION_EVENT"

非公開メンバ関数
void	lazyInit (KeycloakSession session)
SessionAndKeyHolder	getCacheKeyToInvalidate (ProviderEvent event)

非公開変数類
volatile Cache< String, PublicKeysEntry >	keysCache
final Map< String, FutureTask< PublicKeysEntry > >	tasksInProgress = new ConcurrentHashMap<>()
int	minTimeBetweenRequests

静的非公開変数類
static final Logger	log = Logger.getLogger(InfinispanPublicKeyStorageProviderFactory.class)

詳解

著者

Marek Posolda

関数詳解

close()

void org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProviderFactory.close ( )

inline

org.keycloak.provider.ProviderFactory< T extends Provider >を実装しています。

                        {

    }

create()

PublicKeyStorageProvider org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProviderFactory.create ( KeycloakSession  session )

inline

org.keycloak.provider.ProviderFactory< T extends Provider >を実装しています。

                                                                    {
        lazyInit(session);
        return new InfinispanPublicKeyStorageProvider(session, keysCache, tasksInProgress, minTimeBetweenRequests);
    }

getCacheKeyToInvalidate()

SessionAndKeyHolder org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProviderFactory.getCacheKeyToInvalidate ( ProviderEvent  event )

inlineprivate

                                                                             {
        if (event instanceof RealmModel.ClientUpdatedEvent) {
            RealmModel.ClientUpdatedEvent eventt = (RealmModel.ClientUpdatedEvent) event;
            String cacheKey = PublicKeyStorageUtils.getClientModelCacheKey(eventt.getUpdatedClient().getRealm().getId(), eventt.getUpdatedClient().getId());
            return new SessionAndKeyHolder(eventt.getKeycloakSession(), cacheKey);
        } else if (event instanceof RealmModel.ClientRemovedEvent) {
            RealmModel.ClientRemovedEvent eventt = (RealmModel.ClientRemovedEvent) event;
            String cacheKey = PublicKeyStorageUtils.getClientModelCacheKey(eventt.getClient().getRealm().getId(), eventt.getClient().getId());
            return new SessionAndKeyHolder(eventt.getKeycloakSession(), cacheKey);
        } else if (event instanceof RealmModel.IdentityProviderUpdatedEvent) {
            RealmModel.IdentityProviderUpdatedEvent eventt = (RealmModel.IdentityProviderUpdatedEvent) event;
            String cacheKey = PublicKeyStorageUtils.getIdpModelCacheKey(eventt.getRealm().getId(), eventt.getUpdatedIdentityProvider().getInternalId());
            return new SessionAndKeyHolder(eventt.getKeycloakSession(), cacheKey);
        } else if (event instanceof RealmModel.IdentityProviderRemovedEvent) {
            RealmModel.IdentityProviderRemovedEvent eventt = (RealmModel.IdentityProviderRemovedEvent) event;
            String cacheKey = PublicKeyStorageUtils.getIdpModelCacheKey(eventt.getRealm().getId(), eventt.getRemovedIdentityProvider().getInternalId());
            return new SessionAndKeyHolder(eventt.getKeycloakSession(), cacheKey);
        } else {
            return null;
        }
    }

getId()

String org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProviderFactory.getId ( )

inline

org.keycloak.provider.ProviderFactory< T extends Provider >を実装しています。

                          {
        return PROVIDER_ID;
    }

init()

void org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProviderFactory.init ( Config.Scope  config )

inline

org.keycloak.provider.ProviderFactory< T extends Provider >を実装しています。

                                          {
        minTimeBetweenRequests = config.getInt("minTimeBetweenRequests", 10);
        log.debugf("minTimeBetweenRequests is %d", minTimeBetweenRequests);
    }

lazyInit()

void org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProviderFactory.lazyInit ( KeycloakSession  session )

inlineprivate

                                                   {
        if (keysCache == null) {
            synchronized (this) {
                if (keysCache == null) {
                    this.keysCache = session.getProvider(InfinispanConnectionProvider.class).getCache(InfinispanConnectionProvider.KEYS_CACHE_NAME);

                    ClusterProvider cluster = session.getProvider(ClusterProvider.class);
                    cluster.registerListener(PUBLIC_KEY_STORAGE_INVALIDATION_EVENT, (ClusterEvent event) -> {

                        PublicKeyStorageInvalidationEvent invalidationEvent = (PublicKeyStorageInvalidationEvent) event;
                        keysCache.remove(invalidationEvent.getCacheKey());

                    });

                    cluster.registerListener(KEYS_CLEAR_CACHE_EVENTS, (ClusterEvent event) -> {

                        keysCache.clear();

                    });
                }
            }
        }
    }

order()

default int org.keycloak.provider.ProviderFactory< T extends Provider >.order ( )

inlineinherited

org.keycloak.protocol.docker.DockerAuthV2ProtocolFactory, org.keycloak.urls.HostnameProviderFactory, org.keycloak.protocol.oidc.ext.OIDCExtProviderFactoryで実装されています。

                        {
        return 0;
    }

postInit()

void org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProviderFactory.postInit ( KeycloakSessionFactory  factory )

inline

org.keycloak.provider.ProviderFactory< T extends Provider >を実装しています。

                                                         {
        factory.register(new ProviderEventListener() {

            @Override
            public void onEvent(ProviderEvent event) {
                if (keysCache == null) {
                    return;
                }

                SessionAndKeyHolder cacheKey = getCacheKeyToInvalidate(event);
                if (cacheKey != null) {
                    log.debugf("Invalidating %s from keysCache", cacheKey);
                    InfinispanPublicKeyStorageProvider provider = (InfinispanPublicKeyStorageProvider) cacheKey.session.getProvider(PublicKeyStorageProvider.class, getId());
                    provider.addInvalidation(cacheKey.cacheKey);
                }
            }

        });
    }

メンバ詳解

KEYS_CLEAR_CACHE_EVENTS

final String org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProviderFactory.KEYS_CLEAR_CACHE_EVENTS = "KEYS_CLEAR_CACHE_EVENTS"

static

keysCache

volatile Cache<String, PublicKeysEntry> org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProviderFactory.keysCache

private

log

final Logger org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProviderFactory.log = Logger.getLogger(InfinispanPublicKeyStorageProviderFactory.class)

staticprivate

minTimeBetweenRequests

int org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProviderFactory.minTimeBetweenRequests

private

PROVIDER_ID

final String org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProviderFactory.PROVIDER_ID = "infinispan"

static

PUBLIC_KEY_STORAGE_INVALIDATION_EVENT

final String org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProviderFactory.PUBLIC_KEY_STORAGE_INVALIDATION_EVENT = "PUBLIC_KEY_STORAGE_INVALIDATION_EVENT"

static

tasksInProgress

final Map<String, FutureTask<PublicKeysEntry> > org.keycloak.keys.infinispan.InfinispanPublicKeyStorageProviderFactory.tasksInProgress = new ConcurrentHashMap<>()

private

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/doxygen/keycloak/src/keycloak/src/main/java/org/keycloak/keys/infinispan/InfinispanPublicKeyStorageProviderFactory.java