Index

A B C D E F G H I J L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values

A

AbstractBackgroundStreamingActorWithConfigWithStatusReport<C extends BackgroundStreamingConfig> - Class in org.eclipse.ditto.internal.utils.health

Common behavior for actors that stay alive for a long time running a stream over and over.

AbstractBackgroundStreamingActorWithConfigWithStatusReport(C) - Constructor for class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport

Initialize the actor with a background streaming config.

AbstractBackgroundStreamingActorWithConfigWithStatusReport.Event - Interface in org.eclipse.ditto.internal.utils.health

Event to report.

AbstractBackgroundStreamingActorWithConfigWithStatusReport.StreamTerminated - Class in org.eclipse.ditto.internal.utils.health

Event for when a stream terminated.

AbstractBackgroundStreamingActorWithConfigWithStatusReport.WokeUp - Class in org.eclipse.ditto.internal.utils.health

Event for when a stream started.

AbstractHealthCheckingActor - Class in org.eclipse.ditto.internal.utils.health

Abstract base implementations for actors which check the health of a subsystem.

AbstractHealthCheckingActor() - Constructor for class org.eclipse.ditto.internal.utils.health.AbstractHealthCheckingActor

ACTOR_NAME - Static variable in class org.eclipse.ditto.internal.utils.health.AbstractHealthCheckingActor

The required actor name of the Actor to be created in the ActorSystem.

ACTOR_NAME - Static variable in class org.eclipse.ditto.internal.utils.health.DefaultHealthCheckingActorFactory

The actor name of the Actor to be created in the ActorSystem.

ACTOR_NAME - Static variable in class org.eclipse.ditto.internal.utils.health.status.StatusSupplierActor

The name of this Actor in the ActorSystem.

addDetail(StatusDetailMessage) - Method in class org.eclipse.ditto.internal.utils.health.StatusInfo

Creates a new StatusInfo from this StatusInfo, extended with the specified detail.

appendPayload(JsonObjectBuilder, JsonSchemaVersion, Predicate<JsonField>) - Method in class org.eclipse.ditto.internal.utils.health.ResetHealthEvents

appendPayload(JsonObjectBuilder, JsonSchemaVersion, Predicate<JsonField>) - Method in class org.eclipse.ditto.internal.utils.health.ResetHealthEventsResponse

appendPayload(JsonObjectBuilder, JsonSchemaVersion, Predicate<JsonField>) - Method in class org.eclipse.ditto.internal.utils.health.RetrieveHealth

appendPayload(JsonObjectBuilder, JsonSchemaVersion, Predicate<JsonField>) - Method in class org.eclipse.ditto.internal.utils.health.RetrieveHealthResponse

B

BackgroundStreamingConfig - Interface in org.eclipse.ditto.internal.utils.health.config

Configuration for background streaming behavior.

BasicHealthCheckConfig - Interface in org.eclipse.ditto.internal.utils.health.config

Provides configuration settings for Ditto's runtime health checking behaviour.

BasicHealthCheckConfig.HealthCheckConfigValue - Enum Class in org.eclipse.ditto.internal.utils.health.config

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

build() - Method in class org.eclipse.ditto.internal.utils.health.HealthCheckingActorOptions.Builder

Builds the HealthCheckingActorOptions object.

Builder(boolean, Duration) - Constructor for class org.eclipse.ditto.internal.utils.health.HealthCheckingActorOptions.Builder

Constructs a new Builder object.

buildStatusRoute() - Method in class org.eclipse.ditto.internal.utils.health.routes.StatusRoute

Builds the /status route.

C

ClusterRoleStatus - Class in org.eclipse.ditto.internal.utils.health.cluster

Holds the status of a specific pekko cluster role.

ClusterStatus - Class in org.eclipse.ditto.internal.utils.health.cluster

Holds the status of the pekko cluster.

composite(List<StatusInfo>) - Static method in class org.eclipse.ditto.internal.utils.health.StatusInfo

Returns a new StatusInfo instance with the specified children.

composite(Map<String, StatusInfo>) - Static method in class org.eclipse.ditto.internal.utils.health.StatusInfo

Returns a new StatusInfo instance with the specified labeledChildren.

CompositeCachingHealthCheckingActor - Class in org.eclipse.ditto.internal.utils.health

Actor which provides the health of multiple underlying systems, such as messaging and persistence by aggregating the health by means of child actors.

config - Variable in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport

Modifiable config to control this actor.

createReceive() - Method in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport

createReceive() - Method in class org.eclipse.ditto.internal.utils.health.AbstractHealthCheckingActor

createReceive() - Method in class org.eclipse.ditto.internal.utils.health.status.StatusSupplierActor

