You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ak...@apache.org on 2015/08/31 16:11:06 UTC
[13/18] ignite git commit: Defined platform processor interface.
Defined platform processor interface.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/13358c3e
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/13358c3e
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/13358c3e
Branch: refs/heads/ignite-843
Commit: 13358c3e03d48f481abe6a7178adbfcec4bd92d9
Parents: c2de38d
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Mon Aug 31 13:40:54 2015 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
Committed: Mon Aug 31 13:40:54 2015 +0300
----------------------------------------------------------------------
.../platform/PlatformNoopProcessor.java | 61 +++++++++++
.../processors/platform/PlatformProcessor.java | 106 ++++++++++++++++++-
2 files changed, 164 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/13358c3e/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformNoopProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformNoopProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformNoopProcessor.java
index 7cb65d3..eadb4c7 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformNoopProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformNoopProcessor.java
@@ -20,6 +20,7 @@ package org.apache.ignite.internal.processors.platform;
import org.apache.ignite.*;
import org.apache.ignite.internal.*;
import org.apache.ignite.internal.processors.*;
+import org.jetbrains.annotations.*;
/**
* No-op processor.
@@ -45,11 +46,71 @@ public class PlatformNoopProcessor extends GridProcessorAdapter implements Platf
}
/** {@inheritDoc} */
+ @Override public void releaseStart() {
+ // No-op.
+ }
+
+ /** {@inheritDoc} */
@Override public void awaitStart() throws IgniteCheckedException {
// No-op.
}
/** {@inheritDoc} */
+ @Override public PlatformTarget cache(@Nullable String name) throws IgniteCheckedException {
+ return null;
+ }
+
+ /** {@inheritDoc} */
+ @Override public PlatformTarget createCache(@Nullable String name) throws IgniteCheckedException {
+ return null;
+ }
+
+ /** {@inheritDoc} */
+ @Override public PlatformTarget getOrCreateCache(@Nullable String name) throws IgniteCheckedException {
+ return null;
+ }
+
+ /** {@inheritDoc} */
+ @Override public PlatformTarget affinity(@Nullable String name) throws IgniteCheckedException {
+ return null;
+ }
+
+ /** {@inheritDoc} */
+ @Override public PlatformTarget dataStreamer(@Nullable String cacheName, boolean keepPortable) throws IgniteCheckedException {
+ return null;
+ }
+
+ /** {@inheritDoc} */
+ @Override public PlatformTarget transactions() {
+ return null;
+ }
+
+ /** {@inheritDoc} */
+ @Override public PlatformTarget projection() throws IgniteCheckedException {
+ return null;
+ }
+
+ /** {@inheritDoc} */
+ @Override public PlatformTarget compute(PlatformTarget grp) {
+ return null;
+ }
+
+ /** {@inheritDoc} */
+ @Override public PlatformTarget message(PlatformTarget grp) {
+ return null;
+ }
+
+ @Override
+ public PlatformTarget events(PlatformTarget grp) {
+ return null;
+ }
+
+ /** {@inheritDoc} */
+ @Override public PlatformTarget services(PlatformTarget grp) {
+ return null;
+ }
+
+ /** {@inheritDoc} */
@Override public PlatformTarget extensions() {
return null;
}
http://git-wip-us.apache.org/repos/asf/ignite/blob/13358c3e/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformProcessor.java
index 0cf2df4..a22c787 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformProcessor.java
@@ -19,13 +19,15 @@ package org.apache.ignite.internal.processors.platform;
import org.apache.ignite.*;
import org.apache.ignite.internal.processors.*;
+import org.jetbrains.annotations.*;
/**
* Platform processor.
*/
+@SuppressWarnings("UnusedDeclaration")
public interface PlatformProcessor extends GridProcessor {
/**
- * Get owning Ignite instance.
+ * Gets owning Ignite instance.
*
* @return Ignite instance.
*/
@@ -46,16 +48,114 @@ public interface PlatformProcessor extends GridProcessor {
public PlatformContext context();
/**
- * Await until platform processor is safe to use.
+ * Notify processor that it is safe to use.
+ */
+ public void releaseStart();
+
+ /**
+ * Await until platform processor is safe to use (i.e. {@link #releaseStart() has been called}.
*
* @throws IgniteCheckedException If failed.
*/
public void awaitStart() throws IgniteCheckedException;
/**
+ * Get cache.
+ *
+ * @param name Cache name.
+ * @return Cache.
+ * @throws IgniteCheckedException If failed.
+ */
+ public PlatformTarget cache(@Nullable String name) throws IgniteCheckedException;
+
+ /**
+ * Create cache.
+ *
+ * @param name Cache name.
+ * @return Cache.
+ * @throws IgniteCheckedException If failed.
+ */
+ public PlatformTarget createCache(@Nullable String name) throws IgniteCheckedException;
+
+ /**
+ * Get or create cache.
+ *
+ * @param name Cache name.
+ * @return Cache.
+ * @throws IgniteCheckedException If failed.
+ */
+ public PlatformTarget getOrCreateCache(@Nullable String name) throws IgniteCheckedException;
+
+ /**
+ * Get affinity.
+ *
+ * @param name Cache name.
+ * @return Affinity.
+ * @throws IgniteCheckedException If failed.
+ */
+ public PlatformTarget affinity(@Nullable String name) throws IgniteCheckedException;
+
+ /**
+ * Get data streamer.
+ *
+ * @param cacheName Cache name.
+ * @param keepPortable Portable flag.
+ * @return Data streamer.
+ * @throws IgniteCheckedException If failed.
+ */
+ public PlatformTarget dataStreamer(@Nullable String cacheName, boolean keepPortable) throws IgniteCheckedException;
+
+ /**
+ * Get transactions.
+ *
+ * @return Transactions.
+ */
+ public PlatformTarget transactions();
+
+ /**
+ * Get projection.
+ *
+ * @return Projection.
+ * @throws IgniteCheckedException If failed.
+ */
+ public PlatformTarget projection() throws IgniteCheckedException;
+
+ /**
+ * Create interop compute.
+ *
+ * @param grp Cluster group.
+ * @return Compute instance.
+ */
+ public PlatformTarget compute(PlatformTarget grp);
+
+ /**
+ * Create interop messaging.
+ *
+ * @param grp Cluster group.
+ * @return Messaging instance.
+ */
+ public PlatformTarget message(PlatformTarget grp);
+
+ /**
+ * Create interop events.
+ *
+ * @param grp Cluster group.
+ * @return Events instance.
+ */
+ public PlatformTarget events(PlatformTarget grp);
+
+ /**
+ * Create interop services.
+ *
+ * @param grp Cluster group.
+ * @return Services instance.
+ */
+ public PlatformTarget services(PlatformTarget grp);
+
+ /**
* Get platform extensions. Override this method to provide any additional targets and operations you need.
*
* @return Platform extensions.
*/
- PlatformTarget extensions();
+ public PlatformTarget extensions();
}