Package com.influxdb.client.write.events

Class BackpressureEvent

java.lang.Object

com.influxdb.client.write.events.AbstractWriteEvent

com.influxdb.client.write.events.BackpressureEvent

public final class BackpressureEvent
extends AbstractWriteEvent

The event is published when is backpressure applied.

Author:

Jakub Bednar (bednar@github) (25/09/2018 12:27)

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	BackpressureEvent.BackpressureReason

Constructor Summary

Constructors

Constructor	Description
BackpressureEvent(BackpressureEvent.BackpressureReason reason)
BackpressureEvent(BackpressureEvent.BackpressureReason reason, List<String> droppedLineProtocol)

Method Summary

Modifier and Type	Method	Description
List<String>	getDroppedLineProtocol()
BackpressureEvent.BackpressureReason	getReason()
void	logEvent()	Log current event by Logger.

Methods inherited from class java.lang.Object

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

Constructor Details

BackpressureEvent

public BackpressureEvent(@Nonnull
 BackpressureEvent.BackpressureReason reason)

BackpressureEvent

public BackpressureEvent(@Nonnull
 BackpressureEvent.BackpressureReason reason,
 @Nullable
 List<String> droppedLineProtocol)

Method Details

logEvent

public void logEvent()

Description copied from class: AbstractWriteEvent

Log current event by Logger.

Specified by:

logEvent in class AbstractWriteEvent

getReason

@Nonnull
public BackpressureEvent.BackpressureReason getReason()

Returns:

reason of the backpressure

getDroppedLineProtocol

@Nonnull
public List<String> getDroppedLineProtocol()

Returns:

unmodifiable list of line protocol points in the buffer at the time of the backpressure event