Package org.eclipse.ditto.services.gateway.streaming

Class DefaultStreamingConfig

java.lang.Object

org.eclipse.ditto.services.gateway.streaming.DefaultStreamingConfig

All Implemented Interfaces:

StreamingConfig

@Immutable
public final class DefaultStreamingConfig
extends Object
implements StreamingConfig

This class is the default implementation of the streaming config.

Nested Class Summary

Nested classes/interfaces inherited from interface org.eclipse.ditto.services.gateway.streaming.StreamingConfig

StreamingConfig.StreamingConfigValue

Field Summary

Fields inherited from interface org.eclipse.ditto.services.gateway.streaming.StreamingConfig

CONFIG_PATH

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
int	getParallelism()	Returns maximum number of stream elements to process in parallel.
Duration	getSessionCounterScrapeInterval()	Returns the session counter update interval.
SignalEnrichmentConfig	getSignalEnrichmentConfig()	Returns the signal-enrichment config.
WebsocketConfig	getWebsocketConfig()	Returns the websocket config for streaming.
int	hashCode()
static StreamingConfig	of(com.typesafe.config.Config config)	Returns an instance of DefaultStreamingConfig based on the settings of the specified Config.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.eclipse.ditto.services.gateway.streaming.StreamingConfig

render

Method Detail

of

public static StreamingConfig of(com.typesafe.config.Config config)

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

Parameters:

config - is supposed to provide the settings of the web socket config at "streaming".

Returns:

the instance.

Throws:

org.eclipse.ditto.services.utils.config.DittoConfigError - if config is invalid.

getSessionCounterScrapeInterval

public Duration getSessionCounterScrapeInterval()

Description copied from interface: StreamingConfig

Returns the session counter update interval.

Specified by:

getSessionCounterScrapeInterval in interface StreamingConfig

Returns:

the interval.

getWebsocketConfig

public WebsocketConfig getWebsocketConfig()

Description copied from interface: StreamingConfig

Returns the websocket config for streaming.

Specified by:

getWebsocketConfig in interface StreamingConfig

Returns:

the websocket config.

getSignalEnrichmentConfig

public SignalEnrichmentConfig getSignalEnrichmentConfig()

Description copied from interface: StreamingConfig

Returns the signal-enrichment config.

Specified by:

getSignalEnrichmentConfig in interface StreamingConfig

Returns:

the signal-enrichment config.

getParallelism

public int getParallelism()

Description copied from interface: StreamingConfig

Returns maximum number of stream elements to process in parallel.

Specified by:

getParallelism in interface StreamingConfig

Returns:

the parallelism.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object