mirror of https://github.com/apache/jclouds.git
Merge pull request #25 from mattiasholmqvist/master
First version of compute2 Clojure API.
This commit is contained in:
Adrian Cole
commit
3a0f6a62d8
|
|
@ -0,0 +1,411 @@
|
||||||
|
;
|
||||||
|
;
|
||||||
|
; Copyright (C) 2011 Cloud Conscious, LLC. <info@cloudconscious.com>
|
||||||
|
;
|
||||||
|
; ====================================================================
|
||||||
|
; Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
|
; you may not use this file except in compliance with the License.
|
||||||
|
; You may obtain a copy of the License at
|
||||||
|
;
|
||||||
|
; http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
;
|
||||||
|
; Unless required by applicable law or agreed to in writing, software
|
||||||
|
; distributed under the License is distributed on an "AS IS" BASIS,
|
||||||
|
; WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
|
; See the License for the specific language governing permissions and
|
||||||
|
; limitations under the License.
|
||||||
|
; ====================================================================
|
||||||
|
;
|
||||||
|
|
||||||
|
(ns org.jclouds.compute2
|
||||||
|
"A clojure binding to the jclouds ComputeService.
|
||||||
|
|
||||||
|
Current supported providers are:
|
||||||
|
[aws-ec2, eucualyptus-partnercloud-ec2, elastichosts-lon-b,
|
||||||
|
cloudservers-uk, cloudservers-us, byon, cloudsigma-zrh, stub,
|
||||||
|
trmk-ecloud, trmk-vcloudexpress, vcloud, bluelock, eucalyptus,
|
||||||
|
slicehost, elastichosts-lon-p, elastichosts-sat-p, elastichosts,
|
||||||
|
openhosting-east1, serverlove-z1-man, skalicloud-sdg-my, deltacloud]
|
||||||
|
|
||||||
|
Here's an example of getting some compute configuration from rackspace:
|
||||||
|
|
||||||
|
(use 'org.jclouds.compute2)
|
||||||
|
(use 'clojure.pprint)
|
||||||
|
|
||||||
|
(def provider \"cloudservers\")
|
||||||
|
(def provider-identity \"username\")
|
||||||
|
(def provider-credential \"password\")
|
||||||
|
|
||||||
|
;; create a compute service
|
||||||
|
(def compute
|
||||||
|
(compute-service provider provider-identity provider-credential))
|
||||||
|
|
||||||
|
(pprint (locations compute))
|
||||||
|
(pprint (images compute))
|
||||||
|
(pprint (nodes compute))
|
||||||
|
(pprint (hardware-profiles compute)))
|
||||||
|
|
||||||
|
Here's an example of creating and running a small linux node in the group webserver:
|
||||||
|
|
||||||
|
;; create a compute service using ssh and log4j extensions
|
||||||
|
(def compute
|
||||||
|
(compute-service
|
||||||
|
provider provider-identity provider-credential :ssh :log4j))
|
||||||
|
|
||||||
|
(create-node \"webserver\" compute)
|
||||||
|
|
||||||
|
See http://code.google.com/p/jclouds for details.
|
||||||
|
"
|
||||||
|
(:use org.jclouds.core
|
||||||
|
(clojure.contrib logging core)
|
||||||
|
(org.jclouds predicate))
|
||||||
|
(:require
|
||||||
|
[clojure.contrib.condition :as condition])
|
||||||
|
(:import java.io.File
|
||||||
|
java.util.Properties
|
||||||
|
[org.jclouds.domain Location]
|
||||||
|
[org.jclouds.compute
|
||||||
|
ComputeService ComputeServiceContext ComputeServiceContextFactory]
|
||||||
|
[org.jclouds.compute.domain
|
||||||
|
Template TemplateBuilder ComputeMetadata NodeMetadata Hardware
|
||||||
|
OsFamily Image]
|
||||||
|
[org.jclouds.compute.options TemplateOptions]
|
||||||
|
[org.jclouds.compute.predicates
|
||||||
|
NodePredicates]
|
||||||
|
[com.google.common.collect ImmutableSet])
|
||||||
|
)
|
||||||
|
|
||||||
|
(try
|
||||||
|
(use '[clojure.contrib.reflect :only [get-field]])
|
||||||
|
(catch Exception e
|
||||||
|
(use '[clojure.contrib.java-utils
|
||||||
|
:only [wall-hack-field]
|
||||||
|
:rename {wall-hack-field get-field}])))
|
||||||
|
|
||||||
|
(defn compute-service
|
||||||
|
"Create a logged in context."
|
||||||
|
([#^String provider #^String provider-identity #^String provider-credential
|
||||||
|
& options]
|
||||||
|
(let [module-keys (set (keys module-lookup))
|
||||||
|
ext-modules (filter #(module-keys %) options)
|
||||||
|
opts (apply hash-map (filter #(not (module-keys %)) options))]
|
||||||
|
(.. (ComputeServiceContextFactory.)
|
||||||
|
(createContext
|
||||||
|
provider provider-identity provider-credential
|
||||||
|
(apply modules (concat ext-modules (opts :extensions)))
|
||||||
|
(reduce #(do (.put %1 (name (first %2)) (second %2)) %1)
|
||||||
|
(Properties.) (dissoc opts :extensions)))
|
||||||
|
(getComputeService))))
|
||||||
|
([#^ComputeServiceContext compute-context]
|
||||||
|
(.getComputeService compute-context)))
|
||||||
|
|
||||||
|
(defn compute-context
|
||||||
|
"Returns a compute context from a compute service."
|
||||||
|
[compute]
|
||||||
|
(.getContext compute))
|
||||||
|
|
||||||
|
(defn compute-service?
|
||||||
|
[object]
|
||||||
|
(instance? ComputeService object))
|
||||||
|
|
||||||
|
(defn compute-context?
|
||||||
|
[object]
|
||||||
|
(instance? ComputeServiceContext object))
|
||||||
|
|
||||||
|
(defn locations
|
||||||
|
"Retrieve the available compute locations for the compute context."
|
||||||
|
([#^ComputeService compute]
|
||||||
|
(seq (.listAssignableLocations compute))))
|
||||||
|
|
||||||
|
(defn nodes
|
||||||
|
"Retrieve the existing nodes for the compute context."
|
||||||
|
([#^ComputeService compute]
|
||||||
|
(seq (.listNodes compute))))
|
||||||
|
|
||||||
|
(defn nodes-with-details
|
||||||
|
"Retrieve the existing nodes for the compute context."
|
||||||
|
([#^ComputeService compute]
|
||||||
|
(seq (.listNodesDetailsMatching compute (NodePredicates/all)))))
|
||||||
|
|
||||||
|
(defn nodes-with-details-matching
|
||||||
|
"List details for all nodes matching fn pred.
|
||||||
|
pred should be a fn of one argument that takes a ComputeMetadata and returns true or false.
|
||||||
|
"
|
||||||
|
([#^ComputeService compute pred]
|
||||||
|
(seq (.listNodesDetailsMatching compute (to-predicate pred)))))
|
||||||
|
|
||||||
|
(defn nodes-in-group
|
||||||
|
"list details of all the nodes in the given group."
|
||||||
|
([#^ComputeService compute #^String group]
|
||||||
|
(filter #(= (.getGroup %) group) (nodes-with-details compute))))
|
||||||
|
|
||||||
|
(defn images
|
||||||
|
"Retrieve the available images for the compute context."
|
||||||
|
([#^ComputeService compute]
|
||||||
|
(seq (.listImages compute))))
|
||||||
|
|
||||||
|
(defn hardware-profiles
|
||||||
|
"Retrieve the available node hardware profiles for the compute context."
|
||||||
|
([#^ComputeService compute]
|
||||||
|
(seq (.listHardwareProfiles compute))))
|
||||||
|
|
||||||
|
(defn default-template
|
||||||
|
([#^ComputeService compute]
|
||||||
|
(.. compute (templateBuilder)
|
||||||
|
(options
|
||||||
|
(org.jclouds.compute.options.TemplateOptions$Builder/authorizePublicKey
|
||||||
|
(slurp (str (. System getProperty "user.home") "/.ssh/id_rsa.pub"))))
|
||||||
|
build)))
|
||||||
|
|
||||||
|
(defn create-nodes
|
||||||
|
"Create the specified number of nodes using the default or specified
|
||||||
|
template.
|
||||||
|
;; Simplest way to add 2 small linux nodes to the group webserver is to run
|
||||||
|
(create-nodes \"webserver\" 2 compute)
|
||||||
|
;; Note that this will actually add another 2 nodes to the set called
|
||||||
|
;; \"webserver\""
|
||||||
|
([group count compute]
|
||||||
|
(create-nodes
|
||||||
|
group count (default-template compute) compute))
|
||||||
|
([#^ComputeService compute group count template]
|
||||||
|
(seq
|
||||||
|
(.createNodesInGroup compute group count template))))
|
||||||
|
|
||||||
|
(defn create-node
|
||||||
|
"Create a node using the default or specified template.
|
||||||
|
|
||||||
|
;; simplest way to add a small linux node to the group webserver is to run
|
||||||
|
(create-node \"webserver\" compute)
|
||||||
|
|
||||||
|
;; Note that this will actually add another node to the set called
|
||||||
|
;; \"webserver\""
|
||||||
|
([compute group]
|
||||||
|
(create-node compute group (default-template compute)))
|
||||||
|
([compute group template]
|
||||||
|
(first (create-nodes compute group 1 template))))
|
||||||
|
|
||||||
|
(defn #^NodeMetadata node-details
|
||||||
|
"Retrieve the node metadata, given its id."
|
||||||
|
([#^ComputeService compute id]
|
||||||
|
(.getNodeMetadata compute id)))
|
||||||
|
|
||||||
|
(defn suspend-nodes-matching
|
||||||
|
"Suspend all nodes matching the fn pred.
|
||||||
|
pred should be a fn of one argument that takes a ComputeMetadata and returns true or false."
|
||||||
|
([#^ComputeService compute pred]
|
||||||
|
(.suspendNodesMatching compute (to-predicate pred))))
|
||||||
|
|
||||||
|
(defn suspend-node
|
||||||
|
"Suspend a node, given its id."
|
||||||
|
([id #^ComputeService compute]
|
||||||
|
(.suspendNode compute id)))
|
||||||
|
|
||||||
|
(defn resume-nodes-matching
|
||||||
|
"Suspend all the nodes in the fn pred.
|
||||||
|
pred should be a fn of one argument that takes a ComputeMetadata and returns true or false."
|
||||||
|
([#^ComputeService compute pred]
|
||||||
|
(.resumeNodesMatching compute (to-predicate pred))))
|
||||||
|
|
||||||
|
(defn resume-node
|
||||||
|
"Resume a node, given its id."
|
||||||
|
([id #^ComputeService compute]
|
||||||
|
(.resumeNode compute id)))
|
||||||
|
|
||||||
|
(defn reboot-nodes-matching
|
||||||
|
"Reboot all the nodes in the fn pred.
|
||||||
|
pred should be a fn of one argument that takes a ComputeMetadata and returns true or false."
|
||||||
|
([#^ComputeService compute pred]
|
||||||
|
(.rebootNodesMatching compute (to-predicate pred))))
|
||||||
|
|
||||||
|
(defn reboot-node
|
||||||
|
"Reboot a node, given its id."
|
||||||
|
([id #^ComputeService compute]
|
||||||
|
(.rebootNode compute id)))
|
||||||
|
|
||||||
|
(defn destroy-nodes-matching
|
||||||
|
"Destroy all the nodes in the fn pred.
|
||||||
|
pred should be a fn of one argument that takes a ComputeMetadata and returns true or false."
|
||||||
|
([#^ComputeService compute pred]
|
||||||
|
(.destroyNodesMatching compute (to-predicate pred))))
|
||||||
|
|
||||||
|
(defn destroy-node
|
||||||
|
"Destroy a node, given its id."
|
||||||
|
([id #^ComputeService compute]
|
||||||
|
(.destroyNode compute id)))
|
||||||
|
|
||||||
|
(defmacro state-predicate [node state]
|
||||||
|
`(= (.getState ~node)
|
||||||
|
(. org.jclouds.compute.domain.NodeState ~state)))
|
||||||
|
|
||||||
|
(defn pending?
|
||||||
|
"Predicate for the node being in transition"
|
||||||
|
[#^NodeMetadata node]
|
||||||
|
(state-predicate node PENDING))
|
||||||
|
|
||||||
|
(defn running?
|
||||||
|
"Predicate for the node being available for requests."
|
||||||
|
[#^NodeMetadata node]
|
||||||
|
(state-predicate node RUNNING))
|
||||||
|
|
||||||
|
(defn terminated?
|
||||||
|
"Predicate for the node being halted."
|
||||||
|
[#^NodeMetadata node]
|
||||||
|
(state-predicate node TERMINATED))
|
||||||
|
|
||||||
|
(defn suspended?
|
||||||
|
"Predicate for the node being suspended."
|
||||||
|
[#^NodeMetadata node]
|
||||||
|
(state-predicate node SUSPENDED))
|
||||||
|
|
||||||
|
(defn error-state?
|
||||||
|
"Predicate for the node being in an error state."
|
||||||
|
[#^NodeMetadata node]
|
||||||
|
(state-predicate node ERROR))
|
||||||
|
|
||||||
|
(defn unrecognized-state?
|
||||||
|
"Predicate for the node being in an unrecognized state."
|
||||||
|
[#^NodeMetadata node]
|
||||||
|
(state-predicate node UNRECOGNIZED))
|
||||||
|
|
||||||
|
(defn public-ips
|
||||||
|
"Returns the node's public ips"
|
||||||
|
[#^NodeMetadata node]
|
||||||
|
(.getPublicAddresses node))
|
||||||
|
|
||||||
|
(defn private-ips
|
||||||
|
"Returns the node's private ips"
|
||||||
|
[#^NodeMetadata node]
|
||||||
|
(.getPrivateAddresses node))
|
||||||
|
|
||||||
|
(defn group
|
||||||
|
"Returns a the node's group"
|
||||||
|
[#^NodeMetadata node]
|
||||||
|
(.getGroup node))
|
||||||
|
|
||||||
|
(defn hostname
|
||||||
|
"Returns the compute node's name"
|
||||||
|
[#^ComputeMetadata node]
|
||||||
|
(.getName node))
|
||||||
|
|
||||||
|
(defn location
|
||||||
|
"Returns the compute node's location id"
|
||||||
|
[#^ComputeMetadata node]
|
||||||
|
(-?> node .getLocation .getId))
|
||||||
|
|
||||||
|
(defn id
|
||||||
|
"Returns the compute node's id"
|
||||||
|
[#^ComputeMetadata node]
|
||||||
|
(.getId node))
|
||||||
|
|
||||||
|
(define-accessors Template image hardware location options)
|
||||||
|
(define-accessors Image version os-family os-description architecture)
|
||||||
|
(define-accessors Hardware processors ram volumes)
|
||||||
|
(define-accessors NodeMetadata "node" credentials hardware state group)
|
||||||
|
|
||||||
|
(def
|
||||||
|
^{:doc "TemplateBuilder functions" :private true}
|
||||||
|
template-map
|
||||||
|
(merge
|
||||||
|
(make-option-map
|
||||||
|
kw-memfn-0arg [:smallest :fastest :biggest :any])
|
||||||
|
(make-option-map
|
||||||
|
kw-memfn-1arg
|
||||||
|
[:os-family :location-id :architecture :image-id :hardware-id
|
||||||
|
:os-name-matches :os-version-matches :os-description-matches
|
||||||
|
:os-64-bit :image-version-matches :image-name-matches
|
||||||
|
:image-description-matches :min-cores :min-ram])))
|
||||||
|
|
||||||
|
(def
|
||||||
|
^{:doc "TemplateOptions functions" :private true}
|
||||||
|
options-map
|
||||||
|
(merge
|
||||||
|
(make-option-map
|
||||||
|
kw-memfn-0arg
|
||||||
|
[:destroy-on-error :enable-monitoring :no-placement-group :no-key-pair
|
||||||
|
:with-details])
|
||||||
|
(make-option-map
|
||||||
|
kw-memfn-1arg
|
||||||
|
[:run-script :install-private-key :authorize-public-key
|
||||||
|
;; aws ec2 options
|
||||||
|
:spot-price :spot-options :placement-group :subnet-id
|
||||||
|
:block-device-mappings :unmapDeviceNamed :security-groups
|
||||||
|
:key-pair :user-data])
|
||||||
|
(make-option-map kw-memfn-varargs [:inbound-ports])
|
||||||
|
(make-option-map
|
||||||
|
kw-memfn-2arg
|
||||||
|
[:block-on-port
|
||||||
|
;; aws ec2 options
|
||||||
|
:map-ephemeral-device-to-device-name])
|
||||||
|
{:map-ebs-snapshot-to-device-name
|
||||||
|
(kw-memfn-apply :map-ebs-snapshot-to-device-name
|
||||||
|
device-name snapshot-id size-in-gib delete-on-termination)
|
||||||
|
:map-new-volume-to-device-name
|
||||||
|
(kw-memfn-apply :map-new-volume-to-device-name
|
||||||
|
device-name size-in-gib delete-on-termination)}))
|
||||||
|
|
||||||
|
(def
|
||||||
|
^{:doc "All receognised options"}
|
||||||
|
known-template-options
|
||||||
|
(set (mapcat keys [options-map template-map])))
|
||||||
|
|
||||||
|
(defn os-families []
|
||||||
|
(. OsFamily values))
|
||||||
|
|
||||||
|
(def enum-map {:os-family (os-families)})
|
||||||
|
|
||||||
|
(defn translate-enum-value [kword value]
|
||||||
|
(or (-> (filter #(= (name value) (str %)) (kword enum-map)) first)
|
||||||
|
value))
|
||||||
|
|
||||||
|
(defn apply-option [builder option-map option value]
|
||||||
|
(when-let [f (option-map option)]
|
||||||
|
(f builder (translate-enum-value option value))))
|
||||||
|
|
||||||
|
(defn build-template
|
||||||
|
"Creates a template that can be used to run nodes.
|
||||||
|
|
||||||
|
The :os-family key expects a keyword version of OsFamily,
|
||||||
|
eg. :os-family :ubuntu.
|
||||||
|
|
||||||
|
The :smallest, :fastest, :biggest, :any, and :destroy-on-error keys expect a
|
||||||
|
boolean value.
|
||||||
|
|
||||||
|
Options correspond to TemplateBuilder methods."
|
||||||
|
[#^ComputeService compute
|
||||||
|
{:keys [os-family location-id architecture image-id hardware-id
|
||||||
|
os-name-matches os-version-matches os-description-matches
|
||||||
|
os-64-bit image-version-matches image-name-matches
|
||||||
|
image-description-matches min-cores min-ram
|
||||||
|
run-script install-private-key authorize-public-key
|
||||||
|
inbound-ports smallest fastest biggest any destroy-on-error]
|
||||||
|
:as options}]
|
||||||
|
(let [builder (.. compute (templateBuilder))]
|
||||||
|
(doseq [[option value] options]
|
||||||
|
(when-not (known-template-options option)
|
||||||
|
(condition/raise
|
||||||
|
:type :invalid-template-builder-option
|
||||||
|
:message (format "Invalid template builder option : %s" option)))
|
||||||
|
;; apply template builder options
|
||||||
|
(try
|
||||||
|
(apply-option builder template-map option value)
|
||||||
|
(catch Exception e
|
||||||
|
(condition/raise
|
||||||
|
:type :invalid-template-builder
|
||||||
|
:message (format
|
||||||
|
"Problem applying template builder %s with value %s: %s"
|
||||||
|
option (pr-str value) (.getMessage e))
|
||||||
|
:cause e))))
|
||||||
|
(let [template (.build builder)
|
||||||
|
template-options (.getOptions template)]
|
||||||
|
(doseq [[option value] options]
|
||||||
|
;; apply template option options
|
||||||
|
(try
|
||||||
|
(apply-option template-options options-map option value)
|
||||||
|
(catch Exception e
|
||||||
|
(condition/raise
|
||||||
|
:type :invalid-template-option
|
||||||
|
:message (format
|
||||||
|
"Problem applying template option %s with value %s: %s"
|
||||||
|
option (pr-str value) (.getMessage e))
|
||||||
|
:cause e))))
|
||||||
|
template)))
|
||||||
|
|
@ -0,0 +1,32 @@
|
||||||
|
;
|
||||||
|
;
|
||||||
|
; Copyright (C) 2011 Cloud Conscious, LLC. <info@cloudconscious.com>
|
||||||
|
;
|
||||||
|
; ====================================================================
|
||||||
|
; Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
|
; you may not use this file except in compliance with the License.
|
||||||
|
; You may obtain a copy of the License at
|
||||||
|
;
|
||||||
|
; http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
;
|
||||||
|
; Unless required by applicable law or agreed to in writing, software
|
||||||
|
; distributed under the License is distributed on an "AS IS" BASIS,
|
||||||
|
; WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
|
; See the License for the specific language governing permissions and
|
||||||
|
; limitations under the License.
|
||||||
|
; ====================================================================
|
||||||
|
;
|
||||||
|
(ns org.jclouds.predicate)
|
||||||
|
|
||||||
|
(defprotocol Predicate
|
||||||
|
"Protocol for making a com.google.common.base.Predicate."
|
||||||
|
(to-predicate [p]))
|
||||||
|
|
||||||
|
(extend-protocol Predicate
|
||||||
|
clojure.lang.IFn
|
||||||
|
(to-predicate [p]
|
||||||
|
(reify com.google.common.base.Predicate
|
||||||
|
(apply [this input] (p input))))
|
||||||
|
|
||||||
|
com.google.common.base.Predicate
|
||||||
|
(to-predicate [p] p))
|
||||||
|
|
@ -0,0 +1,101 @@
|
||||||
|
;
|
||||||
|
;
|
||||||
|
; Copyright (C) 2011 Cloud Conscious, LLC. <info@cloudconscious.com>
|
||||||
|
;
|
||||||
|
; ====================================================================
|
||||||
|
; Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
|
; you may not use this file except in compliance with the License.
|
||||||
|
; You may obtain a copy of the License at
|
||||||
|
;
|
||||||
|
; http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
;
|
||||||
|
; Unless required by applicable law or agreed to in writing, software
|
||||||
|
; distributed under the License is distributed on an "AS IS" BASIS,
|
||||||
|
; WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
|
; See the License for the specific language governing permissions and
|
||||||
|
; limitations under the License.
|
||||||
|
; ====================================================================
|
||||||
|
;
|
||||||
|
|
||||||
|
(ns org.jclouds.compute2-test
|
||||||
|
(:use [org.jclouds.compute2] :reload-all)
|
||||||
|
(:use clojure.test)
|
||||||
|
(:import
|
||||||
|
org.jclouds.compute.domain.OsFamily
|
||||||
|
clojure.contrib.condition.Condition))
|
||||||
|
|
||||||
|
|
||||||
|
(defmacro with-private-vars [[ns fns] & tests]
|
||||||
|
"Refers private fns from ns and runs tests in context. From users mailing
|
||||||
|
list, Alan Dipert and MeikelBrandmeyer."
|
||||||
|
`(let ~(reduce #(conj %1 %2 `@(ns-resolve '~ns '~%2)) [] fns)
|
||||||
|
~@tests))
|
||||||
|
|
||||||
|
(deftest os-families-test
|
||||||
|
(is (some #{"centos"} (map str (os-families)))))
|
||||||
|
|
||||||
|
(defn clean-stub-fixture
|
||||||
|
"This should allow basic tests to easily be run with another service."
|
||||||
|
[compute-service]
|
||||||
|
(fn [f]
|
||||||
|
(doseq [node (nodes compute-service)]
|
||||||
|
(destroy-node (.getId node)))
|
||||||
|
(f)))
|
||||||
|
|
||||||
|
(def *compute* (compute-service "stub" "" ""))
|
||||||
|
|
||||||
|
(use-fixtures :each (clean-stub-fixture *compute*))
|
||||||
|
|
||||||
|
(deftest compute-service?-test
|
||||||
|
(is (compute-service? *compute*)))
|
||||||
|
|
||||||
|
(deftest as-compute-service-test
|
||||||
|
(is (compute-service? (compute-service "stub" "user" "password")))
|
||||||
|
(is (compute-service? *compute*))
|
||||||
|
(is (compute-service? (compute-service (compute-context *compute*)))))
|
||||||
|
|
||||||
|
(defn in-group [group] #(= (.getGroup %) group))
|
||||||
|
|
||||||
|
(deftest nodes-test
|
||||||
|
(is (empty? (nodes *compute*)))
|
||||||
|
(is (create-node *compute* "fred" (build-template *compute* {} )))
|
||||||
|
(is (= 1 (count (nodes *compute*))))
|
||||||
|
(is (= 1 (count (nodes-in-group *compute* "fred"))))
|
||||||
|
(is (= 1 (count (nodes-with-details-matching *compute* (in-group "fred")))))
|
||||||
|
(is (= 1 (count (nodes-with-details-matching *compute*
|
||||||
|
(reify com.google.common.base.Predicate
|
||||||
|
(apply [this input] (= (.getGroup input) "fred")))))))
|
||||||
|
(is (= 0 (count (nodes-with-details-matching *compute* (in-group "othergroup")))))
|
||||||
|
(suspend-nodes-matching *compute* (in-group "fred"))
|
||||||
|
(is (suspended? (first (nodes-with-details-matching *compute* (in-group "fred")))))
|
||||||
|
(resume-nodes-matching *compute* (in-group "fred"))
|
||||||
|
(is (running? (first (nodes-in-group *compute* "fred"))))
|
||||||
|
(reboot-nodes-matching *compute* (in-group "fred"))
|
||||||
|
(is (running? (first (nodes-in-group *compute* "fred"))))
|
||||||
|
(is (create-nodes *compute* "fred" 2 (build-template *compute* {} )))
|
||||||
|
(is (= 3 (count (nodes-in-group *compute* "fred"))))
|
||||||
|
(is (= "fred" (group (first (nodes *compute*)))))
|
||||||
|
(destroy-nodes-matching *compute* (in-group "fred"))
|
||||||
|
(is (terminated? (first (nodes-in-group *compute* "fred")))))
|
||||||
|
|
||||||
|
(deftest build-template-test
|
||||||
|
(let [service (compute-service "stub" "user" "password")]
|
||||||
|
(testing "nullary"
|
||||||
|
(is (>= (-> (build-template service {:fastest true})
|
||||||
|
bean :hardware bean :processors first bean :cores)
|
||||||
|
8.0)))
|
||||||
|
(testing "one arg"
|
||||||
|
(is (> (-> (build-template service {:min-ram 512})
|
||||||
|
bean :hardware bean :ram)
|
||||||
|
512)))
|
||||||
|
(testing "enumerated"
|
||||||
|
(is (= OsFamily/CENTOS
|
||||||
|
(-> (build-template service {:os-family :centos})
|
||||||
|
bean :image bean :operatingSystem bean :family))))
|
||||||
|
(testing "varags"
|
||||||
|
(is (java.util.Arrays/equals
|
||||||
|
(int-array [22 8080])
|
||||||
|
(-> (build-template service {:inbound-ports [22 8080]})
|
||||||
|
bean :options bean :inboundPorts))))
|
||||||
|
(testing "invalid"
|
||||||
|
(is (thrown? Condition (build-template service {:xx :yy}))))))
|
||||||
Loading…
Reference in New Issue