riemann.netuitive

Forward events to Netuitive.

generate-event

(generate-event event opts)

Structure for ingest to Netuitive as JSON

generate-tag

(generate-tag tag)

Create Netuitive tag in the form name: value:true

netuitive

(netuitive opts)

Return a function which accepts either single events or batches of events in a vector and sends them to Netuitive. Usage: (netuitive {:api-key “0123456789abcdef01234567890abcde”}) Option: :api-key Required - Netuitive’s API Key for authentication. :url Optional - URL to post to Netuitive ingest - defaults to Production :type Optional - Arbitrary String to use as Element Type - defaults to “Riemann” Example: (def netuitive-forwarder (batch 100 1/10 (async-queue! :netuitive-forwarder ; A name for the forwarder {:queue-size 1e4 ; 10,000 events max :core-pool-size 5 ; Minimum 5 threads :max-pools-size 100} ; Maximum 100 threads (netuitive {:api-key “0123456789abcdef01234567890abcde” :url “https://api.app.netuitive.com/ingest/” :type “Riemann”}))))

netuitive-metric-name

(netuitive-metric-name event)

Constructs a metric-name from an event.

parsetime

(parsetime time)

Converts ratio time in seconds to epoch time in millis

post-datapoint

(post-datapoint api-key url data)

Post the Riemann metrics to Netuitive.