Permalink
Browse files

changed name from tubes to flowjure

Signed-off-by: Luke VanderHart <luke.vanderhart@gmail.com>
  • Loading branch information...
1 parent 79b3d47 commit b10b4efd59d08731e056c045e7765f61cc01d149 Luke VanderHart committed Apr 23, 2009
View
14 My Tubes/test.pipe → My Pipes/test.pipe
@@ -1,26 +1,26 @@
(pipe {"id" "testpipe"
"name" "Test Aggregator"
"description" "Test RSS Aggregator"
- "require" ["tubes.components.rss" "tubes.components.simple-out"]
+ "require" ["flowjure.components.rss" "flowjure.components.simple-out"]
"args" []})
-(tubes.components.rss/rss {"id" "cnn"
+(flowjure.components.rss/rss {"id" "cnn"
"url" "http://rss.cnn.com/rss/cnn_topstories.rss"})
-(tubes.components.rss/rss {"id" "abc"
+(flowjure.components.rss/rss {"id" "abc"
"url" "http://feeds2.feedburner.com/AbcNews_TopStories"})
-(tubes.components.rss/rss {"id" "fox"
+(flowjure.components.rss/rss {"id" "fox"
"url" "http://feeds.foxnews.com/foxnews/latest"})
-(tubes.components.concatenate/concatenate {"id" "together"
+(flowjure.components.concatenate/concatenate {"id" "together"
"inputs" [(reference "cnn")
(reference "abc")
(reference "fox")]})
-(tubes.components.sort/sort-records {"id" "sorted"
+(flowjure.components.sort/sort-records {"id" "sorted"
"key" "title"
"input" (reference "together")})
-(tubes.components.simple-out/simple-out {"id" "output"
+(flowjure.components.simple-out/simple-out {"id" "output"
"input" (reference "sorted")})
View
4 src/tubes/components/concatenate.clj → src/flowjure/components/concatenate.clj
@@ -1,8 +1,8 @@
;; Author: Luke VanderHart
;; Creation Date: 4/16/2009
-(ns tubes.components.concatenate
- (:use tubes.engine))
+(ns flowjure.components.concatenate
+ (:use flowjure.engine))
(def-component {:name "concatenate"
:category "Transform"
View
4 src/tubes/components/rss.clj → src/flowjure/components/rss.clj
@@ -1,10 +1,10 @@
;; Author: Luke VanderHart
;; Creation Date: 4/16/2009
-(ns tubes.components.rss
+(ns flowjure.components.rss
(:require [clojure.xml :as xml]
[clojure.zip :as zip])
- (:use tubes.engine))
+ (:use flowjure.engine))
(defn create-map
"Creates a map object from an RSS 'item' entry"
View
4 src/tubes/components/simple_out.clj → src/flowjure/components/simple_out.clj
@@ -1,9 +1,9 @@
;; Author: Luke VanderHart
;; Creation Date: 4/16/2009
-(ns tubes.components.simple-out
+(ns flowjure.components.simple-out
(:require [clojure.contrib.pprint :as pprint])
- (:use tubes.engine))
+ (:use flowjure.engine))
(def-component {:name "simple-out"
:category "Output"
View
4 src/tubes/components/sort.clj → src/flowjure/components/sort.clj
@@ -1,8 +1,8 @@
;; Author: Luke VanderHart
;; Creation Date: 4/16/2009
-(ns tubes.components.sort
- (:use tubes.engine))
+(ns flowjure.components.sort
+ (:use flowjure.engine))
(def-component {:name "sort-records"
:category "Transform"
View
8 src/tubes/engine.clj → src/flowjure/engine.clj
@@ -1,7 +1,7 @@
;; Author: Luke VanderHart
;; Creation Date: 4/16/2009
-(ns tubes.engine)
+(ns flowjure.engine)
(def *pipe* nil)
(def *pipe-args* nil)
@@ -35,7 +35,7 @@ pipe's arguments and returns the pipe's output value when called."
(apply (@pipe "pipe-output")))))))))
(defmacro pipe
- "Macro that handles the 'pipe' form in a tube definition. Adds the config
+ "Macro that handles the 'pipe' form in a pipe definition. Adds the config
object as metadata to the *pipe* object."
[config]
`(do
@@ -82,8 +82,8 @@ It must return a seq unless it is of type 'Output'"
~(:description component-cfg)
[args#]
(let [action-fun# ~fun
- pipe# tubes.engine/*pipe*
- pipe-args# tubes.engine/*pipe-args*]
+ pipe# flowjure.engine/*pipe*
+ pipe-args# flowjure.engine/*pipe-args*]
(dosync
(let [pipe-key# (if (= (:category ~component-cfg) "Output")
"pipe-output"

0 comments on commit b10b4ef

Please sign in to comment.