You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2015/02/02 11:29:15 UTC
[39/50] [abbrv] incubator-ignite git commit: GridEx -> IgniteEx
GridKernal -> IgniteKernal
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c323a8e7/modules/core/src/main/java/org/apache/ignite/internal/GridKernalContext.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridKernalContext.java b/modules/core/src/main/java/org/apache/ignite/internal/GridKernalContext.java
index a7dd3aa..17f3ec8 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/GridKernalContext.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/GridKernalContext.java
@@ -138,7 +138,7 @@ public interface GridKernalContext extends Iterable<GridComponent> {
*
* @return Grid instance.
*/
- public GridEx grid();
+ public IgniteEx grid();
/**
* Gets grid configuration.
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c323a8e7/modules/core/src/main/java/org/apache/ignite/internal/GridKernalContextImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridKernalContextImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/GridKernalContextImpl.java
index 8bb0085..776cda6 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/GridKernalContextImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/GridKernalContextImpl.java
@@ -266,7 +266,7 @@ public class GridKernalContextImpl implements GridKernalContext, Externalizable
private List<GridComponent> comps = new LinkedList<>();
/** */
- private GridEx grid;
+ private IgniteEx grid;
/** */
private ExecutorService utilityCachePool;
@@ -320,7 +320,7 @@ public class GridKernalContextImpl implements GridKernalContext, Externalizable
*/
@SuppressWarnings("TypeMayBeWeakened")
protected GridKernalContextImpl(GridLoggerProxy log,
- GridEx grid,
+ IgniteEx grid,
IgniteConfiguration cfg,
GridKernalGateway gw,
ExecutorService utilityCachePool,
@@ -496,7 +496,7 @@ public class GridKernalContextImpl implements GridKernalContext, Externalizable
}
/** {@inheritDoc} */
- @Override public GridEx grid() {
+ @Override public IgniteEx grid() {
return grid;
}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c323a8e7/modules/core/src/main/java/org/apache/ignite/internal/GridUpdateNotifier.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridUpdateNotifier.java b/modules/core/src/main/java/org/apache/ignite/internal/GridUpdateNotifier.java
index 9720a60..4bfeb5c 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/GridUpdateNotifier.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/GridUpdateNotifier.java
@@ -219,7 +219,7 @@ class GridUpdateNotifier {
throttle(log, false, "Your version is up to date.");
}
else
- throttle(log, true, "New version is available at " + GridKernal.SITE + ": " + latestVer);
+ throttle(log, true, "New version is available at " + IgniteKernal.SITE + ": " + latestVer);
else
if (!reportOnlyNew)
throttle(log, false, "Update status is not available.");
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c323a8e7/modules/core/src/main/java/org/apache/ignite/internal/IgniteClusterAsyncImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteClusterAsyncImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteClusterAsyncImpl.java
index a02c931..ae4b541 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteClusterAsyncImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteClusterAsyncImpl.java
@@ -31,12 +31,12 @@ import java.util.*;
*/
public class IgniteClusterAsyncImpl extends IgniteAsyncSupportAdapter<IgniteCluster> implements IgniteCluster {
/** */
- private final GridKernal grid;
+ private final IgniteKernal grid;
/**
* @param grid Grid.
*/
- public IgniteClusterAsyncImpl(GridKernal grid) {
+ public IgniteClusterAsyncImpl(IgniteKernal grid) {
super(true);
this.grid = grid;
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c323a8e7/modules/core/src/main/java/org/apache/ignite/internal/IgniteEx.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteEx.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteEx.java
new file mode 100644
index 0000000..6aa8bf5
--- /dev/null
+++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteEx.java
@@ -0,0 +1,143 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.internal;
+
+import org.apache.ignite.*;
+import org.apache.ignite.cache.*;
+import org.apache.ignite.internal.processors.cache.*;
+import org.apache.ignite.lang.*;
+import org.apache.ignite.internal.processors.interop.*;
+import org.jetbrains.annotations.*;
+
+import java.util.*;
+
+/**
+ * Extended Grid interface which provides some additional methods required for kernal and Visor.
+ */
+public interface IgniteEx extends Ignite, ClusterGroupEx, IgniteCluster {
+ /**
+ * Gets utility cache.
+ *
+ * @param keyCls Key class.
+ * @param valCls Value class.
+ * @return Utility cache.
+ */
+ public <K extends GridCacheUtilityKey, V> GridCacheProjectionEx<K, V> utilityCache(Class<K> keyCls, Class<V> valCls);
+
+ /**
+ * Gets the cache instance for the given name if one is configured or
+ * <tt>null</tt> otherwise returning even non-public caches.
+ *
+ * @param <K> Key type.
+ * @param <V> Value type.
+ * @param name Cache name.
+ * @return Cache instance for given name or <tt>null</tt> if one does not exist.
+ */
+ @Nullable public <K, V> GridCache<K, V> cachex(@Nullable String name);
+
+ /**
+ * Gets default cache instance if one is configured or <tt>null</tt> otherwise returning even non-public caches.
+ * The {@link org.apache.ignite.cache.GridCache#name()} method on default instance returns <tt>null</tt>.
+ *
+ * @param <K> Key type.
+ * @param <V> Value type.
+ * @return Default cache instance.
+ */
+ @Nullable public <K, V> GridCache<K, V> cachex();
+
+ /**
+ * Gets configured cache instance that satisfy all provided predicates including non-public caches. If no
+ * predicates provided - all configured caches will be returned.
+ *
+ * @param p Predicates. If none provided - all configured caches will be returned.
+ * @return Configured cache instances that satisfy all provided predicates.
+ */
+ public Collection<GridCache<?, ?>> cachesx(@Nullable IgnitePredicate<? super GridCache<?, ?>>... p);
+
+ /**
+ * Checks if the event type is user-recordable.
+ *
+ * @param type Event type to check.
+ * @return {@code true} if passed event should be recorded, {@code false} - otherwise.
+ */
+ public boolean eventUserRecordable(int type);
+
+ /**
+ * Checks whether all provided events are user-recordable.
+ * <p>
+ * Note that this method supports only predefined GridGain events.
+ *
+ * @param types Event types.
+ * @return Whether all events are recordable.
+ * @throws IllegalArgumentException If {@code types} contains user event type.
+ */
+ public boolean allEventsUserRecordable(int[] types);
+
+ /**
+ * Gets list of compatible versions.
+ *
+ * @return Compatible versions.
+ */
+ public Collection<String> compatibleVersions();
+
+ /**
+ * @return Grace period left in minutes if bursting or {@code -1} otherwise.
+ */
+ public long licenseGracePeriodLeft();
+
+ /**
+ * Whether or not remote JMX management is enabled for this node.
+ *
+ * @return {@code True} if remote JMX management is enabled - {@code false} otherwise.
+ */
+ public boolean isJmxRemoteEnabled();
+
+ /**
+ * Whether or not node restart is enabled.
+ *
+ * @return {@code True} if restart mode is enabled, {@code false} otherwise.
+ */
+ public boolean isRestartEnabled();
+
+ /**
+ * Whether or not SMTP is configured.
+ *
+ * @return {@code True} if SMTP is configured - {@code false} otherwise.
+ */
+ public boolean isSmtpEnabled();
+
+ /**
+ * Schedule sending of given email to all configured admin emails.
+ */
+ IgniteInternalFuture<Boolean> sendAdminEmailAsync(String subj, String body, boolean html);
+
+ /**
+ * Get GGFS instance returning null if it doesn't exist.
+ *
+ * @param name GGFS name.
+ * @return GGFS.
+ */
+ @Nullable public IgniteFs ggfsx(@Nullable String name);
+
+ /**
+ * Gets interop processor.
+ *
+ * @return Interop processor.
+ */
+ public GridInteropProcessor interop();
+}