org.apache.ignite.internal.processors.platform

Class PlatformNoopProcessor

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

org.apache.ignite.internal.processors.platform.PlatformNoopProcessor

All Implemented Interfaces:

GridComponent, GridProcessor, PlatformProcessor

public class PlatformNoopProcessor
extends GridProcessorAdapter
implements PlatformProcessor

No-op processor.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.ignite.internal.GridComponent

GridComponent.DiscoveryDataExchangeType

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

ctx, log

Constructor Summary

Constructors

Constructor and Description
PlatformNoopProcessor(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
PlatformTarget	affinity(String name) Get affinity.
PlatformTarget	atomicLong(String name, long initVal, boolean create) Get or create AtomicLong.
PlatformTarget	atomicReference(String name, long memPtr, boolean create) Get or create AtomicReference.
PlatformTarget	atomicSequence(String name, long initVal, boolean create) Get or create AtomicSequence.
void	awaitStart() Await until platform processor is safe to use (i.e.
PlatformTarget	cache(String name) Get cache.
PlatformTarget	compute(PlatformTarget grp) Create interop compute.
PlatformContext	context() Gets platform context.
PlatformTarget	createCache(String name) Create cache.
PlatformTarget	createCacheFromConfig(long memPtr) Create cache.
PlatformTarget	createNearCache(String cacheName, long memPtr) Starts a near cache on local node if cache was previously started.
PlatformTarget	dataStreamer(String cacheName, boolean keepBinary) Get data streamer.
void	destroyCache(String name) Destroy dynamically created cache.
long	environmentPointer() Get environment pointer associated with this processor.
PlatformTarget	events(PlatformTarget grp) Create interop events.
PlatformTarget	extensions() Get platform extensions.
void	getCacheNames(long memPtr) Gets the cache names.
void	getIgniteConfiguration(long memPtr) Gets the configuration of the current Ignite instance.
PlatformTarget	getOrCreateCache(String name) Get or create cache.
PlatformTarget	getOrCreateCacheFromConfig(long memPtr) Get or create cache.
PlatformTarget	getOrCreateNearCache(String cacheName, long memPtr) Gets existing near cache with the given name or creates a new one.
Ignite	ignite() Gets owning Ignite instance.
PlatformTarget	message(PlatformTarget grp) Create interop messaging.
PlatformTarget	projection() Get projection.
void	registerStore(PlatformCacheStore store, boolean convertBinary) Register cache store.
void	releaseStart() Notify processor that it is safe to use.
PlatformTarget	services(PlatformTarget grp) Create interop services.
PlatformTarget	transactions() Get transactions.

Methods inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

assertParameter, collectDiscoveryData, discoveryDataType, onDisconnected, onDiscoveryDataReceived, onKernalStart, onKernalStop, onReconnected, printMemoryStats, start, stop, toString, validateNode

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.GridComponent

collectDiscoveryData, discoveryDataType, onDisconnected, onDiscoveryDataReceived, onKernalStart, onKernalStop, onReconnected, printMemoryStats, start, stop, validateNode

Constructor Detail

PlatformNoopProcessor

public PlatformNoopProcessor(GridKernalContext ctx)

Method Detail

ignite

public Ignite ignite()

Gets owning Ignite instance.

Specified by:

ignite in interface PlatformProcessor

Returns:

Ignite instance.

environmentPointer

public long environmentPointer()

Get environment pointer associated with this processor.

Specified by:

environmentPointer in interface PlatformProcessor

Returns:

Environment pointer.

context

public PlatformContext context()

Gets platform context.

Specified by:

context in interface PlatformProcessor

Returns:

Platform context.

releaseStart

public void releaseStart()

Notify processor that it is safe to use.

Specified by:

releaseStart in interface PlatformProcessor

awaitStart

public void awaitStart()
                throws IgniteCheckedException

Await until platform processor is safe to use (i.e. has been called.

Specified by:

awaitStart in interface PlatformProcessor

Throws:

IgniteCheckedException - If failed.

cache

public PlatformTarget cache(@Nullable
                   String name)
                     throws IgniteCheckedException

Get cache.

Specified by:

cache in interface PlatformProcessor

Parameters:

name - Cache name.

Returns:

Cache.

Throws:

IgniteCheckedException - If failed.

createCache

public PlatformTarget createCache(@Nullable
                         String name)
                           throws IgniteCheckedException

Create cache.

Specified by:

createCache in interface PlatformProcessor

Parameters:

name - Cache name.

Returns:

Cache.

Throws:

IgniteCheckedException - If failed.

getOrCreateCache

public PlatformTarget getOrCreateCache(@Nullable
                              String name)
                                throws IgniteCheckedException

Get or create cache.

Specified by:

getOrCreateCache in interface PlatformProcessor

Parameters:

name - Cache name.

Returns:

Cache.

Throws:

IgniteCheckedException - If failed.

createCacheFromConfig

public PlatformTarget createCacheFromConfig(long memPtr)
                                     throws IgniteCheckedException

Create cache.

Specified by:

createCacheFromConfig in interface PlatformProcessor

Parameters:

memPtr - Stream with cache config.

Returns:

Cache.

Throws:

IgniteCheckedException - If failed.

getOrCreateCacheFromConfig

public PlatformTarget getOrCreateCacheFromConfig(long memPtr)
                                          throws IgniteCheckedException

Get or create cache.

Specified by:

getOrCreateCacheFromConfig in interface PlatformProcessor

Parameters:

memPtr - Stream with cache config.

Returns:

Cache.

Throws:

IgniteCheckedException - If failed.

destroyCache

public void destroyCache(@Nullable
                String name)
                  throws IgniteCheckedException

Destroy dynamically created cache.

Specified by:

destroyCache in interface PlatformProcessor

Parameters:

name - Cache name.

Throws:

IgniteCheckedException - If failed.

affinity

public PlatformTarget affinity(@Nullable
                      String name)
                        throws IgniteCheckedException

Get affinity.

Specified by:

affinity in interface PlatformProcessor

Parameters:

name - Cache name.

Returns:

Affinity.

Throws:

IgniteCheckedException - If failed.

dataStreamer

public PlatformTarget dataStreamer(@Nullable
                          String cacheName,
                          boolean keepBinary)
                            throws IgniteCheckedException

Get data streamer.

Specified by:

dataStreamer in interface PlatformProcessor

Parameters:

cacheName - Cache name.

keepBinary - Binary flag.

Returns:

Data streamer.

Throws:

IgniteCheckedException - If failed.

transactions

public PlatformTarget transactions()

Get transactions.

Specified by:

transactions in interface PlatformProcessor

Returns:

Transactions.

projection

public PlatformTarget projection()
                          throws IgniteCheckedException

Get projection.

Specified by:

projection in interface PlatformProcessor

Returns:

Projection.

Throws:

IgniteCheckedException - If failed.

compute

public PlatformTarget compute(PlatformTarget grp)

Create interop compute.

Specified by:

compute in interface PlatformProcessor

Parameters:

grp - Cluster group.

Returns:

Compute instance.

message

public PlatformTarget message(PlatformTarget grp)

Create interop messaging.

Specified by:

message in interface PlatformProcessor

Parameters:

grp - Cluster group.

Returns:

Messaging instance.

events

public PlatformTarget events(PlatformTarget grp)

Create interop events.

Specified by:

events in interface PlatformProcessor

Parameters:

grp - Cluster group.

Returns:

Events instance.

services

public PlatformTarget services(PlatformTarget grp)

Create interop services.

Specified by:

services in interface PlatformProcessor

Parameters:

grp - Cluster group.

Returns:

Services instance.

extensions

public PlatformTarget extensions()

Get platform extensions. Override this method to provide any additional targets and operations you need.

Specified by:

extensions in interface PlatformProcessor

Returns:

Platform extensions.

registerStore

public void registerStore(PlatformCacheStore store,
                 boolean convertBinary)
                   throws IgniteCheckedException

Register cache store.

Specified by:

registerStore in interface PlatformProcessor

Parameters:

store - Store.

convertBinary - Convert binary flag.

Throws:

IgniteCheckedException - If failed.

atomicLong

public PlatformTarget atomicLong(String name,
                        long initVal,
                        boolean create)
                          throws IgniteException

Get or create AtomicLong.

Specified by:

atomicLong in interface PlatformProcessor

Parameters:

name - Name.

initVal - Initial value.

create - Create flag.

Returns:

Platform atomic long.

Throws:

IgniteException

getIgniteConfiguration

public void getIgniteConfiguration(long memPtr)

Gets the configuration of the current Ignite instance.

Specified by:

getIgniteConfiguration in interface PlatformProcessor

Parameters:

memPtr - Stream to write data to.

getCacheNames

public void getCacheNames(long memPtr)

Gets the cache names.

Specified by:

getCacheNames in interface PlatformProcessor

Parameters:

memPtr - Stream to write data to.

atomicSequence

public PlatformTarget atomicSequence(String name,
                            long initVal,
                            boolean create)
                              throws IgniteException

Get or create AtomicSequence.

Specified by:

atomicSequence in interface PlatformProcessor

Parameters:

name - Name.

initVal - Initial value.

create - Create flag.

Returns:

Platform atomic long.

Throws:

IgniteException

atomicReference

public PlatformTarget atomicReference(String name,
                             long memPtr,
                             boolean create)
                               throws IgniteException

Get or create AtomicReference.

Specified by:

atomicReference in interface PlatformProcessor

Parameters:

name - Name.

memPtr - Pointer to a stream with initial value. 0 for null initial value.

create - Create flag.

Returns:

Platform atomic long.

Throws:

IgniteException

createNearCache

public PlatformTarget createNearCache(@Nullable
                             String cacheName,
                             long memPtr)

Starts a near cache on local node if cache was previously started.

Specified by:

createNearCache in interface PlatformProcessor

Parameters:

cacheName - Cache name.

memPtr - Pointer to a stream with near cache config. 0 for default config.

Returns:

Cache.

getOrCreateNearCache

public PlatformTarget getOrCreateNearCache(@Nullable
                                  String cacheName,
                                  long memPtr)

Gets existing near cache with the given name or creates a new one.

Specified by:

getOrCreateNearCache in interface PlatformProcessor

Parameters:

cacheName - Cache name.

memPtr - Pointer to a stream with near cache config. 0 for default config.

Returns:

Cache.