CurrentMongoStatus - Class in org.eclipse.ditto.internal.utils.health.mongo

Reflects the currently determined MongoDB health status.

CurrentMongoStatus(boolean) - Constructor for class org.eclipse.ditto.internal.utils.health.mongo.CurrentMongoStatus

Constructs a new CurrentMongoStatus object.

CurrentMongoStatus(boolean, String) - Constructor for class org.eclipse.ditto.internal.utils.health.mongo.CurrentMongoStatus

Constructs a new CurrentMongoStatus object.

D

DEFAULT - Static variable in enum class org.eclipse.ditto.internal.utils.health.StatusDetailMessage.Level

DefaultBasicHealthCheckConfig - Class in org.eclipse.ditto.internal.utils.health.config

This class is the default implementation which provides the basic settings of health checking.

DefaultHealthCheckConfig - Class in org.eclipse.ditto.internal.utils.health.config

This class is the default implementation of HealthCheckConfig.

DefaultHealthCheckingActorFactory - Class in org.eclipse.ditto.internal.utils.health

Provides an actor for checking and caching the health of a ditto service.

DefaultMetricsReporterConfig - Class in org.eclipse.ditto.internal.utils.health.config

This class is the default implementation of the health check persistence metrics-reporter config.

DefaultPersistenceConfig - Class in org.eclipse.ditto.internal.utils.health.config

This class is the default implementation of the health check persistence config.

DOWN - Enum constant in enum class org.eclipse.ditto.internal.utils.health.StatusInfo.Status

Signals the application is down.

E

ENABLED - Enum constant in enum class org.eclipse.ditto.internal.utils.health.config.BasicHealthCheckConfig.HealthCheckConfigValue

Determines whether global health checking should be enabled.

ENABLED - Enum constant in enum class org.eclipse.ditto.internal.utils.health.config.PersistenceConfig.PersistenceConfigValue

Determines whether the persistence health check should be enabled.

enablePersistenceCheck() - Method in class org.eclipse.ditto.internal.utils.health.HealthCheckingActorOptions.Builder

Enables the health check for the persistence.

enqueue(Deque<Pair<Instant, T>>, T, int) - Static method in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport

Enqueue an element into a deque of bounded size.

equals(Object) - Method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterRoleStatus

equals(Object) - Method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterStatus

equals(Object) - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultBasicHealthCheckConfig

equals(Object) - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultHealthCheckConfig

equals(Object) - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultMetricsReporterConfig

equals(Object) - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultPersistenceConfig

equals(Object) - Method in class org.eclipse.ditto.internal.utils.health.HealthCheckingActorOptions

equals(Object) - Method in class org.eclipse.ditto.internal.utils.health.mongo.CurrentMongoStatus

equals(Object) - Method in class org.eclipse.ditto.internal.utils.health.ResetHealthEventsResponse

equals(Object) - Method in class org.eclipse.ditto.internal.utils.health.RetrieveHealthResponse

equals(Object) - Method in class org.eclipse.ditto.internal.utils.health.StatusDetailMessage

equals(Object) - Method in class org.eclipse.ditto.internal.utils.health.StatusInfo

ERROR - Enum constant in enum class org.eclipse.ditto.internal.utils.health.StatusDetailMessage.Level

F

fromDetail(StatusDetailMessage) - Static method in class org.eclipse.ditto.internal.utils.health.StatusInfo

Returns a new StatusInfo instance with the specified detail.

fromDetails(Collection<StatusDetailMessage>) - Static method in class org.eclipse.ditto.internal.utils.health.StatusInfo

Returns a new StatusInfo instance with the specified details.

fromJson(String) - Static method in class org.eclipse.ditto.internal.utils.health.StatusInfo

Creates a new StatusInfo from a JSON string.

fromJson(JsonObject) - Static method in class org.eclipse.ditto.internal.utils.health.StatusDetailMessage

Creates a new StatusDetailMessage from a JSON object.

fromJson(JsonObject) - Static method in class org.eclipse.ditto.internal.utils.health.StatusInfo

Creates a new StatusInfo from a JSON object.

fromJson(JsonObject, DittoHeaders) - Static method in class org.eclipse.ditto.internal.utils.health.ResetHealthEvents

Creates a new RetrieveHealth command from the given JSON object.

fromJson(JsonObject, DittoHeaders) - Static method in class org.eclipse.ditto.internal.utils.health.ResetHealthEventsResponse

Create a ResetHealthEventsResponse from its JSON representation.

fromJson(JsonObject, DittoHeaders) - Static method in class org.eclipse.ditto.internal.utils.health.RetrieveHealth

Creates a new RetrieveHealth command from the given JSON object.

fromJson(JsonObject, DittoHeaders) - Static method in class org.eclipse.ditto.internal.utils.health.RetrieveHealthResponse

