| /* |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You under the Apache License, Version 2.0 |
| * (the "License"); you may not use this file except in compliance with |
| * the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| package org.apache.ignite.events; |
| |
| import java.util.Collection; |
| import java.util.List; |
| import org.apache.ignite.IgniteCache; |
| import org.apache.ignite.IgniteCluster; |
| import org.apache.ignite.IgniteEvents; |
| import org.apache.ignite.IgniteSnapshot; |
| import org.apache.ignite.compute.ComputeTaskSession; |
| import org.apache.ignite.configuration.IgniteConfiguration; |
| import org.apache.ignite.internal.GridComponent; |
| import org.apache.ignite.internal.util.typedef.internal.U; |
| import org.apache.ignite.lang.IgnitePredicate; |
| import org.apache.ignite.spi.checkpoint.CheckpointSpi; |
| import org.apache.ignite.spi.eventstorage.NoopEventStorageSpi; |
| import org.apache.ignite.spi.eventstorage.memory.MemoryEventStorageSpi; |
| |
| /** |
| * Contains event type constants. The decision to use class and not enumeration |
| * dictated by allowing users to create their own events and/or event types which |
| * would be impossible with enumerations. |
| * <p> |
| * Note that this interface defines not only |
| * individual type constants but arrays of types as well to be conveniently used with |
| * {@link IgniteEvents#localListen(IgnitePredicate, int...)} method: |
| * <ul> |
| * <li>{@link #EVTS_CACHE}</li> |
| * <li>{@link #EVTS_CACHE_LIFECYCLE}</li> |
| * <li>{@link #EVTS_CACHE_REBALANCE}</li> |
| * <li>{@link #EVTS_CACHE_QUERY}</li> |
| * <li>{@link #EVTS_CHECKPOINT}</li> |
| * <li>{@link #EVTS_DEPLOYMENT}</li> |
| * <li>{@link #EVTS_DISCOVERY}</li> |
| * <li>{@link #EVTS_DISCOVERY_ALL}</li> |
| * <li>{@link #EVTS_ERROR}</li> |
| * <li>{@link #EVTS_JOB_EXECUTION}</li> |
| * <li>{@link #EVTS_TASK_EXECUTION}</li> |
| * </ul> |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * <h1 class="header">Events and Performance</h1> |
| * Note that by default all events in Ignite are enabled and therefore generated and stored |
| * by whatever event storage SPI is configured. Ignite can and often does generate thousands events per seconds |
| * under the load and therefore it creates a significant additional load on the system. If these events are |
| * not needed by the application this load is unnecessary and leads to significant performance degradation. |
| * <p> |
| * It is <b>highly recommended</b> to enable only those events that your application logic requires |
| * by using either {@link IgniteConfiguration#getIncludeEventTypes()} method in Ignite configuration. |
| * Note that certain events are required for Ignite's internal operations and such events will still be |
| * generated but not stored by event storage SPI if they are disabled in Ignite configuration. |
| */ |
| public interface EventType { |
| /** |
| * Built-in event type: intermediate state of a job or task, so-called checkpoint, was saved. |
| * <p> |
| * Checkpointing provides the ability to save an intermediate job state. |
| * It can be useful when long running jobs need to store some intermediate state to protect from node failures. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CheckpointEvent |
| * @see CheckpointSpi |
| * @see ComputeTaskSession#saveCheckpoint(String, Object) |
| */ |
| public static final int EVT_CHECKPOINT_SAVED = 1; |
| |
| /** |
| * Built-in event type: intermediate state of a job or task, so-called checkpoint, was loaded. |
| * <p> |
| * Checkpointing provides the ability to save an intermediate job state. |
| * It can be useful when long running jobs need to store some intermediate state to protect from node failures. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CheckpointEvent |
| * @see CheckpointSpi |
| * @see ComputeTaskSession#loadCheckpoint(String) |
| */ |
| public static final int EVT_CHECKPOINT_LOADED = 2; |
| |
| /** |
| * Built-in event type: intermediate state of a job or task, so-called checkpoint, was removed. Reasons are: |
| * <ul> |
| * <li>timeout expired, or |
| * <li>or it was manually removed, or |
| * <li>it was automatically removed by the task session |
| * </ul> |
| * <p> |
| * Checkpointing provides the ability to save an intermediate job state. |
| * It can be useful when long running jobs need to store some intermediate state to protect from node failures. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CheckpointEvent |
| * @see CheckpointSpi |
| * @see ComputeTaskSession#removeCheckpoint(String) |
| */ |
| public static final int EVT_CHECKPOINT_REMOVED = 3; |
| |
| /** |
| * Built-in event type: node joined topology. |
| * <br> |
| * New node has been discovered and joined grid topology. |
| * Note that even though a node has been discovered there could be |
| * a number of warnings in the log. In certain situations Ignite |
| * doesn't prevent a node from joining but prints warning messages into the log. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see DiscoveryEvent |
| */ |
| public static final int EVT_NODE_JOINED = 10; |
| |
| /** |
| * Built-in event type: node has normally left topology. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see DiscoveryEvent |
| */ |
| public static final int EVT_NODE_LEFT = 11; |
| |
| /** |
| * Built-in event type: node failed. |
| * <br> |
| * Ignite detected that node has presumably crashed and is considered failed. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see DiscoveryEvent |
| */ |
| public static final int EVT_NODE_FAILED = 12; |
| |
| /** |
| * Built-in event type: node metrics updated. |
| * <br> |
| * Generated when node's metrics are updated. In most cases this callback |
| * is invoked with every metrics update received from a node (including local node). |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see DiscoveryEvent |
| */ |
| public static final int EVT_NODE_METRICS_UPDATED = 13; |
| |
| /** |
| * Built-in event type: local node segmented. |
| * <br> |
| * Generated when node determines that it runs in invalid network segment. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see DiscoveryEvent |
| */ |
| public static final int EVT_NODE_SEGMENTED = 14; |
| |
| /** |
| * Built-in event type: client node disconnected. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see DiscoveryEvent |
| */ |
| public static final int EVT_CLIENT_NODE_DISCONNECTED = 16; |
| |
| /** |
| * Built-in event type: client node reconnected. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see DiscoveryEvent |
| */ |
| public static final int EVT_CLIENT_NODE_RECONNECTED = 17; |
| |
| /** |
| * Built-in event type: task started. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see TaskEvent |
| */ |
| public static final int EVT_TASK_STARTED = 20; |
| |
| /** |
| * Built-in event type: task finished. |
| * <br> |
| * Task got finished. This event is triggered every time |
| * a task finished without exception. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see TaskEvent |
| */ |
| public static final int EVT_TASK_FINISHED = 21; |
| |
| /** |
| * Built-in event type: task failed. |
| * <br> |
| * Task failed. This event is triggered every time a task finished with an exception. |
| * Note that prior to this event, there could be other events recorded specific |
| * to the failure. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see TaskEvent |
| */ |
| public static final int EVT_TASK_FAILED = 22; |
| |
| /** |
| * Built-in event type: task timed out. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see TaskEvent |
| */ |
| public static final int EVT_TASK_TIMEDOUT = 23; |
| |
| /** |
| * Built-in event type: task session attribute set. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see TaskEvent |
| */ |
| public static final int EVT_TASK_SESSION_ATTR_SET = 24; |
| |
| /** |
| * Built-in event type: task reduced. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| */ |
| public static final int EVT_TASK_REDUCED = 25; |
| |
| /** |
| * Built-in event type: Visor or Web Console management task started. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see TaskEvent |
| */ |
| public static final int EVT_MANAGEMENT_TASK_STARTED = 26; |
| |
| /** |
| * Built-in event type: non-task class deployed. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see DeploymentEvent |
| */ |
| public static final int EVT_CLASS_DEPLOYED = 30; |
| |
| /** |
| * Built-in event type: non-task class undeployed. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see DeploymentEvent |
| */ |
| public static final int EVT_CLASS_UNDEPLOYED = 31; |
| |
| /** |
| * Built-in event type: non-task class deployment failed. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see DeploymentEvent |
| */ |
| public static final int EVT_CLASS_DEPLOY_FAILED = 32; |
| |
| /** |
| * Built-in event type: task deployed. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see DeploymentEvent |
| */ |
| public static final int EVT_TASK_DEPLOYED = 33; |
| |
| /** |
| * Built-in event type: task undeployed. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see DeploymentEvent |
| */ |
| public static final int EVT_TASK_UNDEPLOYED = 34; |
| |
| /** |
| * Built-in event type: task deployment failed. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see DeploymentEvent |
| */ |
| public static final int EVT_TASK_DEPLOY_FAILED = 35; |
| |
| /** |
| * Built-in event type: grid job was mapped in |
| * {@link org.apache.ignite.compute.ComputeTask#map(List, Object)} method. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see JobEvent |
| */ |
| public static final int EVT_JOB_MAPPED = 40; |
| |
| /** |
| * Built-in event type: grid job result was received by |
| * {@link org.apache.ignite.compute.ComputeTask#result(org.apache.ignite.compute.ComputeJobResult, List)} method. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see JobEvent |
| */ |
| public static final int EVT_JOB_RESULTED = 41; |
| |
| /** |
| * Built-in event type: grid job failed over. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see JobEvent |
| */ |
| public static final int EVT_JOB_FAILED_OVER = 43; |
| |
| /** |
| * Built-in event type: grid job started. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see JobEvent |
| */ |
| public static final int EVT_JOB_STARTED = 44; |
| |
| /** |
| * Built-in event type: grid job finished. |
| * <br> |
| * Job has successfully completed and produced a result which from the user perspective |
| * can still be either negative or positive. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see JobEvent |
| */ |
| public static final int EVT_JOB_FINISHED = 45; |
| |
| /** |
| * Built-in event type: grid job timed out. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see JobEvent |
| */ |
| public static final int EVT_JOB_TIMEDOUT = 46; |
| |
| /** |
| * Built-in event type: grid job rejected during collision resolution. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see JobEvent |
| */ |
| public static final int EVT_JOB_REJECTED = 47; |
| |
| /** |
| * Built-in event type: grid job failed. |
| * <br> |
| * Job has failed. This means that there was some error event during job execution |
| * and job did not produce a result. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see JobEvent |
| */ |
| public static final int EVT_JOB_FAILED = 48; |
| |
| /** |
| * Built-in event type: grid job queued. |
| * <br> |
| * Job arrived for execution and has been queued (added to passive queue during |
| * collision resolution). |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see JobEvent |
| */ |
| public static final int EVT_JOB_QUEUED = 49; |
| |
| /** |
| * Built-in event type: grid job cancelled. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see JobEvent |
| */ |
| public static final int EVT_JOB_CANCELLED = 50; |
| |
| /** |
| * Built-in event type: entry created. |
| * <p/> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheEvent |
| */ |
| public static final int EVT_CACHE_ENTRY_CREATED = 60; |
| |
| /** |
| * Built-in event type: entry destroyed. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheEvent |
| */ |
| public static final int EVT_CACHE_ENTRY_DESTROYED = 61; |
| |
| /** |
| * Built-in event type: entry evicted. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheEvent |
| */ |
| public static final int EVT_CACHE_ENTRY_EVICTED = 62; |
| |
| /** |
| * Built-in event type: object put. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheEvent |
| */ |
| public static final int EVT_CACHE_OBJECT_PUT = 63; |
| |
| /** |
| * Built-in event type: object read. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheEvent |
| */ |
| public static final int EVT_CACHE_OBJECT_READ = 64; |
| |
| /** |
| * Built-in event type: object removed. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheEvent |
| */ |
| public static final int EVT_CACHE_OBJECT_REMOVED = 65; |
| |
| /** |
| * Built-in event type: object locked. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheEvent |
| */ |
| public static final int EVT_CACHE_OBJECT_LOCKED = 66; |
| |
| /** |
| * Built-in event type: object unlocked. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheEvent |
| */ |
| public static final int EVT_CACHE_OBJECT_UNLOCKED = 67; |
| |
| /** |
| * Built-in event type: cache object was transformed. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheEvent |
| */ |
| public static final int EVT_CACHE_OBJECT_TRANSFORMED = 68; |
| |
| /** |
| * Built-in event type: cache object was expired when reading it. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheEvent |
| */ |
| public static final int EVT_CACHE_OBJECT_EXPIRED = 70; |
| |
| /** |
| * Built-in event type: cache rebalance started. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheRebalancingEvent |
| */ |
| public static final int EVT_CACHE_REBALANCE_STARTED = 80; |
| |
| /** |
| * Built-in event type: cache rebalance stopped. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheRebalancingEvent |
| */ |
| public static final int EVT_CACHE_REBALANCE_STOPPED = 81; |
| |
| /** |
| * Built-in event type: cache partition loaded. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheRebalancingEvent |
| */ |
| public static final int EVT_CACHE_REBALANCE_PART_LOADED = 82; |
| |
| /** |
| * Built-in event type: cache partition unloaded. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheRebalancingEvent |
| */ |
| public static final int EVT_CACHE_REBALANCE_PART_UNLOADED = 83; |
| |
| /** |
| * Built-in event type: cache entry rebalanced. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheEvent |
| */ |
| public static final int EVT_CACHE_REBALANCE_OBJECT_LOADED = 84; |
| |
| /** |
| * Built-in event type: cache entry unloaded. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheEvent |
| */ |
| public static final int EVT_CACHE_REBALANCE_OBJECT_UNLOADED = 85; |
| |
| /** |
| * Built-in event type: all nodes that hold partition left topology. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheRebalancingEvent |
| */ |
| public static final int EVT_CACHE_REBALANCE_PART_DATA_LOST = 86; |
| |
| /** |
| * Built-in event type: cache partition was fully sent to remote node. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheRebalancingEvent |
| */ |
| public static final int EVT_CACHE_REBALANCE_PART_SUPPLIED = 87; |
| |
| /** |
| * Built-in event type: cache partition was not sent to remote node. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheRebalancingEvent |
| */ |
| public static final int EVT_CACHE_REBALANCE_PART_MISSED = 88; |
| |
| /** |
| * Built-in event type: query executed. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheQueryExecutedEvent |
| */ |
| public static final int EVT_CACHE_QUERY_EXECUTED = 96; |
| |
| /** |
| * Built-in event type: query entry read. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheQueryExecutedEvent |
| */ |
| public static final int EVT_CACHE_QUERY_OBJECT_READ = 97; |
| |
| /** |
| * Built-in event type: cache started. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheEvent |
| */ |
| public static final int EVT_CACHE_STARTED = 98; |
| |
| /** |
| * Built-in event type: cache started. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheEvent |
| */ |
| public static final int EVT_CACHE_STOPPED = 99; |
| |
| /** |
| * Built-in event type: cache nodes left. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheEvent |
| */ |
| public static final int EVT_CACHE_NODES_LEFT = 100; |
| |
| /** |
| * Built-in event type: WAL segment movement to archive folder completed |
| * <p> |
| * Fired for each completed WAL segment which was moved to archive |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see WalSegmentArchivedEvent |
| */ |
| public static final int EVT_WAL_SEGMENT_ARCHIVED = 128; |
| |
| /** |
| * Built-in event type: Transaction has been started. |
| * <p> |
| * Fired for each started transaction except system transactions. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see TransactionStateChangedEvent |
| */ |
| public static final int EVT_TX_STARTED = 129; |
| |
| /** |
| * Built-in event type: Transaction has been committed. |
| * <p> |
| * Fired for each committed transaction except system transactions. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see TransactionStateChangedEvent |
| */ |
| public static final int EVT_TX_COMMITTED = 130; |
| |
| /** |
| * Built-in event type: Transaction has been rolled back. |
| * <p> |
| * Fired for each rolled back transaction except system transactions. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see TransactionStateChangedEvent |
| */ |
| public static final int EVT_TX_ROLLED_BACK = 131; |
| |
| /** |
| * Built-in event type: Transaction has been suspended. |
| * <p> |
| * Fired for each suspended transaction except system transactions. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see TransactionStateChangedEvent |
| */ |
| public static final int EVT_TX_SUSPENDED = 132; |
| |
| /** |
| * Built-in event type: Transaction has been resumed. |
| * <p> |
| * Fired for each resumed transaction except system transactions. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see TransactionStateChangedEvent |
| */ |
| public static final int EVT_TX_RESUMED = 133; |
| |
| /** |
| * Built-in event type: WAL archive segment compaction is completed. |
| * <p> |
| * Fired for each WAL archive segment upon its compaction completion. |
| * <p> |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see WalSegmentArchivedEvent |
| */ |
| public static final int EVT_WAL_SEGMENT_COMPACTED = 134; |
| |
| /** |
| * Built-in event type: Cache consistency violation detected. |
| * <p> |
| * Fired for each consistency violation incident. |
| * <p> |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see CacheConsistencyViolationEvent |
| * @see IgniteCache#withReadRepair |
| */ |
| public static final int EVT_CONSISTENCY_VIOLATION = 135; |
| |
| /** |
| * Built-in event type: Cluster activation state changed. |
| * <p> |
| * Fired when cluster activated. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see ClusterActivationEvent |
| */ |
| public static final int EVT_CLUSTER_ACTIVATED = 140; |
| |
| /** |
| * Built-in event type: Cluster activation state changed. |
| * <p> |
| * Fired when cluster deactivated. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see ClusterActivationEvent |
| */ |
| public static final int EVT_CLUSTER_DEACTIVATED = 141; |
| |
| /** |
| * Built-in event type: page replacement started in one of the data regions. The name of the data region will |
| * be indicated in the event. |
| * <p> |
| * Fired when all existing free pages are exhausted and Ignite replaces one of the loaded pages with a |
| * cold page from disk. |
| * <p> |
| * When started, page replacement negatively affects performance; it is recommended to monitor page replacement |
| * metrics and set data region size accordingly. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see org.apache.ignite.configuration.DataRegionConfiguration#setMaxSize(long) |
| * @see PageReplacementStartedEvent |
| */ |
| public static final int EVT_PAGE_REPLACEMENT_STARTED = 142; |
| |
| /** |
| * Built-in event type: cluster tag has been changed by user request. |
| * Event includes the following information: ID of the cluster, old tag and new tag. |
| * |
| * <p> |
| * Fired when new tag is successfully set on all nodes. |
| * </p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see IgniteCluster#tag(String) |
| * @see IgniteCluster#id() |
| */ |
| public static final int EVT_CLUSTER_TAG_UPDATED = 143; |
| |
| /** |
| * Built-in event type: Cluster state changed. |
| * <p> |
| * Fired when cluster state changed. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see ClusterActivationEvent |
| */ |
| public static final int EVT_CLUSTER_STATE_CHANGED = 144; |
| |
| /** |
| * Built-in event type: Cluster state change initiated. |
| * <p> |
| * Fired when cluster deactivation process started. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see ClusterStateChangeStartedEvent |
| */ |
| public static final int EVT_CLUSTER_STATE_CHANGE_STARTED = 145; |
| |
| /** |
| * Built-in event type: baseline topology has been changed by either user request or auto-adjust timeout event. |
| * Event includes the following information: new baseline nodes. |
| * |
| * <p> |
| * Fired when new tag is successfully set on all nodes. |
| * </p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see IgniteCluster#setBaselineTopology(long) |
| * @see IgniteCluster#setBaselineTopology(Collection) |
| */ |
| public static final int EVT_BASELINE_CHANGED = 146; |
| |
| /** |
| * Built-in event type: baseline auto-adjust "enabled" flag has been changed by user request. |
| * Event includes the following information: auto-adjust enabled flag, auto-adjust timeout. |
| * |
| * <p> |
| * Fired when new tag is successfully set on all nodes. |
| * </p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see IgniteCluster#baselineAutoAdjustEnabled(boolean) |
| */ |
| public static final int EVT_BASELINE_AUTO_ADJUST_ENABLED_CHANGED = 147; |
| |
| /** |
| * Built-in event type: baseline auto-adjust timeout has been changed by user request. |
| * Event includes the following information: auto-adjust "enabled" flag, auto-adjust timeout. |
| * |
| * <p> |
| * Fired when new tag is successfully set on all nodes. |
| * </p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see IgniteCluster#baselineAutoAdjustTimeout(long) |
| */ |
| public static final int EVT_BASELINE_AUTO_ADJUST_AWAITING_TIME_CHANGED = 148; |
| |
| /** |
| * Built-in event type: Cluster snapshot has been started event. |
| * |
| * <p> |
| * Fired when new tag is successfully set on all nodes. |
| * </p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see IgniteSnapshot#createSnapshot(String) |
| * @see IgniteSnapshot#cancelSnapshot(String) |
| */ |
| public static final int EVT_CLUSTER_SNAPSHOT_STARTED = 149; |
| |
| /** |
| * Built-in event type: Cluster snapshot has been finished event. |
| * |
| * <p> |
| * Fired when new tag is successfully set on all nodes. |
| * </p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see IgniteSnapshot#createSnapshot(String) |
| * @see IgniteSnapshot#cancelSnapshot(String) |
| */ |
| public static final int EVT_CLUSTER_SNAPSHOT_FINISHED = 150; |
| |
| /** |
| * Built-in event type: Cluster snapshot has been failed event. |
| * |
| * <p> |
| * Fired when new tag is successfully set on all nodes. |
| * </p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see IgniteSnapshot#createSnapshot(String) |
| * @see IgniteSnapshot#cancelSnapshot(String) |
| */ |
| public static final int EVT_CLUSTER_SNAPSHOT_FAILED = 151; |
| |
| /** |
| * Built-in event type: query execution. |
| * This event is triggered after a corresponding SQL query validated and before it is executed. |
| * Unlike {@link #EVT_CACHE_QUERY_EXECUTED}, {@code EVT_SQL_QUERY_EXECUTION} is fired only once for a request |
| * and does not relate to a specific cache. |
| * Event includes the following information: query text and its arguments, security subject id. |
| * |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see SqlQueryExecutionEvent |
| */ |
| public static final int EVT_SQL_QUERY_EXECUTION = 160; |
| |
| /** |
| * Built-in event type: node validation failed. |
| * <br> |
| * This event is triggered if a node join fails due to a node validation failure. |
| * <p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see NodeValidationFailedEvent |
| * @see GridComponent#validateNode |
| */ |
| public static final int EVT_NODE_VALIDATION_FAILED = 170; |
| |
| /** |
| * Built-in event type: Cluster snapshot restore has been started event. |
| * |
| * <p> |
| * Fired on the initiator node when a snapshot restore operation is started. |
| * </p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see IgniteSnapshot#restoreSnapshot(String, Collection) |
| * @see IgniteSnapshot#cancelSnapshotRestore(String) |
| */ |
| public static final int EVT_CLUSTER_SNAPSHOT_RESTORE_STARTED = 171; |
| |
| /** |
| * Built-in event type: Cluster snapshot restore has been finished event. |
| * |
| * <p> |
| * Fired on the initiator node when the snapshot restore operation has completed on all nodes. |
| * </p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see IgniteSnapshot#restoreSnapshot(String, Collection) |
| * @see IgniteSnapshot#cancelSnapshotRestore(String) |
| */ |
| public static final int EVT_CLUSTER_SNAPSHOT_RESTORE_FINISHED = 172; |
| |
| /** |
| * Built-in event type: Cluster snapshot restore has been failed event. |
| * |
| * <p> |
| * Fired on the initiator node when the snapshot restore operation failed. |
| * </p> |
| * NOTE: all types in range <b>from 1 to 1000 are reserved</b> for |
| * internal Ignite events and should not be used by user-defined events. |
| * |
| * @see IgniteSnapshot#restoreSnapshot(String, Collection) |
| * @see IgniteSnapshot#cancelSnapshotRestore(String) |
| */ |
| public static final int EVT_CLUSTER_SNAPSHOT_RESTORE_FAILED = 173; |
| |
| /** |
| * All cluster snapshot events. This array can be directly passed into |
| * {@link IgniteEvents#localListen(IgnitePredicate, int...)} method to |
| * subscribe to all cluster snapshot events. |
| * |
| * @see SnapshotEvent |
| */ |
| public static final int[] EVTS_CLUSTER_SNAPSHOT = { |
| EVT_CLUSTER_SNAPSHOT_STARTED, |
| EVT_CLUSTER_SNAPSHOT_FINISHED, |
| EVT_CLUSTER_SNAPSHOT_FAILED, |
| EVT_CLUSTER_SNAPSHOT_RESTORE_STARTED, |
| EVT_CLUSTER_SNAPSHOT_RESTORE_FINISHED, |
| EVT_CLUSTER_SNAPSHOT_RESTORE_FAILED |
| }; |
| |
| /** |
| * All checkpoint events. This array can be directly passed into |
| * {@link IgniteEvents#localListen(IgnitePredicate, int...)} method to |
| * subscribe to all checkpoint events. |
| * |
| * @see CheckpointEvent |
| */ |
| public static final int[] EVTS_CHECKPOINT = { |
| EVT_CHECKPOINT_SAVED, |
| EVT_CHECKPOINT_LOADED, |
| EVT_CHECKPOINT_REMOVED |
| }; |
| |
| /** |
| * All deployment events. This array can be directly passed into |
| * {@link IgniteEvents#localListen(IgnitePredicate, int...)} method to |
| * subscribe to all deployment events. |
| * |
| * @see DeploymentEvent |
| */ |
| public static final int[] EVTS_DEPLOYMENT = { |
| EVT_CLASS_DEPLOYED, |
| EVT_CLASS_UNDEPLOYED, |
| EVT_CLASS_DEPLOY_FAILED, |
| EVT_TASK_DEPLOYED, |
| EVT_TASK_UNDEPLOYED, |
| EVT_TASK_DEPLOY_FAILED |
| }; |
| |
| /** |
| * All events indicating an error or failure condition. It is convenient to use |
| * when fetching all events indicating error or failure. |
| */ |
| public static final int[] EVTS_ERROR = { |
| EVT_JOB_TIMEDOUT, |
| EVT_JOB_FAILED, |
| EVT_JOB_FAILED_OVER, |
| EVT_JOB_REJECTED, |
| EVT_JOB_CANCELLED, |
| EVT_TASK_TIMEDOUT, |
| EVT_TASK_FAILED, |
| EVT_CLASS_DEPLOY_FAILED, |
| EVT_TASK_DEPLOY_FAILED, |
| EVT_TASK_DEPLOYED, |
| EVT_TASK_UNDEPLOYED, |
| EVT_CACHE_REBALANCE_STARTED, |
| EVT_CACHE_REBALANCE_STOPPED |
| }; |
| |
| /** |
| * All discovery events <b>except</b> for {@link #EVT_NODE_METRICS_UPDATED}. Subscription to |
| * {@link #EVT_NODE_METRICS_UPDATED} can generate massive amount of event processing in most cases |
| * is not necessary. If this event is indeed required you can subscribe to it individually or use |
| * {@link #EVTS_DISCOVERY_ALL} array. |
| * <p> |
| * This array can be directly passed into |
| * {@link IgniteEvents#localListen(IgnitePredicate, int...)} method to |
| * subscribe to all discovery events <b>except</b> for {@link #EVT_NODE_METRICS_UPDATED}. |
| * |
| * @see DiscoveryEvent |
| */ |
| public static final int[] EVTS_DISCOVERY = { |
| EVT_NODE_JOINED, |
| EVT_NODE_LEFT, |
| EVT_NODE_FAILED, |
| EVT_NODE_SEGMENTED, |
| EVT_CLIENT_NODE_DISCONNECTED, |
| EVT_CLIENT_NODE_RECONNECTED |
| }; |
| |
| /** |
| * All discovery events. This array can be directly passed into |
| * {@link IgniteEvents#localListen(IgnitePredicate, int...)} method to |
| * subscribe to all discovery events. |
| * |
| * @see DiscoveryEvent |
| */ |
| public static final int[] EVTS_DISCOVERY_ALL = { |
| EVT_NODE_JOINED, |
| EVT_NODE_LEFT, |
| EVT_NODE_FAILED, |
| EVT_NODE_SEGMENTED, |
| EVT_NODE_METRICS_UPDATED, |
| EVT_CLIENT_NODE_DISCONNECTED, |
| EVT_CLIENT_NODE_RECONNECTED |
| }; |
| |
| /** |
| * All grid job execution events. This array can be directly passed into |
| * {@link IgniteEvents#localListen(IgnitePredicate, int...)} method to |
| * subscribe to all grid job execution events. |
| * |
| * @see JobEvent |
| */ |
| public static final int[] EVTS_JOB_EXECUTION = { |
| EVT_JOB_MAPPED, |
| EVT_JOB_RESULTED, |
| EVT_JOB_FAILED_OVER, |
| EVT_JOB_STARTED, |
| EVT_JOB_FINISHED, |
| EVT_JOB_TIMEDOUT, |
| EVT_JOB_REJECTED, |
| EVT_JOB_FAILED, |
| EVT_JOB_QUEUED, |
| EVT_JOB_CANCELLED |
| }; |
| |
| /** |
| * All grid task execution events. This array can be directly passed into |
| * {@link IgniteEvents#localListen(IgnitePredicate, int...)} method to |
| * subscribe to all grid task execution events. |
| * |
| * @see TaskEvent |
| */ |
| public static final int[] EVTS_TASK_EXECUTION = { |
| EVT_TASK_STARTED, |
| EVT_TASK_FINISHED, |
| EVT_TASK_FAILED, |
| EVT_TASK_TIMEDOUT, |
| EVT_TASK_SESSION_ATTR_SET, |
| EVT_TASK_REDUCED |
| }; |
| |
| /** |
| * All cache events. This array can be directly passed into |
| * {@link IgniteEvents#localListen(IgnitePredicate, int...)} method to |
| * subscribe to all cache events. |
| */ |
| public static final int[] EVTS_CACHE = { |
| EVT_CACHE_ENTRY_CREATED, |
| EVT_CACHE_ENTRY_DESTROYED, |
| EVT_CACHE_OBJECT_PUT, |
| EVT_CACHE_OBJECT_READ, |
| EVT_CACHE_OBJECT_REMOVED, |
| EVT_CACHE_OBJECT_LOCKED, |
| EVT_CACHE_OBJECT_UNLOCKED, |
| EVT_CACHE_OBJECT_EXPIRED, |
| EVT_CACHE_OBJECT_TRANSFORMED |
| }; |
| |
| /** |
| * All cache rebalance events. This array can be directly passed into |
| * {@link IgniteEvents#localListen(IgnitePredicate, int...)} method to |
| * subscribe to all cache rebalance events. |
| */ |
| public static final int[] EVTS_CACHE_REBALANCE = { |
| EVT_CACHE_REBALANCE_STARTED, |
| EVT_CACHE_REBALANCE_STOPPED, |
| EVT_CACHE_REBALANCE_PART_LOADED, |
| EVT_CACHE_REBALANCE_PART_UNLOADED, |
| EVT_CACHE_REBALANCE_OBJECT_LOADED, |
| EVT_CACHE_REBALANCE_OBJECT_UNLOADED, |
| EVT_CACHE_REBALANCE_PART_DATA_LOST, |
| EVT_CACHE_REBALANCE_PART_SUPPLIED, |
| EVT_CACHE_REBALANCE_PART_MISSED |
| }; |
| |
| /** |
| * All cache lifecycle events. This array can be directly passed into |
| * {@link IgniteEvents#localListen(IgnitePredicate, int...)} method to |
| * subscribe to all cache lifecycle events. |
| */ |
| public static final int[] EVTS_CACHE_LIFECYCLE = { |
| EVT_CACHE_STARTED, |
| EVT_CACHE_STOPPED, |
| EVT_CACHE_NODES_LEFT |
| }; |
| |
| /** |
| * All cache query events. This array can be directly passed into |
| * {@link IgniteEvents#localListen(IgnitePredicate, int...)} method to |
| * subscribe to all cache query events and requires to set {@link MemoryEventStorageSpi} |
| * or other implementation different from {@link NoopEventStorageSpi}. |
| */ |
| public static final int[] EVTS_CACHE_QUERY = { |
| EVT_CACHE_QUERY_EXECUTED, |
| EVT_CACHE_QUERY_OBJECT_READ |
| }; |
| |
| /** |
| * All Transaction events. This array can be directly passed into |
| * {@link IgniteEvents#localListen(IgnitePredicate, int...)} method to |
| * subscribe to all transaction events. |
| * |
| * @see TransactionStateChangedEvent |
| */ |
| public static final int[] EVTS_TX = { |
| EVT_TX_STARTED, |
| EVT_TX_COMMITTED, |
| EVT_TX_ROLLED_BACK, |
| EVT_TX_SUSPENDED, |
| EVT_TX_RESUMED |
| }; |
| |
| /** |
| * All cluster activation events. This array can be directly passed into |
| * {@link IgniteEvents#localListen(IgnitePredicate, int...)} method to |
| * subscribe to all cloud events. |
| * |
| * @see ClusterActivationEvent |
| */ |
| public static final int[] EVTS_CLUSTER_ACTIVATION = { |
| EVT_CLUSTER_ACTIVATED, |
| EVT_CLUSTER_DEACTIVATED |
| }; |
| |
| /** |
| * All Ignite events (<b>including</b> metric update event). |
| */ |
| public static final int[] EVTS_ALL = U.gridEvents(); |
| |
| /** |
| * All Ignite events (<b>excluding</b> metric update event). |
| */ |
| public static final int[] EVTS_ALL_MINUS_METRIC_UPDATE = U.gridEvents(EVT_NODE_METRICS_UPDATED); |
| } |
