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

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

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

クラス
class	PermissionTicketCache
class	PolicyCache
class	ResourceCache
class	ResourceServerCache
class	ScopeCache

公開メンバ関数
	StoreFactoryCacheSession (StoreFactoryCacheManager cache, KeycloakSession session)
ResourceServerStore	getResourceServerStore ()
ScopeStore	getScopeStore ()
ResourceStore	getResourceStore ()
PolicyStore	getPolicyStore ()
PermissionTicketStore	getPermissionTicketStore ()
void	close ()
long	getStartupRevision ()
boolean	isInvalid (String id)
void	registerResourceServerInvalidation (String id)
void	registerScopeInvalidation (String id, String name, String serverId)
void	registerResourceInvalidation (String id, String name, String type, Set< String > uris, Set< String > scopes, String serverId, String owner)
void	registerPolicyInvalidation (String id, String name, Set< String > resources, Set< String > scopes, String defaultResourceType, String serverId)
void	registerPermissionTicketInvalidation (String id, String owner, String requester, String resource, String scope, String serverId)
ResourceServerStore	getResourceServerStoreDelegate ()
ScopeStore	getScopeStoreDelegate ()
ResourceStore	getResourceStoreDelegate ()
PolicyStore	getPolicyStoreDelegate ()
PermissionTicketStore	getPermissionTicketStoreDelegate ()
StoreFactory	getDelegate ()

静的公開メンバ関数
static String	getResourceServerByClientCacheKey (String clientId)
static String	getScopeByNameCacheKey (String name, String serverId)
static String	getResourceByNameCacheKey (String name, String ownerId, String serverId)
static String	getResourceByOwnerCacheKey (String owner, String serverId)
static String	getResourceByTypeCacheKey (String type, String serverId)
static String	getResourceByUriCacheKey (String uri, String serverId)
static String	getResourceByScopeCacheKey (String scopeId, String serverId)
static String	getPolicyByNameCacheKey (String name, String serverId)
static String	getPolicyByResource (String resourceId, String serverId)
static String	getPolicyByResourceType (String type, String serverId)
static String	getPolicyByScope (String scope, String serverId)
static String	getPolicyByResourceScope (String scope, String resourceId, String serverId)
static String	getPermissionTicketByResource (String resourceId, String serverId)
static String	getPermissionTicketByScope (String scopeId, String serverId)
static String	getPermissionTicketByGranted (String userId, String serverId)
static String	getPermissionTicketByOwner (String owner, String serverId)

限定公開メンバ関数
void	runInvalidations ()

限定公開変数類
StoreFactoryCacheManager	cache
boolean	transactionActive
boolean	setRollbackOnly
Map< String, ResourceServerAdapter >	managedResourceServers = new HashMap<>()
Map< String, ScopeAdapter >	managedScopes = new HashMap<>()
Map< String, ResourceAdapter >	managedResources = new HashMap<>()
Map< String, PolicyAdapter >	managedPolicies = new HashMap<>()
Map< String, PermissionTicketAdapter >	managedPermissionTickets = new HashMap<>()
Set< String >	invalidations = new HashSet<>()
Set< InvalidationEvent >	invalidationEvents = new HashSet<>()
boolean	clearAll
final long	startupRevision
StoreFactory	delegate
KeycloakSession	session
ResourceServerCache	resourceServerCache
ScopeCache	scopeCache
ResourceCache	resourceCache
PolicyCache	policyCache
PermissionTicketCache	permissionTicketCache

静的限定公開変数類
static final Logger	logger = Logger.getLogger(StoreFactoryCacheSession.class)

非公開メンバ関数
KeycloakTransaction	getPrepareTransaction ()
KeycloakTransaction	getAfterTransaction ()
Set< String >	getResourceTypes (Set< String > resources, String serverId)
void	setModelDoesNotExists (String id, Long loaded)
boolean	modelMightExist (String id)

詳解

著者

Bill Burke

バージョン

Revision

1

構築子と解体子

StoreFactoryCacheSession()

org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.StoreFactoryCacheSession ( StoreFactoryCacheManager  cache, KeycloakSession  session  )

