Skip navigation links
A B C D E F G H I K L M N O P Q R S T U V W 

A

AbstractBuilder() - Constructor for class io.spine.server.delivery.ShardedStream.AbstractBuilder
Prevents the instantiation of this builder.
AbstractChannel - Class in io.spine.server.transport
An abstract base for message channels.
AbstractChannel(ChannelId) - Constructor for class io.spine.server.transport.AbstractChannel
 
AbstractChannelObserver - Class in io.spine.server.integration
Base routines for the Subscriber.addObserver(StreamObserver) subscriber observers}.
AbstractChannelObserver(BoundedContextName, Class<? extends Message>) - Constructor for class io.spine.server.integration.AbstractChannelObserver
 
AbstractCommandDispatcher - Class in io.spine.server.command
The abstract base for non-aggregate classes that dispatch commands to their methods and post resulting events to to EventBus.
AbstractCommandDispatcher(EventBus) - Constructor for class io.spine.server.command.AbstractCommandDispatcher
Lazily initialized logger.
AbstractCommander - Class in io.spine.server.command
The abstract base for classes that generate commands in response to incoming messages.
AbstractCommander(CommandBus, EventBus) - Constructor for class io.spine.server.command.AbstractCommander
 
AbstractCommandHandler - Class in io.spine.server.command
The abstract base for non-aggregate classes that expose command handling methods and post their results to EventBus.
AbstractCommandHandler(EventBus) - Constructor for class io.spine.server.command.AbstractCommandHandler
Creates a new instance of the command handler.
AbstractEntity<I,S extends com.google.protobuf.Message> - Class in io.spine.server.entity
Abstract base for entities.
AbstractEntity(I) - Constructor for class io.spine.server.entity.AbstractEntity
Creates new instance with the passed ID.
AbstractEntity(I, Function<I, S>) - Constructor for class io.spine.server.entity.AbstractEntity
Creates a new instance with the passed ID and default entity state obtained from the passed function.
AbstractEventSubscriber - Class in io.spine.server.event
The abstract base for objects that can be subscribed to receive events from EventBus.
AbstractEventSubscriber() - Constructor for class io.spine.server.event.AbstractEventSubscriber
 
AbstractExternalEventDispatcher() - Constructor for class io.spine.server.entity.EventDispatchingRepository.AbstractExternalEventDispatcher
 
AbstractStorage<I,M extends com.google.protobuf.Message,R extends ReadRequest<I>> - Class in io.spine.server.storage
Abstract base for storages.
AbstractStorage(boolean) - Constructor for class io.spine.server.storage.AbstractStorage
 
AbstractVersionableEntity<I,S extends com.google.protobuf.Message> - Class in io.spine.server.entity
An abstract base for entities with versions.
AbstractVersionableEntity(I) - Constructor for class io.spine.server.entity.AbstractVersionableEntity
Creates a new instance.
accept(E) - Method in interface io.spine.server.bus.BusFilter
Accepts or rejects a passed message.
accept(CommandEnvelope) - Method in class io.spine.server.commandbus.CommandScheduler
 
activate(Subscription, Stand.EntityUpdateCallback, StreamObserver<Response>) - Method in class io.spine.server.stand.Stand
Activates the subscription created via subscribe() method call.
activate(Subscription, StreamObserver<SubscriptionUpdate>) - Method in class io.spine.server.SubscriptionService
 
activeEntityQueryParams(RecordStorage<?>) - Static method in class io.spine.server.entity.storage.QueryParameters
Creates a new QueryParameters instance which includes filters for column lifecycle flags to equal false.
add(Repository<?, ?>) - Method in class io.spine.server.BoundedContextBuilder
Adds the passed repository to the registration list which will be processed after the Bounded Context is created.
add(BoundedContext) - Method in class io.spine.server.CommandService.Builder
Adds the BoundedContext to the builder.
add(EventFilter) - Method in class io.spine.server.entity.CompositeEventFilter.Builder
Adds a filter to the built composite filter.
add(CompositeQueryParameter) - Method in class io.spine.server.entity.storage.QueryParameters.Builder
 
add(Class<S>, Class<T>, BiFunction<S, EventContext, T>) - Method in class io.spine.server.event.Enricher.Builder
Adds a new field enrichment function.
add(BoundedContext) - Method in class io.spine.server.QueryService.Builder
 
add(BoundedContextBuilder) - Method in class io.spine.server.Server.Builder
Adds a builder for a BoundedContext to be added the server.
add(BoundedContext) - Method in class io.spine.server.SubscriptionService.Builder
 
addAll(Iterable<CompositeQueryParameter>) - Method in class io.spine.server.entity.storage.QueryParameters.Builder
 
addObserver(StreamObserver<ExternalMessage>) - Method in class io.spine.server.transport.Subscriber
Adds an observer, which will be receiving the subscription updates.
addService(BindableService) - Method in class io.spine.server.transport.GrpcContainer.Builder
 
addShutdownHook() - Method in class io.spine.server.transport.GrpcContainer
Makes the JVM shut down the service when it is shutting down itself.
Aggregate<I,S extends com.google.protobuf.Message,B extends io.spine.validate.ValidatingBuilder<S,? extends com.google.protobuf.Message.Builder>> - Class in io.spine.server.aggregate
Abstract base for aggregates.
Aggregate(I) - Constructor for class io.spine.server.aggregate.Aggregate
Creates a new instance.
aggregateClass() - Method in class io.spine.server.aggregate.AggregateRepository
Obtains class information of aggregates managed by this repository.
AggregateCommandDelivery<I,A extends Aggregate<I,?,?>> - Class in io.spine.server.aggregate
A strategy on delivering the commands to the instances of a certain aggregate type.
AggregateCommandDelivery(AggregateRepository<I, A>) - Constructor for class io.spine.server.aggregate.AggregateCommandDelivery
 
AggregateDelivery<I,A extends Aggregate<I,?,?>,E extends io.spine.core.ActorMessageEnvelope<?,?,?>,S extends ShardedStream<I,?,E>,B extends ShardedStream.AbstractBuilder<I,E,B,S>> - Class in io.spine.server.aggregate
A strategy on delivering the messages to the instances of a certain aggregate type.
AggregateDelivery.AggregateMessageConsumer<I,A extends Aggregate<I,?,?>,E extends io.spine.core.ActorMessageEnvelope<?,?,?>,S extends ShardedStream<I,?,E>,B extends ShardedStream.AbstractBuilder<I,E,B,S>> - Class in io.spine.server.aggregate
 
AggregateEventDelivery<I,A extends Aggregate<I,?,?>> - Class in io.spine.server.aggregate
A strategy on delivering the events to the instances of a certain aggregate type.
AggregateEventDelivery(AggregateRepository<I, A>) - Constructor for class io.spine.server.aggregate.AggregateEventDelivery
 
AggregateField - Enum in io.spine.server.aggregate
A container for the storage fields specific for the AggregateStorage and its implementations.
AggregateMessageConsumer(DeliveryTag, Repository<I, A>) - Constructor for class io.spine.server.aggregate.AggregateDelivery.AggregateMessageConsumer
 
AggregatePart<I,S extends com.google.protobuf.Message,B extends io.spine.validate.ValidatingBuilder<S,? extends com.google.protobuf.Message.Builder>,R extends AggregateRoot<I>> - Class in io.spine.server.aggregate
A part of a larger aggregate.
AggregatePart(R) - Constructor for class io.spine.server.aggregate.AggregatePart
Creates a new instance of the aggregate part.
AggregatePart.GenericParameter - Enum in io.spine.server.aggregate
Enumeration of generic type parameters of this class.
AggregatePartRepository<I,A extends AggregatePart<I,?,?,R>,R extends AggregateRoot<I>> - Class in io.spine.server.aggregate
Common abstract base for repositories that manage AggregateParts.
AggregatePartRepository() - Constructor for class io.spine.server.aggregate.AggregatePartRepository
Creates a new instance.
AggregateRepository<I,A extends Aggregate<I,?,?>> - Class in io.spine.server.aggregate
The repository which manages instances of Aggregates.
AggregateRepository() - Constructor for class io.spine.server.aggregate.AggregateRepository
Creates a new instance.
AggregateRoot<I> - Class in io.spine.server.aggregate
A root object for a larger aggregate.
AggregateRoot(BoundedContext, I) - Constructor for class io.spine.server.aggregate.AggregateRoot
Creates an new instance.
AggregateStateId<I> - Class in io.spine.server.stand
An identifier for the state of a certain Aggregate.
aggregateStorage() - Method in class io.spine.server.aggregate.AggregateRepository
Returns the storage assigned to this aggregate.
AggregateStorage<I> - Class in io.spine.server.aggregate
An event-sourced storage of aggregate part events and snapshots.
AggregateStorage(boolean) - Constructor for class io.spine.server.aggregate.AggregateStorage
 
allIndexes() - Method in interface io.spine.server.delivery.ShardingStrategy
Obtains all possible indexes of existing shards.
allIndexes() - Method in class io.spine.server.delivery.UniformAcrossTargets
 
allowAll() - Static method in interface io.spine.server.entity.EventFilter
Obtains an EventFilter which always returns the input event without any change.
allowEvents(Class<? extends EventMessage>...) - Static method in class io.spine.server.entity.EventWhiteList
Creates a new instance of EventWhiteList allowing events of the given types.
and(EntityColumn, ColumnFilter) - Method in class io.spine.server.entity.storage.CompositeQueryParameter
Merges current instance with the given filter.
append(Event) - Method in class io.spine.server.event.EventStore
Appends the passed event to the history of events.
appendAll(Iterable<Event>) - Method in class io.spine.server.event.EventStore
Appends the passed events to the history of events.
appendFilter(BusFilter<E>) - Method in class io.spine.server.bus.BusBuilder
Adds the given filter to the builder.
appEngineVersion() - Method in class io.spine.server.ServerEnvironment
Returns the current Google AppEngine version or null if the program is running not on the AppEngine.
Apply - Annotation Type in io.spine.server.aggregate
Marks a method of an aggregate as one that modifies the state of the aggregate with data from the passed event.
apply(M, C) - Method in interface io.spine.server.route.Route
Obtains entity ID(s) from the passed message and its context.
apply() - Method in class io.spine.server.tenant.TenantAwareFunction0
 
apply(Empty) - Method in class io.spine.server.tenant.TenantAwareFunction0
 
applyMask(FieldMask, Collection<M>) - Static method in class io.spine.server.entity.FieldMasks
Applies the given FieldMask to given collection of Messages.
applyMask(FieldMask, M) - Static method in class io.spine.server.entity.FieldMasks
Applies the FieldMask to the given Message if the mask parameter is valid.
asError() - Method in exception io.spine.server.aggregate.UnsupportedImportEventException
 
asError() - Method in exception io.spine.server.commandbus.CommandException
 
asError() - Method in exception io.spine.server.event.EventException
 
asError() - Method in exception io.spine.server.integration.UnsupportedExternalMessageException
 
asError() - Method in exception io.spine.server.stand.InvalidRequestException
 
asOptional(CommandMessage) - Static method in class io.spine.server.route.DefaultCommandRoute
Tries to obtain a target ID from the passed command message.
Assign - Annotation Type in io.spine.server.command
Marks a method as command handler.
asThrowable() - Method in exception io.spine.server.aggregate.UnsupportedImportEventException
 
asThrowable() - Method in exception io.spine.server.commandbus.CommandException
 
asThrowable() - Method in exception io.spine.server.event.EventException
 
asThrowable() - Method in exception io.spine.server.integration.UnsupportedExternalMessageException
 
asThrowable() - Method in exception io.spine.server.stand.InvalidRequestException
 
ATTR_COMMAND_TYPE_NAME - Static variable in exception io.spine.server.commandbus.CommandException
The name of the attribute of the command type reported in an error.
ATTR_EVENT_TYPE_NAME - Static variable in exception io.spine.server.event.EventException
 
awaitTermination() - Method in class io.spine.server.Server
Waits for the server to become terminated.
awaitTermination() - Method in class io.spine.server.transport.GrpcContainer
Waits for the service to become terminated.

B

bindToTransport(BoundedContextName, ShardingKey, TransportFactory) - Method in class io.spine.server.delivery.Consumer
 
BoundedContext - Annotation Type in io.spine.server.annotation
Marks a package as one belonging to a Bounded Context with the specified name.
BoundedContext - Class in io.spine.server
A logical and structural boundary of a model.
BoundedContextBuilder - Class in io.spine.server
A builder for producing BoundedContext instances.
build() - Method in class io.spine.server.aggregate.ImportBus.Builder
 
build() - Method in class io.spine.server.BoundedContextBuilder
Creates a new instance of BoundedContext with the set configurations.
build() - Method in class io.spine.server.bus.BusBuilder
Creates new instance of Bus with the set parameters.
build() - Method in class io.spine.server.CommandService.Builder
Builds a new CommandService.
build(TransportFactory) - Method in class io.spine.server.delivery.ShardedStream.AbstractBuilder
 
build() - Method in class io.spine.server.entity.CompositeEventFilter.Builder
Creates a new instance of CompositeEventFilter.
build() - Method in class io.spine.server.entity.EventFieldFilter.Builder
Creates a new instance of EventFieldFilter.
build() - Method in class io.spine.server.entity.storage.ColumnTypeRegistry.Builder
 
build() - Method in class io.spine.server.entity.storage.QueryParameters.Builder
Creates a new instance of QueryParameters with the collected parameters.
build() - Method in class io.spine.server.event.Enricher.Builder
Creates a new Enricher.
build() - Method in class io.spine.server.event.EventStore.Builder
Creates new EventStore instance.
build() - Method in class io.spine.server.integration.IntegrationBus.Builder
 
build() - Method in class io.spine.server.QueryService.Builder
Builds the QueryService.
build() - Method in class io.spine.server.Server.Builder
Creates a new instance of the server.
build() - Method in class io.spine.server.SubscriptionService.Builder
build() - Method in class io.spine.server.transport.GrpcContainer.Builder
 
Builder() - Constructor for class io.spine.server.CommandService.Builder
 
Builder() - Constructor for class io.spine.server.delivery.CommandShardedStream.Builder
 
Builder() - Constructor for class io.spine.server.delivery.EventShardedStream.Builder
 
Builder() - Constructor for class io.spine.server.integration.IntegrationBus.Builder
 
Builder() - Constructor for class io.spine.server.QueryService.Builder
 
Builder() - Constructor for class io.spine.server.stand.Stand.Builder
 
Builder() - Constructor for class io.spine.server.SubscriptionService.Builder
 
Builder() - Constructor for class io.spine.server.transport.GrpcContainer.Builder
 
Bus<T extends com.google.protobuf.Message,E extends io.spine.core.MessageEnvelope<?,T,?>,C extends io.spine.type.MessageClass<? extends com.google.protobuf.Message>,D extends MessageDispatcher<C,E,?>> - Class in io.spine.server.bus
Abstract base for buses.
Bus(BusBuilder<E, T, ?>) - Constructor for class io.spine.server.bus.Bus
 
BusBuilder<E extends io.spine.core.MessageEnvelope<?,T,?>,T extends com.google.protobuf.Message,B extends BusBuilder<E,T,B>> - Class in io.spine.server.bus
The implementation base for the bus builders.
BusBuilder() - Constructor for class io.spine.server.bus.BusBuilder
Creates a new instance of the bus builder.
BusBuilder.FieldCheck - Class in io.spine.server.bus
Verifies if required fields of a BusBuilder are set.
BusFilter<E extends io.spine.core.MessageEnvelope<?,?,?>> - Interface in io.spine.server.bus
The filter for the messages posted to a bus.
byFirstMessageField() - Static method in interface io.spine.server.route.EventRoute
Creates an event route that obtains event producer ID from an EventContext and returns it as a sole element of the the immutable set.
byProducerId() - Static method in interface io.spine.server.route.EventRoute
Creates an event route that obtains event producer ID from an EventContext and returns it as a sole element of the immutable set.

C

callDispatchers(E) - Method in class io.spine.server.bus.MulticastBus
Call the dispatchers for the messageEnvelope.
callObservers(ExternalMessage) - Method in class io.spine.server.transport.Subscriber
 
canBeEnriched(EventEnvelope) - Method in class io.spine.server.event.Enricher
Verifies if the passed message can be enriched.
cancel(Subscription, StreamObserver<Response>) - Method in class io.spine.server.stand.Stand
Cancels the Subscription.
cancel(Subscription, StreamObserver<Response>) - Method in class io.spine.server.SubscriptionService
 
canDispatch(E) - Method in interface io.spine.server.bus.MessageDispatcher
Checks if this dispatcher can dispatch the given message.
canDispatch(ExternalMessageEnvelope) - Method in class io.spine.server.entity.EventDispatchingRepository.AbstractExternalEventDispatcher
 
canDispatch(EventEnvelope) - Method in class io.spine.server.event.AbstractEventSubscriber
 
canDispatch(EventEnvelope) - Method in class io.spine.server.projection.ProjectionRepository
 
causedByRejection(Throwable) - Static method in class io.spine.server.command.Rejections
Tells whether or not the given throwable is caused by a ThrowableMessage.
ChannelHub<C extends MessageChannel> - Class in io.spine.server.transport
The hub of channels, grouped in some logical way.
ChannelHub(TransportFactory) - Constructor for class io.spine.server.transport.ChannelHub
 
checkDispatcher(D) - Method in class io.spine.server.bus.DispatcherRegistry
Ensures that the passed dispatcher is valid.
checkEntityState(S) - Method in class io.spine.server.entity.AbstractEntity
Verifies the new entity state and returns ConstraintViolations, if any.
checkFieldsSet() - Method in class io.spine.server.bus.BusBuilder
 
checkFieldsSet() - Method in class io.spine.server.commandbus.CommandBus.Builder
 
checkNotArchived() - Method in class io.spine.server.entity.AbstractVersionableEntity
Ensures that the entity is not marked as archived.
checkNotClosed() - Method in class io.spine.server.aggregate.AggregateStorage
Ensures the storage is not closed.
checkNotClosed(String) - Method in class io.spine.server.storage.AbstractStorage
Ensures the storage is not closed.
checkNotClosed() - Method in class io.spine.server.storage.AbstractStorage
Ensures the storage is not closed.
checkNotDeleted() - Method in class io.spine.server.entity.AbstractVersionableEntity
Ensures that the entity is not marked as deleted.
checkSet(Object, Class<?>, String) - Static method in class io.spine.server.bus.BusBuilder.FieldCheck
 
checkStorage(S) - Static method in class io.spine.server.entity.Repository
Ensures that the storage is not null.
clearCache() - Method in class io.spine.server.tenant.TenantRepository
Clears the cache of known tenant IDs.
clearRecentHistory() - Method in class io.spine.server.aggregate.Aggregate
clearRecentHistory() - Method in class io.spine.server.entity.TransactionalEntity
close() - Method in class io.spine.server.aggregate.AggregateRepository
 
