Categories:
Audio (13)
Biotech (29)
Bytecode (36)
Database (77)
Framework (7)
Game (7)
General (507)
Graphics (53)
I/O (35)
IDE (2)
JAR Tools (101)
JavaBeans (21)
JDBC (121)
JDK (426)
JSP (20)
Logging (108)
Mail (58)
Messaging (8)
Network (84)
PDF (97)
Report (7)
Scripting (84)
Security (32)
Server (121)
Servlet (26)
SOAP (24)
Testing (54)
Web (15)
XML (309)
Collections:
Other Resources:
Apache ZooKeeper Server Source Code
Apache ZooKeeper is an open-source server which enables highly reliable distributed coordination.
Apache ZooKeeper Server Source Code files are provided in the source package file, apache-zookeeper-3.8.0.tar.gz.
You can download apache-zookeeper-3.8.0.tar.gz as described in the previous tutorial and go to the "zookeeper-server" sub-folder to view Apache ZooKeeper Server Source Code files.
You can also browse Apache ZooKeeper Server Source Code below:
✍: FYIcenter.com
⏎ org/apache/zookeeper/server/ZooKeeperServerMXBean.java
/* * 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.zookeeper.server; /** * ZooKeeper server MBean. */ public interface ZooKeeperServerMXBean { /** * @return the server socket port number */ String getClientPort(); /** * @return the zookeeper server version */ String getVersion(); /** * @return time the server was started */ String getStartTime(); /** * @return min request latency in ms */ long getMinRequestLatency(); /** * @return average request latency in ms */ double getAvgRequestLatency(); /** * @return max request latency in ms */ long getMaxRequestLatency(); /** * @return number of packets received so far */ long getPacketsReceived(); /** * @return number of packets sent so far */ long getPacketsSent(); /** * @return number of fsync threshold exceeds so far */ long getFsyncThresholdExceedCount(); /** * @return number of AuthFailedCount so far */ long getAuthFailedCount(); /** * @return number of NonMTLSLocalConnCount so far */ long getNonMTLSLocalConnCount(); /** * @return number of NonMTLSRemoteConnCount so far */ long getNonMTLSRemoteConnCount(); /** * @return number of outstanding requests. */ long getOutstandingRequests(); /** * Current TickTime of server in milliseconds */ int getTickTime(); /** * Set TickTime of server in milliseconds */ void setTickTime(int tickTime); /** Current maxClientCnxns allowed from a particular host */ int getMaxClientCnxnsPerHost(); /** Set maxClientCnxns allowed from a particular host */ void setMaxClientCnxnsPerHost(int max); /** * Current minSessionTimeout of the server in milliseconds */ int getMinSessionTimeout(); /** * Set minSessionTimeout of server in milliseconds */ void setMinSessionTimeout(int min); /** * Current maxSessionTimeout of the server in milliseconds */ int getMaxSessionTimeout(); /** * Set maxSessionTimeout of server in milliseconds */ void setMaxSessionTimeout(int max); boolean getResponseCachingEnabled(); void setResponseCachingEnabled(boolean isEnabled); /* Connection throttling settings */ int getConnectionMaxTokens(); void setConnectionMaxTokens(int val); int getConnectionTokenFillTime(); void setConnectionTokenFillTime(int val); int getConnectionTokenFillCount(); void setConnectionTokenFillCount(int val); int getConnectionFreezeTime(); void setConnectionFreezeTime(int val); double getConnectionDropIncrease(); void setConnectionDropIncrease(double val); double getConnectionDropDecrease(); void setConnectionDropDecrease(double val); double getConnectionDecreaseRatio(); void setConnectionDecreaseRatio(double val); int getCommitProcMaxReadBatchSize(); void setCommitProcMaxReadBatchSize(int size); int getCommitProcMaxCommitBatchSize(); void setCommitProcMaxCommitBatchSize(int size); int getRequestThrottleLimit(); void setRequestThrottleLimit(int requests); int getRequestThrottleStallTime(); void setRequestThrottleStallTime(int time); boolean getRequestThrottleDropStale(); void setRequestThrottleDropStale(boolean drop); int getThrottledOpWaitTime(); void setThrottledOpWaitTime(int val); boolean getRequestStaleLatencyCheck(); void setRequestStaleLatencyCheck(boolean check); boolean getRequestStaleConnectionCheck(); void setRequestStaleConnectionCheck(boolean check); int getLargeRequestMaxBytes(); void setLargeRequestMaxBytes(int bytes); int getLargeRequestThreshold(); void setLargeRequestThreshold(int threshold); /** * Reset packet and latency statistics */ void resetStatistics(); /** * Reset min/avg/max latency statistics */ void resetLatency(); /** * Reset max latency statistics only. */ void resetMaxLatency(); /** * Reset Fsync Threshold Exceed Count statistics only. */ void resetFsyncThresholdExceedCount(); /** * Reset NonMTLS(Local+Remote)ConnCount statistics only. */ void resetNonMTLSConnCount(); /** * Reset AuthFailedCount statistics only. */ void resetAuthFailedCount(); /** * @return number of alive client connections */ long getNumAliveConnections(); /** * @return estimated size of data directory in bytes */ long getDataDirSize(); /** * @return estimated size of log directory in bytes */ long getLogDirSize(); /** * @return secure client port */ String getSecureClientPort(); /** * @return secure client address */ String getSecureClientAddress(); /** * Returns the elapsed sync of time of transaction log in milliseconds. */ long getTxnLogElapsedSyncTime(); /** * @return Returns the value of the following config setting: jute.maxbuffer */ int getJuteMaxBufferSize(); /** * @return size of latest generated client response */ int getLastClientResponseSize(); /** * @return size of smallest generated client response */ int getMinClientResponseSize(); /** * @return size of largest generated client response */ int getMaxClientResponseSize(); long getFlushDelay(); void setFlushDelay(long delay); long getMaxWriteQueuePollTime(); void setMaxWriteQueuePollTime(long delay); int getMaxBatchSize(); void setMaxBatchSize(int size); /** * @return Current maxCnxns allowed to a single ZooKeeper server */ int getMaxCnxns(); }
⏎ org/apache/zookeeper/server/ZooKeeperServerMXBean.java
Or download all of them as a single archive file:
File name: zookeeper-server-3.8.0-fyi.zip File size: 885581 bytes Release date: 2022-02-25 Download
⇒ Apache ZooKeeper Jute Source Code
⇐ Download and Install Apache ZooKeeper Source Package
2022-11-16, 13071👍, 0💬
Popular Posts:
JDK 17 java.base.jmod is the JMOD file for JDK 17 Base module. JDK 17 Base module compiled class fil...
The Jakarta-ORO Java classes are a set of text-processing Java classes that provide Perl5 compatible...
kernel.jar is a component in iText Java library to provide low-level functionalities. iText Java lib...
How to download and install xml-commons External Source Package? The source package contains Java so...
How to read XML document from socket connections with the socket\DelayedInput.java provided in the A...