- class DbFinalizedResponseStore extends FinalizedResponseStore with DbStore
- class DbMediatorDomainConfigurationStore extends MediatorDomainConfigurationStore with DbStore
- trait FinalizedResponseStore extends AutoCloseable
Stores and retrieves finalized mediator response aggregations
- class InMemoryFinalizedResponseStore extends FinalizedResponseStore with NamedLogging
- class InMemoryMediatorDomainConfigurationStore extends MediatorDomainConfigurationStore
- final case class MediatorDomainConfiguration(initialKeyFingerprint: Fingerprint, domainId: DomainId, domainParameters: StaticDomainParameters, sequencerConnection: SequencerConnection) extends Product with Serializable
- trait MediatorDomainConfigurationStore extends AutoCloseable
- sealed trait MediatorDomainConfigurationStoreError extends AnyRef
- class MediatorState extends NamedLogging with FlagCloseable
Provides state management for messages received by the mediator.
Provides state management for messages received by the mediator. Non-finalized response aggregations are kept in memory, such that in case of the node shutting down, they are lost but the participants waiting for a transaction result will simply timeout. The finalized response aggregations are stored in the provided FinalizedResponseStore. It is expected that
fetchPendingRequestIdsBeforeoperation is not called concurrently with operations to modify the pending requests.
- object FinalizedResponseStore
- object MediatorDomainConfigurationStore
- object MediatorDomainConfigurationStoreError