Create a RetrieveHealthResponse from its JSON representation.

fromStatus(StatusInfo.Status) - Static method in class org.eclipse.ditto.internal.utils.health.StatusInfo

Returns a new StatusInfo instance with the specified status.

fromStatus(StatusInfo.Status, String) - Static method in class org.eclipse.ditto.internal.utils.health.StatusInfo

Returns a new StatusInfo instance with the specified status and message.

fromStatus(StatusInfo.Status, Collection<StatusDetailMessage>) - Static method in class org.eclipse.ditto.internal.utils.health.StatusInfo

Returns a new StatusInfo instance with the specified status and details.

G

get() - Method in class org.eclipse.ditto.internal.utils.health.HealthRouteSupplier

getBuilder(boolean, Duration) - Static method in class org.eclipse.ditto.internal.utils.health.HealthCheckingActorOptions

Returns a Builder to build a HealthCheckActorOptions object.

getCategory() - Method in class org.eclipse.ditto.internal.utils.health.ResetHealthEvents

getCategory() - Method in class org.eclipse.ditto.internal.utils.health.RetrieveHealth

getChildren() - Method in class org.eclipse.ditto.internal.utils.health.StatusInfo

Returns the children.

getConfig() - Method in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport

getConfig() - Method in interface org.eclipse.ditto.internal.utils.health.config.BackgroundStreamingConfig

Return the config in HOCON format.

getConfigPath() - Method in enum class org.eclipse.ditto.internal.utils.health.config.BasicHealthCheckConfig.HealthCheckConfigValue

getConfigPath() - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultBasicHealthCheckConfig

getConfigPath() - Method in enum class org.eclipse.ditto.internal.utils.health.config.MetricsReporterConfig.MetricsReporterConfigValue

getConfigPath() - Method in enum class org.eclipse.ditto.internal.utils.health.config.PersistenceConfig.PersistenceConfigValue

getDefaultValue() - Method in enum class org.eclipse.ditto.internal.utils.health.config.BasicHealthCheckConfig.HealthCheckConfigValue

getDefaultValue() - Method in enum class org.eclipse.ditto.internal.utils.health.config.MetricsReporterConfig.MetricsReporterConfigValue

getDefaultValue() - Method in enum class org.eclipse.ditto.internal.utils.health.config.PersistenceConfig.PersistenceConfigValue

getDescription() - Method in class org.eclipse.ditto.internal.utils.health.mongo.CurrentMongoStatus

Returns an optional description why it is alive/not alive.

getDetails() - Method in class org.eclipse.ditto.internal.utils.health.StatusInfo

Returns the details.

getEventStream() - Method in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport

getHealth() - Method in class org.eclipse.ditto.internal.utils.health.AbstractHealthCheckingActor

getHealthCheckConfig() - Method in interface org.eclipse.ditto.internal.utils.health.config.WithHealthCheckConfig

Returns the health check configuration of this service.

getHistory() - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultMetricsReporterConfig

getHistory() - Method in interface org.eclipse.ditto.internal.utils.health.config.MetricsReporterConfig

Returns how many historical items to keep.

getInterval() - Method in interface org.eclipse.ditto.internal.utils.health.config.BasicHealthCheckConfig

Returns the interval of health check.

getInterval() - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultBasicHealthCheckConfig

getInterval() - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultHealthCheckConfig

getInterval() - Method in class org.eclipse.ditto.internal.utils.health.HealthCheckingActorOptions

Returns the persistence check interval.

getKeptEvents() - Method in interface org.eclipse.ditto.internal.utils.health.config.BackgroundStreamingConfig

Returns how many events to keep in the actor state.

getLabel() - Method in class org.eclipse.ditto.internal.utils.health.StatusInfo

Returns the (optional) label.

getLeader() - Method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterRoleStatus

Returns the optional leader for the given role.

getLeader() - Method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterStatus

Returns the optional leader.

getLevel() - Method in class org.eclipse.ditto.internal.utils.health.StatusDetailMessage

getMessage() - Method in class org.eclipse.ditto.internal.utils.health.StatusDetailMessage

getMetricsReporterConfig() - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultPersistenceConfig

getMetricsReporterConfig() - Method in interface org.eclipse.ditto.internal.utils.health.config.PersistenceConfig

Returns the configuration settings of the metrics reporter.

getMostSevereLevelFromEvents(Deque<Pair<Instant, AbstractBackgroundStreamingActorWithConfigWithStatusReport.Event>>) - Method in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport

Get the most severe log level from events.

getOwnRoles() - Method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterStatus

Returns a list of the roles this member has.

getPersistenceConfig() - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultHealthCheckConfig

