揭秘Kubernetes Indexer性能大PK，看看谁更胜一筹！

2023-09-05 21:01:28

Kubernetes Indexer 性能测试：谁是速度之王？

Indexer 的强大作用

作为 Kubernetes 的忠实用户，你一定对 Indexer 接口不陌生。这个大名鼎鼎的组件负责维护和更新 Kubernetes 集群中对象的索引，让查询和检索操作更加高效。理论知识固然重要，但实践出真知，我们今天就来一场 Indexer 性能大比拼，用数据说话，看看它的真本事！

测试环境搭建

为了确保测试的公平公正，我们精选了一台配置强劲的服务器作为测试平台，其配置如下：

CPU：Intel Core i9-10900K，10 核 20 线程，主频 3.7GHz，睿频 5.3GHz
内存：64GB DDR4-3200MHz
存储：1TB NVMe SSD

操作系统方面，我们选择了 Ubuntu 20.04 LTS，并安装了 Kubernetes 1.22 版本。

测试代码编写

为了测试 Indexer 的性能，我们编写了一段代码，具体如下：

import (
    "context"
    "fmt"
    "time"

    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/tools/cache"
)

func main() {
    // 创建 Kubernetes 客户端
    clientset, err := kubernetes.NewForConfig(restConfig)
    if err != nil {
        panic(err)
    }

    // 创建 Indexer
    indexer := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{})

    // 添加对象到 Indexer
    for i := 0; i < 10000; i++ {
        pod := &v1.Pod{
            ObjectMeta: metav1.ObjectMeta{
                Name:      fmt.Sprintf("pod-%d", i),
                Namespace: "default",
            },
        }
        indexer.Add(pod)
    }

    // 启动 Indexer
    stopCh := make(chan struct{})
    go indexer.Run(stopCh)

    // 模拟查询操作
    for i := 0; i < 1000; i++ {
        pod, exists, err := indexer.GetByKey("pod-5000")
        if err != nil {
            panic(err)
        }
        if !exists {
            fmt.Println("Pod not found")
        } else {
            fmt.Printf("Pod found: %s\n", pod.Name)
        }
    }

    // 停止 Indexer
    close(stopCh)

    // 计算查询时间
    elapsed := time.Since(startTime)
    fmt.Printf("查询时间：%s\n", elapsed)
}