Pod deletion

1. 代码

所有的rest请求都会转到api server，由apiserver处理。

staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go（其他接口也在这，比如: GET）

// Delete removes the item from storage.
func (e *Store) Delete(ctx genericapirequest.Context, name string, options *metav1.DeleteOptions) (runtime.Object, bool, error)

参数里有个DeleteOptions，是为了实现graceful shutdown。

staging/src/k8s.io/apiserver/pkg/endpoints/installer.go在install rest api handler时会对这种支持DeleteOptions的handler进行特殊处理，从http body里取出delete options相关的参数。

func (a *APIInstaller) registerResourceHandlers(path string, storage rest.Storage, ws *restful.WebService, proxyHandler http.Handler) (*metav1.APIResource, error) {
    ...
    gracefulDeleter, isGracefulDeleter := storage.(rest.GracefulDeleter)
    ...
    switch {
    case isGracefulDeleter:
        versionedDeleteOptions, err = a.group.Creater.New(optionsExternalVersion.WithKind("DeleteOptions"))
        if err != nil {
            return nil, err
        }
        versionedDeleterObject = indirectArbitraryPointer(versionedDeleteOptions)
        isDeleter = true
    case isDeleter:
        gracefulDeleter = rest.GracefulDeleteAdapter{Deleter: deleter}
    }
    ...
            case "DELETE": // Delete a resource.
            article := getArticleForNoun(kind, " ")
            doc := "delete" + article + kind
            if hasSubresource {
                doc = "delete " + subresource + " of" + article + kind
            }
            handler := metrics.InstrumentRouteFunc(action.Verb, resource, subresource, requestScope, restfulDeleteResource(gracefulDeleter, isGracefulDeleter, reqScope, admit))
            route := ws.DELETE(action.Path).To(handler).
                Doc(doc).
                Param(ws.QueryParameter("pretty", "If 'true', then the output is pretty printed.")).
                Operation("delete"+namespaced+kind+strings.Title(subresource)+operationSuffix).
                Produces(append(storageMeta.ProducesMIMETypes(action.Verb), mediaTypes...)...).
                Writes(versionedStatus).
                Returns(http.StatusOK, "OK", versionedStatus)
            if isGracefulDeleter {
                route.Reads(versionedDeleterObject)
                if err := addObjectParams(ws, route, versionedDeleteOptions); err != nil {
                    return nil, err
                }
            }
            addParams(route, action.Params)
            routes = append(routes, route)
}

注意：如果是gracefulDeleter，则最终传给store.go#Delete函数的options参数一定不为nil。

删除pod的接口如下：

Delete(name string, options *meta_v1.DeleteOptions)

最后，Pod etcd strategy在文件夹pkg/registry/core/pod下。

2. Issue

Graceful delete
具体的应用，怎么删除一个pod

3. 参考资料

保证at most on instance，避免多实例，对statefulset格外重要

PreviousInformer

Last updated 6 years ago

Was this helpful?