object mediators extends Helpful
- Annotations
- @Summary(s = "Inspect mediator synchronizer state", flag = console.this.Help.Summary.<init>$default$2) @Group(name = "Mediator Synchronizer State")
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- mediators
- Helpful
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- 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
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def help(methodName: String)(implicit consoleEnvironment: ConsoleEnvironment): Unit
- Definition Classes
- Helpful
- Annotations
- @Summary(s = "Help for specific commands (use help() or help(\"method\") for more information)", flag = console.this.Help.Summary.<init>$default$2) @Topic(t = Seq("Top-level Commands"))
- def help()(implicit consoleEnvironment: ConsoleEnvironment): Unit
- Definition Classes
- Helpful
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def list(synchronizerId: Option[SynchronizerId] = None, proposals: Boolean = false, timeQuery: TimeQuery = TimeQuery.HeadState, operation: Option[TopologyChangeOp] = Some(TopologyChangeOp.Replace), filterSynchronizer: String = "", filterSigningKey: String = "", protocolVersion: Option[String] = None, group: Option[NonNegativeInt] = None): Seq[ListMediatorSynchronizerStateResult]
- Annotations
- @Summary(s = "List mediator synchronizer topology state", flag = console.this.Help.Summary.<init>$default$2) @Description(s = """
synchronizerId: the optional target synchronizer
proposals: if true then proposals are shown, otherwise actual validated state
""")
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def propose(synchronizerId: SynchronizerId, threshold: PositiveInt, active: Seq[MediatorId], observers: Seq[MediatorId] = Seq.empty, group: NonNegativeInt, store: Option[TopologyStoreId] = None, synchronize: Option[NonNegativeDuration] = Some(
consoleEnvironment.commandTimeouts.bounded
), mustFullyAuthorize: Boolean = false, signedBy: Option[Fingerprint] = None, serial: Option[PositiveInt] = None): SignedTopologyTransaction[TopologyChangeOp, MediatorSynchronizerState]
- Annotations
- @Summary(s = "Replace the mediator topology", flag = console.this.Help.Summary.<init>$default$2) @Description(s = """
synchronizerId: the target synchronizer
threshold: the minimum number of mediators that need to come to a consensus for a message to be sent to other members.
active: the list of mediators that will take part in the mediator consensus in this mediator group
passive: the mediators that will receive all messages but will not participate in mediator consensus
group: the mediator group identifier
store: - "Authorized": the topology transaction will be stored in the node's authorized store and automatically
propagated to connected synchronizers, if applicable.
- "<synchronizer id>": the topology transaction will be directly submitted to the specified synchronizer without
storing it locally first. This also means it will _not_ be synchronized to other synchronizers
automatically.
mustFullyAuthorize: when set to true, the proposal's previously received signatures and the signature of this node must be
sufficient to fully authorize the topology transaction. if this is not the case, the request fails.
when set to false, the proposal retains the proposal status until enough signatures are accumulated to
satisfy the mapping's authorization requirements.
signedBy: the fingerprint of the key to be used to sign this proposal
serial: the expected serial this topology transaction should have. Serials must be contiguous and start at 1.
This transaction will be rejected if another fully authorized transaction with the same serial already
exists, or if there is a gap between this serial and the most recently used serial.
If None, the serial will be automatically selected by the node.""")
- def propose_delta(synchronizerId: SynchronizerId, group: NonNegativeInt, adds: List[MediatorId] = Nil, removes: List[MediatorId] = Nil, observerAdds: List[MediatorId] = Nil, observerRemoves: List[MediatorId] = Nil, updateThreshold: Option[PositiveInt] = None, synchronize: Option[NonNegativeDuration] = Some(
consoleEnvironment.commandTimeouts.bounded
), mustFullyAuthorize: Boolean = false, signedBy: Option[Fingerprint] = None): Unit
- Annotations
- @Summary(s = "Propose changes to the mediator topology", flag = console.this.Help.Summary.<init>$default$2) @Description(s = """
synchronizerId: the target synchronizer
group: the mediator group identifier
adds: The unique identifiers of the active mediators to add.
removes: The unique identifiers of the mediators that should no longer be active mediators.
observerAdds: The unique identifiers of the observer mediators to add.
observerRemoves: The unique identifiers of the mediators that should no longer be observer mediators.
updateThreshold: Optionally an updated value for the threshold of the mediator group.
await: optional timeout to wait for the proposal to be persisted in the specified topology store
mustFullyAuthorize: when set to true, the proposal's previously received signatures and the signature of this node must be
sufficient to fully authorize the topology transaction. if this is not the case, the request fails.
when set to false, the proposal retains the proposal status until enough signatures are accumulated to
satisfy the mapping's authorization requirements.
signedBy: the fingerprint of the key to be used to sign this proposal""")
- def remove_group(synchronizerId: SynchronizerId, group: NonNegativeInt, store: Option[TopologyStoreId] = None, synchronize: Option[NonNegativeDuration] = Some(
consoleEnvironment.commandTimeouts.bounded
), mustFullyAuthorize: Boolean = false): SignedTopologyTransaction[TopologyChangeOp, MediatorSynchronizerState]
- Annotations
- @Summary(s = "Propose to remove a mediator group", flag = console.this.Help.Summary.<init>$default$2) @Description(s = """
synchronizerId: the target synchronizer
group: the mediator group identifier
store: - "Authorized": the topology transaction will be stored in the node's authorized store and automatically
propagated to connected synchronizers, if applicable.
- "<synchronizer id>": the topology transaction will be directly submitted to the specified synchronizer without
storing it locally first. This also means it will _not_ be synchronized to other synchronizers
automatically.
mustFullyAuthorize: when set to true, the proposal's previously received signatures and the signature of this node must be
sufficient to fully authorize the topology transaction. if this is not the case, the request fails.
when set to false, the proposal retains the proposal status until enough signatures are accumulated to
satisfy the mapping's authorization requirements.""")
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- 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])