IGNITE-125 Moved MXBean interfaces into org.apache.ignite.mxbean package.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/4916c90c Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/4916c90c Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/4916c90c Branch: refs/heads/ignite-125 Commit: 4916c90c7f7822c88ffe134f065a36635c06d1eb Parents: 903e698 Author: nikolay_tikhonov <ntikho...@gridgain.com> Authored: Wed Jan 28 12:19:56 2015 +0300 Committer: nikolay_tikhonov <ntikho...@gridgain.com> Committed: Wed Jan 28 12:49:22 2015 +0300 ---------------------------------------------------------------------- .../checkpoint/s3/S3CheckpointSpiMXBean.java | 1 - .../eviction/fifo/CacheFifoEvictionPolicy.java | 3 +- .../fifo/CacheFifoEvictionPolicyMXBean.java | 58 ---- .../CacheGgfsPerBlockLruEvictionPolicy.java | 3 +- ...acheGgfsPerBlockLruEvictionPolicyMXBean.java | 93 ------ .../eviction/lru/CacheLruEvictionPolicy.java | 1 + .../lru/CacheLruEvictionPolicyMXBean.java | 58 ---- .../random/CacheRandomEvictionPolicy.java | 1 + .../random/CacheRandomEvictionPolicyMXBean.java | 42 --- .../client/router/GridTcpRouterMXBean.java | 88 ------ .../client/router/impl/GridTcpRouterImpl.java | 13 +- .../streamer/GridStreamProcessor.java | 1 + .../processors/streamer/StreamerMXBeanImpl.java | 2 +- .../streamer/StreamerStageMXBeanImpl.java | 2 +- .../internal/visor/util/VisorTaskUtils.java | 4 +- .../mxbean/AdaptiveLoadBalancingSpiMXBean.java | 34 +++ .../ignite/mxbean/AlwaysFailoverSpiMXBean.java | 43 +++ .../ignite/mxbean/CacheCheckpointSpiMXBean.java | 33 +++ .../mxbean/CacheFifoEvictionPolicyMXBean.java | 56 ++++ ...acheGgfsPerBlockLruEvictionPolicyMXBean.java | 92 ++++++ .../mxbean/CacheLruEvictionPolicyMXBean.java | 56 ++++ .../mxbean/CacheRandomEvictionPolicyMXBean.java | 40 +++ .../mxbean/FifoQueueCollisionSpiMXBean.java | 90 ++++++ .../ignite/mxbean/FileSwapSpaceSpiMXBean.java | 66 +++++ .../ignite/mxbean/GridTcpRouterMXBean.java | 86 ++++++ .../mxbean/IgniteSpiManagementMXBean.java | 83 ++++++ .../ignite/mxbean/JdbcCheckpointSpiMXBean.java | 113 ++++++++ .../mxbean/JobStealingCollisionSpiMXBean.java | 192 +++++++++++++ .../mxbean/JobStealingFailoverSpiMXBean.java | 53 ++++ .../ignite/mxbean/LocalDeploymentSpiMXBean.java | 28 ++ .../mxbean/MemoryEventStorageSpiMXBean.java | 64 +++++ .../ignite/mxbean/NeverFailoverSpiMXBean.java | 28 ++ .../mxbean/NoopAuthenticationSpiMXBean.java | 28 ++ .../mxbean/NoopSecureSessionSpiMXBean.java | 28 ++ .../mxbean/PriorityQueueCollisionSpiMXBean.java | 159 +++++++++++ .../RoundRobinLoadBalancingSpiMXBean.java | 44 +++ .../mxbean/SharedFsCheckpointSpiMXBean.java | 44 +++ .../mxbean/StreamerIndexProviderMXBean.java | 74 +++++ .../apache/ignite/mxbean/StreamerMXBean.java | 168 +++++++++++ .../ignite/mxbean/StreamerStageMXBean.java | 112 ++++++++ .../ignite/mxbean/StreamerWindowMXBean.java | 56 ++++ .../mxbean/TcpClientDiscoverySpiMXBean.java | 163 +++++++++++ .../mxbean/TcpCommunicationSpiMXBean.java | 281 ++++++++++++++++++ .../ignite/mxbean/TcpDiscoverySpiMXBean.java | 274 ++++++++++++++++++ .../WeightedRandomLoadBalancingSpiMXBean.java | 44 +++ .../org/apache/ignite/spi/IgniteSpiAdapter.java | 1 + .../ignite/spi/IgniteSpiManagementMXBean.java | 85 ------ .../noop/NoopAuthenticationSpi.java | 1 + .../noop/NoopAuthenticationSpiMXBean.java | 29 -- .../checkpoint/cache/CacheCheckpointSpi.java | 1 + .../cache/CacheCheckpointSpiMXBean.java | 36 --- .../spi/checkpoint/jdbc/JdbcCheckpointSpi.java | 1 + .../jdbc/JdbcCheckpointSpiMXBean.java | 117 -------- .../sharedfs/SharedFsCheckpointSpi.java | 1 + .../sharedfs/SharedFsCheckpointSpiMXBean.java | 47 ---- .../fifoqueue/FifoQueueCollisionSpi.java | 1 + .../fifoqueue/FifoQueueCollisionSpiMXBean.java | 93 ------ .../jobstealing/JobStealingCollisionSpi.java | 1 + .../JobStealingCollisionSpiMXBean.java | 193 ------------- .../PriorityQueueCollisionSpi.java | 1 + .../PriorityQueueCollisionSpiMXBean.java | 162 ----------- .../communication/tcp/TcpCommunicationSpi.java | 1 + .../tcp/TcpCommunicationSpiMXBean.java | 282 ------------------- .../deployment/local/LocalDeploymentSpi.java | 1 + .../local/LocalDeploymentSpiMXBean.java | 29 -- .../discovery/tcp/TcpClientDiscoverySpi.java | 1 + .../tcp/TcpClientDiscoverySpiMXBean.java | 164 ----------- .../spi/discovery/tcp/TcpDiscoverySpi.java | 1 + .../discovery/tcp/TcpDiscoverySpiMXBean.java | 275 ------------------ .../memory/MemoryEventStorageSpi.java | 1 + .../memory/MemoryEventStorageSpiMXBean.java | 65 ----- .../spi/failover/always/AlwaysFailoverSpi.java | 1 + .../always/AlwaysFailoverSpiMXBean.java | 44 --- .../jobstealing/JobStealingFailoverSpi.java | 1 + .../JobStealingFailoverSpiMXBean.java | 54 ---- .../spi/failover/never/NeverFailoverSpi.java | 1 + .../failover/never/NeverFailoverSpiMXBean.java | 29 -- .../adaptive/AdaptiveLoadBalancingSpi.java | 1 + .../AdaptiveLoadBalancingSpiMXBean.java | 35 --- .../roundrobin/RoundRobinLoadBalancingSpi.java | 1 + .../RoundRobinLoadBalancingSpiMXBean.java | 45 --- .../WeightedRandomLoadBalancingSpi.java | 1 + .../WeightedRandomLoadBalancingSpiMXBean.java | 45 --- .../noop/NoopSecureSessionSpi.java | 1 + .../noop/NoopSecureSessionSpiMXBean.java | 29 -- .../spi/swapspace/file/FileSwapSpaceSpi.java | 1 + .../swapspace/file/FileSwapSpaceSpiMXBean.java | 67 ----- .../apache/ignite/streamer/StreamerMXBean.java | 169 ----------- .../ignite/streamer/StreamerStageMXBean.java | 114 -------- .../ignite/streamer/StreamerWindowMXBean.java | 58 ---- .../streamer/index/StreamerIndexProvider.java | 1 + .../index/StreamerIndexProviderMXBean.java | 74 ----- .../streamer/window/StreamerWindowAdapter.java | 1 + .../util/mbeans/IgniteMXBeanSelfTest.java | 2 +- .../uri/GridUriDeploymentSpiMXBean.java | 1 - 95 files changed, 2673 insertions(+), 2695 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/aws/src/main/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiMXBean.java ---------------------------------------------------------------------- diff --git a/modules/aws/src/main/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiMXBean.java b/modules/aws/src/main/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiMXBean.java index 16604b2..347b891 100644 --- a/modules/aws/src/main/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiMXBean.java +++ b/modules/aws/src/main/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiMXBean.java @@ -18,7 +18,6 @@ package org.apache.ignite.spi.checkpoint.s3; import org.apache.ignite.mxbean.*; -import org.apache.ignite.spi.*; /** * Management bean for {@link S3CheckpointSpi}. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/CacheFifoEvictionPolicy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/CacheFifoEvictionPolicy.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/CacheFifoEvictionPolicy.java index d7b5c05..1a072ce 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/CacheFifoEvictionPolicy.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/CacheFifoEvictionPolicy.java @@ -20,6 +20,7 @@ package org.apache.ignite.cache.eviction.fifo; import org.apache.ignite.*; import org.apache.ignite.cache.*; import org.apache.ignite.cache.eviction.*; +import org.apache.ignite.mxbean.*; import org.jdk8.backport.*; import org.jdk8.backport.ConcurrentLinkedDeque8.*; import org.apache.ignite.internal.util.typedef.*; @@ -34,7 +35,7 @@ import java.util.*; * maintained by attaching ordering metadata to cache entries. */ public class CacheFifoEvictionPolicy<K, V> implements CacheEvictionPolicy<K, V>, - CacheFifoEvictionPolicyMXBean { + CacheFifoEvictionPolicyMXBean { /** Tag. */ private final String meta = UUID.randomUUID().toString(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/CacheFifoEvictionPolicyMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/CacheFifoEvictionPolicyMXBean.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/CacheFifoEvictionPolicyMXBean.java deleted file mode 100644 index 61f1573..0000000 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/fifo/CacheFifoEvictionPolicyMXBean.java +++ /dev/null @@ -1,58 +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.cache.eviction.fifo; - -import org.apache.ignite.mxbean.*; - -/** - * MBean for {@code FIFO} eviction policy. - */ -@IgniteMXBeanDescription("MXBean for FIFO cache eviction policy.") -public interface CacheFifoEvictionPolicyMXBean { - /** - * Gets name of metadata attribute used to store eviction policy data. - * - * @return Name of metadata attribute used to store eviction policy data. - */ - @IgniteMXBeanDescription("Name of metadata attribute used to store eviction policy data.") - public String getMetaAttributeName(); - - /** - * Gets maximum allowed cache size. - * - * @return Maximum allowed cache size. - */ - @IgniteMXBeanDescription("Maximum allowed cache size.") - public int getMaxSize(); - - /** - * Sets maximum allowed cache size. - * - * @param max Maximum allowed cache size. - */ - @IgniteMXBeanDescription("Set maximum allowed cache size.") - public void setMaxSize(int max); - - /** - * Gets current queue size. - * - * @return Current queue size. - */ - @IgniteMXBeanDescription("Current FIFO queue size.") - public int getCurrentSize(); -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/cache/eviction/ggfs/CacheGgfsPerBlockLruEvictionPolicy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/ggfs/CacheGgfsPerBlockLruEvictionPolicy.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/ggfs/CacheGgfsPerBlockLruEvictionPolicy.java index 1c7fadb..573a748 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/ggfs/CacheGgfsPerBlockLruEvictionPolicy.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/ggfs/CacheGgfsPerBlockLruEvictionPolicy.java @@ -22,6 +22,7 @@ import org.apache.ignite.cache.*; import org.apache.ignite.cache.eviction.*; import org.apache.ignite.fs.*; import org.apache.ignite.internal.processors.fs.*; +import org.apache.ignite.mxbean.*; import org.jdk8.backport.*; import org.jdk8.backport.ConcurrentLinkedDeque8.*; import org.jetbrains.annotations.*; @@ -34,7 +35,7 @@ import java.util.regex.*; * GGFS eviction policy which evicts particular blocks. */ public class CacheGgfsPerBlockLruEvictionPolicy implements CacheEvictionPolicy<GridGgfsBlockKey, byte[]>, - CacheGgfsPerBlockLruEvictionPolicyMXBean { + CacheGgfsPerBlockLruEvictionPolicyMXBean { /** Meta denoting node in the queue. */ public static final String META_NODE = "ggfs_node"; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/cache/eviction/ggfs/CacheGgfsPerBlockLruEvictionPolicyMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/ggfs/CacheGgfsPerBlockLruEvictionPolicyMXBean.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/ggfs/CacheGgfsPerBlockLruEvictionPolicyMXBean.java deleted file mode 100644 index 54476da..0000000 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/ggfs/CacheGgfsPerBlockLruEvictionPolicyMXBean.java +++ /dev/null @@ -1,93 +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.cache.eviction.ggfs; - -import org.apache.ignite.mxbean.*; -import org.jetbrains.annotations.*; - -import java.util.*; - -/** - * MBean for {@code GGFS per-block LRU} eviction policy. - */ -@IgniteMXBeanDescription("MXBean for GGFS per-block LRU cache eviction policy.") -public interface CacheGgfsPerBlockLruEvictionPolicyMXBean { - /** - * Gets maximum allowed size of all blocks in bytes. - * - * @return Maximum allowed size of all blocks in bytes. - */ - @IgniteMXBeanDescription("Maximum allowed size of all blocks in bytes.") - public long getMaxSize(); - - /** - * Sets maximum allowed size of data in all blocks in bytes. - * - * @param maxSize Maximum allowed size of data in all blocks in bytes. - */ - @IgniteMXBeanDescription("Sets aximum allowed size of data in all blocks in bytes.") - public void setMaxSize(long maxSize); - - /** - * Gets maximum allowed amount of blocks. - * - * @return Maximum allowed amount of blocks. - */ - @IgniteMXBeanDescription("Maximum allowed amount of blocks.") - public int getMaxBlocks(); - - /** - * Sets maximum allowed amount of blocks. - * - * @param maxBlocks Maximum allowed amount of blocks. - */ - @IgniteMXBeanDescription("Sets maximum allowed amount of blocks.") - public void setMaxBlocks(int maxBlocks); - - /** - * Gets collection of regex for paths whose blocks must not be evicted. - * - * @return Collection of regex for paths whose blocks must not be evicted. - */ - @IgniteMXBeanDescription("Collection of regex for paths whose blocks must not be evicted.") - @Nullable public Collection<String> getExcludePaths(); - - /** - * Sets collection of regex for paths whose blocks must not be evicted. - * - * @param excludePaths Collection of regex for paths whose blocks must not be evicted. - */ - @IgniteMXBeanDescription("Sets collection of regex for paths whose blocks must not be evicted.") - public void setExcludePaths(@Nullable Collection<String> excludePaths); - - /** - * Gets current size of data in all blocks. - * - * @return Current size of data in all blocks. - */ - @IgniteMXBeanDescription("Current size of data in all blocks.") - public long getCurrentSize(); - - /** - * Gets current amount of blocks. - * - * @return Current amount of blocks. - */ - @IgniteMXBeanDescription("Current amount of blocks.") - public int getCurrentBlocks(); -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/CacheLruEvictionPolicy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/CacheLruEvictionPolicy.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/CacheLruEvictionPolicy.java index b897bac..b772ed2 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/CacheLruEvictionPolicy.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/CacheLruEvictionPolicy.java @@ -19,6 +19,7 @@ package org.apache.ignite.cache.eviction.lru; import org.apache.ignite.cache.*; import org.apache.ignite.cache.eviction.*; +import org.apache.ignite.mxbean.*; import org.jdk8.backport.*; import org.jdk8.backport.ConcurrentLinkedDeque8.*; import org.apache.ignite.internal.util.typedef.internal.*; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/CacheLruEvictionPolicyMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/CacheLruEvictionPolicyMXBean.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/CacheLruEvictionPolicyMXBean.java deleted file mode 100644 index f919b72..0000000 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/lru/CacheLruEvictionPolicyMXBean.java +++ /dev/null @@ -1,58 +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.cache.eviction.lru; - -import org.apache.ignite.mxbean.*; - -/** - * MBean for {@code LRU} eviction policy. - */ -@IgniteMXBeanDescription("MXBean for LRU cache eviction policy.") -public interface CacheLruEvictionPolicyMXBean { - /** - * Gets name of metadata attribute used to store eviction policy data. - * - * @return Name of metadata attribute used to store eviction policy data. - */ - @IgniteMXBeanDescription("Name of metadata attribute used to store eviction policy data.") - public String getMetaAttributeName(); - - /** - * Gets maximum allowed cache size. - * - * @return Maximum allowed cache size. - */ - @IgniteMXBeanDescription("Maximum allowed cache size.") - public int getMaxSize(); - - /** - * Sets maximum allowed cache size. - * - * @param max Maximum allowed cache size. - */ - @IgniteMXBeanDescription("Sets maximum allowed cache size.") - public void setMaxSize(int max); - - /** - * Gets current queue size. - * - * @return Current queue size. - */ - @IgniteMXBeanDescription("Current queue size.") - public int getCurrentSize(); -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/CacheRandomEvictionPolicy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/CacheRandomEvictionPolicy.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/CacheRandomEvictionPolicy.java index c5c5fe1..549dd06 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/CacheRandomEvictionPolicy.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/CacheRandomEvictionPolicy.java @@ -22,6 +22,7 @@ import org.apache.ignite.cache.*; import org.apache.ignite.cache.eviction.*; import org.apache.ignite.internal.util.typedef.*; import org.apache.ignite.internal.util.typedef.internal.*; +import org.apache.ignite.mxbean.*; /** * Cache eviction policy which will select random cache entry for eviction if cache http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/CacheRandomEvictionPolicyMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/CacheRandomEvictionPolicyMXBean.java b/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/CacheRandomEvictionPolicyMXBean.java deleted file mode 100644 index 3805c79..0000000 --- a/modules/core/src/main/java/org/apache/ignite/cache/eviction/random/CacheRandomEvictionPolicyMXBean.java +++ /dev/null @@ -1,42 +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.cache.eviction.random; - -import org.apache.ignite.mxbean.*; - -/** - * MBean for {@code random} eviction policy. - */ -@IgniteMXBeanDescription("MXBean for random cache eviction policy.") -public interface CacheRandomEvictionPolicyMXBean { - /** - * Gets maximum allowed cache size. - * - * @return Maximum allowed cache size. - */ - @IgniteMXBeanDescription("Maximum allowed cache size.") - public int getMaxSize(); - - /** - * Sets maximum allowed cache size. - * - * @param max Maximum allowed cache size. - */ - @IgniteMXBeanDescription("Sets maximum allowed cache size.") - public void setMaxSize(int max); -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/client/router/GridTcpRouterMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/client/router/GridTcpRouterMXBean.java b/modules/core/src/main/java/org/apache/ignite/client/router/GridTcpRouterMXBean.java deleted file mode 100644 index bf2e738..0000000 --- a/modules/core/src/main/java/org/apache/ignite/client/router/GridTcpRouterMXBean.java +++ /dev/null @@ -1,88 +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.client.router; - -import org.apache.ignite.mxbean.*; - -import java.util.*; - -/** - * MBean interface for TCP router. - */ -@IgniteMXBeanDescription("MXBean for TCP router.") -public interface GridTcpRouterMXBean { - /** - * Gets host for TCP binary protocol server. - * - * @return TCP host. - */ - @IgniteMXBeanDescription("Host for TCP binary protocol server.") - public String getHost(); - - /** - * Gets port for TCP binary protocol server. - * - * @return TCP port. - */ - @IgniteMXBeanDescription("Port for TCP binary protocol server.") - public int getPort(); - - /** - * Gets a flag indicating whether or not remote clients will be required to have a valid SSL certificate which - * validity will be verified with trust manager. - * - * @return Whether or not client authentication is required. - */ - @IgniteMXBeanDescription("Flag indicating whether or not SSL is enabled for incoming connections.") - public boolean isSslEnabled(); - - /** - * Gets a flag indicating whether or not remote clients will be required to have a valid SSL certificate which - * validity will be verified with trust manager. - * - * @return Whether or not client authentication is required. - */ - @IgniteMXBeanDescription("Flag indicating whether or not remote clients are required to have a valid SSL certificate.") - public boolean isSslClientAuth(); - - /** - * Gets list of server addresses where router's embedded client should connect. - * - * @return List of server addresses. - */ - @IgniteMXBeanDescription("Gets list of server addresses where router's embedded client should connect.") - public Collection<String> getServers(); - - /** - * Returns number of messages received by this router. - * Note that this parameter has approximate value. - * - * @return Number of messages received by this router. - */ - @IgniteMXBeanDescription("Number of messages received by this router.") - public long getReceivedCount(); - - /** - * Returns number of responses returned by this router. - * Note that this parameter has approximate value. - * - * @return Number of responses returned by this router. - */ - @IgniteMXBeanDescription("Number of responses returned by this router.") - public long getSendCount(); -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/client/router/impl/GridTcpRouterImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/client/router/impl/GridTcpRouterImpl.java b/modules/core/src/main/java/org/apache/ignite/client/router/impl/GridTcpRouterImpl.java index e852402..a4cc73d 100644 --- a/modules/core/src/main/java/org/apache/ignite/client/router/impl/GridTcpRouterImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/client/router/impl/GridTcpRouterImpl.java @@ -27,6 +27,7 @@ import org.apache.ignite.internal.processors.rest.client.message.*; import org.apache.ignite.internal.util.nio.*; import org.apache.ignite.internal.util.nio.ssl.*; import org.apache.ignite.internal.util.typedef.internal.*; +import org.apache.ignite.mxbean.*; import org.jetbrains.annotations.*; import javax.management.*; @@ -159,12 +160,12 @@ public class GridTcpRouterImpl implements GridTcpRouter, GridTcpRouterMXBean, Li try { ObjectName objName = U.registerMXBean( - ManagementFactory.getPlatformMBeanServer(), - "Router", - "TCP Router " + id, - getClass().getSimpleName(), - this, - GridTcpRouterMXBean.class); + ManagementFactory.getPlatformMBeanServer(), + "Router", + "TCP Router " + id, + getClass().getSimpleName(), + this, + GridTcpRouterMXBean.class); if (log.isDebugEnabled()) log.debug("Registered MBean: " + objName); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamProcessor.java index 3c49d58..53cbd10 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamProcessor.java @@ -21,6 +21,7 @@ import org.apache.ignite.*; import org.apache.ignite.cluster.*; import org.apache.ignite.internal.*; import org.apache.ignite.internal.processors.*; +import org.apache.ignite.mxbean.*; import org.apache.ignite.streamer.*; import org.apache.ignite.streamer.index.*; import org.apache.ignite.streamer.window.*; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/StreamerMXBeanImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/StreamerMXBeanImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/StreamerMXBeanImpl.java index d940893..eb76993 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/StreamerMXBeanImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/StreamerMXBeanImpl.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.processors.streamer; -import org.apache.ignite.streamer.*; +import org.apache.ignite.mxbean.*; import org.jetbrains.annotations.*; /** http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/StreamerStageMXBeanImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/StreamerStageMXBeanImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/StreamerStageMXBeanImpl.java index 1b0d3f0..5719432 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/StreamerStageMXBeanImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/StreamerStageMXBeanImpl.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.processors.streamer; -import org.apache.ignite.streamer.*; +import org.apache.ignite.mxbean.*; /** * Streamer stage MXBean adapter. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/internal/visor/util/VisorTaskUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/util/VisorTaskUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/util/VisorTaskUtils.java index bdd72dd..ca3f323 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/visor/util/VisorTaskUtils.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/util/VisorTaskUtils.java @@ -19,9 +19,6 @@ package org.apache.ignite.internal.visor.util; import org.apache.ignite.*; import org.apache.ignite.cache.eviction.*; -import org.apache.ignite.cache.eviction.fifo.*; -import org.apache.ignite.cache.eviction.lru.*; -import org.apache.ignite.cache.eviction.random.*; import org.apache.ignite.cluster.*; import org.apache.ignite.events.*; import org.apache.ignite.internal.processors.fs.*; @@ -31,6 +28,7 @@ import org.apache.ignite.internal.visor.file.*; import org.apache.ignite.internal.visor.log.*; import org.apache.ignite.internal.util.typedef.*; import org.apache.ignite.internal.util.typedef.internal.*; +import org.apache.ignite.mxbean.*; import org.jetbrains.annotations.*; import java.io.*; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/mxbean/AdaptiveLoadBalancingSpiMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/AdaptiveLoadBalancingSpiMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/AdaptiveLoadBalancingSpiMXBean.java new file mode 100644 index 0000000..22bfef4 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/AdaptiveLoadBalancingSpiMXBean.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 org.apache.ignite.spi.loadbalancing.adaptive.*; + +/** + * Management MBean for {@link AdaptiveLoadBalancingSpi} SPI. + */ +@IgniteMXBeanDescription("MXBean that provides access to adaptive load balancing SPI configuration.") +public interface AdaptiveLoadBalancingSpiMXBean extends IgniteSpiManagementMXBean { + /** + * Gets text description of current load probing implementation used. + * + * @return Text description of current load probing implementation used. + */ + @IgniteMXBeanDescription("Text description of current load probing implementation used.") + public String getLoadProbeFormatted(); +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/mxbean/AlwaysFailoverSpiMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/AlwaysFailoverSpiMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/AlwaysFailoverSpiMXBean.java new file mode 100644 index 0000000..ef38928 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/AlwaysFailoverSpiMXBean.java @@ -0,0 +1,43 @@ +/* + * 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 org.apache.ignite.spi.failover.always.*; + +/** + * Management bean for {@link AlwaysFailoverSpi}. + */ +@IgniteMXBeanDescription("MXBean that provides access to always failover SPI configuration.") +public interface AlwaysFailoverSpiMXBean extends IgniteSpiManagementMXBean { + /** + * Gets maximum number of attempts to execute a failed job on another node. + * If not specified, {@link AlwaysFailoverSpi#DFLT_MAX_FAILOVER_ATTEMPTS} value will be used. + * + * @return Maximum number of attempts to execute a failed job on another node. + */ + @IgniteMXBeanDescription("Maximum number of attempts to execute a failed job on another node.") + public int getMaximumFailoverAttempts(); + + /** + * Get total number of jobs that were failed over. + * + * @return Total number of failed over jobs. + */ + @IgniteMXBeanDescription("Total number of jobs that were failed over.") + public int getTotalFailoverJobsCount(); +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/mxbean/CacheCheckpointSpiMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/CacheCheckpointSpiMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/CacheCheckpointSpiMXBean.java new file mode 100644 index 0000000..805f20e --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/CacheCheckpointSpiMXBean.java @@ -0,0 +1,33 @@ +/* + * 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; + +/** + * Management bean that provides general administrative and configuration information + * about cache checkpoint SPI. + */ +@IgniteMXBeanDescription("MXBean provides information about cache checkpoint SPI.") +public interface CacheCheckpointSpiMXBean extends IgniteSpiManagementMXBean { + /** + * Gets cache name to be used by this SPI.. + * + * @return Cache name to be used by this SPI. + */ + @IgniteMXBeanDescription("Cache name to be used by this SPI.") + public String getCacheName(); +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/mxbean/CacheFifoEvictionPolicyMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/CacheFifoEvictionPolicyMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/CacheFifoEvictionPolicyMXBean.java new file mode 100644 index 0000000..67999e9 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/CacheFifoEvictionPolicyMXBean.java @@ -0,0 +1,56 @@ +/* + * 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; + +/** + * MBean for {@code FIFO} eviction policy. + */ +@IgniteMXBeanDescription("MXBean for FIFO cache eviction policy.") +public interface CacheFifoEvictionPolicyMXBean { + /** + * Gets name of metadata attribute used to store eviction policy data. + * + * @return Name of metadata attribute used to store eviction policy data. + */ + @IgniteMXBeanDescription("Name of metadata attribute used to store eviction policy data.") + public String getMetaAttributeName(); + + /** + * Gets maximum allowed cache size. + * + * @return Maximum allowed cache size. + */ + @IgniteMXBeanDescription("Maximum allowed cache size.") + public int getMaxSize(); + + /** + * Sets maximum allowed cache size. + * + * @param max Maximum allowed cache size. + */ + @IgniteMXBeanDescription("Set maximum allowed cache size.") + public void setMaxSize(int max); + + /** + * Gets current queue size. + * + * @return Current queue size. + */ + @IgniteMXBeanDescription("Current FIFO queue size.") + public int getCurrentSize(); +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/mxbean/CacheGgfsPerBlockLruEvictionPolicyMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/CacheGgfsPerBlockLruEvictionPolicyMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/CacheGgfsPerBlockLruEvictionPolicyMXBean.java new file mode 100644 index 0000000..5dc0993 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/CacheGgfsPerBlockLruEvictionPolicyMXBean.java @@ -0,0 +1,92 @@ +/* + * 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 org.jetbrains.annotations.*; + +import java.util.*; + +/** + * MXBean for {@code GGFS per-block LRU} eviction policy. + */ +@IgniteMXBeanDescription("MXBean for GGFS per-block LRU cache eviction policy.") +public interface CacheGgfsPerBlockLruEvictionPolicyMXBean { + /** + * Gets maximum allowed size of all blocks in bytes. + * + * @return Maximum allowed size of all blocks in bytes. + */ + @IgniteMXBeanDescription("Maximum allowed size of all blocks in bytes.") + public long getMaxSize(); + + /** + * Sets maximum allowed size of data in all blocks in bytes. + * + * @param maxSize Maximum allowed size of data in all blocks in bytes. + */ + @IgniteMXBeanDescription("Sets aximum allowed size of data in all blocks in bytes.") + public void setMaxSize(long maxSize); + + /** + * Gets maximum allowed amount of blocks. + * + * @return Maximum allowed amount of blocks. + */ + @IgniteMXBeanDescription("Maximum allowed amount of blocks.") + public int getMaxBlocks(); + + /** + * Sets maximum allowed amount of blocks. + * + * @param maxBlocks Maximum allowed amount of blocks. + */ + @IgniteMXBeanDescription("Sets maximum allowed amount of blocks.") + public void setMaxBlocks(int maxBlocks); + + /** + * Gets collection of regex for paths whose blocks must not be evicted. + * + * @return Collection of regex for paths whose blocks must not be evicted. + */ + @IgniteMXBeanDescription("Collection of regex for paths whose blocks must not be evicted.") + @Nullable public Collection<String> getExcludePaths(); + + /** + * Sets collection of regex for paths whose blocks must not be evicted. + * + * @param excludePaths Collection of regex for paths whose blocks must not be evicted. + */ + @IgniteMXBeanDescription("Sets collection of regex for paths whose blocks must not be evicted.") + public void setExcludePaths(@Nullable Collection<String> excludePaths); + + /** + * Gets current size of data in all blocks. + * + * @return Current size of data in all blocks. + */ + @IgniteMXBeanDescription("Current size of data in all blocks.") + public long getCurrentSize(); + + /** + * Gets current amount of blocks. + * + * @return Current amount of blocks. + */ + @IgniteMXBeanDescription("Current amount of blocks.") + public int getCurrentBlocks(); +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/mxbean/CacheLruEvictionPolicyMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/CacheLruEvictionPolicyMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/CacheLruEvictionPolicyMXBean.java new file mode 100644 index 0000000..3518ad5 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/CacheLruEvictionPolicyMXBean.java @@ -0,0 +1,56 @@ +/* + * 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; + +/** + * MXBean for {@code LRU} eviction policy. + */ +@IgniteMXBeanDescription("MXBean for LRU cache eviction policy.") +public interface CacheLruEvictionPolicyMXBean { + /** + * Gets name of metadata attribute used to store eviction policy data. + * + * @return Name of metadata attribute used to store eviction policy data. + */ + @IgniteMXBeanDescription("Name of metadata attribute used to store eviction policy data.") + public String getMetaAttributeName(); + + /** + * Gets maximum allowed cache size. + * + * @return Maximum allowed cache size. + */ + @IgniteMXBeanDescription("Maximum allowed cache size.") + public int getMaxSize(); + + /** + * Sets maximum allowed cache size. + * + * @param max Maximum allowed cache size. + */ + @IgniteMXBeanDescription("Sets maximum allowed cache size.") + public void setMaxSize(int max); + + /** + * Gets current queue size. + * + * @return Current queue size. + */ + @IgniteMXBeanDescription("Current queue size.") + public int getCurrentSize(); +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/mxbean/CacheRandomEvictionPolicyMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/CacheRandomEvictionPolicyMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/CacheRandomEvictionPolicyMXBean.java new file mode 100644 index 0000000..4542a3e --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/CacheRandomEvictionPolicyMXBean.java @@ -0,0 +1,40 @@ +/* + * 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; + +/** + * MBean for {@code random} eviction policy. + */ +@IgniteMXBeanDescription("MXBean for random cache eviction policy.") +public interface CacheRandomEvictionPolicyMXBean { + /** + * Gets maximum allowed cache size. + * + * @return Maximum allowed cache size. + */ + @IgniteMXBeanDescription("Maximum allowed cache size.") + public int getMaxSize(); + + /** + * Sets maximum allowed cache size. + * + * @param max Maximum allowed cache size. + */ + @IgniteMXBeanDescription("Sets maximum allowed cache size.") + public void setMaxSize(int max); +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/mxbean/FifoQueueCollisionSpiMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/FifoQueueCollisionSpiMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/FifoQueueCollisionSpiMXBean.java new file mode 100644 index 0000000..f4b8263 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/FifoQueueCollisionSpiMXBean.java @@ -0,0 +1,90 @@ +/* + * 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; + +/** + * Management bean that provides access to the FIFO queue collision SPI configuration. + */ +@IgniteMXBeanDescription("MXBean provides information about FIFO queue based collision SPI configuration.") +public interface FifoQueueCollisionSpiMXBean extends IgniteSpiManagementMXBean { + /** + * Gets number of jobs that can be executed in parallel. + * + * @return Number of jobs that can be executed in parallel. + */ + @IgniteMXBeanDescription("Number of jobs that can be executed in parallel.") + public int getParallelJobsNumber(); + + /** + * Sets number of jobs that can be executed in parallel. + * + * @param num Parallel jobs number. + */ + @IgniteMXBeanDescription("Number of jobs that can be executed in parallel.") + public void setParallelJobsNumber(int num); + + /** + * Maximum number of jobs that are allowed to wait in waiting queue. If number + * of waiting jobs ever exceeds this number, excessive jobs will be rejected. + * + * @return Maximum allowed number of waiting jobs. + */ + @IgniteMXBeanDescription("Maximum allowed number of waiting jobs.") + public int getWaitingJobsNumber(); + + /** + * Sets maximum number of jobs that are allowed to wait in waiting queue. If number + * of waiting jobs ever exceeds this number, excessive jobs will be rejected. + * + * @param num Waiting jobs number. + */ + @IgniteMXBeanDescription("Maximum allowed number of waiting jobs.") + public void setWaitingJobsNumber(int num); + + /** + * Gets current number of jobs that wait for the execution. + * + * @return Number of jobs that wait for execution. + */ + @IgniteMXBeanDescription("Number of jobs that wait for execution.") + public int getCurrentWaitJobsNumber(); + + /** + * Gets current number of jobs that are active, i.e. {@code 'running + held'} jobs. + * + * @return Number of active jobs. + */ + @IgniteMXBeanDescription("Number of active jobs.") + public int getCurrentActiveJobsNumber(); + + /* + * Gets number of currently running (not {@code 'held}) jobs. + * + * @return Number of currently running (not {@code 'held}) jobs. + */ + @IgniteMXBeanDescription("Number of running jobs.") + public int getCurrentRunningJobsNumber(); + + /** + * Gets number of currently {@code 'held'} jobs. + * + * @return Number of currently {@code 'held'} jobs. + */ + @IgniteMXBeanDescription("Number of held jobs.") + public int getCurrentHeldJobsNumber(); +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/mxbean/FileSwapSpaceSpiMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/FileSwapSpaceSpiMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/FileSwapSpaceSpiMXBean.java new file mode 100644 index 0000000..204ec7a --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/FileSwapSpaceSpiMXBean.java @@ -0,0 +1,66 @@ +/* + * 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 org.apache.ignite.spi.swapspace.file.*; + +/** + * Management bean for {@link FileSwapSpaceSpi}. + */ +@IgniteMXBeanDescription("MXBean that provides configuration information on file-based swapspace SPI.") +public interface FileSwapSpaceSpiMXBean extends IgniteSpiManagementMXBean { + /** + * Gets base directory. + * + * @return Base directory. + */ + @IgniteMXBeanDescription("Base directory.") + public String getBaseDirectory(); + + /** + * Gets maximum sparsity. + * + * @return Maximum sparsity. + */ + @IgniteMXBeanDescription("Maximum sparsity.") + public float getMaximumSparsity(); + + /** + * Gets write buffer size in bytes. + * + * @return Write buffer size in bytes. + */ + @IgniteMXBeanDescription("Write buffer size in bytes.") + public int getWriteBufferSize(); + + /** + * Gets max write queue size in bytes. + * + * @return Max write queue size in bytes. + */ + @IgniteMXBeanDescription("Max write queue size in bytes.") + public int getMaxWriteQueueSize(); + + /** + * Gets read pool size. + * + * @return Read pool size. + */ + @IgniteMXBeanDescription("Read pool size.") + public int getReadStripesNumber(); +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/mxbean/GridTcpRouterMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/GridTcpRouterMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/GridTcpRouterMXBean.java new file mode 100644 index 0000000..2a70862 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/GridTcpRouterMXBean.java @@ -0,0 +1,86 @@ +/* + * 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.util.*; + +/** + * MBean interface for TCP router. + */ +@IgniteMXBeanDescription("MXBean for TCP router.") +public interface GridTcpRouterMXBean { + /** + * Gets host for TCP binary protocol server. + * + * @return TCP host. + */ + @IgniteMXBeanDescription("Host for TCP binary protocol server.") + public String getHost(); + + /** + * Gets port for TCP binary protocol server. + * + * @return TCP port. + */ + @IgniteMXBeanDescription("Port for TCP binary protocol server.") + public int getPort(); + + /** + * Gets a flag indicating whether or not remote clients will be required to have a valid SSL certificate which + * validity will be verified with trust manager. + * + * @return Whether or not client authentication is required. + */ + @IgniteMXBeanDescription("Flag indicating whether or not SSL is enabled for incoming connections.") + public boolean isSslEnabled(); + + /** + * Gets a flag indicating whether or not remote clients will be required to have a valid SSL certificate which + * validity will be verified with trust manager. + * + * @return Whether or not client authentication is required. + */ + @IgniteMXBeanDescription("Flag indicating whether or not remote clients are required to have a valid SSL certificate.") + public boolean isSslClientAuth(); + + /** + * Gets list of server addresses where router's embedded client should connect. + * + * @return List of server addresses. + */ + @IgniteMXBeanDescription("Gets list of server addresses where router's embedded client should connect.") + public Collection<String> getServers(); + + /** + * Returns number of messages received by this router. + * Note that this parameter has approximate value. + * + * @return Number of messages received by this router. + */ + @IgniteMXBeanDescription("Number of messages received by this router.") + public long getReceivedCount(); + + /** + * Returns number of responses returned by this router. + * Note that this parameter has approximate value. + * + * @return Number of responses returned by this router. + */ + @IgniteMXBeanDescription("Number of responses returned by this router.") + public long getSendCount(); +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteSpiManagementMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteSpiManagementMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteSpiManagementMXBean.java new file mode 100644 index 0000000..a6371ee --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/IgniteSpiManagementMXBean.java @@ -0,0 +1,83 @@ +/* + * 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.util.*; + +/** + * This interface defines basic MXBean for all SPI implementations. Every SPI implementation + * should provide implementation for this MXBean interface. Note that SPI implementation can extend this + * interface as necessary. + */ +public interface IgniteSpiManagementMXBean { + /** + * Gets string presentation of the start timestamp. + * + * @return String presentation of the start timestamp. + */ + @IgniteMXBeanDescription("String presentation of the start timestamp.") + public String getStartTimestampFormatted(); + + /** + * Gets string presentation of up-time for this SPI. + * + * @return String presentation of up-time for this SPI. + */ + @IgniteMXBeanDescription("String presentation of up-time for this SPI.") + public String getUpTimeFormatted(); + + /** + * Get start timestamp of this SPI. + * + * @return Start timestamp of this SPI. + */ + @IgniteMXBeanDescription("Start timestamp of this SPI.") + public long getStartTimestamp(); + + /** + * Gets up-time of this SPI in ms. + * + * @return Up-time of this SPI. + */ + @IgniteMXBeanDescription("Up-time of this SPI in milliseconds.") + public long getUpTime(); + + /** + * Gets Gridgain installation home folder (i.e. ${GRIDGAIN_HOME}); + * + * @return Gridgain installation home folder. + */ + @IgniteMXBeanDescription("Gridgain installation home folder.") + public String getGridGainHome(); + + /** + * Gets ID of the local node. + * + * @return ID of the local node. + */ + @IgniteMXBeanDescription("ID of the local node.") + public UUID getLocalNodeId(); + + /** + * Gets name of the SPI. + * + * @return Name of the SPI. + */ + @IgniteMXBeanDescription("Name of the SPI.") + public String getName(); +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/mxbean/JdbcCheckpointSpiMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/JdbcCheckpointSpiMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/JdbcCheckpointSpiMXBean.java new file mode 100644 index 0000000..17027e0 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/JdbcCheckpointSpiMXBean.java @@ -0,0 +1,113 @@ +/* + * 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; + +/** + * Management bean that provides general administrative and configuration information + * about jdbc checkpoint SPI. + */ +@IgniteMXBeanDescription("MXBean that provides information about jdbc checkpoint SPI.") +public interface JdbcCheckpointSpiMXBean extends IgniteSpiManagementMXBean { + /** + * Gets number of retries in case of DB failure. + * + * @return Number of retries. + */ + @IgniteMXBeanDescription("Number of retries.") + public int getNumberOfRetries(); + + /** + * Gets data source description. + * + * @return Description for data source. + */ + @IgniteMXBeanDescription("Data source description.") + public String getDataSourceInfo(); + + /** + * Gets checkpoint jdbc user name. + * + * @return User name for checkpoint jdbc. + */ + @IgniteMXBeanDescription("User name for checkpoint database.") + public String getUser(); + + /** + * Gets checkpoint jdbc password. + * + * @return Password for checkpoint jdbc. + */ + @IgniteMXBeanDescription("Password for checkpoint database.") + public String getPwd(); + + /** + * Gets checkpoint table name. + * + * @return Checkpoint table name. + */ + @IgniteMXBeanDescription("Checkpoint table name.") + public String getCheckpointTableName(); + + /** + * Gets key field name for checkpoint table. + * + * @return Key field name for checkpoint table. + */ + @IgniteMXBeanDescription("Key field name for checkpoint table.") + public String getKeyFieldName(); + + /** + * Gets key field type for checkpoint table. + * + * @return Key field type for checkpoint table. + */ + @IgniteMXBeanDescription("Key field type for checkpoint table.") + public String getKeyFieldType(); + + /** + * Gets value field name for checkpoint table. + * + * @return Value field name for checkpoint table. + */ + @IgniteMXBeanDescription("Value field name for checkpoint table.") + public String getValueFieldName(); + + /** + * Gets value field type for checkpoint table. + * + * @return Value field type for checkpoint table. + */ + @IgniteMXBeanDescription("Value field type for checkpoint table.") + public String getValueFieldType(); + + /** + * Gets expiration date field name for checkpoint table. + * + * @return Create date field name for checkpoint table. + */ + @IgniteMXBeanDescription("Expiration date field name for checkpoint table.") + public String getExpireDateFieldName(); + + /** + * Gets expiration date field type for checkpoint table. + * + * @return Expiration date field type for checkpoint table. + */ + @IgniteMXBeanDescription("Expiration date field type for checkpoint table.") + public String getExpireDateFieldType(); +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/mxbean/JobStealingCollisionSpiMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/JobStealingCollisionSpiMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/JobStealingCollisionSpiMXBean.java new file mode 100644 index 0000000..7e6dccf --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/JobStealingCollisionSpiMXBean.java @@ -0,0 +1,192 @@ +/* + * 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 org.apache.ignite.spi.collision.jobstealing.*; + +import java.io.*; +import java.util.*; + +/** + * Management MXBean for job stealing based collision SPI. + */ +@IgniteMXBeanDescription("MXBean for job stealing based collision SPI.") +public interface JobStealingCollisionSpiMXBean extends IgniteSpiManagementMXBean { + /** + * Gets current number of jobs to be stolen. This is outstanding + * requests number. + * + * @return Number of jobs to be stolen. + */ + @IgniteMXBeanDescription("Number of jobs to be stolen.") + public int getCurrentJobsToStealNumber(); + + /** + * Gets current number of jobs that wait for the execution. + * + * @return Number of jobs that wait for execution. + */ + @IgniteMXBeanDescription("Number of jobs that wait for execution.") + public int getCurrentWaitJobsNumber(); + + /** + * Gets current number of jobs that are being executed. + * + * @return Number of active jobs. + */ + @IgniteMXBeanDescription("Number of active jobs.") + public int getCurrentActiveJobsNumber(); + + /* + * Gets number of currently running (not {@code 'held}) jobs. + * + * @return Number of currently running (not {@code 'held}) jobs. + */ + @IgniteMXBeanDescription("Number of running jobs.") + public int getCurrentRunningJobsNumber(); + + /** + * Gets number of currently {@code 'held'} jobs. + * + * @return Number of currently {@code 'held'} jobs. + */ + @IgniteMXBeanDescription("Number of held jobs.") + public int getCurrentHeldJobsNumber(); + + /** + * Gets total number of stolen jobs. + * + * @return Number of stolen jobs. + */ + @IgniteMXBeanDescription("Number of stolen jobs.") + public int getTotalStolenJobsNumber(); + + /** + * Gets number of jobs that can be executed in parallel. + * + * @return Number of jobs that can be executed in parallel. + */ + @IgniteMXBeanDescription("Number of jobs that can be executed in parallel.") + public int getActiveJobsThreshold(); + + /** + * Sets number of jobs that can be executed in parallel. + * + * @param activeJobsTreshold Number of jobs that can be executed in parallel. + */ + @IgniteMXBeanDescription("Number of jobs that can be executed in parallel.") + public void setActiveJobsThreshold(int activeJobsTreshold); + + /** + * Gets job count threshold at which this node will + * start stealing jobs from other nodes. + * + * @return Job count threshold. + */ + @IgniteMXBeanDescription("Job count threshold.") + public int getWaitJobsThreshold(); + + /** + * Sets job count threshold at which this node will + * start stealing jobs from other nodes. + * + * @param waitJobsThreshold Job count threshold. + */ + @IgniteMXBeanDescription("Job count threshold.") + public void setWaitJobsThreshold(int waitJobsThreshold); + + /** + * Message expire time configuration parameter. If no response is received + * from a busy node to a job stealing message, then implementation will + * assume that message never got there, or that remote node does not have + * this node included into topology of any of the jobs it has. + * + * @return Message expire time. + */ + @IgniteMXBeanDescription("Message expire time.") + public long getMessageExpireTime(); + + /** + * Message expire time configuration parameter. If no response is received + * from a busy node to a job stealing message, then implementation will + * assume that message never got there, or that remote node does not have + * this node included into topology of any of the jobs it has. + * + * @param msgExpireTime Message expire time. + */ + @IgniteMXBeanDescription("Message expire time.") + public void setMessageExpireTime(long msgExpireTime); + + /** + * Gets flag indicating whether this node should attempt to steal jobs + * from other nodes. If {@code false}, then this node will steal allow + * jobs to be stolen from it, but won't attempt to steal any jobs from + * other nodes. + * <p> + * Default value is {@code true}. + * + * @return Flag indicating whether this node should attempt to steal jobs + * from other nodes. + */ + @IgniteMXBeanDescription("Flag indicating whether this node should attempt to steal jobs from other nodes.") + public boolean isStealingEnabled(); + + /** + * Gets flag indicating whether this node should attempt to steal jobs + * from other nodes. If {@code false}, then this node will steal allow + * jobs to be stolen from it, but won't attempt to steal any jobs from + * other nodes. + * <p> + * Default value is {@code true}. + * + * @param stealingEnabled Flag indicating whether this node should attempt to steal jobs + * from other nodes. + */ + @IgniteMXBeanDescription("Flag indicating whether this node should attempt to steal jobs from other nodes.") + public void setStealingEnabled(boolean stealingEnabled); + + /** + * Gets maximum number of attempts to steal job by another node. + * If not specified, {@link JobStealingCollisionSpi#DFLT_MAX_STEALING_ATTEMPTS} + * value will be used. + * + * @return Maximum number of attempts to steal job by another node. + */ + @IgniteMXBeanDescription("Maximum number of attempts to steal job by another node.") + public int getMaximumStealingAttempts(); + + /** + * Gets maximum number of attempts to steal job by another node. + * If not specified, {@link JobStealingCollisionSpi#DFLT_MAX_STEALING_ATTEMPTS} + * value will be used. + * + * @param maximumStealingAttempts Maximum number of attempts to steal job by another node. + */ + @IgniteMXBeanDescription("Maximum number of attempts to steal job by another node.") + public void setMaximumStealingAttempts(int maximumStealingAttempts); + + /** + * Configuration parameter to enable stealing to/from only nodes that + * have these attributes set (see {@link org.apache.ignite.cluster.ClusterNode#attribute(String)} and + * {@link org.apache.ignite.configuration.IgniteConfiguration#getUserAttributes()} methods). + * + * @return Node attributes to enable job stealing for. + */ + @IgniteMXBeanDescription("Node attributes to enable job stealing for.") + public Map<String, ? extends Serializable> getStealingAttributes(); +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/mxbean/JobStealingFailoverSpiMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/JobStealingFailoverSpiMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/JobStealingFailoverSpiMXBean.java new file mode 100644 index 0000000..584f9bf --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/JobStealingFailoverSpiMXBean.java @@ -0,0 +1,53 @@ +/* + * 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 org.apache.ignite.spi.failover.jobstealing.*; + +/** + * Management bean for {@link JobStealingFailoverSpi}. + */ +@IgniteMXBeanDescription("MXBean that provides access to job stealing failover SPI configuration.") +public interface JobStealingFailoverSpiMXBean extends IgniteSpiManagementMXBean { + /** + * Gets maximum number of attempts to execute a failed job on another node. + * If job gets stolen and thief node exists then it is not considered as + * failed job. + * If not specified, {@link JobStealingFailoverSpi#DFLT_MAX_FAILOVER_ATTEMPTS} value will be used. + * + * @return Maximum number of attempts to execute a failed job on another node. + */ + @IgniteMXBeanDescription("Maximum number of attempts to execute a failed job on another node.") + public int getMaximumFailoverAttempts(); + + /** + * Get total number of jobs that were failed over including stolen ones. + * + * @return Total number of failed over jobs. + */ + @IgniteMXBeanDescription("Total number of jobs that were failed over including stolen ones.") + public int getTotalFailedOverJobsCount(); + + /** + * Get total number of jobs that were stolen. + * + * @return Total number of stolen jobs. + */ + @IgniteMXBeanDescription("Total number of jobs that were stolen.") + public int getTotalStolenJobsCount(); +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/mxbean/LocalDeploymentSpiMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/LocalDeploymentSpiMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/LocalDeploymentSpiMXBean.java new file mode 100644 index 0000000..43acce7 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/LocalDeploymentSpiMXBean.java @@ -0,0 +1,28 @@ +/* + * 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 org.apache.ignite.spi.deployment.local.*; + +/** + * Management MXBean for {@link LocalDeploymentSpi} SPI. + */ +@IgniteMXBeanDescription("MXBean that provides access to local deployment SPI configuration.") +public interface LocalDeploymentSpiMXBean extends IgniteSpiManagementMXBean { + // No-op. +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/mxbean/MemoryEventStorageSpiMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/MemoryEventStorageSpiMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/MemoryEventStorageSpiMXBean.java new file mode 100644 index 0000000..6e52e79 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/MemoryEventStorageSpiMXBean.java @@ -0,0 +1,64 @@ +/* + * 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 org.apache.ignite.spi.eventstorage.memory.*; + +/** + * Management bean for {@link MemoryEventStorageSpi}. + * Beside properties defined for every SPI bean this one gives access to: + * <ul> + * <li>Event expiration time (see {@link #getExpireAgeMs()})</li> + * <li>Maximum queue size (see {@link #getExpireCount()})</li> + * <li>Method that removes all items from queue (see {@link #clearAll()})</li> + * </ul> + */ +@IgniteMXBeanDescription("MXBean that provides access to memory event storage SPI configuration.") +public interface MemoryEventStorageSpiMXBean extends IgniteSpiManagementMXBean { + /** + * Gets event time-to-live value. Implementation must guarantee + * that event would not be accessible if its lifetime exceeds this value. + * + * @return Event time-to-live. + */ + @IgniteMXBeanDescription("Event time-to-live value.") + public long getExpireAgeMs(); + + /** + * Gets maximum event queue size. New incoming events will oust + * oldest ones if queue size exceeds this limit. + * + * @return Maximum event queue size. + */ + @IgniteMXBeanDescription("Maximum event queue size.") + public long getExpireCount(); + + /** + * Gets current queue size of the event queue. + * + * @return Current queue size of the event queue. + */ + @IgniteMXBeanDescription("Current event queue size.") + public long getQueueSize(); + + /** + * Removes all events from the event queue. + */ + @IgniteMXBeanDescription("Removes all events from the event queue.") + public void clearAll(); +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/mxbean/NeverFailoverSpiMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/NeverFailoverSpiMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/NeverFailoverSpiMXBean.java new file mode 100644 index 0000000..93b8372 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/NeverFailoverSpiMXBean.java @@ -0,0 +1,28 @@ +/* + * 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 org.apache.ignite.spi.failover.never.*; + +/** + * Management bean for {@link NeverFailoverSpi}. + */ +@IgniteMXBeanDescription("MXBean that provides access to never failover SPI configuration.") +public interface NeverFailoverSpiMXBean extends IgniteSpiManagementMXBean { + // No-op. +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/mxbean/NoopAuthenticationSpiMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/NoopAuthenticationSpiMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/NoopAuthenticationSpiMXBean.java new file mode 100644 index 0000000..c0988b8 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/NoopAuthenticationSpiMXBean.java @@ -0,0 +1,28 @@ +/* + * 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 org.apache.ignite.spi.authentication.noop.*; + +/** + * Management bean for {@link NoopAuthenticationSpi}. + */ +@IgniteMXBeanDescription("MXBean that provides access to no-op authentication SPI configuration.") +public interface NoopAuthenticationSpiMXBean extends IgniteSpiManagementMXBean { + // No-op. +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4916c90c/modules/core/src/main/java/org/apache/ignite/mxbean/NoopSecureSessionSpiMXBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/mxbean/NoopSecureSessionSpiMXBean.java b/modules/core/src/main/java/org/apache/ignite/mxbean/NoopSecureSessionSpiMXBean.java new file mode 100644 index 0000000..dd09480 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/mxbean/NoopSecureSessionSpiMXBean.java @@ -0,0 +1,28 @@ +/* + * 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 org.apache.ignite.spi.securesession.noop.*; + +/** + * Management bean for {@link NoopSecureSessionSpi}. + */ +@IgniteMXBeanDescription("MXBean that provides access to no-op secure session SPI configuration.") +public interface NoopSecureSessionSpiMXBean extends IgniteSpiManagementMXBean { + // No-op. +}
