trait CompositeHealthElement[ID, HE <: HealthElement] extends HealthElement
Defines a HealthElement that merely aggregates the state of other (dependent) HealthElements. The dependencies need not be reported anywhere.
If you need to manage a state separately for this component, add a dedicated dependency on AtomicHealthElement.
- ID
The identifier type for the dependent health elements.
- Alphabetic
- By Inheritance
- CompositeHealthElement
- HealthElement
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- abstract type State
The type of health states exposed by this component
The type of health states exposed by this component
- Definition Classes
- HealthElement
Abstract Value Members
- abstract def associatedOnShutdownRunner: OnShutdownRunner
The com.digitalasset.canton.lifecycle.OnShutdownRunner associated with this object.
The com.digitalasset.canton.lifecycle.OnShutdownRunner associated with this object.
When this com.digitalasset.canton.lifecycle.OnShutdownRunner closes, the health state permanently becomes closingState and all listeners are notified about this.
- Attributes
- protected
- Definition Classes
- HealthElement
- abstract def closingState: State
The state set when the associatedOnShutdownRunner closes
The state set when the associatedOnShutdownRunner closes
- Attributes
- protected
- Definition Classes
- HealthElement
- abstract def combineDependentStates: State
Fetch the current states from the relevant dependencies and combine them into the new state to report for this element.
Fetch the current states from the relevant dependencies and combine them into the new state to report for this element.
- Attributes
- protected
- abstract def initialHealthState: State
The initial state upon creation
The initial state upon creation
- Attributes
- protected
- Definition Classes
- HealthElement
- abstract def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- HealthElement
- abstract def name: String
Name of the health element.
Name of the health element. Used for logging.
- Definition Classes
- HealthElement
- abstract def prettyState: Pretty[State]
- Attributes
- protected
- Definition Classes
- HealthElement
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def alterDependencies(remove: Set[ID], add: Map[ID, HE]): Unit
First removes all dependencies in
remove, then adds all those inadd.First removes all dependencies in
remove, then adds all those inadd. If anIDappears inremoveandadd, then theIDis replaced. Refreshes the state if any of the dependencies was changed.Updates of
dependenciesare not atomic: If this method is called concurrently multiple times, the resulting dependencies may not correspond to a serializable execution.If an dependency triggers a concurrent state refresh, then the state refresh may see an inconsistent set of dependencies and therefore derive an inconsistent state. This however is only temporary as in this case another state refresh will be triggered at the end.
- Attributes
- protected
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def getDependencies: Map[ID, HE]
- Attributes
- protected
- final def getState: State
Returns the current state
Returns the current state
- Definition Classes
- HealthElement
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def refreshFromDependencies()(implicit traceContext: TraceContext): Unit
- Attributes
- protected
- def refreshState(newState: Eval[State])(implicit traceContext: TraceContext): Unit
Triggers a refresh of the component's state, using
newStateto determine the new state.Triggers a refresh of the component's state, using
newStateto determine the new state. May return before thenewStatehas been evaluated and the listeners have been poked.Note that listeners need not be poked about every state change; it suffices that they are poked eventually after each state change. So if there are frequent updates to the state, possibly from concurrent calls, then the listeners may never see some intermediate states.
- Attributes
- protected
- Definition Classes
- HealthElement
- def registerOnHealthChange(listener: HealthListener): Boolean
Registers a listener that gets poked upon each change of this element's health state.
Registers a listener that gets poked upon each change of this element's health state.
- returns
Whether the listener was not registered before
- Definition Classes
- HealthElement
- def removeDependency(id: ID): Unit
- Attributes
- protected
- def setDependency(id: ID, dependency: HE): Unit
- Attributes
- protected
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def unregisterOnHealthChange(listener: HealthListener): Boolean
Unregisters a listener.
Unregisters a listener.
- returns
Whether the listener was registered before.
- Definition Classes
- HealthElement
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])