X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/1dee1aad0573bf3a54d536c8dd3693a352cf0cbe..85d79eb901f52a2fb10fae4bc64b8f9a18dff781:/services/keepstore/trash_worker.go diff --git a/services/keepstore/trash_worker.go b/services/keepstore/trash_worker.go index 3b1bd04230..d7c73127eb 100644 --- a/services/keepstore/trash_worker.go +++ b/services/keepstore/trash_worker.go @@ -2,22 +2,17 @@ // // SPDX-License-Identifier: AGPL-3.0 -package main +package keepstore import ( "errors" "time" - "git.curoverse.com/arvados.git/sdk/go/arvados" + "git.arvados.org/arvados.git/sdk/go/arvados" "github.com/sirupsen/logrus" ) -// RunTrashWorker is used by Keepstore to initiate trash worker channel goroutine. -// The channel will process trash list. -// For each (next) trash request: -// Delete the block indicated by the trash request Locator -// Repeat -// +// RunTrashWorker processes the trash request queue. func RunTrashWorker(volmgr *RRVolumeManager, logger logrus.FieldLogger, cluster *arvados.Cluster, trashq *WorkQueue) { for item := range trashq.NextItem { trashRequest := item.(TrashRequest)