final class CachingSynchronizerTopologyClient extends SynchronizerTopologyClientWithInit with NamedLogging

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CachingSynchronizerTopologyClient
  2. SynchronizerTopologyClientWithInit
  3. NamedLogging
  4. HasFutureSupervision
  5. TopologyTransactionProcessingSubscriber
  6. SynchronizerTopologyClient
  7. AutoCloseable
  8. TopologyClientApi
  9. AnyRef
  10. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new CachingSynchronizerTopologyClient(delegate: StoreBasedSynchronizerTopologyClient, cachingConfigs: CachingConfigs, batchingConfig: BatchingConfig, timeouts: ProcessingTimeout, futureSupervisor: FutureSupervisor, loggerFactory: NamedLoggerFactory)(implicit executionContext: ExecutionContext)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def approximateTimestamp: CantonTimestamp

    The 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)

    Definition Classes
    CachingSynchronizerTopologyClientTopologyClientApi
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. 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
    CachingSynchronizerTopologyClientSynchronizerTopologyClient
  7. def awaitMaxTimestamp(sequencedTime: SequencedTime)(implicit traceContext: TraceContext): FutureUnlessShutdown[Option[(SequencedTime, EffectiveTime)]]

    Finds the transaction with maximum effective time that has been sequenced before or at sequencedTime and yields the sequenced / effective time of that transaction.

    Finds the transaction with maximum effective time that has been sequenced before or at sequencedTime and yields the sequenced / effective time of that transaction. Potentially waits for sequencedTime to be observed.

    Definition Classes
    CachingSynchronizerTopologyClientTopologyClientApi
  8. def awaitSequencedTimestamp(timestampInclusive: SequencedTime)(implicit traceContext: TraceContext): Option[FutureUnlessShutdown[Unit]]

    Returns an optional future which will complete when the sequenced timestamp has been observed

    Returns an optional future which will complete when the sequenced timestamp has been observed

    If the timestamp is already observed, returns None.

    Definition Classes
    CachingSynchronizerTopologyClientTopologyClientApi
  9. final def awaitSnapshot(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[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 reassignment 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
    SynchronizerTopologyClientWithInitTopologyClientApi
  10. def awaitSnapshotUSSupervised(description: => String, warnAfter: Duration = 30.seconds)(timestamp: CantonTimestamp)(implicit loggingContext: ErrorLoggingContext): FutureUnlessShutdown[TopologySnapshot]

    Supervised version of awaitSnapshot

    Supervised version of awaitSnapshot

    Definition Classes
    TopologyClientApi
  11. def awaitTimestamp(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): Option[FutureUnlessShutdown[Unit]]

    Returns an optional future which will complete when the effective timestamp has been observed

    Returns an optional future which will complete when the effective timestamp has been observed

    If the timestamp is already observed, returns None.

    Definition Classes
    CachingSynchronizerTopologyClientTopologyClientApi
  12. def awaitUS(condition: (TopologySnapshot) => FutureUnlessShutdown[Boolean], timeout: Duration)(implicit traceContext: TraceContext): FutureUnlessShutdown[Boolean]
  13. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  14. def close(): Unit
    Definition Classes
    CachingSynchronizerTopologyClient → AutoCloseable
  15. def currentSnapshotApproximation(implicit traceContext: TraceContext): TopologySnapshotLoader

    Overloaded recent snapshot returning derived type

    Overloaded recent snapshot returning derived type

    Definition Classes
    CachingSynchronizerTopologyClientSynchronizerTopologyClientWithInitTopologyClientApi
  16. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  17. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  18. implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  19. implicit val executionContext: ExecutionContext
  20. def executionOrder: Int

    The order in which the subscriber should be executed among all the subscriptions.

    The order in which the subscriber should be executed among all the subscriptions. Lower values are executed first.

    Definition Classes
    TopologyTransactionProcessingSubscriber
  21. val futureSupervisor: FutureSupervisor
    Attributes
    protected
    Definition Classes
    CachingSynchronizerTopologyClientHasFutureSupervision
  22. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  23. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  24. def headSnapshot(implicit traceContext: TraceContext): TopologySnapshotLoader

    Possibly 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 prepare regular transactions using this snapshot, but use the currentSnapshotApproximation instead. A head snapshot can be useful, however, for producing new topology changes, e.g., for picking the correct serial.

    Definition Classes
    SynchronizerTopologyClientWithInitTopologyClientApi
  25. def hypotheticalSnapshot(timestamp: CantonTimestamp, desiredTimestamp: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[TopologySnapshotLoader]

    Returns the topology information at the timestamp point in time, but using desiredTimestamp as the actual "forwarded" timestamp.

    Returns the topology information at the timestamp point in time, but using desiredTimestamp as the actual "forwarded" timestamp.

    The snapshot returned by this method should ONLY BE USED when computing the timestamp for signature validation (i.e. com.digitalasset.canton.crypto.SyncCryptoClient.getSnapshotForTimestamp).

    Definition Classes
    CachingSynchronizerTopologyClientTopologyClientApi
  26. def initialize()(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]
  27. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  28. def logger: TracedLogger
    Attributes
    protected
    Definition Classes
    NamedLogging
  29. val loggerFactory: NamedLoggerFactory
  30. implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  31. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  32. def noTracingLogger: Logger
    Attributes
    protected
    Definition Classes
    NamedLogging
  33. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  34. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  35. def numPendingChanges: Int

    current number of changes waiting to become effective

    current number of changes waiting to become effective

    Definition Classes
    CachingSynchronizerTopologyClientSynchronizerTopologyClientWithInit
  36. def observed(sequencedTimestamp: SequencedTime, effectiveTimestamp: EffectiveTime, sequencerCounter: SequencerCounter, transactions: Seq[GenericSignedTopologyTransaction])(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]

    This must be called whenever a topology transaction is committed.

    This must be called whenever a topology transaction is committed. It may be called at additional timestamps with transactions being empty. Calls must have strictly increasing sequencedTimestamp and effectiveTimestamp.

    During crash recovery previous calls of this method may be replayed. Therefore, implementations must be idempotent.

    The effective timestamp may have not yet been reached on the synchronizer.

    Definition Classes
    CachingSynchronizerTopologyClientTopologyTransactionProcessingSubscriber
  37. def protocolVersion: ProtocolVersion
    Definition Classes
    TopologyClientApi
  38. def psid: PhysicalSynchronizerId

    The synchronizer this client applies to

    The synchronizer this client applies to

    Definition Classes
    CachingSynchronizerTopologyClientTopologyClientApi
  39. def setSynchronizerTimeTracker(tracker: SynchronizerTimeTracker): Unit
  40. def snapshot(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[TopologySnapshotLoader]

    Returns the topology information at a certain point in time

    Returns the topology information at a certain point in time

    Use this method if you are sure to be synchronized with the topology state updates. The method will block & wait for an update, but emit a warning if it is not available

    The snapshot returned by this method should be used for validating transaction and reassignment 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
    CachingSynchronizerTopologyClientTopologyClientApi
  41. def snapshotAvailable(timestamp: CantonTimestamp): Boolean

    Returns 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
    CachingSynchronizerTopologyClientTopologyClientApi
  42. def staticSynchronizerParameters: StaticSynchronizerParameters
  43. def supervised[T](description: => String, warnAfter: Duration = 10.seconds)(fut: Future[T])(implicit loggingContext: ErrorLoggingContext): Future[T]
    Attributes
    protected
    Definition Classes
    HasFutureSupervision
  44. def supervisedUS[T](description: => String, warnAfter: Duration = 10.seconds)(fut: FutureUnlessShutdown[T])(implicit loggingContext: ErrorLoggingContext): FutureUnlessShutdown[T]
    Definition Classes
    HasFutureSupervision
  45. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  46. def synchronizerId: SynchronizerId
  47. val synchronizerTimeTracker: SingleUseCell[SynchronizerTimeTracker]
    Attributes
    protected
    Definition Classes
    SynchronizerTopologyClientWithInit
  48. val timeouts: ProcessingTimeout
  49. def toString(): String
    Definition Classes
    AnyRef → Any
  50. def topologyKnownUntilTimestamp: CantonTimestamp

    The 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 synchronizer parameters.

    This is the highest timestamp for which we can serve snapshots

    Definition Classes
    CachingSynchronizerTopologyClientTopologyClientApi
  51. def trySnapshot(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): TopologySnapshotLoader

    Returns 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 reassignment 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.

    Attributes
    protected[topology]
    Definition Classes
    CachingSynchronizerTopologyClientSynchronizerTopologyClient
  52. def updateHead(sequencedTimestamp: SequencedTime, effectiveTimestamp: EffectiveTime, approximateTimestamp: ApproximateTime)(implicit traceContext: TraceContext): Unit

    Move the highest known (effective / approximate) timestamp ahead in the future.

    Move the highest known (effective / approximate) timestamp ahead in the future.

    May only be called if:

    1. All committed topology transactions with effective time up to effectiveTimestamp have been persisted in the topology store.
    2. All committed topology transactions with sequenced time up to sequencedTimestamp have been persisted in the topology store.
    3. sequencedTimestamp <= effectiveTimestamp
    4. approximateTimestamp <= effectiveTimestamp
    5. A sequenced event with timestamp at least approximateTimestamp has been received from the sequencer.

    The effective timestamp may have not yet been reached on the synchronizer.

    Definition Classes
    CachingSynchronizerTopologyClientTopologyTransactionProcessingSubscriber
  53. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  54. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  55. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  56. def waitForTimestampWithLogging(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]
    Attributes
    protected
    Definition Classes
    SynchronizerTopologyClientWithInit

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from NamedLogging

Inherited from HasFutureSupervision

Inherited from AutoCloseable

Inherited from AnyRef

Inherited from Any

Ungrouped