close() - Method in class io.spine.server.BoundedContext
Closes the BoundedContext performing all necessary clean-ups.
close() - Method in class io.spine.server.bus.Bus
Closes the filters of this bus and unregisters all the dispatchers.
close() - Method in interface io.spine.server.bus.BusFilter
close() - Method in class io.spine.server.commandbus.CommandScheduler
 
close() - Method in class io.spine.server.delivery.ShardedStream
 
close() - Method in class io.spine.server.entity.Repository
Closes the repository by closing the underlying storage.
close() - Method in class io.spine.server.event.EventBus
 
close() - Method in class io.spine.server.event.EventStore
Closes the underlying storage.
close() - Method in class io.spine.server.integration.IntegrationBus
Removes all subscriptions and closes all the underlying transport channels.
close() - Method in class io.spine.server.procman.ProcessManagerRepository
 
close() - Method in class io.spine.server.projection.ProjectionRepository
 
close() - Method in class io.spine.server.stand.Stand
Dumps all TypeUrl-to-RecordBasedRepository relations.
close() - Method in class io.spine.server.storage.AbstractStorage
Closes the storage.
close() - Method in class io.spine.server.storage.memory.InMemoryProjectionStorage
 
close() - Method in class io.spine.server.storage.memory.InMemoryStorageFactory
 
close() - Method in interface io.spine.server.storage.Storage
Closes the storage.
close() - Method in interface io.spine.server.tenant.TenantIndex
Closes the index for further read or write operations.
close() - Method in class io.spine.server.transport.ChannelHub
 
close() - Method in class io.spine.server.transport.memory.InMemoryPublisher
Does nothing as there are no resources to close in the in-memory implementation.
close() - Method in class io.spine.server.transport.memory.InMemorySubscriber
Does nothing as there are no resources to close in the in-memory implementation.
closeStaleChannels() - Method in class io.spine.server.transport.ChannelHub
Closes the stale channels and removes those from the hub.
Column - Annotation Type in io.spine.server.entity.storage
An annotation, which is used to mark getters for entity columns.
ColumnRecords - Class in io.spine.server.entity.storage
A utility for dealing with the EntityRecordWithColumns and the entity columns.
ColumnType<J,S,R,C> - Interface in io.spine.server.entity.storage
An interface for handling type conversion for the entity columns.
ColumnTypeRegistry<C extends ColumnType> - Class in io.spine.server.entity.storage
A registry of type conversion strategies for the entity columns.
ColumnTypeRegistry.Builder<C extends ColumnType> - Class in io.spine.server.entity.storage
 
Command - Annotation Type in io.spine.server.command
Marks a commanding method.
CommandBus - Class in io.spine.server.commandbus
Dispatches the incoming commands to the corresponding handler.
commandBus() - Method in class io.spine.server.commandbus.CommandScheduler
Obtains CommandBus associated with this scheduler.
CommandBus.Builder - Class in io.spine.server.commandbus
The Builder for CommandBus.
CommandDispatcher<I> - Interface in io.spine.server.commandbus
Delivers commands to their handlers.
Commander - Interface in io.spine.server.command
An interface common for objects that post one or more command in response to an incoming message.
CommandException - Exception in io.spine.server.commandbus
Abstract base for exceptions related to commands.
CommandException(String, Command, Error) - Constructor for exception io.spine.server.commandbus.CommandException
Creates a new instance.
CommandHandler - Interface in io.spine.server.command
A common interface for objects which declare one or more methods assigned to handle commands, producing events in response.
CommandHandlingEntity<I,S extends com.google.protobuf.Message,B extends io.spine.validate.ValidatingBuilder<S,? extends com.google.protobuf.Message.Builder>> - Class in io.spine.server.command
An entity that handles commands.
CommandHandlingEntity(I) - Constructor for class io.spine.server.command.CommandHandlingEntity
Creates a new entity with the passed ID.
CommandPostingException - Exception in io.spine.server.commandbus
Exception that is thrown when a command could not be posted to a CommandBus.
CommandReceiver - Interface in io.spine.server.command
Common interface for all objects that receive commands in the end of the dispatching.
CommandRoute<I,M extends io.spine.base.CommandMessage> - Interface in io.spine.server.route
Obtains an ID of an entity which handles the command.
CommandRouting<I> - Class in io.spine.server.route
A routing schema used by a CommandDispatcher for delivering a command to its handler.
CommandScheduler - Class in io.spine.server.commandbus
Schedules commands delivering them to the target according to the scheduling options.
CommandScheduler() - Constructor for class io.spine.server.commandbus.CommandScheduler
 
CommandSequence.ErrorHandler - Interface in io.spine.server.commandbus
A callback for errors occurred during posting a command from the sequence to the CommandBus.
CommandService - Class in io.spine.server
The CommandService allows client applications to post commands and receive updates from the application backend.
CommandService(Map<CommandClass, BoundedContext>) - Constructor for class io.spine.server.CommandService
Constructs new instance using the map from a CommandClass to a BoundedContext instance which handles the command.
CommandService.Builder - Class in io.spine.server
 
CommandShardedStream<I> - Class in io.spine.server.delivery
The stream of commands sent to a specific shard.
CommandShardedStream.Builder<I> - Class in io.spine.server.delivery
The builder for the CommandShardedStream instances.
commandTypeAttribute(Message) - Static method in exception io.spine.server.commandbus.CommandException
Returns a map with a command type attribute.
CompositeEventFilter - Class in io.spine.server.entity
An EventFilter which composes several other filters.
CompositeEventFilter.Builder - Class in io.spine.server.entity
A builder for the CompositeEventFilter instances.
CompositeQueryParameter - Class in io.spine.server.entity.storage
A set of ColumnFilter instances joined by a logical composite operator.
conjunct(Iterable<CompositeQueryParameter>) - Method in class io.spine.server.entity.storage.CompositeQueryParameter
Merges current instance with the given instances by the rules of conjunction.
Consumer<I,E extends Entity<I,?>,M extends io.spine.core.ActorMessageEnvelope<?,?,?>,S extends ShardedStream<I,?,M>,B extends ShardedStream.AbstractBuilder<I,M,B,S>> - Class in io.spine.server.delivery
The consuming part of the Delivery.
Consumer(DeliveryTag, Repository<I, E>) - Constructor for class io.spine.server.delivery.Consumer
 
contains(BoundedContext) - Method in class io.spine.server.CommandService.Builder
Verifies if the passed BoundedContext was previously added to the builder.
contains(BoundedContext) - Method in class io.spine.server.QueryService.Builder
 
convertColumnValue(J) - Method in interface io.spine.server.entity.storage.ColumnType
Converts the EntityColumn specified in the Entity declaration to the type in which the Field is stored.
convertColumnValue(T) - Method in class io.spine.server.entity.storage.SimpleColumnType
 
copyFor(BoundedContextName, boolean) - Method in class io.spine.server.storage.memory.InMemoryStorageFactory
 
copyFor(BoundedContextName, boolean) - Method in interface io.spine.server.storage.StorageFactory
Creates a new instance for serving a BoundedContext with the passed name and multi-tenancy status.
create(I) - Method in class io.spine.server.aggregate.AggregatePartRepository
 
create(I) - Method in class io.spine.server.aggregate.AggregateRepository
 
create(I) - Method in interface io.spine.server.entity.EntityFactory
Creates a new entity with the passed ID.
create(I) - Method in class io.spine.server.entity.RecordBasedRepository
 
create(I) - Method in class io.spine.server.entity.Repository
Create a new entity instance with its default state.
create(EntityRecord, Entity<?, ?>, RecordStorage<?>) - Static method in class io.spine.server.entity.storage.EntityRecordWithColumns
Creates a new instance of the EntityRecordWithColumns with EntityColumn values from the given Entity.
create(I) - Method in class io.spine.server.procman.ProcessManagerRepository
 
create(I) - Method in class io.spine.server.projection.ProjectionRepository
 
createAggregateStorage(Class<? extends Aggregate<I, ?, ?>>) - Method in class io.spine.server.storage.memory.InMemoryStorageFactory
NOTE: the parameter is unused.
createAggregateStorage(Class<? extends Aggregate<I, ?, ?>>) - Method in interface io.spine.server.storage.StorageFactory
Creates a new AggregateStorage instance.
createCommandErrorHandler() - Method in class io.spine.server.BoundedContext
Creates a CommandErrorHandler for objects that handle commands.
createDefault(StorageFactory) - Static method in interface io.spine.server.tenant.TenantIndex
Creates default implementation of TenantIndex for multi-tenant context.
createError(String, Command, CommandValidationError) - Static method in exception io.spine.server.commandbus.CommandException
 
createEvent(EventMessage, Version) - Method in class io.spine.server.event.EventFactory
Creates an event for the passed event message.
createExternalDispatcher() - Method in class io.spine.server.event.AbstractEventSubscriber
 
createExternalDispatcher() - Method in interface io.spine.server.integration.ExternalDispatcherFactory
Creates and returns new ExternalMessageDispatcher if implementing object dispatches at least one external message.
createExternalDispatcher() - Method in class io.spine.server.procman.ProcessManagerRepository
 
createExternalDispatcher() - Method in class io.spine.server.projection.ProjectionRepository
 
createProjectionStorage(Class<? extends Projection<I, ?, ?>>) - Method in class io.spine.server.storage.memory.InMemoryStorageFactory
 
createProjectionStorage(Class<? extends Projection<I, ?, ?>>) - Method in interface io.spine.server.storage.StorageFactory
Creates a new ProjectionStorage instance.
createPublisher(ChannelId) - Method in class io.spine.server.transport.memory.InMemoryTransportFactory
 
createPublisher(ChannelId) - Method in interface io.spine.server.transport.TransportFactory
Creates a Publisher channel with the given ID.
createRecordStorage(Class<? extends Entity<I, ?>>) - Method in class io.spine.server.storage.memory.InMemoryStorageFactory
 
createRecordStorage(Class<? extends Entity<I, ?>>) - Method in interface io.spine.server.storage.StorageFactory
Creates a new RecordStorage instance.
createRegistry() - Method in class io.spine.server.aggregate.ImportBus
 
createRegistry() - Method in class io.spine.server.bus.Bus
Factory method for creating an instance of the registry for dispatchers of the bus.
createRegistry() - Method in class io.spine.server.commandbus.CommandBus
 
createRegistry() - Method in class io.spine.server.event.EventBus
 
createRegistry() - Method in class io.spine.server.integration.IntegrationBus
 
createRejectionEvent(RejectionMessage, Version, RejectionEventContext) - Method in class io.spine.server.event.EventFactory
Creates a rejection event for the passed rejection message.
createStorage(StorageFactory) - Method in class io.spine.server.aggregate.AggregateRepository
Creates aggregate storage for the repository.
createStorage(StorageFactory) - Method in class io.spine.server.entity.RecordBasedRepository
 
createStorage(StorageFactory) - Method in class io.spine.server.entity.Repository
Creates the storage using the passed factory.
createStorage(StorageFactory) - Method in class io.spine.server.projection.ProjectionRepository
 
createStream() - Method in class io.spine.server.delivery.CommandShardedStream.Builder
 
createStream() - Method in class io.spine.server.delivery.EventShardedStream.Builder
 
createStream() - Method in class io.spine.server.delivery.ShardedStream.AbstractBuilder
 
createSubscriber(ChannelId) - Method in class io.spine.server.transport.memory.InMemoryTransportFactory
 
createSubscriber(ChannelId) - Method in interface io.spine.server.transport.TransportFactory
Creates a Subscriber channel with the given ID.

D

DefaultCommandRoute<I> - Class in io.spine.server.route
Obtains a command target entity ID based on a command message and context.
DefaultRecordBasedRepository<I,E extends AbstractEntity<I,S>,S extends com.google.protobuf.Message> - Class in io.spine.server.entity
Implementation of RecordBasedRepository that manages entities derived from AbstractEntity.
DefaultRecordBasedRepository() - Constructor for class io.spine.server.entity.DefaultRecordBasedRepository
Creates a new instance with the factory of entities of class specified as the <E> generic parameter, and with the default entity storage converter.
delete(I) - Method in class io.spine.server.storage.memory.InMemoryProjectionStorage
 
delete(I) - Method in class io.spine.server.storage.memory.InMemoryRecordStorage
 
delete(I) - Method in class io.spine.server.storage.RecordStorage
Deletes the record with the passed ID.
deliverNow(I, M) - Method in class io.spine.server.delivery.Consumer
Delivers the envelope to the entity of the given ID taking into account the target tenant.
DeliveryTag - Class in io.spine.server.delivery
A value, that defines the message destination in the delivery process.
discardEvents(Class<? extends EventMessage>...) - Static method in class io.spine.server.entity.EventBlackList
Creates a new instance of EventBlackList discarding events of the given types.
dispatch(CommandEnvelope) - Method in class io.spine.server.aggregate.AggregateRepository
Dispatches the passed command to an aggregate.
dispatch(EventEnvelope) - Method in class io.spine.server.aggregate.ImportBus
 
dispatch(E) - Method in class io.spine.server.bus.Bus
Passes the given envelope for dispatching.
dispatch(E) - Method in interface io.spine.server.bus.MessageDispatcher
Dispatches the message contained in the passed envelope.
dispatch(CommandEnvelope) - Method in class io.spine.server.command.AbstractCommander
 
dispatch(CommandEnvelope) - Method in class io.spine.server.command.AbstractCommandHandler
Dispatches the command to the handler method and posts resulting events to the EventBus.
dispatch(CommandEnvelope) - Method in class io.spine.server.commandbus.CommandBus
 
dispatch(ExternalMessageEnvelope) - Method in class io.spine.server.entity.EventDispatchingRepository.AbstractExternalEventDispatcher
 
dispatch(EventEnvelope) - Method in class io.spine.server.entity.EventDispatchingRepository
Dispatches the event to the corresponding entities.
dispatch(EventEnvelope) - Method in class io.spine.server.event.AbstractEventSubscriber
Dispatches event to the handling method.
dispatch(EventEnvelope) - Method in class io.spine.server.event.EventBus
 
dispatch(ExternalMessageEnvelope) - Method in class io.spine.server.integration.IntegrationBus
 
dispatchCommand(CommandEnvelope) - Method in class io.spine.server.aggregate.Aggregate
Obtains a method for the passed command and invokes it.
dispatchCommand(CommandEnvelope) - Method in class io.spine.server.command.CommandHandlingEntity
Dispatches the passed command to appropriate handler.
dispatchCommand(CommandEnvelope) - Method in class io.spine.server.procman.ProcessManager
Dispatches the command to the handling method.
dispatchCommand(CommandEnvelope) - Method in class io.spine.server.procman.ProcessManagerRepository
Dispatches the command to a corresponding process manager.
DispatcherRegistry<C extends io.spine.type.MessageClass<? extends com.google.protobuf.Message>,E extends io.spine.core.MessageEnvelope<?,?,?>,D extends MessageDispatcher<C,E,?>> - Class in io.spine.server.bus
A registry of message dispatchers.
DispatcherRegistry() - Constructor for class io.spine.server.bus.DispatcherRegistry
 
dispatchesCommands() - Method in interface io.spine.server.commandbus.CommandDispatcher
Verifies if this instance dispatches at least one command.
dispatchesEvents() - Method in interface io.spine.server.event.EventDispatcher
Verifies if this instance dispatches at least one domestic event.
dispatchesExternalEvents() - Method in interface io.spine.server.event.EventDispatcher
Verifies if this instance dispatches at least one external event.
dispatchEvent(EventEnvelope) - Method in class io.spine.server.aggregate.AggregateRepository
Dispatches event to one or more aggregates reacting on the event.
dispatchEvent(EventEnvelope) - Method in class io.spine.server.command.AbstractCommander
 
dispatchTo(I, Event) - Method in class io.spine.server.entity.EventDispatchingRepository
Dispatches the given event to an entity with the given ID.
dispatchTo(I, Event) - Method in class io.spine.server.procman.ProcessManagerRepository
Dispatches the given event to an entity with the given ID.
dispatchTo(I, Event) - Method in class io.spine.server.projection.ProjectionRepository
Dispatches the given event to an entity with the given ID.
doBackward(EntityRecord) - Method in class io.spine.server.entity.EntityStorageConverter
 
doForward(E) - Method in class io.spine.server.entity.EntityStorageConverter
 
doSchedule(Command) - Method in class io.spine.server.commandbus.CommandScheduler
Schedules a command and delivers it to the target according to the scheduling options set to a context.
doSchedule(Command) - Method in class io.spine.server.commandbus.ExecutorCommandScheduler
 
DuplicateCommandException - Exception in io.spine.server.commandbus
Reports an attempt to dispatch a duplicate command.
DuplicateEventException - Exception in io.spine.server.event
Reports an attempt to dispatch a duplicate event.
DuplicateEventException(Event) - Constructor for exception io.spine.server.event.DuplicateEventException
 

E

Either - Class in io.spine.server.tuple
Abstract base for a values that can be one of the possible types.
Either(Message, int) - Constructor for class io.spine.server.tuple.Either
 
EitherOf2<A extends com.google.protobuf.Message,B extends com.google.protobuf.Message> - Class in io.spine.server.tuple
A value which can be one of two possible types.
EitherOf3<A extends com.google.protobuf.Message,B extends com.google.protobuf.Message,C extends com.google.protobuf.Message> - Class in io.spine.server.tuple
A value which can be of one of three possible types.
EitherOf4<A extends com.google.protobuf.Message,B extends com.google.protobuf.Message,C extends com.google.protobuf.Message,D extends com.google.protobuf.Message> - Class in io.spine.server.tuple
A value which can be of one of four possible types.
EitherOf5<A extends com.google.protobuf.Message,B extends com.google.protobuf.Message,C extends com.google.protobuf.Message,D extends com.google.protobuf.Message,E extends com.google.protobuf.Message> - Class in io.spine.server.tuple
A value which can be of one of five possible types.
enrich(EventEnvelope) - Method in class io.spine.server.event.Enricher
Enriches the passed message.
enrich(EventEnvelope) - Method in class io.spine.server.event.EventBus
 
Enricher - Class in io.spine.server.event
Enriches events after they are stored, and before they are dispatched.
enricher() - Method in class io.spine.server.event.EventBus
Obtains Enricher used by this Event Bus.
Enricher.Builder - Class in io.spine.server.event
The Builder allows to register EnrichmentFunctions handled by the Enricher and set a custom translation function, if needed.
Entity<I,S extends com.google.protobuf.Message> - Interface in io.spine.server.entity
A server-side object with an identity.
Entity(TenantId) - Constructor for class io.spine.server.tenant.TenantRepository.Entity
 
Entity(TenantId, Function<TenantId, T>) - Constructor for class io.spine.server.tenant.TenantRepository.Entity
 
