From 89d029d8de9dfb422623e667a3f7d3bdaa13d7ac Mon Sep 17 00:00:00 2001 From: "R. Tyler Croy" Date: Sat, 7 Nov 2015 13:25:14 -0800 Subject: [PATCH] Publish of Github pages from Gradle. --- groovydoc/allclasses-frame.html | 27 +- .../github/reiseburo/verspaetung/Delay.html | 343 ++++++++++++++++++ .../verspaetung/KafkaBroker.html | 16 +- .../verspaetung/KafkaConsumer.html | 16 +- .../verspaetung/KafkaPoller.html | 116 +----- .../verspaetung/Main.html | 39 +- .../verspaetung/TopicPartition.html | 16 +- .../verspaetung/metrics/ConsumerGauge.html | 36 +- .../verspaetung/metrics/HeartbeatGauge.html | 16 +- .../verspaetung/metrics/package-frame.html | 8 +- .../verspaetung/metrics/package-summary.html | 14 +- .../verspaetung/package-frame.html | 8 +- .../verspaetung/package-summary.html | 35 +- .../zk/AbstractConsumerTreeWatcher.html | 45 +-- .../verspaetung/zk/AbstractTreeWatcher.html | 43 ++- .../verspaetung/zk/BrokerTreeWatcher.html | 24 +- .../verspaetung/zk/ConsumerOffset.html | 102 +++++- .../verspaetung/zk/KafkaSpoutTreeWatcher.html | 37 +- .../verspaetung/zk/StandardTreeWatcher.html | 37 +- .../verspaetung/zk/package-frame.html | 8 +- .../verspaetung/zk/package-summary.html | 22 +- groovydoc/deprecated-list.html | 6 +- groovydoc/help-doc.html | 6 +- groovydoc/index-all.html | 182 +++++----- groovydoc/index.html | 2 +- groovydoc/overview-frame.html | 14 +- groovydoc/overview-summary.html | 12 +- groovydoc/package-list | 6 +- index.html | 15 +- 29 files changed, 826 insertions(+), 425 deletions(-) create mode 100644 groovydoc/com/github/reiseburo/verspaetung/Delay.html rename groovydoc/com/github/{lookout => reiseburo}/verspaetung/KafkaBroker.html (94%) rename groovydoc/com/github/{lookout => reiseburo}/verspaetung/KafkaConsumer.html (95%) rename groovydoc/com/github/{lookout => reiseburo}/verspaetung/KafkaPoller.html (65%) rename groovydoc/com/github/{lookout => reiseburo}/verspaetung/Main.html (73%) rename groovydoc/com/github/{lookout => reiseburo}/verspaetung/TopicPartition.html (94%) rename groovydoc/com/github/{lookout => reiseburo}/verspaetung/metrics/ConsumerGauge.html (85%) rename groovydoc/com/github/{lookout => reiseburo}/verspaetung/metrics/HeartbeatGauge.html (92%) rename groovydoc/com/github/{lookout => reiseburo}/verspaetung/metrics/package-frame.html (76%) rename groovydoc/com/github/{lookout => reiseburo}/verspaetung/metrics/package-summary.html (88%) rename groovydoc/com/github/{lookout => reiseburo}/verspaetung/package-frame.html (59%) rename groovydoc/com/github/{lookout => reiseburo}/verspaetung/package-summary.html (78%) rename groovydoc/com/github/{lookout => reiseburo}/verspaetung/zk/AbstractConsumerTreeWatcher.html (85%) rename groovydoc/com/github/{lookout => reiseburo}/verspaetung/zk/AbstractTreeWatcher.html (88%) rename groovydoc/com/github/{lookout => reiseburo}/verspaetung/zk/BrokerTreeWatcher.html (89%) rename groovydoc/com/github/{lookout => reiseburo}/verspaetung/zk/ConsumerOffset.html (66%) rename groovydoc/com/github/{lookout => reiseburo}/verspaetung/zk/KafkaSpoutTreeWatcher.html (80%) rename groovydoc/com/github/{lookout => reiseburo}/verspaetung/zk/StandardTreeWatcher.html (75%) rename groovydoc/com/github/{lookout => reiseburo}/verspaetung/zk/package-frame.html (58%) rename groovydoc/com/github/{lookout => reiseburo}/verspaetung/zk/package-summary.html (88%) diff --git a/groovydoc/allclasses-frame.html b/groovydoc/allclasses-frame.html index 219d5e4..995c298 100644 --- a/groovydoc/allclasses-frame.html +++ b/groovydoc/allclasses-frame.html @@ -29,19 +29,20 @@

