X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/765604b096c464b242e60860ace75bd6645fd4e7..c68e4ba51336a871dff26ae9f8dc7eb7e316083d:/sdk/go/arvadostest/api.go diff --git a/sdk/go/arvadostest/api.go b/sdk/go/arvadostest/api.go index 9b51e5ce2e..4e214414d7 100644 --- a/sdk/go/arvadostest/api.go +++ b/sdk/go/arvadostest/api.go @@ -8,12 +8,15 @@ import ( "context" "encoding/json" "errors" + "io" + "net/http" "net/url" "reflect" "runtime" "sync" "git.arvados.org/arvados.git/sdk/go/arvados" + "git.arvados.org/arvados.git/sdk/go/httpserver" ) var ErrStubUnimplemented = errors.New("stub unimplemented") @@ -45,6 +48,26 @@ func (as *APIStub) Logout(ctx context.Context, options arvados.LogoutOptions) (a as.appendCall(ctx, as.Logout, options) return arvados.LogoutResponse{}, as.Error } +func (as *APIStub) AuthorizedKeyCreate(ctx context.Context, options arvados.CreateOptions) (arvados.AuthorizedKey, error) { + as.appendCall(ctx, as.AuthorizedKeyCreate, options) + return arvados.AuthorizedKey{}, as.Error +} +func (as *APIStub) AuthorizedKeyUpdate(ctx context.Context, options arvados.UpdateOptions) (arvados.AuthorizedKey, error) { + as.appendCall(ctx, as.AuthorizedKeyUpdate, options) + return arvados.AuthorizedKey{}, as.Error +} +func (as *APIStub) AuthorizedKeyGet(ctx context.Context, options arvados.GetOptions) (arvados.AuthorizedKey, error) { + as.appendCall(ctx, as.AuthorizedKeyGet, options) + return arvados.AuthorizedKey{}, as.Error +} +func (as *APIStub) AuthorizedKeyList(ctx context.Context, options arvados.ListOptions) (arvados.AuthorizedKeyList, error) { + as.appendCall(ctx, as.AuthorizedKeyList, options) + return arvados.AuthorizedKeyList{}, as.Error +} +func (as *APIStub) AuthorizedKeyDelete(ctx context.Context, options arvados.DeleteOptions) (arvados.AuthorizedKey, error) { + as.appendCall(ctx, as.AuthorizedKeyDelete, options) + return arvados.AuthorizedKey{}, as.Error +} func (as *APIStub) CollectionCreate(ctx context.Context, options arvados.CreateOptions) (arvados.Collection, error) { as.appendCall(ctx, as.CollectionCreate, options) return arvados.Collection{}, as.Error @@ -141,6 +164,22 @@ func (as *APIStub) ContainerRequestDelete(ctx context.Context, options arvados.D as.appendCall(ctx, as.ContainerRequestDelete, options) return arvados.ContainerRequest{}, as.Error } +func (as *APIStub) ContainerRequestLog(ctx context.Context, options arvados.ContainerLogOptions) (http.Handler, error) { + as.appendCall(ctx, as.ContainerRequestLog, options) + // Return a handler that responds with the configured + // error/success status. + return http.HandlerFunc(func(w http.ResponseWriter, _ *http.Request) { + if as.Error == nil { + w.WriteHeader(http.StatusOK) + } else if err := httpserver.HTTPStatusError(nil); errors.As(as.Error, &err) { + w.WriteHeader(err.HTTPStatus()) + io.WriteString(w, err.Error()) + } else { + w.WriteHeader(http.StatusInternalServerError) + io.WriteString(w, err.Error()) + } + }), nil +} func (as *APIStub) GroupCreate(ctx context.Context, options arvados.CreateOptions) (arvados.Group, error) { as.appendCall(ctx, as.GroupCreate, options) return arvados.Group{}, as.Error