macro.clj

(defmacro defphase
  [name argvec & body]
  `(def ~name
     (phase-fn ~argvec ~@body)))

(defmacro phase-fn
  [argvec & body]
  `(fn [request# ~@argvec]
     (-> request#
         ~@body)))

;;examples

(defphase name-node
  "Run a Hadoop name node."
  [data-dir]
  (format-hdfs)
   (hadoop-service "namenode" "Name Node")
   (hadoop-command "dfsadmin" "-safemode" "wait")
   (hadoop-command "fs" "-mkdir" data-dir)
   (hadoop-command "fs" "-chmod" "+w" data-dir))

(defphase secondary-name-node
  "Run a Hadoop secondary name node"
  []
  (hadoop-service "secondarynamenode" "secondary name node"))

(defphase job-tracker
  "Run a Hadoop job tracker"
  []
  (hadoop-service "jobtracker" "job tracker"))

(defphase data-node
  "Run a Hadoop data node"
  []
  (hadoop-service "datanode" "data node"))

(defphase task-tracker
  "Run a Hadoop task tracker"
  []
  (hadoop-service "tasktracker" "task tracker"))