Entity.GenericParameter - Enum in io.spine.server.entity
Enumeration of generic type parameters of this interface.
entityClass() - Method in class io.spine.server.entity.Repository
Obtains model class for the entities managed by this repository.
EntityColumn - Class in io.spine.server.entity.storage
An Entity field stored in a way allowing ordering and filtering.
entityConverter() - Method in class io.spine.server.entity.DefaultRecordBasedRepository
 
entityConverter() - Method in class io.spine.server.entity.RecordBasedRepository
Obtains EntityStorageConverter associated with this repository.
entityConverter() - Method in class io.spine.server.projection.ProjectionRepository
Obtains EntityStorageConverter associated with this repository.
entityFactory() - Method in class io.spine.server.entity.DefaultRecordBasedRepository
 
EntityFactory<I,E extends Entity<I,?>> - Interface in io.spine.server.entity
Base interface for objects that can create entities.
entityFactory() - Method in class io.spine.server.entity.RecordBasedRepository
Obtains EntityFactory associated with this repository.
EntityField - Enum in io.spine.server.storage
A container for the storage fields used in multiple storages.
EntityQuery<I> - Class in io.spine.server.entity.storage
A query to a RecordStorage for the records matching the given parameters.
EntityRecordWithColumns - Class in io.spine.server.entity.storage
A value of EntityRecord associated with its columns.
EntityStateEnvelope<I,S extends com.google.protobuf.Message> - Class in io.spine.server.entity
An envelope holder of the entity state.
EntityStorageConverter<I,E extends Entity<I,S>,S extends com.google.protobuf.Message> - Class in io.spine.server.entity
An abstract base for converters of entities into EntityRecord.
EntityStorageConverter(TypeUrl, EntityFactory<I, E>, FieldMask) - Constructor for class io.spine.server.entity.EntityStorageConverter
 
EntityWithLifecycle<I,S extends com.google.protobuf.Message> - Interface in io.spine.server.entity
An entity which has lifecycle flags.
Enumerated - Annotation Type in io.spine.server.entity.storage
Mark an entity column as an enumerated value.
EnumType - Enum in io.spine.server.entity.storage
Enumeration of persistence methods for the enumerated values.
EnvelopeValidator<E extends io.spine.core.MessageEnvelope<?,?,?>> - Interface in io.spine.server.bus
An interface defining the validator for a MessageEnvelope.
equals(Object) - Method in class io.spine.server.command.AbstractCommandDispatcher
Indicates whether some another command handler is "equal to" this one.
equals(Object) - Method in class io.spine.server.delivery.DeliveryTag
 
equals(Object) - Method in class io.spine.server.delivery.ShardedStream
 
equals(Object) - Method in class io.spine.server.delivery.ShardingKey
 
equals(Object) - Method in class io.spine.server.delivery.UniformAcrossTargets
 
equals(Object) - Method in class io.spine.server.entity.AbstractEntity
 
equals(Object) - Method in class io.spine.server.entity.AbstractVersionableEntity
 
equals(Object) - Method in class io.spine.server.entity.EntityStateEnvelope
 
equals(Object) - Method in class io.spine.server.entity.EntityStorageConverter
 
equals(Object) - Method in class io.spine.server.entity.RecentHistory
 
equals(Object) - Method in class io.spine.server.entity.storage.CompositeQueryParameter
 
equals(Object) - Method in class io.spine.server.entity.storage.EntityColumn
 
equals(Object) - Method in class io.spine.server.entity.storage.EntityQuery
 
equals(Object) - Method in class io.spine.server.entity.storage.EntityRecordWithColumns
 
equals(Object) - Method in class io.spine.server.entity.storage.QueryParameters
 
equals(Object) - Method in class io.spine.server.integration.AbstractChannelObserver
 
equals(Object) - Method in class io.spine.server.stand.AggregateStateId
 
equals(Object) - Method in class io.spine.server.storage.memory.StorageSpec
 
equals(Object) - Method in class io.spine.server.tuple.Either
 
equals(Object) - Method in class io.spine.server.tuple.Tuple
 
error(Message, String) - Static method in exception io.spine.server.commandbus.DuplicateCommandException
Creates a duplicate command error.
EventBlackList - Class in io.spine.server.entity
An EventFilter which allows any events except for the events of given types.
EventBus - Class in io.spine.server.event
Dispatches incoming events to subscribers, and provides ways for registering those subscribers.
EventBus.Builder - Class in io.spine.server.event
The Builder for EventBus.
EventContextField - Enum in io.spine.server.event.storage
Enumeration of storage fields required for storing EventContext.
EventDispatcher<I> - Interface in io.spine.server.event
EventDispatcher delivers events to receiving objects.
EventDispatchingRepository<I,E extends AbstractVersionableEntity<I,S>,S extends com.google.protobuf.Message> - Class in io.spine.server.entity
Abstract base for repositories that deliver events to entities they manage.
EventDispatchingRepository(EventRoute<I, EventMessage>) - Constructor for class io.spine.server.entity.EventDispatchingRepository
Creates new repository instance.
EventDispatchingRepository.AbstractExternalEventDispatcher - Class in io.spine.server.entity
An abstract base for the external message dispatchers, enabling the EventDispatchingRepository instances to handle external events.
EventException - Exception in io.spine.server.event
A base for exceptions related to events.
EventException(String, EventMessage, Error) - Constructor for exception io.spine.server.event.EventException
Creates a new instance.
EventFactory - Class in io.spine.server.event
Produces events in response to a command.
EventFactory(MessageEnvelope<?, ?, ?>, Any) - Constructor for class io.spine.server.event.EventFactory
 
EventField - Enum in io.spine.server.event.storage
Enumeration of storage fields required for storing events.
EventFieldFilter - Class in io.spine.server.entity
An EventFilter which allows all the events but trims some of their message fields.
EventFieldFilter.Builder - Class in io.spine.server.entity
A builder for the EventFieldFilter instances.
EventFilter - Interface in io.spine.server.entity
A filter accepting Events posted by a Repository.
eventFilter() - Method in class io.spine.server.entity.Repository
Creates an EventFilter for this repository.
eventFilter() - Method in class io.spine.server.procman.ProcessManagerRepository
Creates an EventFilter for this repository.
EventProducer - Interface in io.spine.server
An object with identity which produces events.
EventReactor - Interface in io.spine.server.event
A event reactor declares methods that receive events and may generate other events in response.
EventReceiver - Interface in io.spine.server.event
Common interface for objects receiving events.
EventRoute<I,M extends io.spine.base.EventMessage> - Interface in io.spine.server.route
Obtains a set of entity IDs for which to deliver an event.
EventRouting<I> - Class in io.spine.server.route
A routing schema used to deliver events.
EventShardedStream<I> - Class in io.spine.server.delivery
The stream of events sent to a specific shard.
EventShardedStream.Builder<I> - Class in io.spine.server.delivery
The builder for the EventShardedStream instances.
EventStore - Class in io.spine.server.event
A store of all events in a bounded context.
EventStore.Builder - Class in io.spine.server.event
Builder for creating new EventStore instance.
EventSubscriber - Interface in io.spine.server.event
An event subscriber declares one or more methods subscribed to events.
eventTypeAttribute(Message) - Static method in exception io.spine.server.event.EventException
Returns a map with an event type attribute.
EventWhiteList - Class in io.spine.server.entity
An EventFilter which allows only events of given types.
execute(Query, StreamObserver<QueryResponse>) - Method in class io.spine.server.stand.Stand
Reads a particular set of items from the read-side of the application and feed the result into an instance.
execute(F) - Method in class io.spine.server.tenant.TenantAwareFunction
Returns the result of applying the function to the passed input.
execute() - Method in class io.spine.server.tenant.TenantAwareFunction0
 
execute() - Method in class io.spine.server.tenant.TenantAwareOperation
Executes the operation.
ExecutorCommandScheduler - Class in io.spine.server.commandbus
The command scheduler implementation which uses basic Java task scheduling features.
ExecutorCommandScheduler() - Constructor for class io.spine.server.commandbus.ExecutorCommandScheduler
 
expectedDefault(Message, Message) - Method in class io.spine.server.command.CommandHandlingEntity
Creates ValueMismatch for the case of discovering a non-default value, when the default value was expected by a command.
expectedEmpty(String, String) - Method in class io.spine.server.command.CommandHandlingEntity
Creates ValueMismatch for the case of discovering a non-empty value, when an empty string was expected by a command.
expectedNotDefault(Message) - Method in class io.spine.server.command.CommandHandlingEntity
Creates a ValueMismatch for a command that wanted to clear a value, but discovered that the field already has the default value.
expectedNotDefault(Message, Message) - Method in class io.spine.server.command.CommandHandlingEntity
Creates a ValueMismatch for a command that wanted to change a field value, but discovered that the field has the default value.
expectedNotEmpty(String) - Method in class io.spine.server.command.CommandHandlingEntity
Creates a ValueMismatch for a command that wanted to clear a string value, but discovered that the field is already empty.
ExternalDispatcherFactory<I> - Interface in io.spine.server.integration
Creates external message dispatcher.
ExternalMessageDispatcher<I> - Interface in io.spine.server.integration
Delivers messages produced outside of the current BoundedContext to dispatchers, that are configured to receive external events.
ExternalMessageEnvelope - Class in io.spine.server.integration
An envelope for the messages, produced outside of the current bounded context.

F

feedColumnsTo(D, EntityRecordWithColumns, ColumnTypeRegistry<? extends ColumnType<?, ?, D, I>>, Function<String, I>) - Static method in class io.spine.server.entity.storage.ColumnRecords
Feeds the given EntityRecordWithColumns to the given record representation.
fetchHistory(I) - Method in class io.spine.server.aggregate.AggregateRepository
Fetches the history of the Aggregate with the given ID.
FieldMasks - Class in io.spine.server.entity
A utility class for creating instances of FieldMask and processing them against instances of Message.
filter(EventMessage) - Method in class io.spine.server.entity.CompositeEventFilter
 
filter(EventMessage) - Method in class io.spine.server.entity.EventBlackList
 
filter(EventMessage) - Method in class io.spine.server.entity.EventFieldFilter
 
filter(Collection<Event>) - Method in class io.spine.server.entity.EventFieldFilter
 
filter(EventMessage) - Method in interface io.spine.server.entity.EventFilter
Applies this filter to the given event.
filter(Collection<Event>) - Method in interface io.spine.server.entity.EventFilter
Applies this filter to the given Events in bulk.
filter(EventMessage) - Method in class io.spine.server.entity.EventWhiteList
 
filterChainHead() - Method in class io.spine.server.bus.Bus
Obtains the BusFilters to prepend to the chain head.
filterChainHead() - Method in class io.spine.server.commandbus.CommandBus
 
filterChainTail() - Method in class io.spine.server.bus.Bus
Obtains the BusFilters to append to the chain tail.
filterChainTail() - Method in class io.spine.server.commandbus.CommandBus
 
find(I) - Method in class io.spine.server.aggregate.AggregateRepository
Loads an aggregate by the passed ID.
find(DeliveryTag, I) - Method in class io.spine.server.delivery.InProcessSharding
Finds the message streams which delivery tag and target entity identifier match the specified values.
find(DeliveryTag, I) - Method in interface io.spine.server.delivery.Sharding
Finds the message streams which delivery tag and target entity identifier match the specified values.
find(I) - Method in class io.spine.server.entity.RecordBasedRepository
Finds an entity with the passed ID if this entity is active.
find(EntityFilters, OrderBy, Pagination, FieldMask) - Method in class io.spine.server.entity.RecordBasedRepository
Finds the entities passing the given filters and applies the given FieldMask to the results.
find(I) - Method in interface io.spine.server.entity.RepositoryView
Finds an entity with the passed ID.
findOrCreate(I) - Method in class io.spine.server.entity.RecordBasedRepository
Loads an entity by the passed ID or creates a new one, if the entity was not found.
findOrCreate(I) - Method in class io.spine.server.procman.ProcessManagerRepository
Loads or creates a process manager by the passed ID.
findOrCreate(I) - Method in class io.spine.server.projection.ProjectionRepository
Loads an entity by the passed ID or creates a new one, if the entity was not found.
forCommandsOf(Shardable) - Static method in class io.spine.server.delivery.DeliveryTag
Creates an instance of DeliveryTag that identifies the need to deliver command envelopes to entities that are sharded within the given Shardable.
forEventsOf(Shardable) - Static method in class io.spine.server.delivery.DeliveryTag
Creates an instance of DeliveryTag that identifies the need to deliver event envelopes to entities that are sharded within the given Shardable.
forNumber(int) - Static method in class io.spine.server.delivery.UniformAcrossTargets
Creates a strategy of uniform target distribution across shards, for a given shard number.
from(Method) - Static method in class io.spine.server.entity.storage.EntityColumn
Creates new instance of the EntityColumn from the given getter method.
from(EventEnvelope) - Static method in class io.spine.server.event.RejectionEnvelope
Creates a new RejectionEnvelope from the given event.
from(CommandEnvelope, Throwable) - Static method in class io.spine.server.event.RejectionEnvelope
Creates an instance of Rejection from the rejected command and a Throwable caused by the ThrowableMessage.

G

get(EntityColumn) - Method in class io.spine.server.entity.storage.ColumnTypeRegistry
Retrieves the ColumnType for specified EntityColumn.
get(Class<M>) - Method in class io.spine.server.route.CommandRouting
Obtains a route for the passed command class.
get(Class<M>) - Method in class io.spine.server.route.EventRouting
Obtains a route for the passed event class.
get() - Method in class io.spine.server.storage.StorageFactorySwitch
Obtains StorageFactory for the current execution mode.
get(ChannelId) - Method in class io.spine.server.transport.ChannelHub
Obtains a channel from this hub according to the channel ID.
get(Either, int) - Static method in class io.spine.server.tuple.Either
 
get(int) - Method in class io.spine.server.tuple.Tuple
Obtains a value at the specified index.
getA() - Method in class io.spine.server.tuple.EitherOf2
Obtains the value of the first alternative.
getA() - Method in class io.spine.server.tuple.EitherOf3
Obtains the value of the first alternative.
getA() - Method in class io.spine.server.tuple.EitherOf4
Obtains the value of the first alternative.
getA() - Method in class io.spine.server.tuple.EitherOf5
Obtains the value of the first alternative.
getA() - Method in class io.spine.server.tuple.Pair
 
getA() - Method in class io.spine.server.tuple.Quartet
 
getA() - Method in class io.spine.server.tuple.Quintet
 
getA() - Method in class io.spine.server.tuple.Triplet
 
getActorContext() - Method in class io.spine.server.event.RejectionEnvelope
 
getAggregateId() - Method in class io.spine.server.stand.AggregateStateId
 
getAll() - Method in interface io.spine.server.tenant.TenantIndex
Obtains the set of all stored tenant IDs.
getAll() - Method in class io.spine.server.tenant.TenantRepository
 
getB() - Method in class io.spine.server.tuple.EitherOf2
Obtains the value of the second alternative.
getB() - Method in class io.spine.server.tuple.EitherOf3
Obtains the value of the second alternative.
getB() - Method in class io.spine.server.tuple.EitherOf4
Obtains the value of the second alternative.
getB() - Method in class io.spine.server.tuple.EitherOf5
Obtains the value of the second alternative.
getB() - Method in class io.spine.server.tuple.Pair
 
getB() - Method in class io.spine.server.tuple.Quartet
 
getB() - Method in class io.spine.server.tuple.Quintet
 
getB() - Method in class io.spine.server.tuple.Triplet
 
getBoundedContext() - Method in class io.spine.server.entity.Repository
Obtains BoundedContext to which this repository belongs.
getBoundedContextName() - Method in class io.spine.server.aggregate.AggregateRepository
 
getBoundedContextName() - Method in class io.spine.server.delivery.DeliveryTag
 
getBoundedContextName() - Method in interface io.spine.server.delivery.Shardable
Obtains the name of the bounded context, in scope of which the current Shardable operates.
getBoundedContextName() - Method in class io.spine.server.delivery.ShardedStream.AbstractBuilder
 
getBoundedContextName() - Method in class io.spine.server.integration.IntegrationBus.Builder
 
getBoundedContextName() - Method in class io.spine.server.procman.ProcessManagerRepository
 
getBoundedContextName() - Method in class io.spine.server.projection.ProjectionRepository
 
getBoundedContextName() - Method in class io.spine.server.storage.memory.StorageSpec
 
getBoundedContexts() - Method in class io.spine.server.SubscriptionService.Builder
 
getBuilder() - Method in class io.spine.server.aggregate.Aggregate
Obtains the instance of the state builder.
getBuilder() - Method in class io.spine.server.entity.TransactionalEntity
Obtains the instance of the state builder.
getBuilder() - Method in class io.spine.server.procman.ProcessManager
Obtains the instance of the state builder.
getBuilder() - Method in class io.spine.server.projection.Projection
Obtains the instance of the state builder.
getC() - Method in class io.spine.server.tuple.EitherOf3
Obtains the value of the third alternative.
getC() - Method in class io.spine.server.tuple.EitherOf4
Obtains the value of the third alternative.
getC() - Method in class io.spine.server.tuple.EitherOf5
Obtains the value of the third alternative.
getC() - Method in class io.spine.server.tuple.Quartet
 
getC() - Method in class io.spine.server.tuple.Quintet
 
getC() - Method in class io.spine.server.tuple.Triplet
 
getCallbackExecutor() - Method in class io.spine.server.stand.Stand.Builder
 
getColumnNames() - Method in class io.spine.server.entity.storage.EntityRecordWithColumns
Obtains entity column names for the record.
getCommand() - Method in exception io.spine.server.commandbus.CommandException
Returns a related command.
getCommandBus() - Method in class io.spine.server.BoundedContext
Obtains instance of CommandBus of this BoundedContext.
getCommandBus() - Method in class io.spine.server.BoundedContextBuilder
 
getCommandClasses() - Method in class io.spine.server.procman.ProcessManagerRepository
Obtains a set of classes of commands handled by process managers of this repository.
getCommandEndpointDelivery() - Method in class io.spine.server.aggregate.AggregateRepository
Defines a strategy of command delivery applied to the instances managed by this repository.
getCommandEndpointDelivery() - Method in class io.spine.server.procman.ProcessManagerRepository
Defines a strategy of command delivery applied to the instances managed by this repository.
getCommandMessage() - Method in exception io.spine.server.commandbus.CommandPostingException
Obtains the command message of the command which could not be posted.
getCommandRouting() - Method in class io.spine.server.aggregate.AggregateRepository
Obtains command routing instance used by this repository.
getCommandRouting() - Method in class io.spine.server.procman.ProcessManagerRepository
Obtains command routing schema used by this repository.
getCommandScheduler() - Method in class io.spine.server.commandbus.CommandBus.Builder
 
getConsumer() - Method in class io.spine.server.delivery.ShardedStream.AbstractBuilder
 
