Type Members

1.  final case class DeduplicationStoreConfig(pruneAtMostEvery: PositiveFiniteDuration = PositiveFiniteDuration.ofSeconds(10), persistBatching: BatchAggregatorConfig = BatchAggregatorConfig()) extends UniformCantonConfigValidation with Product with Serializable

   Configuration for deduplication store

   Configuration for deduplication store

   pruneAtMostEvery

   An interval to throttle pruning operations to at most once per this duration

   persistBatching

   Configuration for batching of persist operation in the deduplication store

2.  class DefaultMediatorEventDeduplicator extends MediatorEventDeduplicator with NamedLogging
3.  final case class FinalizedResponse(requestId: RequestId, request: MediatorConfirmationRequest, finalizationTime: CantonTimestamp, verdict: Verdict)(requestTraceContext: TraceContext) extends ResponseAggregator with Product with Serializable
4.  final case class MediatorConfig(pruning: MediatorPruningConfig = MediatorPruningConfig(), deduplicationStore: DeduplicationStoreConfig = DeduplicationStoreConfig()) extends UniformCantonConfigValidation with Product with Serializable

   Configuration for the mediator.

   Configuration for the mediator.

   pruning

   mediator pruning configuration

5.  class MediatorNode extends CantonNode with NamedLogging with HasUptime
6.  class MediatorNodeBootstrap extends CantonNodeBootstrapImpl[MediatorNode, MediatorNodeConfig, MediatorNodeParameters, MediatorMetrics]
7.  trait MediatorNodeBootstrapFactory extends AnyRef
8.  final case class MediatorNodeConfig(adminApi: AdminServerConfig = AdminServerConfig(), storage: StorageConfig = StorageConfig.Memory(), crypto: CryptoConfig = CryptoConfig(), replication: Option[ReplicationConfig] = None, init: InitConfig = InitConfig(), timeTracker: SynchronizerTimeTrackerConfig = SynchronizerTimeTrackerConfig(), sequencerClient: SequencerClientConfig = SequencerClientConfig(), caching: CachingConfigs = CachingConfigs(), parameters: MediatorNodeParameterConfig = MediatorNodeParameterConfig(), mediator: MediatorConfig = MediatorConfig(), monitoring: NodeMonitoringConfig = NodeMonitoringConfig(), topology: TopologyConfig = TopologyConfig()) extends LocalNodeConfig with ConfigDefaults[Option[DefaultPorts], MediatorNodeConfig] with UniformCantonConfigValidation with Product with Serializable

   Mediator Node configuration that defaults to auto-init

9.  final case class MediatorNodeParameterConfig(alphaVersionSupport: Boolean = false, betaVersionSupport: Boolean = false, dontWarnOnDeprecatedPV: Boolean = false, batching: BatchingConfig = BatchingConfig(), caching: CachingConfigs = CachingConfigs(), watchdog: Option[WatchdogConfig] = None) extends ProtocolConfig with LocalNodeParametersConfig with UniformCantonConfigValidation with Product with Serializable

   Various parameters for non-standard mediator settings

   Various parameters for non-standard mediator settings

   dontWarnOnDeprecatedPV

   if true, then this mediator will not emit a warning when connecting to a sequencer using a deprecated protocol version.

10.  final case class MediatorNodeParameters(general: General, protocol: Protocol) extends CantonNodeParameters with HasGeneralCantonNodeParameters with HasProtocolCantonNodeParameters with Product with Serializable
11.  final case class MediatorPruningConfig(maxPruningBatchSize: PositiveInt = PositiveInt.tryCreate(50000), pruningMetricUpdateInterval: Option[PositiveDurationSeconds] = config.PositiveDurationSeconds.ofHours(1L).some) extends UniformCantonConfigValidation with Product with Serializable

    Configuration for mediator pruning

    Configuration for mediator pruning

    maxPruningBatchSize

    Maximum number of events to prune from a mediator at a time, used to break up batches internally

    pruningMetricUpdateInterval

    How frequently to update the max-event-age pruning progress metric in the background. A setting of None disables background metric updating.

12.  class MediatorPruningScheduler extends JobScheduler with HasCloseContext with PruningScheduler with HasPruningSchedulerStore with UpdatePruningMetric
13.  class MediatorReplicaManager extends ReplicaManager with NamedLogging with FlagCloseableAsync

    Manages replicas of a single Mediator instance.

    Manages replicas of a single Mediator instance. Passive instances are currently entirely passive and have no components running at runtime. When becoming active a MediatorRuntime is started and connected to the admin services. When becoming passive the running MediatorRuntime is shutdown and the admin services are disconnected.

    If the admin services are called while passive every method will return an unavailable response.

14.  class MediatorReplicaManagerException extends RuntimeException

    An unexpected error occurred while transitioning between replica states

15.  final class MediatorRuntime extends FlagCloseable with NamedLogging

    Mediator component and its supporting services

16.  sealed trait MediatorVerdict extends Product with Serializable with PrettyPrinting
17.  final case class RemoteMediatorConfig(adminApi: FullClientConfig, token: Option[String] = None) extends NodeConfig with UniformCantonConfigValidation with Product with Serializable
18.  final case class ResponseAggregation[VKEY](requestId: RequestId, request: MediatorConfirmationRequest, responseTimeout: CantonTimestamp, decisionTime: CantonTimestamp, version: CantonTimestamp, state: Either[MediatorVerdict, Map[VKEY, ViewState]])(requestTraceContext: TraceContext, participantResponseDeadlineTick: Option[TickRequest])(implicit viewKeyOps: ViewKey[VKEY]) extends ResponseAggregator with PrettyPrinting with Product with Serializable

    Aggregates the responses for a request that the mediator has processed so far.

    Aggregates the responses for a request that the mediator has processed so far.

    state

    If the com.digitalasset.canton.protocol.messages.MediatorConfirmationRequest has been finalized, this will be a Left otherwise a Right which shows which transaction view hashes are not confirmed yet.

    requestTraceContext

    We retain the original trace context from the initial transaction confirmation request for raising timeouts to help with debugging. this ideally would be the same trace context throughout all responses could not be in a distributed setup so this is not validated anywhere. Intentionally supplied in a separate parameter list to avoid being included in equality checks.

19.  trait ResponseAggregator extends HasLoggerName with Product with Serializable
20.  trait ViewKey[VKEY] extends Pretty[VKEY] with Product with Serializable