org.apache.ignite.internal.processors.platform

Interface PlatformProcessor

All Superinterfaces:

GridComponent, GridProcessor

All Known Implementing Classes:

PlatformNoopProcessor

public interface PlatformProcessor
extends GridProcessor

Platform processor.

Nested Class Summary

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

GridComponent.DiscoveryDataExchangeType

Method Summary

Methods

Modifier and Type	Method and Description
PlatformTarget	affinity(String name) Get affinity.
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	dataStreamer(String cacheName, boolean keepPortable) Get data streamer.
long	environmentPointer() Get environment pointer associated with this processor.
PlatformTarget	events(PlatformTarget grp) Create interop events.
PlatformTarget	extensions() Get platform extensions.
PlatformTarget	getOrCreateCache(String name) Get or create cache.
Ignite	ignite() Gets owning Ignite instance.
PlatformTarget	message(PlatformTarget grp) Create interop messaging.
PlatformTarget	projection() Get projection.
void	registerStore(PlatformCacheStore store, boolean convertPortable) 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 interface org.apache.ignite.internal.GridComponent

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

Method Detail

ignite

Ignite ignite()

Gets owning Ignite instance.

Returns:

Ignite instance.

environmentPointer

long environmentPointer()

Get environment pointer associated with this processor.

Returns:

Environment pointer.

context

PlatformContext context()

Gets platform context.

Returns:

Platform context.

releaseStart

void releaseStart()

Notify processor that it is safe to use.

awaitStart

void awaitStart()
                throws IgniteCheckedException

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

Throws:

IgniteCheckedException - If failed.

cache

PlatformTarget cache(@Nullable
                   String name)
                     throws IgniteCheckedException

Get cache.

Parameters:

name - Cache name.

Returns:

Cache.

Throws:

IgniteCheckedException - If failed.

createCache

PlatformTarget createCache(@Nullable
                         String name)
                           throws IgniteCheckedException

Create cache.

Parameters:

name - Cache name.

Returns:

Cache.

Throws:

IgniteCheckedException - If failed.

getOrCreateCache

PlatformTarget getOrCreateCache(@Nullable
                              String name)
                                throws IgniteCheckedException

Get or create cache.

Parameters:

name - Cache name.

Returns:

Cache.

Throws:

IgniteCheckedException - If failed.

affinity

PlatformTarget affinity(@Nullable
                      String name)
                        throws IgniteCheckedException

Get affinity.

Parameters:

name - Cache name.

Returns:

Affinity.

Throws:

IgniteCheckedException - If failed.

dataStreamer

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

Get data streamer.

Parameters:

cacheName - Cache name.

keepPortable - Portable flag.

Returns:

Data streamer.

Throws:

IgniteCheckedException - If failed.

transactions

PlatformTarget transactions()

Get transactions.

Returns:

Transactions.

projection

PlatformTarget projection()
                          throws IgniteCheckedException

Get projection.

Returns:

Projection.

Throws:

IgniteCheckedException - If failed.

compute

PlatformTarget compute(PlatformTarget grp)

Create interop compute.

Parameters:

grp - Cluster group.

Returns:

Compute instance.

message

PlatformTarget message(PlatformTarget grp)

Create interop messaging.

Parameters:

grp - Cluster group.

Returns:

Messaging instance.

events

PlatformTarget events(PlatformTarget grp)

Create interop events.

Parameters:

grp - Cluster group.

Returns:

Events instance.

services

PlatformTarget services(PlatformTarget grp)

Create interop services.

Parameters:

grp - Cluster group.

Returns:

Services instance.

extensions

PlatformTarget extensions()

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

Returns:

Platform extensions.

registerStore

void registerStore(PlatformCacheStore store,
                 boolean convertPortable)
                   throws IgniteCheckedException

Register cache store.

Parameters:

store - Store.

convertPortable - Convert portable flag.

Throws:

IgniteCheckedException - If failed.