Index (Eclipse Ditto :: Services :: Utils

A B C D E F G H L M N O P R S T U V X
All Classes All Packages

A

AbstractActorWithLock - Class in org.eclipse.ditto.services.utils.akka: Actor that can prevent itself from handling messages for a period of time.
AbstractActorWithLock() - Constructor for class org.eclipse.ditto.services.utils.akka.AbstractActorWithLock
AbstractStreamingActor<C,E> - Class in org.eclipse.ditto.services.utils.akka.streaming: Abstract actor that responds to each command by streaming elements from a source to the sender of the command.
AbstractStreamingActor() - Constructor for class org.eclipse.ditto.services.utils.akka.streaming.AbstractStreamingActor

B

batchMessages(List<E>) - Method in class org.eclipse.ditto.services.utils.akka.streaming.AbstractStreamingActor: Batch elements together into 1 message.
become(AbstractActor.Receive) - Method in class org.eclipse.ditto.services.utils.akka.AbstractActorWithLock: Switches the actor's message handler.
become(AbstractActor.Receive, boolean) - Method in class org.eclipse.ditto.services.utils.akka.AbstractActorWithLock: Switches the actor's message handler.

C

calculateStreamTrigger(Instant, Instant, Duration, Duration) - Static method in class org.eclipse.ditto.services.utils.akka.streaming.StreamTrigger: Calculates a StreamTrigger based on the given parameters.
createActorName() - Method in class org.eclipse.ditto.services.utils.akka.PrefixedActorNameFactory: Creates a new prefixed actor name.
createReceive() - Method in class org.eclipse.ditto.services.utils.akka.AbstractActorWithLock
createReceive() - Method in class org.eclipse.ditto.services.utils.akka.streaming.AbstractStreamingActor
createSource(C) - Method in class org.eclipse.ditto.services.utils.akka.streaming.AbstractStreamingActor: Starts a source of elements according to the command.

D

DOES_NOT_HAVE_NEXT_MSG - Static variable in class org.eclipse.ditto.services.utils.akka.streaming.StreamConstants: Message received by stream forwarder to signal that all messages for a stream element have been sent.

E

enhanceLogWithCorrelationId(DiagnosticLoggingAdapter, CharSequence, LogUtil.MdcField...) - Static method in class org.eclipse.ditto.services.utils.akka.LogUtil: Enhances the passed DiagnosticLoggingAdapter with an "MDC" map entry for the passed correlationId (if present).
enhanceLogWithCorrelationId(DiagnosticLoggingAdapter, Optional<String>, LogUtil.MdcField...) - Static method in class org.eclipse.ditto.services.utils.akka.LogUtil: Enhances the passed DiagnosticLoggingAdapter with an "MDC" map entry for the passed correlationId (if present).
enhanceLogWithCorrelationId(DiagnosticLoggingAdapter, DittoHeaders, LogUtil.MdcField...) - Static method in class org.eclipse.ditto.services.utils.akka.LogUtil: Enhances the passed DiagnosticLoggingAdapter with an "MDC" map entry by extracting a correlationId of the passed dittoHeaders (if present).
enhanceLogWithCorrelationId(DiagnosticLoggingAdapter, WithDittoHeaders<?>, LogUtil.MdcField...) - Static method in class org.eclipse.ditto.services.utils.akka.LogUtil: Enhances the passed DiagnosticLoggingAdapter with an "MDC" map entry by extracting a correlationId of the passed withDittoHeaders (if present).
enhanceLogWithCorrelationId(CharSequence) - Static method in class org.eclipse.ditto.services.utils.akka.LogUtil: Enhances the default slf4j MDC with a correlationId.
enhanceLogWithCorrelationId(Optional<String>) - Static method in class org.eclipse.ditto.services.utils.akka.LogUtil: Enhances the default slf4j MDC with a correlationId.
enhanceLogWithCorrelationId(DittoHeaders) - Static method in class org.eclipse.ditto.services.utils.akka.LogUtil: Enhances the default slf4j MDC with a correlationId of the passed dittoHeaders (if present).
enhanceLogWithCorrelationId(WithDittoHeaders<?>) - Static method in class org.eclipse.ditto.services.utils.akka.LogUtil: Enhances the default slf4j MDC with a correlationId of the passed withDittoHeaders (if present).
enhanceLogWithCorrelationIdOrRandom(DittoHeaders) - Static method in class org.eclipse.ditto.services.utils.akka.LogUtil: Enhances the default slf4j MDC with a correlationId of the passed dittoHeaders (if present), else a random correlation ID.
enhanceLogWithCorrelationIdOrRandom(WithDittoHeaders<?>) - Static method in class org.eclipse.ditto.services.utils.akka.LogUtil: Enhances the default slf4j MDC with a correlationId of the passed withDittoHeaders (if present), else a random correlation ID.
enhanceLogWithCustomField(DiagnosticLoggingAdapter, String, CharSequence, LogUtil.MdcField...) - Static method in class org.eclipse.ditto.services.utils.akka.LogUtil: Enhances the passed DiagnosticLoggingAdapter with an "MDC" map entry for the passed fieldName with the passed fieldValue (if present).
enhanceLogWithCustomField(LogUtil.MdcField) - Static method in class org.eclipse.ditto.services.utils.akka.LogUtil: Enhances the default MDC with a map entry for the passed mdcFields.
equals(Object) - Method in class org.eclipse.ditto.services.utils.akka.SimpleCommand
equals(Object) - Method in class org.eclipse.ditto.services.utils.akka.SimpleCommandResponse
equals(Object) - Method in class org.eclipse.ditto.services.utils.akka.streaming.StreamAck
equals(Object) - Method in class org.eclipse.ditto.services.utils.akka.streaming.StreamTrigger

F

failure(String) - Static method in class org.eclipse.ditto.services.utils.akka.streaming.StreamAck: Create an failure ack.
FAILURE - org.eclipse.ditto.services.utils.akka.streaming.StreamAck.Status: Failure status.
FORWARDER_EXCEEDED_MAX_IDLE_TIME_MSG - Static variable in class org.eclipse.ditto.services.utils.akka.streaming.StreamConstants: Message which signals the forwarder stayed idle for too long.
fromJson(String) - Static method in class org.eclipse.ditto.services.utils.akka.SimpleCommand: Creates a new SimpleCommand from a JSON string.
fromJson(String) - Static method in class org.eclipse.ditto.services.utils.akka.SimpleCommandResponse: Creates a new SimpleCommandResponse from a JSON string.
fromJson(JsonObject) - Static method in class org.eclipse.ditto.services.utils.akka.SimpleCommand: Creates a new SimpleCommand from a JSON object.
fromJson(JsonObject) - Static method in class org.eclipse.ditto.services.utils.akka.SimpleCommandResponse: Creates a new SimpleCommandResponse from a JSON object.
fromJson(JsonObject) - Static method in class org.eclipse.ditto.services.utils.akka.streaming.StreamAck: Creates a new StreamAck from a JSON object.

G

getBurst(C) - Method in class org.eclipse.ditto.services.utils.akka.streaming.AbstractStreamingActor: Extract batch size from a command.
getCommandClass() - Method in class org.eclipse.ditto.services.utils.akka.streaming.AbstractStreamingActor
getCommandName() - Method in class org.eclipse.ditto.services.utils.akka.SimpleCommand: Returns the name of the SimpleCommand.
getConfig() - Method in interface org.eclipse.ditto.services.utils.akka.actors.RetrieveConfigBehavior: Get the config.
getCorrelationId() - Static method in class org.eclipse.ditto.services.utils.akka.LogUtil: Gets the correlationId from the default slf4j MDC.
getCorrelationId() - Method in class org.eclipse.ditto.services.utils.akka.SimpleCommand: Returns the optional correlationId of the SimpleCommand.
getCorrelationId() - Method in class org.eclipse.ditto.services.utils.akka.SimpleCommandResponse: Returns the optional correlationId of the SimpleCommandResponse.
getCorrelationId(Supplier<String>) - Static method in class org.eclipse.ditto.services.utils.akka.LogUtil: Gets the correlationId from the default slf4j MDC.
getIdleTimeout(C) - Method in class org.eclipse.ditto.services.utils.akka.streaming.AbstractStreamingActor: Extract idle timeout.
getInitialTimeout(C) - Method in class org.eclipse.ditto.services.utils.akka.streaming.AbstractStreamingActor: Extract initial timeout.
getName() - Method in interface org.eclipse.ditto.services.utils.akka.LogUtil.MdcField: Get the name of the MDC field.
getPayload() - Method in class org.eclipse.ditto.services.utils.akka.SimpleCommand: Returns the optional JSON payload of the SimpleCommand.
getPayload() - Method in class org.eclipse.ditto.services.utils.akka.SimpleCommandResponse: Returns the optional JSON payload of the SimpleCommandResponse.
getPlannedStreamStart() - Method in class org.eclipse.ditto.services.utils.akka.streaming.StreamTrigger: Returns the planned start of the stream.
getQueryEnd() - Method in class org.eclipse.ditto.services.utils.akka.streaming.StreamTrigger: Returns the minimum creation time of the entities to be queried.
getQueryStart() - Method in class org.eclipse.ditto.services.utils.akka.streaming.StreamTrigger: Returns the maximum creation time of the entities to be queried.
getTaggedTimestamp() - Method in interface org.eclipse.ditto.services.utils.akka.streaming.TimestampPersistence: Retrieve the tagged timestamp if any exists in the collection.
getTimestampAsync() - Method in interface org.eclipse.ditto.services.utils.akka.streaming.TimestampPersistence: Retrieve the timestamp in the persistence.
getValue() - Method in interface org.eclipse.ditto.services.utils.akka.LogUtil.MdcField: Get the value of the MDC field.

H

handleMessage() - Method in class org.eclipse.ditto.services.utils.akka.AbstractActorWithLock
hashCode() - Method in class org.eclipse.ditto.services.utils.akka.SimpleCommand
hashCode() - Method in class org.eclipse.ditto.services.utils.akka.SimpleCommandResponse
hashCode() - Method in class org.eclipse.ditto.services.utils.akka.streaming.StreamAck
hashCode() - Method in class org.eclipse.ditto.services.utils.akka.streaming.StreamTrigger

L

log - Variable in class org.eclipse.ditto.services.utils.akka.streaming.AbstractStreamingActor: Logger for this actor.
LogUtil - Class in org.eclipse.ditto.services.utils.akka: Utilities for logging.
LogUtil.MdcField - Interface in org.eclipse.ditto.services.utils.akka: Represents an MDC field that can be added to the MDC of a logger.

M

materializer - Variable in class org.eclipse.ditto.services.utils.akka.streaming.AbstractStreamingActor: Actor materializer of this actor's system.
modifyConfigBehavior() - Method in interface org.eclipse.ditto.services.utils.akka.actors.ModifyConfigBehavior: Injectable behavior to handle ModifyConfig.
ModifyConfigBehavior - Interface in org.eclipse.ditto.services.utils.akka.actors: Behavior to modify this actor's config.

N

newMdcField(String, String) - Static method in class org.eclipse.ditto.services.utils.akka.LogUtil: Creates a new MDC field.

O

obtain(Actor) - Static method in class org.eclipse.ditto.services.utils.akka.LogUtil: Obtain LoggingAdapter with MDC support for the given actor.
of(String) - Static method in class org.eclipse.ditto.services.utils.akka.PrefixedActorNameFactory: Creates a new instance of this factory which generates actor names with the specified prefix.
of(String, String, JsonValue) - Static method in class org.eclipse.ditto.services.utils.akka.SimpleCommand: Returns a new SimpleCommand instance.
of(String, JsonValue) - Static method in class org.eclipse.ditto.services.utils.akka.SimpleCommandResponse: Returns a new SimpleCommandResponse instance.
of(Instant, Instant, Instant) - Static method in class org.eclipse.ditto.services.utils.akka.streaming.StreamTrigger: Constructor.
org.eclipse.ditto.services.utils.akka - package org.eclipse.ditto.services.utils.akka
org.eclipse.ditto.services.utils.akka.actors - package org.eclipse.ditto.services.utils.akka.actors: Common actor behaviors.
org.eclipse.ditto.services.utils.akka.streaming - package org.eclipse.ditto.services.utils.akka.streaming

P

postStop() - Method in class org.eclipse.ditto.services.utils.akka.AbstractActorWithLock
PrefixedActorNameFactory - Class in org.eclipse.ditto.services.utils.akka: Generates prefixed actor names.

R

removeCorrelationId() - Static method in class org.eclipse.ditto.services.utils.akka.LogUtil: Removes the correlationId from the default slf4j MDC.
removeCustomField(DiagnosticLoggingAdapter, String) - Static method in class org.eclipse.ditto.services.utils.akka.LogUtil: Removes the fieldName from the default slf4j MDC.
rescheduleAt(Instant) - Method in class org.eclipse.ditto.services.utils.akka.streaming.StreamTrigger: Reschedules this trigger at newPlannedStreamStart.
retrieveConfigBehavior() - Method in interface org.eclipse.ditto.services.utils.akka.actors.RetrieveConfigBehavior: Injectable behavior to handle RetrieveConfig.
RetrieveConfigBehavior - Interface in org.eclipse.ditto.services.utils.akka.actors: Behavior to respond to RetrieveConfig.

S

setConfig(Config) - Method in interface org.eclipse.ditto.services.utils.akka.actors.ModifyConfigBehavior: Update config for this actor.
setLocked(Duration) - Method in class org.eclipse.ditto.services.utils.akka.AbstractActorWithLock: Prevents this actor from handling messages until it gets unlocked.
setTaggedTimestamp(Instant, String) - Method in interface org.eclipse.ditto.services.utils.akka.streaming.TimestampPersistence: Update the timestamp with a tag.
setTimestamp(Instant) - Method in interface org.eclipse.ditto.services.utils.akka.streaming.TimestampPersistence: Updates the timestamp in the persistence..
SimpleCommand - Class in org.eclipse.ditto.services.utils.akka: Internal simple command which is Jsonifiable, has a command name, an optional correlationId and optionally payload.
SimpleCommand.JsonFields - Class in org.eclipse.ditto.services.utils.akka: An enumeration of the known JsonFieldDefinitions of a SimpleCommand.
SimpleCommandResponse - Class in org.eclipse.ditto.services.utils.akka: Internal simple command response which is Jsonifiable, has an optional correlationId and optionally payload.
SimpleCommandResponse.JsonFields - Class in org.eclipse.ditto.services.utils.akka: An enumeration of the known JsonFieldDefinitions of a SimpleCommandResponse.
STREAM_ACK_MSG - Static variable in class org.eclipse.ditto.services.utils.akka.streaming.StreamConstants: Ack message from AbstractStreamForwarder to AbstractStreamingActor for back-pressure.
STREAM_COMPLETED - Static variable in class org.eclipse.ditto.services.utils.akka.streaming.StreamConstants: Message which signals that a stream has been successfully finished.
STREAM_FAILED - Static variable in class org.eclipse.ditto.services.utils.akka.streaming.StreamConstants: Message to signal upstream failure.
STREAM_STARTED - Static variable in class org.eclipse.ditto.services.utils.akka.streaming.StreamConstants: Message which signals that a stream is started.
StreamAck - Class in org.eclipse.ditto.services.utils.akka.streaming: Ack message that is used for acking elements while streaming.
StreamAck.Status - Enum in org.eclipse.ditto.services.utils.akka.streaming: Status of ACKs.
StreamConstants - Class in org.eclipse.ditto.services.utils.akka.streaming: Constants used for streaming utils.
StreamTrigger - Class in org.eclipse.ditto.services.utils.akka.streaming: Contains timestamps required for triggering a stream.
success(String) - Static method in class org.eclipse.ditto.services.utils.akka.streaming.StreamAck: Create an successful ack.
SUCCESS - org.eclipse.ditto.services.utils.akka.streaming.StreamAck.Status: Success status.

T

TimestampPersistence - Interface in org.eclipse.ditto.services.utils.akka.streaming: Defines operations for managing metadata of streams.
toJson() - Method in class org.eclipse.ditto.services.utils.akka.SimpleCommand
toJson() - Method in class org.eclipse.ditto.services.utils.akka.SimpleCommandResponse
toJson() - Method in class org.eclipse.ditto.services.utils.akka.streaming.StreamAck
toString() - Method in class org.eclipse.ditto.services.utils.akka.SimpleCommand
toString() - Method in class org.eclipse.ditto.services.utils.akka.SimpleCommandResponse
toString() - Method in class org.eclipse.ditto.services.utils.akka.streaming.StreamAck
toString() - Method in class org.eclipse.ditto.services.utils.akka.streaming.StreamTrigger

U

UNKNOWN - org.eclipse.ditto.services.utils.akka.streaming.StreamAck.Status: Status that can be used if status of ack is unknown.
unlock() - Method in class org.eclipse.ditto.services.utils.akka.AbstractActorWithLock: Unlocks this actor to handle messages again.

V

valueOf(String) - Static method in enum org.eclipse.ditto.services.utils.akka.streaming.StreamAck.Status: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.eclipse.ditto.services.utils.akka.streaming.StreamAck.Status: Returns an array containing the constants of this enum type, in the order they are declared.

X

X_CORRELATION_ID - Static variable in class org.eclipse.ditto.services.utils.akka.LogUtil: Name of the Header for the global Ditto correlation ID.

A B C D E F G H L M N O P R S T U V X
All Classes All Packages