event-data-common.event-bus — event-data-common 0.1.57

Interact with the Event Bus. Retrieval of Events from the Archive is done by prefix. A callback to a lazy sequence, rather than returning that sequence, is done so that the stream can be closed after. The alternative is buffering a very large amount of data.

event-bus-prefixes-length clj

(event-bus-prefixes-length length)

event-ids-for-day clj

(event-ids-for-day the-date)

Retrieve a set of IDs for Events for this date and prefix of the archive.

event-ids-for-prefix clj

(event-ids-for-prefix the-date prefix)

Retrieve a list of IDs for Events for this date and prefix of the archive.

get-event clj

(get-event event-id)

Retrieve an Event by its ID.

hexadecimal clj

jwt-for-source clj

(jwt-for-source source-id)

Create a JWT that can

jwt-for-source-cached clj

jwt-verifier clj

post-event clj

(post-event event)

Send an Event to the Bus. Derive an appropriate JWT. Ignore duplicates. Since this may potentially be called more than once with the same Event, it's OK to get a 409 duplicate.

prefix-length clj

prefixes clj

retrieve-events-for-date clj

(retrieve-events-for-date the-date callback)

Retrieve all events for all prefixes of the given date, keywords for keys.

retrieve-events-for-date-prefix clj

(retrieve-events-for-date-prefix the-date prefix callback)

Retrieve a realized list of Events for this date and prefix of the archive, keywords for keys. Calback with lazy seq for flexibility.

retry-delay clj

Time to sleep between unsuccessful HTTP requests. Configurable for tests.

send-event clj

(send-event event jwt)

Update an extant Event.

wildcard-jwt clj

A minimal JWT for access to the bus.