Package org.apache.ignite.spi
Interface IgniteSpiContext
- 
 public interface IgniteSpiContextSPI context provides common functionality for all SPI implementations.
- 
- 
Method SummaryAll Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method Description voidaddLocalEventListener(org.apache.ignite.internal.managers.eventstorage.GridLocalEventListener lsnr, int... types)Adds an event listener for local events.voidaddLocalMessageListener(@Nullable Object topic, IgniteBiPredicate<UUID,?> p)Register an local message listener to receive messages sent by remote nodes.voidaddMessageListener(org.apache.ignite.internal.managers.communication.GridMessageListener lsnr, String topic)Deprecated.UseaddLocalMessageListener(Object, IgniteBiPredicate)instead.voidaddMetricRegistryCreationListener(Consumer<ReadOnlyMetricRegistry> lsnr)Register listener which will be notified on metric registry creation.voidaddTimeoutObject(IgniteSpiTimeoutObject c)SecuritySubjectauthenticatedSubject(UUID subjId)Gets security subject based on subject ID.Collection<SecuritySubject>authenticatedSubjects()Gets collection of authenticated subjects together with their permissions.booleancommunicationFailureResolveSupported()<K> booleancontainsKey(String cacheName, K key)Returnstrueif this cache contains a mapping for the specified key.voidderegisterPort(int port, IgnitePortProtocol proto)Deregisters closed port.voidderegisterPorts()Deregisters all closed ports.voidfailNode(UUID nodeId, @Nullable String warning)<K,V>
 Vget(String cacheName, K key)Gets object from cache.ReadOnlyMetricRegistrygetOrCreateMetricRegistry(String name)Returns existing or newly created instance of metric registry with given name.booleanisEventRecordable(int... types)Checks whether all provided event types are recordable.booleanisStopping()ClusterNodelocalNode()Gets local grid node.MessageFactorymessageFactory()Gets message factory.MessageFormattermessageFormatter()Gets message formatter.Iterable<ReadOnlyMetricRegistry>metricRegistries()Returns all registered metric registries.@Nullable ClusterNodenode(UUID nodeId)Gets a node instance based on its ID.Map<String,Object>nodeAttributes()Collection<ClusterNode>nodes()Gets a collection of all grid nodes.intpartition(String cacheName, Object key)Calculates partition number for given key.booleanpingNode(UUID nodeId)Pings a remote node.<K,V>
 Vput(String cacheName, K key, V val, long ttl)Puts object in cache.<K,V>
 VputIfAbsent(String cacheName, K key, V val, long ttl)Puts object into cache if there was no previous object associated with given key.voidrecordEvent(Event evt)Records local event.voidregisterPort(int port, IgnitePortProtocol proto)Registers open port.Collection<ClusterNode>remoteNodes()Gets a collection of remote grid nodes.<K,V>
 Vremove(String cacheName, K key)Removes object from cache.booleanremoveLocalEventListener(org.apache.ignite.internal.managers.eventstorage.GridLocalEventListener lsnr)Removes local event listener.voidremoveLocalMessageListener(@Nullable Object topic, IgniteBiPredicate<UUID,?> p)Removes a previously registered local message listener.booleanremoveMessageListener(org.apache.ignite.internal.managers.communication.GridMessageListener lsnr, String topic)Deprecated.voidremoveMetricRegistry(String name)Removes metric registry with given name.voidremoveTimeoutObject(IgniteSpiTimeoutObject c)voidresolveCommunicationFailure(ClusterNode node, Exception err)voidsend(ClusterNode node, Serializable msg, String topic)Sends a message to a remote node.booleantryFailNode(UUID nodeId, @Nullable String warning)@Nullable IgniteNodeValidationResultvalidateNode(ClusterNode node)Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.@Nullable IgniteNodeValidationResultvalidateNode(ClusterNode node, DiscoveryDataBag discoData)
 
- 
- 
- 
Method Detail- 
remoteNodesCollection<ClusterNode> remoteNodes() Gets a collection of remote grid nodes. Remote nodes are discovered via underlyingDiscoverySpiimplementation used. Unlikenodes(), this method does not include local grid node.- Returns:
- Collection of remote grid nodes.
- See Also:
- localNode(),- nodes(),- DiscoverySpi
 
 - 
nodesCollection<ClusterNode> nodes() Gets a collection of all grid nodes. Remote nodes are discovered via underlyingDiscoverySpiimplementation used. UnlikeremoteNodes(), this method does include local grid node.- Returns:
- Collection of remote grid nodes.
- See Also:
- localNode(),- remoteNodes(),- DiscoverySpi
 
 - 
localNodeClusterNode localNode() Gets local grid node. Instance of local node is provided by underlyingDiscoverySpiimplementation used.- Returns:
- Local grid node.
- See Also:
- DiscoverySpi
 
 - 
