A B C D E F G H I L O R S T W
All Classes All Packages
All Classes All Packages
All Classes All Packages
A
- AbstractEntityIdWithRevision<I extends org.eclipse.ditto.base.model.entity.id.EntityId> - Class in org.eclipse.ditto.internal.models.streaming
-
Abstract base implementation of
EntityIdWithRevision. - AbstractEntityIdWithRevision(I, long) - Constructor for class org.eclipse.ditto.internal.models.streaming.AbstractEntityIdWithRevision
- appendPayload(JsonObjectBuilder, JsonSchemaVersion, Predicate<JsonField>) - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamPids
- appendPayload(JsonObjectBuilder, JsonSchemaVersion, Predicate<JsonField>) - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
- asIdentifierString() - Method in interface org.eclipse.ditto.internal.models.streaming.EntityIdWithRevision
-
Returns this tag as an identifier in the format
<id>:<revision>. - asIdentifierString() - Method in interface org.eclipse.ditto.internal.models.streaming.IdentifiableStreamingMessage
-
Returns an identifier for this message.
B
- BatchedEntityIdWithRevisions<E extends EntityIdWithRevision<?>> - Class in org.eclipse.ditto.internal.models.streaming
-
A list of
EntityIdWithRevisionbatched together.
C
- canEqual(Object) - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamPids
- canEqual(Object) - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
D
- deserializer(Function<JsonObject, T>) - Static method in class org.eclipse.ditto.internal.models.streaming.BatchedEntityIdWithRevisions
-
Create a deserializer from a deserializer of the elements.
E
- empty(EntityType) - Static method in class org.eclipse.ditto.internal.models.streaming.LowerBound
- emptyEntityId(EntityType) - Static method in class org.eclipse.ditto.internal.models.streaming.LowerBound
- ENTITY_ID - Static variable in class org.eclipse.ditto.internal.models.streaming.EntityIdWithRevision.JsonFields
-
JSON field containing the message's ID.
- ENTITY_TYPE - Static variable in class org.eclipse.ditto.internal.models.streaming.EntityIdWithRevision.JsonFields
-
JSON field containing the message's entity type.
- EntityIdWithRevision<I extends org.eclipse.ditto.base.model.entity.id.EntityId> - Interface in org.eclipse.ditto.internal.models.streaming
-
Represents the ID of an entity with a revision of the entity.
- EntityIdWithRevision.JsonFields - Class in org.eclipse.ditto.internal.models.streaming
-
An enumeration of the known
JsonFields of a EntityIdWithRevision. - equals(Object) - Method in class org.eclipse.ditto.internal.models.streaming.AbstractEntityIdWithRevision
- equals(Object) - Method in class org.eclipse.ditto.internal.models.streaming.BatchedEntityIdWithRevisions
- equals(Object) - Method in class org.eclipse.ditto.internal.models.streaming.StreamedSnapshot
- equals(Object) - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamPids
- equals(Object) - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
F
- fromJson(JsonObject) - Static method in class org.eclipse.ditto.internal.models.streaming.LowerBound
- fromJson(JsonObject) - Static method in class org.eclipse.ditto.internal.models.streaming.StreamedSnapshot
-
Deserialize a streamed snapshot from JSON.
- fromJson(JsonObject, DittoHeaders) - Static method in class org.eclipse.ditto.internal.models.streaming.SudoStreamPids
-
Creates a new
SudoStreamSnapshotRevisionsfrom a JSON object. - fromJson(JsonObject, DittoHeaders) - Static method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
-
Creates a new
SudoStreamSnapshotsfrom a JSON object.
G
- getBurst() - Method in interface org.eclipse.ditto.internal.models.streaming.StartStreamRequest
-
Returns the streaming burst.
- getBurst() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamPids
- getBurst() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
- getCategory() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamPids
- getCategory() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
- getElements() - Method in class org.eclipse.ditto.internal.models.streaming.BatchedEntityIdWithRevisions
-
Retrieve the elements.
- getEntityId() - Method in class org.eclipse.ditto.internal.models.streaming.AbstractEntityIdWithRevision
- getEntityId() - Method in interface org.eclipse.ditto.internal.models.streaming.EntityIdWithRevision
-
Returns the Entity ID of the modified entity.
- getEntityId() - Method in class org.eclipse.ditto.internal.models.streaming.StreamedSnapshot
-
Retrieve the entity ID of the streamed snapshot.
- getLowerBound() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamPids
-
Return the lower-bound PID to resume a stream.
- getLowerBound() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
-
Return the lower-bound PID to resume a stream.
- getManifest() - Method in class org.eclipse.ditto.internal.models.streaming.BatchedEntityIdWithRevisions
- getResourcePath() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamPids
- getResourcePath() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
- getResourceType() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamPids
- getResourceType() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
- getRevision() - Method in class org.eclipse.ditto.internal.models.streaming.AbstractEntityIdWithRevision
- getRevision() - Method in interface org.eclipse.ditto.internal.models.streaming.EntityIdWithRevision
-
Returns the revision of the modified entity.
- getSnapshot() - Method in class org.eclipse.ditto.internal.models.streaming.StreamedSnapshot
-
Retrieve the snapshot as JSON object.
- getSnapshotFields() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
-
Return snapshot fields to request for each streamed snapshot.
- getTimeoutMillis() - Method in interface org.eclipse.ditto.internal.models.streaming.StartStreamRequest
-
Returns the timeout in milliseconds.
- getTimeoutMillis() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamPids
- getTimeoutMillis() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
- getTypePrefix() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamPids
- getTypePrefix() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
H
- hashCode() - Method in class org.eclipse.ditto.internal.models.streaming.AbstractEntityIdWithRevision
- hashCode() - Method in class org.eclipse.ditto.internal.models.streaming.BatchedEntityIdWithRevisions
- hashCode() - Method in class org.eclipse.ditto.internal.models.streaming.StreamedSnapshot
- hashCode() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamPids
- hashCode() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
- hasNonEmptyLowerBound() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamPids
-
Return whether the command has a non-empty lower bound.
- hasNonEmptyLowerBound() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
-
Return whether the command has a non-empty lower bound.
I
- IdentifiableStreamingMessage - Interface in org.eclipse.ditto.internal.models.streaming
-
Represents an identifiable Streaming message (identifier is required to correlate acknowledgements).
L
- LowerBound - Class in org.eclipse.ditto.internal.models.streaming
-
Special Entity ID's (with Revision).
O
- of(Class<T>, List<T>) - Static method in class org.eclipse.ditto.internal.models.streaming.BatchedEntityIdWithRevisions
-
Create a
BatchedEntityIdWithRevisionsobject. - of(Integer, Long, List<String>, DittoHeaders, EntityType) - Static method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
-
Creates a new
SudoStreamSnapshotscommand. - of(Integer, Long, DittoHeaders, EntityType) - Static method in class org.eclipse.ditto.internal.models.streaming.SudoStreamPids
-
Creates a new
SudoStreamPidscommand. - of(EntityId, JsonObject) - Static method in class org.eclipse.ditto.internal.models.streaming.StreamedSnapshot
-
Create a streamed snapshot from entity ID and snapshot as JSON object.
- org.eclipse.ditto.internal.models.streaming - package org.eclipse.ditto.internal.models.streaming
-
Contains interfaces and classes for authorization.
R
- REVISION - Static variable in class org.eclipse.ditto.internal.models.streaming.EntityIdWithRevision.JsonFields
-
JSON field containing the message's revision.
S
- setDittoHeaders(DittoHeaders) - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamPids
- setDittoHeaders(DittoHeaders) - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
- StartStreamRequest - Interface in org.eclipse.ditto.internal.models.streaming
-
Supertype of commands to request the start of a stream.
- StreamedSnapshot - Class in org.eclipse.ditto.internal.models.streaming
-
Serializable message for streamed snapshots.
- StreamingMessage - Interface in org.eclipse.ditto.internal.models.streaming
-
Marker interface for streaming-related messages.
- SudoStreamPids - Class in org.eclipse.ditto.internal.models.streaming
-
Command which starts a stream of persistence IDs with their latest snapshot revisions.
- SudoStreamSnapshots - Class in org.eclipse.ditto.internal.models.streaming
-
Command which starts a stream of snapshots.
T
- toJson() - Method in class org.eclipse.ditto.internal.models.streaming.AbstractEntityIdWithRevision
- toJson() - Method in class org.eclipse.ditto.internal.models.streaming.BatchedEntityIdWithRevisions
- toJson() - Method in class org.eclipse.ditto.internal.models.streaming.StreamedSnapshot
- toString() - Method in class org.eclipse.ditto.internal.models.streaming.AbstractEntityIdWithRevision
- toString() - Method in class org.eclipse.ditto.internal.models.streaming.BatchedEntityIdWithRevisions
- toString() - Method in class org.eclipse.ditto.internal.models.streaming.StreamedSnapshot
- toString() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamPids
- toString() - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
- TYPE - Static variable in class org.eclipse.ditto.internal.models.streaming.SudoStreamPids
-
Type of this command.
- TYPE - Static variable in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
-
Type of this command.
- TYPE_PREFIX - Static variable in interface org.eclipse.ditto.internal.models.streaming.StreamingMessage
-
Type Prefix of streaming messages - used to avoid overlaps with messages from other modules/services.
- typeOf(Class<T>) - Static method in class org.eclipse.ditto.internal.models.streaming.BatchedEntityIdWithRevisions
-
Create a type name for the JSON deserializer based on the type of elements.
W
- withLowerBound(EntityId) - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
-
Create a copy of this command with a lower-bound set.
- withLowerBound(EntityIdWithRevision<?>) - Method in class org.eclipse.ditto.internal.models.streaming.SudoStreamPids
-
Create a copy of this command with a lower-bound set.
All Classes All Packages