| 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.
|
| Class | Description |
|---|---|
| EventWriterConfig | |
| EventWriterConfig.EventWriterConfigBuilder | |
| ReaderConfig | |
| ReaderConfig.ReaderConfigBuilder | |
| ReaderGroupConfig | |
| ReaderGroupConfig.ReaderGroupConfigBuilder | |
| 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 |
| Enum | Description |
|---|---|
| RetentionPolicy.RetentionType | |
| ScalingPolicy.ScaleType | |
| Transaction.Status |
| Exception | Description |
|---|---|
| InvalidStreamException | |
| PingFailedException |
Transaction heartbeat to a controller instance failed, because of one of the following reasons.
|
| ReinitializationRequiredException | |
| TruncatedDataException | |
| TxnFailedException |
A transaction has failed.
|