class InMemoryPartyMetadataStore extends PartyMetadataStore
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- InMemoryPartyMetadataStore
- PartyMetadataStore
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new InMemoryPartyMetadataStore()
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()
- def close(): Unit
- Definition Classes
- InMemoryPartyMetadataStore → AutoCloseable
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def fetchNotNotified()(implicit traceContext: TraceContext): FutureUnlessShutdown[Seq[PartyMetadata]]
Fetch the current set of party metadata that still needs to be notified.
Fetch the current set of party metadata that still needs to be notified.
- Definition Classes
- InMemoryPartyMetadataStore → PartyMetadataStore
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def insertOrUpdatePartyMetadata(partiesMetadata: Seq[PartyMetadata])(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]
Reflect the specified batch of party metadata in the store.
Reflect the specified batch of party metadata in the store.
- Definition Classes
- InMemoryPartyMetadataStore → PartyMetadataStore
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def markNotified(effectiveAt: CantonTimestamp, partyIds: Seq[PartyId])(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]
Mark the given parties as having been successfully forwarded to the ledger API server as of the specified effectiveAt timestamp.
Mark the given parties as having been successfully forwarded to the ledger API server as of the specified effectiveAt timestamp.
- Definition Classes
- InMemoryPartyMetadataStore → PartyMetadataStore
- def metadataForParties(partyIds: Seq[PartyId])(implicit traceContext: TraceContext): FutureUnlessShutdown[Seq[Option[PartyMetadata]]]
Fetch the metadata for the given party IDs.
Fetch the metadata for the given party IDs. The order of the response corresponds to the input order. None is returned on behalf of currently unknown parties.
- Definition Classes
- InMemoryPartyMetadataStore → PartyMetadataStore
- 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()
- 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])