Message Signature #300278

Message Signature Verified.

Address Copy

Message Copy

// k8s/gaia-operator/controllers/gaia_cluster_controller.go
package controllers

import (
    "context"
    "time"
    
    "k8s.io/apimachinery/pkg/runtime"
    ctrl "sigs.k8s.io/controller-runtime"
    "sigs.k8s.io/controller-runtime/pkg/client"
    "sigs.k8s.io/controller-runtime/pkg/log"
    
    clusterv1alpha1 "github.com/gaia-operator/api/v1alpha1"
)

// GaiaClusterReconciler reconciles a GaiaCluster object
type GaiaClusterReconciler struct {
    client.Client
    Scheme *runtime.Scheme
    // I45: Resource Pool (ATP)
    atpPool *ResourcePool
    // I38: Distributed Clock
    clock *clock.Clock
}

// +kubebuilder:rbac:groups=cluster.gaia.io,resources=gaiaclusters,verbs=get;list;watch;create;update;patch;delete
// +kubebuilder:rbac:groups=cluster.gaia.io,resources=gaiaclusters/status,verbs=get;update;patch

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

    // I38: Tick do Clock Distribuído
    r.clock.Tick("reconcile_cycle_start")

    var gaia clusterv1alpha1.GaiaCluster
    if err := r.Get(ctx, req.NamespacedName, &gaia); err != nil {
        return ctrl.Result{}, client.IgnoreNotFound(err)
    }

    // I40: TMR - Consultar 3 replicasets por zone
    nodes, err := r.getNodesFrom3Zones(ctx)
    if err != nil {
        log.Error(err, "Falha ao consultar nós TMR")
        return ctrl.Result{RequeueAfter: 5 * time.Second}, nil
    }

    // I45: Verificar ATP Pool antes de escalonamento
    if !r.atpPool.HasSufficientResources(gaia.Spec.ATPPool) {
        log.Info("I45: ATP insuficiente, rollback solicitado")
        r.clock.Tick("atp_rollback")
        return ctrl.Result{RequeueAfter: 30 * time.Second}, nil
    }

    // I16: Verificar temperatura dos nodes
    for _, node := range nodes {
        if node.Status.Temperature > gaia.Spec.MaxNodeTemperature {
            log.Info("I16: Node superaquecido, aplicando throttling", "node", node.Name)
            r.applyThermalThrottling(ctx, node.Name)
        }
    }

    // I46: Apoptose de nodes não saudáveis
    unhealthyNodes := r.findUnhealthyNodes(nodes)
    if len(unhealthyNodes) > 0 {
        log.Info("I46: Nodes não saudáveis detectados", "count", len(unhealthyNodes))
        r.triggerApoptosis(ctx, unhealthyNodes)
    }

    // I44: Verificar coerência do cluster
    if err := r.verifyClusterCoherence(nodes); err != nil {
        log.Error(err, "I44: Coerência de cluster violada")
        r.clock.Tick("coherence_violation")
        return ctrl.Result{RequeueAfter: 10 * time.Second}, nil
    }

    // I38: Tique final do ciclo
    r.clock.Tick("reconcile_cycle_complete")

    return ctrl.Result{RequeueAfter: 60 * time.Second}, nil
}

Signature Hash Copy

0x32e2d4187daac76965f1b0337263bd3b4339eddf484432a17283712c0459cece257ed14311ff3d2c849f472c0ac597f1f340e706d973bc7ad10209c7c7ca2c011b

[ Signature Verification Module is Powered by Nethereum (Thanks @juanfranblanco) ]

Tools & Services

Message Signature #300278