"strings"
"syscall"
"time"
- "git.curoverse.com/arvados.git/sdk/go/arvadosclient"
"git.curoverse.com/arvados.git/sdk/go/keepclient"
)
}
// Initialize Pull queue and worker
- arv, err := arvadosclient.MakeArvadosClient()
- if err != nil {
- log.Fatalf("Error setting up arvados client %s", err.Error())
- }
-
- keepClient, err := keepclient.MakeKeepClient(&arv)
- if err != nil {
- log.Fatalf("Error setting up keep client %s", err.Error())
+ keepClient = keepclient.KeepClient{
+ Arvados: nil,
+ Want_replicas: 1,
+ Using_proxy: true,
+ Client: &http.Client{},
}
pullq = NewWorkQueue()