org.apache.ignite.internal.processors.service

Class ServiceProcessorAdapter

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

org.apache.ignite.internal.processors.service.ServiceProcessorAdapter

All Implemented Interfaces:

GridComponent, GridProcessor

Direct Known Subclasses:

GridServiceProcessor, IgniteServiceProcessor

public abstract class ServiceProcessorAdapter
extends GridProcessorAdapter

Adapter for different service processor implementations.

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, diagnosticLog, log

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ServiceProcessorAdapter(GridKernalContext ctx)

Method Summary

Modifier and Type	Method and Description
abstract IgniteInternalFuture<?>	cancel(String name)
abstract IgniteInternalFuture<?>	cancelAll()
abstract IgniteInternalFuture<?>	cancelAll(Collection<String> servicesNames)
abstract IgniteInternalFuture<?>	deployAll(ClusterGroup prj, Collection<ServiceConfiguration> cfgs)
abstract IgniteInternalFuture<?>	deployClusterSingleton(ClusterGroup prj, String name, Service srvc)
abstract IgniteInternalFuture<?>	deployKeyAffinitySingleton(String name, Service srvc, String cacheName, Object affKey)
abstract IgniteInternalFuture<?>	deployMultiple(ClusterGroup prj, String name, Service srvc, int totalCnt, int maxPerNodeCnt)
abstract IgniteInternalFuture<?>	deployNodeSingleton(ClusterGroup prj, String name, Service srvc)
void	onLocalJoin(DiscoveryEvent evt, DiscoCache discoCache) Callback for local join events for which the regular events are not generated.
abstract <T> T	service(String name)
abstract ServiceContextImpl	serviceContext(String name)
abstract Collection<ServiceDescriptor>	serviceDescriptors()
abstract <T> T	serviceProxy(ClusterGroup prj, String name, Class<? super T> srvcCls, boolean sticky, long timeout)
abstract <T> Collection<T>	services(String name)
abstract Map<UUID,Integer>	serviceTopology(String name, long timeout)

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, validateNode

Methods inherited from class java.lang.Object

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

Constructor Detail

ServiceProcessorAdapter

protected ServiceProcessorAdapter(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

deployNodeSingleton

public abstract IgniteInternalFuture<?> deployNodeSingleton(ClusterGroup prj,
                                                            String name,
                                                            Service srvc)

Parameters:

prj - Grid projection.

name - Service name.

srvc - Service.

Returns:

Future.

deployClusterSingleton

public abstract IgniteInternalFuture<?> deployClusterSingleton(ClusterGroup prj,
                                                               String name,
                                                               Service srvc)

Parameters:

name - Service name.

srvc - Service instance.

Returns:

Future.

deployMultiple

public abstract IgniteInternalFuture<?> deployMultiple(ClusterGroup prj,
                                                       String name,
                                                       Service srvc,
                                                       int totalCnt,
                                                       int maxPerNodeCnt)

Parameters:

name - Service name.

srvc - Service.

totalCnt - Total count.

maxPerNodeCnt - Max per-node count.

Returns:

Future.

deployKeyAffinitySingleton

public abstract IgniteInternalFuture<?> deployKeyAffinitySingleton(String name,
                                                                   Service srvc,
                                                                   String cacheName,
                                                                   Object affKey)

Parameters:

name - Service name.

srvc - Service.

cacheName - Cache name.

affKey - Affinity key.

Returns:

Future.

deployAll

public abstract IgniteInternalFuture<?> deployAll(ClusterGroup prj,
                                                  Collection<ServiceConfiguration> cfgs)

Parameters:

prj - Grid projection.

cfgs - Service configurations.

Returns:

Future for deployment.

cancel

public abstract IgniteInternalFuture<?> cancel(String name)

Parameters:

name - Service name.

Returns:

Future.

cancelAll

public abstract IgniteInternalFuture<?> cancelAll()

Returns:

Future.

cancelAll

public abstract IgniteInternalFuture<?> cancelAll(Collection<String> servicesNames)

Parameters:

servicesNames - Name of services to deploy.

Returns:

Future.

serviceDescriptors

public abstract Collection<ServiceDescriptor> serviceDescriptors()

Returns:

Collection of service descriptors.

service

public abstract <T> T service(String name)

Type Parameters:

T - Service type.

Parameters:

name - Service name.

Returns:

Service by specified service name.

serviceProxy

public abstract <T> T serviceProxy(ClusterGroup prj,
                                   String name,
                                   Class<? super T> srvcCls,
                                   boolean sticky,
                                   long timeout)
                            throws IgniteException

Type Parameters:

T - Service interface type.

Parameters:

prj - Grid projection.

name - Service name.

srvcCls - Service class.

sticky - Whether multi-node request should be done.

timeout - If greater than 0 limits service acquire time. Cannot be negative.

Returns:

The proxy of a service by its name and class.

Throws:

IgniteException - If failed to create proxy.

services

public abstract <T> Collection<T> services(String name)

Type Parameters:

T - Service type.

Parameters:

name - Service name.

Returns:

Services by specified service name.

serviceContext

public abstract ServiceContextImpl serviceContext(String name)

Parameters:

name - Service name.

Returns:

Service by specified service name.

serviceTopology

public abstract Map<UUID,Integer> serviceTopology(String name,
                                                  long timeout)
                                           throws IgniteCheckedException

Parameters:

name - Service name.

timeout - If greater than 0 limits task execution time. Cannot be negative.

Returns:

Service topology.

Throws:

IgniteCheckedException - On error.

onLocalJoin

public void onLocalJoin(DiscoveryEvent evt,
                        DiscoCache discoCache)

Callback for local join events for which the regular events are not generated.

Local join event is expected in cases of joining to topology or client reconnect.

Parameters:

evt - Discovery event.

discoCache - Discovery cache.