extern/rclone
1
0
Fork 0
mirror of https://github.com/rclone/rclone.git synced 2025-08-18 09:30:03 +02:00
Code Issues Packages Projects Releases Wiki Activity

rc: Add operations/settier to API

Browse Source
This commit is contained in:
Drew Stinnett
2023-09-05 13:57:23 -04:00
committed by Nick Craig-Wood
parent ed755bf04f
commit 643386f026
3 changed files with 93 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

55
fs/operations/rc_test.go
View File

@@ -307,6 +307,61 @@ func TestRcStat(t *testing.T) {
})
}
// operations/settier: Set the storage tier of a fs
func TestRcSetTier(t *testing.T) {
ctx := context.Background()
r, call := rcNewRun(t, "operations/settier")
if !r.Fremote.Features().SetTier {
t.Skip("settier not supported")
}
file1 := r.WriteObject(context.Background(), "file1", "file1 contents", t1)
r.CheckRemoteItems(t, file1)
// Because we don't know what the current tier options here are, let's
// just get the current tier, and re-use that
o, err := r.Fremote.NewObject(ctx, file1.Path)
require.NoError(t, err)
trr, ok := o.(fs.GetTierer)
require.True(t, ok)
ctier := trr.GetTier()
in := rc.Params{
"fs": r.FremoteName,
"tier": ctier,
}
out, err := call.Fn(context.Background(), in)
require.NoError(t, err)
assert.Equal(t, rc.Params(nil), out)
}
// operations/settier: Set the storage tier of a file
func TestRcSetTierFile(t *testing.T) {
ctx := context.Background()
r, call := rcNewRun(t, "operations/settierfile")
if !r.Fremote.Features().SetTier {
t.Skip("settier not supported")
}
file1 := r.WriteObject(context.Background(), "file1", "file1 contents", t1)
r.CheckRemoteItems(t, file1)
// Because we don't know what the current tier options here are, let's
// just get the current tier, and re-use that
o, err := r.Fremote.NewObject(ctx, file1.Path)
require.NoError(t, err)
trr, ok := o.(fs.GetTierer)
require.True(t, ok)
ctier := trr.GetTier()
in := rc.Params{
"fs": r.FremoteName,
"remote": "file1",
"tier": ctier,
}
out, err := call.Fn(context.Background(), in)
require.NoError(t, err)
assert.Equal(t, rc.Params(nil), out)
}
// operations/mkdir: Make a destination directory or container
func TestRcMkdir(t *testing.T) {
ctx := context.Background()