getContext() - Method in exception io.spine.server.commandbus.CommandPostingException
Obtains the context of the command which could not be posted.
getD() - Method in class io.spine.server.tuple.EitherOf4
Obtains the value of the third alternative.
getD() - Method in class io.spine.server.tuple.EitherOf5
Obtains the value of the third alternative.
getD() - Method in class io.spine.server.tuple.Quartet
 
getD() - Method in class io.spine.server.tuple.Quintet
 
getDeadMessageHandler() - Method in class io.spine.server.aggregate.ImportBus
 
getDeadMessageHandler() - Method in class io.spine.server.bus.Bus
Obtains the instance of DeadMessageHandler for this bus.
getDeadMessageHandler() - Method in class io.spine.server.commandbus.CommandBus
 
getDeadMessageHandler() - Method in class io.spine.server.event.EventBus
 
getDeadMessageHandler() - Method in class io.spine.server.integration.IntegrationBus
 
getDefault() - Method in class io.spine.server.route.CommandRouting
 
getDefault() - Method in class io.spine.server.route.EventRouting
Obtains the default route used by the schema.
getDefaultState() - Method in class io.spine.server.entity.AbstractEntity
Obtains the default state of the entity.
getDispatcher(E) - Method in class io.spine.server.bus.DispatcherRegistry
Obtains a single dispatcher (if available) for the passed message.
getDispatcher(E) - Method in class io.spine.server.bus.UnicastBus
 
getDispatcherForType(C) - Method in class io.spine.server.bus.DispatcherRegistry
Obtains a single dispatcher (if available) for the passed message.
getDispatchers(E) - Method in class io.spine.server.bus.DispatcherRegistry
Obtains dispatchers for the passed message class.
getDispatchersForType(C) - Method in class io.spine.server.bus.DispatcherRegistry
Obtains all the dispatchers for the passed message class.
getE() - Method in class io.spine.server.tuple.EitherOf5
 
getE() - Method in class io.spine.server.tuple.Quintet
 
getEndpoint(E) - Method in class io.spine.server.aggregate.AggregateDelivery.AggregateMessageConsumer
 
getEndpoint(M) - Method in class io.spine.server.delivery.Consumer
Obtains an endpoint to dispatch the given envelope.
getEndpoint(M) - Method in class io.spine.server.procman.PmDelivery.PmMessageConsumer
 
getEndpointDelivery() - Method in class io.spine.server.projection.ProjectionRepository
Defines a strategy of event delivery applied to the projections managed by this repository.
getEnricher() - Method in class io.spine.server.event.EventBus.Builder
 
getEntityClass() - Method in class io.spine.server.delivery.ShardingKey
Obtains the class of the Entity, which message dispatching is being sharded.
getEntityClass() - Method in class io.spine.server.entity.Repository
Returns the class of entities managed by this repository.
getEntityFactory() - Method in class io.spine.server.entity.EntityStorageConverter
Obtains the entity factory used by the converter.
getEntityId() - Method in class io.spine.server.entity.EntityStateEnvelope
Obtains the Entity ID.
getEntityState() - Method in exception io.spine.server.entity.InvalidEntityStateException
Returns a related event message.
getEntityStateType() - Method in class io.spine.server.entity.EntityStorageConverter
Obtains the type URL of the state of entities which this converter builds.
getEntityStateType() - Method in class io.spine.server.entity.Repository
Obtains the TypeUrl for the state objects wrapped by entities managed by this repository.
getEntityStateTypes(EntityOption.Visibility) - Method in class io.spine.server.BoundedContext
Obtains a set of entity type names by their visibility.
getEntityStateUrl() - Method in class io.spine.server.storage.memory.StorageSpec
 
getEntityVersion() - Method in class io.spine.server.entity.EntityStateEnvelope
 
getError() - Method in exception io.spine.server.entity.InvalidEntityStateException
Returns an error occurred.
getEvent() - Method in class io.spine.server.event.RejectionEnvelope
 
getEventBus() - Method in class io.spine.server.BoundedContext
Obtains instance of EventBus of this BoundedContext.
getEventBus() - Method in class io.spine.server.BoundedContextBuilder
 
getEventBus() - Method in class io.spine.server.integration.IntegrationBus.Builder
 
getEventClasses() - Method in class io.spine.server.aggregate.AggregateRepository
 
getEventClasses() - Method in class io.spine.server.command.AbstractCommander
 
getEventClasses() - Method in interface io.spine.server.event.EventDispatcher
Obtains classes of domestic events processed by this dispatcher.
getEventEndpointDelivery() - Method in class io.spine.server.aggregate.AggregateRepository
Defines a strategy of event delivery applied to the instances managed by this repository.
getEventEndpointDelivery() - Method in class io.spine.server.procman.ProcessManagerRepository
Defines a strategy of event delivery applied to the instances managed by this repository.
getEventImportRouting() - Method in class io.spine.server.aggregate.AggregateRepository
Obtains the event import routing, which by default uses producer ID of the event as the target aggregate ID.
getEventMessage() - Method in exception io.spine.server.event.EventException
Returns a related event message.
getEventRouting() - Method in class io.spine.server.aggregate.AggregateRepository
Obtains event routing instance used by this repository.
getEventRouting() - Method in class io.spine.server.entity.EventDispatchingRepository
Obtains the EventRouting schema used by the repository for calculating identifiers of event targets.
getEventStore() - Method in class io.spine.server.event.EventBus.Builder
 
getEventStore() - Method in class io.spine.server.event.EventBus
Returns EventStore associated with the bus.
getEventStoreStreamExecutor() - Method in class io.spine.server.event.EventBus.Builder
 
getExposedAggregateTypes() - Method in class io.spine.server.stand.Stand
Reads all Aggregate entity types exposed for reading by this instance of Stand.
getExposedTypes() - Method in class io.spine.server.stand.Stand
Reads all Entity types exposed for reading by this instance of Stand.
getExternalEventClasses() - Method in class io.spine.server.aggregate.AggregateRepository
 
getExternalEventClasses() - Method in class io.spine.server.command.AbstractCommander
 
getExternalEventClasses() - Method in class io.spine.server.event.AbstractEventSubscriber
 
getExternalEventClasses() - Method in interface io.spine.server.event.EventDispatcher
Obtains classes of external events processed by this dispatcher.
getExternalEventClasses() - Method in class io.spine.server.procman.ProcessManagerRepository
Obtains classes of external events on which process managers managed by this repository react.
getExternalEventClasses() - Method in class io.spine.server.projection.ProjectionRepository
 
getFieldMask() - Method in class io.spine.server.entity.EntityStorageConverter
Obtains the field mask used by this converter to trim the state of entities before the state is injected into entities.
getFilters() - Method in class io.spine.server.bus.BusBuilder
Obtains the bus filters of this builder.
getFilters() - Method in class io.spine.server.entity.storage.CompositeQueryParameter
 
getFor(Entity<?, ?>) - Method in class io.spine.server.entity.storage.EntityColumn
Retrieves the column value from the given Entity.
getId() - Method in class io.spine.server.aggregate.AggregateRoot
Obtains the aggregate ID.
getId() - Method in class io.spine.server.aggregate.ImportOrigin
 
getId() - Method in class io.spine.server.command.AbstractCommandDispatcher
Obtains identity string of the dispatcher.
getId() - Method in class io.spine.server.entity.AbstractEntity
 
getId() - Method in interface io.spine.server.entity.Entity
Obtains the identifier of the entity.
getId() - Method in class io.spine.server.entity.EntityStateEnvelope
 
getId() - Method in class io.spine.server.event.RejectionEnvelope
 
getId() - Method in class io.spine.server.integration.ExternalMessageEnvelope
 
getId() - Method in class io.spine.server.transport.AbstractChannel
 
getId() - Method in interface io.spine.server.transport.MessageChannel
An identifier of this channel.
getIdClass() - Method in class io.spine.server.entity.Repository
Returns the class of IDs used by this repository.
getIdClass() - Method in class io.spine.server.storage.memory.StorageSpec
 
getIds() - Method in class io.spine.server.entity.storage.EntityQuery
Obtains an immutable set of accepted ID values.
getImportableEventClasses() - Method in class io.spine.server.aggregate.AggregateRepository
 
getImportBus() - Method in class io.spine.server.BoundedContext
Obtains instance of ImportBus of this BoundedContext.
getIndex() - Method in enum io.spine.server.aggregate.AggregatePart.GenericParameter
 
getIndex() - Method in class io.spine.server.delivery.ShardingKey
The index of the shard, to which this sharding key corresponds.
getIndex() - Method in enum io.spine.server.entity.Entity.GenericParameter
 
getIndex() - Method in class io.spine.server.tuple.Either
Obtains a zero-based index of the value.
getInstance() - Static method in class io.spine.server.ServerEnvironment
Returns a singleton instance.
getIntegrationBus() - Method in class io.spine.server.BoundedContext
Obtains instance of IntegrationBus of this BoundedContext.
getIntegrationBus() - Method in class io.spine.server.BoundedContextBuilder
 
getKey() - Method in class io.spine.server.delivery.ShardedStream.AbstractBuilder
 