node@Nullable @Nullable ClusterNode node(UUID nodeId) Gets a node instance based on its ID.- Parameters:
- nodeId- ID of a node to get.
- Returns:
- Node for a given ID or nullis such not has not been discovered.
- See Also:
- DiscoverySpi
 
 - 
pingNodeboolean pingNode(UUID nodeId) Pings a remote node. The underlying communication is provided viaDiscoverySpi.pingNode(UUID)implementation.Discovery SPIs usually have some latency in discovering failed nodes. Hence, communication to remote nodes may fail at times if an attempt was made to establish communication with a failed node. This method can be used to check if communication has failed due to node failure or due to some other reason. - Parameters:
- nodeId- ID of a node to ping.
- Returns:
- trueif node for a given ID is alive,- falseotherwise.
- See Also:
- DiscoverySpi
 
 - 
sendvoid send(ClusterNode node, Serializable msg, String topic) throws IgniteSpiException Sends a message to a remote node. The underlying communication mechanism is defined byCommunicationSpiimplementation used.- Parameters:
- node- Node to send a message to.
- msg- Message to send.
- topic- Topic to send message to.
- Throws:
- IgniteSpiException- If failed to send a message to remote node.
 
 - 
addLocalMessageListenervoid addLocalMessageListener(@Nullable @Nullable Object topic, IgniteBiPredicate<UUID,?> p)Register an local message listener to receive messages sent by remote nodes. The underlying communication mechanism is defined byCommunicationSpiimplementation used.- Parameters:
- topic- Topic to subscribe to.
- p- Message predicate.
 
 - 
removeLocalMessageListenervoid removeLocalMessageListener(@Nullable @Nullable Object topic, IgniteBiPredicate<UUID,?> p)Removes a previously registered local message listener.- Parameters:
- topic- Topic to unsubscribe from.
- p- Message predicate.
 
 - 
addMessageListener@Deprecated void addMessageListener(org.apache.ignite.internal.managers.communication.GridMessageListener lsnr, String topic) Deprecated.UseaddLocalMessageListener(Object, IgniteBiPredicate)instead.Register a message listener to receive messages sent by remote nodes. The underlying communication mechanism is defined byCommunicationSpiimplementation used.This method can be used by jobs to communicate with other nodes in the grid. Remote nodes can send messages by calling send(org.apache.ignite.cluster.ClusterNode, Serializable, String)method.- Parameters:
- lsnr- Message listener to register.
- topic- Topic to register listener for.
 
 - 
removeMessageListener@Deprecated boolean removeMessageListener(org.apache.ignite.internal.managers.communication.GridMessageListener lsnr, String topic) Deprecated.Removes a previously registered message listener.- Parameters:
- lsnr- Message listener to remove.
- topic- Topic to unregister listener for.
- Returns:
- trueof message listener was removed,- falseif it was not previously registered.
 
 - 
addLocalEventListenervoid addLocalEventListener(org.apache.ignite.internal.managers.eventstorage.GridLocalEventListener lsnr, int... types)Adds an event listener for local events.- Parameters:
- lsnr- Event listener for local events.
- types- Optional types for which this listener will be notified. If no types are provided this listener will be notified for all local events.
- See Also:
- Event
 
 - 
removeLocalEventListenerboolean removeLocalEventListener(org.apache.ignite.internal.managers.eventstorage.GridLocalEventListener lsnr) Removes local event listener.- Parameters:
- lsnr- Local event listener to remove.
- Returns:
- trueif listener was removed,- falseotherwise.
 
 - 
isEventRecordableboolean isEventRecordable(int... types) Checks whether all provided event types are recordable.- Parameters:
- types- Event types to check.
- Returns:
- Whether or not all provided event types are recordable..
 
 - 
recordEventvoid recordEvent(Event evt) Records local event.- Parameters:
- evt- Local grid event to record.
 
 - 
registerPortvoid registerPort(int port, IgnitePortProtocol proto)Registers open port.- Parameters:
- port- Port.
- proto- Protocol.
 
 - 
deregisterPortvoid deregisterPort(int port, IgnitePortProtocol proto)Deregisters closed port.- Parameters:
- port- Port.
- proto- Protocol.
 
 - 
deregisterPortsvoid deregisterPorts() Deregisters all closed ports.
 - 
get@Nullable <K,V> V get(String cacheName, K key) throws javax.cache.CacheException Gets object from cache.- Type Parameters:
- K- Key type.
- V- Value type.
- Parameters:
- cacheName- Cache name.
- key- Object key.
- Returns:
- Cached object.
- Throws:
- javax.cache.CacheException- Thrown if any exception occurs.
 
 - 
put@Nullable <K,V> V put(String cacheName, K key, V val, long ttl) throws javax.cache.CacheException Puts object in cache.- Type Parameters:
- K- Key type.
- V- Value type.
- Parameters:
- cacheName- Cache name.
- key- Object key.
- val- Cached object.
- ttl- Time to live,- 0means the entry will never expire.
- Returns:
- Previous value associated with specified key, possibly null.
- Throws:
- javax.cache.CacheException- Thrown if any exception occurs.
 
 - 
