Type Members

1.  class DefaultMediatorEventDeduplicator extends MediatorEventDeduplicator with NamedLogging
2.  final case class EnterpriseMediatorConfig(pruning: MediatorPruningConfig = MediatorPruningConfig()) extends Product with Serializable

   Configuration for the mediator in enterprise.

   Configuration for the mediator in enterprise.

   pruning

   mediator pruning configuration

3.  class EnterpriseMediatorRuntime extends MediatorRuntime with NamedLogging
4.  class EnterpriseMediatorRuntimeFactory extends MediatorRuntimeFactory
5.  class GrpcEnterpriseMediatorAdministrationService extends EnterpriseMediatorAdministrationService with GrpcPruningScheduler with HasPruningScheduler
6.  class MediatorNode extends CantonNode with NamedLogging with HasUptime
7.  class MediatorNodeBootstrap extends CantonNodeBootstrapBase[MediatorNode, MediatorNodeConfig, MediatorNodeParameters]
8.  case class MediatorNodeConfig(adminApi: EnterpriseAdminServerConfig = EnterpriseAdminServerConfig(), storage: EnterpriseStorageConfig = EnterpriseStorageConfig.Memory(), crypto: EnterpriseCryptoConfig = EnterpriseCryptoConfig(), init: InitConfig = InitConfig(identity = None), replication: ReplicationConfig = ReplicationConfig(), timeTracker: DomainTimeTrackerConfig = DomainTimeTrackerConfig(), sequencerClient: SequencerClientConfig = SequencerClientConfig(), caching: CachingConfigs = CachingConfigs(), parameters: MediatorNodeParameterConfig = MediatorNodeParameterConfig(), mediator: EnterpriseMediatorConfig = EnterpriseMediatorConfig(), monitoring: NodeMonitoringConfig = NodeMonitoringConfig()) extends EnterpriseLocalNodeConfig with ConfigDefaults[DefaultPorts, MediatorNodeConfig] with Product with Serializable

   Mediator Node configuration

   Mediator Node configuration

   init

   all nodes must provided a init config however the mediator cannot auto initialize itself so defaults autoInit to false

   timeTracker

   configuration for how time is tracked on the connected domain using the sequencer

9.  case class MediatorNodeParameterConfig(devVersionSupport: Boolean = false, dontWarnOnDeprecatedPV: Boolean = false, initialProtocolVersion: ProtocolVersion = ProtocolVersion.latest) extends ProtocolConfig 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.  case class MediatorNodeParameters(general: General, protocol: Protocol) extends CantonNodeParameters with HasGeneralCantonNodeParameters with HasProtocolCantonNodeParameters with Product with Serializable
11.  case class MediatorPruningConfig(maxPruningBatchSize: PositiveInt = PositiveInt.tryCreate(50000), pruningMetricUpdateInterval: Option[PositiveDurationSeconds] = config.PositiveDurationSeconds.ofHours(1L).some) extends Product with Serializable

    Configuration for enterprise sequencer pruning

    Configuration for enterprise sequencer 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 EnterpriseScheduler with HasCloseContext with PruningScheduler with HasPruningSchedulerStore with UpdatePruningMetric
13.  class MediatorReplicaManager extends ReplicaManager

    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.  trait MediatorRuntime extends FlagCloseable

    Mediator component and its supporting services

16.  trait MediatorRuntimeFactory extends AnyRef
17.  final case class RemoteMediatorConfig(adminApi: ClientConfig) extends NodeConfig with Product with Serializable