X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/c72b6bb73def5f60f0a10f5bbb75f9228980dd8c..d6446b03e2f5d5079a870bdd7b963456dc12b485:/sdk/go/arvados/fs_backend.go diff --git a/sdk/go/arvados/fs_backend.go b/sdk/go/arvados/fs_backend.go index 9ae0fc3a5f..cc4c32ffe9 100644 --- a/sdk/go/arvados/fs_backend.go +++ b/sdk/go/arvados/fs_backend.go @@ -4,7 +4,11 @@ package arvados -import "io" +import ( + "context" + "errors" + "io" +) type fsBackend interface { keepClient @@ -20,11 +24,23 @@ type keepBackend struct { type keepClient interface { ReadAt(locator string, p []byte, off int) (int, error) - PutB(p []byte) (string, int, error) + BlockWrite(context.Context, BlockWriteOptions) (BlockWriteResponse, error) LocalLocator(locator string) (string, error) } type apiClient interface { RequestAndDecode(dst interface{}, method, path string, body io.Reader, params interface{}) error - UpdateBody(rsc resource) io.Reader +} + +var errStubClient = errors.New("stub client") + +type StubClient struct{} + +func (*StubClient) ReadAt(string, []byte, int) (int, error) { return 0, errStubClient } +func (*StubClient) LocalLocator(loc string) (string, error) { return loc, nil } +func (*StubClient) BlockWrite(context.Context, BlockWriteOptions) (BlockWriteResponse, error) { + return BlockWriteResponse{}, errStubClient +} +func (*StubClient) RequestAndDecode(_ interface{}, _, _ string, _ io.Reader, _ interface{}) error { + return errStubClient }