Contrarian View: DevOps Is Dead – Platform Engineering Is the Future – 2026 Data

package main\n\nimport (\n\t\"context\"\n\t\"flag\"\n\t\"fmt\"\n\t\"log\"\n\t\"os\"\n\t\"time\"\n\n\tmetav1 \"k8s.io/apimachinery/pkg/apis/meta/v1\"\n\t\"k8s.io/apimachinery/pkg/api/resource\"\n\tcorev1 \"k8s.io/api/core/v1\"\n\t\"k8s.io/client-go/kubernetes\"\n\t\"k8s.io/client-go/tools/clientcmd\"\n\t\"k8s.io/apimachinery/pkg/util/wait\"\n)\n\n// NamespaceProvisioner handles self-service namespace creation with quotas\ntype NamespaceProvisioner struct {\n\tclientset *kubernetes.Clientset\n\tquotaCPU  string\n\tquotaMem  string\n}\n\n// NewNamespaceProvisioner initializes a new provisioner with k8s client\nfunc NewNamespaceProvisioner(kubeconfig, quotaCPU, quotaMem string) (*NamespaceProvisioner, error) {\n\tconfig, err := clientcmd.BuildConfigFromFlags(\"\", kubeconfig)\n\tif err != nil {\n\t\treturn nil, fmt.Errorf(\"failed to build k8s config: %w\", err)\n\t}\n\n\tclientset, err := kubernetes.NewForConfig(config)\n\tif err != nil {\n\t\treturn nil, fmt.Errorf(\"failed to create k8s client: %w\", err)\n\t}\n\n\treturn &NamespaceProvisioner{\n\t\tclientset: clientset,\n\t\tquotaCPU:  quotaCPU,\n\t\tquotaMem:  quotaMem,\n\t}, nil\n}\n\n// Provision creates a new namespace with resource quotas and labels\nfunc (p *NamespaceProvisioner) Provision(ctx context.Context, nsName, team, environment string) error {\n\t// Validate inputs\n\tif nsName == \"\" || team == \"\" || environment == \"\" {\n\t\treturn fmt.Errorf(\"namespace name, team, and environment are required\")\n\t}\n\n\t// Check if namespace already exists\n\t_, err := p.clientset.CoreV1().Namespaces().Get(ctx, nsName, metav1.GetOptions{})\n\tif err == nil {\n\t\tlog.Printf(\"namespace %s already exists, skipping creation\", nsName)\n\t\treturn nil\n\t}\n\n\t// Create namespace with labels\n\tns := &corev1.Namespace{\n\t\tObjectMeta: metav1.ObjectMeta{\n\t\t\tName: nsName,\n\t\t\tLabels: map[string]string{\n\t\t\t\t\"app.kubernetes.io/part-of\": \"idp\",\n\t\t\t\t\"team\":                      team,\n\t\t\t\t\"environment\":               environment,\n\t\t\t},\n\t\t},\n\t}\n\n\tcreatedNs, err := p.clientset.CoreV1().Namespaces().Create(ctx, ns, metav1.CreateOptions{})\n\tif err != nil {\n\t\treturn fmt.Errorf(\"failed to create namespace %s: %w\", nsName, err)\n\t}\n\tlog.Printf(\"created namespace %s for team %s\", createdNs.Name, team)\n\n\t// Create resource quota for the namespace\n\tquota := &corev1.ResourceQuota{\n\t\tObjectMeta: metav1.ObjectMeta{\n\t\t\tName:      fmt.Sprintf(\"%s-quota\", nsName),\n\t\t\tNamespace: nsName,\n\t\t},\n\t\tSpec: corev1.ResourceQuotaSpec{\n\t\t\tHard: corev1.ResourceList{\n\t\t\t\tcorev1.ResourceLimitsCPU:    resource.MustParse(p.quotaCPU),\n\t\t\t\tcorev1.ResourceLimitsMemory: resource.MustParse(p.quotaMem),\n\t\t\t\tcorev1.ResourcePods:         resource.MustParse(\"10\"),\n\t\t\t},\n\t\t},\n\t}\n\n\t// Retry quota creation up to 3 times with backoff\n\terr = wait.ExponentialBackoff(wait.Backoff{\n\t\tDuration: 1 * time.Second,\n\t\tFactor:   2.0,\n\t\tJitter:   0.1,\n\t\tSteps:    3,\n\t}, func() (bool, error) {\n\t\t_, err := p.clientset.CoreV1().ResourceQuotas(nsName).Create(ctx, quota, metav1.CreateOptions{})\n\t\tif err != nil {\n\t\t\tlog.Printf(\"failed to create resource quota for %s: %v, retrying\", nsName, err)\n\t\t\treturn false, nil\n\t\t}\n\t\treturn true, nil\n\t})\n\n\tif err != nil {\n\t\treturn fmt.Errorf(\"failed to create resource quota for %s after retries: %w\", nsName, err)\n\t}\n\tlog.Printf(\"applied resource quota to namespace %s: cpu=%s, mem=%s\", nsName, p.quotaCPU, p.quotaMem)\n\n\treturn nil\n}\n\nfunc main() {\n\t// CLI flags for configuration\n\tkubeconfig := flag.String(\"kubeconfig\", os.Getenv(\"KUBECONFIG\"), \"path to kubeconfig file\")\n\tquotaCPU := flag.String(\"quota-cpu\", \"2\", \"default CPU quota per namespace\")\n\tquotaMem := flag.String(\"quota-mem\", \"4Gi\", \"default memory quota per namespace\")\n\tnsName := flag.String(\"namespace\", \"\", \"namespace to provision\")\n\tteam := flag.String(\"team\", \"\", \"team owning the namespace\")\n\tenv := flag.String(\"env\", \"dev\", \"environment (dev/staging/prod)\")\n\tflag.Parse()\n\n\t// Validate required flags\n\tif *nsName == \"\" || *team == \"\" {\n\t\tlog.Fatal(\"--namespace and --team are required\")\n\t}\n\n\t// Initialize provisioner\n\tprovisioner, err := NewNamespaceProvisioner(*kubeconfig, *quotaCPU, *quotaMem)\n\tif err != nil {\n\t\tlog.Fatalf(\"failed to initialize provisioner: %v\", err)\n\t}\n\n\t// Provision namespace\n\tctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)\n\tdefer cancel()\n\n\tif err := provisioner.Provision(ctx, *nsName, *team, *env); err != nil {\n\t\tlog.Fatalf(\"provisioning failed: %v\", err)\n\t}\n\n\tfmt.Printf(\"successfully provisioned namespace %s\\n\", *nsName)\n}\n

provider \"aws\" {\n  region = var.aws_region\n}\n\nvariable \"aws_region\" {\n  type        = string\n  description = \"AWS region to deploy resources\"\n  default     = \"us-east-1\"\n}\n\nvariable \"cluster_name\" {\n  type        = string\n  description = \"Name of the EKS cluster\"\n  default     = \"platform-eks-cluster\"\n}\n\nvariable \"cluster_version\" {\n  type        = string\n  description = \"Kubernetes version for EKS cluster\"\n  default     = \"1.29\"\n}\n\nvariable \"node_group_instance_type\" {\n  type        = list(string)\n  description = \"Instance types for EKS node group\"\n  default     = [\"t3.medium\"]\n}\n\nvariable \"node_group_desired_size\" {\n  type        = number\n  description = \"Desired number of nodes in default node group\"\n  default     = 2\n}\n\nvariable \"backstage_chart_version\" {\n  type        = string\n  description = \"Backstage Helm chart version\"\n  default     = \"1.22.0\"\n}\n\nvariable \"crossplane_chart_version\" {\n  type        = string\n  description = \"Crossplane Helm chart version\"\n  default     = \"1.14.0\"\n}\n\ndata \"aws_caller_identity\" \"current\" {}\n\n# EKS Cluster\nresource \"aws_eks_cluster\" \"platform_cluster\" {\n  name     = var.cluster_name\n  role_arn = aws_iam_role.eks_cluster_role.arn\n  version  = var.cluster_version\n\n  vpc_config {\n    subnet_ids = aws_subnet.platform_subnets[*].id\n  }\n\n  depends_on = [aws_iam_role_policy_attachment.eks_cluster_policy]\n}\n\n# EKS Node Group\nresource \"aws_eks_node_group\" \"default\" {\n  cluster_name    = aws_eks_cluster.platform_cluster.name\n  node_group_name = \"default-node-group\"\n  node_role_arn   = aws_iam_role.eks_node_role.arn\n  subnet_ids      = aws_subnet.platform_subnets[*].id\n\n  instance_types = var.node_group_instance_type\n\n  scaling_config {\n    desired_size = var.node_group_desired_size\n    max_size     = 4\n    min_size     = 1\n  }\n\n  depends_on = [aws_iam_role_policy_attachment.eks_node_policy]\n}\n\n# IAM Role for EKS Cluster\nresource \"aws_iam_role\" \"eks_cluster_role\" {\n  name = \"${var.cluster_name}-cluster-role\"\n\n  assume_role_policy = jsonencode({\n    Version = \"2012-10-17\"\n    Statement = [\n      {\n        Action = \"sts:AssumeRole\"\n        Effect = \"Allow\"\n        Principal = {\n          Service = \"eks.amazonaws.com\"\n        }\n      }\n    ]\n  })\n}\n\nresource \"aws_iam_role_policy_attachment\" \"eks_cluster_policy\" {\n  role       = aws_iam_role.eks_cluster_role.name\n  policy_arn = \"arn:aws:iam::aws:policy/AmazonEKSClusterPolicy\"\n}\n\n# IAM Role for EKS Nodes\nresource \"aws_iam_role\" \"eks_node_role\" {\n  name = \"${var.cluster_name}-node-role\"\n\n  assume_role_policy = jsonencode({\n    Version = \"2012-10-17\"\n    Statement = [\n      {\n        Action = \"sts:AssumeRole\"\n        Effect = \"Allow\"\n        Principal = {\n          Service = \"ec2.amazonaws.com\"\n        }\n      }\n    ]\n  })\n}\n\nresource \"aws_iam_role_policy_attachment\" \"eks_node_policy\" {\n  role       = aws_iam_role.eks_node_role.name\n  policy_arn = \"arn:aws:iam::aws:policy/AmazonEKSWorkerNodePolicy\"\n}\n\nresource \"aws_iam_role_policy_attachment\" \"eks_cni_policy\" {\n  role       = aws_iam_role.eks_node_role.name\n  policy_arn = \"arn:aws:iam::aws:policy/AmazonEKS_CNI_Policy\"\n}\n\nresource \"aws_iam_role_policy_attachment\" \"ecr_read_policy\" {\n  role       = aws_iam_role.eks_node_role.name\n  policy_arn = \"arn:aws:iam::aws:policy/AmazonEC2ContainerRegistryReadOnly\"\n}\n\n# Helm Provider for Kubernetes\nprovider \"helm\" {\n  kubernetes {\n    host                   = aws_eks_cluster.platform_cluster.endpoint\n    cluster_ca_certificate = base64decode(aws_eks_cluster.platform_cluster.certificate_authority[0].data)\n    exec {\n      api_version = \"client.authentication.k8s.io/v1beta1\"\n      args        = [\"eks\", \"get-token\", \"--cluster-name\", aws_eks_cluster.platform_cluster.name]\n      command     = \"aws\"\n    }\n  }\n}\n\n# Install Crossplane via Helm\nresource \"helm_release\" \"crossplane\" {\n  name       = \"crossplane\"\n  repository = \"https://charts.crossplane.io/stable\"\n  chart      = \"crossplane\"\n  version    = var.crossplane_chart_version\n  namespace  = \"crossplane-system\"\n\n  create_namespace = true\n\n  set {\n    name  = \"image.tag\"\n    value = var.crossplane_chart_version\n  }\n}\n\n# Install Backstage via Helm\nresource \"helm_release\" \"backstage\" {\n  name       = \"backstage\"\n  repository = \"https://backstage.github.io/charts\"\n  chart      = \"backstage\"\n  version    = var.backstage_chart_version\n  namespace  = \"backstage\"\n\n  create_namespace = true\n\n  set {\n    name  = \"image.tag\"\n    value = var.backstage_chart_version\n  }\n\n  depends_on = [helm_release.crossplane]\n}\n\n# VPC and Subnets (simplified for brevity, real module would use AWS VPC module)\nresource \"aws_vpc\" \"platform_vpc\" {\n  cidr_block = \"10.0.0.0/16\"\n  tags = {\n    Name = \"${var.cluster_name}-vpc\"\n  }\n}\n\nresource \"aws_subnet\" \"platform_subnets\" {\n  count             = 2\n  vpc_id            = aws_vpc.platform_vpc.id\n  cidr_block        = \"10.0.${count.index}.0/24\"\n  availability_zone = \"${var.aws_region}a\"\n  tags = {\n    Name = \"${var.cluster_name}-subnet-${count.index}\"\n  }\n}\n\noutput \"eks_cluster_endpoint\" {\n  value = aws_eks_cluster.platform_cluster.endpoint\n}\n\noutput \"backstage_url\" {\n  value = \"http://${helm_release.backstage.metadata[0].name}.backstage.svc.cluster.local:7007\"\n}\n

import boto3\nimport pandas as pd\nfrom prometheus_api_client import PrometheusConnect\nfrom datetime import datetime, timedelta\nimport logging\nfrom typing import Dict, List\n\n# Configure logging\nlogging.basicConfig(\n    level=logging.INFO,\n    format=\"%(asctime)s - %(levelname)s - %(message)s\"\n)\nlogger = logging.getLogger(__name__)\n\nclass PlatformMetricsCollector:\n    \"\"\"Collects platform engineering metrics from Prometheus and AWS Cost Explorer\"\"\"\n    \n    def __init__(self, prometheus_url: str, aws_region: str = \"us-east-1\"):\n        self.prometheus_url = prometheus_url\n        self.aws_region = aws_region\n        self.prom_client = PrometheusConnect(url=prometheus_url, disable_ssl_verify=True)\n        self.cost_explorer = boto3.client(\"ce\", region_name=aws_region)\n        \n    def get_dora_metrics(self, start_time: datetime, end_time: datetime) -> Dict[str, float]:\n        \"\"\"Fetch DORA metrics (MTTD, MTTR) from Prometheus\"\"\"\n        metrics = {}\n        \n        # Mean Time to Deploy (MTTD): average time from code merge to prod deploy\n        mttd_query = \"\"\"\n            avg(rate(deploy_duration_seconds{env=\"prod\"}[30d])) * 3600\n        \"\"\"\n        try:\n            mttd_result = self.prom_client.custom_query(query=mttd_query)\n            if mttd_result:\n                metrics[\"mttd_hours\"] = float(mttd_result[0][\"value\"][1])\n                logger.info(f\"Fetched MTTD: {metrics['mttd_hours']:.2f} hours\")\n        except Exception as e:\n            logger.error(f\"Failed to fetch MTTD: {e}\")\n            metrics[\"mttd_hours\"] = 0.0\n            \n        # Mean Time to Recovery (MTTR): average time to resolve prod incidents\n        mttr_query = \"\"\"\n            avg(rate(incident_resolution_duration_seconds{env=\"prod\"}[30d])) / 60\n        \"\"\"\n        try:\n            mttr_result = self.prom_client.custom_query(query=mttr_query)\n            if mttr_result:\n                metrics[\"mttr_minutes\"] = float(mttr_result[0][\"value\"][1])\n                logger.info(f\"Fetched MTTR: {metrics['mttr_minutes']:.2f} minutes\")\n        except Exception as e:\n            logger.error(f\"Failed to fetch MTTR: {e}\")\n            metrics[\"mttr_minutes\"] = 0.0\n            \n        return metrics\n    \n    def get_cloud_cost(self, start_time: datetime, end_time: datetime) -> float:\n        \"\"\"Fetch total cloud cost for the period from AWS Cost Explorer\"\"\"\n        try:\n            response = self.cost_explorer.get_cost_and_usage(\n                TimePeriod={\n                    \"Start\": start_time.strftime(\"%Y-%m-%d\"),\n                    \"End\": end_time.strftime(\"%Y-%m-%d\")\n                },\n                Granularity=\"MONTHLY\",\n                Metrics=[\"BlendedCost\"]\n            )\n            total_cost = sum(\n                float(result[\"Total\"][\"BlendedCost\"][\"Amount\"])\n                for result in response[\"ResultsByTime\"]\n            )\n            logger.info(f\"Fetched total cloud cost: ${total_cost:.2f}\")\n            return total_cost\n        except Exception as e:\n            logger.error(f\"Failed to fetch cloud cost: {e}\")\n            return 0.0\n    \n    def get_self_service_adoption(self) -> float:\n        \"\"\"Calculate self-service adoption rate: % of infra requests via API vs tickets\"\"\"\n        query = \"\"\"\n            sum(increase(platform_api_request_total{endpoint=\"/provision\"}[30d])) \n            / \n            sum(increase(platform_ticket_request_total{type=\"infra\"}[30d])) \n            * 100\n        \"\"\"\n        try:\n            result = self.prom_client.custom_query(query=query)\n            if result:\n                adoption_rate = float(result[0][\"value\"][1])\n                logger.info(f\"Self-service adoption rate: {adoption_rate:.2f}%\")\n                return adoption_rate\n        except Exception as e:\n            logger.error(f\"Failed to fetch adoption rate: {e}\")\n        return 0.0\n    \n    def generate_report(self, output_path: str = \"platform_metrics_2026.csv\"):\n        \"\"\"Generate a 2026 benchmark report with all collected metrics\"\"\"\n        end_time = datetime.now()\n        start_time = end_time - timedelta(days=30)\n        \n        logger.info(f\"Collecting metrics from {start_time} to {end_time}\")\n        \n        # Collect all metrics\n        dora_metrics = self.get_dora_metrics(start_time, end_time)\n        cloud_cost = self.get_cloud_cost(start_time, end_time)\n        adoption_rate = self.get_self_service_adoption()\n        \n        # Create report DataFrame\n        report_data = [{\n            \"report_date\": end_time.strftime(\"%Y-%m-%d\"),\n            \"mttd_hours\": dora_metrics.get(\"mttd_hours\", 0.0),\n            \"mttr_minutes\": dora_metrics.get(\"mttr_minutes\", 0.0),\n            \"monthly_cloud_cost_usd\": cloud_cost,\n            \"self_service_adoption_pct\": adoption_rate,\n            \"team_size\": 8,  # Example team size\n            \"platform_tooling\": \"Backstage 1.22 + Crossplane 1.14\"\n        }]\n        \n        df = pd.DataFrame(report_data)\n        df.to_csv(output_path, index=False)\n        logger.info(f\"Report saved to {output_path}\")\n        return df\n\nif __name__ == \"__main__\":\n    # Configuration\n    PROMETHEUS_URL = \"http://prometheus.platform.svc.cluster.local:9090\"\n    AWS_REGION = \"us-east-1\"\n    OUTPUT_PATH = \"2026_platform_metrics.csv\"\n    \n    # Initialize collector\n    collector = PlatformMetricsCollector(\n        prometheus_url=PROMETHEUS_URL,\n        aws_region=AWS_REGION\n    )\n    \n    # Generate report\n    try:\n        report = collector.generate_report(OUTPUT_PATH)\n        print(\"2026 Platform Metrics Report:\")\n        print(report.to_string(index=False))\n    except Exception as e:\n        logger.error(f\"Failed to generate report: {e}\")\n        exit(1)\n

apiVersion: backstage.io/v1alpha1\nkind: Component\nmetadata:\n  name: checkout-service\n  description: Handles all e-commerce checkout operations\n  labels:\n    team: payments\n    environment: prod\n  annotations:\n    backstage.io/techdocs-ref: dir:.\n    crossplane.io/composition: checkout-infra\nspec:\n  type: service\n  lifecycle: production\n  owner: team-payments\n  system: e-commerce\n

apiVersion: apiextensions.crossplane.io/v1\nkind: CompositeResourceDefinition\nmetadata:\n  name: xs3buckets.platform.example.com\nspec:\n  group: platform.example.com\n  names:\n    kind: XS3Bucket\n    plural: xs3buckets\n  claimNames:\n    kind: S3Bucket\n    plural: s3buckets\n  versions:\n    - name: v1alpha1\n      served: true\n      referenceable: true\n      schema:\n        openAPIV3Schema:\n          type: object\n          properties:\n            spec:\n              type: object\n              properties:\n                region:\n                  type: string\n                  default: us-east-1\n                acl:\n                  type: string\n                  default: private\n

receivers:\n  prometheus:\n    config:\n      scrape_configs:\n        - job_name: 'backstage'\n          scrape_interval: 30s\n          static_configs:\n            - targets: ['backstage:7007']\n\nexporters:\n  prometheus:\n    endpoint: \"0.0.0.0:9090\"\n\nservice:\n  pipelines:\n    metrics:\n      receivers: [prometheus]\n      exporters: [prometheus]\n