k8s의 CRD 만들기

mkdir simple-operator
cd simple-operator

# 저는 go버전이 달라서 버전 스킵 옵션을 사용했습니다. 현재 버전:go1.21.5, 필요 버전: go1.23
k8s-master@k8s-master:~/simple-operator$ kubebuilder init --skip-go-version-check --domain=mydomain.io --repo=simple-operator 
#--domain 옵션은 Custom Resource의 그룹 도메인을 결정합니다. 예시로 mydomain.io라고 설정했습니다.

k8s-master@k8s-master:~/simple-operator$ kubebuilder create api --group=sample --version=v1alpha1 --kind=Hello
#--group=sample: 그룹은 보통 도메인 하위로 sample.mydomain.io 이런 식으로 생성될 것입니다.
#--version=v1alpha1: CRD 버전을 v1alpha1로 지정합니다.
#--kind=Hello: Custom Resource의 Kind를 Hello라고 지었고, 이를 통해 CR 이름은 hellos.sample.mydomain.io 형태가 됩니다.

// HelloSpec defines the desired state of Hello
type HelloSpec struct {
    // 원하는 메시지
    Message string `json:"message,omitempty"`
}

// HelloStatus defines the observed state of Hello
type HelloStatus struct {
    // 현재 생성된 ConfigMap 이름(예시)
    ConfigMapName string `json:"configMapName,omitempty"`
}

apiVersion: mygroup.example.com/v1alpha1
kind: Hello
metadata:
  name: my-hello
spec:
  message: "Hello, Kubernetes!"

func (r *HelloReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
    log := ctrllog.FromContext(ctx)

    // 1) CR(Hello) 가져오기
    var hello samplev1alpha1.Hello
    if err := r.Get(ctx, req.NamespacedName, &hello); err != nil {
        // CR이 삭제된 경우 등 NotFound 에러면 무시
        if errors.IsNotFound(err) {
            return ctrl.Result{}, nil
        }
        return ctrl.Result{}, err
    }

    // 2) CR.spec.message를 참조하여 ConfigMap 생성/업데이트
    configMapName := hello.Name + "-configmap"

    // ConfigMap 원하는 spec
    desiredConfigMap := &corev1.ConfigMap{
        ObjectMeta: metav1.ObjectMeta{
            Name:      configMapName,
            Namespace: hello.Namespace,
        },
        Data: map[string]string{
            "message": hello.Spec.Message,
        },
    }

    // ConfigMap 실제 상태 가져오기
    var existingConfigMap corev1.ConfigMap
    err := r.Get(ctx, types.NamespacedName{
        Name:      configMapName,
        Namespace: hello.Namespace,
    }, &existingConfigMap)

    if err != nil && errors.IsNotFound(err) {
        // 없으면 만들기
        if createErr := r.Create(ctx, desiredConfigMap); createErr != nil {
            return ctrl.Result{}, createErr
        }
        log.Info("Created ConfigMap", "ConfigMapName", configMapName)
    } else if err == nil {
        // 이미 있으면, Data만 업데이트
        existingConfigMap.Data = desiredConfigMap.Data
        if updateErr := r.Update(ctx, &existingConfigMap); updateErr != nil {
            return ctrl.Result{}, updateErr
        }
        log.Info("Updated ConfigMap", "ConfigMapName", configMapName)
    } else {
        return ctrl.Result{}, err
    }

    // 3) CR Status 업데이트(옵션)
    if hello.Status.ConfigMapName != configMapName {
        hello.Status.ConfigMapName = configMapName
        if statusErr := r.Status().Update(ctx, &hello); statusErr != nil {
            return ctrl.Result{}, statusErr
        }
    }

    return ctrl.Result{}, nil
}

apiVersion: sample.mydomain.io/v1alpha1 #위에서 정의한 domain이름 내용을 토대로 apiVersion을 작성 할 수 있습니다.
kind: Hello #저희가 작성한 ConfigMap의 기능을 하는 새로운 리소스 Hello를 정의합니다.
metadata:
  name: hello-sample
  namespace: default
spec:
  message: "Hello from CR!"  #작성된 API 구조 정의된 내용을 토대로 작성 할 수 있습니다.

kubectl apply -f hello-sample.yaml
kubectl get hello hello-sample -o yaml

k8s-master@k8s-master:~/simple-operator$ kubectl get pods -n simple-operator-system
NAME                                                  READY   STATUS    RESTARTS   AGE
simple-operator-controller-manager-6f9c5ff4d5-dv2rl   0/1     Pending   0          12m
k8s-master@k8s-master:~/simple-operator$ kubectl logs simple-operator-controller-manager-6f9c5ff4d5-dv2rl -n simple-operator-system
k8s-master@k8s-master:~/simple-operator$ kubectl describe pod simple-operator-controller-manager-6f9c5ff4d5-dv2rl -n simple-operator-system
Name:             simple-operator-controller-manager-6f9c5ff4d5-dv2rl
Namespace:        simple-operator-system
Priority:         0
Service Account:  simple-operator-controller-manager
Node:             <none>
Labels:           app.kubernetes.io/name=simple-operator
                  control-plane=controller-manager
                  pod-template-hash=6f9c5ff4d5
Annotations:      kubectl.kubernetes.io/default-container: manager
Status:           Pending

. . .

QoS Class:                   Burstable
Node-Selectors:              <none>
Tolerations:                 node.kubernetes.io/not-ready:NoExecute op=Exists for 300s
                             node.kubernetes.io/unreachable:NoExecute op=Exists for 300s
Events:
  Type     Reason            Age                    From               Message
  ----     ------            ----                   ----               -------
  Warning  FailedScheduling  13m                    default-scheduler  0/3 nodes are available: 1 node(s) had untolerated taint {node-role.kubernetes.io/control-plane: }, 2 node(s) had untolerated taint {node.kubernetes.io/unreachable: }. preemption: 0/3 nodes are available: 3 Preemption is not helpful for scheduling.
  Warning  FailedScheduling  3m34s (x2 over 8m34s)  default-scheduler  0/3 nodes are available: 1 node(s) had untolerated taint {node-role.kubernetes.io/control-plane: }, 2 node(s) had untolerated taint {node.kubernetes.io/unreachable: }. preemption: 0/3 nodes are available: 3 Preemption is not helpful for scheduling.

spec:
  template:
    spec:
      tolerations:
        - key: "node-role.kubernetes.io/control-plane"
          operator: "Exists"
          effect: "NoSchedule"

kubectl get nodes -A