Index (Eclipse Ditto :: Services :: Utils

A

ACTOR_NAME - Static variable in class org.eclipse.ditto.services.utils.search.SubscriptionManager: Name of this actor.
asSubscriber(ActorRef) - Static method in class org.eclipse.ditto.services.utils.search.SubscriptionActor: Wrap a subscription actor as a reactive stream subscriber.

build() - Method in class org.eclipse.ditto.services.utils.search.SearchSourceBuilder: Create a search-source from this builder.

conciergeForwarder(ActorSelection) - Method in class org.eclipse.ditto.services.utils.search.SearchSourceBuilder: Set the concierge forwarder to send commands.
createReceive() - Method in class org.eclipse.ditto.services.utils.search.SubscriptionActor
createReceive() - Method in class org.eclipse.ditto.services.utils.search.SubscriptionManager

dittoHeaders(DittoHeaders) - Method in class org.eclipse.ditto.services.utils.search.SearchSourceBuilder: Set the Ditto headers to use including authorization context and correlation ID.

fields(String) - Method in class org.eclipse.ditto.services.utils.search.SearchSourceBuilder: Set the selected fields of search results from a comma-separated string.
fields(JsonFieldSelector) - Method in class org.eclipse.ditto.services.utils.search.SearchSourceBuilder: Set the selected fields of search results.
filter(String) - Method in class org.eclipse.ditto.services.utils.search.SearchSourceBuilder: Set the filter string of the search command.

lastThingId(String) - Method in class org.eclipse.ditto.services.utils.search.SearchSourceBuilder: Set the last thing ID to resume from.

namespaces(String) - Method in class org.eclipse.ditto.services.utils.search.SearchSourceBuilder: Set the namespaces of the search command from a comma-separated string.
namespaces(JsonArray) - Method in class org.eclipse.ditto.services.utils.search.SearchSourceBuilder: Set the namespaces of the search command.
newBuilder() - Static method in class org.eclipse.ditto.services.utils.search.SearchSource: Create a new builder.

options(String) - Method in class org.eclipse.ditto.services.utils.search.SearchSourceBuilder: Set the sort option and sort fields from the value of the options parameter.
org.eclipse.ditto.services.utils.search - package org.eclipse.ditto.services.utils.search: Encode control flow as data flow through akka streams for modular actor decomposition.

postStop() - Method in class org.eclipse.ditto.services.utils.search.SubscriptionActor
props(Duration, ActorRef, ActorSelection, Materializer) - Static method in class org.eclipse.ditto.services.utils.search.SubscriptionManager: Create Props for a subscription manager.
props(Duration, ActorRef, DittoHeaders) - Static method in class org.eclipse.ditto.services.utils.search.SubscriptionActor: Create Props object for the SubscriptionActor.
pubSubMediator(ActorRef) - Method in class org.eclipse.ditto.services.utils.search.SearchSourceBuilder: Set the pub-sub mediator for error reporting.

searchAskTimeout(Duration) - Method in class org.eclipse.ditto.services.utils.search.SearchSourceBuilder: Set the timeout when asking the search actor.
SearchSource - Class in org.eclipse.ditto.services.utils.search: Source of search results for one query.
SearchSourceBuilder - Class in org.eclipse.ditto.services.utils.search: Builder for SearchSource.
SearchSourceBuilder() - Constructor for class org.eclipse.ditto.services.utils.search.SearchSourceBuilder
sort(String) - Method in class org.eclipse.ditto.services.utils.search.SearchSourceBuilder: Set the sort option as a string with consideration to the default sort option.
sortValues(JsonArray) - Method in class org.eclipse.ditto.services.utils.search.SearchSourceBuilder: Set the sort values for cursor computation.
start(Consumer<ResumeSourceBuilder<?, ?>>) - Method in class org.eclipse.ditto.services.utils.search.SearchSource: Start a source of search results.
startAsPair(Consumer<ResumeSourceBuilder<?, ?>>) - Method in class org.eclipse.ditto.services.utils.search.SearchSource: Start a robust source of search results paired with their IDs.
SubscriptionActor - Class in org.eclipse.ditto.services.utils.search: Actor that translates subscription commands into stream operations and stream signals into subscription events.
SubscriptionManager - Class in org.eclipse.ditto.services.utils.search: Actor that manages search subscriptions for 1 websocket connection or 1 ConnectionPersistenceActor.

thingsAskTimeout(Duration) - Method in class org.eclipse.ditto.services.utils.search.SearchSourceBuilder: Set the timeout when asking the things-shard-region.