See: Description
Interface | Description |
---|---|
ByteBufferRecord |
A
Record within the stream backed by a collection of binary field/value paris. |
ByteRecord |
A
Record within the stream backed by a collection of binary field/value paris. |
MapRecord<S,K,V> |
A
Record within the stream backed by a collection of field/value paris. |
ObjectRecord<S,V> |
A
Record within the stream mapped to a single object. |
Record<S,V> |
A single entry in the stream consisting of the
entry-id and the actual entry-value (typically a
collection of field/value pairs ). |
StringRecord |
Class | Description |
---|---|
Consumer |
Value object representing a Stream consumer within a consumer group.
|
PendingMessage |
Value object representing a single pending message containing its ID, the consumer that fetched
the message and has still to acknowledge it, the time elapsed since the messages last delivery and the the total
number of times delivered.
|
PendingMessages |
Value object holding detailed information about pending messages in consumer group for a given
Range and offset. |
PendingMessagesSummary |
Value Object summarizing pending messages in a consumer group.
|
ReadOffset |
Value object representing read offset for a Stream.
|
RecordId |
The id of a single
Record within a stream. |
StreamInfo | |
StreamInfo.XInfoConsumer | |
StreamInfo.XInfoConsumers | |
StreamInfo.XInfoGroup | |
StreamInfo.XInfoGroups |
Value object holding general information about consumer groups associated with a
Redis Stream.
|
StreamInfo.XInfoObject | |
StreamInfo.XInfoStream |
Value object holding general information about a Redis Stream.
|
StreamOffset<K> |
Value object representing a Stream Id with its offset.
|
StreamReadOptions |
Options for reading messages from a Redis Stream.
|
StreamRecords |
StreamRecords provides utilities to create specific Record instances. |
StreamRecords.RecordBuilder<S> |
Builder for
Record . |
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.