Packages

package sync

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. final case class AbortedDueToShutdownError(msg: String) extends ConnectedSynchronizerInitializationError with Product with Serializable
  2. class CantonDynamicSynchronizerParameterGetter extends DynamicSynchronizerParameterGetter with NamedLogging
  3. 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.

  4. final case class CommandProgressTrackerConfig(enabled: Boolean = true, maxFailed: NonNegativeInt = defaultMaxFailed, maxPending: NonNegativeInt = defaultMaxPending, maxSucceeded: NonNegativeInt = defaultMaxSucceeded) extends UniformCantonConfigValidation with Product with Serializable
  5. class CommandProgressTrackerImpl extends CommandProgressTracker with NamedLogging
    Annotations
    @SuppressWarnings()
  6. class ConnectedSynchronizer extends NamedLogging with FlagCloseableAsync with ReassignmentSubmissionHandle with CloseableHealthComponent with AtomicHealthComponent

    A connected synchronizer from the synchronization service.

  7. sealed trait ConnectedSynchronizerInitializationError extends AnyRef
  8. trait ConnectedSynchronizersLookup extends AnyRef

    Read-only interface to the current map of which synchronizers we're connected to.

  9. class ConnectedSynchronizersLookupContainer extends ConnectedSynchronizersLookup
  10. class EnterpriseCantonSyncServiceFactory extends Factory[CantonSyncService]
  11. final case class ParticipantDidNotBecomeActive(msg: String) extends ConnectedSynchronizerInitializationError with Product with Serializable
  12. 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.

  13. final case class ParticipantTopologyHandshakeError(err: SynchronizerRegistryError) extends ConnectedSynchronizerInitializationError with Product with Serializable
  14. final case class SequencedEventStoreError(err: store.SequencedEventStoreError) extends ConnectedSynchronizerInitializationError with Product with Serializable
  15. 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.

  16. trait SyncEphemeralStateFactory extends AnyRef
  17. class SyncEphemeralStateFactoryImpl extends SyncEphemeralStateFactory with NamedLogging
  18. trait SyncEphemeralStateLookup extends AnyRef
  19. trait SyncPersistentStateLookup extends AnyRef

    Read-only interface to the SyncPersistentStateManager

  20. 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

  21. trait SyncServiceError extends Serializable with Product with ContextualizedCantonError
  22. 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.

  23. sealed trait SynchronizerMigrationError extends Product with Serializable with ContextualizedCantonError

Ungrouped