mirror of
https://github.com/kopia/kopia.git
synced 2025-12-23 22:57:50 -05:00
fe55dcb6a2
* test(providers): added capacity limits to blobtesting.mapStorage * refactor(general): added mutex map which dynamically allocates and releases named mutexes * refactor(repository): refactored cache cleanup and limit enforcement * refactor(repository): plumb through cache size limits in the repository * feat(cli): added CLI options to set cache size limits * unified flag setting and field naming * Update cli/command_cache_set.go Co-authored-by: Shikhar Mall <mall.shikhar.in@gmail.com> * pr feedback --------- Co-authored-by: Shikhar Mall <mall.shikhar.in@gmail.com>
64 lines
1.8 KiB
Go
64 lines
1.8 KiB
Go
package cli_test
|
|
|
|
import (
|
|
"strings"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/require"
|
|
|
|
"github.com/kopia/kopia/internal/testutil"
|
|
"github.com/kopia/kopia/tests/testenv"
|
|
)
|
|
|
|
func TestCacheSet(t *testing.T) {
|
|
env := testenv.NewCLITest(t, testenv.RepoFormatNotImportant, testenv.NewInProcRunner(t))
|
|
|
|
env.RunAndExpectSuccess(t, "repo", "create", "filesystem", "--path", env.RepoDir)
|
|
|
|
// no changes
|
|
env.RunAndExpectFailure(t, "cache", "set")
|
|
|
|
ncd := testutil.TempDirectory(t)
|
|
|
|
env.RunAndExpectSuccess(t,
|
|
"cache", "set",
|
|
"--cache-directory", ncd,
|
|
"--max-list-cache-duration=55s",
|
|
)
|
|
|
|
env.RunAndExpectSuccess(t,
|
|
"cache", "set",
|
|
"--cache-directory", ncd,
|
|
"--content-cache-size-mb=33",
|
|
"--content-cache-size-limit-mb=331",
|
|
"--metadata-cache-size-mb=44",
|
|
"--metadata-cache-size-limit-mb=441",
|
|
)
|
|
|
|
out := env.RunAndExpectSuccess(t, "cache", "info")
|
|
require.Contains(t, mustGetLineContaining(t, out, "33 MB"), ncd)
|
|
require.Contains(t, mustGetLineContaining(t, out, "soft limit: 33 MB"), "contents")
|
|
require.Contains(t, mustGetLineContaining(t, out, "hard limit: 331 MB"), "contents")
|
|
require.Contains(t, mustGetLineContaining(t, out, "min sweep age: 10m0s"), "contents")
|
|
|
|
require.Contains(t, mustGetLineContaining(t, out, "soft limit: 44 MB"), "metadata")
|
|
require.Contains(t, mustGetLineContaining(t, out, "hard limit: 441 MB"), "metadata")
|
|
require.Contains(t, mustGetLineContaining(t, out, "min sweep age: 24h0m0s"), "metadata")
|
|
|
|
require.Contains(t, mustGetLineContaining(t, out, "55s"), "blob-list")
|
|
}
|
|
|
|
func mustGetLineContaining(t *testing.T, lines []string, containing string) string {
|
|
t.Helper()
|
|
|
|
for _, l := range lines {
|
|
if strings.Contains(l, containing) {
|
|
return l
|
|
}
|
|
}
|
|
|
|
t.Fatalf("no line containing %q found in %v", containing, lines)
|
|
|
|
return ""
|
|
}
|