search

FundingCircle / jackdaw

A Clojure library for the Apache Kafka distributed streaming platform.
https://fundingcircle.github.io/jackdaw/
BSD 3-Clause "New" or "Revised" License
369 stars 80 forks source link

Add journal access functions #215

Closed TrevorRawlings closed 4 years ago

TrevorRawlings commented 4 years ago

Adds functions to simply querying the test-machine journal. These can help make the test machine steps a little more concise:

(with-open [test-machine (j/test-machine ...)]
  (j/run-test test-machine [[:write! :input-topic record]
                            ...
                            [:watch (j/by-key :output-topic-1 [:status] "success")]]
                            [:watch (j/by-id :investor-updated (:id investor))
                            ...])]

Checklist

codecov[bot] commented 4 years ago

Codecov Report

Merging #215 into master will increase coverage by 0.19%. The diff coverage is 100%.

Impacted file tree graph

@@            Coverage Diff             @@
##           master     #215      +/-   ##
==========================================
+ Coverage   79.78%   79.97%   +0.19%     
==========================================
  Files          42       42              
  Lines        2572     2597      +25     
  Branches      150      150              
==========================================
+ Hits         2052     2077      +25     
  Misses        370      370              
  Partials      150      150
Impacted Files Coverage Δ
src/jackdaw/test/journal.clj 84.14% <100%> (+6.95%) :arrow_up:

Continue to review full report at Codecov.

Legend - Click here to learn more Δ = absolute <relative> (impact), ø = not affected, ? = missing data Powered by Codecov. Last update a08db3a...cde8df2. Read the comment docs.