org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache クラス

org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache の継承関係図

org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache 連携図

公開メンバ関数
Resource	create (String name, ResourceServer resourceServer, String owner)
Resource	create (String id, String name, ResourceServer resourceServer, String owner)
void	delete (String id)
Resource	findById (String id, String resourceServerId)
Resource	findByName (String name, String resourceServerId)
Resource	findByName (String name, String ownerId, String resourceServerId)
List< Resource >	findByOwner (String ownerId, String resourceServerId)
void	findByOwner (String ownerId, String resourceServerId, Consumer< Resource > consumer)
List< Resource >	findByUri (String uri, String resourceServerId)
List< Resource >	findByResourceServer (String resourceServerId)
List< Resource >	findByResourceServer (Map< String, String[]> attributes, String resourceServerId, int firstResult, int maxResult)
List< Resource >	findByScope (List< String > ids, String resourceServerId)
void	findByScope (List< String > ids, String resourceServerId, Consumer< Resource > consumer)
List< Resource >	findByType (String type, String resourceServerId)
void	findByType (String type, String resourceServerId, Consumer< Resource > consumer)

関数
private< R, Q extends ResourceQuery > List< R >	cacheQuery (String cacheKey, Class< Q > queryType, Supplier< List< R >> resultSupplier, BiFunction< Long, List< R >, Q > querySupplier, String resourceServerId)
private< R, Q extends ResourceQuery > List< R >	cacheQuery (String cacheKey, Class< Q > queryType, Supplier< List< R >> resultSupplier, BiFunction< Long, List< R >, Q > querySupplier, String resourceServerId, Consumer< R > consumer)

詳解

関数詳解

cacheQuery() [1/2]

private<R, Q extends ResourceQuery> List<R> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache.cacheQuery ( String  cacheKey, Class< Q >  queryType, Supplier< List< R >>  resultSupplier, BiFunction< Long, List< R >, Q >  querySupplier, String  resourceServerId  )

inlinepackage

                                                                                                                                                                                                            {
            return cacheQuery(cacheKey, queryType, resultSupplier, querySupplier, resourceServerId, null);
        }

cacheQuery() [2/2]

private<R, Q extends ResourceQuery> List<R> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache.cacheQuery ( String  cacheKey, Class< Q >  queryType, Supplier< List< R >>  resultSupplier, BiFunction< Long, List< R >, Q >  querySupplier, String  resourceServerId, Consumer< R >  consumer  )

inlinepackage

                                                                                                                                                                                                                                  {
            Q query = cache.get(cacheKey, queryType);
            if (query != null) {
                logger.tracev("cache hit for key: {0}", cacheKey);
            }
            if (query == null) {
                Long loaded = cache.getCurrentRevision(cacheKey);
                List<R> model = resultSupplier.get();
                if (model == null) return null;
                if (invalidations.contains(cacheKey)) return model;
                query = querySupplier.apply(loaded, model);
                cache.addRevisioned(query, startupRevision);
                if (consumer != null) {
                    for (R resource : model) {
                        consumer.accept(resource);
                    }
                }
                return model;
            } else if (query.isInvalid(invalidations)) {
                List<R> result = resultSupplier.get();

                if (consumer != null) {
                    for (R resource : result) {
                        consumer.accept(resource);
                    }
                }

                return result;
            } else {
                Set<String> resources = query.getResources();

                if (consumer != null) {
                    resources.stream().map(resourceId -> (R) findById(resourceId, resourceServerId)).forEach(consumer);
                    return Collections.emptyList();
                }

                return resources.stream().map(resourceId -> (R) findById(resourceId, resourceServerId)).collect(Collectors.toList());
            }
        }

create() [1/2]