inline

                                                                                             {
        this.cache = cache;
        this.startupRevision = cache.getCurrentCounter();
        this.session = session;
        this.resourceServerCache = new ResourceServerCache();
        this.scopeCache = new ScopeCache();
        this.resourceCache = new ResourceCache();
        this.policyCache = new PolicyCache();
        this.permissionTicketCache = new PermissionTicketCache();
        session.getTransactionManager().enlistPrepare(getPrepareTransaction());
        session.getTransactionManager().enlistAfterCompletion(getAfterTransaction());
    }

関数詳解

close()

void org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.close ( )

inline

org.keycloak.provider.Providerを実装しています。

                        {
    }

getAfterTransaction()

KeycloakTransaction org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getAfterTransaction ( )

inlineprivate

                                                      {
        return new KeycloakTransaction() {
            @Override
            public void begin() {
                transactionActive = true;
            }

            @Override
            public void commit() {
                try {
                    if (getDelegate() == null) return;
                    if (clearAll) {
                        cache.clear();
                    }
                    runInvalidations();
                    transactionActive = false;
                } finally {
                    cache.endRevisionBatch();
                }
            }

            @Override
            public void rollback() {
                try {
                    setRollbackOnly = true;
                    runInvalidations();
                    transactionActive = false;
                } finally {
                    cache.endRevisionBatch();
                }
            }

            @Override
            public void setRollbackOnly() {
                setRollbackOnly = true;
            }

            @Override
            public boolean getRollbackOnly() {
                return setRollbackOnly;
            }

            @Override
            public boolean isActive() {
                return transactionActive;
            }
        };
    }

getDelegate()

StoreFactory org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getDelegate ( )

inline

                                      {
        if (delegate != null) return delegate;
        delegate = session.getProvider(StoreFactory.class);
        return delegate;
    }

getPermissionTicketByGranted()

static String org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getPermissionTicketByGranted ( String  userId, String  serverId  )

inlinestatic

                                                                                      {
        return "permission.ticket.granted." + userId + "." + serverId;
    }

getPermissionTicketByOwner()

static String org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getPermissionTicketByOwner ( String  owner, String  serverId  )

inlinestatic

                                                                                   {
        return "permission.ticket.owner." + owner + "." + serverId;
    }

getPermissionTicketByResource()

static String org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getPermissionTicketByResource ( String  resourceId, String  serverId  )

inlinestatic

                                                                                           {
        return "permission.ticket.resource." + resourceId + "." + serverId;
    }

getPermissionTicketByScope()

static String org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getPermissionTicketByScope ( String  scopeId, String  serverId  )

inlinestatic

                                                                                     {
        return "permission.ticket.scope." + scopeId + "." + serverId;
    }

getPermissionTicketStore()

PermissionTicketStore org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getPermissionTicketStore ( )

inline

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

                                                            {
        return permissionTicketCache;
    }

getPermissionTicketStoreDelegate()

PermissionTicketStore org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getPermissionTicketStoreDelegate ( )

inline

                                                                    {
        return getDelegate().getPermissionTicketStore();
    }

getPolicyByNameCacheKey()

static String org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getPolicyByNameCacheKey ( String  name, String  serverId  )

inlinestatic

                                                                               {
        return "policy.name." + name + "." + serverId;
    }

getPolicyByResource()

static String org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getPolicyByResource ( String  resourceId, String  serverId  )

inlinestatic

                                                                                 {
        return "policy.resource." + resourceId + "." + serverId;
    }

getPolicyByResourceScope()

static String org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getPolicyByResourceScope ( String  scope, String  resourceId, String  serverId  )

inlinestatic

                                                                                                    {
        return "policy.resource. " + resourceId + ".scope." + scope + "." + serverId;
    }

getPolicyByResourceType()

static String org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getPolicyByResourceType ( String  type, String  serverId  )

inlinestatic

                                                                               {
        return "policy.resource.type." + type + "." + serverId;
    }

getPolicyByScope()

static String org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getPolicyByScope ( String  scope, String  serverId  )

inlinestatic

                                                                         {
        return "policy.scope." + scope + "." + serverId;
    }

getPolicyStore()

PolicyStore org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getPolicyStore ( )

inline

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

                                        {
        return policyCache;
    }

getPolicyStoreDelegate()

PolicyStore org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getPolicyStoreDelegate ( )

inline

                                                {
        return getDelegate().getPolicyStore();
    }

getPrepareTransaction()

KeycloakTransaction org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getPrepareTransaction ( )

