Index

A C D E G H L N O P R S T U V W
All Classes and Interfaces|All Packages

A

AbstractDDataProvider() - Constructor for class org.eclipse.ditto.internal.utils.ddata.DistributedData.AbstractDDataProvider

Constructor available for subclasses only.

C

createConfig(ActorSystem, CharSequence, CharSequence) - Static method in class org.eclipse.ditto.internal.utils.ddata.DistributedData

Create a distributed data config with Pekko's default options.

createExtension(ExtendedActorSystem) - Method in class org.eclipse.ditto.internal.utils.ddata.DistributedData.AbstractDDataProvider

D

DefaultDistributedDataConfig - Class in org.eclipse.ditto.internal.utils.ddata

This class is the default implementation of the distributed data config.

DistributedData<R> - Class in org.eclipse.ditto.internal.utils.ddata

Supertype of typed interfaces for distributed data.

DistributedData(DistributedDataConfig, ActorRefFactory, Executor) - Constructor for class org.eclipse.ditto.internal.utils.ddata.DistributedData

Create a wrapper of distributed data replicator.

DistributedData.AbstractDDataProvider<R,T> - Class in org.eclipse.ditto.internal.utils.ddata

Extension provider for Ditto distributed data.

DistributedDataConfig - Interface in org.eclipse.ditto.internal.utils.ddata

Provides configuration settings for DistributedData.

DistributedDataConfig.DistributedDataConfigValue - Enum Class in org.eclipse.ditto.internal.utils.ddata

An enumeration of the known config path expressions and their associated default values for DistributedDataConfig.

E

equals(Object) - Method in class org.eclipse.ditto.internal.utils.ddata.DefaultDistributedDataConfig

G

get(Key<R>, Replicator.ReadConsistency) - Method in class org.eclipse.ditto.internal.utils.ddata.DistributedData

Asynchronously retrieves the replicated data.

getCompleteConfig() - Method in interface org.eclipse.ditto.internal.utils.ddata.PekkoReplicatorConfig

Gets the complete Pekko distributed-data config to use for the Replicator.

getConfig() - Method in class org.eclipse.ditto.internal.utils.ddata.DistributedData

Get the config of this distributed data.

getConfigPath() - Method in enum class org.eclipse.ditto.internal.utils.ddata.DistributedDataConfig.DistributedDataConfigValue

getConfigPath() - Method in enum class org.eclipse.ditto.internal.utils.ddata.PekkoReplicatorConfig.PekkoReplicatorConfigValue

getDefaultValue() - Method in enum class org.eclipse.ditto.internal.utils.ddata.DistributedDataConfig.DistributedDataConfigValue

getDefaultValue() - Method in enum class org.eclipse.ditto.internal.utils.ddata.PekkoReplicatorConfig.PekkoReplicatorConfigValue

getGossipInterval() - Method in interface org.eclipse.ditto.internal.utils.ddata.PekkoReplicatorConfig

Returns the interval with which cluster members initiate gossip.

getInitialValue() - Method in class org.eclipse.ditto.internal.utils.ddata.DistributedData

getKey(int) - Method in class org.eclipse.ditto.internal.utils.ddata.DistributedData

Creates/gets a key for the passed shardNumber.

getName() - Method in interface org.eclipse.ditto.internal.utils.ddata.PekkoReplicatorConfig

Returns the name of the replicator.

getNotifySubscribersInterval() - Method in interface org.eclipse.ditto.internal.utils.ddata.PekkoReplicatorConfig

Returns the interval subscribers are notified.

getNumberOfShards() - Method in class org.eclipse.ditto.internal.utils.ddata.DefaultDistributedDataConfig

getNumberOfShards() - Method in interface org.eclipse.ditto.internal.utils.ddata.DistributedDataConfig

The number of shards Ditto's ddata extension applies for Map keys.

getPekkoReplicatorConfig() - Method in class org.eclipse.ditto.internal.utils.ddata.DefaultDistributedDataConfig

getPekkoReplicatorConfig() - Method in interface org.eclipse.ditto.internal.utils.ddata.DistributedDataConfig

Returns the config to use for creating the Replicator.

getReadTimeout() - Method in class org.eclipse.ditto.internal.utils.ddata.DefaultDistributedDataConfig

getReadTimeout() - Method in interface org.eclipse.ditto.internal.utils.ddata.DistributedDataConfig

Returns the timeout of GET-messages of the replicator.

getReplicator() - Method in class org.eclipse.ditto.internal.utils.ddata.DistributedData

getRole() - Method in interface org.eclipse.ditto.internal.utils.ddata.PekkoReplicatorConfig

Returns the cluster role of members with replicas of the distributed collection.

getSubscriberPoolSize() - Method in class org.eclipse.ditto.internal.utils.ddata.DefaultDistributedDataConfig

getSubscriberPoolSize() - Method in interface org.eclipse.ditto.internal.utils.ddata.DistributedDataConfig

The number of subscribers in each subscriber pool.

getSubscriptionDelay() - Method in class org.eclipse.ditto.internal.utils.ddata.DefaultDistributedDataConfig

getSubscriptionDelay() - Method in interface org.eclipse.ditto.internal.utils.ddata.DistributedDataConfig

Returns the delay for subscriptions.

getSubscriptionWriteConsistency() - Method in class org.eclipse.ditto.internal.utils.ddata.DefaultDistributedDataConfig

getSubscriptionWriteConsistency() - Method in interface org.eclipse.ditto.internal.utils.ddata.DistributedDataConfig

