             [onyx.plugin.bench-plugin]
             [onyx.static.logging-configuration :as log-config]
             [onyx.plugin.core-async]
+            [onyx.test-helper :refer [load-config]]
             [interval-metrics.core :as im]
             [onyx.api])
   (:import [onyx.plugin RandomInputPlugin]))

                                                             (Thread/sleep 1000)
                                                             (.println (System/out) (str (:onyx.core/id event) " RATE: " (im/snapshot! rate)))))}))
   :lifecycle/after-batch (fn after-batch [event lifecycle]
                            (im/update! (:generator/rate event) (count (:onyx.core/batch event)))
                            {})})

(def in-calls 

    :onyx/batch-size batch-size
    :onyx/doc "Drops messages on the floor"}])

(def workflow [[:in :inc1] 
               [:inc1 :inc2] 
               [:inc2 :inc3]
               [:inc3 :inc4]
               [:inc4 :no-op]])

(println "Starting Vpeers")
(def v-peers (onyx.api/start-peers 6 peer-group))

(println "Started vpeers")
(def bench-length 120000)

(def messages-tracking (atom {}))
(def rate+latency (im/rate+latency {:rate-unit :nanoseconds 
                                    :latency-unit :nanoseconds}))
(def retry-counter 
  (atom (long 0)))

(def total-segments (atom 0))

(Thread/sleep 10000)

