A B C D E F G H I L O R S T W 
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 EntityIdWithRevision batched 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 SudoStreamSnapshotRevisions from a JSON object.
fromJson(JsonObject, DittoHeaders) - Static method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
Creates a new SudoStreamSnapshots from 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 BatchedEntityIdWithRevisions object.
of(Integer, Long, List<String>, DittoHeaders, EntityType) - Static method in class org.eclipse.ditto.internal.models.streaming.SudoStreamSnapshots
Creates a new SudoStreamSnapshots command.
of(Integer, Long, DittoHeaders, EntityType) - Static method in class org.eclipse.ditto.internal.models.streaming.SudoStreamPids
Creates a new SudoStreamPids command.
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.
A B C D E F G H I L O R S T W 
All Classes All Packages