public class AtomicRefService extends RaftAtomicValueService<Data,AtomicRef,AtomicRefSnapshot>
Modifier and Type | Field and Description |
---|---|
static String |
SERVICE_NAME
Name of the service
|
nodeEngine
Constructor and Description |
---|
AtomicRefService(NodeEngine nodeEngine) |
Modifier and Type | Method and Description |
---|---|
protected AtomicRef |
newAtomicValue(CPGroupId groupId,
String name,
Data val) |
protected IAtomicReference |
newRaftAtomicProxy(NodeEngineImpl nodeEngine,
RaftGroupId groupId,
String proxyName,
String objectNameForProxy) |
protected AtomicRefSnapshot |
newSnapshot(Map<String,Data> values,
Set<String> destroyed) |
clearPartitionReplica, createProxy, destroyRaftObject, getAtomicValue, getBackupCount, getSnapshotMap, init, onCPSubsystemRestart, onRaftGroupDestroyed, onRaftNodeSteppedDown, reset, restoreSnapshot, shutdown, takeSnapshot
beforeMigration, commitMigration, prepareReplicationOperation, rollbackMigration
public static final String SERVICE_NAME
public AtomicRefService(NodeEngine nodeEngine)
protected AtomicRefSnapshot newSnapshot(Map<String,Data> values, Set<String> destroyed)
newSnapshot
in class RaftAtomicValueService<Data,AtomicRef,AtomicRefSnapshot>
protected AtomicRef newAtomicValue(CPGroupId groupId, String name, Data val)
newAtomicValue
in class RaftAtomicValueService<Data,AtomicRef,AtomicRefSnapshot>
protected IAtomicReference newRaftAtomicProxy(NodeEngineImpl nodeEngine, RaftGroupId groupId, String proxyName, String objectNameForProxy)
newRaftAtomicProxy
in class RaftAtomicValueService<Data,AtomicRef,AtomicRefSnapshot>
Copyright © 2019 Hazelcast, Inc.. All rights reserved.