View Source Electric.Shapes.Querying (electric v1.0.0-beta.19)

Summary

Types

json_iodata()
json_result_stream()

Functions

stream_initial_data(conn, stack_id, shape, chunk_bytes_threshold \\ LogChunker.default_chunk_size_threshold())

Streams the initial data for a shape. Query results are returned as a stream of JSON strings, as prepared on PostgreSQL.

Types

Link to this type

json_iodata()

View Source 
@type json_iodata() :: iodata()
Link to this type

json_result_stream()

View Source 
@type json_result_stream() :: Enumerable.t(json_iodata())

Functions

Link to this function

stream_initial_data(conn, stack_id, shape, chunk_bytes_threshold \\ LogChunker.default_chunk_size_threshold())

View Source 
@spec stream_initial_data(
  DBConnection.t(),
  String.t(),
  Electric.Shapes.Shape.t(),
  non_neg_integer()
) ::
  json_result_stream()

Streams the initial data for a shape. Query results are returned as a stream of JSON strings, as prepared on PostgreSQL.