c

com.digitalasset.canton.domain.sequencing.service

DirectSequencerSubscriptionFactory

class DirectSequencerSubscriptionFactory extends NamedLogging

Factory for creating resilient subscriptions directly to an in-process sequencer.Sequencer

Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DirectSequencerSubscriptionFactory
  2. NamedLogging
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new DirectSequencerSubscriptionFactory(sequencer: Sequencer, timeouts: ProcessingTimeout, loggerFactory: NamedLoggerFactory)(implicit materializer: Materializer, executionContext: ExecutionContext)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  6. def create[E](startingAt: SequencerCounter, identifier: String, member: Member, handler: SerializedEventOrErrorHandler[E])(implicit traceContext: TraceContext): EitherT[Future, CreateSubscriptionError, SequencerSubscription[E]]

    Create a subscription for an event handler to observe sequencer events for this member.

    Create a subscription for an event handler to observe sequencer events for this member. By connecting from startingAt it is assumed that all prior events have been successfully read by the member (and may be removed by a separate administrative process). Closing the returned subscription should disconnect the handler. If member is unknown by the sequencer a sequencer.errors.CreateSubscriptionError.UnknownMember error will be returned. If the counter is invalid (currently will only happen if counter <0) a sequencer.errors.CreateSubscriptionError.InvalidCounter error will be returned.

    startingAt

    Counter of the next event to observe. (e.g. 0 will return the first event when it is available)

    identifier

    a name to attach to the connection

    member

    Member to subscribe on behalf of.

    handler

    The handler to invoke with sequencer events

    returns

    A running subscription

  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  9. implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  10. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. def logger: TracedLogger
    Attributes
    protected
    Definition Classes
    NamedLogging
  14. val loggerFactory: NamedLoggerFactory
    Attributes
    protected
    Definition Classes
    DirectSequencerSubscriptionFactoryNamedLogging
  15. implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  16. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  17. def noTracingLogger: Logger
    Attributes
    protected
    Definition Classes
    NamedLogging
  18. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  19. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  20. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  21. def toString(): String
    Definition Classes
    AnyRef → Any
  22. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  23. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  24. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated @Deprecated
    Deprecated

Inherited from NamedLogging

Inherited from AnyRef

Inherited from Any

Ungrouped