X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/9eca684a1c2b52689986797d84f927dccef30ea9..c68e4ba51336a871dff26ae9f8dc7eb7e316083d:/sdk/go/arvadostest/api.go diff --git a/sdk/go/arvadostest/api.go b/sdk/go/arvadostest/api.go index 9c70e9776a..4e214414d7 100644 --- a/sdk/go/arvadostest/api.go +++ b/sdk/go/arvadostest/api.go @@ -136,22 +136,6 @@ func (as *APIStub) ContainerUnlock(ctx context.Context, options arvados.GetOptio as.appendCall(ctx, as.ContainerUnlock, options) return arvados.Container{}, as.Error } -func (as *APIStub) ContainerLog(ctx context.Context, options arvados.ContainerLogOptions) (http.Handler, error) { - as.appendCall(ctx, as.ContainerLog, 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) ContainerSSH(ctx context.Context, options arvados.ContainerSSHOptions) (arvados.ConnectionResponse, error) { as.appendCall(ctx, as.ContainerSSH, options) return arvados.ConnectionResponse{}, as.Error @@ -180,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