View Source K8s.Client.HTTPStream (k8s v2.6.1)

Helper functions for HTTP stream processing.

Summary

Types

to_lines_t()

Functions

decode_json_objects(stream)
transform_to_lines(stream)

Types

Link to this type

to_lines_t()

View Source 
@type to_lines_t() :: %{remainder: binary()}

Functions

Link to this function

decode_json_objects(stream)

View Source 
@spec decode_json_objects(Enumerable.t(K8s.Client.Provider.http_chunk_t())) ::
  Enumerable.t(K8s.Client.Provider.http_chunk_t() | {:object, binary()})
Link to this function

transform_to_lines(stream)

View Source 
@spec transform_to_lines(Enumerable.t(K8s.Client.Provider.http_chunk_t())) ::
  Enumerable.t(K8s.Client.Provider.http_chunk_t() | {:line, binary()})