Loading kinetic-client/src/main/java/kinetic/admin/KineticAdminClient.java +2 −2 Original line number Diff line number Diff line Loading @@ -234,8 +234,8 @@ public interface KineticAdminClient extends KineticP2pClient { /** * Set cluster version with the specified version. * * @param newClusterVersion * @throws KineticException * @param newClusterVersion new cluster version to be set. * @throws KineticException if any internal error occurred */ public void setClusterVersion (long newClusterVersion) throws KineticException; Loading kinetic-client/src/main/java/kinetic/admin/KineticLog.java +1 −1 Original line number Diff line number Diff line Loading @@ -77,7 +77,7 @@ public interface KineticLog { * * @throws KineticException * if any internal error occurred. * @see DefaultConfiguration * @see Configuration */ public Configuration getConfiguration() throws KineticException; Loading kinetic-client/src/main/java/kinetic/admin/Limits.java +38 −40 Original line number Diff line number Diff line Loading @@ -24,7 +24,7 @@ package kinetic.admin; * A Limits contains maxKeySize, maxValueSize, maxVersionSize, maxTagSize, * maxConnections, maxOutstandingReadRequests, maxOutstandingWriteRequests, * maxMessageSize. * <p> * </p> * * @see KineticLog * @see KineticLogType Loading Loading @@ -70,10 +70,10 @@ public class Limits { } /** * Set the max key size field content of the limits. * Set the max allowed key size. * * @param key * the content to be set to the max key size field. * @param maxKeySize * the max allowed key size. */ public void setMaxKeySize(int maxKeySize) { this.maxKeySize = maxKeySize; Loading @@ -89,29 +89,29 @@ public class Limits { } /** * Set the max value size field content of the limits. * Set the max allowed value size. * * @param key * the content to be set to the max value size field. * @param maxValueSize * the max allowed value size. */ public void setMaxValueSize(int maxValueSize) { this.maxValueSize = maxValueSize; } /** * Get the value of max version size. * Get max allowed version size. * * @return the content of the max version size field. * @return max allowed version size. */ public int getMaxVersionSize() { return maxVersionSize; } /** * Set the max version size field content of the limits. * Set the max allowed version size. * * @param key * the content to be set to the max version size field. * @param maxVersionSize * the max allowed version size. */ public void setMaxVersionSize(int maxVersionSize) { this.maxVersionSize = maxVersionSize; Loading @@ -127,29 +127,29 @@ public class Limits { } /** * Set the max tag size field content of the limits. * Set the max tag size. * * @param key * the content to be set to the max tag field. * @param maxTagSize * the max tag size */ public void setMaxTagSize(int maxTagSize) { this.maxTagSize = maxTagSize; } /** * Get the value of max connections. * Get max allowed concurrent connections. * * @return the content of the max connections field. * @return max allowed concurrent connections */ public int getMaxConnections() { return maxConnections; } /** * Set the max connections field content of the limits. * Set max allowed concurrent connections * * @param key * the content to be set to the max connections field. * @param maxConnections * the max allowed concurrent connections */ public void setMaxConnections(int maxConnections) { this.maxConnections = maxConnections; Loading @@ -165,69 +165,67 @@ public class Limits { } /** * Set the max out standing read requests field content of the limits. * Set the max allowed out standing read requests. * * @param key * the content to be set to the max out standing read requests * field. * @param maxOutstandingReadRequests * the max allowed out standing read requests */ public void setMaxOutstandingReadRequests(int maxOutstandingReadRequests) { this.maxOutstandingReadRequests = maxOutstandingReadRequests; } /** * Get the value of max out standing write requests. * Get max allowed out-standing write requests. * * @return the content of the max out standing write requests field. * @return tmax allowed out-standing write requests. */ public int getMaxOutstandingWriteRequests() { return maxOutstandingWriteRequests; } /** * Set the max out standing write requests field content of the limits. * Set max allowed out-standing write requests * * @param key * the content to be set to the max out standing write requests * field. * @param maxOutstandingWriteRequests * max allowed out-standing write requests */ public void setMaxOutstandingWriteRequests(int maxOutstandingWriteRequests) { this.maxOutstandingWriteRequests = maxOutstandingWriteRequests; } /** * Get the value of max message size. * Get max allowed message size. * * @return the content of the max message size. * @return max allowed message size */ public int getMaxMessageSize() { return maxMessageSize; } /** * Set the max message size field content of the limits. * Set the max allowed message size. * * @param key * the content to be set to the max message size field. * @param maxMessageSize * tthe max allowed message size */ public void setMaxMessageSize(int maxMessageSize) { this.maxMessageSize = maxMessageSize; } /** * Get the value of max key range size. * Get max allowed number of keys can be returned from getKeyRange. * * @return the content of the max key range size. * @return max allowed number of keys can be returned from getKeyRange. */ public int getMaxKeyRangeCount() { return maxKeyRangeCount; } /** * Set the max key range size field content of the limits. * Set max allowed number of keys can be returned from getKeyRange. * * @param key * the content to be set to the max key range size field. * @param maxKeyRangeCount * max allowed number of keys can be returned from getKeyRange. */ public void setMaxKeyRangeCount(int maxKeyRangeCount) { this.maxKeyRangeCount = maxKeyRangeCount; Loading kinetic-client/src/main/java/kinetic/admin/package-info.java 0 → 100644 +36 −0 Original line number Diff line number Diff line /** * Copyright (C) 2014 Seagate Technology. * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation; either * version 2.1 of the License, or (at your option) any later version. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public * License along with this library; if not, write to the Free Software * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA */ /** * Kinetic Java Admin API. * <p> * A Kinetic admin user uses the Java Admin API provided in this package to configure, * setup, and monitor Kinetic devices.</P> * <p> * The boot-strap API for using the Kinetic admin client library is * <code>KineticAdminClientFactory.createInstance(AdminClientConfiguration)</code>.</P> * <p> * Kinetic admin applications construct a new instance of <code>AdminClientConfiguration</code> * and set the appropriate configurations (such as server host/port) to the * configuration instance. Applications then invoke the static createInstance * method <code>KineticAdminClientFactory.createInstance(AdminClientConfiguration)</code> to obtain a new * instance of KineticAdminClient.</p> * */ package kinetic.admin; kinetic-client/src/main/java/kinetic/client/BatchOperation.java +1 −1 Original line number Diff line number Diff line Loading @@ -5,7 +5,7 @@ package kinetic.client; * Kinetic client batch operation interface. * <p> * * @auther James Hughes * @author James Hughes * @author chiaming * */ Loading Loading
kinetic-client/src/main/java/kinetic/admin/KineticAdminClient.java +2 −2 Original line number Diff line number Diff line Loading @@ -234,8 +234,8 @@ public interface KineticAdminClient extends KineticP2pClient { /** * Set cluster version with the specified version. * * @param newClusterVersion * @throws KineticException * @param newClusterVersion new cluster version to be set. * @throws KineticException if any internal error occurred */ public void setClusterVersion (long newClusterVersion) throws KineticException; Loading
kinetic-client/src/main/java/kinetic/admin/KineticLog.java +1 −1 Original line number Diff line number Diff line Loading @@ -77,7 +77,7 @@ public interface KineticLog { * * @throws KineticException * if any internal error occurred. * @see DefaultConfiguration * @see Configuration */ public Configuration getConfiguration() throws KineticException; Loading
kinetic-client/src/main/java/kinetic/admin/Limits.java +38 −40 Original line number Diff line number Diff line Loading @@ -24,7 +24,7 @@ package kinetic.admin; * A Limits contains maxKeySize, maxValueSize, maxVersionSize, maxTagSize, * maxConnections, maxOutstandingReadRequests, maxOutstandingWriteRequests, * maxMessageSize. * <p> * </p> * * @see KineticLog * @see KineticLogType Loading Loading @@ -70,10 +70,10 @@ public class Limits { } /** * Set the max key size field content of the limits. * Set the max allowed key size. * * @param key * the content to be set to the max key size field. * @param maxKeySize * the max allowed key size. */ public void setMaxKeySize(int maxKeySize) { this.maxKeySize = maxKeySize; Loading @@ -89,29 +89,29 @@ public class Limits { } /** * Set the max value size field content of the limits. * Set the max allowed value size. * * @param key * the content to be set to the max value size field. * @param maxValueSize * the max allowed value size. */ public void setMaxValueSize(int maxValueSize) { this.maxValueSize = maxValueSize; } /** * Get the value of max version size. * Get max allowed version size. * * @return the content of the max version size field. * @return max allowed version size. */ public int getMaxVersionSize() { return maxVersionSize; } /** * Set the max version size field content of the limits. * Set the max allowed version size. * * @param key * the content to be set to the max version size field. * @param maxVersionSize * the max allowed version size. */ public void setMaxVersionSize(int maxVersionSize) { this.maxVersionSize = maxVersionSize; Loading @@ -127,29 +127,29 @@ public class Limits { } /** * Set the max tag size field content of the limits. * Set the max tag size. * * @param key * the content to be set to the max tag field. * @param maxTagSize * the max tag size */ public void setMaxTagSize(int maxTagSize) { this.maxTagSize = maxTagSize; } /** * Get the value of max connections. * Get max allowed concurrent connections. * * @return the content of the max connections field. * @return max allowed concurrent connections */ public int getMaxConnections() { return maxConnections; } /** * Set the max connections field content of the limits. * Set max allowed concurrent connections * * @param key * the content to be set to the max connections field. * @param maxConnections * the max allowed concurrent connections */ public void setMaxConnections(int maxConnections) { this.maxConnections = maxConnections; Loading @@ -165,69 +165,67 @@ public class Limits { } /** * Set the max out standing read requests field content of the limits. * Set the max allowed out standing read requests. * * @param key * the content to be set to the max out standing read requests * field. * @param maxOutstandingReadRequests * the max allowed out standing read requests */ public void setMaxOutstandingReadRequests(int maxOutstandingReadRequests) { this.maxOutstandingReadRequests = maxOutstandingReadRequests; } /** * Get the value of max out standing write requests. * Get max allowed out-standing write requests. * * @return the content of the max out standing write requests field. * @return tmax allowed out-standing write requests. */ public int getMaxOutstandingWriteRequests() { return maxOutstandingWriteRequests; } /** * Set the max out standing write requests field content of the limits. * Set max allowed out-standing write requests * * @param key * the content to be set to the max out standing write requests * field. * @param maxOutstandingWriteRequests * max allowed out-standing write requests */ public void setMaxOutstandingWriteRequests(int maxOutstandingWriteRequests) { this.maxOutstandingWriteRequests = maxOutstandingWriteRequests; } /** * Get the value of max message size. * Get max allowed message size. * * @return the content of the max message size. * @return max allowed message size */ public int getMaxMessageSize() { return maxMessageSize; } /** * Set the max message size field content of the limits. * Set the max allowed message size. * * @param key * the content to be set to the max message size field. * @param maxMessageSize * tthe max allowed message size */ public void setMaxMessageSize(int maxMessageSize) { this.maxMessageSize = maxMessageSize; } /** * Get the value of max key range size. * Get max allowed number of keys can be returned from getKeyRange. * * @return the content of the max key range size. * @return max allowed number of keys can be returned from getKeyRange. */ public int getMaxKeyRangeCount() { return maxKeyRangeCount; } /** * Set the max key range size field content of the limits. * Set max allowed number of keys can be returned from getKeyRange. * * @param key * the content to be set to the max key range size field. * @param maxKeyRangeCount * max allowed number of keys can be returned from getKeyRange. */ public void setMaxKeyRangeCount(int maxKeyRangeCount) { this.maxKeyRangeCount = maxKeyRangeCount; Loading
kinetic-client/src/main/java/kinetic/admin/package-info.java 0 → 100644 +36 −0 Original line number Diff line number Diff line /** * Copyright (C) 2014 Seagate Technology. * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation; either * version 2.1 of the License, or (at your option) any later version. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public * License along with this library; if not, write to the Free Software * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA */ /** * Kinetic Java Admin API. * <p> * A Kinetic admin user uses the Java Admin API provided in this package to configure, * setup, and monitor Kinetic devices.</P> * <p> * The boot-strap API for using the Kinetic admin client library is * <code>KineticAdminClientFactory.createInstance(AdminClientConfiguration)</code>.</P> * <p> * Kinetic admin applications construct a new instance of <code>AdminClientConfiguration</code> * and set the appropriate configurations (such as server host/port) to the * configuration instance. Applications then invoke the static createInstance * method <code>KineticAdminClientFactory.createInstance(AdminClientConfiguration)</code> to obtain a new * instance of KineticAdminClient.</p> * */ package kinetic.admin;
kinetic-client/src/main/java/kinetic/client/BatchOperation.java +1 −1 Original line number Diff line number Diff line Loading @@ -5,7 +5,7 @@ package kinetic.client; * Kinetic client batch operation interface. * <p> * * @auther James Hughes * @author James Hughes * @author chiaming * */ Loading