All Classes

diff --git a/groovydoc/com/github/reiseburo/verspaetung/Delay.html b/groovydoc/com/github/reiseburo/verspaetung/Delay.html new file mode 100644 index 0000000..22b800c --- /dev/null +++ b/groovydoc/com/github/reiseburo/verspaetung/Delay.html @@ -0,0 +1,343 @@ + + + + + + + + + + + Delay (verspaetung 0.5.0 API) + + + + + + + + + + +
+ + + + + +
+ +
+
+ +
+
+
    +
  • Summary: 
    • + Nested   Field   
  • Property
    •    Constructor   
  • Method
    •     +
+
    +
  •  | Detail: 
    • + Field   
  • Property
    •    Constructor   
  • Method
    •     +
+
+ + +
+ + + +
+ +
Package: com.github.reiseburo.verspaetung
+ +

[Groovy] Class Delay

+
+
+ +
+
    +
  • + + + +

    abstract the logic on how to reduce the polling speed and get back to + to full speed. +

    + +
    • +
+
+ +
+
    +
  • + + + + + + + + + + +
      +
    • +

      Properties Summary

      +
        + + + + + + + + + + + + + + + + + +
        Properties 
        TypeName and description
        static java.lang.Integer POLLER_DELAY_MAX
        static java.lang.Integer POLLER_DELAY_MIN
        +
      +
      • +
    + + + + + + + + + +
      + +
    • +

      Methods Summary

      +
        + + + + + + + + + + + + + + + + + + + + + + + + + + + +
        Methods 
        TypeName and description
        booleanreset()
        booleanslower()
        java.lang.StringtoString()
        java.lang.Integervalue()
        +
      +
      • + +
    • +

      Inherited Methods Summary

      +
        + + + + + + + + + + + +
        Inherited Methods 
        Methods inherited from className
        class java.lang.Objectjava.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#wait(), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()
        +
      +
      • + +
    + +
    • +
+
+ +
+
    +
  • + + + + + + +
      +
    • + + +

      Property Detail

      + + +
        +
      • +

        static final java.lang.Integer POLLER_DELAY_MAX

        +

        +
        • +
      + + +
        +
      • +

        static final java.lang.Integer POLLER_DELAY_MIN

        +

        +
        • +
      + +
      • +
    + + + + + + + + + +
      +
    • + + +

      Method Detail

      + + +
        +
      • +

        boolean reset()

        +

        +
        • +
      + + +
        +
      • +

        boolean slower()

        +

        +
        • +
      + + +
        +
      • +

        java.lang.String toString()

        +

        +
        • +
      + + +
        +
      • +

        java.lang.Integer value()

        +

        +
        • +
      + +
      • +
    + +
    • +
+
+ + + +
+ + + + + +
+ +
+
+ +
+
+
    +
  • Summary: 
    • + Nested   Field   
  • Property
    •    Constructor   
  • Method
    •     +
+
    +
  •  | Detail: 
    • + Field   
  • Property
    •    Constructor   
  • Method
    •     +
+
+

Groovy Documentation

