trait OrderedBucketMergeHubOps[Name, A, Config, Offset, +M] extends AnyRef
- Alphabetic
- By Inheritance
- OrderedBucketMergeHubOps
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- abstract type Bucket
The type of equivalence classes for the merged elements
- abstract type PriorElement
The type of prior elements that is passed to makeSource.
The type of prior elements that is passed to makeSource. toPriorElement defines an abstraction function from com.digitalasset.canton.util.OrderedBucketMergeHub.OutputElements.
Abstract Value Members
- abstract def bucketOf(x: A): Bucket
Defines an equivalence relation on
A - abstract def exclusiveLowerBoundForBegin: Offset
The initial offset to start from
- abstract def makeSource(name: Name, config: Config, exclusiveStart: Offset, priorElement: Option[PriorElement]): Source[A, (KillSwitch, Future[Done], M)]
Creates a new source upon a config change.
Creates a new source upon a config change. The returned source is materialized at most once. To close the source, the materialized org.apache.pekko.stream.KillSwitch is pulled and the source is drained until it completes. The materialized scala.concurrent.Future should complete when all internal computations have stopped. The OrderedBucketMergeHub's materialized scala.concurrent.Future completes only after these materialized futures of all created ordered sources have completed.
- priorElement
The prior element that last reached the threshold or priorElement if there was none.
- abstract def offsetOfBucket(bucket: Bucket): Offset
- abstract def orderingOffset: Ordering[Offset]
The ordering for the offsets.
The ordering for the offsets. This defines a total preorder (AKA total quasi-order) on buckets and elements via the projections offsetOfBucket and bucketOf
- abstract def prettyBucket: Pretty[Bucket]
- abstract def priorElement: Option[PriorElement]
The prior element to be passed to makeSource at the start
- abstract def toPriorElement(output: OutputElement[Name, A]): PriorElement
An abstraction function from com.digitalasset.canton.util.OrderedBucketMergeHub.OutputElement to PriorElement
- abstract def traceContextOf(x: A): TraceContext
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]) @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 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()
- final def offsetOf(x: A): Offset
- 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])