X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/df591042778408d03d410d5c22a669d85652d1ea..44c93373e97da98645d41ae8f09c6eef6788bb26:/sdk/go/arvados/fs_backend.go diff --git a/sdk/go/arvados/fs_backend.go b/sdk/go/arvados/fs_backend.go index 301f0b48be..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,10 +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 }