Client: &http.Client{},
}
+ // Initialize the pullq and worker
pullq = NewWorkQueue()
go RunPullWorker(pullq, keepClient)
+ // Initialize the trashq and worker
+ trashq = NewWorkQueue()
+ go RunTrashWorker(trashq)
+
// Shut down the server gracefully (by closing the listener)
// if SIGTERM is received.
term := make(chan os.Signal, 1)