Returns the write consistency for topic subscription.

getWriteTimeout() - Method in class org.eclipse.ditto.internal.utils.ddata.DefaultDistributedDataConfig

getWriteTimeout() - Method in interface org.eclipse.ditto.internal.utils.ddata.DistributedDataConfig

Returns the timeout of UPDATE-messages of the replicator.

GOSSIP_INTERVAL - Enum constant in enum class org.eclipse.ditto.internal.utils.ddata.PekkoReplicatorConfig.PekkoReplicatorConfigValue

How often distributed data changes are deseminated in the cluster.

H

hashCode() - Method in class org.eclipse.ditto.internal.utils.ddata.DefaultDistributedDataConfig

L

lookup() - Method in class org.eclipse.ditto.internal.utils.ddata.DistributedData.AbstractDDataProvider

Lookup an extension provider to load an extension from config on actor system startup.

N

NAME - Enum constant in enum class org.eclipse.ditto.internal.utils.ddata.PekkoReplicatorConfig.PekkoReplicatorConfigValue

The name to be used for the Replicator.

NOTIFY_SUBSCRIBERS_INTERVAL - Enum constant in enum class org.eclipse.ditto.internal.utils.ddata.PekkoReplicatorConfig.PekkoReplicatorConfigValue

the interval subscribers are notified.

NUMBER_OF_SHARDS - Enum constant in enum class org.eclipse.ditto.internal.utils.ddata.DistributedDataConfig.DistributedDataConfigValue

The number of shards Ditto's ddata extension applies for Map keys.

numberOfShards - Variable in class org.eclipse.ditto.internal.utils.ddata.DistributedData

O

of(Config) - Static method in class org.eclipse.ditto.internal.utils.ddata.DefaultDistributedDataConfig

Returns an instance of DefaultDistributedDataConfig based on the settings of the specified Config.

of(Config, CharSequence, CharSequence) - Static method in class org.eclipse.ditto.internal.utils.ddata.DefaultDistributedDataConfig

Returns an instance of DefaultDistributedDataConfig based on the settings of the specified Config.

org.eclipse.ditto.internal.utils.ddata - package org.eclipse.ditto.internal.utils.ddata

P

PekkoReplicatorConfig - Interface in org.eclipse.ditto.internal.utils.ddata

Provides configuration settings for the Pekko Replicator.

PekkoReplicatorConfig.PekkoReplicatorConfigValue - Enum Class in org.eclipse.ditto.internal.utils.ddata

An enumeration of the known config path expressions and their associated default values for PekkoReplicatorConfig.

R

READ_TIMEOUT - Enum constant in enum class org.eclipse.ditto.internal.utils.ddata.DistributedDataConfig.DistributedDataConfigValue

The read timeout duration: the timeout of GET-messages of the replicator.

readTimeout - Variable in class org.eclipse.ditto.internal.utils.ddata.DistributedData

Default timeout of read operations.

replicator - Variable in class org.eclipse.ditto.internal.utils.ddata.DistributedData

Reference of the distributed data replicator.

ROLE - Enum constant in enum class org.eclipse.ditto.internal.utils.ddata.PekkoReplicatorConfig.PekkoReplicatorConfigValue

The role to be used for the Replicator.

S

subscribeForChanges(ActorRef) - Method in class org.eclipse.ditto.internal.utils.ddata.DistributedData

Request updates when the distributed data changes.

SUBSCRIBER_POOL_SIZE - Enum constant in enum class org.eclipse.ditto.internal.utils.ddata.DistributedDataConfig.DistributedDataConfigValue

The number of subscribers in each subscriber pool.

SUBSCRIPTION_DELAY - Enum constant in enum class org.eclipse.ditto.internal.utils.ddata.DistributedDataConfig.DistributedDataConfigValue

Local delay for topic subscription to account for replication and notification delay.

SUBSCRIPTION_WRITE_CONSISTENCY - Enum constant in enum class org.eclipse.ditto.internal.utils.ddata.DistributedDataConfig.DistributedDataConfigValue

The write consistency of subscriptions.

T

toString() - Method in class org.eclipse.ditto.internal.utils.ddata.DefaultDistributedDataConfig

U

update(Key<R>, Replicator.WriteConsistency, Function<R, R>) - Method in class org.eclipse.ditto.internal.utils.ddata.DistributedData

Modify the replicated data.

V

valueOf(String) - Static method in enum class org.eclipse.ditto.internal.utils.ddata.DistributedDataConfig.DistributedDataConfigValue

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class org.eclipse.ditto.internal.utils.ddata.PekkoReplicatorConfig.PekkoReplicatorConfigValue

Returns the enum constant of this class with the specified name.

values() - Static method in enum class org.eclipse.ditto.internal.utils.ddata.DistributedDataConfig.DistributedDataConfigValue

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class org.eclipse.ditto.internal.utils.ddata.PekkoReplicatorConfig.PekkoReplicatorConfigValue

Returns an array containing the constants of this enum class, in the order they are declared.

W

WRITE_TIMEOUT - Enum constant in enum class org.eclipse.ditto.internal.utils.ddata.DistributedDataConfig.DistributedDataConfigValue

The write timeout duration: the timeout of UPDATE-messages of the replicator.

writeTimeout - Variable in class org.eclipse.ditto.internal.utils.ddata.DistributedData

Default timeout of write operations.

A C D E G H L N O P R S T U V W
All Classes and Interfaces|All Packages