reiseburo
/
verspaetung
mirror of https://github.com/reiseburo/verspaetung
1
0
Fork 0
Code Issues Releases Wiki Activity
verspaetung/groovydoc/index-all.html

566 lines
34 KiB
HTML
Raw Blame History

<!--
Copyright 2003-2015 the original author or authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
-->
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<!-- Generated by groovydoc (2.4.3) on -->
<title>Index (verspaetung 0.3.0 API)</title>
<meta name="date" content="2015-07-04">
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
</head>
<body class="center">
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
parent.document.title="Index (verspaetung 0.3.0 API)";
}
//-->
</script>
<noscript>
<div>JavaScript is disabled on your browser.</div>
</noscript>
<!-- ========= START OF TOP NAVBAR ======= -->
<div class="topNav"><a name="navbar_top">
<!-- -->
</a><a href="#skip-navbar_top" title="Skip navigation links"></a><a name="navbar_top_firstrow">
<!-- -->
</a>
<ul class="navList" title="Navigation">
<li><a href="overview-summary.html">Overview</a></li>
<li>Package</li>
<li>Class</li>
<li><a href="deprecated-list.html">Deprecated</a></li>
<li class="navBarCell1Rev">Index</li>
<li><a href="help-doc.html">Help</a></li>
</ul>
</div>
<div class="subNav">
<ul class="navList">
<li><a href="./index.html?index-all.html" target="_top">Frames</a></li>
<li><a href="index-all.html" target="_top">No Frames</a></li>
</ul>
<a name="skip-navbar_top">
<!-- -->
</a></div>
<!-- ========= END OF TOP NAVBAR ========= -->
<div class="contentContainer">
<a href="#_A_">A</a>
<a href="#_B_">B</a>
<a href="#_C_">C</a>
<a href="#_D_">D</a>
<a href="#_E_">E</a>
<a href="#_F_">F</a>
<a href="#_G_">G</a>
<a href="#_H_">H</a>
<a href="#_I_">I</a>
<a href="#_J_">J</a>
<a href="#_K_">K</a>
<a href="#_L_">L</a>
<a href="#_M_">M</a>
<a href="#_N_">N</a>
<a href="#_O_">O</a>
<a href="#_P_">P</a>
<a href="#_Q_">Q</a>
<a href="#_R_">R</a>
<a href="#_S_">S</a>
<a href="#_T_">T</a>
<a href="#_U_">U</a>
<a href="#_V_">V</a>
<a href="#_W_">W</a>
<a href="#_X_">X</a>
<a href="#_Y_">Y</a>
<a href="#_Z_">Z</a>
<a href="#___">_</a>
<a name="_A_"><!-- --></a>
<h2 class="title">A</h2>
<dl>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcher.html" title="Class in com.github.lookout.verspaetung.zk">AbstractConsumerTreeWatcher</a></span> - Class in <a href="./com/github/lookout/verspaetung/zk/package-summary.html">com.github.lookout.verspaetung.zk</a>
</dt><dd><div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcher.html#AbstractConsumerTreeWatcher(org.apache.curator.framework.CuratorFramework, java.util.AbstractSet, java.util.AbstractMap)" title="Constructor in AbstractConsumerTreeWatcher">AbstractConsumerTreeWatcher(CuratorFramework, AbstractSet, AbstractMap)</a></span> - Constructor in <a href="com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcher.html">AbstractConsumerTreeWatcher</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/AbstractTreeWatcher.html" title="Class in com.github.lookout.verspaetung.zk">AbstractTreeWatcher</a></span> - Class in <a href="./com/github/lookout/verspaetung/zk/package-summary.html">com.github.lookout.verspaetung.zk</a>
</dt><dd><div class="block">AbstractTreeWatcher defines the contract and base components for the various
Zookeeper tree watchers Verspaetung needs. </div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/AbstractTreeWatcher.html#AbstractTreeWatcher(org.apache.curator.framework.CuratorFramework)" title="Constructor in AbstractTreeWatcher">AbstractTreeWatcher(CuratorFramework)</a></span> - Constructor in <a href="com/github/lookout/verspaetung/zk/AbstractTreeWatcher.html">AbstractTreeWatcher</a>
</dt><dd> <div class="block"></div></dd>
</dl>
<a name="_B_"><!-- --></a>
<h2 class="title">B</h2>
<dl>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/BrokerTreeWatcher.html#brokerIdFromPath(java.lang.String)" title="Method in BrokerTreeWatcher">brokerIdFromPath(String)</a></span> - Method in <a href="com/github/lookout/verspaetung/zk/BrokerTreeWatcher.html">BrokerTreeWatcher</a>
</dt><dd> <div class="block">Process a path string from Zookeeper for the Kafka broker's ID</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/BrokerTreeWatcher.html" title="Class in com.github.lookout.verspaetung.zk">BrokerTreeWatcher</a></span> - Class in <a href="./com/github/lookout/verspaetung/zk/package-summary.html">com.github.lookout.verspaetung.zk</a>
</dt><dd><div class="block">The BrokerTreeWatcher is a kind of watcher whose sole purpose is
to watch the segment of the Zookeeper tree where Kafka stores broker
information</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/BrokerTreeWatcher.html#BrokerTreeWatcher(org.apache.curator.framework.CuratorFramework)" title="Constructor in BrokerTreeWatcher">BrokerTreeWatcher(CuratorFramework)</a></span> - Constructor in <a href="com/github/lookout/verspaetung/zk/BrokerTreeWatcher.html">BrokerTreeWatcher</a>
</dt><dd> <div class="block"></div></dd>
</dl>
<a name="_C_"><!-- --></a>
<h2 class="title">C</h2>
<dl>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/AbstractTreeWatcher.html#cache" title="Field in AbstractTreeWatcher">cache</a></span> - Field in <a href="com/github/lookout/verspaetung/zk/AbstractTreeWatcher.html">AbstractTreeWatcher</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/KafkaPoller.html#captureLatestOffsetFor(com.github.lookout.verspaetung.TopicPartition, java.lang.Object)" title="Method in KafkaPoller">captureLatestOffsetFor(TopicPartition, Object)</a></span> - Method in <a href="com/github/lookout/verspaetung/KafkaPoller.html">KafkaPoller</a>
</dt><dd> <div class="block">Fetch the leader metadata and update our data structures</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcher.html#childEvent(org.apache.curator.framework.CuratorFramework, org.apache.curator.framework.recipes.cache.TreeCacheEvent)" title="Method in AbstractConsumerTreeWatcher">childEvent(CuratorFramework, TreeCacheEvent)</a></span> - Method in <a href="com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcher.html">AbstractConsumerTreeWatcher</a>
</dt><dd> <div class="block">Primary TreeCache event processing callback</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/AbstractTreeWatcher.html#childEvent(org.apache.curator.framework.CuratorFramework, org.apache.curator.framework.recipes.cache.TreeCacheEvent)" title="Method in AbstractTreeWatcher">childEvent(CuratorFramework, TreeCacheEvent)</a></span> - Method in <a href="com/github/lookout/verspaetung/zk/AbstractTreeWatcher.html">AbstractTreeWatcher</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/BrokerTreeWatcher.html#childEvent(org.apache.curator.framework.CuratorFramework, org.apache.curator.framework.recipes.cache.TreeCacheEvent)" title="Method in BrokerTreeWatcher">childEvent(CuratorFramework, TreeCacheEvent)</a></span> - Method in <a href="com/github/lookout/verspaetung/zk/BrokerTreeWatcher.html">BrokerTreeWatcher</a>
</dt><dd> <div class="block">Process events like NODE_ADDED and NODE_REMOVED to keep an up to date
list of brokers</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/AbstractTreeWatcher.html#client" title="Field in AbstractTreeWatcher">client</a></span> - Field in <a href="com/github/lookout/verspaetung/zk/AbstractTreeWatcher.html">AbstractTreeWatcher</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/metrics/ConsumerGauge.html#consumer" title="Field in ConsumerGauge">consumer</a></span> - Field in <a href="com/github/lookout/verspaetung/metrics/ConsumerGauge.html">ConsumerGauge</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/metrics/ConsumerGauge.html" title="Class in com.github.lookout.verspaetung.metrics">ConsumerGauge</a></span> - Class in <a href="./com/github/lookout/verspaetung/metrics/package-summary.html">com.github.lookout.verspaetung.metrics</a>
</dt><dd><div class="block">Dropwizard Metrics Gauge for reporting the value of a given KafkaConsumer</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/metrics/ConsumerGauge.html#ConsumerGauge(com.github.lookout.verspaetung.KafkaConsumer, AbstractMap<KafkaConsumer, Integer>, AbstractMap<TopicPartition, Long>)" title="Constructor in ConsumerGauge">ConsumerGauge(KafkaConsumer, AbstractMap&lt;KafkaConsumer, Integer&gt;, AbstractMap&lt;TopicPartition, Long&gt;)</a></span> - Constructor in <a href="com/github/lookout/verspaetung/metrics/ConsumerGauge.html">ConsumerGauge</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/KafkaSpoutTreeWatcher.html#consumerNameFromPath(java.lang.String)" title="Method in KafkaSpoutTreeWatcher">consumerNameFromPath(String)</a></span> - Method in <a href="com/github/lookout/verspaetung/zk/KafkaSpoutTreeWatcher.html">KafkaSpoutTreeWatcher</a>
</dt><dd> <div class="block">Extract the given name for a KafkaSpout consumer based on the path in
Zookeeper</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/ConsumerOffset.html" title="Class in com.github.lookout.verspaetung.zk">ConsumerOffset</a></span> - Class in <a href="./com/github/lookout/verspaetung/zk/package-summary.html">com.github.lookout.verspaetung.zk</a>
</dt><dd><div class="block">POJO representing data from Zookeeper for a consumer, topic and offset</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/ConsumerOffset.html#ConsumerOffset(java.lang.String, java.lang.Integer, java.lang.Integer)" title="Constructor in ConsumerOffset">ConsumerOffset(String, Integer, Integer)</a></span> - Constructor in <a href="com/github/lookout/verspaetung/zk/ConsumerOffset.html">ConsumerOffset</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcher.html#consumerOffsets" title="Field in AbstractConsumerTreeWatcher">consumerOffsets</a></span> - Field in <a href="com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcher.html">AbstractConsumerTreeWatcher</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/metrics/ConsumerGauge.html#consumers" title="Field in ConsumerGauge">consumers</a></span> - Field in <a href="com/github/lookout/verspaetung/metrics/ConsumerGauge.html">ConsumerGauge</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/Main.html#createCLI()" title="Method in Main">createCLI()</a></span> - Method in <a href="com/github/lookout/verspaetung/Main.html">Main</a>
</dt><dd> <div class="block">Create the Options option necessary for verspaetung to have CLI options</div></dd>
</dl>
<a name="_D_"><!-- --></a>
<h2 class="title">D</h2>
<dl>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/KafkaPoller.html#die()" title="Method in KafkaPoller">die()</a></span> - Method in <a href="com/github/lookout/verspaetung/KafkaPoller.html">KafkaPoller</a>
</dt><dd> <div class="block">Signal the runloop to safely die after it's next iteration</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/KafkaPoller.html#dumpMetadata()" title="Method in KafkaPoller">dumpMetadata()</a></span> - Method in <a href="com/github/lookout/verspaetung/KafkaPoller.html">KafkaPoller</a>
</dt><dd> <div class="block"></div></dd>
</dl>
<a name="_E_"><!-- --></a>
<h2 class="title">E</h2>
<dl>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/KafkaConsumer.html#equals(java.lang.Object)" title="Method in KafkaConsumer">equals(Object)</a></span> - Method in <a href="com/github/lookout/verspaetung/KafkaConsumer.html">KafkaConsumer</a>
</dt><dd> <div class="block">Return true for any two KafkaConsumer instances which have the same
topic, partition and name properties</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/TopicPartition.html#equals(java.lang.Object)" title="Method in TopicPartition">equals(Object)</a></span> - Method in <a href="com/github/lookout/verspaetung/TopicPartition.html">TopicPartition</a>
</dt><dd> <div class="block">Return true for any two TopicPartition instances that have equal topic
and partition properties</div></dd>
</dl>
<a name="_F_"><!-- --></a>
<h2 class="title">F</h2>
<dl>
</dl>
<a name="_G_"><!-- --></a>
<h2 class="title">G</h2>
<dl>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/metrics/ConsumerGauge.html#getName()" title="Method in ConsumerGauge">getName()</a></span> - Method in <a href="com/github/lookout/verspaetung/metrics/ConsumerGauge.html">ConsumerGauge</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/metrics/ConsumerGauge.html#getNameForRegistry()" title="Method in ConsumerGauge">getNameForRegistry()</a></span> - Method in <a href="com/github/lookout/verspaetung/metrics/ConsumerGauge.html">ConsumerGauge</a>
</dt><dd> <div class="block">return a unique name for this gauge</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/metrics/ConsumerGauge.html#getTags()" title="Method in ConsumerGauge">getTags()</a></span> - Method in <a href="com/github/lookout/verspaetung/metrics/ConsumerGauge.html">ConsumerGauge</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/metrics/ConsumerGauge.html#getValue()" title="Method in ConsumerGauge">getValue()</a></span> - Method in <a href="com/github/lookout/verspaetung/metrics/ConsumerGauge.html">ConsumerGauge</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/metrics/HeartbeatGauge.html#getValue()" title="Method in HeartbeatGauge">getValue()</a></span> - Method in <a href="com/github/lookout/verspaetung/metrics/HeartbeatGauge.html">HeartbeatGauge</a>
</dt><dd> <div class="block"></div></dd>
</dl>
<a name="_H_"><!-- --></a>
<h2 class="title">H</h2>
<dl>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/KafkaConsumer.html#hashCode()" title="Method in KafkaConsumer">hashCode()</a></span> - Method in <a href="com/github/lookout/verspaetung/KafkaConsumer.html">KafkaConsumer</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/TopicPartition.html#hashCode()" title="Method in TopicPartition">hashCode()</a></span> - Method in <a href="com/github/lookout/verspaetung/TopicPartition.html">TopicPartition</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/metrics/HeartbeatGauge.html" title="Class in com.github.lookout.verspaetung.metrics">HeartbeatGauge</a></span> - Class in <a href="./com/github/lookout/verspaetung/metrics/package-summary.html">com.github.lookout.verspaetung.metrics</a>
</dt><dd><div class="block">A simple gauge that will always just return 1 indicating that the process is
alive</div></dd>
</dl>
<a name="_I_"><!-- --></a>
<h2 class="title">I</h2>
<dl>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcher.html#isNodeEvent(org.apache.curator.framework.recipes.cache.TreeCacheEvent)" title="Method in AbstractConsumerTreeWatcher">isNodeEvent(TreeCacheEvent)</a></span> - Method in <a href="com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcher.html">AbstractConsumerTreeWatcher</a>
</dt><dd> <div class="block">Return true if the TreeCacheEvent received pertains to a node event that
we're interested in</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcher.html#isOffsetSubtree(java.lang.String)" title="Method in AbstractConsumerTreeWatcher">isOffsetSubtree(String)</a></span> - Method in <a href="com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcher.html">AbstractConsumerTreeWatcher</a>
</dt><dd> <div class="block">Determine whether a given path is of interest, i.e. path which contains
offset data</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/KafkaSpoutTreeWatcher.html#isOffsetSubtree(java.lang.String)" title="Method in KafkaSpoutTreeWatcher">isOffsetSubtree(String)</a></span> - Method in <a href="com/github/lookout/verspaetung/zk/KafkaSpoutTreeWatcher.html">KafkaSpoutTreeWatcher</a>
</dt><dd> <div class="block">We're expecting things to look like:
/kafka_spout/topologyname/partition_0</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/StandardTreeWatcher.html#isOffsetSubtree(java.lang.String)" title="Method in StandardTreeWatcher">isOffsetSubtree(String)</a></span> - Method in <a href="com/github/lookout/verspaetung/zk/StandardTreeWatcher.html">StandardTreeWatcher</a>
</dt><dd> <div class="block"></div></dd>
</dl>
<a name="_J_"><!-- --></a>
<h2 class="title">J</h2>
<dl>
</dl>
<a name="_K_"><!-- --></a>
<h2 class="title">K</h2>
<dl>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/KafkaBroker.html" title="Class in com.github.lookout.verspaetung">KafkaBroker</a></span> - Class in <a href="./com/github/lookout/verspaetung/package-summary.html">com.github.lookout.verspaetung</a>
</dt><dd><div class="block">POJO containing the necessary information to model a Kafka broker</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/KafkaBroker.html#KafkaBroker(java.lang.Object, java.lang.Integer)" title="Constructor in KafkaBroker">KafkaBroker(Object, Integer)</a></span> - Constructor in <a href="com/github/lookout/verspaetung/KafkaBroker.html">KafkaBroker</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/KafkaConsumer.html" title="Class in com.github.lookout.verspaetung">KafkaConsumer</a></span> - Class in <a href="./com/github/lookout/verspaetung/package-summary.html">com.github.lookout.verspaetung</a>
</dt><dd><div class="block">POJO containing the necessary information to model a Kafka consumers</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/KafkaConsumer.html#KafkaConsumer(java.lang.String, java.lang.Integer, java.lang.String)" title="Constructor in KafkaConsumer">KafkaConsumer(String, Integer, String)</a></span> - Constructor in <a href="com/github/lookout/verspaetung/KafkaConsumer.html">KafkaConsumer</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/KafkaPoller.html" title="Class in com.github.lookout.verspaetung">KafkaPoller</a></span> - Class in <a href="./com/github/lookout/verspaetung/package-summary.html">com.github.lookout.verspaetung</a>
</dt><dd><div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/KafkaPoller.html#KafkaPoller(java.util.AbstractMap, java.util.AbstractSet)" title="Constructor in KafkaPoller">KafkaPoller(AbstractMap, AbstractSet)</a></span> - Constructor in <a href="com/github/lookout/verspaetung/KafkaPoller.html">KafkaPoller</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/KafkaSpoutTreeWatcher.html" title="Class in com.github.lookout.verspaetung.zk">KafkaSpoutTreeWatcher</a></span> - Class in <a href="./com/github/lookout/verspaetung/zk/package-summary.html">com.github.lookout.verspaetung.zk</a>
</dt><dd><div class="block">KafkaSpoutTreeWatcher process Zookeeper paths normally associated with Storm
KafkaSpout based consumers</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/KafkaSpoutTreeWatcher.html#KafkaSpoutTreeWatcher(org.apache.curator.framework.CuratorFramework, java.util.AbstractSet, java.util.AbstractMap)" title="Constructor in KafkaSpoutTreeWatcher">KafkaSpoutTreeWatcher(CuratorFramework, AbstractSet, AbstractMap)</a></span> - Constructor in <a href="com/github/lookout/verspaetung/zk/KafkaSpoutTreeWatcher.html">KafkaSpoutTreeWatcher</a>
</dt><dd> <div class="block"></div></dd>
</dl>
<a name="_L_"><!-- --></a>
<h2 class="title">L</h2>
<dl>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/KafkaPoller.html#latestFromLeader(java.lang.Integer, java.lang.String, java.lang.Integer)" title="Method in KafkaPoller">latestFromLeader(Integer, String, Integer)</a></span> - Method in <a href="com/github/lookout/verspaetung/KafkaPoller.html">KafkaPoller</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/AbstractTreeWatcher.html#logger" title="Field in AbstractTreeWatcher">logger</a></span> - Field in <a href="com/github/lookout/verspaetung/zk/AbstractTreeWatcher.html">AbstractTreeWatcher</a>
</dt><dd> <div class="block"></div></dd>
</dl>
<a name="_M_"><!-- --></a>
<h2 class="title">M</h2>
<dl>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/Main.html" title="Class in com.github.lookout.verspaetung">Main</a></span> - Class in <a href="./com/github/lookout/verspaetung/package-summary.html">com.github.lookout.verspaetung</a>
</dt><dd><div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/Main.html#main(java.lang.String)" title="Method in Main">main(String)</a></span> - Method in <a href="com/github/lookout/verspaetung/Main.html">Main</a>
</dt><dd> <div class="block"></div></dd>
</dl>
<a name="_N_"><!-- --></a>
<h2 class="title">N</h2>
<dl>
</dl>
<a name="_O_"><!-- --></a>
<h2 class="title">O</h2>
<dl>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcher.html#onConsumerData" title="Field in AbstractConsumerTreeWatcher">onConsumerData</a></span> - Field in <a href="com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcher.html">AbstractConsumerTreeWatcher</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/AbstractTreeWatcher.html#onInitComplete" title="Field in AbstractTreeWatcher">onInitComplete</a></span> - Field in <a href="com/github/lookout/verspaetung/zk/AbstractTreeWatcher.html">AbstractTreeWatcher</a>
</dt><dd> <div class="block"></div></dd>
</dl>
<a name="_P_"><!-- --></a>
<h2 class="title">P</h2>
<dl>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/Main.html#parseCommandLine(java.lang.String)" title="Method in Main">parseCommandLine(String)</a></span> - Method in <a href="com/github/lookout/verspaetung/Main.html">Main</a>
</dt><dd> <div class="block">Parse out all the command line options from the array of string
arguments</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcher.html#processChildData(org.apache.curator.framework.recipes.cache.ChildData)" title="Method in AbstractConsumerTreeWatcher">processChildData(ChildData)</a></span> - Method in <a href="com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcher.html">AbstractConsumerTreeWatcher</a>
</dt><dd> <div class="block">Process the ChildData associated with an event</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/KafkaSpoutTreeWatcher.html#processChildData(org.apache.curator.framework.recipes.cache.ChildData)" title="Method in KafkaSpoutTreeWatcher">processChildData(ChildData)</a></span> - Method in <a href="com/github/lookout/verspaetung/zk/KafkaSpoutTreeWatcher.html">KafkaSpoutTreeWatcher</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/StandardTreeWatcher.html#processChildData(org.apache.curator.framework.recipes.cache.ChildData)" title="Method in StandardTreeWatcher">processChildData(ChildData)</a></span> - Method in <a href="com/github/lookout/verspaetung/zk/StandardTreeWatcher.html">StandardTreeWatcher</a>
</dt><dd> <div class="block">Extract the necessary information from a standard (i.e. high-level Kafka
consumer) tree of offsets</div></dd>
</dl>
<a name="_Q_"><!-- --></a>
<h2 class="title">Q</h2>
<dl>
</dl>
<a name="_R_"><!-- --></a>
<h2 class="title">R</h2>
<dl>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/KafkaPoller.html#reconnect()" title="Method in KafkaPoller">reconnect()</a></span> - Method in <a href="com/github/lookout/verspaetung/KafkaPoller.html">KafkaPoller</a>
</dt><dd> <div class="block">Blocking reconnect to the Kafka brokers</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/KafkaPoller.html#refresh(List<KafkaBroker>)" title="Method in KafkaPoller">refresh(List&lt;KafkaBroker&gt;)</a></span> - Method in <a href="com/github/lookout/verspaetung/KafkaPoller.html">KafkaPoller</a>
</dt><dd> <div class="block">Store a new list of KafkaBroker objects and signal a reconnection</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/Main.html#registerMetricFor(com.github.lookout.verspaetung.KafkaConsumer, ConcurrentHashMap<KafkaConsumer, ConsumerGauge>, ConcurrentHashMap<KafkaConsumer, Integer>, ConcurrentHashMap<TopicPartition, Long>)" title="Method in Main">registerMetricFor(KafkaConsumer, ConcurrentHashMap&lt;KafkaConsumer, ConsumerGauge&gt;, ConcurrentHashMap&lt;KafkaConsumer, Integer&gt;, ConcurrentHashMap&lt;TopicPartition, Long&gt;)</a></span> - Method in <a href="com/github/lookout/verspaetung/Main.html">Main</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/KafkaPoller.html#run()" title="Method in KafkaPoller">run()</a></span> - Method in <a href="com/github/lookout/verspaetung/KafkaPoller.html">KafkaPoller</a>
</dt><dd> <div class="block"></div></dd>
</dl>
<a name="_S_"><!-- --></a>
<h2 class="title">S</h2>
<dl>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/StandardTreeWatcher.html" title="Class in com.github.lookout.verspaetung.zk">StandardTreeWatcher</a></span> - Class in <a href="./com/github/lookout/verspaetung/zk/package-summary.html">com.github.lookout.verspaetung.zk</a>
</dt><dd><div class="block">StandardTreeWatcher processes Zookeeper paths for standard high-level Kafka
consumers</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/AbstractTreeWatcher.html#start()" title="Method in AbstractTreeWatcher">start()</a></span> - Method in <a href="com/github/lookout/verspaetung/zk/AbstractTreeWatcher.html">AbstractTreeWatcher</a>
</dt><dd> <div class="block">Start our internal cache and return ourselves for API cleanliness</div></dd>
</dl>
<a name="_T_"><!-- --></a>
<h2 class="title">T</h2>
<dl>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/TopicPartition.html" title="Class in com.github.lookout.verspaetung">TopicPartition</a></span> - Class in <a href="./com/github/lookout/verspaetung/package-summary.html">com.github.lookout.verspaetung</a>
</dt><dd><div class="block">Simple container for Kafka topic names and partition IDs</div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/TopicPartition.html#TopicPartition(java.lang.String, java.lang.Integer)" title="Constructor in TopicPartition">TopicPartition(String, Integer)</a></span> - Constructor in <a href="com/github/lookout/verspaetung/TopicPartition.html">TopicPartition</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/metrics/ConsumerGauge.html#topics" title="Field in ConsumerGauge">topics</a></span> - Field in <a href="com/github/lookout/verspaetung/metrics/ConsumerGauge.html">ConsumerGauge</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/ConsumerOffset.html#toString()" title="Method in ConsumerOffset">toString()</a></span> - Method in <a href="com/github/lookout/verspaetung/zk/ConsumerOffset.html">ConsumerOffset</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/KafkaBroker.html#toString()" title="Method in KafkaBroker">toString()</a></span> - Method in <a href="com/github/lookout/verspaetung/KafkaBroker.html">KafkaBroker</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/KafkaConsumer.html#toString()" title="Method in KafkaConsumer">toString()</a></span> - Method in <a href="com/github/lookout/verspaetung/KafkaConsumer.html">KafkaConsumer</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/TopicPartition.html#toString()" title="Method in TopicPartition">toString()</a></span> - Method in <a href="com/github/lookout/verspaetung/TopicPartition.html">TopicPartition</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcher.html#trackConsumerOffset(com.github.lookout.verspaetung.zk.ConsumerOffset)" title="Method in AbstractConsumerTreeWatcher">trackConsumerOffset(ConsumerOffset)</a></span> - Method in <a href="com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcher.html">AbstractConsumerTreeWatcher</a>
</dt><dd> <div class="block">Keep track of a ConsumerOffset in the consumersMap that was passed into
this class on instantiation</div></dd>
</dl>
<a name="_U_"><!-- --></a>
<h2 class="title">U</h2>
<dl>
</dl>
<a name="_V_"><!-- --></a>
<h2 class="title">V</h2>
<dl>
</dl>
<a name="_W_"><!-- --></a>
<h2 class="title">W</h2>
<dl>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcher.html#watchedTopics" title="Field in AbstractConsumerTreeWatcher">watchedTopics</a></span> - Field in <a href="com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcher.html">AbstractConsumerTreeWatcher</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/KafkaPoller.html#withScalaCollection(scala.collection.Iterable)" title="Method in KafkaPoller">withScalaCollection(Iterable)</a></span> - Method in <a href="com/github/lookout/verspaetung/KafkaPoller.html">KafkaPoller</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/KafkaPoller.html#withTopicsAndPartitions(java.lang.Object, groovy.lang.Closure)" title="Method in KafkaPoller">withTopicsAndPartitions(Object, Closure)</a></span> - Method in <a href="com/github/lookout/verspaetung/KafkaPoller.html">KafkaPoller</a>
</dt><dd> <div class="block">Invoke the given closure with the TopicPartition and Partition meta-data
informationn for all of the topic meta-data that was passed in.</div></dd>
</dl>
<a name="_X_"><!-- --></a>
<h2 class="title">X</h2>
<dl>
</dl>
<a name="_Y_"><!-- --></a>
<h2 class="title">Y</h2>
<dl>
</dl>
<a name="_Z_"><!-- --></a>
<h2 class="title">Z</h2>
<dl>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/AbstractTreeWatcher.html#zookeeperPath()" title="Method in AbstractTreeWatcher">zookeeperPath()</a></span> - Method in <a href="com/github/lookout/verspaetung/zk/AbstractTreeWatcher.html">AbstractTreeWatcher</a>
</dt><dd> <div class="block">Return the String of the path in Zookeeper this class should watch. </div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/BrokerTreeWatcher.html#zookeeperPath()" title="Method in BrokerTreeWatcher">zookeeperPath()</a></span> - Method in <a href="com/github/lookout/verspaetung/zk/BrokerTreeWatcher.html">BrokerTreeWatcher</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/KafkaSpoutTreeWatcher.html#zookeeperPath()" title="Method in KafkaSpoutTreeWatcher">zookeeperPath()</a></span> - Method in <a href="com/github/lookout/verspaetung/zk/KafkaSpoutTreeWatcher.html">KafkaSpoutTreeWatcher</a>
</dt><dd> <div class="block"></div></dd>
<dt><span class="strong"><a href="com/github/lookout/verspaetung/zk/StandardTreeWatcher.html#zookeeperPath()" title="Method in StandardTreeWatcher">zookeeperPath()</a></span> - Method in <a href="com/github/lookout/verspaetung/zk/StandardTreeWatcher.html">StandardTreeWatcher</a>
</dt><dd> <div class="block"></div></dd>
</dl>
<a name="___"><!-- --></a>
<h2 class="title">_</h2>
<dl>
</dl>
</div>
<a href="#_A_">A</a>
<a href="#_B_">B</a>
<a href="#_C_">C</a>
<a href="#_D_">D</a>
<a href="#_E_">E</a>
<a href="#_F_">F</a>
<a href="#_G_">G</a>
<a href="#_H_">H</a>
<a href="#_I_">I</a>
<a href="#_J_">J</a>
<a href="#_K_">K</a>
<a href="#_L_">L</a>
<a href="#_M_">M</a>
<a href="#_N_">N</a>
<a href="#_O_">O</a>
<a href="#_P_">P</a>
<a href="#_Q_">Q</a>
<a href="#_R_">R</a>
<a href="#_S_">S</a>
<a href="#_T_">T</a>
<a href="#_U_">U</a>
<a href="#_V_">V</a>
<a href="#_W_">W</a>
<a href="#_X_">X</a>
<a href="#_Y_">Y</a>
<a href="#_Z_">Z</a>
<a href="#___">_</a>
<!-- ======= START OF BOTTOM NAVBAR ====== -->
<div class="bottomNav"><a name="navbar_bottom">
<!-- -->
</a><a href="#skip-navbar_bottom" title="Skip navigation links"></a><a name="navbar_bottom_firstrow">
<!-- -->
</a>
<ul class="navList" title="Navigation">
<li><a href="overview-summary.html">Overview</a></li>
<li>Package</li>
<li>Class</li>
<li><a href="deprecated-list.html">Deprecated</a></li>
<li class="navBarCell1Rev">Index</li>
<li><a href="help-doc.html">Help</a></li>
</ul>
</div>
<div class="subNav">
<ul class="navList">
<li><a href="./index.html?index-all.html" target="_top">Frames</a></li>
<li><a href="index-all.html" target="_top">No Frames</a></li>
</ul>
<div class="aboutLanguage"><em>Groovy Documentation</em></div>
<a name="skip-navbar_bottom">
<!-- -->
</a></div>
<!-- ======== END OF BOTTOM NAVBAR ======= -->
</body>
</html>
Reference in New Issue View Git Blame Copy Permalink