summaryrefslogtreecommitdiff
path: root/bookpipeline/cmd/lspipeline/main.go
diff options
context:
space:
mode:
authorNick White <git@njw.name>2019-10-02 12:32:59 +0100
committerNick White <git@njw.name>2019-10-02 12:32:59 +0100
commit94352c6124aed2d85cfb21e83c0dafb6f918fb7d (patch)
tree6bf574be2db265f714d16bf0140b5c3056b408e8 /bookpipeline/cmd/lspipeline/main.go
parent33e538c56f7513f1b98cab16de771a47a0e2a300 (diff)
Add wipeonly queue and functionality
This is useful for prebinarised images, which don't need full preprocessing, but do require wiping, albeit with a more conservative threshold.
Diffstat (limited to 'bookpipeline/cmd/lspipeline/main.go')
-rw-r--r--bookpipeline/cmd/lspipeline/main.go2
1 files changed, 2 insertions, 0 deletions
diff --git a/bookpipeline/cmd/lspipeline/main.go b/bookpipeline/cmd/lspipeline/main.go
index 3e9df61..46a1d63 100644
--- a/bookpipeline/cmd/lspipeline/main.go
+++ b/bookpipeline/cmd/lspipeline/main.go
@@ -24,6 +24,7 @@ Lists useful things related to the pipeline.
type LsPipeliner interface {
Init() error
PreQueueId() string
+ WipeQueueId() string
OCRQueueId() string
AnalyseQueueId() string
GetQueueDetails(url string) (string, string, error)
@@ -57,6 +58,7 @@ func getInstances(conn LsPipeliner, detailsc chan bookpipeline.InstanceDetails)
func getQueueDetails(conn LsPipeliner, qdetails chan queueDetails) {
queues := []struct{ name, id string }{
{"preprocess", conn.PreQueueId()},
+ {"wipeonly", conn.WipeQueueId()},
{"ocr", conn.OCRQueueId()},
{"analyse", conn.AnalyseQueueId()},
}