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
PlatformTargetProxy	affinity(String name) Get affinity.
PlatformTargetProxy	atomicLong(String name, long initVal, boolean create) Get or create AtomicLong.
PlatformTargetProxy	atomicReference(String name, long memPtr, boolean create) Get or create AtomicReference.
PlatformTargetProxy	atomicSequence(String name, long initVal, boolean create) Get or create AtomicSequence.
void	awaitStart() Await until platform processor is safe to use (i.e.
PlatformTargetProxy	binaryProcessor() Gets the binary processor.
PlatformTargetProxy	cache(String name) Get cache.
PlatformTargetProxy	compute(PlatformTargetProxy grp) Create interop compute.
PlatformContext	context() Gets platform context.
PlatformTargetProxy	createCache(String name) Create cache.
PlatformTargetProxy	createCacheFromConfig(long memPtr) Create cache.
PlatformTargetProxy	createNearCache(String cacheName, long memPtr) Starts a near cache on local node if cache was previously started.
PlatformTargetProxy	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.
PlatformTargetProxy	events(PlatformTargetProxy grp) Create interop events.
PlatformTargetProxy	extension(int id) Gets platform extension by id.
PlatformTargetProxy	extensions() Get platform extensions.
void	getCacheNames(long memPtr) Gets the cache names.
void	getIgniteConfiguration(long memPtr) Gets the configuration of the current Ignite instance.
PlatformTargetProxy	getOrCreateCache(String name) Get or create cache.
PlatformTargetProxy	getOrCreateCacheFromConfig(long memPtr) Get or create cache.
PlatformTargetProxy	getOrCreateNearCache(String cacheName, long memPtr) Gets existing near cache with the given name or creates a new one.
Ignite	ignite() Gets owning Ignite instance.
boolean	loggerIsLevelEnabled(int level) Gets a value indicating whether Ignite logger has specified level enabled.
void	loggerLog(int level, String message, String category, String errorInfo) Logs to the Ignite logger.
PlatformTargetProxy	message(PlatformTargetProxy grp) Create interop messaging.
PlatformTargetProxy	projection() Get projection.
void	registerStore(PlatformCacheStore store, boolean convertBinary) Register cache store.
void	releaseStart() Notify processor that it is safe to use.
PlatformTargetProxy	services(PlatformTargetProxy grp) Create interop services.
PlatformTargetProxy	transactions() Get transactions.

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

assertParameter, collectGridNodeData, collectJoiningNodeData, discoveryDataType, onDisconnected, onGridDataReceived, onJoiningNodeDataReceived, 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

collectGridNodeData, collectJoiningNodeData, discoveryDataType, onDisconnected, onGridDataReceived, onJoiningNodeDataReceived, 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 PlatformTargetProxy 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 PlatformTargetProxy 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 PlatformTargetProxy 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 PlatformTargetProxy 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 PlatformTargetProxy 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 PlatformTargetProxy 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 PlatformTargetProxy 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 PlatformTargetProxy transactions()

Get transactions.

Specified by:

transactions in interface PlatformProcessor

Returns:

Transactions.

projection

public PlatformTargetProxy projection()
                               throws IgniteCheckedException

Get projection.

Specified by:

projection in interface PlatformProcessor

Returns:

Projection.

Throws:

IgniteCheckedException - If failed.

compute

public PlatformTargetProxy compute(PlatformTargetProxy grp)

Create interop compute.

Specified by:

compute in interface PlatformProcessor

Parameters:

grp - Cluster group.

Returns:

Compute instance.

message

public PlatformTargetProxy message(PlatformTargetProxy grp)

Create interop messaging.

Specified by:

message in interface PlatformProcessor

Parameters:

grp - Cluster group.

Returns:

Messaging instance.

events

public PlatformTargetProxy events(PlatformTargetProxy grp)

Create interop events.

Specified by:

events in interface PlatformProcessor

Parameters:

grp - Cluster group.

Returns:

Events instance.

services

public PlatformTargetProxy services(PlatformTargetProxy grp)

Create interop services.

Specified by:

services in interface PlatformProcessor

Parameters:

grp - Cluster group.

Returns:

Services instance.

extensions

public PlatformTargetProxy 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.

extension

public PlatformTargetProxy extension(int id)

Gets platform extension by id.

Specified by:

extension in interface PlatformProcessor

Returns:

Platform extension target.

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 PlatformTargetProxy 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 PlatformTargetProxy 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 PlatformTargetProxy 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 PlatformTargetProxy 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 PlatformTargetProxy 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.

loggerIsLevelEnabled

public boolean loggerIsLevelEnabled(int level)

Gets a value indicating whether Ignite logger has specified level enabled.

Specified by:

loggerIsLevelEnabled in interface PlatformProcessor

Parameters:

level - Log level.

loggerLog

public void loggerLog(int level,
             String message,
             String category,
             String errorInfo)

Logs to the Ignite logger.

Specified by:

loggerLog in interface PlatformProcessor

Parameters:

level - Log level.

message - Message.

category - Category.

errorInfo - Error info.

binaryProcessor

public PlatformTargetProxy binaryProcessor()

Gets the binary processor.

Specified by:

binaryProcessor in interface PlatformProcessor

Returns:

Binary processor.