public final class RepairingTask extends Object implements Runnable
Repairing responsibilities of this task are:
RepairingHandler
s to see if any Near Cache needs to be
invalidated according to missed invalidation counts (controlled via
MAX_TOLERATED_MISS_COUNT
).
MIN_RECONCILIATION_INTERVAL_SECONDS
).
Modifier and Type | Field and Description |
---|---|
static HazelcastProperty |
MAX_TOLERATED_MISS_COUNT |
static HazelcastProperty |
MIN_RECONCILIATION_INTERVAL_SECONDS |
static HazelcastProperty |
RECONCILIATION_INTERVAL_SECONDS |
Constructor and Description |
---|
RepairingTask(HazelcastProperties properties,
InvalidationMetaDataFetcher invalidationMetaDataFetcher,
TaskScheduler scheduler,
SerializationService serializationService,
MinimalPartitionService partitionService,
String localUuid,
ILogger logger) |
Modifier and Type | Method and Description |
---|---|
void |
deregisterHandler(String dataStructureName) |
ConcurrentMap<String,RepairingHandler> |
getHandlers() |
InvalidationMetaDataFetcher |
getInvalidationMetaDataFetcher() |
<K,V> RepairingHandler |
registerAndGetHandler(String dataStructureName,
NearCache<K,V> nearCache) |
void |
run() |
String |
toString() |
public static final HazelcastProperty MAX_TOLERATED_MISS_COUNT
public static final HazelcastProperty RECONCILIATION_INTERVAL_SECONDS
public static final HazelcastProperty MIN_RECONCILIATION_INTERVAL_SECONDS
public RepairingTask(HazelcastProperties properties, InvalidationMetaDataFetcher invalidationMetaDataFetcher, TaskScheduler scheduler, SerializationService serializationService, MinimalPartitionService partitionService, String localUuid, ILogger logger)
public <K,V> RepairingHandler registerAndGetHandler(String dataStructureName, NearCache<K,V> nearCache)
public void deregisterHandler(String dataStructureName)
public InvalidationMetaDataFetcher getInvalidationMetaDataFetcher()
public ConcurrentMap<String,RepairingHandler> getHandlers()
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.