View Source Plausible.Imported.Buffer (Plausible v0.0.1)
This GenServer inserts records into Clickhouse imported_* tables. Multiple buffers are
automatically created for each table. Records are flushed when the table buffer reaches the
maximum size, defined by max_buffer_size/0.
Summary
Functions
Returns a specification to start this module under a supervisor.
Flushes all table buffers to Clickhouse.
Callback implementation for GenServer.handle_continue/2.
Callback implementation for GenServer.init/1.
Puts the given records into the table buffer.
Returns the total count of items in the given table buffer.
Functions
Returns a specification to start this module under a supervisor.
See Supervisor.
Flushes all table buffers to Clickhouse.
Callback implementation for GenServer.handle_continue/2.
Callback implementation for GenServer.init/1.
Puts the given records into the table buffer.
@spec size(pid(), term()) :: non_neg_integer()
Returns the total count of items in the given table buffer.