package internal
Ordering
- Alphabetic
Visibility
- Public
- Protected
Type Members
- trait Checkpointer[F[_], C] extends Monoid[C]
Checkpoints messages to the input stream so that we don't read them again.
Checkpoints messages to the input stream so that we don't read them again. A single checkpointer might be responsible for multiple incoming messages.
- F
An effect
- C
Source-specific type describing the outstading messages
- case class LowLevelEvents[C](events: Chunk[ByteBuffer], ack: C, earliestSourceTstamp: Option[Instant]) extends Product with Serializable
The events and checkpointable item emitted by a LowLevelSource
The events and checkpointable item emitted by a LowLevelSource
This library uses LowLevelEvents internally, but it is never exposed to the high level event processor
Value Members
- object Checkpointer extends Serializable
- object CleanCancellation