k8s ：kube-apiserver RESTful API 實(shí)現(xiàn) - Storage

frank_fun 發(fā)布于2019-07-01 17:29 / 1600人閱讀

摘要：前言了解的同學(xué)都知道，對(duì)外提供接口提供查詢(xún)，監(jiān)聽(tīng)集群資源狀態(tài)的服務(wù)，主要就做一件事，就是如何將接口調(diào)用映射到對(duì)后端存儲(chǔ)比如的增刪改查訪問(wèn)，在設(shè)計(jì)的時(shí)候考慮到是個(gè)快速迭代的開(kāi)源項(xiàng)目，很多接口版本可能在未來(lái)版本發(fā)生變化，因此如何設(shè)計(jì)一個(gè)擴(kuò)展

前言

了解 k8s 的同學(xué)都知道，kube-apiserver 對(duì)外提供 RESTful API 接口提供查詢(xún)，監(jiān)聽(tīng)集群（資源）狀態(tài)的服務(wù)，kube-apiserver 主要就做一件事，就是如何將 RESTful API （CREATE, DELETE, UPDATE, GET .etc）接口調(diào)用映射到對(duì)后端存儲(chǔ)（比如 etcd）的（增刪改查）訪問(wèn)，在設(shè)計(jì)的時(shí)候考慮到 k8s 是個(gè)快速迭代的開(kāi)源項(xiàng)目，很多 API 接口（版本）可能在未來(lái)版本發(fā)生變化，因此如何設(shè)計(jì)一個(gè)擴(kuò)展性強(qiáng)，耦合度低的架構(gòu)應(yīng)該是 Google 那幫貨當(dāng)初主要考慮的問(wèn)題，所以才導(dǎo)致 kube-apiserver 本來(lái)相比 kube-scheduler 和 kube-controller-manager 應(yīng)該簡(jiǎn)單的代碼設(shè)計(jì)的巨復(fù)雜（個(gè)人觀點(diǎn)）～

從 kube-apiserver 收到 RESTful API 請(qǐng)求到從后端存儲(chǔ)中獲取（更新 .etc）到數(shù)據(jù)大概需要經(jīng)過(guò)一下幾層（非官方命名），各層之間通過(guò) 《接口》交互（解偶）

RESTful API
||

||
Storage
||

||
Sotrage Backend（etcd2，etcd3）

比如 Storage 和 Storage Backend 之間通過(guò) Storage Backend Interface（參考k8s ：kube-apiserver 訪問(wèn) etcd 后端存儲(chǔ) ）交互，Storage 和 RESTful API 之間通過(guò) REST Operation Interface（增刪改查方法的封裝）交互

Storage

Storage is a generic interface for RESTful storage services.
Resources which are exported to the RESTful API of apiserver need to implement this interface（原文注釋?zhuān)峦?br>It is expected that objects may implement any of the below interfaces
所有想通過(guò) RESTful API 暴露出去的資源都必須實(shí)現(xiàn) Storage 接口，Storage 接口是個(gè)最小接口（單一職責(zé)），資源類(lèi)可以根據(jù)自身情況實(shí)現(xiàn)其它各種接口

// kubernetes/staging/src/k8s.io/apiserver/pkg/registry/rest/rest.go
type Storage interface {
    New() runtime.Object
}

REST Operation Interface

StandardStorage is an interface covering the common verbs. Provided for testing whether a resource satisfies the normal storage methods.
Use Storage when passing opaque storage objects
StandardStorage

type StandardStorage interface {
    Getter
    Lister
    GreaterUpdater
    GracefulDeleter
    CollectionDeleter
    Watcher
}

StandardStorage 聚合了可以對(duì) Storage 施加的操作（或者叫 Verb，動(dòng)作），RESTful API根據(jù)該（子）接口測(cè)試 Storage 是否支持相關(guān)操作，然后注冊(cè)相應(yīng)的 API 接口，比如如果 Storage 支持 Delete 接口，就注冊(cè)一個(gè) HTTP method 為 DELETE 的方法到相應(yīng)的資源路徑

Storage 實(shí)現(xiàn)類(lèi)

kubernetes/pkg/registry/core 目錄下包含了各種 Storage 實(shí)現(xiàn)類(lèi)，比如大家耳熟能詳?shù)?pod, service, endpoint, configmap, node 等等，各個(gè)資源的目錄結(jié)構(gòu)很相似，以 pod 為例

