View Source Bella.Watcher.ResponseBuffer (bella v0.2.2)

Buffers streaming responses from HTTPoison and returns kubernetes watch events as JSON

ResponseBuffer implementation from Kazan's LineBuffer.

Link to this section Summary

t()

Add an HTTP response chunk to the buffer

get_lines(buffer)

Returns complete lines of JSON from streaming HTTP Response.

new()

Create a new ResponseBuffer

t() :: %Bella.Watcher.ResponseBuffer{lines: [binary()], pending: binary()}

add_chunk(t(), binary()) :: t()

Add an HTTP response chunk to the buffer

get_lines(t()) :: {[binary()], t()}

Returns complete lines of JSON from streaming HTTP Response.

Lines are in NDJSON format; each line is a JSON object.

new() :: t()

Create a new ResponseBuffer