# sprint-1 Renamed package mbean - mxbean.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/16edda18 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/16edda18 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/16edda18 Branch: refs/heads/ignite-99-2 Commit: 16edda187bae866556094a1570d2bc6885bef8bd Parents: 76390df Author: sboikov <sboi...@gridgain.com> Authored: Mon Jan 26 10:20:38 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Mon Jan 26 10:20:38 2015 +0300 ---------------------------------------------------------------------- .../spi/checkpoint/s3/S3CheckpointSpiMBean.java | 2 +- .../org/apache/ignite/cache/CacheMBean.java | 2 +- .../org/apache/ignite/cache/CacheManager.java | 2 +- .../fifo/CacheFifoEvictionPolicyMBean.java | 2 +- ...CacheGgfsPerBlockLruEvictionPolicyMBean.java | 2 +- .../lru/CacheLruEvictionPolicyMBean.java | 2 +- .../random/CacheRandomEvictionPolicyMBean.java | 2 +- .../client/router/GridTcpRouterMBean.java | 2 +- .../ignite/cluster/ClusterNodeMetrics.java | 2 +- .../internal/ClusterNodeMetricsMBean.java | 2 +- .../org/apache/ignite/internal/GridGainEx.java | 2 +- .../org/apache/ignite/internal/GridKernal.java | 2 +- .../internal/IgniteThreadPoolMBeanAdapter.java | 4 +- .../ignite/internal/IgnitionMBeanAdapter.java | 2 +- .../apache/ignite/internal/util/GridUtils.java | 2 +- .../apache/ignite/mbean/IgniteCacheMXBean.java | 72 ---- .../org/apache/ignite/mbean/IgniteMBean.java | 386 ------------------- .../ignite/mbean/IgniteMBeanDescription.java | 34 -- .../IgniteMBeanParametersDescriptions.java | 34 -- .../mbean/IgniteMBeanParametersNames.java | 34 -- .../ignite/mbean/IgniteStandardMBean.java | 275 ------------- .../ignite/mbean/IgniteThreadPoolMBean.java | 152 -------- .../org/apache/ignite/mbean/IgnitionMBean.java | 151 -------- .../java/org/apache/ignite/mbean/package.html | 23 -- .../apache/ignite/mxbean/IgniteCacheMXBean.java | 72 ++++ .../org/apache/ignite/mxbean/IgniteMBean.java | 386 +++++++++++++++++++ .../ignite/mxbean/IgniteMBeanDescription.java | 34 ++ .../IgniteMBeanParametersDescriptions.java | 34 ++ .../mxbean/IgniteMBeanParametersNames.java | 34 ++ .../ignite/mxbean/IgniteStandardMBean.java | 275 +++++++++++++ .../ignite/mxbean/IgniteThreadPoolMBean.java | 152 ++++++++ .../org/apache/ignite/mxbean/IgnitionMBean.java | 151 ++++++++ .../java/org/apache/ignite/mxbean/package.html | 23 ++ .../ignite/spi/IgniteSpiManagementMBean.java | 2 +- .../noop/NoopAuthenticationSpiMBean.java | 2 +- .../cache/CacheCheckpointSpiMBean.java | 2 +- .../checkpoint/jdbc/JdbcCheckpointSpiMBean.java | 2 +- .../sharedfs/SharedFsCheckpointSpiMBean.java | 2 +- .../fifoqueue/FifoQueueCollisionSpiMBean.java | 2 +- .../JobStealingCollisionSpiMBean.java | 2 +- .../PriorityQueueCollisionSpiMBean.java | 2 +- .../tcp/TcpCommunicationSpiMBean.java | 2 +- .../local/LocalDeploymentSpiMBean.java | 2 +- .../tcp/TcpClientDiscoverySpiMBean.java | 2 +- .../spi/discovery/tcp/TcpDiscoverySpiMBean.java | 2 +- .../memory/MemoryEventStorageSpiMBean.java | 2 +- .../failover/always/AlwaysFailoverSpiMBean.java | 2 +- .../JobStealingFailoverSpiMBean.java | 2 +- .../failover/never/NeverFailoverSpiMBean.java | 2 +- .../adaptive/AdaptiveLoadBalancingSpiMBean.java | 2 +- .../RoundRobinLoadBalancingSpiMBean.java | 2 +- .../WeightedRandomLoadBalancingSpiMBean.java | 2 +- .../noop/NoopSecureSessionSpiMBean.java | 2 +- .../swapspace/file/FileSwapSpaceSpiMBean.java | 2 +- .../apache/ignite/streamer/StreamerMBean.java | 2 +- .../ignite/streamer/StreamerStageMBean.java | 2 +- .../ignite/streamer/StreamerWindowMBean.java | 2 +- .../index/StreamerIndexProviderMBean.java | 2 +- .../GridCheckpointManagerAbstractSelfTest.java | 2 +- .../ignite/util/mbeans/GridMBeanSelfTest.java | 2 +- .../uri/GridUriDeploymentSpiMBean.java | 2 +- 61 files changed, 1205 insertions(+), 1205 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/aws/src/main/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiMBean.java ---------------------------------------------------------------------- diff --git a/modules/aws/src/main/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiMBean.java b/modules/aws/src/main/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiMBean.java index b773e51..f482ade 100644 --- a/modules/aws/src/main/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiMBean.java +++ b/modules/aws/src/main/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiMBean.java @@ -17,7 +17,7 @@ package org.apache.ignite.spi.checkpoint.s3; -import org.apache.ignite.mbean.*; +import org.apache.ignite.mxbean.*; import org.apache.ignite.spi.*; /** http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/cache/CacheMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheMBean.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheMBean.java index 36a010f..eb19166 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheMBean.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheMBean.java @@ -17,7 +17,7 @@ package org.apache.ignite.cache; -import org.apache.ignite.mbean.*; +import org.apache.ignite.mxbean.*; /** * This interface defines JMX view on {@link GridCache}. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/cache/CacheManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/CacheManager.java b/modules/core/src/main/java/org/apache/ignite/cache/CacheManager.java index 4880a09..4f52b18 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/CacheManager.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/CacheManager.java @@ -21,7 +21,7 @@ import org.apache.ignite.*; import org.apache.ignite.configuration.*; import org.apache.ignite.lang.*; import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.mbean.*; +import org.apache.ignite.mxbean.*; import javax.cache.*; import javax.cache.configuration.*; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/CacheFifoEvictionPolicyMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/CacheFifoEvictionPolicyMBean.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/CacheFifoEvictionPolicyMBean.java index 6289306..6b4d185 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/CacheFifoEvictionPolicyMBean.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/CacheFifoEvictionPolicyMBean.java @@ -17,7 +17,7 @@ package org.apache.ignite.cache.eviction.fifo; -import org.apache.ignite.mbean.*; +import org.apache.ignite.mxbean.*; /** * MBean for {@code FIFO} eviction policy. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/cache/eviction/ggfs/CacheGgfsPerBlockLruEvictionPolicyMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/ggfs/CacheGgfsPerBlockLruEvictionPolicyMBean.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/ggfs/CacheGgfsPerBlockLruEvictionPolicyMBean.java index d0026dc..eca8007 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/ggfs/CacheGgfsPerBlockLruEvictionPolicyMBean.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/ggfs/CacheGgfsPerBlockLruEvictionPolicyMBean.java @@ -17,7 +17,7 @@ package org.apache.ignite.cache.eviction.ggfs; -import org.apache.ignite.mbean.*; +import org.apache.ignite.mxbean.*; import org.jetbrains.annotations.*; import java.util.*; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/CacheLruEvictionPolicyMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/CacheLruEvictionPolicyMBean.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/CacheLruEvictionPolicyMBean.java index 8fbefae..5e4d3bf 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/CacheLruEvictionPolicyMBean.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/CacheLruEvictionPolicyMBean.java @@ -17,7 +17,7 @@ package org.apache.ignite.cache.eviction.lru; -import org.apache.ignite.mbean.*; +import org.apache.ignite.mxbean.*; /** * MBean for {@code LRU} eviction policy. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/CacheRandomEvictionPolicyMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/CacheRandomEvictionPolicyMBean.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/CacheRandomEvictionPolicyMBean.java index aaf4e4d..2cb4b6a 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/CacheRandomEvictionPolicyMBean.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/CacheRandomEvictionPolicyMBean.java @@ -17,7 +17,7 @@ package org.apache.ignite.cache.eviction.random; -import org.apache.ignite.mbean.*; +import org.apache.ignite.mxbean.*; /** * MBean for {@code random} eviction policy. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/client/router/GridTcpRouterMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/client/router/GridTcpRouterMBean.java b/modules/core/src/main/java/org/apache/ignite/client/router/GridTcpRouterMBean.java index 769fa9c..fbd898a 100644 --- a/modules/core/src/main/java/org/apache/ignite/client/router/GridTcpRouterMBean.java +++ b/modules/core/src/main/java/org/apache/ignite/client/router/GridTcpRouterMBean.java @@ -17,7 +17,7 @@ package org.apache.ignite.client.router; -import org.apache.ignite.mbean.*; +import org.apache.ignite.mxbean.*; import java.util.*; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/cluster/ClusterNodeMetrics.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cluster/ClusterNodeMetrics.java b/modules/core/src/main/java/org/apache/ignite/cluster/ClusterNodeMetrics.java index c818b3d..bc8a969 100644 --- a/modules/core/src/main/java/org/apache/ignite/cluster/ClusterNodeMetrics.java +++ b/modules/core/src/main/java/org/apache/ignite/cluster/ClusterNodeMetrics.java @@ -17,7 +17,7 @@ package org.apache.ignite.cluster; -import org.apache.ignite.mbean.*; +import org.apache.ignite.mxbean.*; import java.io.*; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/internal/ClusterNodeMetricsMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/ClusterNodeMetricsMBean.java b/modules/core/src/main/java/org/apache/ignite/internal/ClusterNodeMetricsMBean.java index d2e6d3e..59a00bc 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/ClusterNodeMetricsMBean.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/ClusterNodeMetricsMBean.java @@ -18,7 +18,7 @@ package org.apache.ignite.internal; import org.apache.ignite.cluster.*; -import org.apache.ignite.mbean.*; +import org.apache.ignite.mxbean.*; /** * MBean for local node metrics. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/internal/GridGainEx.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridGainEx.java b/modules/core/src/main/java/org/apache/ignite/internal/GridGainEx.java index 131c4f2..d1d5a86 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridGainEx.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridGainEx.java @@ -30,7 +30,7 @@ import org.apache.ignite.logger.java.*; import org.apache.ignite.marshaller.*; import org.apache.ignite.marshaller.jdk.*; import org.apache.ignite.marshaller.optimized.*; -import org.apache.ignite.mbean.*; +import org.apache.ignite.mxbean.*; import org.apache.ignite.spi.*; import org.apache.ignite.spi.authentication.*; import org.apache.ignite.spi.authentication.noop.*; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/internal/GridKernal.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridKernal.java b/modules/core/src/main/java/org/apache/ignite/internal/GridKernal.java index 681009d..608aa47 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridKernal.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridKernal.java @@ -29,7 +29,7 @@ import org.apache.ignite.lang.*; import org.apache.ignite.lifecycle.*; import org.apache.ignite.marshaller.*; import org.apache.ignite.marshaller.optimized.*; -import org.apache.ignite.mbean.*; +import org.apache.ignite.mxbean.*; import org.apache.ignite.plugin.*; import org.apache.ignite.product.*; import org.apache.ignite.spi.*; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/internal/IgniteThreadPoolMBeanAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteThreadPoolMBeanAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteThreadPoolMBeanAdapter.java index e42fab1..45a6ffd 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteThreadPoolMBeanAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteThreadPoolMBeanAdapter.java @@ -17,12 +17,12 @@ package org.apache.ignite.internal; -import org.apache.ignite.mbean.*; +import org.apache.ignite.mxbean.*; import java.util.concurrent.*; /** - * Adapter for {@link org.apache.ignite.mbean.IgniteThreadPoolMBean} which delegates all method calls to the underlying + * Adapter for {@link org.apache.ignite.mxbean.IgniteThreadPoolMBean} which delegates all method calls to the underlying * {@link ExecutorService} instance. */ public class IgniteThreadPoolMBeanAdapter implements IgniteThreadPoolMBean { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/internal/IgnitionMBeanAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgnitionMBeanAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/IgnitionMBeanAdapter.java index aa21f9e..dda2ebd 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgnitionMBeanAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgnitionMBeanAdapter.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal; -import org.apache.ignite.mbean.*; +import org.apache.ignite.mxbean.*; import org.apache.ignite.internal.util.typedef.*; /** http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/internal/util/GridUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridUtils.java index 851f62d..6ec7f32 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridUtils.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridUtils.java @@ -27,7 +27,7 @@ import org.apache.ignite.internal.*; import org.apache.ignite.internal.processors.cache.*; import org.apache.ignite.lang.*; import org.apache.ignite.lifecycle.*; -import org.apache.ignite.mbean.*; +import org.apache.ignite.mxbean.*; import org.apache.ignite.portables.*; import org.apache.ignite.product.*; import org.apache.ignite.spi.*; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/mbean/IgniteCacheMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mbean/IgniteCacheMXBean.java b/modules/core/src/main/java/org/apache/ignite/mbean/IgniteCacheMXBean.java deleted file mode 100644 index 0e87956..0000000 --- a/modules/core/src/main/java/org/apache/ignite/mbean/IgniteCacheMXBean.java +++ /dev/null @@ -1,72 +0,0 @@ -/* - * 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.mbean; - -import javax.cache.*; -import javax.cache.configuration.*; -import javax.cache.management.*; - -/** - * - */ -public class IgniteCacheMXBean implements CacheMXBean { - /** */ - private final Cache<?, ?> cache; - - /** - * @param cache Cache. - */ - public IgniteCacheMXBean(Cache<?, ?> cache) { - this.cache = cache; - } - - /** {@inheritDoc} */ - @Override public String getKeyType() { - return cache.getConfiguration(CompleteConfiguration.class).getKeyType().getName(); - } - - /** {@inheritDoc} */ - @Override public String getValueType() { - return cache.getConfiguration(CompleteConfiguration.class).getValueType().getName(); - } - - /** {@inheritDoc} */ - @Override public boolean isReadThrough() { - return cache.getConfiguration(CompleteConfiguration.class).isReadThrough(); - } - - /** {@inheritDoc} */ - @Override public boolean isWriteThrough() { - return cache.getConfiguration(CompleteConfiguration.class).isWriteThrough(); - } - - /** {@inheritDoc} */ - @Override public boolean isStoreByValue() { - return cache.getConfiguration(CompleteConfiguration.class).isStoreByValue(); - } - - /** {@inheritDoc} */ - @Override public boolean isStatisticsEnabled() { - return cache.getConfiguration(CompleteConfiguration.class).isStatisticsEnabled(); - } - - /** {@inheritDoc} */ - @Override public boolean isManagementEnabled() { - return cache.getConfiguration(CompleteConfiguration.class).isManagementEnabled(); - } -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/mbean/IgniteMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mbean/IgniteMBean.java b/modules/core/src/main/java/org/apache/ignite/mbean/IgniteMBean.java deleted file mode 100644 index 9f19b80..0000000 --- a/modules/core/src/main/java/org/apache/ignite/mbean/IgniteMBean.java +++ /dev/null @@ -1,386 +0,0 @@ -/* - * 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.mbean; - -import javax.management.*; -import java.util.*; - -/** - * This interface defines JMX view on kernal. - */ -@IgniteMBeanDescription("MBean that provides access to Kernal information.") -public interface IgniteMBean { - /** - * Gets file path of the license. - * - * @return File path of the license. - */ - @IgniteMBeanDescription("File path of the license.") - public String getLicenseFilePath(); - - /** - * Gets string presentation of the version. - * - * @return String presentation of the version. - */ - @IgniteMBeanDescription("String presentation of the Ignite version.") - public String getFullVersion(); - - /** - * Gets copyright statement for GridGain product. - * - * @return Copyright statement for GridGain product. - */ - @IgniteMBeanDescription("Copyright statement for GridGain product.") - public String getCopyright(); - - /** - * Gets string presentation of the kernal start timestamp. - * - * @return String presentation of the kernal start timestamp. - */ - @IgniteMBeanDescription("String presentation of the kernal start timestamp.") - public String getStartTimestampFormatted(); - - /** - * Gets string presentation of up-time for the kernal. - * - * @return String presentation of up-time for the kernal. - */ - @IgniteMBeanDescription("String presentation of up-time for the kernal.") - public String getUpTimeFormatted(); - - /** - * Get start timestamp of the kernal. - * - * @return Start timestamp of the kernal. - */ - @IgniteMBeanDescription("Start timestamp of the kernal.") - public long getStartTimestamp(); - - /** - * Gets up-time of the kernal. - * - * @return Up-time of the kernal. - */ - @IgniteMBeanDescription("Up-time of the kernal.") - public long getUpTime(); - - /** - * Gets a collection of formatted user-defined attributes added to this node. - * <p> - * Note that grid will add all System properties and environment properties - * to grid node attributes also. SPIs may also add node attributes that are - * used for SPI implementation. - * - * @return User defined attributes for this node. - */ - @IgniteMBeanDescription("Collection of formatted user-defined attributes added to this node.") - public Collection<String> getUserAttributesFormatted(); - - /** - * Gets a formatted instance of logger that is in grid. - * - * @return Logger that is used in grid. - */ - @IgniteMBeanDescription("Formatted instance of logger that is in grid.") - public String getGridLoggerFormatted(); - - /** - * Gets a formatted instance of fully configured thread pool that is used in grid. - * - * @return Thread pool implementation that is used in grid. - */ - @IgniteMBeanDescription("Formatted instance of fully configured thread pool that is used in grid.") - public String getExecutorServiceFormatted(); - - /** - * Gets GridGain installation home folder. - * - * @return GridGain installation home. - */ - @IgniteMBeanDescription("GridGain installation home folder.") - public String getGridGainHome(); - - /** - * Gets a formatted instance of MBean server instance. - * - * @return MBean server instance. - */ - @IgniteMBeanDescription("Formatted instance of MBean server instance.") - public String getMBeanServerFormatted(); - - /** - * Unique identifier for this node within grid. - * - * @return Unique identifier for this node within grid. - */ - @IgniteMBeanDescription("Unique identifier for this node within grid.") - public UUID getLocalNodeId(); - - /** - * Returns {@code true} if peer class loading is enabled, {@code false} - * otherwise. Default value is {@code true}. - * <p> - * When peer class loading is enabled and task is not deployed on local node, - * local node will try to load classes from the node that initiated task - * execution. This way, a task can be physically deployed only on one node - * and then internally penetrate to all other nodes. - * - * @return {@code true} if peer class loading is enabled, {@code false} - * otherwise. - */ - @IgniteMBeanDescription("Whether or not peer class loading (a.k.a. P2P class loading) is enabled.") - public boolean isPeerClassLoadingEnabled(); - - /** - * Gets {@code toString()} representation of of lifecycle beans configured - * with GridGain. - * - * @return {@code toString()} representation of all lifecycle beans configured - * with GridGain. - */ - @IgniteMBeanDescription("String representation of lifecycle beans.") - public Collection<String> getLifecycleBeansFormatted(); - - /** - * This method allows manually remove the checkpoint with given {@code key}. - * - * @param key Checkpoint key. - * @return {@code true} if specified checkpoint was indeed removed, {@code false} - * otherwise. - */ - @IgniteMBeanDescription("This method allows manually remove the checkpoint with given key. Return true " + - "if specified checkpoint was indeed removed, false otherwise.") - @IgniteMBeanParametersNames( - "key" - ) - @IgniteMBeanParametersDescriptions( - "Checkpoint key to remove." - ) - public boolean removeCheckpoint(String key); - - /** - * Pings node with given node ID to see whether it is alive. - * - * @param nodeId String presentation of node ID. See {@link UUID#fromString(String)} for - * details on string formatting. - * @return Whether or not node is alive. - */ - @IgniteMBeanDescription("Pings node with given node ID to see whether it is alive. " + - "Returns whether or not node is alive.") - @IgniteMBeanParametersNames( - "nodeId" - ) - @IgniteMBeanParametersDescriptions( - "String presentation of node ID. See java.util.UUID class for details." - ) - public boolean pingNode(String nodeId); - - /** - * Makes the best attempt to undeploy a task from the whole grid. Note that this - * method returns immediately and does not wait until the task will actually be - * undeployed on every node. - * <p> - * Note that GridGain maintains internal versions for grid tasks in case of redeployment. - * This method will attempt to undeploy all versions on the grid task with - * given name. - * - * @param taskName Name of the task to undeploy. If task class has {@link org.apache.ignite.compute.ComputeTaskName} annotation, - * then task was deployed under a name specified within annotation. Otherwise, full - * class name should be used as task's name. - * @throws JMException Thrown if undeploy failed. - */ - @IgniteMBeanDescription("Makes the best attempt to undeploy a task from the whole grid.") - @IgniteMBeanParametersNames( - "taskName" - ) - @IgniteMBeanParametersDescriptions( - "Name of the task to undeploy." - ) - public void undeployTaskFromGrid(String taskName) throws JMException; - - /** - * A shortcut method that executes given task assuming single {@code java.lang.String} argument - * and {@code java.lang.String} return type. - * - * @param taskName Name of the task to execute. - * @param arg Single task execution argument (can be {@code null}). - * @return Task return value (assumed of {@code java.lang.String} type). - * @throws JMException Thrown in case when execution failed. - */ - @IgniteMBeanDescription("A shortcut method that executes given task assuming single " + - "String argument and String return type. Returns Task return value (assumed of String type).") - @IgniteMBeanParametersNames( - { - "taskName", - "arg" - } - ) - @IgniteMBeanParametersDescriptions( - { - "Name of the task to execute.", - "Single task execution argument (can be null)." - } - ) - public String executeTask(String taskName, String arg) throws JMException; - - /** - * Pings node with given host name to see if it is alive. - * - * @param host Host name or IP address of the node to ping. - * @return Whether or not node is alive. - */ - @IgniteMBeanDescription("Pings node with given host name to see if it is alive. " + - "Returns whether or not node is alive.") - @IgniteMBeanParametersNames( - "host" - ) - @IgniteMBeanParametersDescriptions( - "Host name or IP address of the node to ping." - ) - public boolean pingNodeByAddress(String host); - - /** - * Gets a formatted instance of configured discovery SPI implementation. - * - * @return Grid discovery SPI implementation. - */ - @IgniteMBeanDescription("Formatted instance of configured discovery SPI implementation.") - public String getDiscoverySpiFormatted(); - - /** - * Gets a formatted instance of fully configured SPI communication implementation. - * - * @return Grid communication SPI implementation. - */ - @IgniteMBeanDescription("Formatted instance of fully configured SPI communication implementation.") - public String getCommunicationSpiFormatted(); - - /** - * Gets a formatted instance of fully configured deployment SPI implementation. - * - * @return Grid deployment SPI implementation. - */ - @IgniteMBeanDescription("Formatted instance of fully configured deployment SPI implementation.") - public String getDeploymentSpiFormatted(); - - /** - * Gets a formatted instance of configured checkpoint SPI implementation. - * - * @return Grid checkpoint SPI implementation. - */ - @IgniteMBeanDescription("Formatted instance of configured checkpoint SPI implementation.") - public String getCheckpointSpiFormatted(); - - /** - * Gets a formatted instance of configured collision SPI implementations. - * - * @return Grid collision SPI implementations. - */ - @IgniteMBeanDescription("Formatted instance of configured collision SPI implementations.") - public String getCollisionSpiFormatted(); - - /** - * Gets a formatted instance of configured swapspace SPI implementations. - * - * @return Grid swapspace SPI implementations. - */ - @IgniteMBeanDescription("Formatted instance of configured swapspace SPI implementations.") - public String getSwapSpaceSpiFormatted(); - - /** - * Gets a formatted instance of fully configured event SPI implementation. - * - * @return Grid event SPI implementation. - */ - @IgniteMBeanDescription("Formatted instance of fully configured event SPI implementation.") - public String getEventStorageSpiFormatted(); - - /** - * Gets a formatted instance of fully configured failover SPI implementations. - * - * @return Grid failover SPI implementations. - */ - @IgniteMBeanDescription("Formatted instance of fully configured failover SPI implementations.") - public String getFailoverSpiFormatted(); - - /** - * Gets a formatted instance of fully configured load balancing SPI implementations. - * - * @return Grid load balancing SPI implementations. - */ - @IgniteMBeanDescription("Formatted instance of fully configured load balancing SPI implementations.") - public String getLoadBalancingSpiFormatted(); - - /** - * Gets a formatted instance of fully configured authentication SPI implementation. - * - * @return Grid authentication SPI implementation. - */ - @IgniteMBeanDescription("Formatted instance of fully configured authentication SPI implementation.") - public String getAuthenticationSpiFormatted(); - - /** - * Gets a formatted instance of fully configured secure session SPI implementation. - * - * @return Grid secure session SPI implementation. - */ - @IgniteMBeanDescription("Formatted instance of fully configured secure session SPI implementation.") - public String getSecureSessionSpiFormatted(); - - /** - * Gets OS information. - * - * @return OS information. - */ - @IgniteMBeanDescription("OS information.") - public String getOsInformation(); - - /** - * Gets JDK information. - * - * @return JDK information. - */ - @IgniteMBeanDescription("JDK information.") - public String getJdkInformation(); - - /** - * Gets OS user. - * - * @return OS user name. - */ - @IgniteMBeanDescription("OS user name.") - public String getOsUser(); - - /** - * Gets VM name. - * - * @return VM name. - */ - @IgniteMBeanDescription("VM name.") - public String getVmName(); - - /** - * Gets optional kernal instance name. It can be {@code null}. - * - * @return Optional kernal instance name. - */ - @IgniteMBeanDescription("Optional kernal instance name.") - public String getInstanceName(); -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/mbean/IgniteMBeanDescription.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mbean/IgniteMBeanDescription.java b/modules/core/src/main/java/org/apache/ignite/mbean/IgniteMBeanDescription.java deleted file mode 100644 index 6250593..0000000 --- a/modules/core/src/main/java/org/apache/ignite/mbean/IgniteMBeanDescription.java +++ /dev/null @@ -1,34 +0,0 @@ -/* - * 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.mbean; - -import java.lang.annotation.*; - -/** - * Provides description for MBean classes and methods. - */ -@Documented -@Retention(RetentionPolicy.RUNTIME) -@Target({ElementType.TYPE, ElementType.METHOD}) -public @interface IgniteMBeanDescription { - /** - * - * Description for Mbean. - */ - @SuppressWarnings({"JavaDoc"}) public String value(); -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/mbean/IgniteMBeanParametersDescriptions.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mbean/IgniteMBeanParametersDescriptions.java b/modules/core/src/main/java/org/apache/ignite/mbean/IgniteMBeanParametersDescriptions.java deleted file mode 100644 index 5572347..0000000 --- a/modules/core/src/main/java/org/apache/ignite/mbean/IgniteMBeanParametersDescriptions.java +++ /dev/null @@ -1,34 +0,0 @@ -/* - * 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.mbean; - -import java.lang.annotation.*; - -/** - * Provides MBean method parameters description. - */ -@Documented -@Retention(RetentionPolicy.RUNTIME) -@Target({ElementType.METHOD}) -public @interface IgniteMBeanParametersDescriptions { - /** - * - * Array of descriptions for parameters. - */ - @SuppressWarnings({"JavaDoc"}) public String[] value(); -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/mbean/IgniteMBeanParametersNames.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mbean/IgniteMBeanParametersNames.java b/modules/core/src/main/java/org/apache/ignite/mbean/IgniteMBeanParametersNames.java deleted file mode 100644 index fe012fc..0000000 --- a/modules/core/src/main/java/org/apache/ignite/mbean/IgniteMBeanParametersNames.java +++ /dev/null @@ -1,34 +0,0 @@ -/* - * 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.mbean; - -import java.lang.annotation.*; - -/** - * Provides MBean method parameters names. - */ -@Documented -@Retention(RetentionPolicy.RUNTIME) -@Target({ElementType.METHOD}) -public @interface IgniteMBeanParametersNames { - /** - * - * Array of parameter names in MBean. - */ - @SuppressWarnings({"JavaDoc"}) public String[] value(); -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/mbean/IgniteStandardMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mbean/IgniteStandardMBean.java b/modules/core/src/main/java/org/apache/ignite/mbean/IgniteStandardMBean.java deleted file mode 100644 index f01f7cb..0000000 --- a/modules/core/src/main/java/org/apache/ignite/mbean/IgniteStandardMBean.java +++ /dev/null @@ -1,275 +0,0 @@ -/* - * 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.mbean; - -import org.apache.ignite.internal.util.typedef.internal.*; -import javax.management.*; -import java.lang.reflect.*; -import java.util.*; - -/** - * Extension of standard Java MBean. Overrides some hooks to return - * annotation based descriptions. - */ -public class IgniteStandardMBean extends StandardMBean { - /** - * Objects maps from primitive classes to primitive object classes. - */ - private static final Map<String, Class<?>> primCls = new HashMap<>(); - - /** - * Static constructor. - */ - static{ - primCls.put(Boolean.TYPE.toString().toLowerCase(), Boolean.TYPE); - primCls.put(Character.TYPE.toString().toLowerCase(), Character.TYPE); - primCls.put(Byte.TYPE.toString().toLowerCase(), Byte.TYPE); - primCls.put(Short.TYPE.toString().toLowerCase(), Short.TYPE); - primCls.put(Integer.TYPE.toString().toLowerCase(), Integer.TYPE); - primCls.put(Long.TYPE.toString().toLowerCase(), Long.TYPE); - primCls.put(Float.TYPE.toString().toLowerCase(), Float.TYPE); - primCls.put(Double.TYPE.toString().toLowerCase(), Double.TYPE); - } - - /** - * Make a DynamicMBean out of the object implementation, using the specified - * mbeanInterface class. - * - * @param implementation The implementation of this MBean. - * @param mbeanInterface The Management Interface exported by this - * MBean's implementation. If {@code null}, then this - * object will use standard JMX design pattern to determine - * the management interface associated with the given - * implementation. - * If {@code null} value passed then information will be built by - * {@link StandardMBean} - * - * @exception NotCompliantMBeanException if the {@code mbeanInterface} - * does not follow JMX design patterns for Management Interfaces, or - * if the given {@code implementation} does not implement the - * specified interface. - */ - public <T> IgniteStandardMBean(T implementation, Class<T> mbeanInterface) - throws NotCompliantMBeanException { - super(implementation, mbeanInterface); - } - - /** {@inheritDoc} */ - @Override protected String getDescription(MBeanAttributeInfo info) { - String str = super.getDescription(info); - - String methodName = (info.isIs() ? "is" : "get") + info.getName(); - - try { - // Recursively get method. - Method mtd = findMethod(getMBeanInterface(), methodName, new Class[]{}); - - if (mtd != null) { - IgniteMBeanDescription desc = mtd.getAnnotation(IgniteMBeanDescription.class); - - if (desc != null) { - str = desc.value(); - - assert str != null : "Failed to find method: " + mtd; - assert str.trim().length() > 0 : "Method description cannot be empty: " + mtd; - - // Enforce proper English. - assert Character.isUpperCase(str.charAt(0)) == true : - "Description must start with upper case: " + str; - - assert str.charAt(str.length() - 1) == '.' : "Description must end with period: " + str; - } - } - } - catch (SecurityException e) { - // No-op. Default value will be returned. - } - - return str; - } - - /** {@inheritDoc} */ - @Override protected String getDescription(MBeanInfo info) { - String str = super.getDescription(info); - - // Return either default one or given by annotation. - IgniteMBeanDescription desc = U.getAnnotation(getMBeanInterface(), IgniteMBeanDescription.class); - - if (desc != null) { - str = desc.value(); - - assert str != null; - assert str.trim().length() > 0; - - // Enforce proper English. - assert Character.isUpperCase(str.charAt(0)) == true : str; - assert str.charAt(str.length() - 1) == '.' : str; - } - - return str; - } - - /** {@inheritDoc} */ - @Override protected String getDescription(MBeanOperationInfo info) { - String str = super.getDescription(info); - - try { - Method m = getMethod(info); - - IgniteMBeanDescription desc = m.getAnnotation(IgniteMBeanDescription.class); - - if (desc != null) { - str = desc.value(); - - assert str != null; - assert str.trim().length() > 0; - - // Enforce proper English. - assert Character.isUpperCase(str.charAt(0)) == true : str; - assert str.charAt(str.length() - 1) == '.' : str; - } - } - catch (SecurityException | ClassNotFoundException e) { - // No-op. Default value will be returned. - } - - return str; - } - - /** {@inheritDoc} */ - @Override protected String getDescription(MBeanOperationInfo op, MBeanParameterInfo param, int seq) { - String str = super.getDescription(op, param, seq); - - try { - Method m = getMethod(op); - - IgniteMBeanParametersDescriptions decsAnn = m.getAnnotation(IgniteMBeanParametersDescriptions.class); - - if (decsAnn != null) { - assert decsAnn.value() != null; - assert seq < decsAnn.value().length; - - str = decsAnn.value()[seq]; - - assert str != null; - assert str.trim().length() > 0; - - // Enforce proper English. - assert Character.isUpperCase(str.charAt(0)) == true : str; - assert str.charAt(str.length() - 1) == '.' : str; - } - } - catch (SecurityException | ClassNotFoundException e) { - // No-op. Default value will be returned. - } - - return str; - } - - /** {@inheritDoc} */ - @Override protected String getParameterName(MBeanOperationInfo op, MBeanParameterInfo param, int seq) { - String str = super.getParameterName(op, param, seq); - - try { - Method m = getMethod(op); - - IgniteMBeanParametersNames namesAnn = m.getAnnotation(IgniteMBeanParametersNames.class); - - if (namesAnn != null) { - assert namesAnn.value() != null; - assert seq < namesAnn.value().length; - - str = namesAnn.value()[seq]; - - assert str != null; - assert str.trim().length() > 0; - } - } - catch (SecurityException | ClassNotFoundException e) { - // No-op. Default value will be returned. - } - - return str; - } - - /** - * Gets method by operation info. - * - * @param op MBean operation info. - * @return Method. - * @throws ClassNotFoundException Thrown if parameter type is unknown. - * @throws SecurityException Thrown if method access is not allowed. - */ - private Method getMethod(MBeanOperationInfo op) throws ClassNotFoundException, SecurityException { - String methodName = op.getName(); - - MBeanParameterInfo[] signature = op.getSignature(); - - Class<?>[] params = new Class<?>[signature.length]; - - for (int i = 0; i < signature.length; i++) { - // Parameter type is either a primitive type or class. Try both. - Class<?> type = primCls.get(signature[i].getType().toLowerCase()); - - if (type == null) - type = Class.forName(signature[i].getType()); - - params[i] = type; - } - - return findMethod(getMBeanInterface(), methodName, params); - } - - /** - * Finds method for the given interface. - * - * @param itf MBean interface. - * @param methodName Method name. - * @param params Method parameters. - * @return Method. - */ - @SuppressWarnings("unchecked") - private Method findMethod(Class itf, String methodName, Class[] params) { - assert itf.isInterface() == true; - - Method res = null; - - // Try to get method from given interface. - try { - res = itf.getDeclaredMethod(methodName, params); - - if (res != null) - return res; - } - catch (NoSuchMethodException e) { - // No-op. Default value will be returned. - } - - // Process recursively super interfaces. - Class[] superItfs = itf.getInterfaces(); - - for (Class superItf: superItfs) { - res = findMethod(superItf, methodName, params); - - if (res != null) - return res; - } - - return res; - } -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/mbean/IgniteThreadPoolMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mbean/IgniteThreadPoolMBean.java b/modules/core/src/main/java/org/apache/ignite/mbean/IgniteThreadPoolMBean.java deleted file mode 100644 index 6c37d3f..0000000 --- a/modules/core/src/main/java/org/apache/ignite/mbean/IgniteThreadPoolMBean.java +++ /dev/null @@ -1,152 +0,0 @@ -/* - * 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.mbean; - -/** - * MBean that provides access to information about executor service. - */ -@IgniteMBeanDescription("MBean that provides access to information about executor service.") -public interface IgniteThreadPoolMBean { - /** - * Returns the approximate number of threads that are actively executing tasks. - * - * @return The number of threads. - */ - @IgniteMBeanDescription("Approximate number of threads that are actively executing tasks.") - public int getActiveCount(); - - /** - * Returns the approximate total number of tasks that have completed execution. - * Because the states of tasks and threads may change dynamically during - * computation, the returned value is only an approximation, but one that - * does not ever decrease across successive calls. - * - * @return The number of tasks. - */ - @IgniteMBeanDescription("Approximate total number of tasks that have completed execution.") - public long getCompletedTaskCount(); - - /** - * Returns the core number of threads. - * - * @return The core number of threads. - */ - @IgniteMBeanDescription("The core number of threads.") - public int getCorePoolSize(); - - /** - * Returns the largest number of threads that have ever - * simultaneously been in the pool. - * - * @return The number of threads. - */ - @IgniteMBeanDescription("Largest number of threads that have ever simultaneously been in the pool.") - public int getLargestPoolSize(); - - /** - * Returns the maximum allowed number of threads. - * - * @return The maximum allowed number of threads. - */ - @IgniteMBeanDescription("The maximum allowed number of threads.") - public int getMaximumPoolSize(); - - /** - * Returns the current number of threads in the pool. - * - * @return The number of threads. - */ - @IgniteMBeanDescription("Current number of threads in the pool.") - public int getPoolSize(); - - /** - * Returns the approximate total number of tasks that have been scheduled - * for execution. Because the states of tasks and threads may change dynamically - * during computation, the returned value is only an approximation, but - * one that does not ever decrease across successive calls. - * - * @return The number of tasks. - */ - @IgniteMBeanDescription("Approximate total number of tasks that have been scheduled for execution.") - public long getTaskCount(); - - /** - * Gets current size of the execution queue. This queue buffers local - * executions when there are not threads available for processing in the pool. - * - * @return Current size of the execution queue. - */ - @IgniteMBeanDescription("Current size of the execution queue.") - public int getQueueSize(); - - /** - * Returns the thread keep-alive time, which is the amount of time which threads - * in excess of the core pool size may remain idle before being terminated. - * - * @return Keep alive time. - */ - @IgniteMBeanDescription("Thread keep-alive time, which is the amount of time which threads in excess of " + - "the core pool size may remain idle before being terminated.") - public long getKeepAliveTime(); - - /** - * Returns {@code true} if this executor has been shut down. - * - * @return {@code True} if this executor has been shut down. - */ - @IgniteMBeanDescription("True if this executor has been shut down.") - public boolean isShutdown(); - - /** - * Returns {@code true} if all tasks have completed following shut down. Note that - * {@code isTerminated()} is never {@code true} unless either {@code shutdown()} or - * {@code shutdownNow()} was called first. - * - * @return {@code True} if all tasks have completed following shut down. - */ - @IgniteMBeanDescription("True if all tasks have completed following shut down.") - public boolean isTerminated(); - - /** - * Returns {@code true} if this executor is in the process of terminating after - * {@code shutdown()} or {@code shutdownNow()} but has not completely terminated. - * This method may be useful for debugging. A return of {@code true} reported a - * sufficient period after shutdown may indicate that submitted tasks have ignored - * or suppressed interruption, causing this executor not to properly terminate. - * - * @return {@code True} if terminating but not yet terminated. - */ - @IgniteMBeanDescription("True if terminating but not yet terminated.") - public boolean isTerminating(); - - /** - * Returns the class name of current rejection handler. - * - * @return Class name of current rejection handler. - */ - @IgniteMBeanDescription("Class name of current rejection handler.") - public String getRejectedExecutionHandlerClass(); - - /** - * Returns the class name of thread factory used to create new threads. - * - * @return Class name of thread factory used to create new threads. - */ - @IgniteMBeanDescription("Class name of thread factory used to create new threads.") - public String getThreadFactoryClass(); -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/mbean/IgnitionMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mbean/IgnitionMBean.java b/modules/core/src/main/java/org/apache/ignite/mbean/IgnitionMBean.java deleted file mode 100644 index 2cdce0e..0000000 --- a/modules/core/src/main/java/org/apache/ignite/mbean/IgnitionMBean.java +++ /dev/null @@ -1,151 +0,0 @@ -/* - * 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.mbean; - -/** - * This interface defines JMX view on {@link org.apache.ignite.Ignition}. - */ -@IgniteMBeanDescription("MBean that provides access to grid life-cycle operations.") -public interface IgnitionMBean { - /** - * Gets state of default grid instance. - * - * @return State of default grid instance. - * @see org.apache.ignite.Ignition#state() - */ - @IgniteMBeanDescription("State of default grid instance.") - public String getState(); - - /** - * Gets state for a given grid instance. - * - * @param name Name of grid instance. - * @return State of grid instance with given name. - * @see org.apache.ignite.Ignition#state(String) - */ - @IgniteMBeanDescription("Gets state for a given grid instance. Returns state of grid instance with given name.") - @IgniteMBeanParametersNames( - "name" - ) - @IgniteMBeanParametersDescriptions( - "Name of grid instance." - ) - public String getState(String name); - - /** - * Stops default grid instance. - * - * @param cancel If {@code true} then all jobs currently executing on - * default grid will be cancelled by calling {@link org.apache.ignite.compute.ComputeJob#cancel()} - * method. Note that just like with {@link Thread#interrupt()}, it is - * up to the actual job to exit from execution. - * @return {@code true} if default grid instance was indeed stopped, - * {@code false} otherwise (if it was not started). - * @see org.apache.ignite.Ignition#stop(boolean) - */ - @IgniteMBeanDescription("Stops default grid instance. Return true if default grid instance was " + - "indeed stopped, false otherwise (if it was not started).") - @IgniteMBeanParametersNames( - "cancel" - ) - @IgniteMBeanParametersDescriptions( - "If true then all jobs currently executing on default grid will be cancelled." - ) - public boolean stop(boolean cancel); - - /** - * Stops named grid. If {@code cancel} flag is set to {@code true} then - * all jobs currently executing on local node will be interrupted. If - * grid name is {@code null}, then default no-name grid will be stopped. - * It does not wait for the tasks to finish their execution. - * - * @param name Grid name. If {@code null}, then default no-name grid will - * be stopped. - * @param cancel If {@code true} then all jobs currently will be cancelled - * by calling {@link org.apache.ignite.compute.ComputeJob#cancel()} method. Note that just like with - * {@link Thread#interrupt()}, it is up to the actual job to exit from - * execution. If {@code false}, then jobs currently running will not be - * canceled. In either case, grid node will wait for completion of all - * jobs running on it before stopping. - * @return {@code true} if named grid instance was indeed found and stopped, - * {@code false} otherwise (the instance with given {@code name} was - * not found). - * @see org.apache.ignite.Ignition#stop(String, boolean) - */ - @IgniteMBeanDescription("Stops grid by name. Cancels running jobs if cancel is true. Returns true if named " + - "grid instance was indeed found and stopped, false otherwise.") - @IgniteMBeanParametersNames( - { - "name", - "cancel" - }) - @IgniteMBeanParametersDescriptions( - { - "Grid instance name to stop.", - "Whether or not running jobs should be cancelled." - } - ) - public boolean stop(String name, boolean cancel); - - /** - * Stops <b>all</b> started grids. If {@code cancel} flag is set to {@code true} then - * all jobs currently executing on local node will be interrupted. - * It does not wait for the tasks to finish their execution. - * <p> - * <b>Note:</b> it is usually safer and more appropriate to stop grid instances individually - * instead of blanket operation. In most cases, the party that started the grid instance - * should be responsible for stopping it. - * - * @param cancel If {@code true} then all jobs currently executing on - * all grids will be cancelled by calling {@link org.apache.ignite.compute.ComputeJob#cancel()} - * method. Note that just like with {@link Thread#interrupt()}, it is - * up to the actual job to exit from execution - * @see org.apache.ignite.Ignition#stopAll(boolean) - */ - @IgniteMBeanDescription("Stops all started grids.") - @IgniteMBeanParametersNames( - "cancel" - ) - @IgniteMBeanParametersDescriptions( - "If true then all jobs currently executing on all grids will be cancelled." - ) - public void stopAll(boolean cancel); - - /** - * Restart JVM. - * - * @param cancel If {@code true} then all jobs currently executing on - * all grids will be cancelled by calling {@link org.apache.ignite.compute.ComputeJob#cancel()} - * method. Note that just like with {@link Thread#interrupt()}, it is - * up to the actual job to exit from execution - * @see org.apache.ignite.Ignition#stopAll(boolean) - */ - @IgniteMBeanDescription("Restart JVM.") - @IgniteMBeanParametersNames( - { - "cancel", - "wait" - }) - @IgniteMBeanParametersDescriptions( - { - "If true then all jobs currently executing on default grid will be cancelled.", - "If true then method will wait for all task being executed until they finish their execution." - } - ) - public void restart(boolean cancel); -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/mbean/package.html ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mbean/package.html b/modules/core/src/main/java/org/apache/ignite/mbean/package.html deleted file mode 100644 index f16e61d..0000000 --- a/modules/core/src/main/java/org/apache/ignite/mbean/package.html +++ /dev/null @@ -1,23 +0,0 @@ -<!-- - 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. - --> -<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd";> -<html> -<body> - <!-- Package description. --> - Contains annotations for Dynamic MBeans. -</body> -</html> http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteCacheMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteCacheMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteCacheMXBean.java new file mode 100644 index 0000000..bcc14e7 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteCacheMXBean.java @@ -0,0 +1,72 @@ +/* + * 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.mxbean; + +import javax.cache.*; +import javax.cache.configuration.*; +import javax.cache.management.*; + +/** + * + */ +public class IgniteCacheMXBean implements CacheMXBean { + /** */ + private final Cache<?, ?> cache; + + /** + * @param cache Cache. + */ + public IgniteCacheMXBean(Cache<?, ?> cache) { + this.cache = cache; + } + + /** {@inheritDoc} */ + @Override public String getKeyType() { + return cache.getConfiguration(CompleteConfiguration.class).getKeyType().getName(); + } + + /** {@inheritDoc} */ + @Override public String getValueType() { + return cache.getConfiguration(CompleteConfiguration.class).getValueType().getName(); + } + + /** {@inheritDoc} */ + @Override public boolean isReadThrough() { + return cache.getConfiguration(CompleteConfiguration.class).isReadThrough(); + } + + /** {@inheritDoc} */ + @Override public boolean isWriteThrough() { + return cache.getConfiguration(CompleteConfiguration.class).isWriteThrough(); + } + + /** {@inheritDoc} */ + @Override public boolean isStoreByValue() { + return cache.getConfiguration(CompleteConfiguration.class).isStoreByValue(); + } + + /** {@inheritDoc} */ + @Override public boolean isStatisticsEnabled() { + return cache.getConfiguration(CompleteConfiguration.class).isStatisticsEnabled(); + } + + /** {@inheritDoc} */ + @Override public boolean isManagementEnabled() { + return cache.getConfiguration(CompleteConfiguration.class).isManagementEnabled(); + } +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteMBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteMBean.java new file mode 100644 index 0000000..3bf3971 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteMBean.java @@ -0,0 +1,386 @@ +/* + * 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.mxbean; + +import javax.management.*; +import java.util.*; + +/** + * This interface defines JMX view on kernal. + */ +@IgniteMBeanDescription("MBean that provides access to Kernal information.") +public interface IgniteMBean { + /** + * Gets file path of the license. + * + * @return File path of the license. + */ + @IgniteMBeanDescription("File path of the license.") + public String getLicenseFilePath(); + + /** + * Gets string presentation of the version. + * + * @return String presentation of the version. + */ + @IgniteMBeanDescription("String presentation of the Ignite version.") + public String getFullVersion(); + + /** + * Gets copyright statement for GridGain product. + * + * @return Copyright statement for GridGain product. + */ + @IgniteMBeanDescription("Copyright statement for GridGain product.") + public String getCopyright(); + + /** + * Gets string presentation of the kernal start timestamp. + * + * @return String presentation of the kernal start timestamp. + */ + @IgniteMBeanDescription("String presentation of the kernal start timestamp.") + public String getStartTimestampFormatted(); + + /** + * Gets string presentation of up-time for the kernal. + * + * @return String presentation of up-time for the kernal. + */ + @IgniteMBeanDescription("String presentation of up-time for the kernal.") + public String getUpTimeFormatted(); + + /** + * Get start timestamp of the kernal. + * + * @return Start timestamp of the kernal. + */ + @IgniteMBeanDescription("Start timestamp of the kernal.") + public long getStartTimestamp(); + + /** + * Gets up-time of the kernal. + * + * @return Up-time of the kernal. + */ + @IgniteMBeanDescription("Up-time of the kernal.") + public long getUpTime(); + + /** + * Gets a collection of formatted user-defined attributes added to this node. + * <p> + * Note that grid will add all System properties and environment properties + * to grid node attributes also. SPIs may also add node attributes that are + * used for SPI implementation. + * + * @return User defined attributes for this node. + */ + @IgniteMBeanDescription("Collection of formatted user-defined attributes added to this node.") + public Collection<String> getUserAttributesFormatted(); + + /** + * Gets a formatted instance of logger that is in grid. + * + * @return Logger that is used in grid. + */ + @IgniteMBeanDescription("Formatted instance of logger that is in grid.") + public String getGridLoggerFormatted(); + + /** + * Gets a formatted instance of fully configured thread pool that is used in grid. + * + * @return Thread pool implementation that is used in grid. + */ + @IgniteMBeanDescription("Formatted instance of fully configured thread pool that is used in grid.") + public String getExecutorServiceFormatted(); + + /** + * Gets GridGain installation home folder. + * + * @return GridGain installation home. + */ + @IgniteMBeanDescription("GridGain installation home folder.") + public String getGridGainHome(); + + /** + * Gets a formatted instance of MBean server instance. + * + * @return MBean server instance. + */ + @IgniteMBeanDescription("Formatted instance of MBean server instance.") + public String getMBeanServerFormatted(); + + /** + * Unique identifier for this node within grid. + * + * @return Unique identifier for this node within grid. + */ + @IgniteMBeanDescription("Unique identifier for this node within grid.") + public UUID getLocalNodeId(); + + /** + * Returns {@code true} if peer class loading is enabled, {@code false} + * otherwise. Default value is {@code true}. + * <p> + * When peer class loading is enabled and task is not deployed on local node, + * local node will try to load classes from the node that initiated task + * execution. This way, a task can be physically deployed only on one node + * and then internally penetrate to all other nodes. + * + * @return {@code true} if peer class loading is enabled, {@code false} + * otherwise. + */ + @IgniteMBeanDescription("Whether or not peer class loading (a.k.a. P2P class loading) is enabled.") + public boolean isPeerClassLoadingEnabled(); + + /** + * Gets {@code toString()} representation of of lifecycle beans configured + * with GridGain. + * + * @return {@code toString()} representation of all lifecycle beans configured + * with GridGain. + */ + @IgniteMBeanDescription("String representation of lifecycle beans.") + public Collection<String> getLifecycleBeansFormatted(); + + /** + * This method allows manually remove the checkpoint with given {@code key}. + * + * @param key Checkpoint key. + * @return {@code true} if specified checkpoint was indeed removed, {@code false} + * otherwise. + */ + @IgniteMBeanDescription("This method allows manually remove the checkpoint with given key. Return true " + + "if specified checkpoint was indeed removed, false otherwise.") + @IgniteMBeanParametersNames( + "key" + ) + @IgniteMBeanParametersDescriptions( + "Checkpoint key to remove." + ) + public boolean removeCheckpoint(String key); + + /** + * Pings node with given node ID to see whether it is alive. + * + * @param nodeId String presentation of node ID. See {@link UUID#fromString(String)} for + * details on string formatting. + * @return Whether or not node is alive. + */ + @IgniteMBeanDescription("Pings node with given node ID to see whether it is alive. " + + "Returns whether or not node is alive.") + @IgniteMBeanParametersNames( + "nodeId" + ) + @IgniteMBeanParametersDescriptions( + "String presentation of node ID. See java.util.UUID class for details." + ) + public boolean pingNode(String nodeId); + + /** + * Makes the best attempt to undeploy a task from the whole grid. Note that this + * method returns immediately and does not wait until the task will actually be + * undeployed on every node. + * <p> + * Note that GridGain maintains internal versions for grid tasks in case of redeployment. + * This method will attempt to undeploy all versions on the grid task with + * given name. + * + * @param taskName Name of the task to undeploy. If task class has {@link org.apache.ignite.compute.ComputeTaskName} annotation, + * then task was deployed under a name specified within annotation. Otherwise, full + * class name should be used as task's name. + * @throws JMException Thrown if undeploy failed. + */ + @IgniteMBeanDescription("Makes the best attempt to undeploy a task from the whole grid.") + @IgniteMBeanParametersNames( + "taskName" + ) + @IgniteMBeanParametersDescriptions( + "Name of the task to undeploy." + ) + public void undeployTaskFromGrid(String taskName) throws JMException; + + /** + * A shortcut method that executes given task assuming single {@code java.lang.String} argument + * and {@code java.lang.String} return type. + * + * @param taskName Name of the task to execute. + * @param arg Single task execution argument (can be {@code null}). + * @return Task return value (assumed of {@code java.lang.String} type). + * @throws JMException Thrown in case when execution failed. + */ + @IgniteMBeanDescription("A shortcut method that executes given task assuming single " + + "String argument and String return type. Returns Task return value (assumed of String type).") + @IgniteMBeanParametersNames( + { + "taskName", + "arg" + } + ) + @IgniteMBeanParametersDescriptions( + { + "Name of the task to execute.", + "Single task execution argument (can be null)." + } + ) + public String executeTask(String taskName, String arg) throws JMException; + + /** + * Pings node with given host name to see if it is alive. + * + * @param host Host name or IP address of the node to ping. + * @return Whether or not node is alive. + */ + @IgniteMBeanDescription("Pings node with given host name to see if it is alive. " + + "Returns whether or not node is alive.") + @IgniteMBeanParametersNames( + "host" + ) + @IgniteMBeanParametersDescriptions( + "Host name or IP address of the node to ping." + ) + public boolean pingNodeByAddress(String host); + + /** + * Gets a formatted instance of configured discovery SPI implementation. + * + * @return Grid discovery SPI implementation. + */ + @IgniteMBeanDescription("Formatted instance of configured discovery SPI implementation.") + public String getDiscoverySpiFormatted(); + + /** + * Gets a formatted instance of fully configured SPI communication implementation. + * + * @return Grid communication SPI implementation. + */ + @IgniteMBeanDescription("Formatted instance of fully configured SPI communication implementation.") + public String getCommunicationSpiFormatted(); + + /** + * Gets a formatted instance of fully configured deployment SPI implementation. + * + * @return Grid deployment SPI implementation. + */ + @IgniteMBeanDescription("Formatted instance of fully configured deployment SPI implementation.") + public String getDeploymentSpiFormatted(); + + /** + * Gets a formatted instance of configured checkpoint SPI implementation. + * + * @return Grid checkpoint SPI implementation. + */ + @IgniteMBeanDescription("Formatted instance of configured checkpoint SPI implementation.") + public String getCheckpointSpiFormatted(); + + /** + * Gets a formatted instance of configured collision SPI implementations. + * + * @return Grid collision SPI implementations. + */ + @IgniteMBeanDescription("Formatted instance of configured collision SPI implementations.") + public String getCollisionSpiFormatted(); + + /** + * Gets a formatted instance of configured swapspace SPI implementations. + * + * @return Grid swapspace SPI implementations. + */ + @IgniteMBeanDescription("Formatted instance of configured swapspace SPI implementations.") + public String getSwapSpaceSpiFormatted(); + + /** + * Gets a formatted instance of fully configured event SPI implementation. + * + * @return Grid event SPI implementation. + */ + @IgniteMBeanDescription("Formatted instance of fully configured event SPI implementation.") + public String getEventStorageSpiFormatted(); + + /** + * Gets a formatted instance of fully configured failover SPI implementations. + * + * @return Grid failover SPI implementations. + */ + @IgniteMBeanDescription("Formatted instance of fully configured failover SPI implementations.") + public String getFailoverSpiFormatted(); + + /** + * Gets a formatted instance of fully configured load balancing SPI implementations. + * + * @return Grid load balancing SPI implementations. + */ + @IgniteMBeanDescription("Formatted instance of fully configured load balancing SPI implementations.") + public String getLoadBalancingSpiFormatted(); + + /** + * Gets a formatted instance of fully configured authentication SPI implementation. + * + * @return Grid authentication SPI implementation. + */ + @IgniteMBeanDescription("Formatted instance of fully configured authentication SPI implementation.") + public String getAuthenticationSpiFormatted(); + + /** + * Gets a formatted instance of fully configured secure session SPI implementation. + * + * @return Grid secure session SPI implementation. + */ + @IgniteMBeanDescription("Formatted instance of fully configured secure session SPI implementation.") + public String getSecureSessionSpiFormatted(); + + /** + * Gets OS information. + * + * @return OS information. + */ + @IgniteMBeanDescription("OS information.") + public String getOsInformation(); + + /** + * Gets JDK information. + * + * @return JDK information. + */ + @IgniteMBeanDescription("JDK information.") + public String getJdkInformation(); + + /** + * Gets OS user. + * + * @return OS user name. + */ + @IgniteMBeanDescription("OS user name.") + public String getOsUser(); + + /** + * Gets VM name. + * + * @return VM name. + */ + @IgniteMBeanDescription("VM name.") + public String getVmName(); + + /** + * Gets optional kernal instance name. It can be {@code null}. + * + * @return Optional kernal instance name. + */ + @IgniteMBeanDescription("Optional kernal instance name.") + public String getInstanceName(); +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteMBeanDescription.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteMBeanDescription.java b/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteMBeanDescription.java new file mode 100644 index 0000000..f1d0e25 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteMBeanDescription.java @@ -0,0 +1,34 @@ +/* + * 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.mxbean; + +import java.lang.annotation.*; + +/** + * Provides description for MBean classes and methods. + */ +@Documented +@Retention(RetentionPolicy.RUNTIME) +@Target({ElementType.TYPE, ElementType.METHOD}) +public @interface IgniteMBeanDescription { + /** + * + * Description for Mbean. + */ + @SuppressWarnings({"JavaDoc"}) public String value(); +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteMBeanParametersDescriptions.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteMBeanParametersDescriptions.java b/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteMBeanParametersDescriptions.java new file mode 100644 index 0000000..e32150f --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteMBeanParametersDescriptions.java @@ -0,0 +1,34 @@ +/* + * 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.mxbean; + +import java.lang.annotation.*; + +/** + * Provides MBean method parameters description. + */ +@Documented +@Retention(RetentionPolicy.RUNTIME) +@Target({ElementType.METHOD}) +public @interface IgniteMBeanParametersDescriptions { + /** + * + * Array of descriptions for parameters. + */ + @SuppressWarnings({"JavaDoc"}) public String[] value(); +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16edda18/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteMBeanParametersNames.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteMBeanParametersNames.java b/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteMBeanParametersNames.java new file mode 100644 index 0000000..c429f32 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteMBeanParametersNames.java @@ -0,0 +1,34 @@ +/* + * 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.mxbean; + +import java.lang.annotation.*; + +/** + * Provides MBean method parameters names. + */ +@Documented +@Retention(RetentionPolicy.RUNTIME) +@Target({ElementType.METHOD}) +public @interface IgniteMBeanParametersNames { + /** + * + * Array of parameter names in MBean. + */ + @SuppressWarnings({"JavaDoc"}) public String[] value(); +}