getPersistenceConfig() - Method in interface org.eclipse.ditto.internal.utils.health.config.WithPersistenceConfig

Returns the configuration settings of the health check persistence.

getQuietPeriod() - Method in interface org.eclipse.ditto.internal.utils.health.config.BackgroundStreamingConfig

Returns how long to wait between streams.

getReachable() - Method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterRoleStatus

Returns a list of all reachable members for the given role.

getReachable() - Method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterStatus

Returns a list of all reachable members.

getResolution() - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultMetricsReporterConfig

getResolution() - Method in interface org.eclipse.ditto.internal.utils.health.config.MetricsReporterConfig

Returns the resolution how far apart each measurement should be done.

getResourcePath() - Method in class org.eclipse.ditto.internal.utils.health.ResetHealthEvents

getResourcePath() - Method in class org.eclipse.ditto.internal.utils.health.ResetHealthEventsResponse

getResourcePath() - Method in class org.eclipse.ditto.internal.utils.health.RetrieveHealth

getResourcePath() - Method in class org.eclipse.ditto.internal.utils.health.RetrieveHealthResponse

getResourceType() - Method in class org.eclipse.ditto.internal.utils.health.ResetHealthEvents

getResourceType() - Method in class org.eclipse.ditto.internal.utils.health.ResetHealthEventsResponse

getResourceType() - Method in class org.eclipse.ditto.internal.utils.health.RetrieveHealth

getResourceType() - Method in class org.eclipse.ditto.internal.utils.health.RetrieveHealthResponse

getRole() - Method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterRoleStatus

Returns the cluster role.

getRoles() - Method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterStatus

Returns the status of each cluster roles members.

getSeenBy() - Method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterStatus

Returns a list of all members that have seen this cluster state.

getSource() - Method in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport

Get the stream that should be restarted again and again in the background as a source of whatever to be followed by a kill switch and a sink that ignores all elements.

getStatus() - Method in class org.eclipse.ditto.internal.utils.health.StatusInfo

Returns the Status.

getStatusInfo() - Method in class org.eclipse.ditto.internal.utils.health.RetrieveHealthResponse

Return the status info.

getTimeout() - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultPersistenceConfig

getTimeout() - Method in interface org.eclipse.ditto.internal.utils.health.config.PersistenceConfig

Returns the timeout of the health check for persistence.

getTypePrefix() - Method in class org.eclipse.ditto.internal.utils.health.ResetHealthEvents

getTypePrefix() - Method in class org.eclipse.ditto.internal.utils.health.RetrieveHealth

getUnreachable() - Method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterRoleStatus

Returns a list of all unreachable members for the given role.

getUnreachable() - Method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterStatus

Returns a list of all unreachable members.

H

hashCode() - Method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterRoleStatus

hashCode() - Method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterStatus

hashCode() - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultBasicHealthCheckConfig

hashCode() - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultHealthCheckConfig

hashCode() - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultMetricsReporterConfig

hashCode() - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultPersistenceConfig

hashCode() - Method in class org.eclipse.ditto.internal.utils.health.HealthCheckingActorOptions

hashCode() - Method in class org.eclipse.ditto.internal.utils.health.mongo.CurrentMongoStatus

hashCode() - Method in class org.eclipse.ditto.internal.utils.health.ResetHealthEventsResponse

hashCode() - Method in class org.eclipse.ditto.internal.utils.health.RetrieveHealthResponse

hashCode() - Method in class org.eclipse.ditto.internal.utils.health.StatusDetailMessage

hashCode() - Method in class org.eclipse.ditto.internal.utils.health.StatusInfo

HealthCheckConfig - Interface in org.eclipse.ditto.internal.utils.health.config

Provides configuration settings regarded to Ditto's runtime health.

HealthCheckingActorOptions - Class in org.eclipse.ditto.internal.utils.health

Configuration options for the DefaultHealthCheckingActorFactory.

HealthCheckingActorOptions.Builder - Class in org.eclipse.ditto.internal.utils.health

A builder for building HealthCheckingActorOptions objects.

HealthRouteSupplier - Class in org.eclipse.ditto.internal.utils.health

Function for Pekko HTTP Routes to transform a RequestContext into a RouteResult with the expected status code for health (200/503) and the required format.

HealthRouteSupplier(ActorRef, LoggingAdapter) - Constructor for class org.eclipse.ditto.internal.utils.health.HealthRouteSupplier

Constructs a new HealthRouteFunction.

HISTORY - Enum constant in enum class org.eclipse.ditto.internal.utils.health.config.MetricsReporterConfig.MetricsReporterConfigValue

The amount of historical items to keep.

I

