Packages

package sync

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. class CantonAuthorityResolver extends AuthorityResolver with NamedLogging
  2. class CantonDynamicDomainParameterGetter extends DynamicDomainParameterGetter with NamedLogging
  3. class CantonSyncService extends WriteService with WriteParticipantPruningService with ReadService with FlagCloseable with Spanning with NamedLogging with HasCloseContext

    The Canton-based synchronization service.

    The Canton-based synchronization service.

    A single Canton sync service can connect to multiple domains.

  4. final case class CommandProgressTrackerConfig(enabled: Boolean = true, maxFailed: NonNegativeInt = defaultMaxFailed, maxPending: NonNegativeInt = defaultMaxPending, maxSucceeded: NonNegativeInt = defaultMaxSucceeded) extends Product with Serializable
  5. class CommandProgressTrackerImpl extends CommandProgressTracker with NamedLogging
    Annotations
    @SuppressWarnings()
  6. trait ConnectedDomainsLookup extends AnyRef

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

  7. class EnterpriseCantonSyncServiceFactory extends Factory[CantonSyncService]
  8. class EnterprisePackageUploaderFactory extends PackageUploaderFactory
  9. class EnterpriseParticipantPersistentStateFactory extends ParticipantNodePersistentStateFactory
  10. final class EventTranslationStrategy extends AnyRef
  11. sealed trait LedgerSyncEvent extends Product with Serializable with PrettyPrinting

    This a copy of com.digitalasset.canton.ledger.participant.state.v2.Update.

    This a copy of com.digitalasset.canton.ledger.participant.state.v2.Update. Refer to com.digitalasset.canton.ledger.participant.state.v2.Update documentation for more information.

  12. final case class ParticipantDidNotBecomeActive(msg: String) extends SyncDomainInitializationError with Product with Serializable
  13. 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" SingleDimensionEventLogs representing domains thread safety is taken care of by the com.digitalasset.canton.participant.event.RecordOrderPublisher.

    ParticipantEventPublisher also encapsulates the participant clock generating unique participant recordTime.

  14. final case class ParticipantTopologyHandshakeError(err: DomainRegistryError) extends SyncDomainInitializationError with Product with Serializable
  15. final case class SequencedEventStoreError(err: store.SequencedEventStoreError) extends SyncDomainInitializationError with Product with Serializable
  16. class SyncDomain extends NamedLogging with StartAndCloseable[Either[SyncDomainInitializationError, Unit]] with TransferSubmissionHandle with CloseableHealthComponent with AtomicHealthComponent with HasCloseContext

    A connected domain from the synchronization service.

  17. sealed trait SyncDomainInitializationError extends AnyRef
  18. class SyncDomainMigration extends NamedLogging with FlagCloseable
  19. sealed trait SyncDomainMigrationError extends Product with Serializable with CantonError
  20. trait SyncDomainPersistentStateLookup extends AnyRef

    Read-only interface to the SyncDomainPersistentStateManager

  21. trait SyncDomainPersistentStateManager extends AutoCloseable with SyncDomainPersistentStateLookup

    Manages domain state that needs to survive reconnects

    Manages domain state that needs to survive reconnects

    Factory for com.digitalasset.canton.participant.store.SyncDomainPersistentState. Tries to discover existing persistent states or create new ones and checks consistency of domain parameters and unique contract key domains

  22. abstract class SyncDomainPersistentStateManagerImpl[S <: SyncDomainPersistentState] extends SyncDomainPersistentStateManager with NamedLogging
  23. class SyncDomainPersistentStateManagerOld extends SyncDomainPersistentStateManagerImpl[SyncDomainPersistentState]
  24. trait SyncServiceError extends Serializable with Product with CantonError
  25. class TimelyRejectNotifier extends NamedLogging
  26. final case class TimestampedEvent(event: LedgerSyncEvent, localOffset: LocalOffset, requestSequencerCounter: Option[SequencerCounter], eventId: Option[EventId])(implicit traceContext: TraceContext) extends PrettyPrinting with Product with Serializable
  27. sealed trait TransactionRoutingError extends TransactionError with Product with Serializable
  28. trait TransactionRoutingErrorWithDomain extends TransactionRoutingError

Value Members

  1. object CantonAuthorityResolver
  2. object CantonSyncService
  3. object CommandDeduplicationError extends InjectionErrorGroup
  4. object CommandProgressTrackerConfig extends Serializable
  5. object ConnectedDomainsLookup
  6. object EnterpriseSyncDomainFactory extends Factory[SyncDomain]
  7. object LedgerSyncEvent extends Serializable
  8. object ParticipantEventPublisher
  9. object SyncDomain
  10. object SyncDomainMigrationError extends MigrationErrors with Serializable
  11. object SyncServiceError extends SyncServiceErrorGroup with Serializable
  12. object SyncServiceInjectionError extends InjectionErrorGroup
  13. object TimelyRejectNotifier
  14. object TimestampedEvent extends Serializable
  15. object TransactionRoutingError extends RoutingErrorGroup with Serializable

    All routing errors happen before in-flight submission checking and are therefore never definite answers.

  16. object UpstreamOffsetConvert

    Conversion utility to convert back and forth between GlobalOffsets and the offsets used by the ParticipantState API ReadService still based on a byte string.

    Conversion utility to convert back and forth between GlobalOffsets and the offsets used by the ParticipantState API ReadService still based on a byte string. Canton emits single-Long GlobalOffsets.

Ungrouped