Package | Description |
---|---|
com.tangosol.coherence.jcache.localcache |
Contains classes related to local cache implementation of Coherence JCache.
|
com.tangosol.coherence.jcache.partitionedcache |
Contains classes related to partitioned cache implementation of Coherence JCache.
|
com.tangosol.coherence.jcache.passthroughcache |
Contains classes related to pass-through cache implementation of Coherence JCache.
|
com.tangosol.coherence.rest.events | |
com.tangosol.net.cache |
Contains classes providing various caching strategies.
|
com.tangosol.util |
Contains various generic utilities.
|
com.tangosol.util.filter |
Contains concrete
Filter implementations and related interfaces. |
com.tangosol.util.transformer |
Contains concrete
MapEventTransformer
implementations. |
Modifier and Type | Method and Description |
---|---|
void |
LocalCacheAsynchronousMapListener.entryDeleted(MapEvent evt) |
void |
LocalCacheAsynchronousMapListener.entryInserted(MapEvent evt) |
void |
LocalCacheAsynchronousMapListener.entryUpdated(MapEvent evt) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionedCacheConfigurationMapListener.entryDeleted(MapEvent evt)
Remove JCacheContext for JCache identified by evt.getKey().
|
void |
PartitionedCacheAsynchronousMapListener.entryDeleted(MapEvent evt) |
void |
PartitionedCacheAsynchronousMapListener.entryInserted(MapEvent evt) |
void |
PartitionedCacheAsynchronousMapListener.entryUpdated(MapEvent evt) |
void |
PartitionedCacheSyntheticDeleteMapListener.entryUpdated(MapEvent evt)
These updated mapEvents were decorated with JACHE_SYNTHETIC_EXPIRY or JCACHE_SYNTHETIC_EXPIRY_EVENT_FOR_ORIGINAL_VALUES.
|
Modifier and Type | Method and Description |
---|---|
void |
PassThroughMapListenerAdapter.entryDeleted(MapEvent event) |
void |
PassThroughMapListenerAdapter.entryInserted(MapEvent event) |
void |
PassThroughMapListenerAdapter.entryUpdated(MapEvent event) |
static <K,V> PassThroughCacheEntryEvent<K,V> |
PassThroughCacheEntryEvent.from(MapEvent event)
Creates a
PassThroughCacheEntryEvent based on a MapEvent |
Constructor and Description |
---|
PassThroughCacheEntryEvent(javax.cache.Cache<K,V> cache,
javax.cache.event.EventType type,
MapEvent event)
Constructs a
PassThroughCacheEntryEvent . |
Modifier and Type | Method and Description |
---|---|
protected org.glassfish.jersey.media.sse.OutboundEvent |
MapEventOutput.createEvent(String sName,
MapEvent<? extends K,? extends V> evt)
Convert MapEvent to JSON-based OutboundEvent that can be sent to the client.
|
void |
MapEventOutput.entryDeleted(MapEvent<K,V> evt) |
void |
MapEventOutput.entryInserted(MapEvent<K,V> evt) |
void |
MapEventOutput.entryUpdated(MapEvent<K,V> evt) |
protected void |
MapEventOutput.writeEvent(String sName,
MapEvent<? extends K,? extends V> evt)
Write single event to this EventOutput.
|
Constructor and Description |
---|
SimpleMapEvent(MapEvent<? extends K,? extends V> evt)
Construct SimpleMapEvent instance.
|
Modifier and Type | Class and Description |
---|---|
class |
CacheEvent<K,V>
An extension of the MapEvent which allows to differentiate between client
driven (natural) events and cache internal (synthetic) events.
|
protected static class |
OverflowMap.HistoricCacheEvent
A CacheEvent that carries a recent value (to avoid it being lost during
eviction).
|
Modifier and Type | Method and Description |
---|---|
MapEvent |
OverflowMap.Status.closeProcessing()
Finish the processing of the entry for which this Status exists and
proceed to the commit phase.
|
MapEvent |
SimpleOverflowMap.Status.closeProcessing()
Finish the processing of the entry for which this Status exists and
proceed to the commit phase.
|
protected MapEvent |
OverflowMap.Status.getBackEvent()
For internal use only, return the current event from the back
Map.
|
protected MapEvent |
OverflowMap.Status.getFrontEvent()
For internal use only, return the current event from the front
Map.
|
protected MapEvent |
SimpleOverflowMap.Status.getFrontEvent()
For internal use only, return the current event from the front
Map.
|
protected MapEvent |
LocalCache.instantiateMapEvent(int nId,
Object oKey,
Object oValueOld,
Object oValueNew)
Factory pattern: instantiate a new CacheEvent corresponding
to the specified parameters.
|
protected MapEvent |
OldCache.instantiateMapEvent(int nId,
Object oKey,
Object oValueOld,
Object oValueNew)
Deprecated.
Factory pattern: instantiate a new MapEvent corresponding
to the specified parameters.
|
protected static MapEvent |
OverflowMap.mergeEvents(MapEvent evtOld,
MapEvent evtNew)
Merge two events that have been raised in sequence from a given
map.
|
protected MapEvent |
SimpleOverflowMap.Status.mergeEvents(MapEvent evtOld,
MapEvent evtNew)
Merge two events that have been raised in sequence from a given
map.
|
MapEvent |
OverflowMap.Status.takeBackEvent()
Obtain the most recent back Map event that has occurred against
the Entry for which this Status exists.
|
MapEvent |
OverflowMap.Status.takeEvent()
Obtain the most recent event that has occurred against the Entry
for which this Status exists.
|
MapEvent |
SimpleOverflowMap.Status.takeEvent()
Obtain the most recent front Map event that has occurred against
the Entry for which this Status exists.
|
MapEvent |
OverflowMap.Status.takeFrontEvent()
Obtain the most recent front Map event that has occurred against
the Entry for which this Status exists.
|
protected MapEvent |
SimpleOverflowMap.Status.useReservation()
After having successfully made a reservation, this method completes
the reservation process by setting the status to processing for the
thread that made the reservation.
|
protected MapEvent |
OverflowMap.Status.waitForAvailable()
Wait for the Entry that this Status represents to become available.
|
protected MapEvent |
SimpleOverflowMap.Status.waitForAvailable()
Wait for the Entry that this Status represents to become available.
|
Modifier and Type | Method and Description |
---|---|
protected void |
ReadWriteBackingMap.InternalMapListener.dispatch(MapEvent evt)
Dispatch the event to the corresponding listeners.
|
protected void |
OldCache.dispatchEvent(MapEvent evt)
Deprecated.
Dispatch the passed event.
|
protected void |
OverflowMap.dispatchEvent(OverflowMap.Status status,
MapEvent evt)
Dispatch the passed event.
|
protected ConfigurableCacheMap |
AbstractEvictionPolicy.ensureCache(MapEvent evt)
Return the ConfigurableCacheMap that uses this eviction policy.
|
void |
LocalCache.InternalListener.entryDeleted(MapEvent evt)
Invoked when a map entry has been removed.
|
void |
CachingMap.DeactivationListener.entryDeleted(MapEvent evt) |
void |
CachingMap.FrontMapListener.entryDeleted(MapEvent evt) |
void |
ReadWriteBackingMap.InternalMapListener.entryDeleted(MapEvent evt)
Invoked when a map entry has been removed.
|
void |
SeppukuMapListener.entryDeleted(MapEvent evt)
Invoked when a map entry has been removed.
|
void |
ContinuousQueryCache.DeactivationListener.entryDeleted(MapEvent evt) |
void |
AbstractEvictionPolicy.entryDeleted(MapEvent evt)
Invoked when a map entry has been removed.
|
void |
VersionedNearCache.VersionCacheListener.entryDeleted(MapEvent evt)
Invoked when a map entry has been removed.
|
void |
LocalCache.InternalListener.entryInserted(MapEvent evt)
Invoked when a map entry has been inserted.
|
void |
ReadWriteBackingMap.InternalMapListener.entryInserted(MapEvent evt)
Invoked when a map entry has been inserted.
|
void |
SeppukuMapListener.entryInserted(MapEvent evt)
Invoked when a map entry has been inserted.
|
void |
AbstractEvictionPolicy.entryInserted(MapEvent evt)
Invoked when a map entry has been inserted.
|
void |
LocalCache.InternalListener.entryUpdated(MapEvent evt)
Invoked when a map entry has been updated.
|
void |
CachingMap.DeactivationListener.entryUpdated(MapEvent evt) |
void |
ReadWriteBackingMap.InternalMapListener.entryUpdated(MapEvent evt)
Invoked when a map entry has been updated.
|
void |
SeppukuMapListener.entryUpdated(MapEvent evt)
Invoked when a map entry has been updated.
|
void |
ContinuousQueryCache.DeactivationListener.entryUpdated(MapEvent evt) |
void |
AbstractEvictionPolicy.entryUpdated(MapEvent evt)
Invoked when a map entry has been updated.
|
void |
VersionedNearCache.VersionCacheListener.entryUpdated(MapEvent evt)
Invoked when a map entry has been updated.
|
protected ConfigurableCacheMap.Entry |
AbstractEvictionPolicy.getEntry(MapEvent evt)
Return the map entry associated with the given map event.
|
protected static Object |
OverflowMap.getLatestOldValue(MapEvent evt)
Obtain the latest old value from the passed event.
|
protected boolean |
CachingMap.isPriming(MapEvent evt)
Check if the specified event is a "priming" one.
|
protected static boolean |
OverflowMap.isSynthetic(MapEvent evt)
Helper method to determine if an event is synthetic.
|
protected static MapEvent |
OverflowMap.mergeEvents(MapEvent evtOld,
MapEvent evtNew)
Merge two events that have been raised in sequence from a given
map.
|
protected static MapEvent |
OverflowMap.mergeEvents(MapEvent evtOld,
MapEvent evtNew)
Merge two events that have been raised in sequence from a given
map.
|
protected MapEvent |
SimpleOverflowMap.Status.mergeEvents(MapEvent evtOld,
MapEvent evtNew)
Merge two events that have been raised in sequence from a given
map.
|
protected MapEvent |
SimpleOverflowMap.Status.mergeEvents(MapEvent evtOld,
MapEvent evtNew)
Merge two events that have been raised in sequence from a given
map.
|
protected void |
OverflowMap.onBackEvent(MapEvent evtBack)
Handle an event occuring against the "back" map.
|
protected void |
OverflowMap.onFrontEvent(MapEvent evt)
Either handle an event by turning it over to another thread that is
processing the key specified by the event, or take responsibility on
this thread for deferring the event and registering its immediate
side-effects.
|
protected void |
SimpleOverflowMap.onFrontEvent(MapEvent evt)
Either handle an event by turning it over to another thread that is
processing the key specified by the event, or take responsibility on
this thread for deferring the event and registering its immediate
side-effects.
|
protected void |
CachingMap.PrimingListener.onMapEvent(MapEvent evt) |
protected void |
CachingMap.SimpleListener.onMapEvent(MapEvent evt) |
protected void |
OverflowMap.FrontMapListener.onMapEvent(MapEvent evt)
Invoked when a map entry has been inserted, updated or deleted.
|
protected void |
OverflowMap.BackMapListener.onMapEvent(MapEvent evt)
Invoked when a map entry has been inserted, updated or deleted.
|
protected void |
SimpleOverflowMap.FrontMapListener.onMapEvent(MapEvent evt)
Invoked when a map entry has been inserted, updated or deleted.
|
protected void |
ContinuousQueryCache.AddListener.onMapEvent(MapEvent<K,V_FRONT> evt) |
protected void |
ContinuousQueryCache.RemoveListener.onMapEvent(MapEvent<K,V_FRONT> evt) |
protected void |
ContinuousQueryCache.InternalMapListener.onMapEvent(MapEvent<K,V_FRONT> evt)
Dispatch events received from the internal map to the
MapListenerSupport 's registered
MapListener s. |
protected void |
ContinuousQueryCache.EventRouter.onMapEvent(MapEvent<K,V> evt) |
protected void |
LocalCache.InternalListener.onModify(MapEvent evt)
A value modification event (insert or update) has occurred.
|
protected void |
OverflowMap.processBackEvent(OverflowMap.Status status,
MapEvent evtBack)
Process an event.
|
protected void |
OverflowMap.processEvent(OverflowMap.Status status,
MapEvent evt)
Process an arbitrary event that has occurred against either the front
or back map.
|
protected void |
OverflowMap.processFrontEvent(OverflowMap.Status status,
MapEvent evtFront)
Process an event.
|
protected void |
SimpleOverflowMap.processFrontEvent(SimpleOverflowMap.Status status,
MapEvent evt)
Process an event.
|
boolean |
OverflowMap.Status.registerBackEvent(MapEvent evt)
Register a MapEvent that has been raised by the back Map against
the same key for which this Status object exists.
|
boolean |
OverflowMap.Status.registerFrontEvent(MapEvent evt)
Register a MapEvent that has been raised by the front Map against
the same key for which this Status object exists.
|
boolean |
SimpleOverflowMap.Status.registerFrontEvent(MapEvent evt)
Register a MapEvent that has been raised by the front Map against
the same key for which this Status object exists.
|
protected void |
OverflowMap.Status.setBackEvent(MapEvent evt)
For internal use only, store the current event from the back Map.
|
protected void |
OverflowMap.Status.setFrontEvent(MapEvent evt)
For internal use only, store the current event from the front Map.
|
protected void |
SimpleOverflowMap.Status.setFrontEvent(MapEvent evt)
For internal use only, store the current event from the front Map.
|
protected void |
CachingMap.validate(MapEvent evt)
Validate the front map entry for the specified back map event.
|
protected static void |
OverflowMap.warnEventSequence(MapEvent evtOld,
MapEvent evtNew)
Issue a one-time warning that events are being received in an order
than cannot be explained by normal operation according to the
contracts expected by this OverflowMap.
|
protected static void |
OverflowMap.warnEventSequence(MapEvent evtOld,
MapEvent evtNew)
Issue a one-time warning that events are being received in an order
than cannot be explained by normal operation according to the
contracts expected by this OverflowMap.
|
protected static void |
SimpleOverflowMap.warnEventSequence(MapEvent evtOld,
MapEvent evtNew)
Issue a one-time warning that events are being received in an order
than cannot be explained by normal operation according to the
contracts expected by this OverflowMap.
|
protected static void |
SimpleOverflowMap.warnEventSequence(MapEvent evtOld,
MapEvent evtNew)
Issue a one-time warning that events are being received in an order
than cannot be explained by normal operation according to the
contracts expected by this OverflowMap.
|
protected void |
OverflowMap.warnUnfathomable(MapEvent evt)
Something totally inexplicable has occurred.
|
Modifier and Type | Class and Description |
---|---|
protected static class |
AbstractKeyBasedMap.DeferredCacheEvent<K,V>
A DeferredCacheEvent is a
CacheEvent object that defers the loading
of the old value . |
static class |
ConverterCollections.ConverterCacheEvent
A Converter CacheEvent views an underlying CacheEvent through a set of
key and value Converters.
|
static class |
ConverterCollections.ConverterMapEvent
A ConverterMapEvent views an underlying MapEvent through a set of key and
value Converters.
|
static class |
MapListenerSupport.FilterEvent
An extension of the CacheEvent which may carry no values (old or new), but
instead holds on an array of Filter objects being the "cause" of the event.
|
Modifier and Type | Field and Description |
---|---|
protected MapEvent |
MapListenerSupport.FilterEvent.f_event
Optional wrapped MapEvent.
|
protected MapEvent |
ConverterCollections.ConverterMapEvent.m_event
The underlying MapEvent.
|
Modifier and Type | Method and Description |
---|---|
static MapEvent |
MapListenerSupport.convertEvent(MapEvent event,
ObservableMap mapConv,
Converter convKey,
Converter convVal)
Convert the specified map event into another MapEvent that ensures the
lazy event data conversion using the specified converters.
|
static MapEvent |
MapListenerSupport.enrichEvent(MapEvent event,
Listeners listeners)
Transform the given MapEvent into a FilterEvent if it is not already a
FilterEvent and there are matching filters associated with the
specified Listeners object.
|
MapEvent |
MapListenerSupport.FilterEvent.getMapEvent()
Return the wrapped event.
|
MapEvent |
ConverterCollections.ConverterMapEvent.getMapEvent()
Return the underlying MapEvent.
|
static MapEvent |
ConverterCollections.getMapEvent(ObservableMap map,
MapEvent event,
Converter convKey,
Converter convVal)
Returns an instance of a MapEvent that uses Converters to retrieve
the event's data.
|
static MapEvent |
ConverterCollections.getMapEvent(ObservableMap map,
MapEvent event,
Converter convKey,
Converter convVal,
BackingMapManagerContext context)
Returns an instance of a MapEvent that uses Converters to retrieve the
event's data, and additionally provides access to the
BackingMapManagerContext.
|
MapEvent<K,U> |
MapEventTransformer.transform(MapEvent<K,V> event)
Transform the specified MapEvent.
|
static MapEvent |
MapListenerSupport.unwrapEvent(MapEvent evt)
Unwrap the specified map event and return the underlying source event.
|
Modifier and Type | Method and Description |
---|---|
Listeners |
MapListenerSupport.collectListeners(MapEvent event)
Collect all Listeners that should be notified for a given event.
|
static MapEvent |
MapListenerSupport.convertEvent(MapEvent event,
ObservableMap mapConv,
Converter convKey,
Converter convVal)
Convert the specified map event into another MapEvent that ensures the
lazy event data conversion using the specified converters.
|
protected void |
ObservableHashMap.dispatchEvent(MapEvent evt)
Dispatch the passed event.
|
protected void |
WrapperObservableMap.dispatchEvent(MapEvent<? extends K,? extends V> evt)
Dispatch the passed event.
|
static MapEvent |
MapListenerSupport.enrichEvent(MapEvent event,
Listeners listeners)
Transform the given MapEvent into a FilterEvent if it is not already a
FilterEvent and there are matching filters associated with the
specified Listeners object.
|
void |
AbstractMapListener.entryDeleted(MapEvent evt)
Invoked when a map entry has been removed.
|
void |
InvocableMapHelper.IndexAdapter.entryDeleted(MapEvent evt)
Invoked when a map entry has been removed.
|
void |
MultiplexingMapListener.entryDeleted(MapEvent<K,V> evt)
Invoked when a map entry has been removed.
|
void |
MapListener.entryDeleted(MapEvent<K,V> evt)
Invoked when a map entry has been removed.
|
void |
AbstractMapListener.entryInserted(MapEvent evt)
Invoked when a map entry has been inserted.
|
void |
InvocableMapHelper.IndexAdapter.entryInserted(MapEvent evt)
Invoked when a map entry has been inserted.
|
void |
MultiplexingMapListener.entryInserted(MapEvent<K,V> evt)
Invoked when a map entry has been inserted.
|
void |
MapListener.entryInserted(MapEvent<K,V> evt)
Invoked when a map entry has been inserted.
|
void |
AbstractMapListener.entryUpdated(MapEvent evt)
Invoked when a map entry has been updated.
|
void |
InvocableMapHelper.IndexAdapter.entryUpdated(MapEvent evt)
Invoked when a map entry has been updated.
|
void |
MultiplexingMapListener.entryUpdated(MapEvent<K,V> evt)
Invoked when a map entry has been updated.
|
void |
MapListener.entryUpdated(MapEvent<K,V> evt)
Invoked when a map entry has been updated.
|
protected boolean |
MapListenerSupport.evaluateEvent(Filter filter,
MapEvent event)
Evaluate whether or not the specified event should be delivered to the
listener associated with the specified filter.
|
void |
MapListenerSupport.fireEvent(MapEvent event,
boolean fStrict)
Fire the specified map event.
|
static MapEvent |
ConverterCollections.getMapEvent(ObservableMap map,
MapEvent event,
Converter convKey,
Converter convVal)
Returns an instance of a MapEvent that uses Converters to retrieve
the event's data.
|
static MapEvent |
ConverterCollections.getMapEvent(ObservableMap map,
MapEvent event,
Converter convKey,
Converter convVal,
BackingMapManagerContext context)
Returns an instance of a MapEvent that uses Converters to retrieve the
event's data, and additionally provides access to the
BackingMapManagerContext.
|
protected static <K,V> boolean |
WrapperObservableMap.isSynthetic(MapEvent<K,V> evt)
Helper method to determine if an event is synthetic.
|
protected boolean |
MapListenerSupport.isTransformedEvent(MapEvent event)
Return true iff the specified event represents a transformed CacheEvent.
|
protected void |
MapTriggerListener.onMapEvent(MapEvent evt)
Invoked when a map entry has been inserted, updated or deleted.
|
protected void |
MapListenerSupport.WrapperPrimingListener.onMapEvent(MapEvent evt)
Invoked when a map entry has been inserted, updated or deleted.
|
protected void |
ConverterCollections.ConverterMapListener.onMapEvent(MapEvent evt) |
protected void |
ConverterCollections.ConverterCacheListener.onMapEvent(MapEvent evt) |
protected abstract void |
MultiplexingMapListener.onMapEvent(MapEvent<K,V> evt)
Invoked when a map entry has been inserted, updated or deleted.
|
protected void |
MapListenerSupport.WrapperListener.onMapEvent(MapEvent<K,V> evt)
Invoked when a map entry has been inserted, updated or deleted.
|
protected void |
WrapperObservableMap.InternalListener.onMapEvent(MapEvent<K,V> evt)
Invoked when a map entry has been inserted, updated or deleted.
|
MapEvent<K,U> |
MapEventTransformer.transform(MapEvent<K,V> event)
Transform the specified MapEvent.
|
static MapEvent |
MapListenerSupport.unwrapEvent(MapEvent evt)
Unwrap the specified map event and return the underlying source event.
|
Constructor and Description |
---|
ConverterMapEvent(ObservableMap map,
MapEvent event,
Converter convKey,
Converter convVal)
Construct a ConverterMapEvent.
|
ConverterMapEvent(ObservableMap map,
MapEvent event,
Converter convKey,
Converter convVal,
BackingMapManagerContext context)
Construct a ConverterMapEvent.
|
FilterEvent(MapEvent event,
Filter[] aFilter)
Constructs a new FilterEvent that wraps the given MapEvent.
|
Modifier and Type | Method and Description |
---|---|
MapEvent |
MapEventTransformerFilter.transform(MapEvent event)
Remove an old value from the specified MapEvent.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ValueChangeEventFilter.evaluate(MapEvent<?,V> event)
Apply the test to the input argument.
|
boolean |
CacheEventFilter.evaluate(MapEvent<K,V> o)
Apply the test to the input argument.
|
boolean |
MapEventFilter.evaluate(MapEvent<K,V> event)
Apply the test to the input argument.
|
MapEvent |
MapEventTransformerFilter.transform(MapEvent event)
Remove an old value from the specified MapEvent.
|
Modifier and Type | Method and Description |
---|---|
MapEvent<K,E> |
ExtractorEventTransformer.transform(MapEvent<K,V> event)
Transform the specified MapEvent using the corresponding extractors.
|
MapEvent<K,V> |
SamplingEventTransformer.transform(MapEvent<K,V> event) |
MapEvent<K,V> |
SemiLiteEventTransformer.transform(MapEvent<K,V> event)
Remove an old value from the specified MapEvent.
|
Modifier and Type | Method and Description |
---|---|
MapEvent<K,E> |
ExtractorEventTransformer.transform(MapEvent<K,V> event)
Transform the specified MapEvent using the corresponding extractors.
|
MapEvent<K,V> |
SamplingEventTransformer.transform(MapEvent<K,V> event) |
MapEvent<K,V> |
SemiLiteEventTransformer.transform(MapEvent<K,V> event)
Remove an old value from the specified MapEvent.
|