public interface ICacheService extends ManagedService, RemoteService, FragmentedMigrationAwareService, EventPublishingService<Object,CacheEventListener>
Modifier and Type | Field and Description |
---|---|
static String |
CACHE_SUPPORT_NOT_AVAILABLE_ERROR_MESSAGE |
static int |
MAX_ADD_CACHE_CONFIG_RETRIES
Maximum retries for adding cache config cluster-wide on stable cluster
|
static String |
SERVICE_NAME |
Modifier and Type | Method and Description |
---|---|
String |
addInvalidationListener(String cacheNameWithPrefix,
CacheEventListener listener,
boolean localOnly) |
<K,V> void |
createCacheConfigOnAllMembers(PreJoinCacheConfig<K,V> cacheConfig)
Creates the given CacheConfig on all members of the cluster synchronously.
|
CacheStatisticsImpl |
createCacheStatIfAbsent(String cacheNameWithPrefix) |
void |
deleteCache(String cacheNameWithPrefix,
String callerUuid,
boolean destroy) |
CacheConfig |
deleteCacheConfig(String cacheNameWithPrefix) |
void |
deleteCacheStat(String cacheNameWithPrefix) |
void |
deregisterAllListener(String cacheNameWithPrefix) |
boolean |
deregisterListener(String cacheNameWithPrefix,
String registrationId) |
CacheConfig |
findCacheConfig(String simpleName) |
CacheConfig |
getCacheConfig(String cacheNameWithPrefix) |
Collection<CacheConfig> |
getCacheConfigs() |
CacheOperationProvider |
getCacheOperationProvider(String cacheNameWithPrefix,
InMemoryFormat storageType)
Creates cache operations according to the storage-type of the cache
|
CacheWanEventPublisher |
getCacheWanEventPublisher()
Returns the WAN event publisher responsible for publishing
primary and backup WAN events for caches.
|
CacheEventJournal |
getEventJournal()
Returns an interface for interacting with the cache event journals.
|
ExpirationManager |
getExpirationManager() |
NodeEngine |
getNodeEngine() |
CacheContext |
getOrCreateCacheContext(String cacheNameWithPrefix) |
ICacheRecordStore |
getOrCreateRecordStore(String cacheNameWithPrefix,
int partitionId)
Gets or creates a cache record store with the prefixed
cacheNameWithPrefix
and partition ID. |
CachePartitionSegment[] |
getPartitionSegments() |
ICacheRecordStore |
getRecordStore(String cacheNameWithPrefix,
int partitionId)
Returns a cache record store with the prefixed
cacheNameWithPrefix and partition ID
or null if one doesn't exist. |
CachePartitionSegment |
getSegment(int partitionId) |
CacheStatistics |
getStatistics(String cacheNameWithPrefix) |
boolean |
isWanReplicationEnabled(String cacheNameWithPrefix)
Returns
true if WAN replication is enabled for the cache named cacheNameWithPrefix . |
void |
publishEvent(CacheEventContext cacheEventContext) |
void |
publishEvent(String cacheNameWithPrefix,
CacheEventSet eventSet,
int orderKey) |
CacheConfig |
putCacheConfigIfAbsent(CacheConfig config) |
String |
registerListener(String cacheNameWithPrefix,
CacheEventListener listener,
boolean isLocal) |
String |
registerListener(String cacheNameWithPrefix,
CacheEventListener listener,
EventFilter eventFilter,
boolean isLocal) |
void |
sendInvalidationEvent(String cacheNameWithPrefix,
Data key,
String sourceUuid) |
void |
setManagementEnabled(CacheConfig cacheConfig,
String cacheNameWithPrefix,
boolean enabled) |
void |
setStatisticsEnabled(CacheConfig cacheConfig,
String cacheNameWithPrefix,
boolean enabled) |
<K,V> void |
setTenantControl(CacheConfig<K,V> cacheConfig) |
init, reset, shutdown
createDistributedObject, destroyDistributedObject
getAllServiceNamespaces, isKnownServiceNamespace, prepareReplicationOperation
beforeMigration, commitMigration, prepareReplicationOperation, rollbackMigration
dispatchEvent
static final String CACHE_SUPPORT_NOT_AVAILABLE_ERROR_MESSAGE
static final String SERVICE_NAME
static final int MAX_ADD_CACHE_CONFIG_RETRIES
ICacheRecordStore getOrCreateRecordStore(String cacheNameWithPrefix, int partitionId)
cacheNameWithPrefix
and partition ID.cacheNameWithPrefix
- the full name of the ICache
, including the manager scope prefixpartitionId
- the record store partition IDICacheRecordStore getRecordStore(String cacheNameWithPrefix, int partitionId)
cacheNameWithPrefix
and partition ID
or null
if one doesn't exist.cacheNameWithPrefix
- the full name of the ICache
, including the manager scope prefixpartitionId
- the record store partition IDnull
if it doesn't existCachePartitionSegment getSegment(int partitionId)
CacheConfig putCacheConfigIfAbsent(CacheConfig config)
CacheConfig getCacheConfig(String cacheNameWithPrefix)
CacheConfig findCacheConfig(String simpleName)
Collection<CacheConfig> getCacheConfigs()
CacheConfig deleteCacheConfig(String cacheNameWithPrefix)
CachePartitionSegment[] getPartitionSegments()
CacheStatisticsImpl createCacheStatIfAbsent(String cacheNameWithPrefix)
CacheContext getOrCreateCacheContext(String cacheNameWithPrefix)
void deleteCacheStat(String cacheNameWithPrefix)
void setStatisticsEnabled(CacheConfig cacheConfig, String cacheNameWithPrefix, boolean enabled)
void setManagementEnabled(CacheConfig cacheConfig, String cacheNameWithPrefix, boolean enabled)
void publishEvent(CacheEventContext cacheEventContext)
void publishEvent(String cacheNameWithPrefix, CacheEventSet eventSet, int orderKey)
NodeEngine getNodeEngine()
String registerListener(String cacheNameWithPrefix, CacheEventListener listener, boolean isLocal)
String registerListener(String cacheNameWithPrefix, CacheEventListener listener, EventFilter eventFilter, boolean isLocal)
void deregisterAllListener(String cacheNameWithPrefix)
CacheStatistics getStatistics(String cacheNameWithPrefix)
ExpirationManager getExpirationManager()
CacheOperationProvider getCacheOperationProvider(String cacheNameWithPrefix, InMemoryFormat storageType)
String addInvalidationListener(String cacheNameWithPrefix, CacheEventListener listener, boolean localOnly)
void sendInvalidationEvent(String cacheNameWithPrefix, Data key, String sourceUuid)
boolean isWanReplicationEnabled(String cacheNameWithPrefix)
true
if WAN replication is enabled for the cache named cacheNameWithPrefix
.cacheNameWithPrefix
- the full name of the ICache
, including the manager scope prefixCacheWanEventPublisher getCacheWanEventPublisher()
CacheEventJournal getEventJournal()
<K,V> void createCacheConfigOnAllMembers(PreJoinCacheConfig<K,V> cacheConfig)
K
- key type parameterV
- value type parametercacheConfig
- the cache config to create on all members of the cluster<K,V> void setTenantControl(CacheConfig<K,V> cacheConfig)
Copyright © 2021 Hazelcast, Inc.. All Rights Reserved.