INFO - Enum constant in enum class org.eclipse.ditto.internal.utils.health.StatusDetailMessage.Level

INTERVAL - Enum constant in enum class org.eclipse.ditto.internal.utils.health.config.BasicHealthCheckConfig.HealthCheckConfigValue

The interval of health check.

isAlive() - Method in class org.eclipse.ditto.internal.utils.health.mongo.CurrentMongoStatus

Returns whether the Persistence is alive.

isComposite() - Method in class org.eclipse.ditto.internal.utils.health.StatusInfo

Returns whether this instance is a composite, i.e.

isEnabled() - Method in interface org.eclipse.ditto.internal.utils.health.config.BackgroundStreamingConfig

Returns whether background streaming is turned on.

isEnabled() - Method in interface org.eclipse.ditto.internal.utils.health.config.BasicHealthCheckConfig

Indicates whether global health checking should be enabled.

isEnabled() - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultBasicHealthCheckConfig

isEnabled() - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultHealthCheckConfig

isEnabled() - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultPersistenceConfig

isEnabled() - Method in interface org.eclipse.ditto.internal.utils.health.config.PersistenceConfig

Indicates whether the persistence health check should be enabled.

isHealthCheckEnabled() - Method in class org.eclipse.ditto.internal.utils.health.HealthCheckingActorOptions

Returns if the health check is enabled globally.

isHealthy() - Method in class org.eclipse.ditto.internal.utils.health.StatusInfo

Returns whether this status is considered as healthy.

isPersistenceCheckEnabled() - Method in class org.eclipse.ditto.internal.utils.health.HealthCheckingActorOptions

Returns if the persistence health check is enabled.

J

JSON_KEY_CHILDREN - Static variable in class org.eclipse.ditto.internal.utils.health.StatusInfo

JSON field of the children (sub-statuses).

JSON_KEY_DETAILS - Static variable in class org.eclipse.ditto.internal.utils.health.StatusInfo

JSON field of the detailed status messages.

JSON_KEY_LABEL - Static variable in class org.eclipse.ditto.internal.utils.health.StatusInfo

JSON field of the label.

JSON_KEY_LEADER - Static variable in class org.eclipse.ditto.internal.utils.health.cluster.ClusterRoleStatus

JSON value of the leaders address.

JSON_KEY_LEADER - Static variable in class org.eclipse.ditto.internal.utils.health.cluster.ClusterStatus

JSON value of the leaders address.

JSON_KEY_OWN_ROLES - Static variable in class org.eclipse.ditto.internal.utils.health.cluster.ClusterStatus

JSON array with all roles this cluster node has.

JSON_KEY_REACHABLE - Static variable in class org.eclipse.ditto.internal.utils.health.cluster.ClusterRoleStatus

JSON array of reachable members.

JSON_KEY_REACHABLE - Static variable in class org.eclipse.ditto.internal.utils.health.cluster.ClusterStatus

JSON array of reachable members.

JSON_KEY_ROLES - Static variable in class org.eclipse.ditto.internal.utils.health.cluster.ClusterStatus

JSON object with the cluster roles and their status.

JSON_KEY_SEEN_BY - Static variable in class org.eclipse.ditto.internal.utils.health.cluster.ClusterStatus

JSON array of all addresses of members which have seen this cluster state.

JSON_KEY_STATUS - Static variable in class org.eclipse.ditto.internal.utils.health.StatusInfo

JSON field of the status.

JSON_KEY_UNREACHABLE - Static variable in class org.eclipse.ditto.internal.utils.health.cluster.ClusterRoleStatus

JSON array of unreachable members.

JSON_KEY_UNREACHABLE - Static variable in class org.eclipse.ditto.internal.utils.health.cluster.ClusterStatus

JSON array of unreachable members.

L

label(String) - Method in class org.eclipse.ditto.internal.utils.health.StatusInfo

Creates a copy of this instance with the given label as label.

level() - Method in interface org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport.Event

level() - Method in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport.StreamTerminated

log - Variable in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport

The logger.

log - Variable in class org.eclipse.ditto.internal.utils.health.AbstractHealthCheckingActor

M

matchCustomMessages() - Method in class org.eclipse.ditto.internal.utils.health.AbstractHealthCheckingActor

Defines a AbstractActor.Receive for the messages to be handled by the subclass actor.

matchCustomMessages() - Method in class org.eclipse.ditto.internal.utils.health.CompositeCachingHealthCheckingActor

matchCustomMessages() - Method in class org.eclipse.ditto.internal.utils.health.SingletonStatusReporter

materializer - Variable in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport

The actor materializer to materialize streams.

mergeWith(StatusInfo.Status) - Method in enum class org.eclipse.ditto.internal.utils.health.StatusInfo.Status

