puppetlabs.analytics.storage — puppetlabs/analytics 1.1.0

discard! clj

(discard! queue entry-ids)

Inputs: [queue :- Stockpile entry-ids :- [schema/Int]]

init-queue clj

(init-queue dir)

Initialize a queue. The dir is expected to exist and be writable.

purge-queue! clj

(purge-queue! queue)

Inputs: [queue :- Stockpile]

read-entry clj

(read-entry queue message-id)

Read a message from the queue. This does not remove it from the queue, but just reads a message by id.

reduce-entries clj

(reduce-entries queue f val)

Reduce over the entries. The reducer function should expect to get entry ids.

store clj

(store queue object)

Inputs: [queue :- puppetlabs.stockpile.queue.Stockpile object :- (schema/if (fn* [p1__8642#] (contains? p1__8642# "event")) internal-api/Event internal-api/Snapshot)] Returns: (schema/protocol stockpile/Entry)

Store a message on the queue. The queue should already be initialized. The message should be a map. This returns a message id that can be used to retrieve the message.