Delete pods (#844)

Co-authored-by: Adam Stafford <adam@minio.io>
Co-authored-by: Daniel Valdivia <18384552+dvaldivia@users.noreply.github.com>
This commit is contained in:
adfost
2021-07-09 09:56:29 -07:00
committed by GitHub
parent b19852a75a
commit 373d576e54
12 changed files with 775 additions and 3 deletions

View File

@@ -141,6 +141,9 @@ func NewConsoleAPI(spec *loads.Document) *ConsoleAPI {
UserAPIDeleteObjectRetentionHandler: user_api.DeleteObjectRetentionHandlerFunc(func(params user_api.DeleteObjectRetentionParams, principal *models.Principal) middleware.Responder {
return middleware.NotImplemented("operation user_api.DeleteObjectRetention has not yet been implemented")
}),
AdminAPIDeletePodHandler: admin_api.DeletePodHandlerFunc(func(params admin_api.DeletePodParams, principal *models.Principal) middleware.Responder {
return middleware.NotImplemented("operation admin_api.DeletePod has not yet been implemented")
}),
UserAPIDeleteRemoteBucketHandler: user_api.DeleteRemoteBucketHandlerFunc(func(params user_api.DeleteRemoteBucketParams, principal *models.Principal) middleware.Responder {
return middleware.NotImplemented("operation user_api.DeleteRemoteBucket has not yet been implemented")
}),
@@ -540,6 +543,8 @@ type ConsoleAPI struct {
UserAPIDeleteObjectHandler user_api.DeleteObjectHandler
// UserAPIDeleteObjectRetentionHandler sets the operation handler for the delete object retention operation
UserAPIDeleteObjectRetentionHandler user_api.DeleteObjectRetentionHandler
// AdminAPIDeletePodHandler sets the operation handler for the delete pod operation
AdminAPIDeletePodHandler admin_api.DeletePodHandler
// UserAPIDeleteRemoteBucketHandler sets the operation handler for the delete remote bucket operation
UserAPIDeleteRemoteBucketHandler user_api.DeleteRemoteBucketHandler
// UserAPIDeleteServiceAccountHandler sets the operation handler for the delete service account operation
@@ -898,6 +903,9 @@ func (o *ConsoleAPI) Validate() error {
if o.UserAPIDeleteObjectRetentionHandler == nil {
unregistered = append(unregistered, "user_api.DeleteObjectRetentionHandler")
}
if o.AdminAPIDeletePodHandler == nil {
unregistered = append(unregistered, "admin_api.DeletePodHandler")
}
if o.UserAPIDeleteRemoteBucketHandler == nil {
unregistered = append(unregistered, "user_api.DeleteRemoteBucketHandler")
}
@@ -1397,6 +1405,10 @@ func (o *ConsoleAPI) initHandlerCache() {
if o.handlers["DELETE"] == nil {
o.handlers["DELETE"] = make(map[string]http.Handler)
}
o.handlers["DELETE"]["/namespaces/{namespace}/tenants/{tenant}/pods/{podName}"] = admin_api.NewDeletePod(o.context, o.AdminAPIDeletePodHandler)
if o.handlers["DELETE"] == nil {
o.handlers["DELETE"] = make(map[string]http.Handler)
}
o.handlers["DELETE"]["/remote-buckets/{source-bucket-name}/{arn}"] = user_api.NewDeleteRemoteBucket(o.context, o.UserAPIDeleteRemoteBucketHandler)
if o.handlers["DELETE"] == nil {
o.handlers["DELETE"] = make(map[string]http.Handler)