pallet use-async api example

plan.clj

(ns pallet.api-examples.plan
  "Examples of pallet's plan api"
  (:refer-clojure :exclude [sync])
  (:require
   [pallet.actions :refer [exec-script*]]
   [pallet.core.executor.ssh :refer [ssh-executor]]
   [pallet.plan :refer [execute-plan execute-plans plan-fn]]
   [pallet.session :as session :refer [set-user]]
   [pallet.user :refer [default-user]]
   [pallet.utils.async :refer [sync]]))

(defn ls-on-localhost
  "Execute a 'ls' on localhost."
  []
  (let [localhost {:id "localhost" :primary-ip "127.0.0.1"
                   ;; Adjust these appropriately
                   :os-family :darwin :packager :brew}
        session (-> (session/create {:executor (ssh-executor)})
                    (set-user (default-user)))
        f (plan-fn [session]
            (exec-script* session "ls"))]
    ;; Use synchronous execution of a single plan function.
    (execute-plan session localhost f)
    ;; Use async execution, which allows running plan functions on
    ;; multiple targets in parallel.
    (sync (execute-plans session [{:target localhost :plan-fn f}]))))

(ns pallet.api-examples.plan
  "Examples of pallet's plan api"
  (:refer-clojure :exclude [sync])
  (:require
   [pallet.actions :refer [exec-script*]]
   [pallet.core.executor.ssh :refer [ssh-executor]]
   [pallet.plan :refer [execute-plan execute-plans plan-fn]]
   [pallet.session :as session :refer [set-user]]
   [pallet.user :refer [default-user]]
   [pallet.utils.async :refer [sync]]))

(defn ls-on-localhost
  "Execute a 'ls' on localhost."
  []
  (let [localhost {:id "localhost" :primary-ip "127.0.0.1"
                   ;; Adjust these appropriately
                   :os-family :darwin :packager :brew}
        session (-> (session/create {:executor (ssh-executor)})
                    (set-user (default-user)))
        f (plan-fn [session]
            (exec-script* session "ls"))]
    ;; sync version
    (execute-plan session localhost f)
    ;; async version 
    (sync (execute-plans session [{:target localhost :plan-fn f}]))))