trait DomainTopologyClientWithInitOld extends DomainTopologyClientWithInit with TopologyTransactionProcessingSubscriber
- Alphabetic
- By Inheritance
- DomainTopologyClientWithInitOld
- TopologyTransactionProcessingSubscriber
- DomainTopologyClientWithInit
- NamedLogging
- HasFutureSupervision
- TopologyTransactionProcessingSubscriberCommon
- DomainTopologyClient
- AutoCloseable
- TopologyClientApi
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
-   abstract  def approximateTimestamp: CantonTimestampThe approximate timestamp The approximate timestamp This is either the last observed sequencer timestamp OR the effective timestamp after we observed the time difference of (effective - sequencer = epsilon) to elapse - Definition Classes
- TopologyClientApi
 
-   abstract  def await(condition: (TopologySnapshot) => Future[Boolean], timeout: Duration)(implicit traceContext: TraceContext): FutureUnlessShutdown[Boolean]Wait for a condition to become true according to the current snapshot approximation Wait for a condition to become true according to the current snapshot approximation - returns
- true if the condition became true, false if it timed out 
 - Definition Classes
- DomainTopologyClient
 
-   abstract  def awaitTimestamp(timestamp: CantonTimestamp, waitForEffectiveTime: Boolean)(implicit traceContext: TraceContext): Option[Future[Unit]]Returns an optional future which will complete when the timestamp has been observed Returns an optional future which will complete when the timestamp has been observed If the timestamp is already observed, we return None. Note that this function allows to wait for effective time (true) and sequenced time (false). If we wait for effective time, we wait until the topology snapshot for that given point in time is known. As we future date topology transactions (to avoid bottlenecks), this might be before we actually observed a sequencing timestamp. - Definition Classes
- TopologyClientApi
 
-   abstract  def awaitTimestampUS(timestamp: CantonTimestamp, waitForEffectiveTime: Boolean)(implicit traceContext: TraceContext): Option[FutureUnlessShutdown[Unit]]- Definition Classes
- TopologyClientApi
 
-   abstract  def close(): Unit- Definition Classes
- AutoCloseable
- Annotations
- @throws(classOf[java.lang.Exception])
 
-   abstract  def domainId: DomainIdThe domain this client applies to The domain this client applies to - Definition Classes
- TopologyClientApi
 
-   implicit abstract  def executionContext: ExecutionContext- Attributes
- protected
- Definition Classes
- DomainTopologyClientWithInit → HasFutureSupervision
 
-   abstract  def futureSupervisor: FutureSupervisor- Attributes
- protected
- Definition Classes
- HasFutureSupervision
 
-   abstract  def loggerFactory: NamedLoggerFactory- Attributes
- protected
- Definition Classes
- NamedLogging
 
-   abstract  def numPendingChanges: Intcurrent number of changes waiting to become effective current number of changes waiting to become effective - Definition Classes
- DomainTopologyClientWithInit
 
-   abstract  def observed(sequencedTimestamp: SequencedTime, effectiveTimestamp: EffectiveTime, sequencerCounter: SequencerCounter, transactions: Seq[SignedTopologyTransaction[TopologyChangeOp]])(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]- Definition Classes
- TopologyTransactionProcessingSubscriber
 
-   abstract  def snapshotAvailable(timestamp: CantonTimestamp): BooleanReturns true if the topology information at the passed timestamp is already known Returns true if the topology information at the passed timestamp is already known - Definition Classes
- TopologyClientApi
 
-   abstract  def topologyKnownUntilTimestamp: CantonTimestampThe most recently observed effective timestamp The most recently observed effective timestamp The effective timestamp is sequencer_time + epsilon(sequencer_time), where epsilon is given by the topology change delay time, defined using the domain parameters. This is the highest timestamp for which we can serve snapshots - Definition Classes
- TopologyClientApi
 
-   abstract  def trySnapshot(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): TopologySnapshotLoaderReturns the topology information at a certain point in time Returns the topology information at a certain point in time Fails with an exception if the state is not yet known. The snapshot returned by this method should be used for validating transaction and transfer requests (Phase 2 - 7). Use the request timestamp as parameter for this method. Do not use a response or result timestamp, because all validation steps must use the same topology snapshot. - Definition Classes
- DomainTopologyClientWithInit → TopologyClientApi
 
Concrete Value Members
-   final  def !=(arg0: Any): Boolean- Definition Classes
- AnyRef → Any
 
-   final  def ##: Int- Definition Classes
- AnyRef → Any
 
-   final  def ==(arg0: Any): Boolean- Definition Classes
- AnyRef → Any
 
-   final  def asInstanceOf[T0]: T0- Definition Classes
- Any
 
-    def awaitSnapshot(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): Future[TopologySnapshot]Waits until a snapshot is available Waits until a snapshot is available The snapshot returned by this method should be used for validating transaction and transfer requests (Phase 2 - 7). Use the request timestamp as parameter for this method. Do not use a response or result timestamp, because all validation steps must use the same topology snapshot. - Definition Classes
- DomainTopologyClientWithInit → TopologyClientApi
 
