com.hazelcast.cp.internal.datastructures.atomicref

Class AtomicRefService

java.lang.Object

com.hazelcast.cp.internal.datastructures.spi.AbstractCPMigrationAwareService

com.hazelcast.cp.internal.datastructures.spi.atomic.RaftAtomicValueService<Data,AtomicRef,AtomicRefSnapshot>

com.hazelcast.cp.internal.datastructures.atomicref.AtomicRefService

All Implemented Interfaces:

RaftManagedService, RaftRemoteService, SnapshotAwareService<AtomicRefSnapshot>, RaftNodeLifecycleAwareService, ManagedService, MigrationAwareService

public class AtomicRefService
extends RaftAtomicValueService<Data,AtomicRef,AtomicRefSnapshot>

Contains Raft-based atomic reference instances, implements snapshotting, and creates proxies

Field Summary

Fields

Modifier and Type	Field and Description
static String	SERVICE_NAME Name of the service

Fields inherited from class com.hazelcast.cp.internal.datastructures.spi.AbstractCPMigrationAwareService

nodeEngine

Constructor Summary

Constructors

Constructor and Description
AtomicRefService(NodeEngine nodeEngine)

Method Summary

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)

Methods inherited from class com.hazelcast.cp.internal.datastructures.spi.atomic.RaftAtomicValueService

clearPartitionReplica, createProxy, destroyRaftObject, getAtomicValue, getBackupCount, getSnapshotMap, init, onCPSubsystemRestart, onRaftGroupDestroyed, onRaftNodeSteppedDown, reset, restoreSnapshot, shutdown, takeSnapshot

Methods inherited from class com.hazelcast.cp.internal.datastructures.spi.AbstractCPMigrationAwareService

beforeMigration, commitMigration, prepareReplicationOperation, rollbackMigration

Methods inherited from class java.lang.Object

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

Field Detail

SERVICE_NAME

public static final String SERVICE_NAME

Name of the service

See Also:

Constant Field Values

Constructor Detail

AtomicRefService

public AtomicRefService(NodeEngine nodeEngine)

Method Detail

newSnapshot

protected AtomicRefSnapshot newSnapshot(Map<String,Data> values,
                                        Set<String> destroyed)

Specified by:

newSnapshot in class RaftAtomicValueService<Data,AtomicRef,AtomicRefSnapshot>

newAtomicValue

protected AtomicRef newAtomicValue(CPGroupId groupId,
                                   String name,
                                   Data val)

Specified by:

newAtomicValue in class RaftAtomicValueService<Data,AtomicRef,AtomicRefSnapshot>

newRaftAtomicProxy

protected IAtomicReference newRaftAtomicProxy(NodeEngineImpl nodeEngine,
                                              RaftGroupId groupId,
                                              String proxyName,
                                              String objectNameForProxy)

Specified by:

newRaftAtomicProxy in class RaftAtomicValueService<Data,AtomicRef,AtomicRefSnapshot>