Merges this status with another status.

MetricsReporterConfig - Interface in org.eclipse.ditto.internal.utils.health.config

Provides the configuration settings of metrics reporting inside of persistence health checking.

MetricsReporterConfig.MetricsReporterConfigValue - Enum Class in org.eclipse.ditto.internal.utils.health.config

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

N

name() - Method in interface org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport.Event

name() - Method in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport.StreamTerminated

name() - Method in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport.WokeUp

NAME - Static variable in class org.eclipse.ditto.internal.utils.health.ResetHealthEvents

Name of this command.

NAME - Static variable in class org.eclipse.ditto.internal.utils.health.RetrieveHealth

Name of this command.

newInstance() - Static method in class org.eclipse.ditto.internal.utils.health.ResetHealthEvents

Returns a new RetrieveHealth instance.

newInstance() - Static method in class org.eclipse.ditto.internal.utils.health.RetrieveHealth

Returns a new RetrieveHealth instance.

O

of(Config) - Static method in class org.eclipse.ditto.internal.utils.health.config.DefaultBasicHealthCheckConfig

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

of(Config) - Static method in class org.eclipse.ditto.internal.utils.health.config.DefaultHealthCheckConfig

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

of(Config) - Static method in class org.eclipse.ditto.internal.utils.health.config.DefaultMetricsReporterConfig

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

of(Config) - Static method in class org.eclipse.ditto.internal.utils.health.config.DefaultPersistenceConfig

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

of(String, Set<String>, Set<String>, String) - Static method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterRoleStatus

Returns a new ClusterRoleStatus instance with the specified leader, reachable and unreachable members.

of(Set<String>, Set<String>, Set<String>, String, Set<String>, Set<ClusterRoleStatus>) - Static method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterStatus

Returns a new ClusterStatus instance with the given parameters.

of(DittoHeaders) - Static method in class org.eclipse.ditto.internal.utils.health.ResetHealthEventsResponse

Create a ResetHealthEventsResponse.

of(StatusDetailMessage.Level, String) - Static method in class org.eclipse.ditto.internal.utils.health.StatusDetailMessage

of(StatusDetailMessage.Level, JsonValue) - Static method in class org.eclipse.ditto.internal.utils.health.StatusDetailMessage

of(StatusInfo, DittoHeaders) - Static method in class org.eclipse.ditto.internal.utils.health.RetrieveHealthResponse

Create a RetrieveHealthResponse.

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

org.eclipse.ditto.internal.utils.health.cluster - package org.eclipse.ditto.internal.utils.health.cluster

org.eclipse.ditto.internal.utils.health.config - package org.eclipse.ditto.internal.utils.health.config

org.eclipse.ditto.internal.utils.health.mongo - package org.eclipse.ditto.internal.utils.health.mongo

org.eclipse.ditto.internal.utils.health.routes - package org.eclipse.ditto.internal.utils.health.routes

org.eclipse.ditto.internal.utils.health.status - package org.eclipse.ditto.internal.utils.health.status

P

parseConfig(Config) - Method in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport

Construct a config object by parsing HOCON.

PersistenceConfig - Interface in org.eclipse.ditto.internal.utils.health.config

Provides the configuration settings of health check persistence.

PersistenceConfig.PersistenceConfigValue - Enum Class in org.eclipse.ditto.internal.utils.health.config

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

postEnhanceStatusReport(JsonObjectBuilder) - Method in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport

Append fields to the status report.

postStop() - Method in class org.eclipse.ditto.internal.utils.health.CompositeCachingHealthCheckingActor

preEnhanceSleepingBehavior(ReceiveBuilder) - Method in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport

Add message handling logic to the sleeping behavior of this actor.

preEnhanceStreamingBehavior(ReceiveBuilder) - Method in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport

Add message handling logic to the streaming behavior of this actor.

preStart() - Method in class org.eclipse.ditto.internal.utils.health.CompositeCachingHealthCheckingActor

props(String) - Static method in class org.eclipse.ditto.internal.utils.health.status.StatusSupplierActor

Creates Pekko configuration object Props for this StatusSupplierActor.

props(String, ActorRef) - Static method in class org.eclipse.ditto.internal.utils.health.SingletonStatusReporter

Create Props actor for this actor.

props(Map<String, Props>, Duration, boolean) - Static method in class org.eclipse.ditto.internal.utils.health.CompositeCachingHealthCheckingActor

Creates Pekko configuration object Props for this CompositeCachingHealthCheckingActor.

props(HealthCheckingActorOptions, Props, Props...) - Static method in class org.eclipse.ditto.internal.utils.health.DefaultHealthCheckingActorFactory

Creates Pekko configuration object Props for a health checking actor.

