Package org.apache.ignite.internal.processors.cache

Class LocalJoinCachesContext

java.lang.Object

org.apache.ignite.internal.processors.cache.LocalJoinCachesContext

public class LocalJoinCachesContext
extends Object

Context to capture caches state for a node joining to an active cluster. Since registered caches is updated in discovery thread and caches info are updated in exchange thread, we must capture the state in discovery thread somehow and pass it to the exchange. This class holds the required context.

Constructor Summary

Constructors

Constructor	Description
LocalJoinCachesContext(List<T2<DynamicCacheDescriptor,NearCacheConfiguration>> locJoinStartCaches, List<DynamicCacheDescriptor> locJoinInitCaches, Map<Integer,CacheGroupDescriptor> cacheGrpDescs, Map<String,DynamicCacheDescriptor> cacheDescs)

Method Summary

Modifier and Type	Method	Description
Map<String,DynamicCacheDescriptor>	cacheDescriptors()
Map<Integer,CacheGroupDescriptor>	cacheGroupDescriptors()
List<T2<DynamicCacheDescriptor,NearCacheConfiguration>>	caches()
List<DynamicCacheDescriptor>	initCaches()
boolean	isEmpty()
void	removeSurvivedCaches(Set<String> cacheNames)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

LocalJoinCachesContext

public LocalJoinCachesContext(List<T2<DynamicCacheDescriptor,NearCacheConfiguration>> locJoinStartCaches,
                              List<DynamicCacheDescriptor> locJoinInitCaches,
                              Map<Integer,CacheGroupDescriptor> cacheGrpDescs,
                              Map<String,DynamicCacheDescriptor> cacheDescs)

Parameters:

locJoinStartCaches - Local caches to start on join.

locJoinInitCaches - Local caches to initialize query infrastructure without start of caches.

cacheGrpDescs - Cache group descriptors captured during join.

cacheDescs - Cache descriptors captured during join.

Method Detail

caches

public List<T2<DynamicCacheDescriptor,NearCacheConfiguration>> caches()

Returns:

Caches to start.

initCaches

public List<DynamicCacheDescriptor> initCaches()

Returns:

Cache descriptors to initialize query infrastructure without start of caches.

cacheGroupDescriptors

public Map<Integer,CacheGroupDescriptor> cacheGroupDescriptors()

Returns:

Group descriptors.

cacheDescriptors

public Map<String,DynamicCacheDescriptor> cacheDescriptors()

Returns:

Cache descriptors.

removeSurvivedCaches

public void removeSurvivedCaches(Set<String> cacheNames)

Parameters:

cacheNames - Survived caches to clean.

isEmpty

public boolean isEmpty()

Returns:

True if the context is empty.

toString

public String toString()

Overrides:

toString in class Object