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 AutomaticLogicalSynchronizerUpgrade extends LogicalSynchronizerUpgrade[Unit]

    This class implements automatic LSU.

    This class implements automatic LSU. It should be called for participants that are not upgrading too late (after the old synchronizer has been decomissioned).

  3. class CantonDynamicSynchronizerParameterGetter extends DynamicSynchronizerParameterGetter with NamedLogging
  4. class CantonSyncService extends SyncService with ParticipantPruningSyncService with FlagCloseable with Spanning with NamedLogging with HasCloseContext with InternalIndexServiceProviderImpl

    The Canton-based synchronization service.

    The Canton-based synchronization service.

    A single Canton sync service can connect to multiple synchronizers.

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

    A connected synchronizer from the synchronization service.

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

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

  10. class ConnectedSynchronizersLookupContainer extends ConnectedSynchronizersLookup
  11. class EnterpriseCantonSyncServiceFactory extends Factory[CantonSyncService]
  12. abstract class LogicalSynchronizerUpgrade[Param] extends NamedLogging with FlagCloseable

    Performs the upgrade from one physical synchronizer to its successor.

    Performs the upgrade from one physical synchronizer to its successor. The final step is to mark the successor configuration as active.

  13. trait LogicalSynchronizerUpgradeCallback extends AnyRef
  14. class LogicalSynchronizerUpgradeCallbackImpl extends LogicalSynchronizerUpgradeCallback with NamedLogging
  15. final case class ParticipantDidNotBecomeActive(msg: String) extends ConnectedSynchronizerInitializationError with Product with Serializable
  16. 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.

  17. final case class ParticipantTopologyHandshakeError(err: SynchronizerRegistryError) extends ConnectedSynchronizerInitializationError with Product with Serializable
  18. final case class SequencedEventStoreError(err: store.SequencedEventStoreError) extends ConnectedSynchronizerInitializationError with Product with Serializable
  19. trait StaticSynchronizerParametersGetter extends AnyRef
  20. 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.

  21. trait SyncEphemeralStateFactory extends AnyRef
  22. class SyncEphemeralStateFactoryImpl extends SyncEphemeralStateFactory with NamedLogging
  23. trait SyncEphemeralStateLookup extends AnyRef
  24. trait SyncPersistentStateLookup extends AnyRef

    Read-only interface to the SyncPersistentStateManager

  25. class SyncPersistentStateManager extends SyncPersistentStateLookup with StaticSynchronizerParametersGetter 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

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

  28. sealed trait SynchronizerMigrationError extends Product with Serializable with ContextualizedCantonError

Ungrouped