cddr.kafka.test.journal — cddr/test-machine 1.0.2-4-gc789324

all-keys-present clj

(all-keys-present topic-name ks ids)

Returns true if all the passed ids can be found in the topic by key ks

by-id clj

(by-id topic-name value)

by-key clj

(by-key topic-name ks value)

by-keys clj

(by-keys topic-name ks values)

journal-read clj

(journal-read journal journal-key v)

Append record into the journal under journal-key

journal-result clj

(journal-result machine record)

journaller clj

(journaller machine stop?)

Returns an asynchronous process that reads all messages produced by the supplied machine's :consumer and records them in the journal

messages clj

(messages journal topic-name)

messages-by-kv clj

(messages-by-kv journal topic-name ks value)

messages-by-kv-fn clj

(messages-by-kv-fn journal topic-name ks pred)

raw-messages clj

(raw-messages journal topic-name)

reverse-lookup clj

(reverse-lookup topic-metadata topic)

Given a map of topic-metadata, find the name of the entry whose :topic-name matches the supplied topic.

The name supplied in the key positions in the supplied map do not necessarily match the topic name. This allows users to provide a 'logical' name that may stay constant if the user wishes over version changes.

This function is used when populating the journal to ensure that the topic identifiers given by the user are used when populating the journal (instead of the real topic names).

watch-for clj

(watch-for machine condition? timeout info)

Returns the first true application of the journal to the specified condition condition?

with-journal clj

(with-journal machine journal)

Enriches the supplied machine with a journaller that will write to the supplied journal.