inlineprivate

                                                        {
        return new KeycloakTransaction() {
            @Override
            public void begin() {
                transactionActive = true;
            }

            @Override
            public void commit() {
            }

            @Override
            public void rollback() {
                setRollbackOnly = true;
                transactionActive = false;
            }

            @Override
            public void setRollbackOnly() {
                setRollbackOnly = true;
            }

            @Override
            public boolean getRollbackOnly() {
                return setRollbackOnly;
            }

            @Override
            public boolean isActive() {
                return transactionActive;
            }
        };
    }

getResourceByNameCacheKey()

static String org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getResourceByNameCacheKey ( String  name, String  ownerId, String  serverId  )

inlinestatic

                                                                                                 {
        return "resource.name." + name + "." + ownerId + "." + serverId;
    }

getResourceByOwnerCacheKey()

static String org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getResourceByOwnerCacheKey ( String  owner, String  serverId  )

inlinestatic

                                                                                   {
        return "resource.owner." + owner + "." + serverId;
    }

getResourceByScopeCacheKey()

static String org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getResourceByScopeCacheKey ( String  scopeId, String  serverId  )

inlinestatic

                                                                                     {
        return "resource.scope." + scopeId + "." + serverId;
    }

getResourceByTypeCacheKey()

static String org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getResourceByTypeCacheKey ( String  type, String  serverId  )

inlinestatic

                                                                                 {
        return "resource.type." + type + "." + serverId;
    }

getResourceByUriCacheKey()

static String org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getResourceByUriCacheKey ( String  uri, String  serverId  )

inlinestatic

                                                                               {
        return "resource.uri." + uri + "." + serverId;
    }

getResourceServerByClientCacheKey()

static String org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getResourceServerByClientCacheKey ( String  clientId )

inlinestatic

                                                                            {
        return "resource.server.client.id." + clientId;
    }

getResourceServerStore()

ResourceServerStore org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getResourceServerStore ( )

inline

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

                                                        {
        return resourceServerCache;
    }

getResourceServerStoreDelegate()

ResourceServerStore org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getResourceServerStoreDelegate ( )

inline

                                                                {
        return getDelegate().getResourceServerStore();
    }

getResourceStore()

ResourceStore org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getResourceStore ( )

inline

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

                                            {
        return resourceCache;
    }

getResourceStoreDelegate()

ResourceStore org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getResourceStoreDelegate ( )

inline

                                                    {
        return getDelegate().getResourceStore();
    }

getResourceTypes()

Set<String> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getResourceTypes ( Set< String >  resources, String  serverId  )

inlineprivate

                                                                                 {
        if (resources == null) {
            return Collections.emptySet();
        }

        return resources.stream().map(resourceId -> {
            Resource resource = getResourceStore().findById(resourceId, serverId);
            String type = resource.getType();

            if (type != null) {
                return type;
            }

            return null;
        }).filter(Objects::nonNull).collect(Collectors.toSet());
    }

getScopeByNameCacheKey()

static String org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getScopeByNameCacheKey ( String  name, String  serverId  )

inlinestatic

                                                                              {
        return "scope.name." + name + "." + serverId;
    }

getScopeStore()

ScopeStore org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getScopeStore ( )

inline

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

                                      {
        return scopeCache;
    }

getScopeStoreDelegate()

ScopeStore org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getScopeStoreDelegate ( )

inline

                                              {
        return getDelegate().getScopeStore();
    }

getStartupRevision()

long org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.getStartupRevision ( )

inline

                                     {
        return startupRevision;
    }

isInvalid()

boolean org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.isInvalid ( String  id )

inline

                                        {
        return invalidations.contains(id);
    }

modelMightExist()

boolean org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.modelMightExist ( String  id )

inlineprivate

                                               {
        return invalidations.contains(id) || cache.get(id, NonExistentItem.class) == null;
    }

registerPermissionTicketInvalidation()

void org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.registerPermissionTicketInvalidation ( String  id, String  owner, String  requester, String  resource, String  scope, String  serverId  )

inline

                                                                                                                                                  {
        cache.permissionTicketUpdated(id, owner, requester, resource, scope, serverId, invalidations);
        PermissionTicketAdapter adapter = managedPermissionTickets.get(id);
        if (adapter != null) adapter.invalidateFlag();

        invalidationEvents.add(PermissionTicketUpdatedEvent.create(id, owner, requester, resource, scope, serverId));
    }

