package sync
- Alphabetic
- Public
- Protected
Type Members
- final case class AbortedDueToShutdownError(msg: String) extends ConnectedSynchronizerInitializationError with Product with Serializable
- class CantonDynamicSynchronizerParameterGetter extends DynamicSynchronizerParameterGetter with NamedLogging
- class CantonSyncService extends SyncService with ParticipantPruningSyncService with FlagCloseable with Spanning with NamedLogging with HasCloseContext with InternalStateServiceProviderImpl
The Canton-based synchronization service.
The Canton-based synchronization service.
A single Canton sync service can connect to multiple synchronizers.
- final case class CommandProgressTrackerConfig(enabled: Boolean = true, maxFailed: NonNegativeInt = defaultMaxFailed, maxPending: NonNegativeInt = defaultMaxPending, maxSucceeded: NonNegativeInt = defaultMaxSucceeded) extends UniformCantonConfigValidation with Product with Serializable
- class CommandProgressTrackerImpl extends CommandProgressTracker with NamedLogging
- Annotations
- @SuppressWarnings()
- class ConnectedSynchronizer extends NamedLogging with FlagCloseableAsync with ReassignmentSubmissionHandle with CloseableHealthComponent with AtomicHealthComponent
A connected synchronizer from the synchronization service.
- sealed trait ConnectedSynchronizerInitializationError extends AnyRef
- trait ConnectedSynchronizersLookup extends AnyRef
Read-only interface to the current map of which synchronizers we're connected to.
- class ConnectedSynchronizersLookupContainer extends ConnectedSynchronizersLookup
- class EnterpriseCantonSyncServiceFactory extends Factory[CantonSyncService]
- final case class ParticipantDidNotBecomeActive(msg: String) extends ConnectedSynchronizerInitializationError with Product with Serializable
- class ParticipantEventPublisher extends NamedLogging with FlagCloseable
Helper to publish participant events in a thread-safe way.
Helper to publish participant events in a thread-safe way. For "regular" synchronizer related events thread safety is taken care of by the com.digitalasset.canton.participant.event.RecordOrderPublisher.
ParticipantEventPublisher also encapsulates the participant clock generating unique participant recordTime.
- final case class ParticipantTopologyHandshakeError(err: SynchronizerRegistryError) extends ConnectedSynchronizerInitializationError with Product with Serializable
- final case class SequencedEventStoreError(err: store.SequencedEventStoreError) extends ConnectedSynchronizerInitializationError with Product with Serializable
- class SyncEphemeralState extends SyncEphemeralStateLookup with NamedLogging with CloseableHealthComponent with AtomicHealthComponent
The participant-relevant state and components for a synchronizer that is kept only in memory and must be reconstructed after crashes and fatal errors from the com.digitalasset.canton.participant.store.SyncPersistentState.
The participant-relevant state and components for a synchronizer that is kept only in memory and must be reconstructed after crashes and fatal errors from the com.digitalasset.canton.participant.store.SyncPersistentState. The ephemeral state can be kept across network disconnects provided that the local processing continues as far as possible.
- trait SyncEphemeralStateFactory extends AnyRef
- class SyncEphemeralStateFactoryImpl extends SyncEphemeralStateFactory with NamedLogging
- trait SyncEphemeralStateLookup extends AnyRef
- trait SyncPersistentStateLookup extends AnyRef
Read-only interface to the SyncPersistentStateManager
- class SyncPersistentStateManager extends SyncPersistentStateLookup with AutoCloseable with NamedLogging
Manages participant-relevant state for a synchronizer that needs to survive reconnects
Manages participant-relevant state for a synchronizer that needs to survive reconnects
Factory for com.digitalasset.canton.participant.store.SyncPersistentState. Tries to discover existing persistent states or create new ones and checks consistency of synchronizer parameters and unique contract key synchronizers
- trait SyncServiceError extends Serializable with Product with ContextualizedCantonError
- class SynchronizerMigration extends NamedLogging with FlagCloseable
Migration of contracts from a source synchronizer to target synchronizer by re-associating them in the participant's persistent store.
- sealed trait SynchronizerMigrationError extends Product with Serializable with ContextualizedCantonError
Value Members
- object CantonSyncService
- object CommandDeduplicationError extends InjectionErrorGroup
- object CommandProgressTrackerConfig extends Serializable
- object ConnectedSynchronizer
- object ConnectedSynchronizersLookup
- object ParticipantEventPublisher
- object SyncEphemeralState
- object SyncEphemeralStateFactory
- object SyncServiceError extends SyncServiceErrorGroup with Serializable
- object SyncServiceInjectionError extends InjectionErrorGroup
- object SynchronizerMigrationError extends MigrationErrors with Serializable