MCPcopy
hub / github.com/wal-g/wal-g / CreateMockStorageFolder

Function CreateMockStorageFolder

internal/delete_handler_test.go:14–28  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

12)
13
14func CreateMockStorageFolder() storage.Folder {
15 var folder = memory.NewFolder("in_memory/", memory.NewKVS())
16 subFolder := folder.GetSubFolder("basebackups_005/")
17 subFolder.PutObject("base_123_backup_stop_sentinel.json", &bytes.Buffer{})
18 subFolder.PutObject("base_456_backup_stop_sentinel.json", strings.NewReader("{}"))
19 subFolder.PutObject("base_000_backup_stop_sentinel.json", &bytes.Buffer{}) // last put
20 subFolder.PutObject("base_123312", &bytes.Buffer{}) // not a sentinel
21 subFolder.PutObject("base_321/nop", &bytes.Buffer{})
22 subFolder.PutObject("folder123/nop", &bytes.Buffer{})
23 subFolder.PutObject("base_456/tar_partitions/1", &bytes.Buffer{})
24 subFolder.PutObject("base_456/tar_partitions/2", &bytes.Buffer{})
25 subFolder.PutObject("base_456/tar_partitions/3", &bytes.Buffer{})
26 subFolder.PutObject("base_456/some_folder/3", &bytes.Buffer{})
27 return folder
28}
29
30func CreateMockDeleteHandler(backups []BackupObject, folder storage.Folder) *DeleteHandler {
31 lessFunction := func(object1, object2 storage.Object) bool { return object1.GetName() < object2.GetName() }

Callers 5

TestDeleteOldObjectsFunction · 0.70
TestFindTargetByNameFunction · 0.70

Calls 5

NewFolderFunction · 0.92
NewKVSFunction · 0.92
NewReaderMethod · 0.80
GetSubFolderMethod · 0.65
PutObjectMethod · 0.65

Tested by

no test coverage detected