K8s.Client.Runner.Stream (k8s v2.7.0)

View Source

Takes a K8s.Client.list/3 operation and returns an Elixir Stream of resources.

Summary

Functions

run(op)

Validates operation type before calling stream/3. Only supports verbs: list_all_namespaces and list.

run(op, http_opts)
run(conn, op, http_opts)

Functions

run(op)

@spec run(K8s.Operation.t()) ::
  {:ok, Enumerable.t()} | {:error, K8s.Operation.Error.t()}

Validates operation type before calling stream/3. Only supports verbs: list_all_namespaces and list.

run(op, http_opts)

@spec run(
  K8s.Operation.t(),
  keyword()
) :: {:ok, Enumerable.t()} | {:error, K8s.Operation.Error.t()}
@spec run(K8s.Conn.t(), K8s.Operation.t()) ::
  {:ok, Enumerable.t()} | {:error, K8s.Operation.Error.t()}

run(conn, op, http_opts)

@spec run(K8s.Conn.t(), K8s.Operation.t(), keyword()) ::
  {:ok, Enumerable.t()} | {:error, K8s.Operation.Error.t()}