diff --git a/go.mod b/go.mod index d24ee2e6a..c84ca3398 100644 --- a/go.mod +++ b/go.mod @@ -31,9 +31,9 @@ require ( github.com/scylladb/go-reflectx v1.0.1 github.com/scylladb/go-set v1.0.2 github.com/scylladb/gocqlx/v2 v2.8.0 - github.com/scylladb/scylla-manager/v3/pkg/managerclient v0.0.0-20241104134613-aba35605c28b - github.com/scylladb/scylla-manager/v3/pkg/util v0.0.0-20241104134613-aba35605c28b - github.com/scylladb/scylla-manager/v3/swagger v0.0.0-20250103082619-ef3b968167d0 + github.com/scylladb/scylla-manager/v3/pkg/managerclient v0.0.0-20250122142320-e1127475cc4c + github.com/scylladb/scylla-manager/v3/pkg/util v0.0.0-20250122142320-e1127475cc4c + github.com/scylladb/scylla-manager/v3/swagger v0.0.0-20250122142320-e1127475cc4c github.com/spf13/cobra v1.8.0 github.com/spf13/pflag v1.0.5 github.com/stoewer/go-strcase v1.3.0 diff --git a/go.sum b/go.sum index 24ed7c036..8e622bc13 100644 --- a/go.sum +++ b/go.sum @@ -1062,12 +1062,12 @@ github.com/scylladb/google-api-go-client v0.34.1-patched h1:DW+T0HA+74o6FDr3TFzV github.com/scylladb/google-api-go-client v0.34.1-patched/go.mod h1:RriRmS2wJXH+2yd9PRTEcR380U9AXmurWwznqVhzsSc= github.com/scylladb/rclone v1.54.1-0.20240312172628-afe1fd2aa65e h1:lJRphCtu+nKd+mfo8whOTeFkgjMWvk8iCSlqgibKSa8= github.com/scylladb/rclone v1.54.1-0.20240312172628-afe1fd2aa65e/go.mod h1:JGZp4EvCUK+6AM1Fe1dye5xvihTc/Bk0WnHHSCJOePM= -github.com/scylladb/scylla-manager/v3/pkg/managerclient v0.0.0-20241104134613-aba35605c28b h1:JRDV1d1FIiH0TIyHVmTAILAjQ2f8O4t7ZtZ/S+fT2sY= -github.com/scylladb/scylla-manager/v3/pkg/managerclient v0.0.0-20241104134613-aba35605c28b/go.mod h1:Tss7a99vrgds+B70w8ZFG3Skxfr9Br3kAzrKP2b3CmQ= -github.com/scylladb/scylla-manager/v3/pkg/util v0.0.0-20241104134613-aba35605c28b h1:7CHNmPrQqSdApaEh5nkRL+D52KFHaOHVBBVDvytHEOY= -github.com/scylladb/scylla-manager/v3/pkg/util v0.0.0-20241104134613-aba35605c28b/go.mod h1:+sPCx2oaOXmMpy/ODNNEDGJ7vCghBeKP4S7xEfMI+eA= -github.com/scylladb/scylla-manager/v3/swagger v0.0.0-20250103082619-ef3b968167d0 h1:P2RcsgtiMsaKrDUWRI7+eBd7Io0YCctaBFPyqqlsH0I= -github.com/scylladb/scylla-manager/v3/swagger v0.0.0-20250103082619-ef3b968167d0/go.mod h1:nCN5P0jiWL0W7jbcZ9p0ndtZAPoyEWXefddx/nbyFes= +github.com/scylladb/scylla-manager/v3/pkg/managerclient v0.0.0-20250122142320-e1127475cc4c h1:scmfi5j0Sgl7i3g6tVsu5yhCBlnT/PLN/PYVaY8B+Hc= +github.com/scylladb/scylla-manager/v3/pkg/managerclient v0.0.0-20250122142320-e1127475cc4c/go.mod h1:7+yHDmds+qO/8b0w4xTptCLh/Gr/hXyAjIIZkMj4KHk= +github.com/scylladb/scylla-manager/v3/pkg/util v0.0.0-20250122142320-e1127475cc4c h1:RLgSH0r/TI+Aw1f2bHUqnjVOI+8cOc9eX5Kr73N9Iuc= +github.com/scylladb/scylla-manager/v3/pkg/util v0.0.0-20250122142320-e1127475cc4c/go.mod h1:VKqHSrDj9zfgCKilpbdpmqV1TjmSglt/df79eIg6wuI= +github.com/scylladb/scylla-manager/v3/swagger v0.0.0-20250122142320-e1127475cc4c h1:1qkWdf5FbOwW3iE712s7mwOFSHaTRf9vlZ1LW+HDmVE= +github.com/scylladb/scylla-manager/v3/swagger v0.0.0-20250122142320-e1127475cc4c/go.mod h1:nCN5P0jiWL0W7jbcZ9p0ndtZAPoyEWXefddx/nbyFes= github.com/scylladb/termtables v0.0.0-20191203121021-c4c0b6d42ff4 h1:8qmTC5ByIXO3GP/IzBkxcZ/99VITvnIETDhdFz/om7A= github.com/scylladb/termtables v0.0.0-20191203121021-c4c0b6d42ff4/go.mod h1:C1a7PQSMz9NShzorzCiG2fk9+xuCgLkPeCvMHYR2OWg= github.com/sirupsen/logrus v1.7.0 h1:ShrD1U9pZB12TX0cVy0DtePoCH97K8EtX+mg7ZARUtM= diff --git a/v3/pkg/managerclient/go.mod b/v3/pkg/managerclient/go.mod index d0f7a7ca7..6e6f8e4ff 100644 --- a/v3/pkg/managerclient/go.mod +++ b/v3/pkg/managerclient/go.mod @@ -10,8 +10,8 @@ require ( github.com/lnquy/cron v1.1.1 github.com/pkg/errors v0.9.1 github.com/scylladb/go-set v1.0.2 - github.com/scylladb/scylla-manager/v3/pkg/util v0.0.0-20241030073626-e409ae491c83 - github.com/scylladb/scylla-manager/v3/swagger v0.0.0-20241030073626-e409ae491c83 + github.com/scylladb/scylla-manager/v3/pkg/util v0.0.0-20250122142320-e1127475cc4c + github.com/scylladb/scylla-manager/v3/swagger v0.0.0-20250122142320-e1127475cc4c github.com/scylladb/termtables v0.0.0-20191203121021-c4c0b6d42ff4 ) diff --git a/v3/pkg/managerclient/go.sum b/v3/pkg/managerclient/go.sum index 1ecdbc4ef..070f3aa0a 100644 --- a/v3/pkg/managerclient/go.sum +++ b/v3/pkg/managerclient/go.sum @@ -84,10 +84,10 @@ github.com/rogpeppe/go-internal v1.11.0 h1:cWPaGQEPrBb5/AsnsZesgZZ9yb1OQ+GOISoDN github.com/rogpeppe/go-internal v1.11.0/go.mod h1:ddIwULY96R17DhadqLgMfk9H9tvdUzkipdSkR5nkCZA= github.com/scylladb/go-set v1.0.2 h1:SkvlMCKhP0wyyct6j+0IHJkBkSZL+TDzZ4E7f7BCcRE= github.com/scylladb/go-set v1.0.2/go.mod h1:DkpGd78rljTxKAnTDPFqXSGxvETQnJyuSOQwsHycqfs= -github.com/scylladb/scylla-manager/v3/pkg/util v0.0.0-20241030073626-e409ae491c83 h1:6kyuL5XXRTPbBSUessmfz6TxhYgOiIHCwC63wvDExgQ= -github.com/scylladb/scylla-manager/v3/pkg/util v0.0.0-20241030073626-e409ae491c83/go.mod h1:+sPCx2oaOXmMpy/ODNNEDGJ7vCghBeKP4S7xEfMI+eA= -github.com/scylladb/scylla-manager/v3/swagger v0.0.0-20241030073626-e409ae491c83 h1:+2wvERSjYAhGushwWpqw8EemmntHOIcCjHCWzEdpXcM= -github.com/scylladb/scylla-manager/v3/swagger v0.0.0-20241030073626-e409ae491c83/go.mod h1:Oxfuz1XcXi9iV4ggSGfQdn+p6gPz6djPOegRMMe/6/s= +github.com/scylladb/scylla-manager/v3/pkg/util v0.0.0-20250122142320-e1127475cc4c h1:RLgSH0r/TI+Aw1f2bHUqnjVOI+8cOc9eX5Kr73N9Iuc= +github.com/scylladb/scylla-manager/v3/pkg/util v0.0.0-20250122142320-e1127475cc4c/go.mod h1:VKqHSrDj9zfgCKilpbdpmqV1TjmSglt/df79eIg6wuI= +github.com/scylladb/scylla-manager/v3/swagger v0.0.0-20250122142320-e1127475cc4c h1:1qkWdf5FbOwW3iE712s7mwOFSHaTRf9vlZ1LW+HDmVE= +github.com/scylladb/scylla-manager/v3/swagger v0.0.0-20250122142320-e1127475cc4c/go.mod h1:nCN5P0jiWL0W7jbcZ9p0ndtZAPoyEWXefddx/nbyFes= github.com/scylladb/termtables v0.0.0-20191203121021-c4c0b6d42ff4 h1:8qmTC5ByIXO3GP/IzBkxcZ/99VITvnIETDhdFz/om7A= github.com/scylladb/termtables v0.0.0-20191203121021-c4c0b6d42ff4/go.mod h1:C1a7PQSMz9NShzorzCiG2fk9+xuCgLkPeCvMHYR2OWg= github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= diff --git a/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla-manager/models/restore_host_progress.go b/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla-manager/models/restore_host_progress.go index c97ba47aa..9f83f2ba9 100644 --- a/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla-manager/models/restore_host_progress.go +++ b/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla-manager/models/restore_host_progress.go @@ -15,22 +15,28 @@ import ( // swagger:model RestoreHostProgress type RestoreHostProgress struct { - // Total time spent by host on download in milliseconds + // Total time spent by host on download in milliseconds (included in restore_duration) DownloadDuration int64 `json:"download_duration,omitempty"` - // Total bytes downloaded by host + // Total bytes downloaded by host (included in restored_bytes) DownloadedBytes int64 `json:"downloaded_bytes,omitempty"` // host Host string `json:"host,omitempty"` + // Total time spent by host on restore in milliseconds + RestoreDuration int64 `json:"restore_duration,omitempty"` + + // Total bytes restored by host + RestoredBytes int64 `json:"restored_bytes,omitempty"` + // Host shard count ShardCnt int64 `json:"shard_cnt,omitempty"` - // Total time spent by host on load&stream in milliseconds + // Total time spent by host on load&stream in milliseconds (included in restore_duration) StreamDuration int64 `json:"stream_duration,omitempty"` - // Total bytes load&streamed by host + // Total bytes load&streamed by host (included in restored_bytes) StreamedBytes int64 `json:"streamed_bytes,omitempty"` } diff --git a/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla-manager/models/restore_keyspace_progress.go b/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla-manager/models/restore_keyspace_progress.go index e804217b1..933b02a4f 100644 --- a/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla-manager/models/restore_keyspace_progress.go +++ b/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla-manager/models/restore_keyspace_progress.go @@ -23,7 +23,7 @@ type RestoreKeyspaceProgress struct { // Format: date-time CompletedAt *strfmt.DateTime `json:"completed_at,omitempty"` - // downloaded + // This field is DEPRECATED. Total bytes downloaded from table (included in restored) Downloaded int64 `json:"downloaded,omitempty"` // failed diff --git a/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla-manager/models/restore_progress.go b/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla-manager/models/restore_progress.go index e7c63828c..f23b38d6e 100644 --- a/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla-manager/models/restore_progress.go +++ b/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla-manager/models/restore_progress.go @@ -23,7 +23,7 @@ type RestoreProgress struct { // Format: date-time CompletedAt *strfmt.DateTime `json:"completed_at,omitempty"` - // downloaded + // This field is DEPRECATED. Total bytes downloaded from table (included in restored) Downloaded int64 `json:"downloaded,omitempty"` // failed diff --git a/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla-manager/models/restore_table_progress.go b/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla-manager/models/restore_table_progress.go index f98edf0f3..ebc9a0141 100644 --- a/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla-manager/models/restore_table_progress.go +++ b/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla-manager/models/restore_table_progress.go @@ -21,7 +21,7 @@ type RestoreTableProgress struct { // Format: date-time CompletedAt *strfmt.DateTime `json:"completed_at,omitempty"` - // downloaded + // This field is DEPRECATED. Total bytes downloaded from table (included in restored) Downloaded int64 `json:"downloaded,omitempty"` // error diff --git a/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla/v1/client/operations/operations_client.go b/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla/v1/client/operations/operations_client.go index bf0593584..db351411a 100644 --- a/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla/v1/client/operations/operations_client.go +++ b/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla/v1/client/operations/operations_client.go @@ -783,6 +783,8 @@ type ClientService interface { StorageServiceTabletsBalancingPost(params *StorageServiceTabletsBalancingPostParams) (*StorageServiceTabletsBalancingPostOK, error) + StorageServiceTabletsRepairPost(params *StorageServiceTabletsRepairPostParams) (*StorageServiceTabletsRepairPostOK, error) + StorageServiceTokensByEndpointGet(params *StorageServiceTokensByEndpointGetParams) (*StorageServiceTokensByEndpointGetOK, error) StorageServiceTokensEndpointGet(params *StorageServiceTokensEndpointGetParams) (*StorageServiceTokensEndpointGetOK, error) @@ -14109,6 +14111,41 @@ func (a *Client) StorageServiceTabletsBalancingPost(params *StorageServiceTablet return nil, runtime.NewAPIError("unexpected success response: content available as default response in error", unexpectedSuccess, unexpectedSuccess.Code()) } +/* +StorageServiceTabletsRepairPost tablets repair + +Repair a tablet +*/ +func (a *Client) StorageServiceTabletsRepairPost(params *StorageServiceTabletsRepairPostParams) (*StorageServiceTabletsRepairPostOK, error) { + // TODO: Validate the params before sending + if params == nil { + params = NewStorageServiceTabletsRepairPostParams() + } + + result, err := a.transport.Submit(&runtime.ClientOperation{ + ID: "StorageServiceTabletsRepairPost", + Method: "POST", + PathPattern: "/storage_service/tablets/repair", + ProducesMediaTypes: []string{"application/json"}, + ConsumesMediaTypes: []string{"application/json"}, + Schemes: []string{"http"}, + Params: params, + Reader: &StorageServiceTabletsRepairPostReader{formats: a.formats}, + Context: params.Context, + Client: params.HTTPClient, + }) + if err != nil { + return nil, err + } + success, ok := result.(*StorageServiceTabletsRepairPostOK) + if ok { + return success, nil + } + // unexpected success response + unexpectedSuccess := result.(*StorageServiceTabletsRepairPostDefault) + return nil, runtime.NewAPIError("unexpected success response: content available as default response in error", unexpectedSuccess, unexpectedSuccess.Code()) +} + /* StorageServiceTokensByEndpointGet gets node tokens diff --git a/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla/v1/client/operations/storage_service_tablets_repair_post_parameters.go b/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla/v1/client/operations/storage_service_tablets_repair_post_parameters.go new file mode 100644 index 000000000..ce264d57d --- /dev/null +++ b/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla/v1/client/operations/storage_service_tablets_repair_post_parameters.go @@ -0,0 +1,190 @@ +// Code generated by go-swagger; DO NOT EDIT. + +package operations + +// This file was generated by the swagger tool. +// Editing this file might prove futile when you re-run the swagger generate command + +import ( + "context" + "net/http" + "time" + + "github.com/go-openapi/errors" + "github.com/go-openapi/runtime" + cr "github.com/go-openapi/runtime/client" + "github.com/go-openapi/strfmt" +) + +// NewStorageServiceTabletsRepairPostParams creates a new StorageServiceTabletsRepairPostParams object +// with the default values initialized. +func NewStorageServiceTabletsRepairPostParams() *StorageServiceTabletsRepairPostParams { + var () + return &StorageServiceTabletsRepairPostParams{ + + timeout: cr.DefaultTimeout, + } +} + +// NewStorageServiceTabletsRepairPostParamsWithTimeout creates a new StorageServiceTabletsRepairPostParams object +// with the default values initialized, and the ability to set a timeout on a request +func NewStorageServiceTabletsRepairPostParamsWithTimeout(timeout time.Duration) *StorageServiceTabletsRepairPostParams { + var () + return &StorageServiceTabletsRepairPostParams{ + + timeout: timeout, + } +} + +// NewStorageServiceTabletsRepairPostParamsWithContext creates a new StorageServiceTabletsRepairPostParams object +// with the default values initialized, and the ability to set a context for a request +func NewStorageServiceTabletsRepairPostParamsWithContext(ctx context.Context) *StorageServiceTabletsRepairPostParams { + var () + return &StorageServiceTabletsRepairPostParams{ + + Context: ctx, + } +} + +// NewStorageServiceTabletsRepairPostParamsWithHTTPClient creates a new StorageServiceTabletsRepairPostParams object +// with the default values initialized, and the ability to set a custom HTTPClient for a request +func NewStorageServiceTabletsRepairPostParamsWithHTTPClient(client *http.Client) *StorageServiceTabletsRepairPostParams { + var () + return &StorageServiceTabletsRepairPostParams{ + HTTPClient: client, + } +} + +/* +StorageServiceTabletsRepairPostParams contains all the parameters to send to the API endpoint +for the storage service tablets repair post operation typically these are written to a http.Request +*/ +type StorageServiceTabletsRepairPostParams struct { + + /*Ks + Keyspace name to repair + + */ + Ks string + /*Table + Table name to repair + + */ + Table string + /*Tokens + Tokens owned by the tablets to repair. Multiple tokens can be provided using a comma-separated list. When set to the special word 'all', all tablets will be repaired + + */ + Tokens string + + timeout time.Duration + Context context.Context + HTTPClient *http.Client +} + +// WithTimeout adds the timeout to the storage service tablets repair post params +func (o *StorageServiceTabletsRepairPostParams) WithTimeout(timeout time.Duration) *StorageServiceTabletsRepairPostParams { + o.SetTimeout(timeout) + return o +} + +// SetTimeout adds the timeout to the storage service tablets repair post params +func (o *StorageServiceTabletsRepairPostParams) SetTimeout(timeout time.Duration) { + o.timeout = timeout +} + +// WithContext adds the context to the storage service tablets repair post params +func (o *StorageServiceTabletsRepairPostParams) WithContext(ctx context.Context) *StorageServiceTabletsRepairPostParams { + o.SetContext(ctx) + return o +} + +// SetContext adds the context to the storage service tablets repair post params +func (o *StorageServiceTabletsRepairPostParams) SetContext(ctx context.Context) { + o.Context = ctx +} + +// WithHTTPClient adds the HTTPClient to the storage service tablets repair post params +func (o *StorageServiceTabletsRepairPostParams) WithHTTPClient(client *http.Client) *StorageServiceTabletsRepairPostParams { + o.SetHTTPClient(client) + return o +} + +// SetHTTPClient adds the HTTPClient to the storage service tablets repair post params +func (o *StorageServiceTabletsRepairPostParams) SetHTTPClient(client *http.Client) { + o.HTTPClient = client +} + +// WithKs adds the ks to the storage service tablets repair post params +func (o *StorageServiceTabletsRepairPostParams) WithKs(ks string) *StorageServiceTabletsRepairPostParams { + o.SetKs(ks) + return o +} + +// SetKs adds the ks to the storage service tablets repair post params +func (o *StorageServiceTabletsRepairPostParams) SetKs(ks string) { + o.Ks = ks +} + +// WithTable adds the table to the storage service tablets repair post params +func (o *StorageServiceTabletsRepairPostParams) WithTable(table string) *StorageServiceTabletsRepairPostParams { + o.SetTable(table) + return o +} + +// SetTable adds the table to the storage service tablets repair post params +func (o *StorageServiceTabletsRepairPostParams) SetTable(table string) { + o.Table = table +} + +// WithTokens adds the tokens to the storage service tablets repair post params +func (o *StorageServiceTabletsRepairPostParams) WithTokens(tokens string) *StorageServiceTabletsRepairPostParams { + o.SetTokens(tokens) + return o +} + +// SetTokens adds the tokens to the storage service tablets repair post params +func (o *StorageServiceTabletsRepairPostParams) SetTokens(tokens string) { + o.Tokens = tokens +} + +// WriteToRequest writes these params to a swagger request +func (o *StorageServiceTabletsRepairPostParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error { + + if err := r.SetTimeout(o.timeout); err != nil { + return err + } + var res []error + + // query param ks + qrKs := o.Ks + qKs := qrKs + if qKs != "" { + if err := r.SetQueryParam("ks", qKs); err != nil { + return err + } + } + + // query param table + qrTable := o.Table + qTable := qrTable + if qTable != "" { + if err := r.SetQueryParam("table", qTable); err != nil { + return err + } + } + + // query param tokens + qrTokens := o.Tokens + qTokens := qrTokens + if qTokens != "" { + if err := r.SetQueryParam("tokens", qTokens); err != nil { + return err + } + } + + if len(res) > 0 { + return errors.CompositeValidationError(res...) + } + return nil +} diff --git a/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla/v1/client/operations/storage_service_tablets_repair_post_responses.go b/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla/v1/client/operations/storage_service_tablets_repair_post_responses.go new file mode 100644 index 000000000..159978fe5 --- /dev/null +++ b/vendor/github.com/scylladb/scylla-manager/v3/swagger/gen/scylla/v1/client/operations/storage_service_tablets_repair_post_responses.go @@ -0,0 +1,104 @@ +// Code generated by go-swagger; DO NOT EDIT. + +package operations + +// This file was generated by the swagger tool. +// Editing this file might prove futile when you re-run the swagger generate command + +import ( + "fmt" + "io" + "strings" + + "github.com/go-openapi/runtime" + "github.com/go-openapi/strfmt" + + "github.com/scylladb/scylla-manager/v3/swagger/gen/scylla/v1/models" +) + +// StorageServiceTabletsRepairPostReader is a Reader for the StorageServiceTabletsRepairPost structure. +type StorageServiceTabletsRepairPostReader struct { + formats strfmt.Registry +} + +// ReadResponse reads a server response into the received o. +func (o *StorageServiceTabletsRepairPostReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error) { + switch response.Code() { + case 200: + result := NewStorageServiceTabletsRepairPostOK() + if err := result.readResponse(response, consumer, o.formats); err != nil { + return nil, err + } + return result, nil + default: + result := NewStorageServiceTabletsRepairPostDefault(response.Code()) + if err := result.readResponse(response, consumer, o.formats); err != nil { + return nil, err + } + if response.Code()/100 == 2 { + return result, nil + } + return nil, result + } +} + +// NewStorageServiceTabletsRepairPostOK creates a StorageServiceTabletsRepairPostOK with default headers values +func NewStorageServiceTabletsRepairPostOK() *StorageServiceTabletsRepairPostOK { + return &StorageServiceTabletsRepairPostOK{} +} + +/* +StorageServiceTabletsRepairPostOK handles this case with default header values. + +Success +*/ +type StorageServiceTabletsRepairPostOK struct { +} + +func (o *StorageServiceTabletsRepairPostOK) readResponse(response runtime.ClientResponse, consumer runtime.Consumer, formats strfmt.Registry) error { + + return nil +} + +// NewStorageServiceTabletsRepairPostDefault creates a StorageServiceTabletsRepairPostDefault with default headers values +func NewStorageServiceTabletsRepairPostDefault(code int) *StorageServiceTabletsRepairPostDefault { + return &StorageServiceTabletsRepairPostDefault{ + _statusCode: code, + } +} + +/* +StorageServiceTabletsRepairPostDefault handles this case with default header values. + +internal server error +*/ +type StorageServiceTabletsRepairPostDefault struct { + _statusCode int + + Payload *models.ErrorModel +} + +// Code gets the status code for the storage service tablets repair post default response +func (o *StorageServiceTabletsRepairPostDefault) Code() int { + return o._statusCode +} + +func (o *StorageServiceTabletsRepairPostDefault) GetPayload() *models.ErrorModel { + return o.Payload +} + +func (o *StorageServiceTabletsRepairPostDefault) readResponse(response runtime.ClientResponse, consumer runtime.Consumer, formats strfmt.Registry) error { + + o.Payload = new(models.ErrorModel) + + // response payload + if err := consumer.Consume(response.Body(), o.Payload); err != nil && err != io.EOF { + return err + } + + return nil +} + +func (o *StorageServiceTabletsRepairPostDefault) Error() string { + return fmt.Sprintf("agent [HTTP %d] %s", o._statusCode, strings.TrimRight(o.Payload.Message, ".")) +} diff --git a/vendor/modules.txt b/vendor/modules.txt index a504aa824..580eab81f 100644 --- a/vendor/modules.txt +++ b/vendor/modules.txt @@ -401,12 +401,12 @@ github.com/scylladb/gocqlx/v2/dbutil github.com/scylladb/gocqlx/v2/migrate github.com/scylladb/gocqlx/v2/qb github.com/scylladb/gocqlx/v2/table -# github.com/scylladb/scylla-manager/v3/pkg/managerclient v0.0.0-20241104134613-aba35605c28b -## explicit; go 1.21.1 +# github.com/scylladb/scylla-manager/v3/pkg/managerclient v0.0.0-20250122142320-e1127475cc4c +## explicit; go 1.23.2 github.com/scylladb/scylla-manager/v3/pkg/managerclient github.com/scylladb/scylla-manager/v3/pkg/managerclient/table -# github.com/scylladb/scylla-manager/v3/pkg/util v0.0.0-20241104134613-aba35605c28b -## explicit; go 1.21.1 +# github.com/scylladb/scylla-manager/v3/pkg/util v0.0.0-20250122142320-e1127475cc4c +## explicit; go 1.23.2 github.com/scylladb/scylla-manager/v3/pkg/util github.com/scylladb/scylla-manager/v3/pkg/util/certutil github.com/scylladb/scylla-manager/v3/pkg/util/cfgutil @@ -437,7 +437,7 @@ github.com/scylladb/scylla-manager/v3/pkg/util/timeutc github.com/scylladb/scylla-manager/v3/pkg/util/uuid github.com/scylladb/scylla-manager/v3/pkg/util/version github.com/scylladb/scylla-manager/v3/pkg/util/workerpool -# github.com/scylladb/scylla-manager/v3/swagger v0.0.0-20250103082619-ef3b968167d0 +# github.com/scylladb/scylla-manager/v3/swagger v0.0.0-20250122142320-e1127475cc4c ## explicit; go 1.23.2 github.com/scylladb/scylla-manager/v3/swagger/gen/agent/client github.com/scylladb/scylla-manager/v3/swagger/gen/agent/client/operations