API Reference wardrik_events v#0.1.0-rc.1

Keeps each agent's events as CloudEvents, in a log you can read back and follow.

A view of what an agent is doing now, as the protocol's activity.

Keeps the audit: one log for the deployment of what people changed and who changed it.

Builds events as Wardrik sends them: CloudEvents maps with string keys and the payload under "data".

Encodes and decodes cursors. A cursor is the last sequence number read in each log.

Encodes an agent's WardrikCore.Events as the CloudEvents of WardrikProtocol.

Encodes the values inside an event's data as JSON-ready maps with string keys.

Holds the events' settings, each log's last sequence number and each agent's activity in an ETS table.

Follows agents' events into your app.

Reads and writes one log: an agent's kept events in a store, in order, each under its sequence number.

Matches log names against patterns. * matches any run of characters, and ? matches one.

Reads kept events back from the logs patterns match.

Drops events older than :retention days, once an hour. See WardrikEvents.start_link/1.

A view of an agent's runs, and the totals across them.

Sends each event, as it's written, to the processes subscribed to its log.

Reads logs back from a cursor, then follows them as they're written.

A view of an agent's conversation: each message people sent, and each run that answered, step by step.

The behaviour for views. A view folds an agent's events, oldest first, into what a screen shows.