View Source K8s.Client.Runner.Async (k8s v1.1.5)

K8s.Client runner to process a batch of operations in parallel.

Link to this section Summary

Functions

Runs multiple operations in parallel. Operations will be returned in same order given. Operations will not cease in event of failure.

Link to this section Functions

Link to this function

run(conn, operations, http_opts \\ [])

View Source
@spec run(
  K8s.Conn.t(),
  [K8s.Operation.t()],
  keyword()
) :: [ok: struct(), error: K8s.Client.Runner.Base.error_t()]

Runs multiple operations in parallel. Operations will be returned in same order given. Operations will not cease in event of failure.

example

Example

Get a list of pods in parallel:

  pods_to_get = [
    %{"name" => "nginx", "namespace" => "default"},
    %{"name" => "redis", "namespace" => "default"}
  ]

  # Map each one to an individual `GET` operation.
  operations = Enum.map(pods_to_get, fn(%{"name" => name, "namespace" => ns}) ->
     K8s.Client.get("v1", "Pod", namespace: ns, name: name)
  end)

  # Get the results asynchronously
  {:ok, conn} = K8s.Conn.from_file("test/support/kube-config.yaml")
  results = K8s.Client.Runner.Async.run(conn, operations)