Packages

class ParticipantNode extends CantonNode with NamedLogging with HasUptime with NoTracing

A participant node in the system.

The participant node can connect to a number of domains and offers: - the ledger API to its application. - the participant node admin API to its operator.

Linear Supertypes
NoTracing, HasUptime, NamedLogging, CantonNode, AutoCloseable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ParticipantNode
  2. NoTracing
  3. HasUptime
  4. NamedLogging
  5. CantonNode
  6. AutoCloseable
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new ParticipantNode(id: ParticipantId, metrics: ParticipantMetrics, config: LocalParticipantConfig, nodeParameters: ParticipantNodeParameters, storage: Storage, clock: Clock, topologyManager: ParticipantTopologyManager, cryptoPureApi: CryptoPureApi, identityPusher: ParticipantTopologyDispatcher, partyNotifier: LedgerServerPartyNotifier, ips: IdentityProvidingServiceClient, sync: CantonSyncService, eventPublisher: ParticipantEventPublisher, ledgerApiServer: LedgerApiServerState, ledgerApiDependentCantonServices: StartableStoppableLedgerApiDependentServices, adminToken: CantonAdminToken, recordSequencerInteractions: AtomicReference[Option[RecordingConfig]], replaySequencerConfig: AtomicReference[Option[ReplayConfig]], loggerFactory: NamedLoggerFactory)

    id

    participant id

    config

    Participant node configuration com.digitalasset.canton.participant.config.LocalParticipantConfig parsed * from config file.

    storage

    participant node persistence

    topologyManager

    topology manager

    identityPusher

    identity pusher

    ips

    identity client

    sync

    synchronization service

    eventPublisher

    participant level sync event log for non-domain events

    ledgerApiServer

    ledger api server state

    ledgerApiDependentCantonServices

    admin workflow services (ping, archive distribution)

    adminToken

    the admin token required when JWT is enabled on the ledger api

    recordSequencerInteractions

    If set to Some(path), every sequencer client will record all sends requested and events received to the directory path. A new recording starts whenever the participant is connected to a domain.

    replaySequencerConfig

    If set to Some(replayConfig), a sequencer client transport will be used enabling performance tests to replay previously recorded requests and received events. See sequencing.client.ReplayConfig for more details.

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. val adminToken: CantonAdminToken
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def autoConnectLocalDomain(config: DomainConnectionConfig)(implicit traceContext: TraceContext, ec: ExecutionContext): EitherT[Future, SyncServiceError, Unit]

    helper utility used to auto-connect to local domains

    helper utility used to auto-connect to local domains

    during startup, we first reconnect to existing domains. subsequently, if requested via a cli argument, we also auto-connect to local domains.

  7. val clock: Clock

    The clock used to measure up-time

    The clock used to measure up-time

    Attributes
    protected
    Definition Classes
    ParticipantNode → HasUptime
  8. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  9. def close(): Unit
    Definition Classes
    ParticipantNode → AutoCloseable
  10. val config: LocalParticipantConfig
  11. val cryptoPureApi: CryptoPureApi
  12. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  14. implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  15. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  16. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  17. val id: ParticipantId
  18. def isActive: Boolean
    Definition Classes
    ParticipantNode → CantonNode
  19. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  20. val ledgerApiDependentCantonServices: StartableStoppableLedgerApiDependentServices
  21. def logger: TracedLogger
    Attributes
    protected
    Definition Classes
    NamedLogging
  22. val loggerFactory: NamedLoggerFactory
    Definition Classes
    ParticipantNode → NamedLogging
  23. val metrics: ParticipantMetrics
  24. implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  25. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  26. def noTracingLogger: Logger
    Attributes
    protected
    Definition Classes
    NamedLogging
  27. val nodeParameters: ParticipantNodeParameters
  28. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  29. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  30. def readyDomains: Map[DomainId, Boolean]
  31. def reconnectDomainsIgnoreFailures()(implicit traceContext: TraceContext, ec: ExecutionContext): EitherT[Future, SyncServiceError, Unit]
  32. val recordSequencerInteractions: AtomicReference[Option[RecordingConfig]]
  33. val replaySequencerConfig: AtomicReference[Option[ReplayConfig]]
  34. def status: Future[ParticipantStatus]
    Definition Classes
    ParticipantNode → CantonNode
  35. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  36. def toString(): String
    Definition Classes
    AnyRef → Any
  37. val topologyManager: ParticipantTopologyManager
  38. implicit def traceContext: TraceContext
    Attributes
    protected
    Definition Classes
    NoTracing
  39. def uptime(): Duration
    Attributes
    protected
    Definition Classes
    HasUptime
  40. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  41. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  42. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

Inherited from NoTracing

Inherited from HasUptime

Inherited from NamedLogging

Inherited from CantonNode

Inherited from AutoCloseable

Inherited from AnyRef

Inherited from Any

Ungrouped