class GlobalCausalOrderer extends NamedLogging with AutoCloseable

Linear Supertypes
AutoCloseable, NamedLogging, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. GlobalCausalOrderer
  2. AutoCloseable
  3. NamedLogging
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new GlobalCausalOrderer(participantId: ParticipantId, connectedDomains: (DomainId) => Boolean, timeouts: ProcessingTimeout, domainCausalityStore: MultiDomainCausalityStore, loggerFactory: NamedLoggerFactory)(implicit ec: ExecutionContext)

Type Members

  1. case class PendingEvent(clock: EventClock)(stillWaiting: Map[DomainId, CantonTimestamp], promise: Promise[Unit]) extends Product with Serializable

Value Members

  1. def awaitTransferOutRegistered(id: TransferId, parties: Set[LfPartyId])(implicit tc: TraceContext): Future[Map[LfPartyId, VectorClock]]
  2. def close(): Unit
    Definition Classes
    GlobalCausalOrderer → AutoCloseable
  3. val domainCausalityStore: MultiDomainCausalityStore
  4. def flush(): Future[Unit]

    returns

    A future that completes when all previously spawned futures have finished

    Annotations
    @VisibleForTesting()
  5. val loggerFactory: NamedLoggerFactory
    Definition Classes
    GlobalCausalOrderer → NamedLogging
  6. val participantId: ParticipantId
  7. def registerCausalityMessages(causalityMessages: List[CausalityMessage])(implicit tc: TraceContext): Future[Unit]
  8. def registerPublished(clock: EventClock)(implicit tc: TraceContext): Unit
  9. def waitPublishable(clock: EventClock)(implicit tc: TraceContext): Future[Unit]