blob: de10112b752ed891b552d3c23dca2c52fbe777aa (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
|
// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#pragma once
#include <vespa/document/bucket/bucketspace.h>
#include <vespa/storage/bucketdb/bucketdatabase.h>
namespace storage::distributor {
class MaintenanceScanner
{
public:
virtual ~MaintenanceScanner() = default;
class ScanResult {
bool _done;
document::BucketSpace _bucketSpace;
BucketDatabase::Entry _entry;
public:
[[nodiscard]] bool isDone() const noexcept { return _done; }
document::BucketSpace getBucketSpace() const noexcept { return _bucketSpace; }
const BucketDatabase::Entry& getEntry() const noexcept { return _entry; }
static ScanResult createDone() { return ScanResult(true); }
static ScanResult createNotDone(document::BucketSpace bucketSpace, BucketDatabase::Entry entry) {
return ScanResult(bucketSpace, std::move(entry));
}
private:
explicit ScanResult(bool done) noexcept
: _done(done),
_bucketSpace(document::BucketSpace::invalid()),
_entry()
{}
ScanResult(document::BucketSpace bucketSpace, BucketDatabase::Entry e) noexcept
: _done(false),
_bucketSpace(bucketSpace),
_entry(std::move(e))
{}
};
virtual ScanResult scanNext() = 0;
};
}
|