provideStaticStatus() - Static method in class org.eclipse.ditto.internal.utils.health.status.Status

Returns the static status of this instance as loaded from "versions.json" file in the classpath + calculated JVM specific values determined at startup.

R

renderEvent(Pair<Instant, AbstractBackgroundStreamingActorWithConfigWithStatusReport.Event>) - Method in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport

Render a single event as JSON for health reporting.

renderEvents(Deque<Pair<Instant, AbstractBackgroundStreamingActorWithConfigWithStatusReport.Event>>) - Method in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport

Render known events as a JSON array.

ResetHealthEvents - Class in org.eclipse.ditto.internal.utils.health

Internal command to reset the health events of underlying systems.

ResetHealthEventsResponse - Class in org.eclipse.ditto.internal.utils.health

Response of ResetHealthEvents.

RESOLUTION - Enum constant in enum class org.eclipse.ditto.internal.utils.health.config.MetricsReporterConfig.MetricsReporterConfigValue

The resolution how far apart each measurement should be done

RetrieveHealth - Class in org.eclipse.ditto.internal.utils.health

Internal command to retrieve the health of underlying systems.

RetrieveHealthResponse - Class in org.eclipse.ditto.internal.utils.health

Response of RetrieveHealth.

S

setConfig(Config) - Method in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport

setDittoHeaders(DittoHeaders) - Method in class org.eclipse.ditto.internal.utils.health.ResetHealthEvents

setDittoHeaders(DittoHeaders) - Method in class org.eclipse.ditto.internal.utils.health.ResetHealthEventsResponse

setDittoHeaders(DittoHeaders) - Method in class org.eclipse.ditto.internal.utils.health.RetrieveHealth

setDittoHeaders(DittoHeaders) - Method in class org.eclipse.ditto.internal.utils.health.RetrieveHealthResponse

shutdownStream(Shutdown) - Method in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport

SIMPLE_COMMAND_RETRIEVE_HEALTH - Static variable in class org.eclipse.ditto.internal.utils.health.status.StatusSupplierActor

Command name for retrieving the "health" of this instance.

SIMPLE_COMMAND_RETRIEVE_STATUS - Static variable in class org.eclipse.ditto.internal.utils.health.status.StatusSupplierActor

Command name for retrieving the "status" of this instance.

SingletonStatusReporter - Class in org.eclipse.ditto.internal.utils.health

Actor to report health status for a singleton on and only on the role leader of a cluster.

Status - Class in org.eclipse.ditto.internal.utils.health.status

Helper class providing the status of a Things-Service microservice instance.

STATUS_INFO - Static variable in class org.eclipse.ditto.internal.utils.health.RetrieveHealthResponse

Json field of the StatusInfo-payload.

StatusDetailMessage - Class in org.eclipse.ditto.internal.utils.health

A StatusDetailMessage contains a StatusDetailMessage.Level (INFO, WARN or ERROR) associated with a message.

StatusDetailMessage.Level - Enum Class in org.eclipse.ditto.internal.utils.health

The available levels of a StatusDetailMessage.

StatusHealthSupplier - Interface in org.eclipse.ditto.internal.utils.health.status

Supplies a CompletionStage for a health status, represented as StatusInfo.

StatusInfo - Class in org.eclipse.ditto.internal.utils.health

Contains the status and a detail in case the Status was not StatusInfo.Status.UP of a single health "entry".

StatusInfo.Status - Enum Class in org.eclipse.ditto.internal.utils.health

An enumeration of status codes for the health status in the style of spring boot actuator.

StatusRoute - Class in org.eclipse.ditto.internal.utils.health.routes

Builder for creating Pekko HTTP route for /status.

StatusRoute(Supplier<ClusterStatus>, ActorRef, ActorSystem) - Constructor for class org.eclipse.ditto.internal.utils.health.routes.StatusRoute

Constructs the /status route builder.

StatusSupplier - Interface in org.eclipse.ditto.internal.utils.health.status

Supplies a CompletionStage for a status, consisting of an arbitrary JSON object.

StatusSupplierActor - Class in org.eclipse.ditto.internal.utils.health.status

Actor supplying "status" and "health" information of an ActorSystem.

streamTerminated(AbstractBackgroundStreamingActorWithConfigWithStatusReport.Event) - Method in class org.eclipse.ditto.internal.utils.health.AbstractBackgroundStreamingActorWithConfigWithStatusReport

Handle stream termination.

T

TIMEOUT - Enum constant in enum class org.eclipse.ditto.internal.utils.health.config.PersistenceConfig.PersistenceConfigValue

The timeout of the health check for persistence.

toJson() - Method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterRoleStatus

toJson() - Method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterStatus

toJson() - Method in class org.eclipse.ditto.internal.utils.health.StatusDetailMessage

