Package | Description |
---|---|
com.hazelcast.cache.impl.journal | |
com.hazelcast.client.impl.clientside |
Contains most of the client side HazelcastInstance implementation functionality.
|
com.hazelcast.config |
Provides classes for configuring HazelcastInstance.
|
com.hazelcast.internal.config |
Contains functionality for Hazelcast configurations.
|
com.hazelcast.internal.dynamicconfig |
Classes related to Dynamic Configuration.
|
com.hazelcast.internal.journal |
This package contains supporting classes for data structure specific event journals.
|
com.hazelcast.map.impl.journal | |
com.hazelcast.ringbuffer.impl |
Contains the
Ringbuffer implementation classes. |
Modifier and Type | Method and Description |
---|---|
RingbufferConfig |
RingbufferCacheEventJournalImpl.toRingbufferConfig(EventJournalConfig config,
ObjectNamespace namespace)
Creates a new
RingbufferConfig for a ringbuffer that will keep
event journal events for a single partition. |
Modifier and Type | Method and Description |
---|---|
RingbufferConfig |
ClientDynamicClusterConfig.findRingbufferConfig(String name) |
RingbufferConfig |
ClientDynamicClusterConfig.getRingbufferConfig(String name) |
Modifier and Type | Method and Description |
---|---|
Map<String,RingbufferConfig> |
ClientDynamicClusterConfig.getRingbufferConfigs() |
Modifier and Type | Method and Description |
---|---|
Config |
ClientDynamicClusterConfig.addRingBufferConfig(RingbufferConfig ringbufferConfig) |
Modifier and Type | Method and Description |
---|---|
Config |
ClientDynamicClusterConfig.setRingbufferConfigs(Map<String,RingbufferConfig> ringbufferConfigs) |
Modifier and Type | Method and Description |
---|---|
RingbufferConfig |
Config.findRingbufferConfig(String name)
Returns a read-only
Ringbuffer
configuration for the given name. |
RingbufferConfig |
RingbufferConfig.getAsReadOnly()
Deprecated.
this method will be removed in 4.0; it is meant for internal usage only
|
RingbufferConfig |
Config.getRingbufferConfig(String name)
Returns the RingbufferConfig for the given name, creating one
if necessary and adding it to the collection of known configurations.
|
RingbufferConfig |
RingbufferConfig.setAsyncBackupCount(int asyncBackupCount)
Sets the number of asynchronous backups.
|
RingbufferConfig |
RingbufferConfig.setBackupCount(int backupCount)
Sets the number of synchronous backups.
|
RingbufferConfig |
RingbufferConfig.setCapacity(int capacity)
Sets the capacity of the ringbuffer.
|
RingbufferConfig |
RingbufferConfig.setInMemoryFormat(InMemoryFormat inMemoryFormat)
Sets the in-memory format.
|
RingbufferConfig |
RingbufferConfig.setMergePolicyConfig(MergePolicyConfig mergePolicyConfig)
Sets the
MergePolicyConfig for this ringbuffer. |
RingbufferConfig |
RingbufferConfig.setName(String name)
Sets the name of the ringbuffer.
|
RingbufferConfig |
RingbufferConfig.setQuorumName(String quorumName)
Sets the quorum name for operations.
|
RingbufferConfig |
RingbufferConfig.setRingbufferStoreConfig(RingbufferStoreConfig ringbufferStoreConfig)
Set the RingbufferStore (load and store ringbuffer items from/to a database)
configuration.
|
RingbufferConfig |
RingbufferConfig.setTimeToLiveSeconds(int timeToLiveSeconds)
Sets the time to live in seconds which is the maximum number of seconds
for each item to stay in the ringbuffer before being removed.
|
Modifier and Type | Method and Description |
---|---|
Map<String,RingbufferConfig> |
Config.getRingbufferConfigs()
Returns the map of
Ringbuffer
configurations, mapped by config name. |
Modifier and Type | Method and Description |
---|---|
Config |
Config.addRingBufferConfig(RingbufferConfig ringbufferConfig)
Adds the ringbuffer configuration.
|
Modifier and Type | Method and Description |
---|---|
Config |
Config.setRingbufferConfigs(Map<String,RingbufferConfig> ringbufferConfigs)
Sets the map of
Ringbuffer configurations,
mapped by config name. |
Constructor and Description |
---|
RingbufferConfig(RingbufferConfig config)
Clones a RingbufferConfig
|
RingbufferConfig(String name,
RingbufferConfig config)
Creates a new RingbufferConfig by cloning an existing config and
overriding the name.
|
Modifier and Type | Method and Description |
---|---|
static void |
ConfigValidator.checkRingbufferConfig(RingbufferConfig ringbufferConfig,
SplitBrainMergePolicyProvider mergePolicyProvider)
Validates the given
RingbufferConfig . |
Modifier and Type | Method and Description |
---|---|
RingbufferConfig |
DynamicConfigurationAwareConfig.findRingbufferConfig(String name) |
RingbufferConfig |
ClusterWideConfigurationService.findRingbufferConfig(String name) |
RingbufferConfig |
ConfigurationService.findRingbufferConfig(String name)
Finds existing Ringbuffer config.
|
RingbufferConfig |
DynamicConfigurationAwareConfig.getRingbufferConfig(String name) |
Modifier and Type | Method and Description |
---|---|
Map<String,RingbufferConfig> |
DynamicConfigurationAwareConfig.getRingbufferConfigs() |
ConcurrentMap<String,RingbufferConfig> |
ClusterWideConfigurationService.getRingbufferConfigs() |
Map<String,RingbufferConfig> |
ConfigurationService.getRingbufferConfigs()
Returns all registered ringbuffer configurations.
|
Modifier and Type | Method and Description |
---|---|
Config |
DynamicConfigurationAwareConfig.addRingBufferConfig(RingbufferConfig ringbufferConfig) |
Modifier and Type | Method and Description |
---|---|
Config |
DynamicConfigurationAwareConfig.setRingbufferConfigs(Map<String,RingbufferConfig> ringbufferConfigs) |
Modifier and Type | Method and Description |
---|---|
RingbufferConfig |
EventJournal.toRingbufferConfig(EventJournalConfig config,
ObjectNamespace namespace)
Creates a new
RingbufferConfig for a ringbuffer that will keep
event journal events for a single partition. |
Modifier and Type | Method and Description |
---|---|
RingbufferConfig |
RingbufferMapEventJournalImpl.toRingbufferConfig(EventJournalConfig config,
ObjectNamespace namespace) |
Modifier and Type | Method and Description |
---|---|
RingbufferConfig |
RingbufferContainer.getConfig() |
RingbufferConfig |
RingbufferService.getRingbufferConfig(String name) |
Modifier and Type | Method and Description |
---|---|
void |
RingbufferService.addRingbuffer(int partitionId,
RingbufferContainer ringbuffer,
RingbufferConfig config) |
<T,E> RingbufferContainer<T,E> |
RingbufferService.getOrCreateContainer(int partitionId,
ObjectNamespace namespace,
RingbufferConfig config)
Return the ringbuffer containter for the specified
namespace . |
void |
RingbufferContainer.init(RingbufferConfig config,
NodeEngine nodeEngine)
Initializes the ring buffer with references to other services, the
ringbuffer store and the config.
|
Constructor and Description |
---|
RingbufferContainer(ObjectNamespace namespace,
RingbufferConfig config,
NodeEngine nodeEngine,
int partitionId)
Constructs a fully initialized ringbuffer that can be used immediately.
|
RingbufferProxy(NodeEngine nodeEngine,
RingbufferService service,
String name,
RingbufferConfig config) |
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.