View Source K8s.Client.Runner.StreamTo (k8s v2.6.0)

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

Summary

Functions

run(op, stream_to)

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

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

Functions

Link to this function

run(op, stream_to)

View Source 
@spec run(K8s.Operation.t(), stream_to :: pid()) ::
  K8s.Client.Provider.stream_to_response_t()

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

Link to this function

run(op, http_opts, stream_to)

View Source 
@spec run(K8s.Operation.t(), keyword(), stream_to :: pid()) ::
  K8s.Client.Provider.stream_to_response_t()
@spec run(K8s.Conn.t(), K8s.Operation.t(), stream_to :: pid()) ::
  K8s.Client.Provider.stream_to_response_t()
Link to this function

run(conn, op, http_opts, stream_to)

View Source 
@spec run(K8s.Conn.t(), K8s.Operation.t(), keyword(), stream_to :: pid()) ::
  K8s.Client.Provider.stream_to_response_t()