c

com.digitalasset.canton.participant.store.memory

InMemorySubmissionTrackerStore

class InMemorySubmissionTrackerStore extends SubmissionTrackerStore with InMemoryPrunableByTime with NamedLogging

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. InMemorySubmissionTrackerStore
  2. NamedLogging
  3. InMemoryPrunableByTime
  4. SubmissionTrackerStore
  5. AutoCloseable
  6. PrunableByTime
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new InMemorySubmissionTrackerStore(loggerFactory: NamedLoggerFactory)(implicit ec: 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 advancePruningTimestamp(phase: PruningPhase, timestamp: CantonTimestamp)(implicit traceContext: TraceContext): Future[Unit]
    Attributes
    protected[canton]
    Definition Classes
    InMemoryPrunableByTimePrunableByTime
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clear(): Unit
    Annotations
    @VisibleForTesting()
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  8. def close(): Unit
    Definition Classes
    InMemorySubmissionTrackerStore → AutoCloseable
  9. def doPrune(beforeAndIncluding: CantonTimestamp, lastPruning: Option[CantonTimestamp])(implicit traceContext: TraceContext): Future[Unit]
    Attributes
    protected[canton]
    Definition Classes
    InMemorySubmissionTrackerStorePrunableByTime
  10. implicit val ec: ExecutionContext
  11. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  13. implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  14. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  15. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  16. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  17. def logger: TracedLogger
    Attributes
    protected
    Definition Classes
    NamedLogging
  18. val loggerFactory: NamedLoggerFactory
    Attributes
    protected
    Definition Classes
    InMemorySubmissionTrackerStoreNamedLogging
  19. implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  20. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  21. def noTracingLogger: Logger
    Attributes
    protected
    Definition Classes
    NamedLogging
  22. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  23. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  24. final def prune(limit: CantonTimestamp)(implicit traceContext: TraceContext): Future[Unit]

    Prune all unnecessary data relating to events before the given timestamp.

    Prune all unnecessary data relating to events before the given timestamp.

    The meaning of "unnecessary", and whether the limit is inclusive or exclusive both depend on the particular store. The store must implement the actual pruning logic in the doPrune method.

    Definition Classes
    PrunableByTime
  25. def pruningStatus(implicit traceContext: TraceContext): Future[Option[PruningStatus]]

    Returns the latest timestamp at which pruning was started or completed.

    Returns the latest timestamp at which pruning was started or completed. For com.digitalasset.canton.pruning.PruningPhase.Started, it is guaranteed that no pruning has been run on the store after the returned timestamp. For com.digitalasset.canton.pruning.PruningPhase.Completed, it is guaranteed that the store is pruned at least up to the returned timestamp (inclusive). That is, another pruning with the returned timestamp (or earlier) has no effect on the store. Returns scala.None$ if no pruning has ever been started on the store.

    Definition Classes
    InMemoryPrunableByTimePrunableByTime
  26. val pruningStatusF: AtomicReference[Option[PruningStatus]]
    Attributes
    protected[this]
    Definition Classes
    InMemoryPrunableByTime
  27. def registerFreshRequest(rootHash: RootHash, requestId: RequestId, maxSequencingTime: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[Boolean]

    Register a fresh request in the store.

    Register a fresh request in the store.

    returns

    a Future that resolves to true if the request is indeed fresh and was added to the store, and false if it is a replay, i.e. another request already existed in the store for the given transactionId.

    Definition Classes
    InMemorySubmissionTrackerStoreSubmissionTrackerStore
  28. def size()(implicit traceContext: TraceContext): FutureUnlessShutdown[Int]

    Return the number of entries currently in the store.

    Return the number of entries currently in the store.

    Definition Classes
    InMemorySubmissionTrackerStoreSubmissionTrackerStore
  29. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  30. def toString(): String
    Definition Classes
    AnyRef → Any
  31. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  32. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  33. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

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

Inherited from NamedLogging

Inherited from InMemoryPrunableByTime

Inherited from SubmissionTrackerStore

Inherited from AutoCloseable

Inherited from PrunableByTime

Inherited from AnyRef

Inherited from Any

Ungrouped