public class GridServiceProcessor extends GridProcessorAdapter
GridComponent.DiscoveryDataExchangeTypectx, log| Constructor and Description |
|---|
GridServiceProcessor(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<?> |
cancel(String name) |
IgniteInternalFuture<?> |
cancelAll() |
IgniteInternalFuture<?> |
deploy(ServiceConfiguration cfg) |
IgniteInternalFuture<?> |
deployClusterSingleton(ClusterGroup prj,
String name,
Service svc) |
IgniteInternalFuture<?> |
deployKeyAffinitySingleton(String name,
Service svc,
String cacheName,
Object affKey) |
IgniteInternalFuture<?> |
deployMultiple(ClusterGroup prj,
String name,
Service svc,
int totalCnt,
int maxPerNodeCnt) |
IgniteInternalFuture<?> |
deployNodeSingleton(ClusterGroup prj,
String name,
Service svc) |
void |
onDisconnected(IgniteFuture<?> reconnectFut)
Client disconnected callback.
|
void |
onKernalStart()
Callback that notifies that kernal has successfully started,
including all managers and processors.
|
void |
onKernalStop(boolean cancel)
Callback to notify that kernal is about to stop.
|
<T> T |
service(String name) |
ServiceContextImpl |
serviceContext(String name) |
Collection<ServiceDescriptor> |
serviceDescriptors() |
<T> T |
serviceProxy(ClusterGroup prj,
String name,
Class<? super T> svcItf,
boolean sticky) |
<T> Collection<T> |
services(String name) |
void |
start()
Starts grid component.
|
assertParameter, collectDiscoveryData, discoveryDataType, onDiscoveryDataReceived, onReconnected, printMemoryStats, stop, toString, validateNodepublic GridServiceProcessor(GridKernalContext ctx)
ctx - Kernal context.public void start()
throws IgniteCheckedException
start in interface GridComponentstart in class GridProcessorAdapterIgniteCheckedException - Throws in case of any errors.public void onKernalStart()
throws IgniteCheckedException
onKernalStart in interface GridComponentonKernalStart in class GridProcessorAdapterIgniteCheckedException - Thrown in case of any errors.public void onKernalStop(boolean cancel)
onKernalStop in interface GridComponentonKernalStop in class GridProcessorAdaptercancel - Flag indicating whether jobs should be canceled.public void onDisconnected(IgniteFuture<?> reconnectFut) throws IgniteCheckedException
onDisconnected in interface GridComponentonDisconnected in class GridProcessorAdapterreconnectFut - Reconnect future.IgniteCheckedException - If failed.public IgniteInternalFuture<?> deployNodeSingleton(ClusterGroup prj, String name, Service svc)
name - Service name.svc - Service.public IgniteInternalFuture<?> deployClusterSingleton(ClusterGroup prj, String name, Service svc)
name - Service name.svc - Service.public IgniteInternalFuture<?> deployMultiple(ClusterGroup prj, String name, Service svc, int totalCnt, int maxPerNodeCnt)
name - Service name.svc - Service.totalCnt - Total count.maxPerNodeCnt - Max per-node count.public IgniteInternalFuture<?> deployKeyAffinitySingleton(String name, Service svc, String cacheName, Object affKey)
name - Service name.svc - Service.cacheName - Cache name.affKey - Affinity key.public IgniteInternalFuture<?> deploy(ServiceConfiguration cfg)
cfg - Service configuration.public IgniteInternalFuture<?> cancel(String name)
name - Service name.public IgniteInternalFuture<?> cancelAll()
public Collection<ServiceDescriptor> serviceDescriptors()
public <T> T service(String name)
T - Service type.name - Service name.public ServiceContextImpl serviceContext(String name)
name - Service name.public <T> T serviceProxy(ClusterGroup prj, String name, Class<? super T> svcItf, boolean sticky) throws IgniteException
T - Service interface type.prj - Grid projection.name - Service name.svcItf - Service class.sticky - Whether multi-node request should be done.IgniteException - If failed to create proxy.public <T> Collection<T> services(String name)
T - Service type.name - Service name.
Follow @ApacheIgnite
Ignite Fabric : ver. 1.4.0 Release Date : September 24 2015