Package com.framed.streamer.dispatcher

Class InfluxDispatcher

java.lang.Object

com.framed.core.Service

com.framed.io.dispatch.Dispatcher

com.framed.streamer.dispatcher.InfluxDispatcher

public class InfluxDispatcher
extends Dispatcher

Field Summary

Fields inherited from class com.framed.core.Service

ADDRESS_REGISTRY_SUFFIX, eventBus, formatter, logger

Constructor Summary

Constructors

Constructor	Description
InfluxDispatcher(EventBus eventBus, org.json.JSONArray devices, String url, String token, String org, String bucket)

Method Summary

Modifier and Type	Method	Description
void	push(DataPoint<?> dataPoint)	Pushes a single datapoint to the underlying sink.
void	pushBatch(List<DataPoint<?>> batch)	Pushes a batch of datapoints to the underlying sink.
void	stop()	Stops the service.

Methods inherited from class com.framed.io.dispatch.Dispatcher

onDrop, onHandlerError, shutdown

Methods inherited from class com.framed.core.Service

addressRegistry, announceAddress

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

InfluxDispatcher

public InfluxDispatcher(EventBus eventBus,
 org.json.JSONArray devices,
 String url,
 String token,
 String org,
 String bucket)

Method Details

push

public void push(DataPoint<?> dataPoint)

Description copied from class: Dispatcher

Pushes a single datapoint to the underlying sink.

Invoked on the dispatcher's worker thread. Implementations may throw IOException to signal a transient failure, which triggers retry with exponential backoff.

Specified by:

push in class Dispatcher

Parameters:

dataPoint - the datapoint to push

pushBatch

public void pushBatch(List<DataPoint<?>> batch)

Description copied from class: Dispatcher

Pushes a batch of datapoints to the underlying sink.

Specified by:

pushBatch in class Dispatcher

Parameters:

batch - the datapoints to push

stop

public void stop()

Description copied from class: Service

Stops the service.

By default, this method logs a message indicating that no stop logic is implemented. Subclasses should override this method to provide custom shutdown behavior when necessary.

Overrides:

stop in class Dispatcher