trait PartyMetadataStore extends AutoCloseable
Store to manage batches of party metadata prior to indexing parties for the ledger API
Linear Supertypes
Known Subclasses
Ordering
- Alphabetic
- By Inheritance
Inherited
- PartyMetadataStore
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Abstract Value Members
- abstract def close(): Unit
- Definition Classes
- AutoCloseable
- Annotations
- @throws(classOf[java.lang.Exception])
- abstract def fetchNotNotified()(implicit traceContext: TraceContext): FutureUnlessShutdown[Seq[PartyMetadata]]
Fetch the current set of party metadata that still needs to be notified.
- abstract def insertOrUpdatePartyMetadata(partiesMetadata: Seq[PartyMetadata])(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]
Reflect the specified batch of party metadata in the store.
- abstract 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.
- abstract 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.
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
- 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()
- 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
- @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])