Packages

class SyncDomainEphemeralState extends SyncDomainEphemeralStateLookup with AutoCloseable with NamedLogging with ComponentHealth

The state of a synchronization domain that is kept only in memory and must be reconstructed after crashes and fatal errors from the SyncDomainPersistentState. The ephemeral state can be kept across network disconnects provided that the local processing continues as far as possible.

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SyncDomainEphemeralState
  2. ComponentHealth
  3. HealthElement
  4. NamedLogging
  5. AutoCloseable
  6. SyncDomainEphemeralStateLookup
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new SyncDomainEphemeralState(persistentState: SyncDomainPersistentState, multiDomainEventLog: MultiDomainEventLog, singleDomainCausalTracker: SingleDomainCausalTracker, inFlightSubmissionTracker: InFlightSubmissionTracker, startingPoints: ProcessingStartingPoints, createTimeTracker: (NamedLoggerFactory) => DomainTimeTracker, metrics: SyncDomainMetrics, timeouts: ProcessingTimeout, useCausalityTracking: Boolean, loggerFactory: NamedLoggerFactory, futureSupervisor: FutureSupervisor)(implicit executionContext: ExecutionContext)

Type Members

  1. type HealthListener = (SyncDomainEphemeralState.this.type, State, TraceContext) => Unit
    Definition Classes
    HealthElement
  2. type State = ComponentState
    Definition Classes
    ComponentHealthHealthElement

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. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def causalityLookup: SingleDomainCausalTracker
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  7. def close(): Unit
    Definition Classes
    SyncDomainEphemeralState → AutoCloseable
  8. def contractLookup: ContractLookup
  9. def degradationOccurred(error: String)(implicit tc: TraceContext): Unit

    Report that the component is now degraded.

    Report that the component is now degraded. Note that this will override the component state, even if it is currently failed!

    Definition Classes
    ComponentHealth
  10. def degradationOccurred(error: CantonError)(implicit tc: TraceContext): Unit

    Report that the component is now degraded.

    Report that the component is now degraded. Note that this will override the component state, even if it is currently failed!

    Definition Classes
    ComponentHealth
  11. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  13. implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  14. def failureOccurred(error: String)(implicit tc: TraceContext): Unit

    Report that the component is now failed

    Report that the component is now failed

    Definition Classes
    ComponentHealth
  15. def failureOccurred(error: CantonError)(implicit tc: TraceContext): Unit

    Report that the component is now failed

    Report that the component is now failed

    Definition Classes
    ComponentHealth
  16. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  17. def getState: ComponentState

    Current state

    Current state

    Definition Classes
    ComponentHealthHealthElement
  18. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  19. val initialState: ComponentState

    Initial state of the component

    Initial state of the component

    Definition Classes
    SyncDomainEphemeralStateComponentHealth
  20. def isFailed: Boolean

    Whether the component is in a failed state.

    Whether the component is in a failed state. Note: failed here means exactly _failed_, to know if the component is just unhealthy (i.e degraded or failed), use isUnhealthy.

    Definition Classes
    ComponentHealth
  21. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  22. def isNotFailed: Boolean

    Returns true when the component is not in a failed state (for components, degraded is still not failed)

    Returns true when the component is not in a failed state (for components, degraded is still not failed)

    Definition Classes
    ComponentHealthHealthElement
  23. val listeners: AtomicReference[List[HealthListener]]
    Attributes
    protected
    Definition Classes
    HealthElement
  24. def logger: TracedLogger
    Attributes
    protected
    Definition Classes
    NamedLogging
  25. val loggerFactory: NamedLoggerFactory
  26. def markAsRecovered()(implicit tc: TraceContext): Unit
  27. val name: String

    Name of the health element.

    Name of the health element. Used for logging.

    Definition Classes
    SyncDomainEphemeralStateHealthElement
  28. implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  29. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  30. def noTracingLogger: Logger
    Attributes
    protected
    Definition Classes
    NamedLogging
  31. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  32. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  33. def observedTimestampLookup: WatermarkLookup[CantonTimestamp]
  34. val observedTimestampTracker: WatermarkTracker[CantonTimestamp]
  35. val pendingTransferInSubmissions: TrieMap[RootHash, PendingTransferSubmission]
  36. val pendingTransferOutSubmissions: TrieMap[RootHash, PendingTransferSubmission]
  37. val phase37Synchronizer: Phase37Synchronizer
  38. val recordOrderPublisher: RecordOrderPublisher
  39. def registerOnHealthChange(listener: HealthListener): Unit
    Definition Classes
    HealthElement
  40. def reportHealthState(state: ComponentState)(implicit tc: TraceContext): Boolean
    Definition Classes
    ComponentHealth
  41. def reportHealthState_(state: ComponentState)(implicit tc: TraceContext): Unit
    Definition Classes
    ComponentHealth
  42. val requestCounterAllocator: RequestCounterAllocatorImpl
  43. val requestJournal: RequestJournal
  44. val requestTracker: RequestTracker
  45. def resolveUnhealthy(implicit traceContext: TraceContext): Boolean

    Set the health state to Ok and if the previous state was unhealthy, log a message to inform about the resolution of the ongoing issue.

    Set the health state to Ok and if the previous state was unhealthy, log a message to inform about the resolution of the ongoing issue.

    Definition Classes
    ComponentHealth
  46. def resolveUnhealthy_(implicit traceContext: TraceContext): Unit
    Definition Classes
    ComponentHealth
  47. val singleDomainCausalTracker: SingleDomainCausalTracker
  48. val startingPoints: ProcessingStartingPoints
  49. val storedContractManager: StoredContractManager
  50. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  51. val timeTracker: DomainTimeTracker
  52. def toString(): String
    Definition Classes
    AnyRef → Any
  53. val transferCache: TransferCache
  54. def transferLookup: TransferLookup
  55. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  56. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  57. 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 ComponentHealth

Inherited from HealthElement

Inherited from NamedLogging

Inherited from AutoCloseable

Inherited from AnyRef

Inherited from Any

Ungrouped