View Source Plausible.Google.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.