| Modifier and Type | Method and Description |
|---|---|
<T extends Event> |
IgniteEvents.localQuery(IgnitePredicate<T> p,
int... types)
Queries local node for events using passed-in predicate filter for event selection.
|
<T extends Event> |
IgniteEvents.remoteListen(@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
<T extends Event> |
IgniteEvents.remoteListen(int bufSize,
long interval,
boolean autoUnsubscribe,
@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
<T extends Event> |
IgniteEvents.remoteListenAsync(@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Asynchronously adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
<T extends Event> |
IgniteEvents.remoteListenAsync(int bufSize,
long interval,
boolean autoUnsubscribe,
@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Asynchronously adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
<T extends Event> |
IgniteEvents.remoteQuery(IgnitePredicate<T> p,
long timeout,
int... types)
Queries nodes in this cluster group for events using passed in predicate filter for event
selection.
|
<T extends Event> |
IgniteEvents.remoteQueryAsync(IgnitePredicate<T> p,
long timeout,
int... types)
Asynchronously queries nodes in this cluster group for events using passed in predicate filter for event
selection.
|
<T extends Event> |
IgniteEvents.waitForLocal(@Nullable IgnitePredicate<T> filter,
int... types)
Waits for the specified events.
|
<T extends Event> |
IgniteEvents.waitForLocalAsync(@Nullable IgnitePredicate<T> filter,
int... types)
Create future to wait for the specified events.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteEvents.recordLocal(Event evt)
Records customer user generated event.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteEvents.localListen(IgnitePredicate<? extends Event> lsnr,
int... types)
Adds an event listener for local events.
|
boolean |
IgniteEvents.stopLocalListen(IgnitePredicate<? extends Event> lsnr,
int... types)
Removes local event listener.
|
| Modifier and Type | Method and Description |
|---|---|
Map<IgnitePredicate<? extends Event>,int[]> |
IgniteConfiguration.getLocalEventListeners()
Gets map of pre-configured local event listeners.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteConfiguration |
IgniteConfiguration.setLocalEventListeners(Map<IgnitePredicate<? extends Event>,int[]> lsnrs)
Sets map of pre-configured local event listeners.
|
| Modifier and Type | Class and Description |
|---|---|
class |
BaselineChangedEvent
Baseline changed event.
|
class |
BaselineConfigurationChangedEvent
Baseline configuration changed event.
|
class |
CacheConsistencyViolationEvent<K,V>
This is an experimental API.
|
class |
CacheEvent
In-memory database (cache) event.
|
class |
CacheQueryExecutedEvent<K,V>
Cache query execution event.
|
class |
CacheQueryReadEvent<K,V>
Cache query read event.
|
class |
CacheRebalancingEvent
In-memory database (cache) rebalancing event.
|
class |
CheckpointEvent
Grid checkpoint event.
|
class |
ClusterActivationEvent
Deprecated.
Use
ClusterStateChangeEvent instead. |
class |
ClusterStateChangeEvent
Cluster state change event.
|
class |
ClusterStateChangeStartedEvent
Cluster state change started event.
|
class |
ClusterTagUpdatedEvent
Event type indicating that cluster tag has been updated.
|
class |
DeploymentEvent
Grid deployment event.
|
class |
DiscoveryEvent
Grid discovery event.
|
class |
EventAdapter
Base adapter for the events.
|
class |
JobEvent
Grid job event.
|
class |
NodeValidationFailedEvent
This event is triggered if any of
GridComponents fail to validate the joining node
while join message processing. |
class |
PageReplacementStartedEvent
Event type indicating that page replacement started in one of the configured data regions.
|
class |
SnapshotEvent
Event indicating the cluster snapshot operation result state with the given name.
|
class |
SqlQueryExecutionEvent
Query execution event.
|
class |
TaskEvent
Grid task event.
|
class |
TransactionStateChangedEvent
Event indicates transaction state change.
|
class |
WalSegmentArchivedEvent
Event indicates the completion of WAL segment file transition to archive.
|
class |
WalSegmentCompactedEvent
Event indicates the completion of WAL segment compaction.
|
| Modifier and Type | Method and Description |
|---|---|
int |
EventAdapter.compareTo(Event o) |
| Modifier and Type | Method and Description |
|---|---|
<T extends Event> |
IgniteEventsImpl.localQuery(IgnitePredicate<T> p,
int... types)
Queries local node for events using passed-in predicate filter for event selection.
|
<T extends Event> |
IgniteEventsImpl.remoteListen(@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
<T extends Event> |
IgniteEventsImpl.remoteListen(int bufSize,
long interval,
boolean autoUnsubscribe,
@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
<T extends Event> |
IgniteEventsImpl.remoteListenAsync(@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Asynchronously adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
<T extends Event> |
IgniteEventsImpl.remoteListenAsync(int bufSize,
long interval,
boolean autoUnsubscribe,
@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Asynchronously adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
<T extends Event> |
IgniteEventsImpl.remoteQuery(IgnitePredicate<T> p,
long timeout,
int... types)
Queries nodes in this cluster group for events using passed in predicate filter for event
selection.
|
<T extends Event> |
IgniteEventsImpl.remoteQueryAsync(IgnitePredicate<T> p,
long timeout,
int... types)
Asynchronously queries nodes in this cluster group for events using passed in predicate filter for event
selection.
|
<T extends Event> |
IgniteEventsImpl.waitForLocal(@Nullable IgnitePredicate<T> filter,
int... types)
Waits for the specified events.
|
<T extends Event> |
IgniteEventsImpl.waitForLocalAsync(@Nullable IgnitePredicate<T> filter,
int... types)
Create future to wait for the specified events.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteEventsImpl.recordLocal(Event evt)
Records customer user generated event.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteEventsImpl.localListen(IgnitePredicate<? extends Event> lsnr,
int[] types)
Adds an event listener for local events.
|
boolean |
IgniteEventsImpl.stopLocalListen(IgnitePredicate<? extends Event> lsnr,
int... types)
Removes local event listener.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DiscoveryCustomEvent
Custom event.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends Event> |
GridEventStorageManager.localEvents(IgnitePredicate<T> p) |
<T extends Event> |
GridEventStorageManager.remoteEventsAsync(IgnitePredicate<T> p,
Collection<? extends ClusterNode> nodes,
long timeout) |
<T extends Event> |
GridEventStorageManager.waitForEvent(@Nullable IgnitePredicate<T> p,
int... types) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridLocalEventListener.onEvent(Event evt)
Local event callback.
|
void |
GridEventStorageManager.record(Event evt)
Records event if it's recordable.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridEventStorageManager.addLocalEventListener(IgnitePredicate<? extends Event> lsnr,
int[] types)
Adds local user event listener.
|
boolean |
GridEventStorageManager.removeLocalEventListener(IgnitePredicate<? extends Event> lsnr,
int... types)
Removes user listener for specified events, if any.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ChangeTopologyWatcher.onEvent(Event evt)
Local event callback.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PlatformContextImpl.writeEvent(BinaryRawWriterEx writer,
Event evt)
Write event.
|
void |
PlatformContext.writeEvent(BinaryRawWriterEx writer,
Event evt)
Write event.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
PlatformEventFilterListenerImpl.apply(Event evt)
Predicate body.
|
boolean |
PlatformLocalEventListener.apply(Event evt)
Predicate body.
|
boolean |
PlatformEventFilterListenerImpl.apply(UUID uuid,
Event evt)
Predicate body.
|
| Modifier and Type | Method and Description |
|---|---|
VisorGridEvent |
VisorEventMapper.apply(Event evt)
Closure body.
|
protected VisorGridEvent |
VisorEventMapper.map(Event evt,
int type,
IgniteUuid id,
String name,
UUID nid,
long ts,
String msg,
String shortDisplay)
Map grid event to Visor data transfer object.
|
| Modifier and Type | Method and Description |
|---|---|
static Collection<VisorGridEvent> |
VisorTaskUtils.collectEvents(Ignite ignite,
String evtOrderKey,
String evtThrottleCntrKey,
boolean all,
IgniteClosure<Event,VisorGridEvent> evtMapper)
Grabs local events and detects if events was lost since last poll.
|
static List<VisorGridEvent> |
VisorTaskUtils.collectEvents(Ignite ignite,
String evtOrderKey,
String evtThrottleCntrKey,
int[] evtTypes,
IgniteClosure<Event,VisorGridEvent> evtMapper)
Grabs local events and detects if events was lost since last poll.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteSpiContext.recordEvent(Event evt)
Records local event.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CommunicationDiscoveryEventListener.onEvent(Event evt)
Local event callback.
|
void |
TcpCommunicationConnectionCheckFuture.onEvent(Event evt)
Local event callback.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends Event> |
EventStorageSpi.localEvents(IgnitePredicate<T> p)
Queries locally-stored events only.
|
<T extends Event> |
NoopEventStorageSpi.localEvents(IgnitePredicate<T> p)
Queries locally-stored events only.
|
| Modifier and Type | Method and Description |
|---|---|
void |
EventStorageSpi.record(Event evt)
Records single event.
|
void |
NoopEventStorageSpi.record(Event evt)
Records single event.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends Event> |
MemoryEventStorageSpi.localEvents(IgnitePredicate<T> p)
Queries locally-stored events only.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<Event> |
MemoryEventStorageSpi.getFilter()
Gets filter for events to be recorded.
|
| Modifier and Type | Method and Description |
|---|---|
void |
MemoryEventStorageSpi.record(Event evt)
Records single event.
|
| Modifier and Type | Method and Description |
|---|---|
MemoryEventStorageSpi |
MemoryEventStorageSpi.setFilter(IgnitePredicate<Event> filter)
Sets filter for events to be recorded.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.10.0 Release Date : March 10 2021