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. trait ConnectedDomainsLookup extends AnyRef

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

  5. class EnterpriseCantonSyncServiceFactory extends Factory[CantonSyncService]
  6. class EnterpriseParticipantPersistentStateFactory extends ParticipantNodePersistentStateFactory
  7. final class EventTranslationStrategy extends AnyRef
  8. sealed trait LedgerSyncEvent extends Product with Serializable with PrettyPrinting

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

  9. final case class ParticipantDidNotBecomeActive(msg: String) extends SyncDomainInitializationError with Product with Serializable
  10. 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.

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

    A connected domain from the synchronization service.

  14. sealed trait SyncDomainInitializationError extends AnyRef
  15. class SyncDomainMigration extends NamedLogging with FlagCloseable
  16. sealed trait SyncDomainMigrationError extends Product with Serializable with CantonError
  17. trait SyncDomainPersistentStateLookup extends AnyRef

    Read-only interface to the SyncDomainPersistentStateManager

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

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

Value Members

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

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

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