com.digitalasset.canton.research.participant.multidomain
CompletionStreamRequest
Companion object CompletionStreamRequest
final case class CompletionStreamRequest(ledgerId: String, applicationId: String, parties: Seq[String], offset: Option[LedgerOffset], domainId: String) extends GeneratedMessage with Updatable[CompletionStreamRequest] with Product with Serializable
- ledgerId
Must correspond to the ledger id reported by the Ledger Identification Service. Must be a valid LedgerString (as described in
). Optionalvalue.proto
- applicationId
Only completions of commands submitted with the same application_id will be visible in the stream. Must be a valid ApplicationIdString (as described in
). Required unless authentication is used with a user token or a custom token specifying an application-id. In that case, the token's user-id, respectively application-id, will be used for the request's application_id.value.proto
- parties
Non-empty list of parties whose data should be included. Only completions of commands for which at least one of the
parties is in the given set of parties will be visible in the stream. Must be a valid PartyIdString (as described inact_as
). Requiredvalue.proto
- offset
This field indicates the minimum offset for completions. This can be used to resume an earlier completion stream. This offset is exclusive: the response will only contain commands whose offset is strictly greater than this. Optional, if not set the ledger uses the current ledger end offset instead.
- domainId
Must be a valid domain ID Required
- Annotations
- @SerialVersionUID()
- Alphabetic
- By Inheritance
- CompletionStreamRequest
- Updatable
- GeneratedMessage
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new CompletionStreamRequest(ledgerId: String, applicationId: String, parties: Seq[String], offset: Option[LedgerOffset], domainId: String)
- ledgerId
Must correspond to the ledger id reported by the Ledger Identification Service. Must be a valid LedgerString (as described in
). Optionalvalue.proto
- applicationId
Only completions of commands submitted with the same application_id will be visible in the stream. Must be a valid ApplicationIdString (as described in
). Required unless authentication is used with a user token or a custom token specifying an application-id. In that case, the token's user-id, respectively application-id, will be used for the request's application_id.value.proto
- parties
Non-empty list of parties whose data should be included. Only completions of commands for which at least one of the
parties is in the given set of parties will be visible in the stream. Must be a valid PartyIdString (as described inact_as
). Requiredvalue.proto
- offset
This field indicates the minimum offset for completions. This can be used to resume an earlier completion stream. This offset is exclusive: the response will only contain commands whose offset is strictly greater than this. Optional, if not set the ledger uses the current ledger end offset instead.
- domainId
Must be a valid domain ID Required
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 addAllParties(__vs: Iterable[String]): CompletionStreamRequest
- def addParties(__vs: String*): CompletionStreamRequest
- val applicationId: String
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clearOffset: CompletionStreamRequest
- def clearParties: CompletionStreamRequest
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- def companion: CompletionStreamRequest.type
- Definition Classes
- CompletionStreamRequest → GeneratedMessage
- val domainId: String
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def getField(__field: FieldDescriptor): PValue
- Definition Classes
- CompletionStreamRequest → GeneratedMessage
- def getFieldByNumber(__fieldNumber: Int): Any
- Definition Classes
- CompletionStreamRequest → GeneratedMessage
- def getOffset: LedgerOffset
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val ledgerId: String
- 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()
- val offset: Option[LedgerOffset]
- val parties: Seq[String]
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- def serializedSize: Int
- Definition Classes
- CompletionStreamRequest → GeneratedMessage
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- final def toByteArray: Array[Byte]
- Definition Classes
- GeneratedMessage
- final def toByteString: ByteString
- Definition Classes
- GeneratedMessage
- final def toPMessage: PMessage
- Definition Classes
- GeneratedMessage
- def toProtoString: String
- Definition Classes
- CompletionStreamRequest → GeneratedMessage
- def update(ms: (Lens[CompletionStreamRequest, CompletionStreamRequest]) => Mutation[CompletionStreamRequest]*): CompletionStreamRequest
- Definition Classes
- Updatable
- 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])
- def withApplicationId(__v: String): CompletionStreamRequest
- def withDomainId(__v: String): CompletionStreamRequest
- def withLedgerId(__v: String): CompletionStreamRequest
- def withOffset(__v: LedgerOffset): CompletionStreamRequest
- def withParties(__v: Seq[String]): CompletionStreamRequest
- final def writeDelimitedTo(output: OutputStream): Unit
- Definition Classes
- GeneratedMessage
- def writeTo(_output__: CodedOutputStream): Unit
- Definition Classes
- CompletionStreamRequest → GeneratedMessage
- final def writeTo(output: OutputStream): Unit
- Definition Classes
- GeneratedMessage