+ + + +
+
+ + + diff --git a/groovydoc/com/github/lookout/verspaetung/KafkaBroker.html b/groovydoc/com/github/reiseburo/verspaetung/KafkaBroker.html similarity index 94% rename from groovydoc/com/github/lookout/verspaetung/KafkaBroker.html rename to groovydoc/com/github/reiseburo/verspaetung/KafkaBroker.html index 8239456..c09c61f 100644 --- a/groovydoc/com/github/lookout/verspaetung/KafkaBroker.html +++ b/groovydoc/com/github/reiseburo/verspaetung/KafkaBroker.html @@ -23,9 +23,9 @@ - - KafkaBroker (verspaetung 0.3.0 API) - + + KafkaBroker (verspaetung 0.5.0 API) + @@ -34,7 +34,7 @@ @@ -60,7 +60,7 @@ if (location.href.indexOf('is-external=true') == -1) {
@@ -82,13 +82,13 @@ if (location.href.indexOf('is-external=true') == -1) {
-
Package: com.github.lookout.verspaetung
+
Package: com.github.reiseburo.verspaetung

[Groovy] Class KafkaBroker

    -
    • com.github.lookout.verspaetung.KafkaBroker +
      • com.github.reiseburo.verspaetung.KafkaBroker
        @@ -267,7 +267,7 @@ java.lang.String toString()
        diff --git a/groovydoc/com/github/lookout/verspaetung/KafkaConsumer.html b/groovydoc/com/github/reiseburo/verspaetung/KafkaConsumer.html similarity index 95% rename from groovydoc/com/github/lookout/verspaetung/KafkaConsumer.html rename to groovydoc/com/github/reiseburo/verspaetung/KafkaConsumer.html index 3538bf4..7b76774 100644 --- a/groovydoc/com/github/lookout/verspaetung/KafkaConsumer.html +++ b/groovydoc/com/github/reiseburo/verspaetung/KafkaConsumer.html @@ -23,9 +23,9 @@ - - KafkaConsumer (verspaetung 0.3.0 API) - + + KafkaConsumer (verspaetung 0.5.0 API) + @@ -34,7 +34,7 @@ @@ -60,7 +60,7 @@ if (location.href.indexOf('is-external=true') == -1) {
        @@ -82,13 +82,13 @@ if (location.href.indexOf('is-external=true') == -1) {
        -
        Package: com.github.lookout.verspaetung
        +
        Package: com.github.reiseburo.verspaetung

        [Groovy] Class KafkaConsumer

          -
          • com.github.lookout.verspaetung.KafkaConsumer +
            • com.github.reiseburo.verspaetung.KafkaConsumer
              @@ -363,7 +363,7 @@ java.lang.String toString()
              diff --git a/groovydoc/com/github/lookout/verspaetung/KafkaPoller.html b/groovydoc/com/github/reiseburo/verspaetung/KafkaPoller.html similarity index 65% rename from groovydoc/com/github/lookout/verspaetung/KafkaPoller.html rename to groovydoc/com/github/reiseburo/verspaetung/KafkaPoller.html index f5b6394..b85ce2d 100644 --- a/groovydoc/com/github/lookout/verspaetung/KafkaPoller.html +++ b/groovydoc/com/github/reiseburo/verspaetung/KafkaPoller.html @@ -23,9 +23,9 @@ - - KafkaPoller (verspaetung 0.3.0 API) - + + KafkaPoller (verspaetung 0.5.0 API) + @@ -34,7 +34,7 @@ @@ -60,7 +60,7 @@ if (location.href.indexOf('is-external=true') == -1) {
              @@ -82,13 +82,13 @@ if (location.href.indexOf('is-external=true') == -1) {
              -
              Package: com.github.lookout.verspaetung
              +
              Package: com.github.reiseburo.verspaetung

              [Groovy] Class KafkaPoller

                -
                  • com.github.lookout.verspaetung.KafkaPoller +
                      • com.github.reiseburo.verspaetung.KafkaPoller
                        @@ -96,6 +96,11 @@ if (location.href.indexOf('is-external=true') == -1) { +

                        KafkaPoller is a relatively simple class which contains a runloop for periodically + contacting the Kafka brokers defined in Zookeeper and fetching the latest topic + meta-data for them +

                        +
                      @@ -176,33 +181,13 @@ if (location.href.indexOf('is-external=true') == -1) { - void - captureLatestOffsetFor(TopicPartition tp, java.lang.Object partitionMetadata)
                      Fetch the leader metadata and update our data structures - - - void die()
                      Signal the runloop to safely die after it's next iteration - - void - dumpMetadata()
                      - - - - java.lang.Long - latestFromLeader(java.lang.Integer leaderId, java.lang.String topic, java.lang.Integer partition)
                      - - - - void - reconnect()
                      Blocking reconnect to the Kafka brokers - - void - refresh(java.util.List<KafkaBroker> brokers)
                      Store a new list of KafkaBroker objects and signal a reconnection + refresh(java.util.List<KafkaBroker> brokers)
                      Store a new list of KafkaBroker objects and signal a reconnection @@ -210,17 +195,6 @@ if (location.href.indexOf('is-external=true') == -1) { run()
                      - - java.lang.Iterable - withScalaCollection(scala.collection.Iterable iter)
                      - - - - void - withTopicsAndPartitions(java.lang.Object metadata, groovy.lang.Closure closure)
                      Invoke the given closure with the TopicPartition and Partition meta-data - informationn for all of the topic meta-data that was passed in. - -
                    @@ -237,7 +211,7 @@ if (location.href.indexOf('is-external=true') == -1) { class java.lang.Thread - java.lang.Thread#run(), java.lang.Thread#toString(), java.lang.Thread#isInterrupted(), java.lang.Thread#currentThread(), java.lang.Thread#getName(), java.lang.Thread#start(), java.lang.Thread#getThreadGroup(), java.lang.Thread#getStackTrace(), java.lang.Thread#holdsLock(java.lang.Object), java.lang.Thread#dumpStack(), java.lang.Thread#setPriority(int), java.lang.Thread#setDaemon(boolean), java.lang.Thread#yield(), java.lang.Thread#sleep(long, int), java.lang.Thread#sleep(long), java.lang.Thread#stop(java.lang.Throwable), java.lang.Thread#stop(), java.lang.Thread#interrupt(), java.lang.Thread#interrupted(), java.lang.Thread#destroy(), java.lang.Thread#isAlive(), java.lang.Thread#suspend(), java.lang.Thread#resume(), java.lang.Thread#getPriority(), java.lang.Thread#setName(java.lang.String), java.lang.Thread#activeCount(), java.lang.Thread#enumerate([Ljava.lang.Thread;), java.lang.Thread#countStackFrames(), java.lang.Thread#join(), java.lang.Thread#join(long), java.lang.Thread#join(long, int), java.lang.Thread#isDaemon(), java.lang.Thread#checkAccess(), java.lang.Thread#getContextClassLoader(), java.lang.Thread#setContextClassLoader(java.lang.ClassLoader), java.lang.Thread#getAllStackTraces(), java.lang.Thread#getId(), java.lang.Thread#getState(), java.lang.Thread#setDefaultUncaughtExceptionHandler(java.lang.Thread$UncaughtExceptionHandler), java.lang.Thread#getDefaultUncaughtExceptionHandler(), java.lang.Thread#getUncaughtExceptionHandler(), java.lang.Thread#setUncaughtExceptionHandler(java.lang.Thread$UncaughtExceptionHandler), java.lang.Thread#wait(long, int), java.lang.Thread#wait(long), java.lang.Thread#wait(), java.lang.Thread#equals(java.lang.Object), java.lang.Thread#hashCode(), java.lang.Thread#getClass(), java.lang.Thread#notify(), java.lang.Thread#notifyAll() + java.lang.Thread#run(), java.lang.Thread#toString(), java.lang.Thread#isInterrupted(), java.lang.Thread#currentThread(), java.lang.Thread#getName(), java.lang.Thread#join(long), java.lang.Thread#join(long, int), java.lang.Thread#join(), java.lang.Thread#getThreadGroup(), java.lang.Thread#getStackTrace(), java.lang.Thread#holdsLock(java.lang.Object), java.lang.Thread#checkAccess(), java.lang.Thread#dumpStack(), java.lang.Thread#setPriority(int), java.lang.Thread#setDaemon(boolean), java.lang.Thread#start(), java.lang.Thread#yield(), java.lang.Thread#sleep(long), java.lang.Thread#sleep(long, int), java.lang.Thread#stop(java.lang.Throwable), java.lang.Thread#stop(), java.lang.Thread#interrupt(), java.lang.Thread#interrupted(), java.lang.Thread#destroy(), java.lang.Thread#isAlive(), java.lang.Thread#suspend(), java.lang.Thread#resume(), java.lang.Thread#getPriority(), java.lang.Thread#setName(java.lang.String), java.lang.Thread#activeCount(), java.lang.Thread#enumerate([Ljava.lang.Thread;), java.lang.Thread#countStackFrames(), java.lang.Thread#isDaemon(), java.lang.Thread#getContextClassLoader(), java.lang.Thread#setContextClassLoader(java.lang.ClassLoader), java.lang.Thread#getAllStackTraces(), java.lang.Thread#getId(), java.lang.Thread#getState(), java.lang.Thread#setDefaultUncaughtExceptionHandler(java.lang.Thread$UncaughtExceptionHandler), java.lang.Thread#getDefaultUncaughtExceptionHandler(), java.lang.Thread#getUncaughtExceptionHandler(), java.lang.Thread#setUncaughtExceptionHandler(java.lang.Thread$UncaughtExceptionHandler), java.lang.Thread#wait(long, int), java.lang.Thread#wait(long), java.lang.Thread#wait(), java.lang.Thread#equals(java.lang.Object), java.lang.Thread#hashCode(), java.lang.Thread#getClass(), java.lang.Thread#notify(), java.lang.Thread#notifyAll() class java.lang.Object @@ -293,15 +267,6 @@ if (location.href.indexOf('is-external=true') == -1) {

                    Method Detail

                    - -
                      -
                    • -

                      void captureLatestOffsetFor(TopicPartition tp, java.lang.Object partitionMetadata)

                      -

                      Fetch the leader metadata and update our data structures -

                      -
                      • -
                    -
                    • @@ -311,35 +276,10 @@ if (location.href.indexOf('is-external=true') == -1) {
                    - -
                      -
                    • -

                      void dumpMetadata()

                      -

                      -
                      • -
                    - - -
                      -
                    • -

                      java.lang.Long latestFromLeader(java.lang.Integer leaderId, java.lang.String topic, java.lang.Integer partition)

                      -

                      -
                      • -
                    - - -
                      -
                    • -

                      void reconnect()

                      -

                      Blocking reconnect to the Kafka brokers -

                      -
                      • -
                    -
                    • -

                      void refresh(java.util.List<KafkaBroker> brokers)

                      +

                      void refresh(java.util.List<KafkaBroker> brokers)

                      Store a new list of KafkaBroker objects and signal a reconnection

                      • @@ -348,32 +288,12 @@ if (location.href.indexOf('is-external=true') == -1) {
                      • -

                        void run()

                        +

                        @java.lang.SuppressWarnings(['LoggingSwallowsStacktrace', 'CatchException']) +void run()

                      - -
                        -
                      • -

                        java.lang.Iterable withScalaCollection(scala.collection.Iterable iter)

                        -

                        -
                        • -
                      - - -
                        -
                      • -

                        void withTopicsAndPartitions(java.lang.Object metadata, groovy.lang.Closure closure)

                        -

                        Invoke the given closure with the TopicPartition and Partition meta-data - informationn for all of the topic meta-data that was passed in. - - The 'metadata' is the expected return from - kafka.client.ClientUtils.fetchTopicMetadata -

                        -
                        • -
                      -
                    @@ -401,7 +321,7 @@ if (location.href.indexOf('is-external=true') == -1) {
                    diff --git a/groovydoc/com/github/lookout/verspaetung/Main.html b/groovydoc/com/github/reiseburo/verspaetung/Main.html similarity index 73% rename from groovydoc/com/github/lookout/verspaetung/Main.html rename to groovydoc/com/github/reiseburo/verspaetung/Main.html index 7bab38a..42b03d0 100644 --- a/groovydoc/com/github/lookout/verspaetung/Main.html +++ b/groovydoc/com/github/reiseburo/verspaetung/Main.html @@ -23,9 +23,9 @@ - - Main (verspaetung 0.3.0 API) - + + Main (verspaetung 0.5.0 API) + @@ -34,7 +34,7 @@ @@ -60,7 +60,7 @@ if (location.href.indexOf('is-external=true') == -1) {
                    @@ -82,13 +82,13 @@ if (location.href.indexOf('is-external=true') == -1) {
                    -
                    Package: com.github.lookout.verspaetung
                    +
                    Package: com.github.reiseburo.verspaetung

                    [Groovy] Class Main

                      -
                      • com.github.lookout.verspaetung.Main +
                        • com.github.reiseburo.verspaetung.Main
                          @@ -96,6 +96,9 @@ if (location.href.indexOf('is-external=true') == -1) { +

                          Main entry point for running the verspaetung application +

                          +
                        @@ -151,7 +154,12 @@ if (location.href.indexOf('is-external=true') == -1) { static void - registerMetricFor(KafkaConsumer consumer, java.util.concurrent.ConcurrentHashMap<KafkaConsumer, ConsumerGauge> consumerGauges, java.util.concurrent.ConcurrentHashMap<KafkaConsumer, java.lang.Integer> consumerOffsets, java.util.concurrent.ConcurrentHashMap<TopicPartition, java.lang.Long> topicOffsets)
                        + registerMetricFor(KafkaConsumer consumer, java.util.concurrent.ConcurrentHashMap<KafkaConsumer, ConsumerGauge> consumerGauges, java.util.concurrent.ConcurrentHashMap<KafkaConsumer, java.lang.Integer> consumerOffsets, java.util.concurrent.ConcurrentHashMap<TopicPartition, java.lang.Long> topicOffsets)
                        + + + + static boolean + shouldExcludeConsumer(java.lang.String[] excludeGroups, KafkaConsumer consumer)
                        Return true if we should exclude the given KafkaConsumer from reporting @@ -231,14 +239,23 @@ if (location.href.indexOf('is-external=true') == -1) {
                      - + + +
                        +
                      • +

                        static boolean shouldExcludeConsumer(java.lang.String[] excludeGroups, KafkaConsumer consumer)

                        +

                        Return true if we should exclude the given KafkaConsumer from reporting +

                        +
                        • +
                      + @@ -266,7 +283,7 @@ if (location.href.indexOf('is-external=true') == -1) {
                      diff --git a/groovydoc/com/github/lookout/verspaetung/TopicPartition.html b/groovydoc/com/github/reiseburo/verspaetung/TopicPartition.html similarity index 94% rename from groovydoc/com/github/lookout/verspaetung/TopicPartition.html rename to groovydoc/com/github/reiseburo/verspaetung/TopicPartition.html index 34909fb..03e07a7 100644 --- a/groovydoc/com/github/lookout/verspaetung/TopicPartition.html +++ b/groovydoc/com/github/reiseburo/verspaetung/TopicPartition.html @@ -23,9 +23,9 @@ - - TopicPartition (verspaetung 0.3.0 API) - + + TopicPartition (verspaetung 0.5.0 API) + @@ -34,7 +34,7 @@ @@ -60,7 +60,7 @@ if (location.href.indexOf('is-external=true') == -1) {
                      @@ -82,13 +82,13 @@ if (location.href.indexOf('is-external=true') == -1) {
                      -
                      Package: com.github.lookout.verspaetung
                      +
                      Package: com.github.reiseburo.verspaetung

                      [Groovy] Class TopicPartition

                        -
                        • com.github.lookout.verspaetung.TopicPartition +
                          • com.github.reiseburo.verspaetung.TopicPartition