package mediator

  1. Alphabetic
  1. Public
  2. Protected

Package Members

  1. package admin
  2. package service
  3. package store
  4. package topology

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.


    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


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


    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


    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


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


    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