Type Members

1.  class CommunityMediatorReplicaManager extends MediatorReplicaManager

   Community version of the mediator replica manager.

   Community version of the mediator replica manager. Does not support high-availability.

2.  class DefaultMediatorEventDeduplicator extends MediatorEventDeduplicator with NamedLogging
3.  class EnterpriseMediatorReplicaManager extends ReplicaManager with MediatorReplicaManager

   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.

4.  final case class FinalizedResponse(requestId: RequestId, request: MediatorConfirmationRequest, finalizationTime: CantonTimestamp, verdict: Verdict)(requestTraceContext: TraceContext) extends ResponseAggregator with Product with Serializable
5.  final case class MediatorConfig(pruning: MediatorPruningConfig = MediatorPruningConfig()) extends UniformCantonConfigValidation with Product with Serializable

   Configuration for the mediator.

   Configuration for the mediator.

   pruning

   mediator pruning configuration

6.  class MediatorNode extends CantonNode with NamedLogging with HasUptime
7.  class MediatorNodeBootstrap extends CantonNodeBootstrapImpl[MediatorNode, MediatorNodeConfig, MediatorNodeParameters, MediatorMetrics]
8.  trait MediatorNodeBootstrapFactory extends AnyRef
9.  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[DefaultPorts, MediatorNodeConfig] with UniformCantonConfigValidation with Product with Serializable

   Mediator Node configuration that defaults to auto-init

10.  final case class MediatorNodeParameterConfig(alphaVersionSupport: Boolean = true, 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.

11.  final case class MediatorNodeParameters(general: General, protocol: Protocol) extends CantonNodeParameters with HasGeneralCantonNodeParameters with HasProtocolCantonNodeParameters with Product with Serializable
12.  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.

13.  class MediatorPruningScheduler extends JobScheduler with HasCloseContext with PruningScheduler with HasPruningSchedulerStore with UpdatePruningMetric
14.  trait MediatorReplicaManager extends NamedLogging with FlagCloseableAsync
15.  class MediatorReplicaManagerException extends RuntimeException

    An unexpected error occurred while transitioning between replica states

16.  final class MediatorRuntime extends FlagCloseable with NamedLogging

    Mediator component and its supporting services

17.  sealed trait MediatorVerdict extends Product with Serializable with PrettyPrinting
18.  final case class RemoteMediatorConfig(adminApi: FullClientConfig, token: Option[String] = None) extends NodeConfig with UniformCantonConfigValidation with Product with Serializable
19.  final case class ResponseAggregation[VKEY](requestId: RequestId, request: MediatorConfirmationRequest, timeout: 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.

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