org.infinispan.counter.api

Interface WeakCounter

public interface WeakCounter

A weak consistent counter interface.

This interface represents a weak counter in the way that the write operations does not return a consistent results. In this way, all the writes return a CompletableFuture.

Note: the reset operation is not atomic.

Since:

9.0

Author:

Pedro Ruivo

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	add(long delta) Adds the given value to the new value.
<T extends CounterListener> Handle<T>	addListener(T listener) Adds a CounterListener to this counter.
default CompletableFuture<Void>	decrement() Decrements the counter.
CounterConfiguration	getConfiguration()
String	getName()
long	getValue() It returns the counter's value.
default CompletableFuture<Void>	increment() Increments the counter.
CompletableFuture<Void>	remove() It removes this counter from the cluster.
CompletableFuture<Void>	reset() Resets the counter to its initial value.
SyncWeakCounter	sync() It returns a synchronous weak counter for this instance.

Method Detail

getName

String getName()

Returns:

The counter name.

getValue

long getValue()

It returns the counter's value.

This value may be not the mot up-to-data value.

Returns:

The counter's value.

increment

default CompletableFuture<Void> increment()

Increments the counter.

decrement

default CompletableFuture<Void> decrement()

Decrements the counter.

add

CompletableFuture<Void> add(long delta)

Adds the given value to the new value.

Parameters:

delta - the value to add.

reset

CompletableFuture<Void> reset()

Resets the counter to its initial value.

addListener

<T extends CounterListener> Handle<T> addListener(T listener)

Adds a CounterListener to this counter.

Type Parameters:

T - The type of the listener. It must implement CounterListener.

Parameters:

listener - The listener to add.

Returns:

A Handle that allows to remove the listener via Handle.remove() ()}.

getConfiguration

CounterConfiguration getConfiguration()

Returns:

the CounterConfiguration used by this counter.

remove

CompletableFuture<Void> remove()

It removes this counter from the cluster.

Note that it doesn't remove the counter from the CounterManager. If you want to remove the counter from the CounterManager use CounterManager.remove(String).

Returns:

The CompletableFuture that is completed when the counter is removed from the cluster.

sync

SyncWeakCounter sync()

It returns a synchronous weak counter for this instance.

Returns:

a SyncWeakCounter.