summaryrefslogtreecommitdiff
path: root/cmd/mkpipeline
diff options
context:
space:
mode:
Diffstat (limited to 'cmd/mkpipeline')
-rw-r--r--cmd/mkpipeline/main.go31
1 files changed, 4 insertions, 27 deletions
diff --git a/cmd/mkpipeline/main.go b/cmd/mkpipeline/main.go
index ab68d9a..b15e9ef 100644
--- a/cmd/mkpipeline/main.go
+++ b/cmd/mkpipeline/main.go
@@ -4,11 +4,6 @@
package main
-// TODO: set up iam role and policy needed for ec2 instances to access this stuff;
-// see arn:aws:iam::557852942063:policy/pipelinestorageandqueue
-// and arn:aws:iam::557852942063:role/pipeliner
-// TODO: set up launch template for ec2 instances
-
import (
"log"
"os"
@@ -18,8 +13,7 @@ import (
type MkPipeliner interface {
MinimalInit() error
- CreateBucket(string) error
- CreateQueue(string) error
+ MkPipeline() error
}
func main() {
@@ -34,25 +28,8 @@ func main() {
log.Fatalln("Failed to set up cloud connection:", err)
}
- prefix := "rescribe"
- buckets := []string{"inprogress", "done"}
- queues := []string{"preprocess", "wipeonly", "ocr", "analyse", "ocrpage"}
-
- for _, bucket := range buckets {
- bname := prefix + bucket
- log.Printf("Creating bucket %s\n", bname)
- err = conn.CreateBucket(bname)
- if err != nil {
- log.Fatalln(err)
- }
- }
-
- for _, queue := range queues {
- qname := prefix + queue
- log.Printf("Creating queue %s\n", qname)
- err = conn.CreateQueue(qname)
- if err != nil {
- log.Fatalln(err)
- }
+ err = conn.MkPipeline()
+ if err != nil {
+ log.Fatalln("MkPipeline failed:", err)
}
}