-func RunKeep(params keep.GetKeepServersParams) {
- readServers := keep.GetKeepServers(params)
-
- log.Printf("Returned %d keep disks", len(readServers.ServerToContents))
-
- blockReplicationCounts := make(map[int]int)
- for _, infos := range readServers.BlockToServers {
- replication := len(infos)
- blockReplicationCounts[replication] += 1
- }
-
- log.Printf("Replication level distribution: %v", blockReplicationCounts)
-}
-
-func ComputeSizeOfOwnedCollections(readCollections collection.ReadCollections) (
- results map[string]int) {
- results = make(map[string]int)
- for _, coll := range readCollections.UuidToCollection {
- results[coll.OwnerUuid] = results[coll.OwnerUuid] + coll.TotalSize
+ // Log that we're finished. We force the recording, since go will
+ // not wait for the timer before exiting.
+ if arvLogger != nil {
+ arvLogger.FinalUpdate(func(p map[string]interface{}, e map[string]interface{}) {
+ p["run_info"].(map[string]interface{})["finished_at"] = time.Now()
+ })