X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/a95f899d7ac84f29b3d019aa410d265bb40833e5..b117de413113ab28e2f2e5a2ebd73830fcef96dc:/services/keepstore/volume_test.go diff --git a/services/keepstore/volume_test.go b/services/keepstore/volume_test.go index 5671b8d4a9..43ddd090cc 100644 --- a/services/keepstore/volume_test.go +++ b/services/keepstore/volume_test.go @@ -1,7 +1,12 @@ +// Copyright (C) The Arvados Authors. All rights reserved. +// +// SPDX-License-Identifier: AGPL-3.0 + package main import ( "bytes" + "context" "crypto/md5" "errors" "fmt" @@ -95,7 +100,7 @@ func (v *MockVolume) gotCall(method string) { } } -func (v *MockVolume) Compare(loc string, buf []byte) error { +func (v *MockVolume) Compare(ctx context.Context, loc string, buf []byte) error { v.gotCall("Compare") <-v.Gate if v.Bad { @@ -113,7 +118,7 @@ func (v *MockVolume) Compare(loc string, buf []byte) error { } } -func (v *MockVolume) Get(loc string, buf []byte) (int, error) { +func (v *MockVolume) Get(ctx context.Context, loc string, buf []byte) (int, error) { v.gotCall("Get") <-v.Gate if v.Bad { @@ -125,7 +130,7 @@ func (v *MockVolume) Get(loc string, buf []byte) (int, error) { return 0, os.ErrNotExist } -func (v *MockVolume) Put(loc string, block []byte) error { +func (v *MockVolume) Put(ctx context.Context, loc string, block []byte) error { v.gotCall("Put") <-v.Gate if v.Bad { @@ -189,7 +194,7 @@ func (v *MockVolume) Trash(loc string) error { return MethodDisabledError } if _, ok := v.Store[loc]; ok { - if time.Since(v.Timestamps[loc]) < blobSignatureTTL { + if time.Since(v.Timestamps[loc]) < time.Duration(theConfig.BlobSignatureTTL) { return nil } delete(v.Store, loc) @@ -198,7 +203,18 @@ func (v *MockVolume) Trash(loc string) error { return os.ErrNotExist } -// TBD +func (v *MockVolume) DeviceID() string { + return "mock-device-id" +} + +func (v *MockVolume) Type() string { + return "Mock" +} + +func (v *MockVolume) Start() error { + return nil +} + func (v *MockVolume) Untrash(loc string) error { return nil } @@ -225,3 +241,7 @@ func (v *MockVolume) Replication() int { func (v *MockVolume) EmptyTrash() { } + +func (v *MockVolume) GetStorageClasses() []string { + return nil +}