Uses of Class
io.axoniq.framework.messaging.multitenancy.api.TenantDescriptor
Packages that use TenantDescriptor
Package
Description
Contains the multi-tenancy API, like the tenant descriptor, tenant provider, and tenant resolution contracts.
Part of the Axoniq Framework multi-tenancy module.
Part of the Axoniq Framework multi-tenancy module.
Part of the Axoniq Framework multi-tenancy module.
Axon Server specific multi-tenant event streaming infrastructure, giving each tenant its own persistent stream and
labelling the events it delivers with the tenant they belong to.
Part of the Axoniq Framework multi-tenancy module.
Package containing multitenancy support for event sourcing components.
-
Uses of TenantDescriptor in io.axoniq.framework.messaging.multitenancy.api
Fields in io.axoniq.framework.messaging.multitenancy.api with type parameters of type TenantDescriptorModifier and TypeFieldDescriptionstatic final Context.ResourceKey<TenantDescriptor> TenantDescriptor.RESOURCE_KEYMethods in io.axoniq.framework.messaging.multitenancy.api that return TenantDescriptorModifier and TypeMethodDescriptionMetadataBasedTenantResolver.resolveTenant(Message message, Collection<TenantDescriptor> tenants) Resolves the target tenant by extracting the tenant identifier from the message's metadata.default TenantDescriptorTenantResolver.resolveTenant(Message message) ReturnsTenantDescriptorfor the givenmessage.TenantResolver.resolveTenant(Message message, Collection<TenantDescriptor> tenants) ReturnsTenantDescriptorfor the givenmessage.static TenantDescriptorTenantDescriptor.tenantWithId(String tenantId) Constructs aTenantDescriptorwith the giventenantId.Methods in io.axoniq.framework.messaging.multitenancy.api that return types with arguments of type TenantDescriptorModifier and TypeMethodDescriptionstatic Optional<TenantDescriptor> TenantDescriptor.fromContext(ProcessingContext context) Returns anOptionalof theTenantDescriptorkept under theRESOURCE_KEYin the givencontext, orOptional.empty()when none is present.TenantRouter.resolveFromContext(@Nullable ProcessingContext context) Resolves the tenant carried by the givencontext, taken from itstenant resourcewhen present, otherwise from the message the context carries.TenantRouter.resolveFromMessage(Message message) Resolves the tenant of the givenmessage.TenantRouter.resolveSharedTenant(Collection<? extends Message> messages) Resolves the single tenant shared by all givenmessages.TenantDescriptors.tenants()Returns a list of tenant descriptors.TenantProvider.tenants()Get the list of registeredtenantswith this provided.TenantScopedCache.tenants()Returns the tenants currently registered withthiscache, whether their component was built yet or not.Methods in io.axoniq.framework.messaging.multitenancy.api with parameters of type TenantDescriptorModifier and TypeMethodDescriptionMetadataBasedTenantResolver.attachTenant(Message message, TenantDescriptor tenant) Attaches the giventenantto the givenmessageby writing its identifier into the message's metadata under this instance'smetadataKey, merged with any metadata the message already carries.TenantResolver.attachTenant(Message message, TenantDescriptor tenant) Returns a copy of the givenmessagecarrying the giventenant, the inverse ofTenantResolver.resolveTenant(Message, Collection): where that method determines the tenant a message belongs to, this one makes that determination survive the message being dispatched elsewhere.TenantRouter.attachTenant(Message message, TenantDescriptor tenant) Attaches the giventenantto the givenmessage, the inverse ofTenantRouter.resolveFromMessage(Message), delegating to the wrappedTenantResolver.TenantComponentProvider.componentFor(TenantDescriptor tenant) Returns the component instance for the giventenant.TenantScopedCache.componentFor(TenantDescriptor tenant) Returns the component of the giventenant, creating and caching it on first access.TenantComponentFactory.create(TenantDescriptor tenant) Creates a component instance for the giventenant.default voidTenantComponentFactory.destroy(TenantDescriptor tenant, T component) Destroys the givencomponentwhen itstenantis removed.default booleanTenantDescriptors.isKnown(TenantDescriptor tenant) Indicates whether the giventenantis one of thetenantsof this application.MultiTenantAwareComponent.registerAndStartTenant(TenantDescriptor tenantDescriptor) Registers the giventenantDescriptoras a known tenant with this multi-tenant aware component.TenantScopedCache.registerAndStartTenant(TenantDescriptor tenantDescriptor) Behaves identically toTenantScopedCache.registerTenant(TenantDescriptor): components are created lazily on first use, so there is nothing to start eagerly.MultiTenantAwareComponent.registerTenant(TenantDescriptor tenantDescriptor) Registers the giventenantDescriptoras a known tenant with this multi-tenant aware component.TenantScopedCache.registerTenant(TenantDescriptor tenantDescriptor) Method parameters in io.axoniq.framework.messaging.multitenancy.api with type arguments of type TenantDescriptorModifier and TypeMethodDescriptionMetadataBasedTenantResolver.resolveTenant(Message message, Collection<TenantDescriptor> tenants) Resolves the target tenant by extracting the tenant identifier from the message's metadata.TenantResolver.resolveTenant(Message message, Collection<TenantDescriptor> tenants) ReturnsTenantDescriptorfor the givenmessage.Constructor parameters in io.axoniq.framework.messaging.multitenancy.api with type arguments of type TenantDescriptorModifierConstructorDescriptionTenantScopedCache(Function<TenantDescriptor, C> componentFactory, String owner) Constructs aTenantScopedCachebuilding its components with the givencomponentFactory, dropping its reference to a component on eviction without releasing it any further.TenantScopedCache(Function<TenantDescriptor, C> componentFactory, BiConsumer<TenantDescriptor, C> onEviction, String owner) Constructs aTenantScopedCachebuilding its components with the givencomponentFactoryand handing every component it evicts to the givenonEviction.TenantScopedCache(Function<TenantDescriptor, C> componentFactory, BiConsumer<TenantDescriptor, C> onEviction, String owner) Constructs aTenantScopedCachebuilding its components with the givencomponentFactoryand handing every component it evicts to the givenonEviction. -
Uses of TenantDescriptor in io.axoniq.framework.messaging.multitenancy.axonserver.api
Methods in io.axoniq.framework.messaging.multitenancy.axonserver.api that return types with arguments of type TenantDescriptorMethods in io.axoniq.framework.messaging.multitenancy.axonserver.api with parameters of type TenantDescriptorModifier and TypeMethodDescriptionvoidAxonServerTenantProvider.addTenant(TenantDescriptor tenantDescriptor) Adds the giventenantDescriptoras a known tenant, registering and starting every subscribedMultiTenantAwareComponentfor it.booleanAxonServerTenantProvider.isKnown(TenantDescriptor tenant) voidAxonServerTenantProvider.removeTenant(TenantDescriptor tenantDescriptor) Removes a tenant from the system.booleanAxonServerTenantConnectPredicate.test(TenantDescriptor tenantDescriptor) -
Uses of TenantDescriptor in io.axoniq.framework.messaging.multitenancy.axonserver.commandhandling
Methods in io.axoniq.framework.messaging.multitenancy.axonserver.commandhandling with parameters of type TenantDescriptorModifier and TypeMethodDescriptionMultiTenantAxonServerCommandBusConnector.registerAndStartTenant(TenantDescriptor tenantDescriptor) MultiTenantAxonServerCommandBusConnector.registerTenant(TenantDescriptor tenantDescriptor) -
Uses of TenantDescriptor in io.axoniq.framework.messaging.multitenancy.axonserver.eventsourcing
Methods in io.axoniq.framework.messaging.multitenancy.axonserver.eventsourcing with parameters of type TenantDescriptorModifier and TypeMethodDescriptionAxonServerTenantEventStorageEngineFactory.engineFor(TenantDescriptor tenant) AxonServerTenantEventStorageEngineFactory.registerAndStartTenant(TenantDescriptor tenantDescriptor) AxonServerTenantSnapshotStoreFactory.registerAndStartTenant(TenantDescriptor tenantDescriptor) AxonServerTenantEventStorageEngineFactory.registerTenant(TenantDescriptor tenantDescriptor) AxonServerTenantSnapshotStoreFactory.registerTenant(TenantDescriptor tenantDescriptor) AxonServerTenantSnapshotStoreFactory.storeFor(TenantDescriptor tenant) -
Uses of TenantDescriptor in io.axoniq.framework.messaging.multitenancy.axonserver.eventstreaming
Methods in io.axoniq.framework.messaging.multitenancy.axonserver.eventstreaming with parameters of type TenantDescriptorModifier and TypeMethodDescriptionMultiTenantPersistentStreamEventSource.registerAndStartTenant(TenantDescriptor tenantDescriptor) Behaves identically toMultiTenantPersistentStreamEventSource.registerTenant(TenantDescriptor), which already opens the tenant's stream: this source is only registered with theTenantProviderwhile it has a consumer to feed, so there is no registered-but-not-started state to distinguish.MultiTenantPersistentStreamEventSource.registerTenant(TenantDescriptor tenantDescriptor) Opens the persistent stream of the giventenantDescriptorand joins it to the subscribed consumer. -
Uses of TenantDescriptor in io.axoniq.framework.messaging.multitenancy.axonserver.queryhandling
Methods in io.axoniq.framework.messaging.multitenancy.axonserver.queryhandling with parameters of type TenantDescriptorModifier and TypeMethodDescriptionMultiTenantAxonServerQueryBusConnector.registerAndStartTenant(TenantDescriptor tenantDescriptor) MultiTenantAxonServerQueryBusConnector.registerTenant(TenantDescriptor tenantDescriptor) -
Uses of TenantDescriptor in io.axoniq.framework.messaging.multitenancy.eventsourcing
Methods in io.axoniq.framework.messaging.multitenancy.eventsourcing that return types with arguments of type TenantDescriptorModifier and TypeMethodDescriptionMultiTenantEventStorageEngine.tenants()Returns the tenants currently registered withthisengine.Methods in io.axoniq.framework.messaging.multitenancy.eventsourcing with parameters of type TenantDescriptorModifier and TypeMethodDescriptionTenantEventStorageEngineFactory.engineFor(TenantDescriptor tenant) Returns theEventStorageEngineof the giventenant.MultiTenantEventStorageEngine.registerAndStartTenant(TenantDescriptor tenantDescriptor) MultiTenantEventStorageEngine.registerTenant(TenantDescriptor tenantDescriptor) TenantSnapshotStoreFactory.storeFor(TenantDescriptor tenant) Returns theSnapshotStoreof the giventenant.