| 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.
|
static void |
MarshallerContextImpl.saveMappings(GridKernalContext ctx,
List<Map<Integer,MappedName>> mappings,
File dir) |
void |
IgniteDiagnosticPrepareContext.send(GridKernalContext ctx,
@Nullable 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 | Method and Description |
|---|---|
void |
IndexProcessor.destroyOrphanIndex(GridKernalContext ctx,
RootPage page,
String indexName,
int grpId,
PageMemory pageMemory,
GridAtomicLong removeId,
ReuseList reuseList,
boolean mvccEnabled)
Destroy founded index which belongs to stopped cache.
|
| Constructor and Description |
|---|
IndexProcessor(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<DurableBackgroundTaskResult> |
DurableBackgroundCleanupIndexTreeTask.executeAsync(GridKernalContext ctx)
Asynchronous task execution.
|
| 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(@Nullable GridKernalContext ctx,
@Nullable UUID subjId,
@Nullable IgnitePredicate<ClusterNode> p) |
ClusterGroupAdapter(@Nullable GridKernalContext ctx,
@Nullable UUID subjId,
Set<UUID> ids) |
DistributedBaselineConfiguration(GridInternalSubscriptionProcessor isp,
GridKernalContext ctx,
IgniteLogger log) |
IgniteClusterImpl(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
int |
MetadataTypeArgs.typeId(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridExecutorService(ClusterGroupAdapter prj,
GridKernalContext ctx)
Creates executor service.
|
| Constructor and Description |
|---|
MaintenanceProcessor(GridKernalContext ctx) |
| 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) |
| Modifier and Type | Field and Description |
|---|---|
protected GridKernalContext |
DiscoveryMessageResultsCollector.ctx |
| Constructor and Description |
|---|
ClusterMetricsImpl(GridKernalContext ctx,
long nodeStartTime) |
DiscoveryMessageResultsCollector(GridKernalContext ctx) |
GridDiscoveryManager(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridEncryptionManager.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
GridEncryptionManager.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
| Constructor and Description |
|---|
CacheGroupPageScanner(GridKernalContext ctx) |
GridEncryptionManager(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) |
| Constructor and Description |
|---|
GridSystemViewManager(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridTracingManager(GridKernalContext ctx,
boolean useNoopTracingSpi)
Constructor.
|
| 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) |
| Constructor and Description |
|---|
IgniteAuthenticationProcessor(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
GridKernalContext |
GridCacheContext.kernalContext() |
GridKernalContext |
CacheObjectContext.kernalContext() |
GridKernalContext |
GridCacheSharedContext.kernalContext() |
GridKernalContext |
CacheObjectValueContext.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 Map<Class<? extends WarmUpConfiguration>,WarmUpStrategy> |
GridCacheUtils.warmUpStrategies(GridKernalContext kernalCtx)
Getting available warming strategies.
|
static <K,V,T> javax.cache.processor.EntryProcessor<K,V,T> |
EntryProcessorResourceInjectorProxy.wrap(GridKernalContext ctx,
@Nullable javax.cache.processor.EntryProcessor<K,V,T> proc)
Wraps EntryProcessor if needed.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CacheObjectBinaryProcessorImpl.onContinuousProcessorStarted(GridKernalContext ctx) |
| Constructor and Description |
|---|
CacheObjectBinaryProcessorImpl(GridKernalContext ctx) |
IgniteBinaryImpl(GridKernalContext ctx,
IgniteCacheObjectProcessor proc) |
| Constructor and Description |
|---|
ExchangeLatchManager(GridKernalContext ctx)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
static boolean |
MvccUtils.mvccEnabled(GridKernalContext ctx) |
static @Nullable GridNearTxLocal |
MvccUtils.tx(GridKernalContext ctx) |
static @Nullable GridNearTxLocal |
MvccUtils.tx(GridKernalContext ctx,
@Nullable GridCacheVersion txId) |
static GridNearTxLocal |
MvccUtils.txStart(GridKernalContext ctx,
long timeout) |
| Constructor and Description |
|---|
MvccProcessorImpl(GridKernalContext ctx) |
| Constructor and Description |
|---|
TxLog(GridKernalContext ctx,
IgniteCacheDatabaseSharedManager mgr) |
| Modifier and Type | Method and Description |
|---|---|
protected List<DatabaseLifecycleListener> |
IgniteCacheDatabaseSharedManager.getDatabaseListeners(GridKernalContext kctx) |
void |
GridCacheDatabaseSharedManager.onActivate(GridKernalContext ctx)
Called when cluster performing activation.
|
void |
IgniteCacheDatabaseSharedManager.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
GridCacheDatabaseSharedManager.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
IgniteCacheDatabaseSharedManager.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
GridCacheDatabaseSharedManager.startMemoryRestore(GridKernalContext kctx,
TimeBag startTimer)
Perform memory restore before
GridDiscoveryManager start. |
void |
IgniteCacheDatabaseSharedManager.startMemoryRestore(GridKernalContext kctx,
TimeBag startTimer)
Perform memory restore before
GridDiscoveryManager start. |
| Constructor and Description |
|---|
DataRegionMetricsImpl(DataRegionConfiguration dataRegionCfg,
GridKernalContext kernalCtx)
Same as
DataRegionMetricsImpl.DataRegionMetricsImpl(DataRegionConfiguration, GridKernalContext, DataRegionMetricsProvider)
but uses a no-op implementation for the DataRegionMetricsProvider. |
DataRegionMetricsImpl(DataRegionConfiguration dataRegionCfg,
GridKernalContext kernalCtx,
DataRegionMetricsProvider dataRegionMetricsProvider) |
FileLockHolder(String path,
@NotNull GridKernalContext ctx,
IgniteLogger log) |
GridCacheDatabaseSharedManager(GridKernalContext ctx) |
| Constructor and Description |
|---|
DefragmentationMXBeanImpl(GridKernalContext ctx) |
DefragmentationPageReadWriteManager(GridKernalContext ctx,
String name) |
IgniteDefragmentationImpl(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) |
| Constructor and Description |
|---|
PdsConsistentIdProcessor(GridKernalContext ctx)
Creates folders resolver
|
| Constructor and Description |
|---|
AbstractFreeList(int cacheGrpId,
String name,
DataRegion dataRegion,
ReuseList reuseList,
IgniteWriteAheadLogManager wal,
long metaPageId,
boolean initNew,
PageLockListener lockLsnr,
GridKernalContext ctx,
AtomicLong pageListCacheLimit,
byte pageFlag) |
CacheFreeList(int cacheGrpId,
String name,
DataRegion dataRegion,
IgniteWriteAheadLogManager wal,
long metaPageId,
boolean initNew,
PageLockListener lockLsnr,
GridKernalContext ctx,
AtomicLong pageListCacheLimit,
byte pageFlag) |
PagesList(int cacheGrpId,
String name,
PageMemory pageMem,
int buckets,
IgniteWriteAheadLogManager wal,
long metaPageId,
PageLockListener lockLsnr,
GridKernalContext ctx,
byte pageFlag) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<DurableBackgroundTaskResult> |
DurableBackgroundTask.executeAsync(GridKernalContext ctx)
Asynchronous task execution.
|
| Constructor and Description |
|---|
PageReadWriteManagerImpl(GridKernalContext ctx,
PageStoreCollection pageStores,
String name) |
| Constructor and Description |
|---|
PartitionMetaStorageImpl(int cacheGrpId,
String name,
DataRegion memPlc,
ReuseList reuseList,
IgniteWriteAheadLogManager wal,
long metaPageId,
boolean initNew,
PageLockListener lsnr,
GridKernalContext ctx,
AtomicLong pageListCacheLimit,
byte pageFlag) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteSnapshotManager.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
IgniteCacheSnapshotManager.onActivate(GridKernalContext kctx)
Deprecated.
Called when cluster performing activation.
|
void |
IgniteSnapshotManager.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
IgniteCacheSnapshotManager.onDeActivate(GridKernalContext kctx)
Deprecated.
Called when cluster performing deactivation.
|
GridCloseableIterator<CacheDataRow> |
IgniteSnapshotManager.partitionRowIterator(GridKernalContext ctx,
String grpName,
int partId,
FilePageStore pageStore) |
GridCloseableIterator<CacheDataRow> |
IgniteSnapshotManager.partitionRowIterator(GridKernalContext ctx,
String snpName,
String folderName,
String grpName,
int partId) |
| Constructor and Description |
|---|
IgniteSnapshotManager(GridKernalContext ctx) |
SnapshotMXBeanImpl(GridKernalContext ctx) |
SnapshotRestoreProcess(GridKernalContext ctx) |
| Constructor and Description |
|---|
ReuseListImpl(int cacheId,
String name,
PageMemory pageMem,
IgniteWriteAheadLogManager wal,
long metaPageId,
boolean initNew,
PageLockListener lockLsnr,
GridKernalContext ctx,
AtomicLong pageListCacheLimit,
byte pageFlag) |
| 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)
Constructor.
|
| Modifier and Type | Class and Description |
|---|---|
class |
StandaloneGridKernalContext
Dummy context for offline utilities.
|
| 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.flushOnExchangeDone(GridKernalContext ctx,
AffinityTopologyVersion topVer)
Flushes backup queue.
|
protected void |
CacheContinuousQueryHandler.initRemoteFilter(javax.cache.event.CacheEntryEventFilter filter,
GridKernalContext ctx)
Performs resource injection and checks asynchrony for the provided remote filter.
|
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 |
CacheContinuousQueryHandlerV3.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.p2pMarshal(GridKernalContext ctx)
Deploys and marshals inner objects (called only if peer deployment is enabled).
|
protected <T> T |
CacheContinuousQueryHandler.p2pUnmarshal(org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryDeployableObject depObj,
UUID nodeId,
GridKernalContext ctx) |
void |
CacheContinuousQueryHandlerV3.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).
|
void |
CacheContinuousQueryHandlerV2.p2pUnmarshal(UUID nodeId,
GridKernalContext ctx)
Unmarshals inner objects (called only if peer deployment is enabled).
|
GridContinuousHandler.RegisterStatus |
CacheContinuousQueryHandlerV3.register(UUID nodeId,
UUID routineId,
GridKernalContext ctx)
Registers listener.
|
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.
|
| Constructor and Description |
|---|
TransactionMetricsAdapter(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCacheObjectProcessor.onContinuousProcessorStarted(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 |
|---|
BaselineAutoAdjustMXBeanImpl(GridKernalContext ctx) |
ClusterProcessor(GridKernalContext ctx) |
GridClusterStateProcessor(GridKernalContext ctx) |
| Constructor and Description |
|---|
BaselineTopologyUpdater(GridKernalContext ctx) |
| Constructor and Description |
|---|
CompressionProcessor(GridKernalContext ctx) |
| Constructor and Description |
|---|
DistributedConfigurationProcessor(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,
@Nullable String cacheName,
DelayQueue<DataStreamerImpl<K,V>> flushQ) |
DataStreamProcessor(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
DataStructuresProcessor.onActivate(GridKernalContext ctx)
Called when cluster performing activation.
|
void |
AtomicDataStructureProxy.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
DataStructuresProcessor.onDeActivate(GridKernalContext ctx)
Called when cluster performing deactivation.
|
void |
AtomicDataStructureProxy.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
void |
DataStructuresProcessor.restoreStructuresState(GridKernalContext ctx) |
| Constructor and Description |
|---|
DataStructuresProcessor(GridKernalContext ctx) |
| Constructor and Description |
|---|
DiagnosticProcessor(GridKernalContext ctx)
Constructor.
|
| Constructor and Description |
|---|
FailureProcessor(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridJobProcessor(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridJobMetricsProcessor(GridKernalContext ctx)
Deprecated.
|
| Constructor and Description |
|---|
DurableBackgroundTasksProcessor(GridKernalContext ctx)
Constructor.
|
| Constructor and Description |
|---|
GridMarshallerMappingProcessor(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
static boolean |
ReadableDistributedMetaStorage.isSupported(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
DistributedMetaStorageImpl.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
DistributedMetaStorageImpl.onDeActivate(GridKernalContext kctx)
Called when cluster performing deactivation.
|
| Constructor and Description |
|---|
DistributedMetaStorageImpl(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridMetricManager(GridKernalContext ctx) |
| Constructor and Description |
|---|
OsDiscoveryNodeValidationProcessor(GridKernalContext ctx) |
| Modifier and Type | Field and Description |
|---|---|
protected GridKernalContext |
ClientListenerAbstractConnectionContext.ctx
Kernal context.
|
| Modifier and Type | Method and Description |
|---|---|
GridKernalContext |
ClientListenerAbstractConnectionContext.kernalContext() |
| Constructor and Description |
|---|
ClientListenerAbstractConnectionContext(GridKernalContext ctx,
GridNioSession ses,
long connId)
Constructor.
|
ClientListenerMetrics(GridKernalContext ctx) |
ClientListenerNioListener(GridKernalContext ctx,
GridSpinBusyLock busyLock,
ClientConnectorConfiguration cliConnCfg)
Constructor.
|
ClientListenerProcessor(GridKernalContext ctx) |
| Constructor and Description |
|---|
JdbcConnectionContext(GridKernalContext ctx,
GridNioSession ses,
GridSpinBusyLock busyLock,
long connId,
int maxCursors)
Constructor.
|
JdbcMessageParser(GridKernalContext ctx,
JdbcProtocolContext protoCtx) |
JdbcMetadataInfo(GridKernalContext ctx)
Initializes info.
|
| Modifier and Type | Field and Description |
|---|---|
protected GridKernalContext |
OdbcMessageParser.ctx
Kernal context.
|
| Constructor and Description |
|---|
OdbcConnectionContext(GridKernalContext ctx,
GridNioSession ses,
GridSpinBusyLock busyLock,
long connId,
int maxCursors)
Constructor.
|
OdbcMessageParser(GridKernalContext ctx,
ClientListenerProtocolVersion ver) |
OdbcRequestHandler(GridKernalContext ctx,
GridSpinBusyLock busyLock,
ClientListenerResponseSender sender,
int maxCursors,
boolean distributedJoins,
boolean enforceJoinOrder,
boolean replicatedOnly,
boolean collocated,
boolean lazy,
boolean skipReducerOnUpdate,
NestedTxMode nestedTxMode,
ClientListenerProtocolVersion ver,
OdbcConnectionContext connCtx)
Constructor.
|
| Constructor and Description |
|---|
GridOffHeapProcessor(GridKernalContext ctx) |
| Constructor and Description |
|---|
FilePerformanceStatisticsWriter(GridKernalContext ctx) |
PerformanceStatisticsMBeanImpl(GridKernalContext ctx) |
PerformanceStatisticsProcessor(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 |
|---|
ClientConnectionContext(GridKernalContext ctx,
GridNioSession ses,
long connId,
int maxCursors,
ThinClientConfiguration thinCfg)
Ctor.
|
| 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 |
PlatformMessageLocalFilter.initialize(GridKernalContext ctx)
Initializes the filter.
|
void |
PlatformMessageFilterImpl.initialize(GridKernalContext kernalCtx)
Initializes the filter.
|
| Constructor and Description |
|---|
PlatformPluginProcessor(GridKernalContext ctx)
Ctor.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
PlatformUtils.initializeJavaObject(Object obj,
String clsName,
@Nullable Map<String,Object> props,
@Nullable 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,
boolean notNull,
Object dlftVal,
int precision,
int scale)
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.
|
static QueryTypeCandidate |
QueryUtils.typeForQueryEntity(GridKernalContext ctx,
String cacheName,
String schemaName,
GridCacheContextInfo cacheInfo,
QueryEntity qryEntity,
List<Class<?>> mustDeserializeClss,
boolean escape)
Create type candidate for query entity.
|
| Constructor and Description |
|---|
CacheQueryObjectValueContext(GridKernalContext ctx)
Constructor.
|
GridQueryProcessor(GridKernalContext ctx)
Constructor.
|
RunningQueryManager(GridKernalContext ctx)
Constructor.
|
SqlClientContext(GridKernalContext ctx,
javax.cache.configuration.Factory<GridWorker> orderedBatchWorkerFactory,
boolean distributedJoins,
boolean enforceJoinOrder,
boolean collocated,
boolean replicatedOnly,
boolean lazy,
boolean skipReducerOnUpdate,
@Nullable Boolean dataPageScanEnabled,
@Nullable Integer updateBatchSize) |
| Constructor and Description |
|---|
IndexRebuildStateStorage(GridKernalContext ctx)
Constructor.
|
| Constructor and Description |
|---|
QueryBinaryProperty(GridKernalContext ctx,
String propName,
QueryBinaryProperty parent,
Class<?> type,
boolean key,
String alias,
boolean notNull,
Object defaultValue,
int precision,
int scale)
Constructor.
|
| Constructor and Description |
|---|
SchemaOperationManager(GridKernalContext ctx,
GridQueryProcessor qryProc,
SchemaOperationWorker worker,
@Nullable ClusterNode crd)
Constructor.
|
SchemaOperationWorker(GridKernalContext ctx,
GridQueryProcessor qryProc,
IgniteUuid depId,
SchemaAbstractOperation op,
boolean nop,
@Nullable SchemaOperationException err,
boolean cacheRegistered,
@Nullable 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 |
|---|
AuthenticationCommandHandler(GridKernalContext ctx) |
| Constructor and Description |
|---|
NodeStateBeforeStartCommandHandler(GridKernalContext ctx)
Construecor.
|
| Constructor and Description |
|---|
GridCacheCommandHandler(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridBaselineCommandHandler(GridKernalContext ctx) |
GridChangeClusterStateCommandHandler(GridKernalContext ctx) |
GridChangeStateCommandHandler(GridKernalContext ctx) |
GridClusterNameCommandHandler(GridKernalContext ctx) |
| Constructor and Description |
|---|
DataStructuresCommandHandler(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridLogCommandHandler(GridKernalContext ctx) |
| Constructor and Description |
|---|
MemoryMetricsCommandHandler(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridProbeCommandHandler(GridKernalContext ctx) |
| Constructor and Description |
|---|
QueryCommandHandler(GridKernalContext ctx) |
| Modifier and Type | Field and Description |
|---|---|
protected GridKernalContext |
GridRedisRestCommandHandler.ctx
Kernel context.
|
| Constructor and Description |
|---|
GridRedisConnectionCommandHandler(IgniteLogger log,
GridRestProtocolHandler hnd,
GridKernalContext ctx)
Handler constructor.
|
GridRedisRestCommandHandler(IgniteLogger log,
GridRestProtocolHandler hnd,
GridKernalContext ctx)
Constructor.
|
| Constructor and Description |
|---|
GridRedisDelCommandHandler(IgniteLogger log,
GridRestProtocolHandler hnd,
GridKernalContext ctx)
Handler constructor.
|
GridRedisExistsCommandHandler(IgniteLogger log,
GridRestProtocolHandler hnd,
GridKernalContext ctx)
Handler constructor.
|
GridRedisExpireCommandHandler(IgniteLogger log,
GridRestProtocolHandler hnd,
GridKernalContext ctx)
Handler constructor.
|
| Constructor and Description |
|---|
GridRedisDbSizeCommandHandler(IgniteLogger log,
GridRestProtocolHandler hnd,
GridKernalContext ctx)
Handler constructor.
|
GridRedisFlushCommandHandler(IgniteLogger log,
GridRestProtocolHandler hnd,
GridKernalContext ctx)
Handler constructor.
|
| Constructor and Description |
|---|
GridTaskCommandHandler(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridTopologyCommandHandler(GridKernalContext ctx) |
| Constructor and Description |
|---|
UserActionCommandHandler(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) |
| Modifier and Type | Method and Description |
|---|---|
static boolean |
SecurityUtils.isSystemType(GridKernalContext ctx,
Object target,
boolean considerWrapperCls) |
static <T> T |
SecurityUtils.sandboxedProxy(GridKernalContext ctx,
Class cls,
T instance) |
| Constructor and Description |
|---|
IgniteSecurityProcessor(GridKernalContext ctx,
GridSecurityProcessor secPrc) |
NoOpIgniteSecurityProcessor(GridKernalContext ctx) |
| Constructor and Description |
|---|
AccessControllerSandbox(GridKernalContext ctx,
IgniteSecurity security)
Constructor.
|
| Constructor and Description |
|---|
GridOsSegmentationProcessor(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
ServiceInfo.context(GridKernalContext ctx)
Sets kernal context.
|
void |
IgniteServiceProcessor.onActivate(GridKernalContext kctx)
Called when cluster performing activation.
|
void |
GridServiceProcessor.onActivate(GridKernalContext kctx)
Deprecated.
Called when cluster performing activation.
|
void |
GridServiceProcessor.onContinuousProcessorStarted(GridKernalContext ctx)
Deprecated.
|
void |
IgniteServiceProcessor.onDeActivate(GridKernalContext kctx)
Invokes from services deployment worker.
|
void |
GridServiceProcessor.onDeActivate(GridKernalContext kctx)
Deprecated.
Called when cluster performing deactivation.
|
| Constructor and Description |
|---|
GridServiceProcessor(GridKernalContext ctx)
Deprecated.
|
GridServiceProxy(ClusterGroup prj,
String name,
Class<? super T> svc,
boolean sticky,
long timeout,
GridKernalContext ctx) |
IgniteServiceProcessor(GridKernalContext ctx) |
ServiceProcessorAdapter(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridTaskSessionProcessor(GridKernalContext ctx) |
| Constructor and Description |
|---|
GridInternalSubscriptionProcessor(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 | Field and Description |
|---|---|
protected GridKernalContext |
GridTracingConfigurationManager.ctx
Kernal context.
|
| Constructor and Description |
|---|
GridTracingConfigurationManager(@NotNull GridKernalContext ctx)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
static int |
IgniteUtils.availableThreadCount(GridKernalContext ctx,
byte plc,
int reserved) |
static void |
IgniteUtils.broadcastToNodesSupportingFeature(GridKernalContext kctx,
IgniteRunnable job,
boolean srvrsOnly,
IgniteFeatures feature)
Broadcasts given job to nodes that support ignite feature.
|
static IgniteUuid |
IgniteUtils.contextDeploymentClassLoaderId(GridKernalContext ctx)
Returns Deployment class loader id if method was invoked in the job context
(it may be the context of a cache's operation which was triggered by the distributed job)
or
null if no context was found or Deployment is switched off. |
static ClassLoader |
IgniteUtils.deploymentClassLoader(GridKernalContext ctx,
IgniteUuid ldrId)
Gets that deployment class loader matching by the specific id, or
null
if the class loader was not found. |
static byte |
IgniteUtils.directProtocolVersion(GridKernalContext ctx,
UUID nodeId)
Defines which protocol version to use for
communication with the provided node.
|
static BaselineTopology |
IgniteUtils.getBaselineTopology(@NotNull GridKernalContext ctx) |
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 ClusterNode |
IgniteUtils.randomServerNode(GridKernalContext ctx) |
static void |
IgniteUtils.restoreDeploymentContext(GridKernalContext ctx,
IgniteUuid ldrId)
Restores a deployment context for cache deployment.
|
static <T> T |
IgniteUtils.unmarshal(GridKernalContext ctx,
byte[] arr,
@Nullable ClassLoader clsLdr)
Unmarshals object from the input stream using given class loader.
|
| Constructor and Description |
|---|
DistributedProcess(GridKernalContext ctx,
DistributedProcess.DistributedProcessType type,
Function<I,IgniteInternalFuture<R>> exec,
CI3<UUID,Map<UUID,R>,Map<UUID,Exception>> finish) |
DistributedProcess(GridKernalContext ctx,
DistributedProcess.DistributedProcessType type,
Function<I,IgniteInternalFuture<R>> exec,
CI3<UUID,Map<UUID,R>,Map<UUID,Exception>> finish,
BiFunction<UUID,I,? extends InitMessage<I>> initMsgFactory) |
| Constructor and Description |
|---|
IndexingQueryFilterImpl(GridKernalContext ctx,
@Nullable AffinityTopologyVersion topVer,
@Nullable int[] partsArr)
Constructor.
|
IndexingQueryFilterImpl(GridKernalContext ctx,
@Nullable AffinityTopologyVersion topVer,
@Nullable int[] partsArr,
boolean treatReplicatedAsPartitioned)
Constructor.
|
| Constructor and Description |
|---|
OomExceptionHandler(GridKernalContext ctx) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.11.0 Release Date : September 11 2021