Investigate a possible bug in (where (tagged "foo"))

[aphyr]

https://gist.github.com/0a96223a1b1cc6680375

[jib]

Even when culling it down further to just this, it fails to produce output:

(tagged-any "tag" prn)

[aphyr]

This seems OK to me. Can you reproduce on master?

(logging/init :file "riemann.log")

(tcp-server)
(udp-server)
(ws-server)

(periodically-expire 10)

(let [index (default :ttl 300 (update-index (index)))]
  (streams
    index
    (where (tagged "foo")
           (partial prn "foo")
           (else
             (partial prn "not foo"))))
)

Riemann::Client.new << {service: "x", tags: ["foo", "bar"]}

"foo" #riemann.codec.Event{:host "waterhouse", :service "x", :state nil, :description nil, :metric nil, :tags ["foo"], :time 1352588335, :ttl nil}

[aphyr]

Aha! I did discover a problem with (tagged-any) and (tagged-all), though: they only work with collections of tags, not single strings. I'll fix that right away.

(tagged-any ["foo"] prn) should work, in the mean time. :)

[aphyr]

Fixed in 4d1f932. Enjoy! :)