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 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
- trait TransactionRoutingErrorWithDomain extends TransactionRoutingError
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.