Type Members

1.  trait PartyReplicationProcessor extends SequencerChannelProtocolProcessor
2.  sealed trait PartyReplicationProcessorStore extends AnyRef
3.  final case class PartyReplicationSourceParticipantMessage(dataOrStatus: DataOrStatus)(representativeProtocolVersion: RepresentativeProtocolVersion[PartyReplicationSourceParticipantMessage.type]) extends HasProtocolVersionedWrapper[PartyReplicationSourceParticipantMessage] with Product with Serializable
4.  final class PartyReplicationSourceParticipantProcessor extends PartyReplicationProcessor

   The source participant processor exposes a party's active contracts on a specified synchronizer and timestamp to a target participant as part of Online Party Replication.

   The source participant processor exposes a party's active contracts on a specified synchronizer and timestamp to a target participant as part of Online Party Replication.

   The interaction happens via the com.digitalasset.canton.sequencing.client.channel.SequencerChannelProtocolProcessor API and the source participant processor enforces the protocol guarantees made by a PartyReplicationTargetParticipantProcessor. The following guarantees made by the source participant processor are verifiable by the party replication protocol: The source participant

   • only sends messages after receiving PartyReplicationTargetParticipantMessage.Initialize,
   • only sends as many contracts as requested by the target participant to honor flow control,
   • sends PartyReplicationSourceParticipantMessage.EndOfACS as the last message,
   • and sends only deserializable payloads.
5.  final case class PartyReplicationTargetParticipantMessage(instruction: Instruction)(representativeProtocolVersion: RepresentativeProtocolVersion[PartyReplicationTargetParticipantMessage.type]) extends HasProtocolVersionedWrapper[PartyReplicationTargetParticipantMessage] with Product with Serializable
6.  class PartyReplicationTargetParticipantProcessor extends PartyReplicationProcessor

   The target participant processor ingests a party's active contracts on a specific synchronizer and timestamp from a source participant as part of Online Party Replication.

   The target participant processor ingests a party's active contracts on a specific synchronizer and timestamp from a source participant as part of Online Party Replication.

   The interaction happens via the com.digitalasset.canton.sequencing.client.channel.SequencerChannelProtocolProcessor API and the target participant processor enforces the protocol guarantees made by a PartyReplicationSourceParticipantProcessor. The following guarantees made by the target participant processor are verifiable at the party replication protocol: The target participant

   • sends a PartyReplicationTargetParticipantMessage.Initialize upon (re-)connecting,
   • requests contracts in a strictly increasing contract ordinal order,
   • and sends only deserializable payloads.
7.  final class SourceParticipantStore extends PartyReplicationProcessorStore with FlagCloseable with NamedLogging
8.  final class TargetParticipantStore extends PartyReplicationProcessorStore