kubernetes/pkg/registry/core/pod
    rest
    storage
        storage.go <- Storage 實(shí)現(xiàn)
    doc.go
    strategy.go
    strategy_test.go

PodStorage

我們以 pod storage 為例來(lái)分析 storage 創(chuàng)建，首先是 pod storage 定義

type PodStorage struct {
    Pod *REST
    Binding *BindingREST
    Eviction *EvictionREST
    Status *StatusREST
    Log *podrest.LogREST
    Proxy *podrest.ProxyREST
    Exec *podrest.ExecREST
    Attach *podrest.AttachREST
    PortForward *podrest.PortForwardREST
}

這里又冒出一些新的類(lèi)型 REST，BindingREST .etc，這些 XXXREST 才是"真正"的 Storage，對(duì)應(yīng)具體的 RESTful endpoint

// REST implements a RESTStorage for pods
type REST struct {
    *genericregistry.Store
    proxyTransport http.RoundTripper
}

// BindingREST implements the REST endpoint for binding pods to nodes when etcd is in use
type BindingREST struct {
    store *genericregistry.Store
}

XXXREST 類(lèi)類(lèi)包含一個(gè) genericregistry.Store 類(lèi)型的字段，我們?cè)趉8s ：kube-apiserver 訪問(wèn) etcd 后端存儲(chǔ)中分析過(guò)，它用于訪問(wèn)后端存儲(chǔ)

PodStorage 通過(guò) NewStorage 方法創(chuàng)建，各個(gè) XXXREST 共享 Store

func NewStorage(optsGetter generic.RESTOptionsGetter, ...) {
    創(chuàng)建 genericregistry.Store
    store := &genericregistry.Store {
        ...
    }
    ...
    return PodStorage {
        Pod:      &REST{store, proxyTransport},
        Binding:  &BindingREST{store: store}
        ...
    }
}

Storage 注冊(cè)

Storage 是如何"綁定"到 api 接口呢？這中間還涉及到一些數(shù)據(jù)結(jié)構(gòu)（類(lèi)），這里先列出綁定相關(guān)的代碼：

// kubernetes/pkg/registry/core/rest/storage_core.go
func (c LegacyRESTStorageProvider) NewLegacyRESTStorage(...) {
    ...
    restStorageMap := map[string]rest.Storage {
        "pods": podStorage.Pod,
        "pods/attach": podStorage.Attach
        ...
    }
}

后續(xù)再詳細(xì)分析

總結(jié)

本文介紹了 kube-apiserver 中 Storage 相關(guān)的一些概念，希望對(duì)大家閱讀 k8s 源代碼有所幫助

云服務(wù)器 GPU云服務(wù)器 restful_api返回實(shí)現(xiàn)調(diào)用api api接口實(shí)現(xiàn) 實(shí)現(xiàn)調(diào)用api接口

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://m.hztianpu.com/yun/33049.html

發(fā)表評(píng)論

登陸后可評(píng)論

0條評(píng)論

frank_fun

男|高級(jí)講師

我要關(guān)注我要私信

TA的文章

BudgetVM：$29/月-4GB/200GB/100Mbps不限流量/高防/洛杉磯&am

閱讀 1827·2021-10-18 13:30
firstbyte.ru，新加坡VPS，10元/月，1核/512M內(nèi)存/5GB SSD/不限流量/1

閱讀 2702·2021-10-09 10:02
????入行軟件測(cè)試坑?。?！軟件測(cè)試人常用的軟件測(cè)試工具軟件推薦????

閱讀 3050·2021-09-28 09:35
使用Expect實(shí)現(xiàn)自動(dòng)化交互

閱讀 2148·2019-08-26 13:39
理解React高階組件（裝飾器）

閱讀 3590·2019-08-26 13:36
使用 Linux 子系統(tǒng)部署 Node、Gradle 項(xiàng)目的構(gòu)建工具

閱讀 2011·2019-08-26 11:46
高曉松：區(qū)塊鏈也可以有詩(shī)與遠(yuǎn)方

閱讀 1195·2019-08-23 14:56
JavaScript實(shí)現(xiàn)簡(jiǎn)單二叉查找樹(shù)

閱讀 1778·2019-08-23 10:38

成人无码视频,亚洲精品久久久久av无码,午夜精品久久久久久毛片,亚洲中文字幕日韩无码

資訊專(zhuān)欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

k8s ：kube-apiserver RESTful API 實(shí)現(xiàn) - Storage

相關(guān)文章