class CommandDeduplicatorImpl extends CommandDeduplicator with NamedLogging

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CommandDeduplicatorImpl
  2. NamedLogging
  3. CommandDeduplicator
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new CommandDeduplicatorImpl(store: CommandDeduplicationStore, clock: Clock, publicationTimeLowerBound: => CantonTimestamp, loggerFactory: NamedLoggerFactory)(implicit ec: ExecutionContext)

Value Members

  1. def checkDuplication(changeIdHash: ChangeIdHash, deduplicationPeriod: DeduplicationPeriod)(implicit traceContext: TraceContext): EitherT[Future, DeduplicationFailed, DeduplicationOffset]

    Perform deduplication for the given com.digitalasset.canton.participant.protocol.submission.ChangeIdHash and com.daml.ledger.api.DeduplicationPeriod.

    Perform deduplication for the given com.digitalasset.canton.participant.protocol.submission.ChangeIdHash and com.daml.ledger.api.DeduplicationPeriod.

    changeIdHash

    The change ID hash of the submission to be deduplicated

    deduplicationPeriod

    The deduplication period specified with the submission

    returns

    The com.daml.ledger.api.DeduplicationPeriod.DeduplicationOffset to be included in the command completion's com.daml.ledger.participant.state.v2.CompletionInfo. Canton always returns a com.daml.ledger.api.DeduplicationPeriod.DeduplicationOffset because it cannot meet the the record time requirements for the other kinds of com.daml.ledger.api.DeduplicationPeriods.

    Definition Classes
    CommandDeduplicatorImpl → CommandDeduplicator
  2. def processPublications(publications: Seq[Publication])(implicit traceContext: TraceContext): Future[Unit]

    Register the publication of the events in the com.digitalasset.canton.participant.store.CommandDeduplicationStore

    Register the publication of the events in the com.digitalasset.canton.participant.store.CommandDeduplicationStore

    Definition Classes
    CommandDeduplicatorImpl → CommandDeduplicator