toJson() - Method in class org.eclipse.ditto.internal.utils.health.StatusInfo

toString() - Method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterRoleStatus

toString() - Method in class org.eclipse.ditto.internal.utils.health.cluster.ClusterStatus

toString() - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultBasicHealthCheckConfig

toString() - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultHealthCheckConfig

toString() - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultMetricsReporterConfig

toString() - Method in class org.eclipse.ditto.internal.utils.health.config.DefaultPersistenceConfig

toString() - Method in class org.eclipse.ditto.internal.utils.health.HealthCheckingActorOptions

toString() - Method in class org.eclipse.ditto.internal.utils.health.mongo.CurrentMongoStatus

toString() - Method in class org.eclipse.ditto.internal.utils.health.ResetHealthEvents

toString() - Method in class org.eclipse.ditto.internal.utils.health.ResetHealthEventsResponse

toString() - Method in class org.eclipse.ditto.internal.utils.health.RetrieveHealth

toString() - Method in class org.eclipse.ditto.internal.utils.health.RetrieveHealthResponse

toString() - Method in class org.eclipse.ditto.internal.utils.health.StatusDetailMessage

toString() - Method in class org.eclipse.ditto.internal.utils.health.StatusInfo

triggerHealthRetrieval() - Method in class org.eclipse.ditto.internal.utils.health.AbstractHealthCheckingActor

Defines the action of the subclass actor which will be triggered when its health status is requested.

triggerHealthRetrieval() - Method in class org.eclipse.ditto.internal.utils.health.CompositeCachingHealthCheckingActor

triggerHealthRetrieval() - Method in class org.eclipse.ditto.internal.utils.health.SingletonStatusReporter

TYPE - Static variable in class org.eclipse.ditto.internal.utils.health.ResetHealthEvents

Type of this command.

TYPE - Static variable in class org.eclipse.ditto.internal.utils.health.ResetHealthEventsResponse

Type of this response.

TYPE - Static variable in class org.eclipse.ditto.internal.utils.health.RetrieveHealth

Type of this command.

TYPE - Static variable in class org.eclipse.ditto.internal.utils.health.RetrieveHealthResponse

Type of this response.

TYPE_PREFIX - Static variable in class org.eclipse.ditto.internal.utils.health.ResetHealthEvents

Type prefix of this command.

TYPE_PREFIX - Static variable in class org.eclipse.ditto.internal.utils.health.RetrieveHealth

Type prefix of this command.

U

unknown() - Static method in class org.eclipse.ditto.internal.utils.health.StatusInfo

Returns a StatusInfo with status StatusInfo.Status.UNKNOWN.

UNKNOWN - Enum constant in enum class org.eclipse.ditto.internal.utils.health.StatusInfo.Status

Signals the application is in an unknown state.

UP - Enum constant in enum class org.eclipse.ditto.internal.utils.health.StatusInfo.Status

Signals the application is up and running.

updateHealth(StatusInfo) - Method in class org.eclipse.ditto.internal.utils.health.AbstractHealthCheckingActor

This method has to be used by subclass actors to update the health status.

V

valueOf(String) - Static method in enum class org.eclipse.ditto.internal.utils.health.config.BasicHealthCheckConfig.HealthCheckConfigValue

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

valueOf(String) - Static method in enum class org.eclipse.ditto.internal.utils.health.config.MetricsReporterConfig.MetricsReporterConfigValue

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

valueOf(String) - Static method in enum class org.eclipse.ditto.internal.utils.health.config.PersistenceConfig.PersistenceConfigValue

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

valueOf(String) - Static method in enum class org.eclipse.ditto.internal.utils.health.StatusDetailMessage.Level

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

valueOf(String) - Static method in enum class org.eclipse.ditto.internal.utils.health.StatusInfo.Status

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

values() - Static method in enum class org.eclipse.ditto.internal.utils.health.config.BasicHealthCheckConfig.HealthCheckConfigValue

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.health.config.MetricsReporterConfig.MetricsReporterConfigValue

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.health.config.PersistenceConfig.PersistenceConfigValue

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.health.StatusDetailMessage.Level

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.health.StatusInfo.Status

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

W

warn(Throwable) - Static method in class org.eclipse.ditto.internal.utils.health.StatusDetailMessage

WARN - Enum constant in enum class org.eclipse.ditto.internal.utils.health.StatusDetailMessage.Level

WithHealthCheckConfig - Interface in org.eclipse.ditto.internal.utils.health.config

This interface provides access to the health check config.

WithPersistenceConfig - Interface in org.eclipse.ditto.internal.utils.health.config

This interface provides access to health check persistence config.

A B C D E F G H I J L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values