Go でのカスタム Kubernetes コントローラーの作成

Go でカスタム コントローラーを実装する前に、まず Kubernetes コントローラーとカスタマー リソース定義 (CRD) とは何なのかを理解しましょう

Kubernetes コントローラー

Kubernetes コントローラーは、kubernetes クラスターの状態を継続的に監視し、クラスターの実際の状態が望ましい状態と一致することを確認するためのアクションを実行するコントロール プレーンのコンポーネントです。現在の状態を望ましい状態に近づけようとして変更を加えます。

顧客リソース定義 (CRD)

カスタム リソース定義 (CRD) は、Kubernetes API を拡張して独自のカスタム リソースを作成する方法です。これらのカスタム リソースは、Kubernetes クラスター内で管理したいあらゆる種類のオブジェクトを表すことができます。

独自のカスタム リソース定義 (CRD) の作成

apiVersion: apiextensions.k8s.io/v1
kind: CustomResourceDefinition
metadata:
  name: my-crds.com.shivam.kumar
spec:
  group: com.shivam.kumar
  names:
    kind: my-crd
    plural: my-crds
  scope: Namespaced
  versions:
    - name: v1
      served: true
      storage: true
      schema:
        openAPIV3Schema:
          type: object
          properties:
            apiVersion:
              type: string
            kind:
              type: string
            metadata:
              type: object
            spec:
              type: object
              properties:
                description:
                  type: string

kubectl コマンドを使用してこのファイルを適用すると、クラスター内で使用可能な crd が表示され、作成した crd が表示されます。

カスタムリソース(CR)の作成

apiVersion: com.shivam.kumar/v1
kind: my-crd
metadata:
  name: my-custom-resource
spec:
  description: "My CRD instance"

kubectl コマンドを使用してこのファイルを適用します

次に、独自のカスタム コントローラーの作成に進みましょう

カスタム Kubernetes コントローラーの作成

package main

import (
    "context"
    "fmt"
    "path/filepath"

    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
    "k8s.io/apimachinery/pkg/runtime"
    "k8s.io/apimachinery/pkg/runtime/schema"
    "k8s.io/apimachinery/pkg/watch"
    "k8s.io/client-go/dynamic"
    "k8s.io/client-go/rest"
    "k8s.io/client-go/tools/cache"
    "k8s.io/client-go/tools/clientcmd"
    "k8s.io/client-go/util/homedir"
)

func main() {
    var kubeconfig string
    if home := homedir.HomeDir(); home != "" {
        kubeconfig = filepath.Join(home, ".kube", "config")
    }

    config, err := clientcmd.BuildConfigFromFlags("", kubeconfig)
    if err != nil {
        fmt.Println("Falling back to in-cluster config")
        config, err = rest.InClusterConfig()
        if err != nil {
            panic(err.Error())
        }
    }

    dynClient, err := dynamic.NewForConfig(config)
    if err != nil {
        panic(err.Error())
    }

    thefoothebar := schema.GroupVersionResource{Group: "com.shivam.kumar", Version: "v1", Resource: "my-crds"}

    informer := cache.NewSharedIndexInformer(
        &cache.ListWatch{
            ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
                return dynClient.Resource(thefoothebar).Namespace("").List(context.TODO(), options)
            },
            WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) {
                return dynClient.Resource(thefoothebar).Namespace("").Watch(context.TODO(), options)
            },
        },
        &unstructured.Unstructured{},
        0,
        cache.Indexers{},
    )

    informer.AddEventHandler(cache.ResourceEventHandlerFuncs{
        AddFunc: func(obj interface{}) {
            fmt.Println("Add event detected:", obj)
        },
        UpdateFunc: func(oldObj, newObj interface{}) {
            fmt.Println("Update event detected:", newObj)
        },
        DeleteFunc: func(obj interface{}) {
            fmt.Println("Delete event detected:", obj)
        },
    })

    stop := make(chan struct{})
    defer close(stop)

    go informer.Run(stop)

    if !cache.WaitForCacheSync(stop, informer.HasSynced) {
        panic("Timeout waiting for cache sync")
    }

    fmt.Println("Custom Resource Controller started successfully")
    <-stop
}

この Go プログラムを構築して実行すると、
go build -o k8s-controller .
./k8s-controller

これで、上で作成したカスタム リソースを追加、更新、削除するたびに、そのアクティブなログがターミナルに取得されます。これは、コントローラーが CRD を監視していることを意味します。

以上がGo でのカスタム Kubernetes コントローラーの作成の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。