| Modifier and Type | Class and Description |
|---|---|
class |
GridKernalContextImpl
Implementation of kernal context.
|
| Modifier and Type | Method and Description |
|---|---|
GridKernalContext |
IgniteKernal.context()
It's intended for use by internal marshalling implementation only.
|
GridKernalContext |
IgniteEx.context()
Internal context.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteDiagnosticMessage.TxEntriesInfoClosure.apply(StringBuilder sb,
GridKernalContext ctx)
Closure body.
|
void |
IgniteDiagnosticMessage.ExchangeInfoClosure.apply(StringBuilder sb,
GridKernalContext ctx)
Closure body.
|
void |
IgniteDiagnosticMessage.TxInfoClosure.apply(StringBuilder sb,
GridKernalContext ctx)
Closure body.
|
<T> T |
IgniteComponentType.create(GridKernalContext ctx,
boolean noOp)
Creates component.
|
<T> T |
IgniteComponentType.createIfInClassPath(GridKernalContext ctx,
boolean mandatory)
Creates component.
|
<T> T |
IgniteComponentType.createOptional(GridKernalContext ctx)
First tries to find main component class, if it is not found creates no-op implementation.
|
static IgniteInternalFuture<String> |
IgniteDiagnosticMessage.dumpCommunicationInfo(GridKernalContext ctx,
UUID nodeId) |
static <R> ComputeTaskInternalFuture<R> |
ComputeTaskInternalFuture.finishedFuture(GridKernalContext ctx,
Class<?> taskCls,
IgniteCheckedException e) |
void |
GridMessageListenHandler.notifyCallback(UUID nodeId,
UUID routineId,
Collection<?> objs,
GridKernalContext ctx)
Notifies local callback.
|
void |
GridMessageListenHandler.onBatchAcknowledged(UUID routineId,
GridContinuousBatch batch,
GridKernalContext ctx)
Called when ack for a batch is received from client.
|
void |
MarshallerContextImpl.onMarshallerProcessorStarted(GridKernalContext ctx,
MarshallerMappingTransport transport) |
void |
GridMessageListenHandler.p2pMarshal(GridKernalContext ctx)
Deploys and marshals inner objects (called only if peer deployment is enabled).
|
void |
GridMessageListenHandler.p2pUnmarshal(UUID nodeId,
GridKernalContext ctx)
Unmarshals inner objects (called only if peer deployment is enabled).
|
GridContinuousHandler.RegisterStatus |
GridMessageListenHandler.register(UUID nodeId,
UUID routineId,
GridKernalContext ctx)
Registers listener.
|
void |
IgniteDiagnosticPrepareContext.send(GridKernalContext ctx,
IgniteInClosure<IgniteInternalFuture<String>> lsnr) |
void |
GridMessageListenHandler.unregister(UUID routineId,
GridKernalContext ctx)
Unregisters listener.
|
| Modifier and Type | Method and Description |
|---|---|
static IgniteDiagnosticMessage |
IgniteDiagnosticMessage.createRequest(Marshaller marsh,
IgniteClosure<GridKernalContext,IgniteDiagnosticInfo> c,
long futId) |
| Modifier and Type | Field and Description |
|---|---|
protected GridKernalContext |
ClusterGroupAdapter.ctx
Kernal context.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ClusterGroupAdapter.setKernalContext(GridKernalContext ctx)
Sets kernal context.
|
| Constructor and Description |
|---|
ClusterGroupAdapter(GridKernalContext ctx,
UUID subjId,
IgnitePredicate<ClusterNode> p) |
ClusterGroupAdapter(GridKernalContext ctx,
UUID subjId,
Set<UUID> ids) |
IgniteClusterImpl(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridExecutorService(ClusterGroupAdapter prj,
GridKernalContext ctx)
Creates executor service.
|
| Modifier and Type | Field and Description |
|---|---|
protected GridKernalContext |
GridManagerAdapter.ctx
Kernal context.
|
| Constructor and Description |
|---|
GridManagerAdapter(GridKernalContext ctx,
T... spis) |
| Constructor and Description |
|---|
GridCheckpointManager(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridCollisionManager(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridIoManager(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridDeploymentManager(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridDiscoveryManager(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridEventStorageManager(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridFailoverManager(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridIndexingManager(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridLoadBalancerManager(GridKernalContext ctx) |
| Modifier and Type | Field and Description |
|---|---|
protected GridKernalContext |
GridProcessorAdapter.ctx
Kernal context.
|
| Constructor and Description |
|---|
GridProcessorAdapter(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridAffinityAssignmentCache(GridKernalContext ctx,
String cacheOrGrpName,
int grpId,
AffinityFunction aff,
IgnitePredicate<ClusterNode> nodeFilter,
int backups,
boolean locCache)
Constructs affinity cached calculations.
|
GridAffinityProcessor(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
GridKernalContext |
GridCacheContext.kernalContext() |
GridKernalContext |
GridCacheSharedContext.kernalContext() |
GridKernalContext |
CacheObjectValueContext.kernalContext() |
GridKernalContext |
CacheObjectContext.kernalContext() |
| Modifier and Type | Method and Description |
|---|---|
static Collection<CacheStoreSessionListener> |
GridCacheUtils.startStoreSessionListeners(GridKernalContext ctx,
javax.cache.configuration.Factory<CacheStoreSessionListener>[] factories)
Creates and starts store session listeners.
|
static DynamicCacheChangeRequest |
DynamicCacheChangeRequest.stopRequest(GridKernalContext ctx,
String cacheName,
boolean sql,
boolean destroy) |
static void |
GridCacheUtils.stopStoreSessionListeners(GridKernalContext ctx,
Collection<CacheStoreSessionListener> sesLsnrs)
Stops store session listeners.
|
static <K,V,T> javax.cache.processor.EntryProcessor<K,V,T> |
EntryProcessorResourceInjectorProxy.wrap(GridKernalContext ctx,
javax.cache.processor.EntryProcessor<K,V,T> proc)
Wraps EntryProcessor if needed.
|
| Constructor and Description |
|---|
CacheObjectBinaryContext(GridKernalContext kernalCtx,
CacheConfiguration ccfg,
boolean cpyOnGet,
boolean storeVal,
boolean binaryEnabled,
boolean depEnabled) |
CacheObjectBinaryProcessorImpl(GridKernalContext ctx) |
IgniteBinaryImpl(GridKernalContext ctx,
CacheObjectBinaryProcessor proc) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCacheDatabaseSharedManager.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
GridCacheDatabaseSharedManager.onActivate(GridKernalContext ctx)
Called when cluster performing activation.
|
void |
IgniteCacheDatabaseSharedManager.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
GridCacheDatabaseSharedManager.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
| Constructor and Description |
|---|
GridCacheDatabaseSharedManager(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
FilePageStoreManager.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
FilePageStoreManager.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
| Constructor and Description |
|---|
FilePageStoreManager(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCacheSnapshotManager.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
IgniteCacheSnapshotManager.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
| Modifier and Type | Method and Description |
|---|---|
void |
FileWriteAheadLogManager.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
FileWriteAheadLogManager.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
| Constructor and Description |
|---|
FileWriteAheadLogManager(GridKernalContext ctx) |
| Modifier and Type | Class and Description |
|---|---|
class |
StandaloneGridKernalContext
Dummy grid kernal context
|
| Constructor and Description |
|---|
StandaloneIgnitePluginProcessor(GridKernalContext ctx,
IgniteConfiguration cfg) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheQueryMarshallable.unmarshall(Marshaller m,
GridKernalContext ctx) |
| Constructor and Description |
|---|
GridCacheQueryErrorFuture(GridKernalContext ctx,
Throwable err) |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheContinuousQueryListener.acknowledgeBackupOnTimeout(GridKernalContext ctx) |
void |
CacheContinuousQueryListener.flushBackupQueue(GridKernalContext ctx,
AffinityTopologyVersion topVer)
Flushes backup queue.
|
void |
CacheContinuousQueryHandler.notifyCallback(UUID nodeId,
UUID routineId,
Collection<?> objs,
GridKernalContext ctx)
Notifies local callback.
|
void |
CacheContinuousQueryHandler.onBatchAcknowledged(UUID routineId,
GridContinuousBatch batch,
GridKernalContext ctx)
Called when ack for a batch is received from client.
|
void |
CacheContinuousQueryHandlerV2.p2pMarshal(GridKernalContext ctx)
Deploys and marshals inner objects (called only if peer deployment is enabled).
|
void |
CacheContinuousQueryHandler.p2pMarshal(GridKernalContext ctx)
Deploys and marshals inner objects (called only if peer deployment is enabled).
|
void |
CacheContinuousQueryHandlerV2.p2pUnmarshal(UUID nodeId,
GridKernalContext ctx)
Unmarshals inner objects (called only if peer deployment is enabled).
|
void |
CacheContinuousQueryHandler.p2pUnmarshal(UUID nodeId,
GridKernalContext ctx)
Unmarshals inner objects (called only if peer deployment is enabled).
|
GridContinuousHandler.RegisterStatus |
CacheContinuousQueryHandler.register(UUID nodeId,
UUID routineId,
GridKernalContext ctx)
Registers listener.
|
void |
CacheContinuousQueryHandler.unregister(UUID routineId,
GridKernalContext ctx)
Unregisters listener.
|
| Modifier and Type | Method and Description |
|---|---|
protected abstract GridKernalContext |
GridCacheStoreManagerAdapter.igniteContext() |
protected GridKernalContext |
CacheOsStoreManager.igniteContext() |
| Constructor and Description |
|---|
CacheOsStoreManager(GridKernalContext ctx,
CacheConfiguration cfg)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCacheObjectProcessor.onContinuousProcessorStarted(GridKernalContext ctx) |
void |
IgniteCacheObjectProcessorImpl.onContinuousProcessorStarted(GridKernalContext ctx) |
| Constructor and Description |
|---|
IgniteCacheObjectProcessorImpl(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridClosureProcessor(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteChangeGlobalStateSupport.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
IgniteChangeGlobalStateSupport.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<String> |
ClusterProcessor.requestDiagnosticInfo(UUID nodeId,
IgniteClosure<GridKernalContext,IgniteDiagnosticInfo> c,
String baseMsg)
Sends diagnostic message closure to remote node.
|
| Constructor and Description |
|---|
ClusterProcessor(GridKernalContext ctx) |
GridClusterStateProcessor(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridContinuousHandler.notifyCallback(UUID nodeId,
UUID routineId,
Collection<?> objs,
GridKernalContext ctx)
Notifies local callback.
|
void |
GridContinuousHandler.onBatchAcknowledged(UUID routineId,
GridContinuousBatch batch,
GridKernalContext ctx)
Called when ack for a batch is received from client.
|
void |
GridContinuousHandler.p2pMarshal(GridKernalContext ctx)
Deploys and marshals inner objects (called only if peer deployment is enabled).
|
void |
GridContinuousHandler.p2pUnmarshal(UUID nodeId,
GridKernalContext ctx)
Unmarshals inner objects (called only if peer deployment is enabled).
|
GridContinuousHandler.RegisterStatus |
GridContinuousHandler.register(UUID nodeId,
UUID routineId,
GridKernalContext ctx)
Registers listener.
|
void |
GridContinuousHandler.unregister(UUID routineId,
GridKernalContext ctx)
Unregisters listener.
|
| Constructor and Description |
|---|
GridContinuousProcessor(GridKernalContext ctx) |
| Constructor and Description |
|---|
DataStreamerImpl(GridKernalContext ctx,
String cacheName,
DelayQueue<DataStreamerImpl<K,V>> flushQ) |
DataStreamProcessor(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheAtomicSequenceImpl.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
GridCacheLockImpl.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
GridCacheAtomicStampedImpl.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
GridCacheCountDownLatchImpl.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
GridCacheSemaphoreImpl.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
GridCacheAtomicReferenceImpl.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
DataStructuresProcessor.onActivate(GridKernalContext ctx)
Called when cluster performing activation.
|
void |
GridCacheAtomicLongImpl.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
GridCacheAtomicSequenceImpl.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
GridCacheLockImpl.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
GridCacheAtomicStampedImpl.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
GridCacheCountDownLatchImpl.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
GridCacheSemaphoreImpl.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
GridCacheAtomicReferenceImpl.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
DataStructuresProcessor.onDeActivate(GridKernalContext ctx)
Called when cluster performing deactivation.
|
void |
GridCacheAtomicLongImpl.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
DataStructuresProcessor.restoreStructuresState(GridKernalContext ctx) |
| Constructor and Description |
|---|
DataStructuresProcessor(GridKernalContext ctx) |
| Constructor and Description |
|---|
HadoopNoopHelper(GridKernalContext ctx)
Constructor.
|
HadoopNoopProcessor(GridKernalContext ctx) |
HadoopProcessorAdapter(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
GridKernalContext |
IgfsContext.kernalContext() |
| Modifier and Type | Method and Description |
|---|---|
void |
IgfsProcessor.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
IgfsNoopProcessor.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
IgfsProcessor.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
IgfsNoopProcessor.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
static void |
IgfsUtils.sendEvents(GridKernalContext kernalCtx,
IgfsPath path,
IgfsPath newPath,
int type)
Sends a series of event.
|
static void |
IgfsUtils.sendEvents(GridKernalContext kernalCtx,
IgfsPath path,
int type)
Sends a series of event.
|
| Constructor and Description |
|---|
IgfsContext(GridKernalContext ctx,
FileSystemConfiguration cfg,
IgfsMetaManager metaMgr,
IgfsDataManager dataMgr,
IgfsServerManager srvMgr,
IgfsFragmentizerManager fragmentizerMgr) |
IgfsNoopProcessor(GridKernalContext ctx)
Constructor.
|
IgfsProcessor(GridKernalContext ctx) |
IgfsProcessorAdapter(GridKernalContext ctx)
Constructor.
|
| Constructor and Description |
|---|
GridJobProcessor(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridJobMetricsProcessor(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridMarshallerMappingProcessor(GridKernalContext ctx) |
| Constructor and Description |
|---|
OsDiscoveryNodeValidationProcessor(GridKernalContext ctx) |
| Constructor and Description |
|---|
SqlListenerNioListener(GridKernalContext ctx,
GridSpinBusyLock busyLock,
int maxCursors)
Constructor.
|
SqlListenerProcessor(GridKernalContext ctx) |
| Constructor and Description |
|---|
JdbcMessageParser(GridKernalContext ctx) |
JdbcRequestHandler(GridKernalContext ctx,
GridSpinBusyLock busyLock,
int maxCursors,
boolean distributedJoins,
boolean enforceJoinOrder,
boolean collocated,
boolean replicatedOnly,
boolean autoCloseCursors)
Constructor.
|
| Modifier and Type | Field and Description |
|---|---|
protected GridKernalContext |
OdbcMessageParser.ctx
Kernal context.
|
| Constructor and Description |
|---|
OdbcMessageParser(GridKernalContext ctx) |
OdbcRequestHandler(GridKernalContext ctx,
GridSpinBusyLock busyLock,
int maxCursors,
boolean distributedJoins,
boolean enforceJoinOrder,
boolean replicatedOnly,
boolean collocated)
Constructor.
|
| Constructor and Description |
|---|
GridOffHeapProcessor(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
GridKernalContext |
PlatformContextImpl.kernalContext()
Gets kernal context.
|
GridKernalContext |
PlatformContext.kernalContext()
Gets kernal context.
|
| Modifier and Type | Method and Description |
|---|---|
PlatformJavaObjectFactory |
PlatformJavaObjectFactoryProxy.factory(GridKernalContext ctx)
Get factory instance.
|
void |
PlatformEventFilterListener.initialize(GridKernalContext ctx)
Initializes the filter.
|
| Constructor and Description |
|---|
PlatformContextImpl(GridKernalContext ctx,
PlatformCallbackGateway gate,
PlatformMemoryManagerImpl mem,
String platform)
Constructor.
|
PlatformNoopProcessor(GridKernalContext ctx) |
PlatformProcessorImpl(GridKernalContext ctx)
Constructor.
|
| Constructor and Description |
|---|
PlatformAffinity(PlatformContext platformCtx,
GridKernalContext igniteCtx,
String name)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PlatformBalancingSingleClosureAffinityTask.affinity(String cacheName,
Object affKey,
GridKernalContext ctx)
Init affinity.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PlatformDotNetCacheStore.initialize(GridKernalContext ctx,
boolean convertBinary)
Initialize the store.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PlatformEventFilterListenerImpl.initialize(GridKernalContext gridCtx)
Initializes the filter.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PlatformMessageFilter.initialize(GridKernalContext ctx)
Initializes the filter.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PlatformMessageFilterImpl.initialize(GridKernalContext kernalCtx)
Initializes the filter.
|
void |
PlatformMessageLocalFilter.initialize(GridKernalContext ctx)
Initializes the filter.
|
| Constructor and Description |
|---|
PlatformPluginProcessor(GridKernalContext ctx)
Ctor.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
PlatformUtils.initializeJavaObject(Object obj,
String clsName,
Map<String,Object> props,
GridKernalContext ctx)
Initialize Java object or object factory.
|
| Constructor and Description |
|---|
CachePluginManager(GridKernalContext ctx,
CacheConfiguration cfg) |
IgnitePluginProcessor(GridKernalContext ctx,
IgniteConfiguration cfg,
List<PluginProvider> providers) |
| Constructor and Description |
|---|
PoolProcessor(GridKernalContext ctx)
Constructor.
|
| Constructor and Description |
|---|
GridPortProcessor(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
GridKernalContext |
CacheQueryObjectValueContext.kernalContext() |
| Modifier and Type | Method and Description |
|---|---|
static QueryBinaryProperty |
QueryUtils.buildBinaryProperty(GridKernalContext ctx,
String pathStr,
Class<?> resType,
Map<String,String> aliases,
Boolean isKeyField)
Builds binary object property.
|
static void |
QueryUtils.processBinaryMeta(GridKernalContext ctx,
QueryEntity qryEntity,
QueryTypeDescriptorImpl d)
Processes declarative metadata for binary object.
|
void |
GridQueryIndexing.start(GridKernalContext ctx,
GridSpinBusyLock busyLock)
Starts indexing.
|
| Constructor and Description |
|---|
CacheQueryObjectValueContext(GridKernalContext ctx)
Constructor.
|
GridQueryProcessor(GridKernalContext ctx) |
| Constructor and Description |
|---|
QueryBinaryProperty(GridKernalContext ctx,
String propName,
QueryBinaryProperty parent,
Class<?> type,
Boolean key,
String alias)
Constructor.
|
| Constructor and Description |
|---|
SchemaOperationManager(GridKernalContext ctx,
GridQueryProcessor qryProc,
SchemaOperationWorker worker,
ClusterNode crd)
Constructor.
|
SchemaOperationWorker(GridKernalContext ctx,
GridQueryProcessor qryProc,
IgniteUuid depId,
SchemaAbstractOperation op,
boolean nop,
SchemaOperationException err,
boolean cacheRegistered,
QueryTypeDescriptorImpl type)
Constructor.
|
| Constructor and Description |
|---|
GridResourceProcessor(GridKernalContext ctx)
Creates resources processor.
|
| Constructor and Description |
|---|
GridRestProcessor(GridKernalContext ctx) |
| Modifier and Type | Field and Description |
|---|---|
protected GridKernalContext |
GridRestCommandHandlerAdapter.ctx
Kernal context.
|
| Constructor and Description |
|---|
GridRestCommandHandlerAdapter(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridCacheCommandHandler(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridChangeStateCommandHandler(GridKernalContext ctx) |
| Constructor and Description |
|---|
DataStructuresCommandHandler(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridLogCommandHandler(GridKernalContext ctx) |
| Constructor and Description |
|---|
QueryCommandHandler(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridRedisConnectionCommandHandler(IgniteLogger log,
GridRestProtocolHandler hnd,
GridKernalContext ctx)
Handler constructor.
|
| Constructor and Description |
|---|
GridRedisGetCommandHandler(IgniteLogger log,
GridRestProtocolHandler hnd,
GridKernalContext ctx)
Handler constructor.
|
GridRedisSetCommandHandler(IgniteLogger log,
GridRestProtocolHandler hnd,
GridKernalContext ctx)
Handler constructor.
|
| Constructor and Description |
|---|
GridTaskCommandHandler(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridTopologyCommandHandler(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridVersionCommandHandler(GridKernalContext ctx) |
| Modifier and Type | Field and Description |
|---|---|
protected GridKernalContext |
GridRestProtocolAdapter.ctx
Context.
|
| Constructor and Description |
|---|
GridRestProtocolAdapter(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridTcpRestNioListener(IgniteLogger log,
GridTcpRestProtocol proto,
GridRestProtocolHandler hnd,
GridKernalContext ctx)
Creates listener which will convert incoming tcp packets to rest requests and forward them to
a given rest handler.
|
GridTcpRestProtocol(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridRedisNioListener(IgniteLogger log,
GridRestProtocolHandler hnd,
GridKernalContext ctx) |
| Constructor and Description |
|---|
IgniteNoopScheduleProcessor(GridKernalContext ctx) |
IgniteScheduleProcessorAdapter(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridOsSecurityProcessor(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridOsSegmentationProcessor(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridServiceProcessor.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
GridServiceProcessor.onContinuousProcessorStarted(GridKernalContext ctx) |
void |
GridServiceProcessor.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
| Constructor and Description |
|---|
GridServiceProcessor(GridKernalContext ctx) |
GridServiceProxy(ClusterGroup prj,
String name,
Class<? super T> svc,
boolean sticky,
long timeout,
GridKernalContext ctx) |
| Constructor and Description |
|---|
GridTaskSessionProcessor(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridTaskProcessor.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
GridTaskProcessor.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
| Constructor and Description |
|---|
GridTaskProcessor(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridTimeoutProcessor(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
static byte |
IgniteUtils.directProtocolVersion(GridKernalContext ctx,
UUID nodeId)
Defines which protocol version to use for
communication with the provided node.
|
static IgniteClosure<UUID,ClusterNode> |
IgniteUtils.id2Node(GridKernalContext ctx) |
static IgniteLogger |
IgniteUtils.logger(GridKernalContext ctx,
AtomicReference<IgniteLogger> logRef,
Class<?> cls)
Initializes logger into/from log reference passed in.
|
static IgniteLogger |
IgniteUtils.logger(GridKernalContext ctx,
AtomicReference<IgniteLogger> logRef,
Object obj)
Initializes logger into/from log reference passed in.
|
static byte[] |
IgniteUtils.marshal(GridKernalContext ctx,
Object obj)
Marshals object to byte array.
|
static <T> T |
IgniteUtils.unmarshal(GridKernalContext ctx,
byte[] arr,
ClassLoader clsLdr)
Unmarshals object from the input stream using given class loader.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 2.2.0 Release Date : September 15 2017