Resource org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache.create ( String  name, ResourceServer  resourceServer, String  owner  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                                         {
            return create(null, name, resourceServer, owner);
        }

create() [2/2]

Resource org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache.create ( String  id, String  name, ResourceServer  resourceServer, String  owner  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                                                    {
            Resource resource = getResourceStoreDelegate().create(id, name, resourceServer, owner);
            Resource cached = findById(resource.getId(), resourceServer.getId());
            registerResourceInvalidation(resource.getId(), resource.getName(), resource.getType(), resource.getUris(), resource.getScopes().stream().map(scope -> scope.getId()).collect(Collectors.toSet()), resourceServer.getId(), resource.getOwner());
            if (cached == null) {
                cached = findById(resource.getId(), resourceServer.getId());
            }
            return cached;
        }

delete()

void org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache.delete ( String  id )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                      {
            if (id == null) return;
            Resource resource = findById(id, null);
            if (resource == null) return;

            cache.invalidateObject(id);
            invalidationEvents.add(ResourceRemovedEvent.create(id, resource.getName(), resource.getType(), resource.getUris(), resource.getOwner(), resource.getScopes().stream().map(scope -> scope.getId()).collect(Collectors.toSet()), resource.getResourceServer().getId()));
            cache.resourceRemoval(id, resource.getName(), resource.getType(), resource.getUris(), resource.getOwner(), resource.getScopes().stream().map(scope -> scope.getId()).collect(Collectors.toSet()), resource.getResourceServer().getId(), invalidations);
            getResourceStoreDelegate().delete(id);

        }

findById()

Resource org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache.findById ( String  id, String  resourceServerId  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                     {
            if (id == null) return null;
            CachedResource cached = cache.get(id, CachedResource.class);
            if (cached != null) {
                logger.tracev("by id cache hit: {0}", cached.getId());
            }
            if (cached == null) {
                Long loaded = cache.getCurrentRevision(id);
                if (! modelMightExist(id)) return null;
                Resource model = getResourceStoreDelegate().findById(id, resourceServerId);
                if (model == null) {
                    setModelDoesNotExists(id, loaded);
                    return null;
                }
                if (invalidations.contains(id)) return model;
                cached = new CachedResource(loaded, model);
                cache.addRevisioned(cached, startupRevision);
            } else if (invalidations.contains(id)) {
                return getResourceStoreDelegate().findById(id, resourceServerId);
            } else if (managedResources.containsKey(id)) {
                return managedResources.get(id);
            }
            ResourceAdapter adapter = new ResourceAdapter(cached, StoreFactoryCacheSession.this);
            managedResources.put(id, adapter);
            return adapter;
        }

findByName() [1/2]

Resource org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache.findByName ( String  name, String  resourceServerId  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                         {
            return findByName(name, resourceServerId, resourceServerId);
        }

findByName() [2/2]

Resource org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache.findByName ( String  name, String  ownerId, String  resourceServerId  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                                         {
            if (name == null) return null;
            String cacheKey = getResourceByNameCacheKey(name, ownerId, resourceServerId);
            List<Resource> result = cacheQuery(cacheKey, ResourceListQuery.class, () -> {
                        Resource resource = getResourceStoreDelegate().findByName(name, ownerId, resourceServerId);

                        if (resource == null) {
                            return Collections.emptyList();
                        }

                        return Arrays.asList(resource);
                    },
                    (revision, resources) -> new ResourceListQuery(revision, cacheKey, resources.stream().map(resource -> resource.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId);

            if (result.isEmpty()) {
                return null;
            }

            return result.get(0);
        }

findByOwner() [1/2]

List<Resource> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache.findByOwner ( String  ownerId, String  resourceServerId  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                                   {
            String cacheKey = getResourceByOwnerCacheKey(ownerId, resourceServerId);
            return cacheQuery(cacheKey, ResourceListQuery.class, () -> getResourceStoreDelegate().findByOwner(ownerId, resourceServerId),
                    (revision, resources) -> new ResourceListQuery(revision, cacheKey, resources.stream().map(resource -> resource.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId);
        }

findByOwner() [2/2]

void org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache.findByOwner ( String  ownerId, String  resourceServerId, Consumer< Resource >  consumer  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                                                      {
            String cacheKey = getResourceByOwnerCacheKey(ownerId, resourceServerId);
            cacheQuery(cacheKey, ResourceListQuery.class, () -> getResourceStoreDelegate().findByOwner(ownerId, resourceServerId),
                    (revision, resources) -> new ResourceListQuery(revision, cacheKey, resources.stream().map(resource -> resource.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId, consumer);
        }

findByResourceServer() [1/2]

List<Resource> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache.findByResourceServer ( String  resourceServerId )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                            {
            return getResourceStoreDelegate().findByResourceServer(resourceServerId);
        }

findByResourceServer() [2/2]

List<Resource> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache.findByResourceServer ( Map< String, String[]>  attributes, String  resourceServerId, int  firstResult, int  maxResult  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                                                                                              {
            return getResourceStoreDelegate().findByResourceServer(attributes, resourceServerId, firstResult, maxResult);
        }

findByScope() [1/2]

List<Resource> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache.findByScope ( List< String >  ids, String  resourceServerId  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                                     {
            if (ids == null) return null;
            List<Resource> result = new ArrayList<>();

            for (String id : ids) {
                String cacheKey = getResourceByScopeCacheKey(id, resourceServerId);
                result.addAll(cacheQuery(cacheKey, ResourceScopeListQuery.class, () -> getResourceStoreDelegate().findByScope(Arrays.asList(id), resourceServerId), (revision, resources) -> new ResourceScopeListQuery(revision, cacheKey, id, resources.stream().map(resource -> resource.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId));
            }

            return result;
        }

findByScope() [2/2]

void org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache.findByScope ( List< String >  ids, String  resourceServerId, Consumer< Resource >  consumer  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                                                        {
            if (ids == null) return;

            for (String id : ids) {
                String cacheKey = getResourceByScopeCacheKey(id, resourceServerId);
                cacheQuery(cacheKey, ResourceScopeListQuery.class, () -> getResourceStoreDelegate().findByScope(Arrays.asList(id), resourceServerId), (revision, resources) -> new ResourceScopeListQuery(revision, cacheKey, id, resources.stream().map(resource -> resource.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId, consumer);
            }
        }

findByType() [1/2]

List<Resource> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache.findByType ( String  type, String  resourceServerId  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                               {
             if (type == null) return Collections.emptyList();
             String cacheKey = getResourceByTypeCacheKey(type, resourceServerId);
             return cacheQuery(cacheKey, ResourceListQuery.class, () -> getResourceStoreDelegate().findByType(type, resourceServerId),
                     (revision, resources) -> new ResourceListQuery(revision, cacheKey, resources.stream().map(resource -> resource.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId);
        }

findByType() [2/2]

void org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache.findByType ( String  type, String  resourceServerId, Consumer< Resource >  consumer  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                                                  {
            if (type == null) return;
            String cacheKey = getResourceByTypeCacheKey(type, resourceServerId);
            cacheQuery(cacheKey, ResourceListQuery.class, () -> getResourceStoreDelegate().findByType(type, resourceServerId),
                    (revision, resources) -> new ResourceListQuery(revision, cacheKey, resources.stream().map(resource -> resource.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId, consumer);
        }

findByUri()

List<Resource> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.ResourceCache.findByUri ( String  uri, String  resourceServerId  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                             {
            if (uri == null) return null;
            String cacheKey = getResourceByUriCacheKey(uri, resourceServerId);
            return cacheQuery(cacheKey, ResourceListQuery.class, () -> getResourceStoreDelegate().findByUri(uri, resourceServerId),
                    (revision, resources) -> new ResourceListQuery(revision, cacheKey, resources.stream().map(resource -> resource.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId);
        }

---

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

• D:/AppData/doxygen/keycloak/src/keycloak/src/main/java/org/keycloak/models/cache/infinispan/authorization/StoreFactoryCacheSession.java