X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/4554374c672ee56608c9ddbd6a48486fe20c90d1..c7d05b1dda46923dbf807caca85767429c122341:/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)