package sync
- Alphabetic
- Public
- Protected
Type Members
- 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.
- class DomainRouter extends FlagCloseable with NamedLogging
The domain router routes transaction submissions from upstream to the right domain.
The domain router routes transaction submissions from upstream to the right domain.
Submitted transactions are inspected for which domains are involved based on the location of the involved contracts.
- class EnterpriseCantonSyncServiceFactory extends Factory[CantonSyncService]
- case class ParticipantDidNotBecomeActive(msg: String) extends SyncDomainInitializationError with Product with Serializable
- 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.
- case class ParticipantTopologyHandshakeError(err: DomainRegistryError) extends SyncDomainInitializationError with Product with Serializable
- case class SequencedEventStoreError(err: store.SequencedEventStoreError) extends SyncDomainInitializationError with Product with Serializable
- class SyncDomain extends NamedLogging with StartAndCloseable[Either[SyncDomainInitializationError, Unit]] with TransferSubmissionHandle with HasDegradationState[CantonError]
A connected domain from the synchronization service.
- sealed trait SyncDomainInitializationError extends AnyRef
- class SyncDomainMigration extends NamedLogging with FlagCloseable
- sealed trait SyncDomainMigrationError extends Product with Serializable with CantonError
- trait SyncDomainPersistentStateLookup extends AnyRef
Read-only interface to the SyncDomainPersistentStateManager
- class SyncDomainPersistentStateManager extends SyncDomainPersistentStateLookup with NamedLogging with AutoCloseable
Manages domain state that needs to survive reconnects
- trait SyncServiceError extends Serializable with Product with CantonError
- case class TimestampedEvent(event: LedgerSyncEvent, localOffset: LocalOffset, requestSequencerCounter: Option[SequencerCounter], eventId: Option[EventId])(implicit traceContext: TraceContext) extends PrettyPrinting with Product with Serializable
- case class TimestampedEventAndCausalChange(tse: TimestampedEvent, causalityUpdate: Option[CausalityUpdate]) extends Product with Serializable
- sealed trait TransactionRoutingError extends TransactionError with Product with Serializable
Value Members
- object CantonSyncService
- object CommandDeduplicationError extends InjectionErrorGroup
- object EnterpriseSyncDomainFactory extends Factory[SyncDomain]
- object LedgerEvent
Ledger sync event related helper functions for upstream communication via the participant state read service.
- object ParticipantEventPublisher
- object SyncDomain
- object SyncDomainMigrationError extends MigrationErrors with Serializable
- object SyncServiceError extends SyncServiceErrorGroup with Serializable
- object SyncServiceInjectionError extends InjectionErrorGroup
- object TimestampedEvent extends Serializable
- object TimestampedEventAndCausalChange extends Serializable
- object TransactionRoutingError extends RoutingErrorGroup with Serializable
All routing errors happen before in-flight submission checking and are therefore never definite answers.
- 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.