registerPolicyInvalidation()

void org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.registerPolicyInvalidation ( String  id, String  name, Set< String >  resources, Set< String >  scopes, String  defaultResourceType, String  serverId  )

inline

                                                                                                                                                           {
        Set<String> resourceTypes = getResourceTypes(resources, serverId);
        if (Objects.nonNull(defaultResourceType)) {
            resourceTypes.add(defaultResourceType);
        }
        cache.policyUpdated(id, name, resources, resourceTypes, scopes, serverId, invalidations);
        PolicyAdapter adapter = managedPolicies.get(id);
        if (adapter != null) adapter.invalidateFlag();

        invalidationEvents.add(PolicyUpdatedEvent.create(id, name, resources, resourceTypes, scopes, serverId));
    }

registerResourceInvalidation()

void org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.registerResourceInvalidation ( String  id, String  name, String  type, Set< String >  uris, Set< String >  scopes, String  serverId, String  owner  )

inline

                                                                                                                                                       {
        cache.resourceUpdated(id, name, type, uris, scopes, serverId, owner, invalidations);
        ResourceAdapter adapter = managedResources.get(id);
        if (adapter != null) adapter.invalidateFlag();

        invalidationEvents.add(ResourceUpdatedEvent.create(id, name, type, uris, scopes, serverId, owner));
    }

registerResourceServerInvalidation()

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

inline

                                                              {
        cache.resourceServerUpdated(id, invalidations);
        ResourceServerAdapter adapter = managedResourceServers.get(id);
        if (adapter != null) adapter.invalidateFlag();

        invalidationEvents.add(ResourceServerUpdatedEvent.create(id));
    }

registerScopeInvalidation()

void org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.registerScopeInvalidation ( String  id, String  name, String  serverId  )

inline

                                                                                   {
        cache.scopeUpdated(id, name, serverId, invalidations);
        ScopeAdapter adapter = managedScopes.get(id);
        if (adapter != null) adapter.invalidateFlag();

        invalidationEvents.add(ScopeUpdatedEvent.create(id, name, serverId));
    }

runInvalidations()

void org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.runInvalidations ( )

inlineprotected

                                      {
        for (String id : invalidations) {
            cache.invalidateObject(id);
        }

        cache.sendInvalidationEvents(session, invalidationEvents, InfinispanCacheStoreFactoryProviderFactory.AUTHORIZATION_INVALIDATION_EVENTS);
    }

setModelDoesNotExists()

void org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.setModelDoesNotExists ( String  id, Long  loaded  )

inlineprivate

                                                               {
        if (! invalidations.contains(id)) {
            cache.addRevisioned(new NonExistentItem(id, loaded), startupRevision);
        }
    }

メンバ詳解

cache

StoreFactoryCacheManager org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.cache

protected

clearAll

boolean org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.clearAll

protected

delegate

StoreFactory org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.delegate

protected

invalidationEvents

Set<InvalidationEvent> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.invalidationEvents = new HashSet<>()

protected

invalidations

Set<String> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.invalidations = new HashSet<>()

protected

logger

final Logger org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.logger = Logger.getLogger(StoreFactoryCacheSession.class)

staticprotected

managedPermissionTickets

Map<String, PermissionTicketAdapter> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.managedPermissionTickets = new HashMap<>()

protected

managedPolicies

Map<String, PolicyAdapter> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.managedPolicies = new HashMap<>()

protected

managedResources

Map<String, ResourceAdapter> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.managedResources = new HashMap<>()

protected

managedResourceServers

Map<String, ResourceServerAdapter> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.managedResourceServers = new HashMap<>()

protected

managedScopes

Map<String, ScopeAdapter> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.managedScopes = new HashMap<>()

protected

permissionTicketCache

PermissionTicketCache org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.permissionTicketCache

protected

policyCache

PolicyCache org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.policyCache

protected

resourceCache

ResourceCache org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.resourceCache

protected

resourceServerCache

ResourceServerCache org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.resourceServerCache

protected

scopeCache

ScopeCache org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.scopeCache

protected

session

KeycloakSession org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.session

protected

setRollbackOnly

boolean org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.setRollbackOnly

protected

startupRevision

final long org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.startupRevision

protected

transactionActive

boolean org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.transactionActive

protected

---

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

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