-    def awaitSnapshotSupervised(description: => String, warnAfter: Duration = 30.seconds)(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): Future[TopologySnapshot]Supervised version of awaitSnapshot Supervised version of awaitSnapshot - Definition Classes
- TopologyClientApi
 
-    def awaitSnapshotUS(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[TopologySnapshot]Shutdown safe version of await snapshot Shutdown safe version of await snapshot - Definition Classes
- DomainTopologyClientWithInit → TopologyClientApi
 
-    def awaitSnapshotUSSupervised(description: => String, warnAfter: Duration = 30.seconds)(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[TopologySnapshot]Supervised version of awaitSnapshotUS Supervised version of awaitSnapshotUS - Definition Classes
- TopologyClientApi
 
-    def clone(): AnyRef- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
 
-    def currentSnapshotApproximation(implicit traceContext: TraceContext): TopologySnapshotLoaderOverloaded recent snapshot returning derived type Overloaded recent snapshot returning derived type - Definition Classes
- DomainTopologyClientWithInit → TopologyClientApi
 
-   final  def eq(arg0: AnyRef): Boolean- Definition Classes
- AnyRef
 
-    def equals(arg0: AnyRef): Boolean- Definition Classes
- AnyRef → Any
 
-   implicit  def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext- Attributes
- protected
- Definition Classes
- NamedLogging
 
-   final  def getClass(): Class[_ <: AnyRef]- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
 
-    def hashCode(): Int- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
 
-    def headSnapshot(implicit traceContext: TraceContext): TopologySnapshotPossibly future dated head snapshot Possibly future dated head snapshot As we future date topology transactions, the head snapshot is our latest knowledge of the topology state, but as it can be still future dated, we need to be careful when actually using it: the state might not yet be active, as the topology transactions are future dated. Therefore, do not act towards the sequencer using this snapshot, but use the currentSnapshotApproximation instead. - Definition Classes
- TopologyClientApi
 
-   final  def isInstanceOf[T0]: Boolean- Definition Classes
- Any
 
-    def logger: TracedLogger- Attributes
- protected
- Definition Classes
- NamedLogging
 
-   implicit  def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext- Attributes
- protected
- Definition Classes
- NamedLogging
 
-   final  def ne(arg0: AnyRef): Boolean- Definition Classes
- AnyRef
 
-    def noTracingLogger: Logger- Attributes
- protected
- Definition Classes
- NamedLogging
 
-   final  def notify(): Unit- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
 
-   final  def notifyAll(): Unit- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
 
-    def snapshot(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): Future[TopologySnapshotLoader]Overloaded snapshot returning derived type Overloaded snapshot returning derived type - Definition Classes
- DomainTopologyClientWithInit → TopologyClientApi
 
-    def snapshotUS(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[TopologySnapshotLoader]Overloaded snapshot returning derived type Overloaded snapshot returning derived type - Definition Classes
- DomainTopologyClientWithInit → TopologyClientApi
 
-    def supervised[T](description: => String, warnAfter: Duration = 10.seconds)(fut: Future[T])(implicit traceContext: TraceContext): Future[T]- Attributes
- protected
- Definition Classes
- HasFutureSupervision
 
-    def supervisedUS[T](description: => String, warnAfter: Duration = 10.seconds)(fut: FutureUnlessShutdown[T])(implicit traceContext: TraceContext): FutureUnlessShutdown[T]- Definition Classes
- HasFutureSupervision
 
-   final  def synchronized[T0](arg0: => T0): T0- Definition Classes
- AnyRef
 
-    def toString(): String- Definition Classes
- AnyRef → Any
 
-    def updateHead(effectiveTimestamp: EffectiveTime, approximateTimestamp: ApproximateTime, potentialTopologyChange: Boolean)(implicit traceContext: TraceContext): UnitMove the most known timestamp ahead in future based of newly discovered information Move the most known timestamp ahead in future based of newly discovered information We don't know the most recent timestamp directly. However, we can guess it from two sources: What was the timestamp of the latest topology transaction added? And what was the last processing timestamp. We need to know both such that we can always deliver the latest valid set of topology information, and don't use old snapshots. Therefore, we expose the updateHead function on the public interface for initialisation purposes. - effectiveTimestamp
- sequencer timestamp + epsilon(sequencer timestamp) 
- approximateTimestamp
- our current best guess of what the "best" timestamp is to get a valid current topology snapshot 
- potentialTopologyChange
- if true, the time advancement is related to a topology change that might have occurred or become effective 
 - Definition Classes
- TopologyTransactionProcessingSubscriberCommon
 
-   final  def wait(arg0: Long, arg1: Int): Unit- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
 
-   final  def wait(arg0: Long): Unit- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
 
-   final  def wait(): Unit- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])