package mediator
- Alphabetic
- Public
- Protected
Type Members
- class DefaultMediatorEventDeduplicator extends MediatorEventDeduplicator with NamedLogging
- class EnterpriseMediatorRuntime extends MediatorRuntime with NamedLogging
- class EnterpriseMediatorRuntimeFactory extends MediatorRuntimeFactory
- class GrpcEnterpriseMediatorAdministrationService extends EnterpriseMediatorAdministrationService
- class MediatorNode extends CantonNode with NamedLogging with HasUptime
- class MediatorNodeBootstrap extends CantonNodeBootstrapBase[MediatorNode, MediatorNodeConfig, MediatorNodeParameters]
- 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()) 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
tofalse
- timeTracker
configuration for how time is tracked on the connected domain using the sequencer
- case class MediatorNodeParameterConfig(willCorruptYourSystemDevVersionSupport: Boolean = false, dontWarnOnDeprecatedPV: Boolean = false, initialProtocolVersion: ProtocolVersion = ProtocolVersion.latest) extends Product with Serializable
Various parameters for non-standard mediator settings
Various parameters for non-standard mediator settings
- willCorruptYourSystemDevVersionSupport
if true, then dev version will be turned on, but we will brick this mediator node if it is used for production.
- dontWarnOnDeprecatedPV
if true, then this mediator will not emit a warning when connecting to a sequencer using protocol version 2.0.0.
- case class MediatorNodeParameters(tracing: TracingConfig, delayLoggingThreshold: NonNegativeFiniteDuration, loggingConfig: LoggingConfig, logQueryCost: Option[QueryCostMonitoringConfig], enableAdditionalConsistencyChecks: Boolean, enablePreviewFeatures: Boolean, processingTimeouts: ProcessingTimeout, sequencerClient: SequencerClientConfig, cachingConfigs: CachingConfigs, nonStandardConfig: Boolean, devVersionSupport: Boolean, dontWarnOnDeprecatedPV: Boolean, initialProtocolVersion: ProtocolVersion) extends LocalNodeParameters with Product with Serializable
- 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.
- class MediatorReplicaManagerException extends RuntimeException
An unexpected error occurred while transitioning between replica states
- trait MediatorRuntime extends FlagCloseable
Mediator component and its supporting services
- trait MediatorRuntimeFactory extends AnyRef
- final case class RemoteMediatorConfig(adminApi: ClientConfig) extends NodeConfig with Product with Serializable
Value Members
- object CommunityMediatorRuntimeFactory extends MediatorRuntimeFactory
- object MediatorNodeBootstrap