| Interface | Description |
|---|---|
| Checkpoint | |
| EventPointer |
A pointer to an event.
|
| EventRead<T> |
An event that was read from a stream or a checkpoint marker if one has been requested.
|
| EventStreamReader<T> |
A reader for a stream.
|
| EventStreamWriter<Type> |
A writer can write events to a stream.
|
| IdempotentEventStreamWriter<Type> |
A writer can write events to a stream.
|
| Position |
A position in a stream.
|
| ReaderGroup |
A reader group is a collection of readers that collectively read all the events in the
stream.
|
| ReaderGroupMetrics | |
| Serializer<T> |
Takes events being written and serializes them to byteBuffers so they can be sent over the wire
and deserializes these same byte buffers back into objects.
|
| Stream |
A stream can be thought of as an unbounded sequence of events.
|
| StreamCut |
A set of segment/offset pairs for a single stream that represent a consistent position in the
stream.
|
| Transaction<Type> |
Provides a mechanism for writing many events atomically.
|
| TransactionalEventStreamWriter<Type> |
A writer that writes Events to an Event stream transactionally.
|
| Class | Description |
|---|---|
| EventWriterConfig | |
| EventWriterConfig.EventWriterConfigBuilder | |
| ReaderConfig | |
| ReaderConfig.ReaderConfigBuilder | |
| ReaderGroupConfig | |
| ReaderGroupConfig.ReaderGroupConfigBuilder | |
| ReaderSegmentDistribution |
Describes current distribution of number of segments assigned to each reader in the reader group.
|
| RetentionPolicy | |
| ScalingPolicy |
A policy that specifies how the number of segments in a stream should scale over time.
|
| Sequence |
A wrapper for two numbers.
|
| StreamConfiguration |
The configuration of a Stream.
|
| StreamConfiguration.StreamConfigurationBuilder | |
| TimeWindow |
Represents a time window for the events which are currently being read by a reader.
|
| Enum | Description |
|---|---|
| RetentionPolicy.RetentionType | |
| ScalingPolicy.ScaleType | |
| Transaction.PingStatus | |
| Transaction.Status |
| Exception | Description |
|---|---|
| InvalidStreamException | |
| NoSuchScopeException | |
| PingFailedException |
Transaction heartbeat to a controller instance failed, because of one of the following reasons.
|
| ReaderNotInReaderGroupException |
Read was invoked on a reader that the reader group does not consider a member.
|
| ReinitializationRequiredException | |
| TruncatedDataException | |
| TxnFailedException |
A transaction has failed.
|