View Source K8s.Client.Runner.Stream.ListRequest (k8s v2.6.0)

:list K8s.Operation encapsulated with pagination and K8s.Conn

Summary

Types

continue_t()

Pagination continue token

responses_t()
t()

List operation as a Stream data type

Functions

next_item(state)
stream(conn, op, http_opts)

Types

Link to this type

continue_t()

View Source 
@type continue_t() :: nil | :halt | binary()

Pagination continue token

Link to this type

responses_t()

View Source 
@type responses_t() :: map() | {:error, K8s.Client.HTTPError.t()}
Link to this type

t()

View Source 
@type t() :: %K8s.Client.Runner.Stream.ListRequest{
  conn: K8s.Conn.t(),
  continue: continue_t(),
  http_opts: Keyword.t(),
  limit: pos_integer(),
  operation: K8s.Operation.t()
}

List operation as a Stream data type

Functions

Link to this function

next_item(state)

View Source 
@spec next_item(t()) :: {responses_t(), t()}
Link to this function

stream(conn, op, http_opts)

View Source 
@spec stream(K8s.Conn.t(), K8s.Operation.t(), Keyword.t()) ::
  Enumerable.t(responses_t())