Packages

package sync

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

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

  2. class EnterpriseCantonSyncServiceFactory extends Factory[CantonSyncService]
  3. sealed trait LedgerSyncEvent extends Product with Serializable with PrettyPrinting

    This a copy of com.daml.ledger.participant.state.v2.Update.

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

  4. case class ParticipantDidNotBecomeActive(msg: String) extends SyncDomainInitializationError with Product with Serializable
  5. class ParticipantEventPublisher extends NamedLogging with FlagCloseableAsync

    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.

  6. case class ParticipantTopologyHandshakeError(err: DomainRegistryError) extends SyncDomainInitializationError with Product with Serializable
  7. case class SequencedEventStoreError(err: store.SequencedEventStoreError) extends SyncDomainInitializationError with Product with Serializable
  8. class SyncDomain extends NamedLogging with StartAndCloseable[Either[SyncDomainInitializationError, Unit]] with TransferSubmissionHandle with ComponentHealth

    A connected domain from the synchronization service.

  9. sealed trait SyncDomainInitializationError extends AnyRef
  10. class SyncDomainMigration extends NamedLogging with FlagCloseable
  11. sealed trait SyncDomainMigrationError extends Product with Serializable with CantonError
  12. trait SyncDomainPersistentStateLookup extends AnyRef

    Read-only interface to the SyncDomainPersistentStateManager

  13. class SyncDomainPersistentStateManager extends SyncDomainPersistentStateLookup with NamedLogging with AutoCloseable

    Manages domain state that needs to survive reconnects

  14. trait SyncServiceError extends Serializable with Product with CantonError
  15. final case class TimestampedEvent(event: LedgerSyncEvent, localOffset: LocalOffset, requestSequencerCounter: Option[SequencerCounter], eventId: Option[EventId])(implicit traceContext: TraceContext) extends PrettyPrinting with Product with Serializable
  16. case class TimestampedEventAndCausalChange(tse: TimestampedEvent, causalityUpdate: Option[CausalityUpdate]) extends Product with Serializable
  17. sealed trait TransactionRoutingError extends TransactionError with Product with Serializable
  18. trait TransactionRoutingErrorWithDomain extends TransactionRoutingError

Value Members

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

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

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