com.hazelcast.client.cp.internal.datastructures.atomiclong

Class RaftAtomicLongProxy

java.lang.Object

com.hazelcast.client.spi.ClientProxy

com.hazelcast.client.cp.internal.datastructures.atomiclong.RaftAtomicLongProxy

All Implemented Interfaces:

DistributedObject, IAtomicLong

public class RaftAtomicLongProxy
extends ClientProxy
implements IAtomicLong

Client-side Raft-based proxy implementation of IAtomicLong

Field Summary

Fields inherited from class com.hazelcast.client.spi.ClientProxy

name

Constructor Summary

Constructors

Constructor and Description
RaftAtomicLongProxy(ClientContext context, RaftGroupId groupId, String proxyName, String objectName)

Method Summary

Modifier and Type	Method and Description
long	addAndGet(long delta)
InternalCompletableFuture<Long>	addAndGetAsync(long delta)
void	alter(IFunction<Long,Long> function)
long	alterAndGet(IFunction<Long,Long> function)
InternalCompletableFuture<Long>	alterAndGetAsync(IFunction<Long,Long> function)
InternalCompletableFuture<Void>	alterAsync(IFunction<Long,Long> function)
<R> R	apply(IFunction<Long,R> function)
<R> InternalCompletableFuture<R>	applyAsync(IFunction<Long,R> function)
boolean	compareAndSet(long expect, long update)
InternalCompletableFuture<Boolean>	compareAndSetAsync(long expect, long update)
long	decrementAndGet()
InternalCompletableFuture<Long>	decrementAndGetAsync()
long	get()
long	getAndAdd(long delta)
InternalCompletableFuture<Long>	getAndAddAsync(long delta)
long	getAndAlter(IFunction<Long,Long> function)
InternalCompletableFuture<Long>	getAndAlterAsync(IFunction<Long,Long> function)
long	getAndIncrement()
InternalCompletableFuture<Long>	getAndIncrementAsync()
long	getAndSet(long newValue)
InternalCompletableFuture<Long>	getAndSetAsync(long newValue)
InternalCompletableFuture<Long>	getAsync()
CPGroupId	getGroupId()
String	getPartitionKey()
long	incrementAndGet()
InternalCompletableFuture<Long>	incrementAndGetAsync()
void	onDestroy() Called before proxy is destroyed.
void	set(long newValue)
InternalCompletableFuture<Void>	setAsync(long newValue)

Methods inherited from class com.hazelcast.client.spi.ClientProxy

deregisterListener, destroy, destroyLocally, destroyRemotely, equals, getClient, getConnectedServerVersion, getContext, getDistributedObjectName, getId, getName, getSerializationService, getServiceName, hashCode, invoke, invoke, invokeOnAddress, invokeOnPartition, invokeOnPartitionInterruptibly, onInitialize, onShutdown, postDestroy, preDestroy, registerListener, setContext, toData, toObject

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.core.IAtomicLong

getName

Methods inherited from interface com.hazelcast.core.DistributedObject

destroy, getServiceName

Constructor Detail

RaftAtomicLongProxy

public RaftAtomicLongProxy(ClientContext context,
                           RaftGroupId groupId,
                           String proxyName,
                           String objectName)

Method Detail

addAndGet

public long addAndGet(long delta)

Specified by:

addAndGet in interface IAtomicLong

compareAndSet

public boolean compareAndSet(long expect,
                             long update)

Specified by:

compareAndSet in interface IAtomicLong

decrementAndGet

public long decrementAndGet()

Specified by:

decrementAndGet in interface IAtomicLong

get

public long get()

Specified by:

get in interface IAtomicLong

getAndAdd

public long getAndAdd(long delta)

Specified by:

getAndAdd in interface IAtomicLong

getAndSet

public long getAndSet(long newValue)

Specified by:

getAndSet in interface IAtomicLong

incrementAndGet

public long incrementAndGet()

Specified by:

incrementAndGet in interface IAtomicLong

getAndIncrement

public long getAndIncrement()

Specified by:

getAndIncrement in interface IAtomicLong

set

public void set(long newValue)

Specified by:

set in interface IAtomicLong

alter

public void alter(IFunction<Long,Long> function)

Specified by:

alter in interface IAtomicLong

alterAndGet

public long alterAndGet(IFunction<Long,Long> function)

Specified by:

alterAndGet in interface IAtomicLong

getAndAlter

public long getAndAlter(IFunction<Long,Long> function)

Specified by:

getAndAlter in interface IAtomicLong

apply

public <R> R apply(IFunction<Long,R> function)

Specified by:

apply in interface IAtomicLong

addAndGetAsync

public InternalCompletableFuture<Long> addAndGetAsync(long delta)

Specified by:

addAndGetAsync in interface IAtomicLong

compareAndSetAsync

public InternalCompletableFuture<Boolean> compareAndSetAsync(long expect,
                                                             long update)

Specified by:

compareAndSetAsync in interface IAtomicLong

decrementAndGetAsync

public InternalCompletableFuture<Long> decrementAndGetAsync()

Specified by:

decrementAndGetAsync in interface IAtomicLong

getAsync

public InternalCompletableFuture<Long> getAsync()

Specified by:

getAsync in interface IAtomicLong

getAndAddAsync

public InternalCompletableFuture<Long> getAndAddAsync(long delta)

Specified by:

getAndAddAsync in interface IAtomicLong

getAndSetAsync

public InternalCompletableFuture<Long> getAndSetAsync(long newValue)

Specified by:

getAndSetAsync in interface IAtomicLong

incrementAndGetAsync

public InternalCompletableFuture<Long> incrementAndGetAsync()

Specified by:

incrementAndGetAsync in interface IAtomicLong

getAndIncrementAsync

public InternalCompletableFuture<Long> getAndIncrementAsync()

Specified by:

getAndIncrementAsync in interface IAtomicLong

setAsync

public InternalCompletableFuture<Void> setAsync(long newValue)

Specified by:

setAsync in interface IAtomicLong

alterAsync

public InternalCompletableFuture<Void> alterAsync(IFunction<Long,Long> function)

Specified by:

alterAsync in interface IAtomicLong

alterAndGetAsync

public InternalCompletableFuture<Long> alterAndGetAsync(IFunction<Long,Long> function)

Specified by:

alterAndGetAsync in interface IAtomicLong

getAndAlterAsync

public InternalCompletableFuture<Long> getAndAlterAsync(IFunction<Long,Long> function)

Specified by:

getAndAlterAsync in interface IAtomicLong

applyAsync

public <R> InternalCompletableFuture<R> applyAsync(IFunction<Long,R> function)

Specified by:

applyAsync in interface IAtomicLong

getPartitionKey

public String getPartitionKey()

Specified by:

getPartitionKey in interface DistributedObject

Overrides:

getPartitionKey in class ClientProxy

onDestroy

public void onDestroy()

Description copied from class: ClientProxy

Called before proxy is destroyed. Overriding implementations should clean/release resources created during initialization.

Overrides:

onDestroy in class ClientProxy

getGroupId

public CPGroupId getGroupId()