Type Members

1.  final case class PartyReplicationInstruction(maxCounter: NonNegativeInt)(representativeProtocolVersion: RepresentativeProtocolVersion[PartyReplicationInstruction.type]) extends HasProtocolVersionedWrapper[PartyReplicationInstruction] with Product with Serializable
2.  final case class PartyReplicationSourceMessage(dataOrStatus: DataOrStatus)(representativeProtocolVersion: RepresentativeProtocolVersion[PartyReplicationSourceMessage.type]) extends HasProtocolVersionedWrapper[PartyReplicationSourceMessage] with Product with Serializable
3.  class PartyReplicationSourceParticipantProcessor extends SequencerChannelProtocolProcessor

   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

   • sends PartyReplicationSourceMessage.SourceParticipantIsReady when ready to send contracts,
   • only sends as many PartyReplicationSourceMessage.AcsChunks as requested by the target participant to honor flow control,
   • sends PartyReplicationSourceMessage.AcsChunks in strictly increasing and gap-free chunk id order,
   • sends PartyReplicationSourceMessage.EndOfACS iff the processor is closed by the next message,
   • and sends only deserializable payloads.
4.  class PartyReplicationTargetParticipantProcessor extends SequencerChannelProtocolProcessor

   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

   • only sends messages after receiving PartyReplicationSourceMessage.SourceParticipantIsReady,
   • requests contracts in a strictly increasing chunk id order,
   • and sends only deserializable payloads.
5.  trait PersistsContracts extends AnyRef

   Helper trait to name parameters