Go에서 커스텀 kubernetes 컨트롤러 만들기

Go에서 커스텀 컨트롤러를 구현하기 전에 먼저 Kubernetes 컨트롤러와 CRD(고객 리소스 정의)가 무엇인지 이해해 보겠습니다.

쿠버네티스 컨트롤러

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-컨트롤러

이제 위에서 생성된 사용자 정의 리소스를 추가, 업데이트 또는 삭제할 때마다 터미널에 해당 리소스에 대한 활성 로그가 표시됩니다. 이는 컨트롤러가 CRD를 모니터링하고 있음을 의미합니다.

위 내용은 Go에서 커스텀 kubernetes 컨트롤러 만들기의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!