Skip to content

Commit 97ffb9e

Browse files
committed
add cbt interfaces
Signed-off-by: Lyndon-Li <lyonghui@vmware.com>
1 parent eaef4ea commit 97ffb9e

3 files changed

Lines changed: 81 additions & 0 deletions

File tree

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
Fix issue #9709, add interfaces for CBT service and CBT bitmap

pkg/cbtservice/service.go

Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,34 @@
1+
/*
2+
Copyright The Velero Contributors.
3+
4+
Licensed under the Apache License, Version 2.0 (the "License");
5+
you may not use this file except in compliance with the License.
6+
You may obtain a copy of the License at
7+
8+
http://www.apache.org/licenses/LICENSE-2.0
9+
10+
Unless required by applicable law or agreed to in writing, software
11+
distributed under the License is distributed on an "AS IS" BASIS,
12+
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
See the License for the specific language governing permissions and
14+
limitations under the License.
15+
*/
16+
17+
package cbtservice
18+
19+
import "context"
20+
21+
// Range defines the range of a change
22+
type Range struct {
23+
Offset int64
24+
Length int64
25+
}
26+
27+
// Service defines the methods for CBT service which could be implemented by Kubernetes SnapshotMetadataService or other customized services
28+
type Service interface {
29+
// GetAllocatedBlocks enumerates the allocated blocks of the snapshot and call the record callback
30+
GetAllocatedBlocks(ctx context.Context, snapshot string, record func([]Range) error) error
31+
32+
// GetChangedBlocks enumerates the changed blocks of the snapshot since PIT of changeID and call the record callback
33+
GetChangedBlocks(ctx context.Context, snapshot string, changeID string, record func([]Range) error) error
34+
}

pkg/uploader/cbt/bitmap.go

Lines changed: 46 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,46 @@
1+
/*
2+
Copyright The Velero Contributors.
3+
4+
Licensed under the Apache License, Version 2.0 (the "License");
5+
you may not use this file except in compliance with the License.
6+
You may obtain a copy of the License at
7+
8+
http://www.apache.org/licenses/LICENSE-2.0
9+
10+
Unless required by applicable law or agreed to in writing, software
11+
distributed under the License is distributed on an "AS IS" BASIS,
12+
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
See the License for the specific language governing permissions and
14+
limitations under the License.
15+
*/
16+
17+
package cbt
18+
19+
import "github.com/vmware-tanzu/velero/pkg/cbtservice"
20+
21+
// Bitmap defines the methods to store and iterate the CBT bitmap
22+
type Bitmap interface {
23+
// Set sets bits within the provided range
24+
Set(cbtservice.Range)
25+
26+
// Iterator returns the iterator for the CBT Bitmap
27+
Iterator() Iterator
28+
}
29+
30+
// Iterator defines the methods to iterate the CBT bitmap and query the associated information
31+
type Iterator interface {
32+
// ChangeID returns the changeID of the bitmap
33+
ChangeID() string
34+
35+
// SnapshotID returns snapshotID of the bitmap
36+
SnapshotID() string
37+
38+
// BlockSize returns the granularity of the bitmap
39+
BlockSize() int
40+
41+
// Count returns the toal number of count in the bitmap
42+
Count() uint64
43+
44+
// Next returns the offset of the next set block and whether it comes to the end of the iteration
45+
Next() (int64, bool)
46+
}

0 commit comments

Comments
 (0)