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 with NamedLogging
6.  class MediatorNode extends MediatorNodeCommon
7.  class MediatorNodeBootstrap extends CantonNodeBootstrapBase[MediatorNode, MediatorNodeConfig, MediatorNodeParameters, MediatorNodeMetrics] with MediatorNodeBootstrapCommon[MediatorNode, MediatorNodeConfig]
8.  trait MediatorNodeBootstrapCommon[T <: CantonNode, NC <: LocalNodeConfig with MediatorNodeConfigCommon] extends AnyRef
9.  class MediatorNodeBootstrapX extends CantonNodeBootstrapX[MediatorNodeX, MediatorNodeXConfig, MediatorNodeParameters, MediatorNodeMetrics] with MediatorNodeBootstrapCommon[MediatorNodeX, MediatorNodeXConfig]
10.  class MediatorNodeCommon extends CantonNode with NamedLogging with HasUptime
11.  final 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(), topologyX: TopologyXConfig = TopologyXConfig.NotUsed) extends MediatorNodeConfigCommon 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

12.  abstract class MediatorNodeConfigCommon extends EnterpriseLocalNodeConfig
13.  final 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.

14.  final case class MediatorNodeParameters(general: General, protocol: Protocol) extends CantonNodeParameters with HasGeneralCantonNodeParameters with HasProtocolCantonNodeParameters with Product with Serializable
15.  class MediatorNodeX extends MediatorNodeCommon
16.  final case class MediatorNodeXConfig(adminApi: EnterpriseAdminServerConfig = EnterpriseAdminServerConfig(), storage: EnterpriseStorageConfig = EnterpriseStorageConfig.Memory(), crypto: EnterpriseCryptoConfig = EnterpriseCryptoConfig(), init: InitConfig = InitConfig(identity = Some(InitConfigBase.Identity())), replication: ReplicationConfig = ReplicationConfig(), timeTracker: DomainTimeTrackerConfig = DomainTimeTrackerConfig(), sequencerClient: SequencerClientConfig = SequencerClientConfig(), caching: CachingConfigs = CachingConfigs(), parameters: MediatorNodeParameterConfig = MediatorNodeParameterConfig(), mediator: EnterpriseMediatorConfig = EnterpriseMediatorConfig(), monitoring: NodeMonitoringConfig = NodeMonitoringConfig(), topologyX: TopologyXConfig = TopologyXConfig()) extends MediatorNodeConfigCommon with ConfigDefaults[DefaultPorts, MediatorNodeXConfig] with Product with Serializable

    Mediator Node X configuration that defaults to auto-init

17.  final 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.

18.  class MediatorPruningScheduler extends EnterpriseScheduler with HasCloseContext with PruningScheduler with HasPruningSchedulerStore with UpdatePruningMetric
19.  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.

20.  class MediatorReplicaManagerException extends RuntimeException

    An unexpected error occurred while transitioning between replica states

21.  trait MediatorRuntime extends FlagCloseable

    Mediator component and its supporting services

22.  trait MediatorRuntimeFactory extends AnyRef
23.  final case class RemoteMediatorConfig(adminApi: ClientConfig) extends NodeConfig with Product with Serializable
24.  trait ResponseAggregation extends PrettyPrinting