event_bus_datastore v0.1.3

EventBusDatastore.Producer (event_bus_datastore v0.1.3)

Postgres queue (producer)

Link to this section Summary

Functions

init(state)

Callback implementation for GenStage.init/1.

put(event_shadow)

Push event shadows to queue

start_link(state \\ [])

Link to this section Functions

Link to this function

init(state)

Callback implementation for GenStage.init/1.

Link to this function

put(event_shadow)

Specs

put({atom(), String.t() | integer()}) :: :ok

Push event shadows to queue

Link to this function

start_link(state \\ [])