getKey() - Method in class io.spine.server.delivery.ShardedStream
Obtains the key defining the subset of entities (i.e.
getLifecycleFlags() - Method in class io.spine.server.entity.AbstractVersionableEntity
 
getLifecycleFlags() - Method in class io.spine.server.entity.storage.EntityRecordWithColumns
 
getLifecycleFlags() - Method in class io.spine.server.entity.TransactionalEntity
Obtains the current state of the entity lifecycle flags.
getLifecycleFlags() - Method in interface io.spine.server.entity.WithLifecycle
Obtains current lifecycle flags.
getLogger() - Method in class io.spine.server.event.EventStore.Builder
 
getLogLevelForPost() - Method in class io.spine.server.event.EventBus.Builder
Obtains the logging level for post operations.
getMessage() - Method in class io.spine.server.aggregate.ImportOrigin
 
getMessage() - Method in class io.spine.server.entity.EntityStateEnvelope
 
getMessage() - Method in class io.spine.server.event.RejectionEnvelope
 
getMessage() - Method in class io.spine.server.integration.ExternalMessageEnvelope
Obtains an originally transferred message.
getMessageClass() - Method in class io.spine.server.aggregate.ImportOrigin
 
getMessageClass() - Method in class io.spine.server.entity.EntityStateEnvelope
 
getMessageClass() - Method in class io.spine.server.event.RejectionEnvelope
 
getMessageClass() - Method in class io.spine.server.integration.ExternalMessageEnvelope
Obtains a message class of an originally transferred message, such as io.spine.sample.TaskCreated class.
getMessageClasses() - Method in class io.spine.server.aggregate.AggregateRepository
 
getMessageClasses() - Method in interface io.spine.server.bus.MessageDispatcher
Obtains a set of message classes that can be processed by this dispatcher.
getMessageClasses() - Method in class io.spine.server.command.AbstractCommander
 
getMessageClasses() - Method in class io.spine.server.command.AbstractCommandHandler
 
getMessageClasses() - Method in class io.spine.server.event.AbstractEventSubscriber
 
getMessageClasses() - Method in class io.spine.server.procman.ProcessManagerRepository
Obtains a set of event classes on which process managers of this repository react.
getMessageClasses() - Method in class io.spine.server.projection.ProjectionRepository
 
getMessageConsumers() - Method in class io.spine.server.aggregate.AggregateRepository
 
getMessageConsumers() - Method in interface io.spine.server.delivery.Shardable
Obtains all the message consumers for this Shardable.
getMessageConsumers() - Method in class io.spine.server.procman.ProcessManagerRepository
 
getMessageConsumers() - Method in class io.spine.server.projection.ProjectionRepository
 
getMessageContext() - Method in class io.spine.server.aggregate.ImportOrigin
 
getMessageContext() - Method in class io.spine.server.entity.EntityStateEnvelope
 
getMessageContext() - Method in class io.spine.server.event.RejectionEnvelope
 
getMessageContext() - Method in class io.spine.server.integration.ExternalMessageEnvelope
 
getMissingTxMessage() - Method in class io.spine.server.aggregate.Aggregate
Instructs to modify the state of an aggregate only within an event applier method.
getMissingTxMessage() - Method in class io.spine.server.entity.TransactionalEntity
Provides error message text for the case of not having an active transaction when a state modification call is made.
getMissingTxMessage() - Method in class io.spine.server.procman.ProcessManager
 
getMissingTxMessage() - Method in class io.spine.server.projection.Projection
 
getModelClass(Class<A>) - Method in class io.spine.server.aggregate.AggregateRepository
 
getName() - Method in class io.spine.server.BoundedContext
Obtains an ID of the bounded context.
getName() - Method in class io.spine.server.BoundedContextBuilder
Returns the previously set name or BoundedContextNames.assumingTests() if the name was not explicitly set.
getName() - Method in class io.spine.server.entity.storage.EntityColumn
Obtains the name of the column, which is used for querying.
getNumberOfShards() - Method in interface io.spine.server.delivery.ShardingStrategy
Obtains the total number of shards.
getNumberOfShards() - Method in class io.spine.server.delivery.UniformAcrossTargets
 
getObservers() - Method in class io.spine.server.transport.Subscriber
Obtains current observers registered in this instance of Subscriber, which receive the subscription updates.
getOperator() - Method in class io.spine.server.entity.storage.CompositeQueryParameter
 
getOrigin() - Method in class io.spine.server.event.RejectionEnvelope
Obtains the origin command.
getOriginMessage() - Method in class io.spine.server.event.RejectionEnvelope
Obtains the origin command message.
getOuterObject() - Method in class io.spine.server.aggregate.ImportOrigin
 
getOuterObject() - Method in class io.spine.server.entity.EntityStateEnvelope
Always returns null, as it is impossible to create a Entity instance basing just on its properties.
getParameters() - Method in class io.spine.server.entity.storage.EntityQuery
Obtains a Map of the EntityColumn metadata to the column required value.
getParameters() - Method in class io.spine.server.entity.storage.QueryParameters.Builder
 
getPartState(Class<P>) - Method in class io.spine.server.aggregate.AggregatePart
Obtains a state of another AggregatePart by its class.
getPartState(Class<S>) - Method in class io.spine.server.aggregate.AggregateRoot
Obtains a part state by its class.
getPersistedType() - Method in class io.spine.server.entity.storage.EntityColumn
Returns the type under which the column values are persisted in the data storage.
getPort() - Method in class io.spine.server.Server
Obtains the port assigned to the server.
getPort() - Method in class io.spine.server.transport.GrpcContainer.Builder
 
getProducerId() - Method in class io.spine.server.command.AbstractCommandDispatcher
Obtains ID packed into Any for being used in generated events.
getProducerId() - Method in class io.spine.server.command.CommandHandlingEntity
 
getProducerId() - Method in interface io.spine.server.EventProducer
The object identity packed into Any.
getRecord() - Method in class io.spine.server.entity.storage.EntityRecordWithColumns
 
getRegisteredCommandClasses() - Method in class io.spine.server.commandbus.CommandBus
Obtains the view Set of commands that are known to this CommandBus.
getRegisteredMessageClasses() - Method in class io.spine.server.bus.DispatcherRegistry
Obtains message classes from all registered dispatchers.
getRequest() - Method in exception io.spine.server.stand.InvalidRequestException
Obtains an original request, which caused the error.
getRequest() - Method in exception io.spine.server.stand.InvalidSubscriptionException
 
getRequest() - Method in exception io.spine.server.stand.InvalidTopicException
 
getServices() - Method in class io.spine.server.transport.GrpcContainer.Builder
 
getShardedModelClass() - Method in class io.spine.server.aggregate.AggregateRepository
 
getShardedModelClass() - Method in interface io.spine.server.delivery.Shardable
Obtains the class of Entity which is served by this shardable.
getShardedModelClass() - Method in class io.spine.server.procman.ProcessManagerRepository
 
getShardedModelClass() - Method in class io.spine.server.projection.ProjectionRepository
 
getSharding() - Method in class io.spine.server.ServerEnvironment
 
getShardingStrategy() - Method in class io.spine.server.aggregate.AggregateRepository
 
getShardingStrategy() - Method in interface io.spine.server.delivery.Shardable
Defines the strategy of the sharding.
getShardingStrategy() - Method in class io.spine.server.procman.ProcessManagerRepository
 
getShardingStrategy() - Method in class io.spine.server.projection.ProjectionRepository
 
getSnapshotTrigger() - Method in class io.spine.server.aggregate.AggregateRepository
Returns the number of events until a next Snapshot is made.
getStand() - Method in class io.spine.server.BoundedContext
Obtains instance of Stand of this BoundedContext.
getStand() - Method in class io.spine.server.BoundedContextBuilder
 
getStand() - Method in class io.spine.server.projection.ProjectionRepository
Obtains the Stand from the BoundedContext of this repository.
getState() - Method in class io.spine.server.entity.AbstractEntity
Obtains the state of the entity.
getState() - Method in interface io.spine.server.entity.Entity
Obtains the state of the entity.
getStateType() - Method in class io.spine.server.stand.AggregateStateId
 
getStorage() - Method in class io.spine.server.entity.Repository
Returns the storage assigned to this repository.
getStorageFactory() - Method in class io.spine.server.BoundedContext
Obtains StorageFactory associated with this BoundedContext.
getStorageFactory() - Method in class io.spine.server.event.EventBus.Builder
 
getStorageFactory() - Method in class io.spine.server.event.EventStore.Builder
 
getStorageFactorySupplier() - Method in class io.spine.server.BoundedContextBuilder
 
getStoredName() - Method in class io.spine.server.entity.storage.EntityColumn
Obtains the name of the column, which is used to store it in a Storage.
getStreamExecutor() - Method in class io.spine.server.event.EventStore.Builder
 
getTag() - Method in class io.spine.server.delivery.Consumer
 
getTag() - Method in class io.spine.server.delivery.ShardedStream.AbstractBuilder
 
getTag() - Method in class io.spine.server.delivery.ShardedStream
Obtains the tag which describes the delivery destination for this stream of messages
getTag() - Method in interface io.spine.server.delivery.ShardedStreamConsumer
Defines the consumer tag.
getTargetIdClass() - Method in class io.spine.server.delivery.ShardedStream.AbstractBuilder
 
getTenantId() - Method in class io.spine.server.entity.EntityStateEnvelope
 
getTenantId() - Method in class io.spine.server.event.RejectionEnvelope
 
getTenantIndex() - Method in class io.spine.server.BoundedContextBuilder
 
getTransportFactory() - Method in class io.spine.server.integration.IntegrationBus.Builder
 
getType() - Method in class io.spine.server.entity.storage.EntityColumn
Obtains the type of the column.
getTypeRegistry() - Method in class io.spine.server.storage.memory.InMemoryStorageFactory
Retrieves the type registry which declares how to store values of certain types in the storages generated by this factory.
getTypeRegistry() - Method in interface io.spine.server.storage.StorageFactory
Retrieves the type registry which declares how to store values of certain types in the storages generated by this factory.
getValidator() - Method in class io.spine.server.aggregate.ImportBus
 
getValidator() - Method in class io.spine.server.bus.Bus
Obtains the instance of EnvelopeValidator for this bus.
getValidator() - Method in class io.spine.server.commandbus.CommandBus
 
getValidator() - Method in class io.spine.server.event.EventBus
 
getValidator() - Method in class io.spine.server.integration.IntegrationBus
 
getValue() - Method in class io.spine.server.tuple.Either
Obtains the stored value.
getVersion() - Method in class io.spine.server.command.AbstractCommandHandler
Always returns empty version.
getVersion() - Method in class io.spine.server.entity.AbstractVersionableEntity
 
getVersion() - Method in interface io.spine.server.entity.VersionableEntity
Obtains the version of the entity.
getVersion() - Method in interface io.spine.server.EventProducer
The version of the object to be put into events.
GrpcContainer - Class in io.spine.server.transport
Wrapping container for gRPC server.
GrpcContainer(GrpcContainer.Builder) - Constructor for class io.spine.server.transport.GrpcContainer
 
GrpcContainer.Builder - Class in io.spine.server.transport
 

H

handle(ExternalMessage) - Method in class io.spine.server.integration.AbstractChannelObserver
Handles the message received via this channel.
hasColumns() - Method in class io.spine.server.entity.storage.EntityRecordWithColumns
Determines whether or not there are any columns associated with this record.
hashCode() - Method in class io.spine.server.command.AbstractCommandDispatcher
 
hashCode() - Method in class io.spine.server.delivery.DeliveryTag
 
hashCode() - Method in class io.spine.server.delivery.ShardedStream
 
hashCode() - Method in class io.spine.server.delivery.ShardingKey
 
hashCode() - Method in class io.spine.server.delivery.UniformAcrossTargets
 
hashCode() - Method in class io.spine.server.entity.AbstractEntity
 
hashCode() - Method in class io.spine.server.entity.AbstractVersionableEntity
 
hashCode() - Method in class io.spine.server.entity.EntityStateEnvelope
 
hashCode() - Method in class io.spine.server.entity.EntityStorageConverter
 
hashCode() - Method in class io.spine.server.entity.RecentHistory
 
hashCode() - Method in class io.spine.server.entity.storage.CompositeQueryParameter
 
hashCode() - Method in class io.spine.server.entity.storage.EntityColumn
 
hashCode() - Method in class io.spine.server.entity.storage.EntityQuery
 
hashCode() - Method in class io.spine.server.entity.storage.EntityRecordWithColumns
 
hashCode() - Method in class io.spine.server.entity.storage.QueryParameters
 
hashCode() - Method in class io.spine.server.integration.AbstractChannelObserver
 
hashCode() - Method in class io.spine.server.stand.AggregateStateId
 
hashCode() - Method in class io.spine.server.storage.memory.StorageSpec
 
hashCode() - Method in class io.spine.server.tuple.Either
 
hashCode() - Method in class io.spine.server.tuple.Tuple
 
hasLifecycle() - Method in class io.spine.server.entity.storage.CompositeQueryParameter
 
historyBackward() - Method in class io.spine.server.aggregate.Aggregate
Creates an iterator of the aggregate event history with reverse traversal.
historyBackward(AggregateReadRequest<I>) - Method in class io.spine.server.aggregate.AggregateStorage
Creates iterator of aggregate event history with the reverse traversal.

I

idAsString() - Method in class io.spine.server.entity.AbstractEntity
Obtains ID of the entity in the string form.
idAsString() - Method in interface io.spine.server.entity.Entity
Obtains string representation of the entity identifier.
identity() - Method in interface io.spine.server.bus.MulticastDispatcher
Returns immutable set with one element with the identity of the multicast dispatcher that dispatches messages to itself.
ids() - Method in class io.spine.server.transport.ChannelHub
Returns a set of channel identifiers, that are already served by this hub.
ignoreEntityUpdates(EventRoute<I, EventMessage>) - Static method in interface io.spine.server.route.EventRoute
Creates an event route that ignores EntityStateChanged events and delegates all the other event routing to the given instance.
ImportBus - Class in io.spine.server.aggregate
Dispatches events to repositories of aggregates that import these events.
ImportBus.Builder - Class in io.spine.server.aggregate
The builder for ImportBus.
ImportOrigin - Class in io.spine.server.aggregate
A rudimentary implementation of MessageEnvelope with the sole purpose of setting import context in events created for import into system aggregates.
inapplicableTenantId(Command) - Static method in exception io.spine.server.commandbus.InvalidCommandException
 
index() - Method in class io.spine.server.storage.memory.InMemoryProjectionStorage
 
index() - Method in class io.spine.server.storage.memory.InMemoryRecordStorage
 
index() - Method in interface io.spine.server.storage.Storage
Returns an iterator over identifiers of records in the storage.
indexForTarget(Object) - Method in interface io.spine.server.delivery.ShardingStrategy
By the target identifier, obtains the index of the shard to which the target belongs.
indexForTarget(Object) - Method in class io.spine.server.delivery.UniformAcrossTargets
 
init(Supplier<StorageFactory>, Supplier<StorageFactory>) - Method in class io.spine.server.storage.StorageFactorySwitch
Initializes the current singleton instance with the suppliers.
initStorage(StorageFactory) - Method in class io.spine.server.entity.Repository
Initializes the storage using the passed factory.
initStorage(StorageFactory) - Method in class io.spine.server.tenant.TenantRepository
 
injectState(E, S, EntityRecord) - Method in class io.spine.server.entity.EntityStorageConverter
Derived classes must implement providing state injection into the passed entity.
InMemoryProjectionStorage<I> - Class in io.spine.server.storage.memory
The in-memory implementation of ProjectionStorage.
InMemoryPublisher - Class in io.spine.server.transport.memory
An in-memory implementation of the Publisher.
InMemoryRecordStorage<I> - Class in io.spine.server.storage.memory
Memory-based implementation of RecordStorage.
InMemoryStorageFactory - Class in io.spine.server.storage.memory
A factory for in-memory storages.
InMemorySubscriber - Class in io.spine.server.transport.memory
An in-memory implementation of the Subscriber.
InMemorySubscriber(ChannelId) - Constructor for class io.spine.server.transport.memory.InMemorySubscriber
 
InMemoryTransportFactory - Class in io.spine.server.transport.memory
In-memory implementation of the TransportFactory.
InMemoryTransportFactory() - Constructor for class io.spine.server.transport.memory.InMemoryTransportFactory
Prevent direct instantiation from outside of the inheritance tree.
InProcessSharding - Class in io.spine.server.delivery
An implementation of the sharding service, that manages all the data in-memory and runs only within the current JVM process.
InProcessSharding(TransportFactory) - Constructor for class io.spine.server.delivery.InProcessSharding
Creates a new instance of in-process sharding service, which uses the given transport factory to manage the channels for the sharded message streams.
IntegrationBus - Class in io.spine.server.integration
Dispatches external messages from and to the bounded context, in which this bus operates.
IntegrationBus.Builder - Class in io.spine.server.integration
A Builder for IntegrationBus instances.
InvalidCommandException - Exception in io.spine.server.commandbus
The exception for reporting invalid commands.
InvalidEntityStateException - Exception in io.spine.server.entity
Signals that an entity state does not pass validation.
InvalidEventException - Exception in io.spine.server.event
The exception for reporting invalid events.
InvalidRequestException - Exception in io.spine.server.stand
A base class for exceptions fired in case an invalid request has been submitted to Stand.
InvalidSubscriptionException - Exception in io.spine.server.stand
An exception thrown in case an invalid or unsupported Subscription has been submitted to Stand.
InvalidSubscriptionException(String, Subscription, Error) - Constructor for exception io.spine.server.stand.InvalidSubscriptionException
Creates a new instance.
InvalidTopicException - Exception in io.spine.server.stand
An exception thrown in case an invalid or unsupported Topic has been submitted to Stand.
InvalidTopicException(String, Topic, Error) - Constructor for exception io.spine.server.stand.InvalidTopicException
Creates a new instance.
io.spine.server - package io.spine.server
This package provides classes and interfaces for backend part of the system.
io.spine.server.aggregate - package io.spine.server.aggregate
 
io.spine.server.annotation - package io.spine.server.annotation
This package provides server-side annotations.
io.spine.server.bus - package io.spine.server.bus
This package contains classes and interfaces for abstract Bus.
io.spine.server.command - package io.spine.server.command
This package provides classes and interfaces related to command processing at the server side.
io.spine.server.commandbus - package io.spine.server.commandbus
This package provides classes and interfaces related to CommandBus and its configuration.
io.spine.server.delivery - package io.spine.server.delivery
This package is devoted to message delivery and sharding.
io.spine.server.entity - package io.spine.server.entity
This package contains classes and interfaces defining entity-oriented API and base functionality.
io.spine.server.entity.storage - package io.spine.server.entity.storage
This package contains classes and interfaces for working with entity storage representation.
io.spine.server.event - package io.spine.server.event
This package provides classes for server-side event processing.
io.spine.server.event.storage - package io.spine.server.event.storage
This package contains generated classes and interfaces for storing events.
io.spine.server.integration - package io.spine.server.integration
This package contains classes and interfaces for communications between bounded contexts.
io.spine.server.procman - package io.spine.server.procman
This package provides classes related to Process Managers.
io.spine.server.projection - package io.spine.server.projection
This package provides classes for working with event stream projections.
io.spine.server.route - package io.spine.server.route
This package contains classes and interfaces for obtaining entity identifiers.
io.spine.server.stand - package io.spine.server.stand
This package provides classes for working with Stand.
io.spine.server.storage - package io.spine.server.storage
This package provides interfaces and base classes for storages.
io.spine.server.storage.memory - package io.spine.server.storage.memory
This package provides implementation of in-memory storages.
io.spine.server.tenant - package io.spine.server.tenant
This package contains classes and interfaces for supporting multi-tenancy.
io.spine.server.transport - package io.spine.server.transport
This package contains classes and interfaces that connect Spine with the infrastructure of the outer world.
io.spine.server.transport.memory - package io.spine.server.transport.memory
This package provides implementation of in-memory TransportFactory routines.
io.spine.server.tuple - package io.spine.server.tuple
This package provides tuples for return values from command handling or commanding methods.
isActive() - Method in class io.spine.server.entity.storage.EntityRecordWithColumns
 
isActive() - Method in interface io.spine.server.entity.WithLifecycle
Verifies if any of the lifecycle attributes is set.
isAppEngine() - Method in class io.spine.server.ServerEnvironment
Returns true if the code is running on the Google AppEngine, false otherwise.
isArchived() - Method in class io.spine.server.entity.AbstractVersionableEntity
Tests whether the entity is marked as archived.
isArchived() - Method in interface io.spine.server.entity.EntityWithLifecycle
Shows if current instance is marked as archived or not.
isArchived() - Method in class io.spine.server.entity.storage.EntityRecordWithColumns
 
isArchived() - Method in interface io.spine.server.entity.WithLifecycle
Shows if current instance is marked as archived or not.
isClosed() - Method in class io.spine.server.storage.AbstractStorage
Tests whether the storage is closed.
isDeleted() - Method in class io.spine.server.entity.AbstractVersionableEntity
Tests whether the entity is marked as deleted.
isDeleted() - Method in interface io.spine.server.entity.EntityWithLifecycle
Shows if current instance is marked as deleted or not.
isDeleted() - Method in class io.spine.server.entity.storage.EntityRecordWithColumns
 
isDeleted() - Method in interface io.spine.server.entity.WithLifecycle
Shows if current instance is marked as deleted or not.
isEmpty() - Method in class io.spine.server.entity.RecentHistory
Returns true if there are no events in the recent history, false otherwise.
isLifecycleAttributesSet() - Method in class io.spine.server.entity.storage.QueryParameters
Verifies whether this parameters include filters by the Entity lifecycle flags or not.
isLifecycleSupported() - Method in class io.spine.server.storage.RecordStorage
Indicates if the entity managed by this storage supports the lifecycle flags.
isLive(BindableService) - Method in class io.spine.server.transport.GrpcContainer
Check if the given gRPC service has actually been deployed and is available for interaction within this container.
isMultitenant() - Method in class io.spine.server.BoundedContext
Returns true if the Bounded Context is designed to serve more than one tenant of the application, false otherwise.
isMultitenant() - Method in class io.spine.server.BoundedContextBuilder
 
isMultitenant() - Method in class io.spine.server.storage.AbstractStorage
Verifies whether the storage is multitenant.
isMultitenant() - Method in class io.spine.server.storage.memory.InMemoryStorageFactory
 
isMultitenant() - Method in interface io.spine.server.storage.Storage
Verifies whether the storage is multitenant.
isMultitenant() - Method in interface io.spine.server.storage.StorageFactory
Verifies if the storage factory is configured to serve a multi-tenant application.
isNullable() - Method in class io.spine.server.entity.storage.EntityColumn
Determines whether the column value may be null.
isOpen() - Method in class io.spine.server.entity.Repository
Verifies if the repository open.
isOpen() - Method in class io.spine.server.storage.AbstractStorage
Tests whether the storage is open.
isOpen() - Method in interface io.spine.server.storage.Storage
Verifies whether the storage is open.
isRegistered() - Method in class io.spine.server.entity.Repository
Verifies whether the registry is registered with a BoundedContext.
isScheduledForDeployment(BindableService) - Method in class io.spine.server.transport.GrpcContainer
Check if the given gRPC service is scheduled for the deployment in this container.
isShutdown() - Method in class io.spine.server.transport.GrpcContainer
Returns true if the server is shut down or was not started at all, false otherwise.
isStale() - Method in class io.spine.server.transport.memory.InMemoryPublisher
Always returns false, as publishers don't get stale.
isStale() - Method in interface io.spine.server.transport.MessageChannel
Allows to understand whether this channel is stale and can be closed.
isStale() - Method in class io.spine.server.transport.Subscriber
 
isStorageAssigned() - Method in class io.spine.server.entity.Repository
Returns true if the storage is assigned, false otherwise.
iterator() - Method in class io.spine.server.entity.RecentHistory
Creates a new iterator over the recent history items.
iterator(Predicate<E>) - Method in class io.spine.server.entity.RecordBasedRepository
 
iterator(Predicate<E>) - Method in class io.spine.server.entity.Repository
Returns an iterator over the entities exposed by the view that match the passed filter.
iterator(Predicate<E>) - Method in interface io.spine.server.entity.RepositoryView
Returns an iterator over the entities exposed by the view that match the passed filter.
iterator() - Method in class io.spine.server.entity.storage.QueryParameters
Returns an iterator over the column filters.
iterator() - Method in class io.spine.server.tuple.Either
 
iterator() - Method in class io.spine.server.tuple.Tuple
 

K

keep(TenantId) - Method in interface io.spine.server.tenant.TenantIndex
Stores the passed tenant ID in the index.
keep(TenantId) - Method in class io.spine.server.tenant.TenantRepository
Stores the passed tenant ID in the index.

L

LifecycleFlagField - Enum in io.spine.server.storage
A container for the storage fields used to store the LifecycleFlags.
lifecycleFlagsChanged() - Method in class io.spine.server.entity.AbstractVersionableEntity
 
lifecycleFlagsChanged() - Method in interface io.spine.server.entity.EntityWithLifecycle
Tells whether lifecycle flags of the entity changed since its initialization.
lifecycleOf(I) - Method in class io.spine.server.aggregate.AggregateRepository
Obtains an instance of EntityLifecycle for the entity with the given ID.
lifecycleOf(I) - Method in class io.spine.server.procman.ProcessManagerRepository
Obtains an instance of EntityLifecycle for the entity with the given ID.
limit(int) - Method in class io.spine.server.entity.storage.QueryParameters.Builder
 
limit() - Method in class io.spine.server.entity.storage.QueryParameters.Builder
 
limit() - Method in class io.spine.server.entity.storage.QueryParameters
 
limited() - Method in class io.spine.server.entity.storage.QueryParameters
 
loadAll(Iterable<I>) - Method in class io.spine.server.entity.RecordBasedRepository
Loads all the entities in this repository with IDs, contained within the passed ids values.
loadAll(Iterable<I>, FieldMask) - Method in class io.spine.server.entity.RecordBasedRepository
Loads all the entities in this repository by their IDs and applies the FieldMask to each of them.
loadAll() - Method in class io.spine.server.entity.RecordBasedRepository
Loads all the entities in this repository.
log() - Static method in class io.spine.server.event.EventStore
Returns default logger for this class.
logError(String, MessageEnvelope, RuntimeException) - Method in class io.spine.server.entity.Repository
Logs error caused by a message processing into the repository log.

M

MessageChannel - Interface in io.spine.server.transport
A channel dedicated to exchanging the messages.
MessageDispatcher<C extends io.spine.type.MessageClass,E extends io.spine.core.MessageEnvelope,R> - Interface in io.spine.server.bus
A dispatcher of a message.
messageFormat(String, Command) - Static method in exception io.spine.server.commandbus.CommandException
Builds a formatted string for the passed format and a command.
missingTenantId(Command) - Static method in exception io.spine.server.commandbus.InvalidCommandException
Creates an exception for a command with missing tenant_id attribute in the CommandContext, which is required in a multitenant application.
Multicast<I,M extends com.google.protobuf.Message,C extends com.google.protobuf.Message> - Interface in io.spine.server.route
A route for a message to be delivered to several entities.
MulticastBus<M extends com.google.protobuf.Message,E extends io.spine.core.MessageEnvelope<?,M,?>,C extends io.spine.type.MessageClass<? extends com.google.protobuf.Message>,D extends MessageDispatcher<C,E,?>> - Class in io.spine.server.bus
A Bus, which delivers a single message to multiple dispatchers.
MulticastBus(BusBuilder<E, M, ?>) - Constructor for class io.spine.server.bus.MulticastBus
 
MulticastDispatcher<C extends io.spine.type.MessageClass,E extends io.spine.core.MessageEnvelope,I> - Interface in io.spine.server.bus
Dispatches a message to several entities of the same type.

N

newBuilder() - Static method in class io.spine.server.aggregate.ImportBus
Creates a builder for creating a new ImportBus.
newBuilder() - Static method in class io.spine.server.BoundedContext
Creates a new builder for BoundedContext.
newBuilder() - Static method in class io.spine.server.commandbus.CommandBus
Creates a new CommandBus.Builder for the CommandBus.
newBuilder() - Static method in class io.spine.server.CommandService
Creates a new builder for CommandService.
newBuilder() - Static method in class io.spine.server.delivery.CommandShardedStream
 
newBuilder() - Static method in class io.spine.server.delivery.EventShardedStream
 
newBuilder() - Static method in class io.spine.server.entity.CompositeEventFilter
Creates a new instance of Builder for CompositeEventFilter instances.
newBuilder() - Static method in class io.spine.server.entity.EventFieldFilter
Creates a new instance of Builder for EventFieldFilter instances.
newBuilder() - Static method in class io.spine.server.entity.storage.ColumnTypeRegistry
 
newBuilder(ColumnTypeRegistry<C>) - Static method in class io.spine.server.entity.storage.ColumnTypeRegistry
 
newBuilder() - Static method in class io.spine.server.entity.storage.QueryParameters
 
newBuilder(QueryParameters) - Static method in class io.spine.server.entity.storage.QueryParameters
 
newBuilder() - Static method in class io.spine.server.event.Enricher
 
newBuilder() - Static method in class io.spine.server.event.EventBus
Creates a builder for new EventBus.
newBuilder() - Static method in class io.spine.server.event.EventStore
Creates a builder for locally running EventStore.
newBuilder() - Static method in class io.spine.server.integration.IntegrationBus
Creates a new builder for this bus.
newBuilder() - Static method in class io.spine.server.QueryService
 
newBuilder() - Static method in class io.spine.server.Server
Creates a new builder for the server.
newBuilder() - Static method in class io.spine.server.stand.Stand
 
newBuilder() - Static method in class io.spine.server.SubscriptionService
 
newBuilder() - Static method in class io.spine.server.transport.GrpcContainer
 
newChannel(ChannelId) - Method in class io.spine.server.transport.ChannelHub
Creates a new channel under the specified ID
newChannel(ChannelId) - Method in class io.spine.server.transport.PublisherHub
 
newChannel(ChannelId) - Method in class io.spine.server.transport.SubscriberHub
 
newConverter() - Method in class io.spine.server.delivery.CommandShardedStream
 
newConverter() - Method in class io.spine.server.delivery.EventShardedStream
 
newConverter() - Method in class io.spine.server.delivery.ShardedStream
 
newInstance(ActorContext) - Static method in class io.spine.server.aggregate.ImportOrigin
Creates a new instance with the passed actor context.
newInstance() - Static method in class io.spine.server.route.CommandRouting
Creates a new command routing.
newInstance() - Static method in class io.spine.server.route.DefaultCommandRoute
Creates a new instance.
newInstance() - Static method in class io.spine.server.route.StateUpdateRouting
Creates a new StateUpdateRouting.
newInstance(BoundedContextName, boolean) - Static method in class io.spine.server.storage.memory.InMemoryStorageFactory
 
newInstance(BoundedContextName, boolean) - Static method in class io.spine.server.storage.StorageFactorySwitch
Obtains the instance of the switch that corresponds to multi-tenancy mode.
newInstance() - Static method in class io.spine.server.transport.memory.InMemoryTransportFactory
Creates a new instance of InMemoryTransportFactory.
newInstance() - Static method in class io.spine.server.transport.memory.SingleThreadInMemTransportFactory
 
newShardedStreamBuilder() - Method in class io.spine.server.delivery.Consumer
Creates a new instance of a builder for the sharded stream.
newSubscriber(ChannelId) - Method in class io.spine.server.transport.memory.InMemoryTransportFactory
Creates a new instance of subscriber.
newSubscriber(ChannelId) - Method in class io.spine.server.transport.memory.SingleThreadInMemTransportFactory
 
nothing() - Method in interface io.spine.server.EventProducer
Obtains the Nothing event message.

O

of(Command) - Static method in exception io.spine.server.commandbus.DuplicateCommandException
Creates an exception for a duplicate command.
of(Entity<I, S>, TenantId) - Static method in class io.spine.server.entity.EntityStateEnvelope
 
of(I, S, Version, TenantId) - Static method in class io.spine.server.entity.EntityStateEnvelope
 
of(EntityRecord) - Static method in class io.spine.server.entity.storage.EntityRecordWithColumns
Creates an instance with no columns.
of(ExternalMessage, Message) - Static method in class io.spine.server.integration.ExternalMessageEnvelope
Creates a new instance of ExternalMessageEnvelope from the ExternalMessage instance and the message transferred inside the ExternalMessage, such as a io.spine.sample.TaskCreated event message.
of(I, TypeUrl) - Static method in class io.spine.server.stand.AggregateStateId
 
of(BoundedContextName, TypeUrl, Class<I>) - Static method in class io.spine.server.storage.memory.StorageSpec
 
of(A, B) - Static method in class io.spine.server.tuple.Pair
Creates a new pair of values.
of(A, B, C, D) - Static method in class io.spine.server.tuple.Quartet
Creates a quartet with all values present.
of(A, B, C, D, E) - Static method in class io.spine.server.tuple.Quintet
Creates a quintet with all values present.
of(A, B, C) - Static method in class io.spine.server.tuple.Triplet
Creates new triplet with the passed values.
on(MessageEnvelope, Any) - Static method in class io.spine.server.event.EventFactory
Creates a new event factory for producing events in response to the passed message.
onAfterCommit(EntityRecordChange) - Method in class io.spine.server.entity.TransactionListener.SilentWitness
 
onAfterPhase(Phase<I, ?>) - Method in class io.spine.server.entity.TransactionListener.SilentWitness
 
onBeforeCommit(E, S, Version, LifecycleFlags) - Method in class io.spine.server.entity.TransactionListener.SilentWitness
 
onCompleted() - Method in class io.spine.server.integration.AbstractChannelObserver
 
onConstraintViolations(Command, Iterable<ConstraintViolation>) - Static method in exception io.spine.server.commandbus.InvalidCommandException
Creates an exception instance for a command message, which has fields that violate validation constraint(s).
onConstraintViolations(Message, Iterable<ConstraintViolation>) - Static method in exception io.spine.server.entity.InvalidEntityStateException
Creates an exception instance for an entity state, which has fields that violate validation constraint(s).
onConstraintViolations(EventMessage, Iterable<ConstraintViolation>) - Static method in exception io.spine.server.event.InvalidEventException
Creates an exception instance for a event message, which has fields that violate validation constraint(s).
onError(CommandEnvelope, RuntimeException) - Method in class io.spine.server.aggregate.AggregateRepository
Handles the given error.
onError(EventEnvelope, RuntimeException) - Method in class io.spine.server.aggregate.AggregateRepository
 
onError(E, RuntimeException) - Method in interface io.spine.server.bus.MessageDispatcher
Handles an error occurred during dispatching a message.
onError(CommandEnvelope, RuntimeException) - Method in class io.spine.server.command.AbstractCommandDispatcher
Handles an error occurred during dispatching a message.
onError(EventEnvelope, RuntimeException) - Method in class io.spine.server.command.AbstractCommander
 
onError(Message, CommandContext, Throwable) - Method in interface io.spine.server.commandbus.CommandSequence.ErrorHandler
 
onError(EventEnvelope, RuntimeException) - Method in class io.spine.server.entity.EventDispatchingRepository
Logs error into the repository log.
onError(EventEnvelope, RuntimeException) - Method in class io.spine.server.event.AbstractEventSubscriber
Logs the error into the subscriber log.
onError(Throwable) - Method in class io.spine.server.integration.AbstractChannelObserver
 
onError(CommandEnvelope, RuntimeException) - Method in class io.spine.server.procman.ProcessManagerRepository
 
onMessage(ExternalMessage) - Method in class io.spine.server.transport.Subscriber
Passes the given message to observers.
onNext(I, M) - Method in class io.spine.server.delivery.Consumer
 
onNext(I, E) - Method in interface io.spine.server.delivery.ShardedStreamConsumer
Defines the processing of the message, sent to a particular destination (with the target ID specified).
onNext(ExternalMessage) - Method in class io.spine.server.integration.AbstractChannelObserver
 
onRegistered() - Method in class io.spine.server.aggregate.AggregateRepository
The callback called by a BoundedContext during the registration of the repository.
onRegistered() - Method in class io.spine.server.entity.EventDispatchingRepository
The callback called by a BoundedContext during the registration of the repository.
onRegistered() - Method in class io.spine.server.entity.RecordBasedRepository
The callback called by a BoundedContext during the registration of the repository.
onRegistered() - Method in class io.spine.server.entity.Repository
The callback called by a BoundedContext during the registration of the repository.
onRegistered() - Method in class io.spine.server.procman.ProcessManagerRepository
The callback called by a BoundedContext during the registration of the repository.
onRegistered() - Method in class io.spine.server.projection.ProjectionRepository
The callback called by a BoundedContext during the registration of the repository.
onStateChanged(EntityStateUpdate) - Method in interface io.spine.server.stand.Stand.EntityUpdateCallback
Called when a certain entity state is updated.
onTransactionFailed(Throwable, E, S, Version, LifecycleFlags) - Method in class io.spine.server.entity.TransactionListener.SilentWitness
 
orderBy(OrderBy) - Method in class io.spine.server.entity.storage.QueryParameters.Builder
 
orderBy() - Method in class io.spine.server.entity.storage.QueryParameters.Builder
 
orderBy() - Method in class io.spine.server.entity.storage.QueryParameters
 
ordered() - Method in class io.spine.server.entity.storage.QueryParameters
 

P

Pair<A extends com.google.protobuf.Message,B> - Class in io.spine.server.tuple
A tuple with two elements.
passToEndpoint(I, E) - Method in class io.spine.server.aggregate.AggregateDelivery.AggregateMessageConsumer
 
passToEndpoint(I, M) - Method in class io.spine.server.delivery.Consumer
Calls the dispatching method of endpoint directly.
passToEndpoint(I, M) - Method in class io.spine.server.procman.PmDelivery.PmMessageConsumer
 
pickKeysForNode(Shardable, Set<ShardingKey>) - Method in class io.spine.server.delivery.InProcessSharding
Defines the sharding keys for the given shardable to be served within this Sharding instance.
pickKeysForNode(Shardable, Set<ShardingKey>) - Method in interface io.spine.server.delivery.Sharding
Defines the sharding keys for the given shardable to be served within this Sharding instance.
play(Iterable<Event>) - Method in class io.spine.server.aggregate.Aggregate
 
play(I, AggregateStateRecord) - Method in class io.spine.server.aggregate.AggregateRepository
Plays the given Aggregate history for an instance of Aggregate with the given ID.
play(Iterable<Event>) - Method in class io.spine.server.projection.Projection
 
PmCommandDelivery<I,P extends ProcessManager<I,?,?>> - Class in io.spine.server.procman
A strategy on delivering the ecommandsvents to the instances of a certain process manager type.
PmCommandDelivery(ProcessManagerRepository<I, P, ?>) - Constructor for class io.spine.server.procman.PmCommandDelivery
 
PmDelivery<I,P extends ProcessManager<I,?,?>,M extends io.spine.core.ActorMessageEnvelope<?,?,?>,S extends ShardedStream<I,?,M>,B extends ShardedStream.AbstractBuilder<I,M,B,S>> - Class in io.spine.server.procman
A strategy on delivering the messages to the instances of a certain process manager type.
PmDelivery(PmDelivery.PmMessageConsumer<I, P, M, S, B>) - Constructor for class io.spine.server.procman.PmDelivery
 
PmDelivery.PmMessageConsumer<I,P extends ProcessManager<I,?,?>,M extends io.spine.core.ActorMessageEnvelope<?,?,?>,S extends ShardedStream<I,?,M>,B extends ShardedStream.AbstractBuilder<I,M,B,S>> - Class in io.spine.server.procman
 
PmEventDelivery<I,P extends ProcessManager<I,?,?>> - Class in io.spine.server.procman
A strategy on delivering the events to the instances of a certain process manager type.
PmEventDelivery(ProcessManagerRepository<I, P, ?>) - Constructor for class io.spine.server.procman.PmEventDelivery
 
PmMessageConsumer(DeliveryTag, Repository<I, P>) - Constructor for class io.spine.server.procman.PmDelivery.PmMessageConsumer
 
post(T, StreamObserver<Ack>) - Method in class io.spine.server.bus.Bus
Posts the message to the bus.
post(Iterable<T>, StreamObserver<Ack>) - Method in class io.spine.server.bus.Bus
Posts the given messages to the bus.
post(Command) - Method in class io.spine.server.commandbus.CommandScheduler
Delivers a scheduled command to a target.
post(Command, StreamObserver<Ack>) - Method in class io.spine.server.CommandService
 
post(I, E) - Method in class io.spine.server.delivery.ShardedStream
Posts the message to this stream.
post(Event) - Method in class io.spine.server.event.EventBus
Posts the event for handling.
post(Iterable<Event>) - Method in class io.spine.server.event.EventBus
Posts the events for handling.
post(TenantId, VersionableEntity<?, ?>) - Method in class io.spine.server.stand.Stand
Posts the state of an VersionableEntity to this Stand.
postEvents(Iterable<Event>) - Method in class io.spine.server.command.AbstractCommandDispatcher
Posts passed events to EventBus.
prepareObserver(Iterable<T>, StreamObserver<Ack>) - Method in class io.spine.server.bus.Bus
Prepares the given StreamObserver in order to post messages into this bus.
prepareObserver(Iterable<Command>, StreamObserver<Ack>) - Method in class io.spine.server.commandbus.CommandBus
Prepares the given StreamObserver in order to post messages into this bus.
ProcessManager<I,S extends com.google.protobuf.Message,B extends io.spine.validate.ValidatingBuilder<S,? extends com.google.protobuf.Message.Builder>> - Class in io.spine.server.procman
A central processing unit used to maintain the state of the business process and determine the next processing step based on intermediate results.
ProcessManager(I) - Constructor for class io.spine.server.procman.ProcessManager
Creates a new instance.
ProcessManagerRepository<I,P extends ProcessManager<I,S,?>,S extends com.google.protobuf.Message> - Class in io.spine.server.procman
The abstract base for Process Managers repositories.
ProcessManagerRepository() - Constructor for class io.spine.server.procman.ProcessManagerRepository
Creates a new instance with the event routing by the first message field.
Projection<I,M extends com.google.protobuf.Message,B extends io.spine.validate.ValidatingBuilder<M,? extends com.google.protobuf.Message.Builder>> - Class in io.spine.server.projection
Projection holds a structural representation of data extracted from a stream of events.
Projection(I) - Constructor for class io.spine.server.projection.Projection
Creates a new instance.
ProjectionEventDelivery<I,P extends Projection<I,?,?>> - Class in io.spine.server.projection
A strategy on delivering the events to the instances of a certain projection type.
ProjectionEventDelivery(ProjectionRepository<I, P, ?>) - Constructor for class io.spine.server.projection.ProjectionEventDelivery
 
ProjectionRepository<I,P extends Projection<I,S,?>,S extends com.google.protobuf.Message> - Class in io.spine.server.projection
Abstract base for repositories managing Projections.
ProjectionRepository() - Constructor for class io.spine.server.projection.ProjectionRepository
Creates a new ProjectionRepository.
projectionStorage() - Method in class io.spine.server.projection.ProjectionRepository
Ensures that the repository has the storage.
ProjectionStorage<I> - Class in io.spine.server.projection
The storage used by projection repositories for keeping Projections and the timestamp of the last event processed by the projection repository.
ProjectionStorage(boolean) - Constructor for class io.spine.server.projection.ProjectionStorage
 
publish(Any, ExternalMessage) - Method in class io.spine.server.transport.memory.InMemoryPublisher
 
publish(Any, ExternalMessage) - Method in interface io.spine.server.transport.Publisher
Publishes a given ExternalMessage to the channel under a given ID.
Publisher - Interface in io.spine.server.transport
Publisher of messages for the channel with the specified ID.
PublisherHub - Class in io.spine.server.transport
The hub of Publishers.
PublisherHub(TransportFactory) - Constructor for class io.spine.server.transport.PublisherHub
 
put(Class<J>, ColumnType<J, ?, ?, ?>) - Method in class io.spine.server.entity.storage.ColumnTypeRegistry.Builder
Create a mapping between the Java class and the database column type.
putMask(Class<? extends EventMessage>, FieldMask) - Method in class io.spine.server.entity.EventFieldFilter.Builder
Specifies the FieldMask for the given event type.

Q

Quartet<A extends com.google.protobuf.Message,B,C,D> - Class in io.spine.server.tuple
A tuple with four elements.
QueryParameters - Class in io.spine.server.entity.storage
The parameters of an EntityQuery.
QueryParameters.Builder - Class in io.spine.server.entity.storage
The builder for the QueryParameters.
QueryService - Class in io.spine.server
The QueryService provides a synchronous way to fetch read-side state from the server.
QueryService.Builder - Class in io.spine.server
 
Quintet<A extends com.google.protobuf.Message,B,C,D,E> - Class in io.spine.server.tuple
A tuple of five elements.

R

React - Annotation Type in io.spine.server.event
Marks a method of an entity as one that may modify the state of the entity in response to an external event.
read(AggregateReadRequest<I>) - Method in class io.spine.server.aggregate.AggregateStorage
Forms and returns an AggregateStateRecord based on the aggregate history.
read(EventStreamQuery, StreamObserver<Event>) - Method in class io.spine.server.event.EventStore
Creates the stream with events matching the passed query.
read(Query, StreamObserver<QueryResponse>) - Method in class io.spine.server.QueryService
 
read(RecordReadRequest<I>) - Method in class io.spine.server.storage.RecordStorage
Reads a record, which matches the specified request.
read(RecordReadRequest<I>, FieldMask) - Method in class io.spine.server.storage.RecordStorage
Reads a record, which matches the specified request and applies a FieldMask to it.
read(R) - Method in interface io.spine.server.storage.Storage
Reads a record from the storage by the specified request.
readAll() - Method in class io.spine.server.storage.RecordStorage
 
readAll(FieldMask) - Method in class io.spine.server.storage.RecordStorage
Reads all active items from the storage and apply FieldMask to each of the results.
readAll(EntityQuery<I>, FieldMask) - Method in class io.spine.server.storage.RecordStorage
Reads all the records matching the given EntityQuery and applies the given FieldMask to the resulting record states.
readAll(EntityQuery<I>) - Method in class io.spine.server.storage.RecordStorage
Reads all the records matching the given EntityQuery and applies the given FieldMask to the resulting record states.
readAllRecords(EntityQuery<I>, FieldMask) - Method in class io.spine.server.projection.ProjectionStorage
 
readAllRecords() - Method in class io.spine.server.storage.memory.InMemoryProjectionStorage
 
readAllRecords(FieldMask) - Method in class io.spine.server.storage.memory.InMemoryProjectionStorage
 
readAllRecords() - Method in class io.spine.server.storage.memory.InMemoryRecordStorage
 
readAllRecords(FieldMask) - Method in class io.spine.server.storage.memory.InMemoryRecordStorage
 
readAllRecords(EntityQuery<I>, FieldMask) - Method in class io.spine.server.storage.memory.InMemoryRecordStorage
 
readAllRecords() - Method in class io.spine.server.storage.RecordStorage
Obtains an iterator for reading all records.
readAllRecords(FieldMask) - Method in class io.spine.server.storage.RecordStorage
Obtains an iterator for reading all records, and applying the passed field mask to the results.
readAllRecords(EntityQuery<I>, FieldMask) - Method in class io.spine.server.storage.RecordStorage
Obtains an iterator for reading records matching the query, and applying the passed field mask to the results.
readEventCountAfterLastSnapshot(I) - Method in class io.spine.server.aggregate.AggregateStorage
Reads a count of events which were saved to the storage after the last snapshot was created, or a count of all events if there were no snapshots yet.
readLastHandledEventTime() - Method in class io.spine.server.projection.ProjectionStorage
Reads the time of the last handled event from the storage.
readLastHandledEventTime() - Method in class io.spine.server.storage.memory.InMemoryProjectionStorage
 
readLifecycleFlags(I) - Method in class io.spine.server.storage.RecordStorage
 
readLifecycleFlags(I) - Method in interface io.spine.server.storage.StorageWithLifecycleFlags
Reads the lifecycle status for the entity with the passed ID.
readMultiple(Iterable<I>) - Method in class io.spine.server.storage.RecordStorage
 
readMultiple(Iterable<I>, FieldMask) - Method in class io.spine.server.storage.RecordStorage
Reads multiple active items from the storage and apply FieldMask to the results.
readMultipleRecords(Iterable<I>) - Method in class io.spine.server.storage.memory.InMemoryProjectionStorage
 
readMultipleRecords(Iterable<I>, FieldMask) - Method in class io.spine.server.storage.memory.InMemoryProjectionStorage
 
readMultipleRecords(Iterable<I>, FieldMask) - Method in class io.spine.server.storage.memory.InMemoryRecordStorage
 
readMultipleRecords(Iterable<I>) - Method in class io.spine.server.storage.memory.InMemoryRecordStorage
 
readMultipleRecords(Iterable<I>) - Method in class io.spine.server.storage.RecordStorage
Obtains an iterator for reading multiple records by IDs.
readMultipleRecords(Iterable<I>, FieldMask) - Method in class io.spine.server.storage.RecordStorage
Obtains an iterator for reading multiple records by IDs, and applying the passed field mask to the results.
readRecord(I) - Method in class io.spine.server.projection.ProjectionStorage
 
readRecord(I) - Method in class io.spine.server.storage.memory.InMemoryRecordStorage
 
readRecord(I) - Method in class io.spine.server.storage.RecordStorage
Reads a record from the storage by the passed ID.
RecentHistory - Class in io.spine.server.entity
A copy of recent history of an event-sourced entity.
recentHistory() - Method in class io.spine.server.entity.TransactionalEntity
Obtains recent history of events of this entity.
RecordBasedRepository<I,E extends Entity<I,S>,S extends com.google.protobuf.Message> - Class in io.spine.server.entity
The base class for repositories that store entities as records.
RecordBasedRepository() - Constructor for class io.spine.server.entity.RecordBasedRepository
Creates a new instance.
recordStorage() - Method in class io.spine.server.entity.RecordBasedRepository
Ensures that the repository has the storage.
recordStorage() - Method in class io.spine.server.projection.ProjectionRepository
Ensures that the repository has the storage.
recordStorage() - Method in class io.spine.server.projection.ProjectionStorage
Returns an entity storage implementation.
recordStorage() - Method in class io.spine.server.storage.memory.InMemoryProjectionStorage
 
RecordStorage<I> - Class in io.spine.server.storage
A storage keeping messages with identity.
RecordStorage(boolean) - Constructor for class io.spine.server.storage.RecordStorage
Creates an instance of RecordStorage which does not support the EntityColumnCache.
RecordStorage(boolean, Class<? extends Entity>) - Constructor for class io.spine.server.storage.RecordStorage
Creates an instance of RecordStorage which supports the EntityColumnCache.
register(Repository<I, E>) - Method in class io.spine.server.BoundedContext
Registers the passed repository with the BoundedContext.
register(D) - Method in class io.spine.server.bus.Bus
Registers the passed dispatcher.
register(D) - Method in class io.spine.server.bus.DispatcherRegistry
 
register(Shardable) - Method in class io.spine.server.delivery.InProcessSharding
Registers a shardable instance.
register(Shardable) - Method in interface io.spine.server.delivery.Sharding
Registers a shardable instance.
register(ExternalMessageDispatcher<?>) - Method in class io.spine.server.integration.IntegrationBus
Registers a local dispatcher, which is subscribed to external messages.
register(AbstractEventSubscriber) - Method in class io.spine.server.integration.IntegrationBus
Registers the passed event subscriber as an external event dispatcher by taking only external subscriptions into account.
registerCommandDispatcher(CommandDispatcher<?>) - Method in class io.spine.server.BoundedContext
Registers the passed command dispatcher with the CommandBus of this BoundedContext.
registerCommandDispatcher(CommandDispatcherDelegate<?>) - Method in class io.spine.server.BoundedContext
Registers the passed command dispatcher with the CommandBus of this BoundedContext.
registerEventDispatcher(EventDispatcher<?>) - Method in class io.spine.server.BoundedContext
Registers the passed event dispatcher with the EventBus of this BoundedContext, if it dispatches domestic events.
registerEventDispatcher(EventDispatcherDelegate<?>) - Method in class io.spine.server.BoundedContext
Registers the passed event dispatcher with the EventBus of this BoundedContext, if it dispatchers domestic events.
registerTypeSupplier(Repository<I, E>) - Method in class io.spine.server.stand.Stand
Registers a supplier for the objects of a certain TypeUrl to be able to read them in response to a Query.
registerWithSharding() - Method in interface io.spine.server.delivery.Shardable
Registers this instance with Sharding obtained from the ServerEnvironment.
registry() - Method in class io.spine.server.aggregate.ImportBus
 
registry() - Method in class io.spine.server.bus.Bus
Obtains the dispatcher registry.
registry() - Method in class io.spine.server.commandbus.CommandBus
Obtains the dispatcher registry.
registry() - Method in class io.spine.server.event.EventBus
Obtains the dispatcher registry.
RejectionEnvelope - Class in io.spine.server.event
The holder of a rejection Event which provides convenient access to its properties.
Rejections - Class in io.spine.server.command
A set of utilities for working with rejections and ThrowableMessages.
remember(Iterable<Event>) - Method in class io.spine.server.entity.TransactionalEntity
Adds events to the recent history.
remove(Repository<?, ?>) - Method in class io.spine.server.BoundedContextBuilder
Removes the passed repository from the registration list.
remove(BoundedContext) - Method in class io.spine.server.CommandService.Builder
Removes the BoundedContext from the builder.
remove(EnrichmentFunction) - Method in class io.spine.server.event.Enricher.Builder
Removes a translation for the passed type.
remove(BoundedContext) - Method in class io.spine.server.QueryService.Builder
 
remove(BoundedContext) - Method in class io.spine.server.SubscriptionService.Builder
 
removeObserver(StreamObserver<ExternalMessage>) - Method in class io.spine.server.transport.Subscriber
Removes an existing observer and disconnects it from this subscription channel.
removeService(ServerServiceDefinition) - Method in class io.spine.server.transport.GrpcContainer.Builder
 
replaceDefault(CommandRoute<I, CommandMessage>) - Method in class io.spine.server.route.CommandRouting
Sets new default route in the schema.
replaceDefault(EventRoute<I, EventMessage>) - Method in class io.spine.server.route.EventRouting
Sets new default route in the schema.
repositories() - Method in class io.spine.server.BoundedContextBuilder
Obtains the list of repositories added to the builder by the time of the call.
repository() - Method in class io.spine.server.aggregate.AggregateDelivery.AggregateMessageConsumer
 
repository() - Method in class io.spine.server.delivery.Consumer
 
Repository<I,E extends Entity<I,?>> - Class in io.spine.server.entity
Abstract base class for repositories.
Repository() - Constructor for class io.spine.server.entity.Repository
Creates the repository.
repository() - Method in class io.spine.server.procman.PmDelivery.PmMessageConsumer
 
RepositoryView<I,E extends Entity<I,?>> - Interface in io.spine.server.entity
A view on a repository.
route(Class<M>, CommandRoute<I, M>) - Method in class io.spine.server.route.CommandRouting
Sets a custom route for the passed command class.
route(Class<E>, EventRoute<I, E>) - Method in class io.spine.server.route.EventRouting
Sets a custom route for the passed event class.
Route<M extends com.google.protobuf.Message,C extends com.google.protobuf.Message,R> - Interface in io.spine.server.route
Obtains one or more entity identifiers based on a message and its context.
route(Class<S>, StateUpdateRoute<I, S>) - Method in class io.spine.server.route.StateUpdateRouting
Sets a custom route for the passed entity state class.
routeEntityStateUpdates(StateUpdateRouting<I>) - Method in class io.spine.server.route.EventRouting
Sets a custom routing schema for entity state updates.

S

schedule(Command) - Method in class io.spine.server.commandbus.CommandScheduler
Schedules a command and delivers it to the target according to the scheduling options.
self() - Method in class io.spine.server.aggregate.ImportBus.Builder
 
self() - Method in class io.spine.server.bus.BusBuilder
Returns this reference to avoid redundant casts.
self() - Method in class io.spine.server.commandbus.CommandBus.Builder
 
self() - Method in class io.spine.server.event.EventBus.Builder
 
self() - Method in class io.spine.server.integration.IntegrationBus.Builder
 
send(I, M) - Method in class io.spine.server.delivery.Sender
Send the given message to the consuming part of this delivery, where the target with the specified id will be called to handle it.
Sender<I,M extends io.spine.core.ActorMessageEnvelope<?,?,?>> - Class in io.spine.server.delivery
The sending part of the Delivery.
Sender(DeliveryTag) - Constructor for class io.spine.server.delivery.Sender
 
Server - Class in io.spine.server
Exposes one or more Bounded Contexts via CommandService and QueryService.
Server.Builder - Class in io.spine.server
 
ServerEnvironment - Class in io.spine.server
 
setArchived(boolean) - Method in class io.spine.server.entity.AbstractVersionableEntity
Sets archived status flag to the passed value.
setArchived(boolean) - Method in class io.spine.server.entity.TransactionalEntity
Sets archived status flag to the passed value.
setBoundedContextName(BoundedContextName) - Method in class io.spine.server.delivery.ShardedStream.AbstractBuilder
 
setBoundedContextName(BoundedContextName) - Method in class io.spine.server.integration.IntegrationBus.Builder
 
setCallbackExecutor(Executor) - Method in class io.spine.server.stand.Stand.Builder
Sets an Executor to be used for executing callback methods.
setColumnValue(R, S, C) - Method in interface io.spine.server.entity.storage.ColumnType
Set the EntityColumn value to the database record type.
setCommandBus(CommandBus.Builder) - Method in class io.spine.server.BoundedContextBuilder
 
setCommandScheduler(CommandScheduler) - Method in class io.spine.server.commandbus.CommandBus.Builder
 
setConsumer(ShardedStreamConsumer<I, E>) - Method in class io.spine.server.delivery.ShardedStream.AbstractBuilder
 
setDeleted(boolean) - Method in class io.spine.server.entity.AbstractVersionableEntity
Sets deleted status flag to the passed value.
setDeleted(boolean) - Method in class io.spine.server.entity.TransactionalEntity
Sets deleted status flag to the passed value.
setEnricher(Enricher) - Method in class io.spine.server.event.EventBus.Builder
Sets a custom Enricher for events posted to the EventBus which is being built.
setEventBus(EventBus.Builder) - Method in class io.spine.server.BoundedContextBuilder
 
setEventBus(EventBus) - Method in class io.spine.server.integration.IntegrationBus.Builder
 
setEventStore(EventStore) - Method in class io.spine.server.event.EventBus.Builder
Specifies EventStore to be used when creating new EventBus.
setEventStoreStreamExecutor(Executor) - Method in class io.spine.server.event.EventBus.Builder
Specifies an Executor for returning event stream from EventStore.
setInitialState(S, Version) - Method in class io.spine.server.entity.TransactionalEntity
Sets an initial state for the entity.
setIntegrationBus(IntegrationBus.Builder) - Method in class io.spine.server.BoundedContextBuilder
 
setKey(ShardingKey) - Method in class io.spine.server.delivery.ShardedStream.AbstractBuilder
 
setLogger(Logger) - Method in class io.spine.server.event.EventStore.Builder
 
setLogLevelForPost(LoggingObserver.Level) - Method in class io.spine.server.event.EventBus.Builder
Sets logging level for post operations.
setMultitenant(boolean) - Method in class io.spine.server.BoundedContextBuilder
 
setName(String) - Method in class io.spine.server.BoundedContextBuilder
Sets the value of the name for a new bounded context.
setName(BoundedContextName) - Method in class io.spine.server.BoundedContextBuilder
Sets the name for a new bounded context.
setNull(R, C) - Method in interface io.spine.server.entity.storage.ColumnType
Sets the null value to the EntityColumn.
setOriginFields(EventContext.Builder) - Method in class io.spine.server.aggregate.ImportOrigin
 
setOriginFields(EventContext.Builder) - Method in class io.spine.server.entity.EntityStateEnvelope
This method is not supported and always throws UnsupportedOperationException.
setOriginFields(EventContext.Builder) - Method in class io.spine.server.event.RejectionEnvelope
 
setOriginFields(EventContext.Builder) - Method in class io.spine.server.integration.ExternalMessageEnvelope
This method is not supported and always throws UnsupportedOperationException.
setPort(int) - Method in class io.spine.server.Server.Builder
Defines a port for the server.
setPort(int) - Method in class io.spine.server.transport.GrpcContainer.Builder
 
setSnapshotTrigger(int) - Method in class io.spine.server.aggregate.AggregateRepository
Changes the number of events between making aggregate snapshots to the passed value.
setStand(Stand.Builder) - Method in class io.spine.server.BoundedContextBuilder
 
setStorageFactory(StorageFactory) - Method in class io.spine.server.event.EventBus.Builder
Specifies an StorageFactory to configure this EventBus.
setStorageFactory(StorageFactory) - Method in class io.spine.server.event.EventStore.Builder
 
setStorageFactory(StorageFactory) - Method in class io.spine.server.Server.Builder
Assigns default StorageFactory for the server.
setStorageFactorySupplier(Supplier<StorageFactory>) - Method in class io.spine.server.BoundedContextBuilder
Sets the supplier for StorageFactory.
setStreamExecutor(Executor) - Method in class io.spine.server.event.EventStore.Builder
 
setTag(DeliveryTag) - Method in class io.spine.server.delivery.ShardedStream.AbstractBuilder
 
setTargetIdClass(Class<I>) - Method in class io.spine.server.delivery.ShardedStream.AbstractBuilder
 
setTenantIndex(TenantIndex) - Method in class io.spine.server.BoundedContextBuilder
 
setTransportFactory(TransportFactory) - Method in class io.spine.server.integration.IntegrationBus.Builder
 
Shardable - Interface in io.spine.server.delivery
A contract for all message destinations, which require the messages sent to them to be grouped and processed in shards.
ShardedStream<I,M extends com.google.protobuf.Message,E extends io.spine.core.MessageEnvelope<?,M,?>> - Class in io.spine.server.delivery
The stream of messages of a particular type sent for the processing to a specific shard.
ShardedStream.AbstractBuilder<I,E extends io.spine.core.MessageEnvelope<?,?,?>,B extends ShardedStream.AbstractBuilder<I,?,B,S>,S extends ShardedStream<I,?,?>> - Class in io.spine.server.delivery
An abstract base for builders of the ShardedStream descendants.
ShardedStreamConsumer<I,E extends io.spine.core.MessageEnvelope<?,?,?>> - Interface in io.spine.server.delivery
The consumer of the sharded messages of a certain type.
Sharding - Interface in io.spine.server.delivery
The service responsible for orchestrating the shardables and their inbound streams of messages.
ShardingKey - Class in io.spine.server.delivery
A key which defines the group of Entity instances, which must be processed within a single shard.
ShardingKey(EntityClass<?>, ShardIndex) - Constructor for class io.spine.server.delivery.ShardingKey
 
ShardingStrategy - Interface in io.spine.server.delivery
The strategy of splitting the message targets into shards.
shutdown() - Method in class io.spine.server.commandbus.CommandScheduler
Initiates an orderly shutdown in which previously scheduled commands will be delivered later, but no new commands will be accepted.
shutdown() - Method in class io.spine.server.commandbus.ExecutorCommandScheduler
 
shutdown() - Method in class io.spine.server.Server
Initiates an orderly shutdown in which existing calls continue but new calls are rejected.
shutdown() - Method in class io.spine.server.transport.GrpcContainer
Initiates an orderly shutdown in which existing calls continue but new calls are rejected.
shutdownAndWait() - Method in class io.spine.server.Server
Initiates a forceful shutdown in which preexisting and new calls are rejected.
shutdownNowAndWait() - Method in class io.spine.server.transport.GrpcContainer
Initiates a forceful shutdown in which preexisting and new calls are rejected.
SilentWitness() - Constructor for class io.spine.server.entity.TransactionListener.SilentWitness
 
SimpleColumnType<T,R,C> - Class in io.spine.server.entity.storage
A base for implementing ColumnType interface regardless the type conversion.
SimpleColumnType() - Constructor for class io.spine.server.entity.storage.SimpleColumnType
 
singleShard() - Static method in class io.spine.server.delivery.UniformAcrossTargets
Returns a pre-defined strategy instance, which defines a single shard and puts all the targets into it.
singleTenant() - Static method in interface io.spine.server.tenant.TenantIndex
Obtains a TenantIndex to be used in single-tenant context.
SingleThreadInMemTransportFactory - Class in io.spine.server.transport.memory
The implementation of TransportFactory, which uses single-thread subscribers.
SingleThreadInMemTransportFactory() - Constructor for class io.spine.server.transport.memory.SingleThreadInMemTransportFactory
 
Stand - Class in io.spine.server.stand
A container for storing the latest Aggregate states.
Stand.Builder - Class in io.spine.server.stand
 
Stand.EntityUpdateCallback - Interface in io.spine.server.stand
A contract for the callbacks to be executed upon entity state change.
start() - Method in class io.spine.server.Server
Starts the server.
start() - Method in class io.spine.server.transport.GrpcContainer
Starts the service.
StateUpdateRoute<I,M extends com.google.protobuf.Message> - Interface in io.spine.server.route
Obtains a set of entity IDs for which to deliver an entity state update.
StateUpdateRouting<I> - Class in io.spine.server.route
A routing schema used to deliver entity state updates.
Storage<I,M extends com.google.protobuf.Message,R extends ReadRequest<I>> - Interface in io.spine.server.storage
The base interface for storages.
StorageFactory - Interface in io.spine.server.storage
A factory for creating storages used by repositories, EventStore, and Stand.
StorageFactorySwitch - Class in io.spine.server.storage
The Supplier of StorageFactory that takes into account if the code runs under tests on in the production mode.
StorageField - Interface in io.spine.server.storage
A marker interface for the enums representing the names of the fields used by the framework to store its data.
StorageSpec<I> - Class in io.spine.server.storage.memory
Attributes for accessing in-memory storage over in-process gRPC.
StorageWithLifecycleFlags<I,M extends com.google.protobuf.Message,R extends ReadRequest<I>> - Interface in io.spine.server.storage
A storage that allows to update lifecycle flags of entities.
store(A) - Method in class io.spine.server.aggregate.AggregateRepository
Stores the passed aggregate and commits its uncommitted events.
store(Iterable<Event>) - Method in class io.spine.server.aggregate.ImportBus
Updates the TenantIndex with the ID obtained from the passed events.
store(Iterable<T>) - Method in class io.spine.server.bus.Bus
Stores the given messages into the underlying storage.
store(Iterable<Command>) - Method in class io.spine.server.commandbus.CommandBus
 
store(E) - Method in class io.spine.server.entity.RecordBasedRepository
 
store(Collection<E>) - Method in class io.spine.server.entity.RecordBasedRepository
Stores Entities in bulk.
store(E) - Method in class io.spine.server.entity.Repository
Stores the passed object.
store(Iterable<Event>) - Method in class io.spine.server.event.EventBus
 
store(Iterable<ExternalMessage>) - Method in class io.spine.server.integration.IntegrationBus
 
stream() - Method in class io.spine.server.entity.RecentHistory
Creates a new Stream of the recent history items.
subscribe(Topic, StreamObserver<Subscription>) - Method in class io.spine.server.stand.Stand
Subscribes for all further changes of an entity state, which satisfies the Topic.
subscribe(Topic, StreamObserver<Subscription>) - Method in class io.spine.server.SubscriptionService
 
Subscriber - Class in io.spine.server.transport
Subscriber for messages of a channel with the specified ID.
Subscriber(ChannelId) - Constructor for class io.spine.server.transport.Subscriber
 
SubscriberHub - Class in io.spine.server.transport
The hub of Subscribers.
SubscriberHub(TransportFactory) - Constructor for class io.spine.server.transport.SubscriberHub
 
SubscriptionService - Class in io.spine.server
The SubscriptionService provides an asynchronous way to fetch read-side state from the server.
SubscriptionService.Builder - Class in io.spine.server
 
systemNotSet() - Static method in class io.spine.server.bus.BusBuilder.FieldCheck
 

T

TenantAwareFunction<F,T> - Class in io.spine.server.tenant
A function, which is calculated in a tenant context.
TenantAwareFunction() - Constructor for class io.spine.server.tenant.TenantAwareFunction
 
TenantAwareFunction(TenantId) - Constructor for class io.spine.server.tenant.TenantAwareFunction
 
TenantAwareFunction0<T> - Class in io.spine.server.tenant
A tenant-aware function that takes no parameters.
TenantAwareFunction0() - Constructor for class io.spine.server.tenant.TenantAwareFunction0
 
TenantAwareFunction0(TenantId) - Constructor for class io.spine.server.tenant.TenantAwareFunction0
 
TenantAwareOperation - Class in io.spine.server.tenant
An abstract base for operations on a tenant data.
TenantAwareOperation() - Constructor for class io.spine.server.tenant.TenantAwareOperation
Creates an instance of an operation, which uses the TenantId set in the execution context.
TenantAwareOperation(TenantId) - Constructor for class io.spine.server.tenant.TenantAwareOperation
Creates an instance of an operation for the tenant specified by the passed ID.
TenantIndex - Interface in io.spine.server.tenant
The index of tenant IDs in a multi-tenant application.
tenantIndexNotSet() - Static method in class io.spine.server.bus.BusBuilder.FieldCheck
 
TenantRepository<T extends com.google.protobuf.Message,E extends TenantRepository.Entity<T>> - Class in io.spine.server.tenant
Abstract base for repositories storing information about tenants.
TenantRepository() - Constructor for class io.spine.server.tenant.TenantRepository
 
TenantRepository.Entity<T extends com.google.protobuf.Message> - Class in io.spine.server.tenant
Stores data associated with a tenant ID.
thisClass() - Method in class io.spine.server.aggregate.Aggregate
Obtains model class for this aggregate.
thisClass() - Method in class io.spine.server.aggregate.AggregatePart
Obtains model class for this aggregate part.
thisClass() - Method in class io.spine.server.entity.AbstractEntity
Obtains model class for this entity.
thisClass() - Method in class io.spine.server.procman.ProcessManager
 
thisClass() - Method in class io.spine.server.projection.Projection
 
toEnvelope(Event) - Method in class io.spine.server.aggregate.ImportBus
 
toEnvelope(T) - Method in class io.spine.server.bus.Bus
Packs the given message of type T into an envelope of type E.
toEnvelope(Command) - Method in class io.spine.server.commandbus.CommandBus
 
toEnvelope(Event) - Method in class io.spine.server.event.EventBus
 
toEnvelope(ExternalMessage) - Method in class io.spine.server.integration.IntegrationBus
 
toEventEnvelope() - Method in class io.spine.server.integration.ExternalMessageEnvelope
Converts this instance to an envelope of the external event.
toPersistedValue(Object) - Method in class io.spine.server.entity.storage.EntityColumn
Converts the column value into the value for persistence in the data storage.
toRecord(E) - Method in class io.spine.server.entity.RecordBasedRepository
Converts the passed entity into the record.
toSingleTenant() - Method in class io.spine.server.storage.memory.InMemoryStorageFactory
 
toSingleTenant() - Method in interface io.spine.server.storage.StorageFactory
Creates a single-tenant version of the factory.
toString() - Method in class io.spine.server.delivery.DeliveryTag
 
toString() - Method in class io.spine.server.delivery.ShardedStream
 
toString() - Method in class io.spine.server.entity.AbstractEntity
 
toString() - Method in class io.spine.server.entity.EntityStateEnvelope
 
toString() - Method in class io.spine.server.entity.RecentHistory
 
toString() - Method in class io.spine.server.entity.storage.CompositeQueryParameter
 
toString() - Method in class io.spine.server.entity.storage.EntityColumn
 
toString() - Method in class io.spine.server.entity.storage.EntityQuery
 
toString() - Method in class io.spine.server.entity.storage.QueryParameters
 
toString() - Method in class io.spine.server.integration.IntegrationBus
 
toString() - Method in class io.spine.server.stand.AggregateStateId
 
toString() - Method in class io.spine.server.storage.memory.StorageSpec
 
TransactionalEntity<I,S extends com.google.protobuf.Message,B extends io.spine.validate.ValidatingBuilder<S,? extends com.google.protobuf.Message.Builder>> - Class in io.spine.server.entity
A base for entities, perform transactions events.
TransactionalEntity(I) - Constructor for class io.spine.server.entity.TransactionalEntity
Creates a new instance.
TransactionListener.SilentWitness<I,E extends TransactionalEntity<I,S,B>,S extends com.google.protobuf.Message,B extends io.spine.validate.ValidatingBuilder<S,? extends com.google.protobuf.Message.Builder>> - Class in io.spine.server.entity
An implementation of a TransactionListener which does not set any behavior for its callbacks.
TransportFactory - Interface in io.spine.server.transport
A factory for creating channel-based transport for Message inter-exchange between the current deployment component and other application parts.
Triplet<A extends com.google.protobuf.Message,B,C> - Class in io.spine.server.tuple
A tuple with three elements.
Tuple - Class in io.spine.server.tuple
Abstract base for tuple classes.
Tuple(Object...) - Constructor for class io.spine.server.tuple.Tuple
Creates a new instance with the passed values.
tx() - Method in class io.spine.server.entity.TransactionalEntity
 
tx() - Method in class io.spine.server.procman.ProcessManager

U

unCache(TenantId) - Method in class io.spine.server.tenant.TenantRepository
Removes the passed value from the in-memory cache of known tenant IDs.
unexpectedValue(Message, Message, Message) - Method in class io.spine.server.command.CommandHandlingEntity
Creates ValueMismatch for the case of discovering a value different than by a command.
unexpectedValue(String, String, String) - Method in class io.spine.server.command.CommandHandlingEntity
Creates ValueMismatch for the case of discovering a value different than expected by a command.
Unicast<I,M extends com.google.protobuf.Message,C extends com.google.protobuf.Message> - Interface in io.spine.server.route
A route for a message to be delivered ton one entity.
UnicastBus<T extends com.google.protobuf.Message,E extends io.spine.core.MessageEnvelope<?,T,?>,C extends io.spine.type.MessageClass<? extends com.google.protobuf.Message>,D extends MessageDispatcher<C,E,?>> - Class in io.spine.server.bus
A bus which delivers a message to one dispatcher.
UnicastBus(BusBuilder<E, T, ?>) - Constructor for class io.spine.server.bus.UnicastBus
 
UnicastDispatcher<C extends io.spine.type.MessageClass,E extends io.spine.core.MessageEnvelope,I> - Interface in io.spine.server.bus
Dispatches a message to one entity.
UniformAcrossTargets - Class in io.spine.server.delivery
The strategy of splitting the entities into a number of shards uniformly.
unknownTenantError(Message, String) - Static method in exception io.spine.server.commandbus.InvalidCommandException
Creates an error for a command with missing tenant_id attribute in the CommandContext, which is required in a multitenant application.
unregister(D) - Method in class io.spine.server.bus.Bus
Unregisters dispatching for message classes of the passed dispatcher.
unregister(D) - Method in class io.spine.server.bus.DispatcherRegistry
 
unregister(Shardable) - Method in class io.spine.server.delivery.InProcessSharding
 
unregister(Shardable) - Method in interface io.spine.server.delivery.Sharding
Unregister a shardable instance.
unregister(ExternalMessageDispatcher<?>) - Method in class io.spine.server.integration.IntegrationBus
Unregisters a local dispatcher, which should no longer be subscribed to external messages.
unregister(AbstractEventSubscriber) - Method in class io.spine.server.integration.IntegrationBus
Unregisters the passed event subscriber as an external event dispatcher by taking only external subscriptions into account.
unregisterAll() - Method in class io.spine.server.bus.DispatcherRegistry
Unregisters all dispatchers.
unregisterWithSharding() - Method in interface io.spine.server.delivery.Shardable
Unregisters this instance Sharding obtained from the ServerEnvironment.
UnsupportedCommandException - Exception in io.spine.server.commandbus
Exception that is thrown when unsupported command is obtained or in case there is no class for given Protobuf command message.
UnsupportedCommandException(Command) - Constructor for exception io.spine.server.commandbus.UnsupportedCommandException
 
UnsupportedEventException - Exception in io.spine.server.event
Exception that is thrown when unsupported event is obtained or in case there is no class for given Protobuf event message.
UnsupportedEventException(EventMessage) - Constructor for exception io.spine.server.event.UnsupportedEventException
 
UnsupportedExternalMessageException - Exception in io.spine.server.integration
Exception that is thrown when unsupported external message is obtained or in case there is no class for the given Protobuf event message.
UnsupportedExternalMessageException(Message) - Constructor for exception io.spine.server.integration.UnsupportedExternalMessageException
 
UnsupportedImportEventException - Exception in io.spine.server.aggregate
Thrown when there are no aggregates that accept an event message for import.
updateBuilder(EntityRecord.Builder, E) - Method in class io.spine.server.entity.EntityStorageConverter
Derived classes may override to additionally tune the passed entity builder.
updateState(S) - Method in class io.spine.server.entity.AbstractEntity
Updates the state of the entity.

V

validate(E) - Method in interface io.spine.server.bus.EnvelopeValidator
Validates the given MessageEnvelope by some specific rules.
valueOf(String) - Static method in enum io.spine.server.aggregate.AggregateField
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.spine.server.aggregate.AggregatePart.GenericParameter
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.spine.server.entity.Entity.GenericParameter
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.spine.server.entity.storage.EnumType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.spine.server.event.storage.EventContextField
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.spine.server.event.storage.EventField
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.spine.server.storage.EntityField
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.spine.server.storage.LifecycleFlagField
Returns the enum constant of this type with the specified name.
values() - Static method in enum io.spine.server.aggregate.AggregateField
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.spine.server.aggregate.AggregatePart.GenericParameter
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.spine.server.entity.Entity.GenericParameter
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.spine.server.entity.storage.EnumType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.spine.server.event.storage.EventContextField
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.spine.server.event.storage.EventField
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.spine.server.storage.EntityField
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.spine.server.storage.LifecycleFlagField
Returns an array containing the constants of this enum type, in the order they are declared.
VersionableEntity<I,S extends com.google.protobuf.Message> - Interface in io.spine.server.entity
An entity with version and timestamp of the last modification.
versionNumber() - Method in class io.spine.server.aggregate.Aggregate
Obtains the version number of the entity.
versionNumber() - Method in class io.spine.server.entity.AbstractVersionableEntity
Obtains the version number of the entity.

W

whenModified() - Method in class io.spine.server.entity.AbstractVersionableEntity
Obtains timestamp of the entity version.
withA(A) - Static method in class io.spine.server.tuple.EitherOf2
Creates a new instance with <A> value.
withA(A) - Static method in class io.spine.server.tuple.EitherOf3
Creates a new instance with <A> value.
withA(A) - Static method in class io.spine.server.tuple.EitherOf4
Creates a new instance with <A> value.
withA(A) - Static method in class io.spine.server.tuple.EitherOf5
Creates a new instance with <A> value.
withB(B) - Static method in class io.spine.server.tuple.EitherOf2
Creates a new instance with <B> value.
withB(B) - Static method in class io.spine.server.tuple.EitherOf3
Creates a new instance with <B> value.
withB(B) - Static method in class io.spine.server.tuple.EitherOf4
Creates a new instance with <B> value.
withB(B) - Static method in class io.spine.server.tuple.EitherOf5
Creates a new instance with <B> value.
withC(C) - Static method in class io.spine.server.tuple.EitherOf3
Creates a new instance with <C> value.
withC(C) - Static method in class io.spine.server.tuple.EitherOf4
Creates a new instance with <C> value.
withC(C) - Static method in class io.spine.server.tuple.EitherOf5
Creates a new instance with <C> value.
withD(D) - Static method in class io.spine.server.tuple.EitherOf4
Creates a new instance with <C> value.
withD(D) - Static method in class io.spine.server.tuple.EitherOf5
Creates a new instance with <D> value.
withDefault(EventRoute<I, EventMessage>) - Static method in class io.spine.server.route.EventRouting
Creates a new event routing with the passed default route.
withDefaultLogger() - Method in class io.spine.server.event.EventStore.Builder
Sets default logger.
withE(E) - Static method in class io.spine.server.tuple.EitherOf5
Creates a new instance with <E> value.
withEither(A, B) - Static method in class io.spine.server.tuple.Pair
Creates a pair with the second element of a type descending from Either.
withFieldMask(FieldMask) - Method in class io.spine.server.entity.EntityStorageConverter
Creates a copy of this converter modified with the passed filed mask.
WithLifecycle - Interface in io.spine.server.entity
Something with LifecycleFlags.
withNullable(A, B) - Static method in class io.spine.server.tuple.Pair
Creates a pair with optionally present second value.
withNullable(A, B, C, D) - Static method in class io.spine.server.tuple.Quartet
Creates a quartet with one optional value.
withNullable(A, B, C, D, E) - Static method in class io.spine.server.tuple.Quintet
Creates a quintet with one optional value.
withNullable(A, B, C) - Static method in class io.spine.server.tuple.Triplet
Creates a triplet with the last element optional.
withNullable2(A, B, C, D) - Static method in class io.spine.server.tuple.Quartet
Creates a quartet with two optional values.
withNullable2(A, B, C, D, E) - Static method in class io.spine.server.tuple.Quintet
Creates a quintet with two optional values.
withNullable2(A, B, C) - Static method in class io.spine.server.tuple.Triplet
Creates a new triplet with optional second and third elements.
withNullable3(A, B, C, D) - Static method in class io.spine.server.tuple.Quartet
Creates a quartet with three optional values.
withNullable3(A, B, C, D, E) - Static method in class io.spine.server.tuple.Quintet
Creates a quintet with three optional values.
withNullable4(A, B, C, D, E) - Static method in class io.spine.server.tuple.Quintet
Creates a quintet with four optional values.
write(I, AggregateStateRecord) - Method in class io.spine.server.aggregate.AggregateStorage
Writes events into the storage.
write(I, EntityRecordWithColumns) - Method in class io.spine.server.storage.RecordStorage
Writes a record and its entity columns into the storage.
write(I, EntityRecord) - Method in class io.spine.server.storage.RecordStorage
 
write(Map<I, EntityRecordWithColumns>) - Method in class io.spine.server.storage.RecordStorage
Writes a bulk of records into the storage.
write(I, M) - Method in interface io.spine.server.storage.Storage
Writes a record into the storage.
writeEventCountAfterLastSnapshot(I, int) - Method in class io.spine.server.aggregate.AggregateStorage
Writes a count of events which were saved to the storage after the last snapshot was created, or a count of all events if there were no snapshots yet.
writeLastHandledEventTime(Timestamp) - Method in class io.spine.server.projection.ProjectionStorage
Writes the time of the last handled event to the storage.
writeLastHandledEventTime(Timestamp) - Method in class io.spine.server.storage.memory.InMemoryProjectionStorage
 
writeLifecycleFlags(I, LifecycleFlags) - Method in class io.spine.server.storage.RecordStorage
 
writeLifecycleFlags(I, LifecycleFlags) - Method in interface io.spine.server.storage.StorageWithLifecycleFlags
Writes the lifecycle status for the entity with the passed ID.
writeRecord(I, AggregateEventRecord) - Method in class io.spine.server.aggregate.AggregateStorage
Writes the passed record into the storage.
writeRecord(I, EntityRecordWithColumns) - Method in class io.spine.server.projection.ProjectionStorage
 
writeRecord(I, EntityRecordWithColumns) - Method in class io.spine.server.storage.memory.InMemoryRecordStorage
 
writeRecord(I, EntityRecordWithColumns) - Method in class io.spine.server.storage.RecordStorage
Writes a record and the associated EntityColumn values into the storage.
writeRecords(Map<I, EntityRecordWithColumns>) - Method in class io.spine.server.projection.ProjectionStorage
 
writeRecords(Map<I, EntityRecordWithColumns>) - Method in class io.spine.server.storage.memory.InMemoryRecordStorage
 
writeRecords(Map<I, EntityRecordWithColumns>) - Method in class io.spine.server.storage.RecordStorage
Writes a bulk of records into the storage.
A B C D E F G H I K L M N O P Q R S T U V W 
Skip navigation links