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

Class CacheDataStructuresManager

java.lang.Object

org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter

org.apache.ignite.internal.processors.cache.datastructures.CacheDataStructuresManager

All Implemented Interfaces:

GridCacheManager

public class CacheDataStructuresManager
extends GridCacheManagerAdapter

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter

cctx, log, starting

Constructor Summary

Constructors

Constructor	Description
CacheDataStructuresManager()

Method Summary

Modifier and Type	Method	Description
boolean	knownType(Object obj)
void	onDisconnected(IgniteFuture reconnectFut)
protected void	onKernalStart0()
protected void	onKernalStop0(boolean cancel)
void	onReconnected(boolean clusterRestarted)
void	onRemoved(GridCacheSetProxy set)
<T> @Nullable GridCacheQueueProxy<T>	queue(String name, int cap, boolean colloc, boolean create)
<T> @Nullable GridCacheQueueProxy<T>	queue0(String name, int cap, boolean colloc, boolean create)
ConcurrentMap<IgniteUuid,GridCacheQueueProxy>	queues()
void	removeSetData(IgniteUuid id, boolean separated)
<T> @Nullable IgniteSet<T>	set(String name, boolean colloc, boolean create, boolean separated)
ConcurrentMap<IgniteUuid,GridCacheSetProxy>	sets()

Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter

context, kernalStartInfo, kernalStopInfo, log, onKernalStart, onKernalStop, printMemoryStats, start, start0, startInfo, stop, stop0, stopInfo, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheDataStructuresManager

public CacheDataStructuresManager()

Method Detail

sets

public ConcurrentMap<IgniteUuid,GridCacheSetProxy> sets()

Returns:

Sets map.

queues

public ConcurrentMap<IgniteUuid,GridCacheQueueProxy> queues()

Returns:

Queue map.

onKernalStart0

protected void onKernalStart0()
                       throws IgniteCheckedException

Overrides:

onKernalStart0 in class GridCacheManagerAdapter

Throws:

IgniteCheckedException - If failed.

onKernalStop0

protected void onKernalStop0(boolean cancel)

Overrides:

onKernalStop0 in class GridCacheManagerAdapter

Parameters:

cancel - Cancel flag.

onDisconnected

public void onDisconnected(IgniteFuture reconnectFut)

Specified by:

onDisconnected in interface GridCacheManager

Overrides:

onDisconnected in class GridCacheManagerAdapter

Parameters:

reconnectFut - Reconnect future.

onRemoved

public void onRemoved(GridCacheSetProxy set)

Parameters:

set - Set.

onReconnected

public void onReconnected(boolean clusterRestarted)
                   throws IgniteCheckedException

Parameters:

clusterRestarted - Cluster restarted flag.

Throws:

IgniteCheckedException - If failed.

queue

@Nullable
public <T> @Nullable GridCacheQueueProxy<T> queue(String name,
                                                  int cap,
                                                  boolean colloc,
                                                  boolean create)
                                           throws IgniteCheckedException

Parameters:

name - Queue name.

cap - Capacity.

colloc - Collocated flag.

create - Create flag.

Returns:

Queue header.

Throws:

IgniteCheckedException - If failed.

queue0

@Nullable
public <T> @Nullable GridCacheQueueProxy<T> queue0(String name,
                                                   int cap,
                                                   boolean colloc,
                                                   boolean create)
                                            throws IgniteCheckedException

Parameters:

name - Queue name.

cap - Capacity.

colloc - Collocated flag.

create - Create flag.

Returns:

Queue header.

Throws:

IgniteCheckedException - If failed.

set

@Nullable
public <T> @Nullable IgniteSet<T> set(String name,
                                      boolean colloc,
                                      boolean create,
                                      boolean separated)
                               throws IgniteCheckedException

Parameters:

name - Set name.

colloc - Collocated flag.

create - Create flag.

separated - Separated cache flag.

Returns:

Set.

Throws:

IgniteCheckedException - If failed.

knownType

public boolean knownType(Object obj)

Parameters:

obj - Object.

Returns:

True

removeSetData

public void removeSetData(IgniteUuid id,
                          boolean separated)
                   throws IgniteCheckedException

Parameters:

id - Set ID.

separated - Separated cache flag.

Throws:

IgniteCheckedException - If failed.