putIfAbsent@Nullable <K,V> V putIfAbsent(String cacheName, K key, V val, long ttl) throws javax.cache.CacheException Puts object into cache if there was no previous object associated with given key.- Type Parameters:
- K- Cache key type.
- V- Cache value type.
- Parameters:
- cacheName- Cache name.
- key- Cache key.
- val- Cache value.
- ttl- Time to live.
- Returns:
- Either existing value or nullif there was no value for given key.
- Throws:
- javax.cache.CacheException- If put failed.
 
 - 
remove@Nullable <K,V> V remove(String cacheName, K key) throws javax.cache.CacheException Removes object from cache.- Type Parameters:
- K- Key type.
- V- Value type.
- Parameters:
- cacheName- Cache name.
- key- Object key.
- Returns:
- Previous value associated with specified key, possibly null.
- Throws:
- javax.cache.CacheException- Thrown if any exception occurs.
 
 - 
containsKey<K> boolean containsKey(String cacheName, K key) Returnstrueif this cache contains a mapping for the specified key.- Type Parameters:
- K- Key type.
- Parameters:
- cacheName- Cache name.
- key- Object key.
- Returns:
- trueif this cache contains a mapping for the specified key.
 
 - 
partitionint partition(String cacheName, Object key) Calculates partition number for given key.- Parameters:
- cacheName- Cache name.
- key- Key.
- Returns:
- Partition.
 
 - 
validateNode@Nullable @Nullable IgniteNodeValidationResult validateNode(ClusterNode node) Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.- Parameters:
- node- Joining node.
- Returns:
- Validation result or nullin case of success.
 
 - 
validateNode@Nullable @Nullable IgniteNodeValidationResult validateNode(ClusterNode node, DiscoveryDataBag discoData) - Parameters:
- node- Node.
- discoData- Disco data.
- Returns:
- Validation result or nullin case of success.
 
 - 
authenticatedSubjectsCollection<SecuritySubject> authenticatedSubjects() throws IgniteException Gets collection of authenticated subjects together with their permissions.- Returns:
- Collection of authenticated subjects.
- Throws:
- IgniteException- If any exception occurs.
 
 - 
authenticatedSubjectSecuritySubject authenticatedSubject(UUID subjId) throws IgniteException Gets security subject based on subject ID.- Parameters:
- subjId- Subject ID.
- Returns:
- Authorized security subject.
- Throws:
- IgniteException- If any exception occurs.
 
 - 
messageFormatterMessageFormatter messageFormatter() Gets message formatter.- Returns:
- Message formatter.
 
 - 
messageFactoryMessageFactory messageFactory() Gets message factory.- Returns:
- Message factory.
 
 - 
isStoppingboolean isStopping() - Returns:
- Trueif node started shutdown sequence.
 
 - 
tryFailNodeboolean tryFailNode(UUID nodeId, @Nullable @Nullable String warning) - Parameters:
- nodeId- Node ID.
- warning- Warning to be shown on all cluster nodes.
- Returns:
- If node was failed.
 
 - 
failNodevoid failNode(UUID nodeId, @Nullable @Nullable String warning) - Parameters:
- nodeId- Node ID.
- warning- Warning to be shown on all cluster nodes.
 
 - 
addTimeoutObjectvoid addTimeoutObject(IgniteSpiTimeoutObject c) - Parameters:
- c- Timeout object.
 
 - 
removeTimeoutObjectvoid removeTimeoutObject(IgniteSpiTimeoutObject c) - Parameters:
- c- Timeout object.
 
 - 
communicationFailureResolveSupportedboolean communicationFailureResolveSupported() - Returns:
- Trueif cluster supports communication error resolving.
 
 - 
resolveCommunicationFailurevoid resolveCommunicationFailure(ClusterNode node, Exception err) - Parameters:
- node- Problem node.
- err- Error.
 
 - 
getOrCreateMetricRegistryReadOnlyMetricRegistry getOrCreateMetricRegistry(String name) Returns existing or newly created instance of metric registry with given name.- Parameters:
- name- Metric registry name.
- Returns:
- Existing or newly created instance of metric registry.
 
 - 
removeMetricRegistryvoid removeMetricRegistry(String name) Removes metric registry with given name.- Parameters:
- name- Metric registry name.
 
 - 
metricRegistriesIterable<ReadOnlyMetricRegistry> metricRegistries() Returns all registered metric registries.- Returns:
- All registered metric registries.
 
 - 
addMetricRegistryCreationListenervoid addMetricRegistryCreationListener(Consumer<ReadOnlyMetricRegistry> lsnr) Register listener which will be notified on metric registry creation.- Parameters:
- lsnr- Listener.
 
 
- 
 
-