From 35da684ec943926c190bb4fa54c95f266dd826a1 Mon Sep 17 00:00:00 2001 From: Alex <33497058+bexsoft@users.noreply.github.com> Date: Tue, 4 May 2021 11:56:33 -0500 Subject: [PATCH] Added direct-csi API support to console (#710) --- models/csi_format_error_response.go | 66 ++++++++ models/format_configuration.go | 99 +++++++++++ models/format_direct_c_s_i_drives_response.go | 97 +++++++++++ restapi/admin_direct_csi.go | 111 +++++++++++++ restapi/embedded_spec.go | 154 ++++++++++++++++++ .../admin_api/direct_c_s_i_format_drive.go | 90 ++++++++++ .../direct_c_s_i_format_drive_parameters.go | 94 +++++++++++ .../direct_c_s_i_format_drive_responses.go | 133 +++++++++++++++ .../direct_c_s_i_format_drive_urlbuilder.go | 104 ++++++++++++ restapi/operations/console_api.go | 12 ++ swagger.yml | 54 ++++++ 11 files changed, 1014 insertions(+) create mode 100644 models/csi_format_error_response.go create mode 100644 models/format_configuration.go create mode 100644 models/format_direct_c_s_i_drives_response.go create mode 100644 restapi/operations/admin_api/direct_c_s_i_format_drive.go create mode 100644 restapi/operations/admin_api/direct_c_s_i_format_drive_parameters.go create mode 100644 restapi/operations/admin_api/direct_c_s_i_format_drive_responses.go create mode 100644 restapi/operations/admin_api/direct_c_s_i_format_drive_urlbuilder.go diff --git a/models/csi_format_error_response.go b/models/csi_format_error_response.go new file mode 100644 index 000000000..d9a579d44 --- /dev/null +++ b/models/csi_format_error_response.go @@ -0,0 +1,66 @@ +// Code generated by go-swagger; DO NOT EDIT. + +// This file is part of MinIO Console Server +// Copyright (c) 2021 MinIO, Inc. +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU Affero General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +// GNU Affero General Public License for more details. +// +// You should have received a copy of the GNU Affero General Public License +// along with this program. If not, see . +// + +package models + +// This file was generated by the swagger tool. +// Editing this file might prove futile when you re-run the swagger generate command + +import ( + "github.com/go-openapi/strfmt" + "github.com/go-openapi/swag" +) + +// CsiFormatErrorResponse csi format error response +// +// swagger:model csiFormatErrorResponse +type CsiFormatErrorResponse struct { + + // drive + Drive string `json:"drive,omitempty"` + + // error + Error string `json:"error,omitempty"` + + // node + Node string `json:"node,omitempty"` +} + +// Validate validates this csi format error response +func (m *CsiFormatErrorResponse) Validate(formats strfmt.Registry) error { + return nil +} + +// MarshalBinary interface implementation +func (m *CsiFormatErrorResponse) MarshalBinary() ([]byte, error) { + if m == nil { + return nil, nil + } + return swag.WriteJSON(m) +} + +// UnmarshalBinary interface implementation +func (m *CsiFormatErrorResponse) UnmarshalBinary(b []byte) error { + var res CsiFormatErrorResponse + if err := swag.ReadJSON(b, &res); err != nil { + return err + } + *m = res + return nil +} diff --git a/models/format_configuration.go b/models/format_configuration.go new file mode 100644 index 000000000..d667ccab2 --- /dev/null +++ b/models/format_configuration.go @@ -0,0 +1,99 @@ +// Code generated by go-swagger; DO NOT EDIT. + +// This file is part of MinIO Console Server +// Copyright (c) 2021 MinIO, Inc. +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU Affero General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +// GNU Affero General Public License for more details. +// +// You should have received a copy of the GNU Affero General Public License +// along with this program. If not, see . +// + +package models + +// This file was generated by the swagger tool. +// Editing this file might prove futile when you re-run the swagger generate command + +import ( + "github.com/go-openapi/errors" + "github.com/go-openapi/strfmt" + "github.com/go-openapi/swag" + "github.com/go-openapi/validate" +) + +// FormatConfiguration format configuration +// +// swagger:model formatConfiguration +type FormatConfiguration struct { + + // drives + // Required: true + // Min Length: 1 + Drives []string `json:"drives"` + + // force + // Required: true + Force *bool `json:"force"` +} + +// Validate validates this format configuration +func (m *FormatConfiguration) Validate(formats strfmt.Registry) error { + var res []error + + if err := m.validateDrives(formats); err != nil { + res = append(res, err) + } + + if err := m.validateForce(formats); err != nil { + res = append(res, err) + } + + if len(res) > 0 { + return errors.CompositeValidationError(res...) + } + return nil +} + +func (m *FormatConfiguration) validateDrives(formats strfmt.Registry) error { + + if err := validate.Required("drives", "body", m.Drives); err != nil { + return err + } + + return nil +} + +func (m *FormatConfiguration) validateForce(formats strfmt.Registry) error { + + if err := validate.Required("force", "body", m.Force); err != nil { + return err + } + + return nil +} + +// MarshalBinary interface implementation +func (m *FormatConfiguration) MarshalBinary() ([]byte, error) { + if m == nil { + return nil, nil + } + return swag.WriteJSON(m) +} + +// UnmarshalBinary interface implementation +func (m *FormatConfiguration) UnmarshalBinary(b []byte) error { + var res FormatConfiguration + if err := swag.ReadJSON(b, &res); err != nil { + return err + } + *m = res + return nil +} diff --git a/models/format_direct_c_s_i_drives_response.go b/models/format_direct_c_s_i_drives_response.go new file mode 100644 index 000000000..76160233c --- /dev/null +++ b/models/format_direct_c_s_i_drives_response.go @@ -0,0 +1,97 @@ +// Code generated by go-swagger; DO NOT EDIT. + +// This file is part of MinIO Console Server +// Copyright (c) 2021 MinIO, Inc. +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU Affero General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +// GNU Affero General Public License for more details. +// +// You should have received a copy of the GNU Affero General Public License +// along with this program. If not, see . +// + +package models + +// This file was generated by the swagger tool. +// Editing this file might prove futile when you re-run the swagger generate command + +import ( + "strconv" + + "github.com/go-openapi/errors" + "github.com/go-openapi/strfmt" + "github.com/go-openapi/swag" +) + +// FormatDirectCSIDrivesResponse format direct c s i drives response +// +// swagger:model formatDirectCSIDrivesResponse +type FormatDirectCSIDrivesResponse struct { + + // format issues list + FormatIssuesList []*CsiFormatErrorResponse `json:"formatIssuesList"` +} + +// Validate validates this format direct c s i drives response +func (m *FormatDirectCSIDrivesResponse) Validate(formats strfmt.Registry) error { + var res []error + + if err := m.validateFormatIssuesList(formats); err != nil { + res = append(res, err) + } + + if len(res) > 0 { + return errors.CompositeValidationError(res...) + } + return nil +} + +func (m *FormatDirectCSIDrivesResponse) validateFormatIssuesList(formats strfmt.Registry) error { + + if swag.IsZero(m.FormatIssuesList) { // not required + return nil + } + + for i := 0; i < len(m.FormatIssuesList); i++ { + if swag.IsZero(m.FormatIssuesList[i]) { // not required + continue + } + + if m.FormatIssuesList[i] != nil { + if err := m.FormatIssuesList[i].Validate(formats); err != nil { + if ve, ok := err.(*errors.Validation); ok { + return ve.ValidateName("formatIssuesList" + "." + strconv.Itoa(i)) + } + return err + } + } + + } + + return nil +} + +// MarshalBinary interface implementation +func (m *FormatDirectCSIDrivesResponse) MarshalBinary() ([]byte, error) { + if m == nil { + return nil, nil + } + return swag.WriteJSON(m) +} + +// UnmarshalBinary interface implementation +func (m *FormatDirectCSIDrivesResponse) UnmarshalBinary(b []byte) error { + var res FormatDirectCSIDrivesResponse + if err := swag.ReadJSON(b, &res); err != nil { + return err + } + *m = res + return nil +} diff --git a/restapi/admin_direct_csi.go b/restapi/admin_direct_csi.go index d886cf762..306ddc9a6 100644 --- a/restapi/admin_direct_csi.go +++ b/restapi/admin_direct_csi.go @@ -18,6 +18,7 @@ package restapi import ( "context" + "errors" "sort" "strings" @@ -33,6 +34,8 @@ import ( metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" ) +const XFS = "xfs" + func registerDirectCSIHandlers(api *operations.ConsoleAPI) { api.AdminAPIGetDirectCSIDriveListHandler = admin_api.GetDirectCSIDriveListHandlerFunc(func(params admin_api.GetDirectCSIDriveListParams, session *models.Principal) middleware.Responder { resp, err := getDirectCSIDrivesListResponse(session) @@ -48,6 +51,13 @@ func registerDirectCSIHandlers(api *operations.ConsoleAPI) { } return admin_api.NewGetDirectCSIVolumeListOK().WithPayload(resp) }) + api.AdminAPIDirectCSIFormatDriveHandler = admin_api.DirectCSIFormatDriveHandlerFunc(func(params admin_api.DirectCSIFormatDriveParams, session *models.Principal) middleware.Responder { + resp, err := formatVolumesResponse(session, params) + if err != nil { + return admin_api.NewDirectCSIFormatDriveDefault(int(err.Code)).WithPayload(err) + } + return admin_api.NewDirectCSIFormatDriveOK().WithPayload(resp) + }) } // getDirectCSIVolumesList returns direct-csi drives @@ -203,3 +213,104 @@ func getDirectCSIVolumesListResponse(session *models.Principal) (*models.GetDire } return volumes, nil } + +func formatDrives(ctx context.Context, clientset directv1alpha1.DirectV1alpha1Interface, drives []string, force bool) (*models.FormatDirectCSIDrivesResponse, error) { + if len(drives) == 0 { + return nil, errors.New("at least one drive needs to be set") + } + + driveList, err := clientset.DirectCSIDrives().List(ctx, metav1.ListOptions{}) + if err != nil { + return nil, err + } + + driveName := func(val string) string { + dr := strings.ReplaceAll(val, sys.DirectCSIDevRoot+"/", "") + dr = strings.ReplaceAll(dr, sys.HostDevRoot+"/", "") + return strings.ReplaceAll(dr, "-part-", "") + } + + drivesArray := map[string]string{} + + for _, driveFromAPI := range drives { + drivesArray[driveFromAPI] = driveFromAPI + } + + if len(driveList.Items) == 0 { + return nil, errors.New("no resources found globally") + } + + var errors []*models.CsiFormatErrorResponse + + for _, driveItem := range driveList.Items { + drName := "/dev/" + driveName(driveItem.Status.Path) + driveName := driveItem.Status.NodeName + ":" + drName + + base := &models.CsiFormatErrorResponse{ + Node: driveItem.Status.NodeName, + Drive: drName, + Error: "", + } + + // Element is requested to be formatted + if _, ok := drivesArray[driveName]; ok { + if driveItem.Status.DriveStatus == directv1alpha1apis.DriveStatusUnavailable { + base.Error = "Status is unavailable" + errors = append(errors, base) + continue + } + + if driveItem.Status.DriveStatus == directv1alpha1apis.DriveStatusInUse { + base.Error = "Drive in use. Cannot be formatted" + errors = append(errors, base) + continue + } + + if !force { + if driveItem.Status.DriveStatus == directv1alpha1apis.DriveStatusReady { + base.Error = "Drive already owned and managed. Use force to overwrite" + errors = append(errors, base) + continue + } + if driveItem.Status.Filesystem != "" && !force { + base.Error = "Drive already has a fs. Use force to overwrite" + errors = append(errors, base) + continue + } + } + + // Validation passes, we request format + driveItem.Spec.DirectCSIOwned = true + driveItem.Spec.RequestedFormat = &directv1alpha1apis.RequestedFormat{ + Filesystem: XFS, + Force: force, + } + + _, err := clientset.DirectCSIDrives().Update(ctx, &driveItem, metav1.UpdateOptions{}) + if err != nil { + base.Error = err.Error() + errors = append(errors, base) + } + } + } + + returnErrors := &models.FormatDirectCSIDrivesResponse{ + FormatIssuesList: errors, + } + + return returnErrors, nil +} + +func formatVolumesResponse(session *models.Principal, params admin_api.DirectCSIFormatDriveParams) (*models.FormatDirectCSIDrivesResponse, *models.Error) { + ctx := context.Background() + client, err := cluster.DirectCSIClient(session.STSSessionToken) + if err != nil { + return nil, prepareError(err) + } + + formatResult, errFormat := formatDrives(ctx, client.DirectV1alpha1(), params.Body.Drives, *params.Body.Force) + if errFormat != nil { + return nil, prepareError(errFormat) + } + return formatResult, nil +} diff --git a/restapi/embedded_spec.go b/restapi/embedded_spec.go index 636713f1e..b49af08ed 100644 --- a/restapi/embedded_spec.go +++ b/restapi/embedded_spec.go @@ -1817,6 +1817,39 @@ func init() { } } }, + "/direct-csi/drives/format": { + "post": { + "tags": [ + "AdminAPI" + ], + "summary": "Format direct-csi drives from a list", + "operationId": "DirectCSIFormatDrive", + "parameters": [ + { + "name": "body", + "in": "body", + "required": true, + "schema": { + "$ref": "#/definitions/formatConfiguration" + } + } + ], + "responses": { + "200": { + "description": "A successful response.", + "schema": { + "$ref": "#/definitions/formatDirectCSIDrivesResponse" + } + }, + "default": { + "description": "Generic error response.", + "schema": { + "$ref": "#/definitions/error" + } + } + } + } + }, "/direct-csi/volumes": { "get": { "tags": [ @@ -4309,6 +4342,20 @@ func init() { } } }, + "csiFormatErrorResponse": { + "type": "object", + "properties": { + "drive": { + "type": "string" + }, + "error": { + "type": "string" + }, + "node": { + "type": "string" + } + } + }, "deleteTenantRequest": { "type": "object", "properties": { @@ -4433,6 +4480,36 @@ func init() { } } }, + "formatConfiguration": { + "type": "object", + "required": [ + "drives", + "force" + ], + "properties": { + "drives": { + "type": "array", + "minLength": 1, + "items": { + "type": "string" + } + }, + "force": { + "type": "boolean" + } + } + }, + "formatDirectCSIDrivesResponse": { + "type": "object", + "properties": { + "formatIssuesList": { + "type": "array", + "items": { + "$ref": "#/definitions/csiFormatErrorResponse" + } + } + } + }, "gcpConfiguration": { "type": "object", "required": [ @@ -8445,6 +8522,39 @@ func init() { } } }, + "/direct-csi/drives/format": { + "post": { + "tags": [ + "AdminAPI" + ], + "summary": "Format direct-csi drives from a list", + "operationId": "DirectCSIFormatDrive", + "parameters": [ + { + "name": "body", + "in": "body", + "required": true, + "schema": { + "$ref": "#/definitions/formatConfiguration" + } + } + ], + "responses": { + "200": { + "description": "A successful response.", + "schema": { + "$ref": "#/definitions/formatDirectCSIDrivesResponse" + } + }, + "default": { + "description": "Generic error response.", + "schema": { + "$ref": "#/definitions/error" + } + } + } + } + }, "/direct-csi/volumes": { "get": { "tags": [ @@ -11561,6 +11671,20 @@ func init() { } } }, + "csiFormatErrorResponse": { + "type": "object", + "properties": { + "drive": { + "type": "string" + }, + "error": { + "type": "string" + }, + "node": { + "type": "string" + } + } + }, "deleteTenantRequest": { "type": "object", "properties": { @@ -11685,6 +11809,36 @@ func init() { } } }, + "formatConfiguration": { + "type": "object", + "required": [ + "drives", + "force" + ], + "properties": { + "drives": { + "type": "array", + "minLength": 1, + "items": { + "type": "string" + } + }, + "force": { + "type": "boolean" + } + } + }, + "formatDirectCSIDrivesResponse": { + "type": "object", + "properties": { + "formatIssuesList": { + "type": "array", + "items": { + "$ref": "#/definitions/csiFormatErrorResponse" + } + } + } + }, "gcpConfiguration": { "type": "object", "required": [ diff --git a/restapi/operations/admin_api/direct_c_s_i_format_drive.go b/restapi/operations/admin_api/direct_c_s_i_format_drive.go new file mode 100644 index 000000000..a65ad366d --- /dev/null +++ b/restapi/operations/admin_api/direct_c_s_i_format_drive.go @@ -0,0 +1,90 @@ +// Code generated by go-swagger; DO NOT EDIT. + +// This file is part of MinIO Console Server +// Copyright (c) 2021 MinIO, Inc. +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU Affero General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +// GNU Affero General Public License for more details. +// +// You should have received a copy of the GNU Affero General Public License +// along with this program. If not, see . +// + +package admin_api + +// This file was generated by the swagger tool. +// Editing this file might prove futile when you re-run the generate command + +import ( + "net/http" + + "github.com/go-openapi/runtime/middleware" + + "github.com/minio/console/models" +) + +// DirectCSIFormatDriveHandlerFunc turns a function with the right signature into a direct c s i format drive handler +type DirectCSIFormatDriveHandlerFunc func(DirectCSIFormatDriveParams, *models.Principal) middleware.Responder + +// Handle executing the request and returning a response +func (fn DirectCSIFormatDriveHandlerFunc) Handle(params DirectCSIFormatDriveParams, principal *models.Principal) middleware.Responder { + return fn(params, principal) +} + +// DirectCSIFormatDriveHandler interface for that can handle valid direct c s i format drive params +type DirectCSIFormatDriveHandler interface { + Handle(DirectCSIFormatDriveParams, *models.Principal) middleware.Responder +} + +// NewDirectCSIFormatDrive creates a new http.Handler for the direct c s i format drive operation +func NewDirectCSIFormatDrive(ctx *middleware.Context, handler DirectCSIFormatDriveHandler) *DirectCSIFormatDrive { + return &DirectCSIFormatDrive{Context: ctx, Handler: handler} +} + +/*DirectCSIFormatDrive swagger:route POST /direct-csi/drives/format AdminAPI directCSIFormatDrive + +Format direct-csi drives from a list + +*/ +type DirectCSIFormatDrive struct { + Context *middleware.Context + Handler DirectCSIFormatDriveHandler +} + +func (o *DirectCSIFormatDrive) ServeHTTP(rw http.ResponseWriter, r *http.Request) { + route, rCtx, _ := o.Context.RouteInfo(r) + if rCtx != nil { + r = rCtx + } + var Params = NewDirectCSIFormatDriveParams() + + uprinc, aCtx, err := o.Context.Authorize(r, route) + if err != nil { + o.Context.Respond(rw, r, route.Produces, route, err) + return + } + if aCtx != nil { + r = aCtx + } + var principal *models.Principal + if uprinc != nil { + principal = uprinc.(*models.Principal) // this is really a models.Principal, I promise + } + + if err := o.Context.BindValidRequest(r, route, &Params); err != nil { // bind params + o.Context.Respond(rw, r, route.Produces, route, err) + return + } + + res := o.Handler.Handle(Params, principal) // actually handle the request + + o.Context.Respond(rw, r, route.Produces, route, res) + +} diff --git a/restapi/operations/admin_api/direct_c_s_i_format_drive_parameters.go b/restapi/operations/admin_api/direct_c_s_i_format_drive_parameters.go new file mode 100644 index 000000000..3cb9eaa80 --- /dev/null +++ b/restapi/operations/admin_api/direct_c_s_i_format_drive_parameters.go @@ -0,0 +1,94 @@ +// Code generated by go-swagger; DO NOT EDIT. + +// This file is part of MinIO Console Server +// Copyright (c) 2021 MinIO, Inc. +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU Affero General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +// GNU Affero General Public License for more details. +// +// You should have received a copy of the GNU Affero General Public License +// along with this program. If not, see . +// + +package admin_api + +// This file was generated by the swagger tool. +// Editing this file might prove futile when you re-run the swagger generate command + +import ( + "io" + "net/http" + + "github.com/go-openapi/errors" + "github.com/go-openapi/runtime" + "github.com/go-openapi/runtime/middleware" + + "github.com/minio/console/models" +) + +// NewDirectCSIFormatDriveParams creates a new DirectCSIFormatDriveParams object +// no default values defined in spec. +func NewDirectCSIFormatDriveParams() DirectCSIFormatDriveParams { + + return DirectCSIFormatDriveParams{} +} + +// DirectCSIFormatDriveParams contains all the bound params for the direct c s i format drive operation +// typically these are obtained from a http.Request +// +// swagger:parameters DirectCSIFormatDrive +type DirectCSIFormatDriveParams struct { + + // HTTP Request Object + HTTPRequest *http.Request `json:"-"` + + /* + Required: true + In: body + */ + Body *models.FormatConfiguration +} + +// BindRequest both binds and validates a request, it assumes that complex things implement a Validatable(strfmt.Registry) error interface +// for simple values it will use straight method calls. +// +// To ensure default values, the struct must have been initialized with NewDirectCSIFormatDriveParams() beforehand. +func (o *DirectCSIFormatDriveParams) BindRequest(r *http.Request, route *middleware.MatchedRoute) error { + var res []error + + o.HTTPRequest = r + + if runtime.HasBody(r) { + defer r.Body.Close() + var body models.FormatConfiguration + if err := route.Consumer.Consume(r.Body, &body); err != nil { + if err == io.EOF { + res = append(res, errors.Required("body", "body", "")) + } else { + res = append(res, errors.NewParseError("body", "body", "", err)) + } + } else { + // validate body object + if err := body.Validate(route.Formats); err != nil { + res = append(res, err) + } + + if len(res) == 0 { + o.Body = &body + } + } + } else { + res = append(res, errors.Required("body", "body", "")) + } + if len(res) > 0 { + return errors.CompositeValidationError(res...) + } + return nil +} diff --git a/restapi/operations/admin_api/direct_c_s_i_format_drive_responses.go b/restapi/operations/admin_api/direct_c_s_i_format_drive_responses.go new file mode 100644 index 000000000..4733c02f4 --- /dev/null +++ b/restapi/operations/admin_api/direct_c_s_i_format_drive_responses.go @@ -0,0 +1,133 @@ +// Code generated by go-swagger; DO NOT EDIT. + +// This file is part of MinIO Console Server +// Copyright (c) 2021 MinIO, Inc. +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU Affero General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +// GNU Affero General Public License for more details. +// +// You should have received a copy of the GNU Affero General Public License +// along with this program. If not, see . +// + +package admin_api + +// This file was generated by the swagger tool. +// Editing this file might prove futile when you re-run the swagger generate command + +import ( + "net/http" + + "github.com/go-openapi/runtime" + + "github.com/minio/console/models" +) + +// DirectCSIFormatDriveOKCode is the HTTP code returned for type DirectCSIFormatDriveOK +const DirectCSIFormatDriveOKCode int = 200 + +/*DirectCSIFormatDriveOK A successful response. + +swagger:response directCSIFormatDriveOK +*/ +type DirectCSIFormatDriveOK struct { + + /* + In: Body + */ + Payload *models.FormatDirectCSIDrivesResponse `json:"body,omitempty"` +} + +// NewDirectCSIFormatDriveOK creates DirectCSIFormatDriveOK with default headers values +func NewDirectCSIFormatDriveOK() *DirectCSIFormatDriveOK { + + return &DirectCSIFormatDriveOK{} +} + +// WithPayload adds the payload to the direct c s i format drive o k response +func (o *DirectCSIFormatDriveOK) WithPayload(payload *models.FormatDirectCSIDrivesResponse) *DirectCSIFormatDriveOK { + o.Payload = payload + return o +} + +// SetPayload sets the payload to the direct c s i format drive o k response +func (o *DirectCSIFormatDriveOK) SetPayload(payload *models.FormatDirectCSIDrivesResponse) { + o.Payload = payload +} + +// WriteResponse to the client +func (o *DirectCSIFormatDriveOK) WriteResponse(rw http.ResponseWriter, producer runtime.Producer) { + + rw.WriteHeader(200) + if o.Payload != nil { + payload := o.Payload + if err := producer.Produce(rw, payload); err != nil { + panic(err) // let the recovery middleware deal with this + } + } +} + +/*DirectCSIFormatDriveDefault Generic error response. + +swagger:response directCSIFormatDriveDefault +*/ +type DirectCSIFormatDriveDefault struct { + _statusCode int + + /* + In: Body + */ + Payload *models.Error `json:"body,omitempty"` +} + +// NewDirectCSIFormatDriveDefault creates DirectCSIFormatDriveDefault with default headers values +func NewDirectCSIFormatDriveDefault(code int) *DirectCSIFormatDriveDefault { + if code <= 0 { + code = 500 + } + + return &DirectCSIFormatDriveDefault{ + _statusCode: code, + } +} + +// WithStatusCode adds the status to the direct c s i format drive default response +func (o *DirectCSIFormatDriveDefault) WithStatusCode(code int) *DirectCSIFormatDriveDefault { + o._statusCode = code + return o +} + +// SetStatusCode sets the status to the direct c s i format drive default response +func (o *DirectCSIFormatDriveDefault) SetStatusCode(code int) { + o._statusCode = code +} + +// WithPayload adds the payload to the direct c s i format drive default response +func (o *DirectCSIFormatDriveDefault) WithPayload(payload *models.Error) *DirectCSIFormatDriveDefault { + o.Payload = payload + return o +} + +// SetPayload sets the payload to the direct c s i format drive default response +func (o *DirectCSIFormatDriveDefault) SetPayload(payload *models.Error) { + o.Payload = payload +} + +// WriteResponse to the client +func (o *DirectCSIFormatDriveDefault) WriteResponse(rw http.ResponseWriter, producer runtime.Producer) { + + rw.WriteHeader(o._statusCode) + if o.Payload != nil { + payload := o.Payload + if err := producer.Produce(rw, payload); err != nil { + panic(err) // let the recovery middleware deal with this + } + } +} diff --git a/restapi/operations/admin_api/direct_c_s_i_format_drive_urlbuilder.go b/restapi/operations/admin_api/direct_c_s_i_format_drive_urlbuilder.go new file mode 100644 index 000000000..d529fef3a --- /dev/null +++ b/restapi/operations/admin_api/direct_c_s_i_format_drive_urlbuilder.go @@ -0,0 +1,104 @@ +// Code generated by go-swagger; DO NOT EDIT. + +// This file is part of MinIO Console Server +// Copyright (c) 2021 MinIO, Inc. +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU Affero General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +// GNU Affero General Public License for more details. +// +// You should have received a copy of the GNU Affero General Public License +// along with this program. If not, see . +// + +package admin_api + +// This file was generated by the swagger tool. +// Editing this file might prove futile when you re-run the generate command + +import ( + "errors" + "net/url" + golangswaggerpaths "path" +) + +// DirectCSIFormatDriveURL generates an URL for the direct c s i format drive operation +type DirectCSIFormatDriveURL struct { + _basePath string +} + +// WithBasePath sets the base path for this url builder, only required when it's different from the +// base path specified in the swagger spec. +// When the value of the base path is an empty string +func (o *DirectCSIFormatDriveURL) WithBasePath(bp string) *DirectCSIFormatDriveURL { + o.SetBasePath(bp) + return o +} + +// SetBasePath sets the base path for this url builder, only required when it's different from the +// base path specified in the swagger spec. +// When the value of the base path is an empty string +func (o *DirectCSIFormatDriveURL) SetBasePath(bp string) { + o._basePath = bp +} + +// Build a url path and query string +func (o *DirectCSIFormatDriveURL) Build() (*url.URL, error) { + var _result url.URL + + var _path = "/direct-csi/drives/format" + + _basePath := o._basePath + if _basePath == "" { + _basePath = "/api/v1" + } + _result.Path = golangswaggerpaths.Join(_basePath, _path) + + return &_result, nil +} + +// Must is a helper function to panic when the url builder returns an error +func (o *DirectCSIFormatDriveURL) Must(u *url.URL, err error) *url.URL { + if err != nil { + panic(err) + } + if u == nil { + panic("url can't be nil") + } + return u +} + +// String returns the string representation of the path with query string +func (o *DirectCSIFormatDriveURL) String() string { + return o.Must(o.Build()).String() +} + +// BuildFull builds a full url with scheme, host, path and query string +func (o *DirectCSIFormatDriveURL) BuildFull(scheme, host string) (*url.URL, error) { + if scheme == "" { + return nil, errors.New("scheme is required for a full url on DirectCSIFormatDriveURL") + } + if host == "" { + return nil, errors.New("host is required for a full url on DirectCSIFormatDriveURL") + } + + base, err := o.Build() + if err != nil { + return nil, err + } + + base.Scheme = scheme + base.Host = host + return base, nil +} + +// StringFull returns the string representation of a complete url +func (o *DirectCSIFormatDriveURL) StringFull(scheme, host string) string { + return o.Must(o.BuildFull(scheme, host)).String() +} diff --git a/restapi/operations/console_api.go b/restapi/operations/console_api.go index 964b05882..66580c4d7 100644 --- a/restapi/operations/console_api.go +++ b/restapi/operations/console_api.go @@ -139,6 +139,9 @@ func NewConsoleAPI(spec *loads.Document) *ConsoleAPI { AdminAPIDeleteTenantHandler: admin_api.DeleteTenantHandlerFunc(func(params admin_api.DeleteTenantParams, principal *models.Principal) middleware.Responder { return middleware.NotImplemented("operation admin_api.DeleteTenant has not yet been implemented") }), + AdminAPIDirectCSIFormatDriveHandler: admin_api.DirectCSIFormatDriveHandlerFunc(func(params admin_api.DirectCSIFormatDriveParams, principal *models.Principal) middleware.Responder { + return middleware.NotImplemented("operation admin_api.DirectCSIFormatDrive has not yet been implemented") + }), UserAPIDisableBucketEncryptionHandler: user_api.DisableBucketEncryptionHandlerFunc(func(params user_api.DisableBucketEncryptionParams, principal *models.Principal) middleware.Responder { return middleware.NotImplemented("operation user_api.DisableBucketEncryption has not yet been implemented") }), @@ -478,6 +481,8 @@ type ConsoleAPI struct { UserAPIDeleteServiceAccountHandler user_api.DeleteServiceAccountHandler // AdminAPIDeleteTenantHandler sets the operation handler for the delete tenant operation AdminAPIDeleteTenantHandler admin_api.DeleteTenantHandler + // AdminAPIDirectCSIFormatDriveHandler sets the operation handler for the direct c s i format drive operation + AdminAPIDirectCSIFormatDriveHandler admin_api.DirectCSIFormatDriveHandler // UserAPIDisableBucketEncryptionHandler sets the operation handler for the disable bucket encryption operation UserAPIDisableBucketEncryptionHandler user_api.DisableBucketEncryptionHandler // UserAPIDownloadObjectHandler sets the operation handler for the download object operation @@ -787,6 +792,9 @@ func (o *ConsoleAPI) Validate() error { if o.AdminAPIDeleteTenantHandler == nil { unregistered = append(unregistered, "admin_api.DeleteTenantHandler") } + if o.AdminAPIDirectCSIFormatDriveHandler == nil { + unregistered = append(unregistered, "admin_api.DirectCSIFormatDriveHandler") + } if o.UserAPIDisableBucketEncryptionHandler == nil { unregistered = append(unregistered, "user_api.DisableBucketEncryptionHandler") } @@ -1229,6 +1237,10 @@ func (o *ConsoleAPI) initHandlerCache() { if o.handlers["POST"] == nil { o.handlers["POST"] = make(map[string]http.Handler) } + o.handlers["POST"]["/direct-csi/drives/format"] = admin_api.NewDirectCSIFormatDrive(o.context, o.AdminAPIDirectCSIFormatDriveHandler) + if o.handlers["POST"] == nil { + o.handlers["POST"] = make(map[string]http.Handler) + } o.handlers["POST"]["/buckets/{bucket_name}/encryption/disable"] = user_api.NewDisableBucketEncryption(o.context, o.UserAPIDisableBucketEncryptionHandler) if o.handlers["GET"] == nil { o.handlers["GET"] = make(map[string]http.Handler) diff --git a/swagger.yml b/swagger.yml index 035c33e52..07d1ddd55 100644 --- a/swagger.yml +++ b/swagger.yml @@ -2461,6 +2461,28 @@ paths: $ref: "#/definitions/error" tags: - AdminAPI + + /direct-csi/drives/format: + post: + summary: Format direct-csi drives from a list + operationId: DirectCSIFormatDrive + parameters: + - name: body + in: body + required: true + schema: + $ref: "#/definitions/formatConfiguration" + responses: + 200: + description: A successful response. + schema: + $ref: "#/definitions/formatDirectCSIDrivesResponse" + default: + description: Generic error response. + schema: + $ref: "#/definitions/error" + tags: + - AdminAPI definitions: accountChangePasswordRequest: @@ -4741,3 +4763,35 @@ definitions: creds: type: string description: a base64 encoded value + formatConfiguration: + type: object + required: + - drives + - force + properties: + drives: + type: array + minLength: 1 + items: + type: string + force: + type: boolean + + csiFormatErrorResponse: + type: object + properties: + node: + type: string + drive: + type: string + error: + type: string + + formatDirectCSIDrivesResponse: + type: object + properties: + formatIssuesList: + type: array + items: + $ref: "#/definitions/csiFormatErrorResponse" +