Packages

package sync

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. class CantonAuthorityResolver extends AuthorityResolver with NamedLogging
  2. class CantonSyncService extends WriteService with WriteParticipantPruningService with ReadService with FlagCloseable with Spanning with NamedLogging

    The Canton-based synchronization service.

    The Canton-based synchronization service.

    A single Canton sync service can connect to multiple domains.

  3. trait ConnectedDomainsLookup extends AnyRef

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

  4. class EnterpriseCantonSyncServiceFactory extends Factory[CantonSyncService]
  5. class EnterpriseParticipantPersistentStateFactory extends ParticipantNodePersistentStateFactory
  6. 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.

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

  9. final case class ParticipantTopologyHandshakeError(err: DomainRegistryError) extends SyncDomainInitializationError with Product with Serializable
  10. final case class SequencedEventStoreError(err: store.SequencedEventStoreError) extends SyncDomainInitializationError with Product with Serializable
  11. class SyncDomain extends NamedLogging with StartAndCloseable[Either[SyncDomainInitializationError, Unit]] with TransferSubmissionHandle with HealthComponent

    A connected domain from the synchronization service.

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

    Read-only interface to the SyncDomainPersistentStateManager

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

  17. abstract class SyncDomainPersistentStateManagerImpl[S <: SyncDomainPersistentState] extends SyncDomainPersistentStateManager with NamedLogging
  18. class SyncDomainPersistentStateManagerOld extends SyncDomainPersistentStateManagerImpl[SyncDomainPersistentStateOld]
  19. class SyncDomainPersistentStateManagerX extends SyncDomainPersistentStateManagerImpl[SyncDomainPersistentStateX]
  20. trait SyncServiceError extends Serializable with Product with CantonError
  21. final case class TimestampedEvent(event: LedgerSyncEvent, localOffset: LocalOffset, requestSequencerCounter: Option[SequencerCounter], eventId: Option[EventId])(implicit traceContext: TraceContext) extends PrettyPrinting with Product with Serializable
  22. sealed trait TransactionRoutingError extends TransactionError with Product with Serializable
  23. 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 TimestampedEvent extends Serializable
  13. object TransactionRoutingError extends RoutingErrorGroup with Serializable

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

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