Namespace Reaqtor.QueryEngine
Classes
CheckpointableExtensions
Extension methods for the ICheckpointable interface.
CheckpointingQueryEngine
Reactive event processing query engine that supports checkpointing.
CheckpointKind
Enum with different checkpoint kinds.
ConfigurationOptions
Exposes a set of configuration options for query engines.
EngineUnloadedException
Exception used to signal the engine has unloaded.
EntityAlreadyExistsException
Exception indicating that an entity with a given identifier already exists.
EntityLoadFailedException
Exception representing the failure to load a reactive entity.
EntityNotFoundException
Exception indicating that an entity with a given identifier was not found.
EntitySaveFailedException
Exception representing the failure to save a reactive entity.
ExpressionPolicy
Expression policy with settable properties.
QueryEngineStatus
Flags representing the status of a query engine.
QuotedTypeConversionTargets
Used to specify mappings between quotation types and target types.
ReactiveEntityKind
Enum with different reactive entity kinds.
ReliableObservableExtensions
Utility and extension methods for reliable observables.
SerializationPolicy
Serialization policy, providing a central location to obtain ISerializer instances, for example when serializing state during a checkpoint, or when deserializing state from a checkpoint where the persisted state contains a name and version for the serializer that was used to write the state.
SerializerVersioning
Exposed version numbers of serializers.
StateWriterExtensions
Extension methods for the IStateWriter interface.
TransactedKeyValueTable
Helper methods for ITransactedKeyValueTable<TKey, TValue>
Transaction
Helper class for ITransaction
Interfaces
ICheckpointable
Represents a system that can be checkpointed.
ICheckpointingQueryEngine
Represents a query engine that can be checkpointed.
ICheckpointStorageProvider
Represents a checkpoint storage provider.
IDelegationTarget
Indicates that a class can analyze and possibly rewrite an expression tree containing itself. The expression tree will map the delegation target as a parameter expression.
IKeyValueStore
A persistent transactional key value store. Transactions span all tables.
IKeyValueStoreTransaction
A transaction for a key value store.
IKeyValueTable<TKey, TValue>
A table in a key value store.
IQueryEngine
Represents a query engine.
IQuotedTypeConversionTargets
Interface to specify mappings between quotation types and target types.
IReactiveServiceResolver
Represents a service resolver used to locate a reactive service hosting artifacts with the specified URIs.
IReliableQueryEngine
Represents a query engine exposing a reliable reactive service, used for cross-engine communication.
ISerializationPolicy
Serialization policy, providing a central location to obtain ISerializer instances, for example when serializing state during a checkpoint, or when deserializing state from a checkpoint where the persisted state contains a name and version for the serializer that was used to write the state.
ISerializer
Interface used to abstract over serializers used for persistence of state (checkpoints, transaction logs, etc.).
IStateReader
Provides capabilities to read an engine's state from a store.
IStateWriter
Provides capabilities to write an engine's state to a store.
ITransactedKeyValueTable<TKey, TValue>
A key value table that operates in the scope of a transaction. For example, if the transaction has snapshot isolation, this acts on a snapshot of the table. Note that the implementation of this data structure is not required to be thread safe. Concurrent reads and/or writes may corrupt the invariants of the implementation.
ITransaction
Represents a series of operations that are all applied or all not applied (in the case of errors).