feat: funcs-service v0.1.3 — /funcs/<namespace> URL without token

- /funcs/<namespace>: user opens URL in browser, no auth needed service uses SLESS_SERVICE_TOKEN to query operator internally - /funcs?token=<jwt>: token as query param (bookmarkable URL) - /funcs: returns usage hint with both URL formats - SLESS_SERVICE_TOKEN set via kubectl set env (not stored in repo)
feat: funcs as global Go service (sless-funcs-service:v0.1.1)
2026-03-18 16:11:17 +03:00 · 2026-03-18 15:58:08 +03:00 · 2026-03-18 11:03:58 +03:00 · 2026-03-18 10:05:15 +03:00 · 2026-03-18 09:23:13 +03:00 · 2026-03-18 09:07:47 +03:00
48 changed files with 2299 additions and 53 deletions
@@ -46,6 +46,20 @@

 ---

+## Именование
+
+Имена должны быть **уникальными и осмысленными по всему проекту**:
+- имена файлов
+- имена функций/методов
+- имена переменных/констант
+- имена ресурсов (Terraform, Kubernetes и т.д.)
+
+Цель: чтобы поиск по проекту находил нужные сущности без неоднозначности, а имя сразу отражало назначение.
+
+Запрещены безликие и повторяющиеся имена вида `handler.py`, `handle`, `data`, `value`, `temp` без контекста.
+
+---
+
 ## Git

 Коммитить и пушить после каждого завершённого этапа.
@@ -43,6 +43,9 @@ examples/*/dist/
 **/handler.zip
 test.token
 *.tfvars
+*.tfplan
+plan.out
+sless-plan
 .e2e-logs/
 .stress-logs/

@@ -57,4 +60,7 @@ test.token
 **/dist/
 # дополнительные вариации переменных/файлов конфигурации
 *.tfvars.json
+*.tfplan
+plan.out
+sless-plan
 examples/.git
@@ -20,6 +20,13 @@ rules:
  - get
  - list
  - watch
+- apiGroups:
+  - ""
+  resources:
+  - secrets
+  verbs:
+  - create
+  - get
 - apiGroups:
  - ""
  resources:
@@ -0,0 +1,107 @@
+# 2026-03-18
+# funcs-service.yaml — глобальный сервис листинга функций для всех пользователей.
+# Развёртывается ОДИН РАЗ в namespace sless рядом с оператором.
+# Доступен по: https://sless.kube5s.ru/funcs (с Bearer токеном пользователя)
+#
+# Обновить образ и применить:
+#   docker push naeel/sless-funcs-service:v0.1.0
+#   kubectl apply -f deployments/k8s/funcs-service.yaml
+
+---
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: sless-funcs-service
+  namespace: sless
+  labels:
+    app: sless-funcs-service
+spec:
+  replicas: 1
+  selector:
+    matchLabels:
+      app: sless-funcs-service
+  template:
+    metadata:
+      labels:
+        app: sless-funcs-service
+    spec:
+      containers:
+        - name: funcs
+          image: naeel/sless-funcs-service:v0.1.3
+          ports:
+            - containerPort: 8090
+          env:
+            - name: SLESS_OPERATOR_URL
+              value: "http://sless-operator.sless.svc.cluster.local:9090"
+            - name: SLESS_EXTERNAL_URL
+              value: "https://sless.kube5s.ru"
+            # Системные функции, скрытые из листинга
+            - name: SLESS_EXCLUDE
+              value: "event-writer,event-monitor,event-cleaner"
+            # Токен сервиса задаётся через kubectl set env или Secret — не хранится в репо
+            # kubectl set env deployment/sless-funcs-service -n sless SLESS_SERVICE_TOKEN="$(cat secrets/test.token)"
+            - name: PORT
+              value: "8090"
+          livenessProbe:
+            httpGet:
+              path: /health
+              port: 8090
+            initialDelaySeconds: 5
+            periodSeconds: 30
+          readinessProbe:
+            httpGet:
+              path: /health
+              port: 8090
+            initialDelaySeconds: 3
+            periodSeconds: 10
+          resources:
+            requests:
+              cpu: 10m
+              memory: 16Mi
+            limits:
+              cpu: 100m
+              memory: 64Mi
+
+---
+apiVersion: v1
+kind: Service
+metadata:
+  name: sless-funcs-service
+  namespace: sless
+spec:
+  selector:
+    app: sless-funcs-service
+  ports:
+    - port: 8090
+      targetPort: 8090
+
+---
+# Отдельный Ingress для /funcs — nginx выбирает более специфичный путь перед /
+# Без rewrite: сервис сам обрабатывает /funcs path
+# TLS-сертификат sless-operator-tls уже управляется cert-manager через ingress оператора;
+# здесь только ссылаемся на существующий секрет без аннотации cert-manager.io/cluster-issuer.
+apiVersion: networking.k8s.io/v1
+kind: Ingress
+metadata:
+  name: sless-funcs-ingress
+  namespace: sless
+  annotations:
+    nginx.ingress.kubernetes.io/force-ssl-redirect: "true"
+    nginx.ingress.kubernetes.io/ssl-redirect: "true"
+spec:
+  ingressClassName: nginx
+  rules:
+    - host: sless.kube5s.ru
+      http:
+        paths:
+          - path: /funcs
+            pathType: Prefix
+            backend:
+              service:
+                name: sless-funcs-service
+                port:
+                  number: 8090
+  tls:
+    - hosts:
+        - sless.kube5s.ru
+      secretName: sless-operator-tls
@@ -0,0 +1,122 @@
+# Изменено: 2026-03-14
+# Node-RED для визуального управления demo сценарием Event Log.
+# Образ: nodered/node-red:4 (официальный, всегда есть на DockerHub)
+# UI доступен по http://<ingress-ip>/nodered/
+# Для AMQP нужен плагин node-red-contrib-amqp — ставится через initContainer.
+---
+apiVersion: v1
+kind: PersistentVolumeClaim
+metadata:
+  name: nodered-data
+  namespace: sless
+spec:
+  accessModes:
+    - ReadWriteOnce
+  resources:
+    requests:
+      storage: 1Gi
+---
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: nodered
+  namespace: sless
+  labels:
+    app: nodered
+spec:
+  replicas: 1
+  selector:
+    matchLabels:
+      app: nodered
+  template:
+    metadata:
+      labels:
+        app: nodered
+    spec:
+      securityContext:
+        fsGroup: 1000
+      # initContainer устанавливает AMQP-плагин в PVC до старта основного контейнера
+      initContainers:
+        - name: install-nodes
+          image: nodered/node-red:latest
+          securityContext:
+            runAsUser: 0
+            runAsGroup: 0
+          command:
+            - sh
+            - -c
+            - |
+              chown -R 1000:1000 /data || true
+              cd /data
+              npm install --prefix /data node-red-contrib-amqp node-red-dashboard 2>&1 || true
+          volumeMounts:
+            - name: data
+              mountPath: /data
+      containers:
+        - name: nodered
+          image: nodered/node-red:latest
+          ports:
+            - containerPort: 1880
+          env:
+            - name: NODE_RED_ENABLE_PROJECTS
+              value: "false"
+            - name: TZ
+              value: "Europe/Moscow"
+          securityContext:
+            runAsUser: 1000
+            runAsGroup: 1000
+          volumeMounts:
+            - name: data
+              mountPath: /data
+          resources:
+            requests:
+              memory: "256Mi"
+              cpu: "100m"
+            limits:
+              memory: "512Mi"
+              cpu: "500m"
+          readinessProbe:
+            httpGet:
+              path: /
+              port: 1880
+            initialDelaySeconds: 15
+            periodSeconds: 10
+      volumes:
+        - name: data
+          persistentVolumeClaim:
+            claimName: nodered-data
+---
+apiVersion: v1
+kind: Service
+metadata:
+  name: nodered
+  namespace: sless
+spec:
+  selector:
+    app: nodered
+  ports:
+    - port: 1880
+      targetPort: 1880
+---
+# Ingress на Node-RED — доступен снаружи по http://nodered.185.247.187.147.nip.io
+apiVersion: networking.k8s.io/v1
+kind: Ingress
+metadata:
+  name: nodered
+  namespace: sless
+  annotations:
+    nginx.ingress.kubernetes.io/proxy-read-timeout: "3600"
+    nginx.ingress.kubernetes.io/proxy-send-timeout: "3600"
+spec:
+  ingressClassName: nginx
+  rules:
+    - host: nodered.185.247.187.147.nip.io
+      http:
+        paths:
+          - path: /
+            pathType: Prefix
+            backend:
+              service:
+                name: nodered
+                port:
+                  number: 1880
@@ -0,0 +1,125 @@
+# Изменено: 2026-03-14
+# Деплой sless оператора на demo-стенде (naeel-test-3, nip.io, без TLS).
+# Отличия от production operator.yaml:
+#   - REGISTRY_HOST=naeel (DockerHub, не Harbor)
+#   - INGRESS_HOST и EXTERNAL_URL — через nip.io без TLS
+#   - cert-manager аннотации убраны
+#   - API_TOKEN берётся из sless-operator-secret (совпадает с secrets/test.token)
+#
+# Перед apply нужно создать секреты:
+#   kubectl create secret generic sless-operator-secret -n sless \
+#     --from-literal=POSTGRES_DSN="postgres://sless:sless-pg-password@postgres.sless.svc.cluster.local:5432/sless?sslmode=disable" \
+#     --from-literal=S3_ACCESS_KEY="0GLQRD38H4I6RBDB0EWJ" \
+#     --from-literal=S3_SECRET_KEY="eTFibiHmBd96IApj9PYsboTR6OBoD7osxoarHykw" \
+#     --from-literal=SLESS_API_TOKEN="<token from secrets/test.token>" \
+#     --from-literal=HARBOR_PASS=""
+#
+#   kubectl create secret docker-registry sless-registry-auth -n sless \
+#     --docker-server=https://index.docker.io/v1/ \
+#     --docker-username=naeel \
+#     --docker-password=<DOCKERHUB_TOKEN>
+---
+apiVersion: v1
+kind: ConfigMap
+metadata:
+  name: sless-operator-config
+  namespace: sless
+data:
+  S3_ENDPOINT: "s3.msk-1.ngcloud.ru"
+  S3_BUCKET: "sless-functions"
+  S3_USE_SSL: "true"
+  # Harbor как registry для demo
+  REGISTRY_HOST: "pearlharbor.registryk8s.services.ngcloud.ru"
+  REGISTRY_SECRET: "sless-registry-auth"
+  HARBOR_USER: "admin"
+  API_PORT: "9090"
+  # nip.io домен без TLS — работает без настройки DNS
+  INGRESS_HOST: "fn.185.247.187.147.nip.io"
+  EXTERNAL_URL: "http://sless-api.185.247.187.147.nip.io"
+---
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: sless-operator
+  namespace: sless
+  labels:
+    app: sless-operator
+spec:
+  replicas: 1
+  selector:
+    matchLabels:
+      app: sless-operator
+  template:
+    metadata:
+      labels:
+        app: sless-operator
+    spec:
+      serviceAccountName: sless-operator
+      containers:
+        - name: operator
+          image: naeel/sless-operator:v0.1.29
+          imagePullPolicy: Always
+          ports:
+            - name: api
+              containerPort: 9090
+            - name: metrics
+              containerPort: 8080
+            - name: health
+              containerPort: 8081
+          envFrom:
+            - configMapRef:
+                name: sless-operator-config
+            - secretRef:
+                name: sless-operator-secret
+          readinessProbe:
+            httpGet:
+              path: /healthz
+              port: 8081
+            initialDelaySeconds: 5
+            periodSeconds: 10
+          livenessProbe:
+            httpGet:
+              path: /healthz
+              port: 8081
+            initialDelaySeconds: 15
+            periodSeconds: 20
+          resources:
+            requests:
+              memory: "64Mi"
+              cpu: "50m"
+            limits:
+              memory: "256Mi"
+              cpu: "500m"
+---
+apiVersion: v1
+kind: Service
+metadata:
+  name: sless-operator
+  namespace: sless
+spec:
+  selector:
+    app: sless-operator
+  ports:
+    - name: api
+      port: 9090
+      targetPort: 9090
+---
+# Ingress без TLS — demo стенд через nip.io
+apiVersion: networking.k8s.io/v1
+kind: Ingress
+metadata:
+  name: sless-operator
+  namespace: sless
+spec:
+  ingressClassName: nginx
+  rules:
+    - host: sless-api.185.247.187.147.nip.io
+      http:
+        paths:
+          - path: /
+            pathType: Prefix
+            backend:
+              service:
+                name: sless-operator
+                port:
+                  number: 9090
@@ -5,7 +5,7 @@
 #   - Secret: секретные данные (S3 keys, postgres DSN, API token, Harbor pass)
 #   - Deployment: оператор naeel/sless-operator:v0.1.23 в namespace sless
 #   - Service: ClusterIP :9090 (REST API)
-#   - Ingress: sless-api.kube5s.ru → :9090 (внешний доступ с TLS)
+#   - Ingress: sless.kube5s.ru → :9090 (внешний доступ с TLS)
 #
 # Чтобы сменить registry — менять только REGISTRY_HOST в ConfigMap.
 # Чтобы сменить Harbor-аккаунт — менять HARBOR_USER в ConfigMap + HARBOR_PASS в Secret.
@@ -32,7 +32,7 @@ data:
  INGRESS_HOST: "fn.kube5s.ru"
  # EXTERNAL_URL — если задан, URL функции = EXTERNAL_URL/fn/{namespace}/{name}
  # Позволяет обойтись без wildcard DNS *.fn.kube5s.ru
-  EXTERNAL_URL: "https://sless-api.kube5s.ru"
+  EXTERNAL_URL: "https://sless.kube5s.ru"
 ---
 # Secret создаётся отдельно через kubectl (не коммитить секреты в git!)
 # Описание ключей:
@@ -72,7 +72,7 @@ spec:
      containers:
        - name: operator
          # При обновлении версии оператора — менять тег здесь (не latest!)
-          image: naeel/sless-operator:v0.1.28
+          image: naeel/sless-operator:v0.1.32
          # Always — чтобы всегда тянуть по точному тегу (не кешировать старый)
          imagePullPolicy: Always
          ports:
@@ -133,7 +133,7 @@ metadata:
 spec:
  ingressClassName: nginx
  rules:
-    - host: sless-api.kube5s.ru
+    - host: sless.kube5s.ru
      http:
        paths:
          - path: /
@@ -145,5 +145,5 @@ spec:
                  number: 9090
  tls:
    - hosts:
-        - sless-api.kube5s.ru
+        - sless.kube5s.ru
      secretName: sless-operator-tls
@@ -0,0 +1,73 @@
+# Изменено: 2026-03-14
+# RabbitMQ для demo сценария Event Log.
+# Используется официальный образ с management-плагином для веб-UI.
+# credentials: sless / sless123
+# AMQP: amqp://sless:sless123@rabbitmq.sless.svc.cluster.local:5672/
+# Management UI: http://rabbitmq.sless.svc.cluster.local:15672/
+---
+apiVersion: v1
+kind: Secret
+metadata:
+  name: rabbitmq-secret
+  namespace: sless
+stringData:
+  RABBITMQ_DEFAULT_USER: "sless"
+  RABBITMQ_DEFAULT_PASS: "sless123"
+---
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: rabbitmq
+  namespace: sless
+  labels:
+    app: rabbitmq
+spec:
+  replicas: 1
+  selector:
+    matchLabels:
+      app: rabbitmq
+  template:
+    metadata:
+      labels:
+        app: rabbitmq
+    spec:
+      containers:
+        - name: rabbitmq
+          image: rabbitmq:3.13-management-alpine
+          ports:
+            - name: amqp
+              containerPort: 5672
+            - name: management
+              containerPort: 15672
+          envFrom:
+            - secretRef:
+                name: rabbitmq-secret
+          resources:
+            requests:
+              memory: "256Mi"
+              cpu: "100m"
+            limits:
+              memory: "512Mi"
+              cpu: "500m"
+          readinessProbe:
+            tcpSocket:
+              port: 5672
+            initialDelaySeconds: 40
+            periodSeconds: 10
+            timeoutSeconds: 10
+---
+apiVersion: v1
+kind: Service
+metadata:
+  name: rabbitmq
+  namespace: sless
+spec:
+  selector:
+    app: rabbitmq
+  ports:
+    - name: amqp
+      port: 5672
+      targetPort: 5672
+    - name: management
+      port: 15672
+      targetPort: 15672
@@ -1,5 +1,63 @@
 # Решения и обоснования

+## 2026-03-18 — Смена sless API endpoint: sless-api.kube5s.ru → sless.kube5s.ru
+
+**Решение:** Оператор sless доступен по `https://sless.kube5s.ru` (не `sless-api.kube5s.ru`). Все examples, deployments и ConfigMap обновлены.
+
+**Причина:** При пересоздании кластера DNS-запись `sless-api.kube5s.ru` не была обновлена — она указывала на IP `5.172.178.182` (старый, мёртвый кластер). Ingress нового кластера закреплён на `185.247.187.147`. Отдельная запись `sless.kube5s.ru` уже корректно указывала на `185.247.187.147`.  
+TLS handshake timeout возникал потому что старый IP принимал TCP:443, но не завершал TLS (nginx жив, бэкенд мёртв). Go HTTP клиент ждал системный таймаут (~90s) и повторял бесконечно.
+
+**Изменения:**
+- `deployments/k8s/operator.yaml`: `EXTERNAL_URL`, `INGRESS_HOST`, ingress host → `sless.kube5s.ru`
+- ConfigMap `sless-operator-config` в кластере: `EXTERNAL_URL` обновлён через `kubectl patch`
+- Ingress `sless-operator` в кластере: host + TLS secret → `sless.kube5s.ru`
+- Все `examples/**/main.tf`: `endpoint = "https://sless.kube5s.ru"`
+
+**Правило:** При пересоздании кластера — первым делом проверять соответствие DNS → ingress IP.
+
+---
+
+## 2026-03-17 — Разделение prod/test endpoint'ов в examples/
+
+**Решение:** Все `examples/` ОБЯЗАНЫ использовать `deck-api-test.ngcloud.ru` для обоих провайдеров: `nubes` и `sless` (`nubes_endpoint`). Продовый `deck-api.ngcloud.ru` — только для реальных клиентов.
+
+**Причина:** Смешивание prod и test endpoint'ов в одном `terraform apply` приводит к тому что ресурсы создаются в разных средах. `sless_function`/`sless_job` могут получать данные (PGHOST, credentials) из прода, а pod запускается в тест-кластере — и не может достучаться до хоста.
+
+**Правило для `main.tf` в examples:**
+```hcl
+provider "nubes" {
+  api_endpoint = "https://deck-api-test.ngcloud.ru/api/v1/index.cfm"
+}
+provider "sless" {
+  nubes_endpoint = "https://deck-api-test.ngcloud.ru/api/v1"
+}
+```
+
+---
+
+## 2026-03-17 — terraform apply только на удалённом сервере
+
+**Решение:** `terraform init/plan/apply/destroy` для `examples/` — исключительно через SSH на сервере `naeel@5.172.178.213`. Локальный запуск запрещён.
+
+**Причина:**
+1. Провайдер `terra.k8c.ru/naeel/sless` кэширован только на удалённом сервере
+2. Локальный terraform не имеет сетевого доступа к k8s кластеру и внутренним кластерным адресам (например PGHOST вида `*.svc.cluster.local`)
+3. Случайный локальный запуск с prod токенами может затронуть боевую среду
+
+**Как запускать:**
+```bash
+# Сначала синхронизировать изменения:
+rsync -av -e "ssh -i /home/naeel/remote_dev/common/id_ed25519.txt" \
+  /home/naeel/remote_dev/sless/examples/<example>/ \
+  naeel@5.172.178.213:/home/naeel/terra/sless/examples/<example>/
+
+# Затем запускать на remote:
+ssh -i /home/naeel/remote_dev/common/id_ed25519.txt naeel@5.172.178.213 \
+  'cd /home/naeel/terra/sless/examples/<example> && terraform apply -auto-approve -no-color'
+```
+
+---
+
 ## 2026-03-06 — Отдельная репа для сервиса

 **Решение:** Serverless service в отдельной репе, не вместе с Terraform provider.
@@ -1,6 +1,75 @@
 # Прогресс разработки

-Последнее обновление: 2026-03-10 (добавлен прагматичный обзор Claude Opus 4.6)
+Последнее обновление: 2026-03-18 12:00 (DNS инцидент устранён, POSTGRES E2E PASS)
+
+## 2026-03-18 — DNS инцидент: sless-api.kube5s.ru → мёртвый кластер
+
+| # | Задача | Статус | Заметки |
+|---|--------|--------|----------|
+| 1 | Диагностика TLS handshake timeout при `terraform apply` POSTGRES | ✅ | `sless-api.kube5s.ru` → `5.172.178.182` (старый кластер). Порт 443 принимал TCP, но TLS не завершался — Go HTTP клиент висел бесконечно |
+| 2 | Подтверждение нового кластера | ✅ | `kubectl get nodes` в контексте `tazetdinovn@gmail.com@naeel-test-3` → 3 ноды Ready. Ingress IP `185.247.187.147`. DNS `sless.kube5s.ru` уже указывал на него |
+| 3 | Обновить Ingress в кластере | ✅ | `kubectl patch ingress sless-operator -n sless`: host + TLS → `sless.kube5s.ru`, secretName → `sless-operator-tls-sless` |
+| 4 | Обновить ConfigMap оператора | ✅ | `EXTERNAL_URL: https://sless.kube5s.ru` (было `https://sless-api.kube5s.ru`) |
+| 5 | Let's Encrypt сертификат | ✅ | `certificate/sless-operator-tls-sless` READY=True, order valid — выдан сразу после смены ingress host (ACME HTTP-01 challenge на новом IP прошёл) |
+| 6 | Заменить `sless-api.kube5s.ru` → `sless.kube5s.ru` во всех examples + deployments | ✅ | `POSTGRES/`, `hello-go/`, `hello-node/`, `simple-node/`, `simple-python/`, `notes-python/`, `pg-list-python/`, `demo-managed-functions/`, `README.md`, `deployments/k8s/operator.yaml` |
+| 7 | POSTGRES `terraform apply` с функцией и job | ✅ PASS | `sless_function` `pg-create-table-runner` — создан за 55s. `sless_job` `pg-create-table-job-main-v13` — создан за 20s. `Apply complete! Resources: 2 added` |
+| 8 | Коммит и push | ✅ | `cca3a8c` — `fix: migrate sless endpoint from sless-api.kube5s.ru to sless.kube5s.ru` |
+
+---
+
+
+## 2026-03-17 — E2E тесты всех примеров на тест-стенде
+
+| # | Задача | Статус | Заметки |
+|---|--------|--------|---------|
+| 1 | Исправить `nubes_endpoint` во всех examples (prod→test) | ✅ | `deck-api.ngcloud.ru` → `deck-api-test.ngcloud.ru/api/v1` в hello-node, hello-go, simple-node, notes-python, pg-list-python, demo-managed-functions |
+| 2 | Исправить `sless_endpoint` в demo-managed-functions | ✅ | `185.247.187.147.nip.io` → `https://sless-api.kube5s.ru` |
+| 3 | Postgres для тестов | ✅ | `postgres.sless.svc.cluster.local:5432`, user=`sless`, pass=`sless-pg-password`, db=`sless`. Уже запущен в кластере |
+| 4 | `hello-node` E2E | ✅ PASS | init → apply (4 ресурса) → modify (memory_mb 128→256, env_var) → apply → destroy |
+| 5 | `simple-python` E2E | ✅ PASS | init → apply → modify (memory_mb 64→96) → apply → destroy. `job_result = {"time": "..."}` |
+| 6 | `simple-node` E2E | ✅ PASS | Аналогично simple-python но nodejs20 |
+| 7 | `notes-python` E2E | ✅ PASS | 7 ресурсов, PostgreSQL init job: `{"ok": true, "executed": 1}`, destroy complete |
+| 8 | Коммит на remote | ✅ | `a768454` в `/home/naeel/terra/sless/examples` |
+| 9 | POSTGRES example | 🔄 | Следующий шаг — вернуться к POSTGRES после прохождения всех тестов |
+
+---
+
+
+## 2026-03-17 — v0.1.31: compile fix + POSTGRES example end-to-end
+
+| # | Задача | Статус | Заметки |
+|---|--------|--------|---------|
+| 1 | Баг 3: `PodLogOptions{Stdout/Stderr}` compile error | ✅ | Убраны несуществующие поля. `getJobPodOutput` в `functionjob_controller.go` |
+| 2 | Сборка `naeel/sless-operator:v0.1.31` | ✅ | Собрано на `naeel@5.172.178.213`, запушено в Docker Hub |
+| 3 | Деплой v0.1.31 в кластер | ✅ | `kubectl rollout status` → success. Pod `sless-operator-545556c59d-n8qv9` |
+| 4 | `simple-python` — сквозной тест на тест-стенде | ✅ | `terraform apply` на remote: `Apply complete! Resources: 3 added`. `job_result = {"time": "..."}` |
+| 5 | Найдена главная причина падения POSTGRES | ✅ | `nubes_endpoint` в `provider "sless"` указывал на **прод** `deck-api.ngcloud.ru` |
+| 6 | Исправлен `nubes_endpoint` в POSTGRES/main.tf | ✅ | Теперь `deck-api-test.ngcloud.ru/api/v1` |
+| 7 | Исправлен `nubes_endpoint` в simple-python/main.tf | ✅ | Аналогично |
+| 8 | End-to-end `terraform apply` для POSTGRES | 🔄 | Следующий шаг: синхронизировать на remote и запустить `terraform apply` |
+
+---
+
+## 2026-03-17 — POSTGRES example: внешний managed PG, FunctionJob и реальные блокеры
+
+| # | Задача | Статус | Заметки |
+|---|--------|--------|---------|
+| 1 | Перевод `examples/POSTGRES` на `PGSSLMODE=require` | ✅ | Для managed PostgreSQL `allow_no_s_s_l = false`; `disable` был некорректен |
+| 2 | Подтверждение root-cause `password authentication failed` | ✅ | Из runtime namespace поднят диагностический pod того же image: `psycopg2.OperationalError: FATAL: password authentication failed for user "u-user0"` |
+| 3 | Проверка источника пароля | ✅ | `nubes_postgres.npg.vault_secrets["users"]` не совпадает с фактическим паролем пользователя в кластере managed PostgreSQL; authoritative source сейчас — k8s secret `u-user0.postgresqlk8s.credentials.postgresql.acid.zalan.do` |
+| 4 | Попытка читать пароль через `hashicorp/external` | ❌ | В текущем окружении доступен только кастомный registry; `registry.terraform.io/hashicorp/external` не устанавливается |
+| 5 | One-command `terraform apply` для `examples/POSTGRES` | 🔄 | Остаточный баг локализован в связке credential-source + FunctionJob observability. После переключения на актуальный пароль `sless_job` всё ещё падает, но актуальные pod logs реального job теряются из-за TTL/слабой наблюдаемости |
+| 6 | Необходимый следующий технический шаг | 🔄 | Либо добавить в проект доступный data-source/провайдер для чтения k8s secret внутри apply, либо починить источник пароля в nubes-потоке, чтобы `vault_secrets` и реальный Postgres user password совпадали |
+
+
+## 2026-03-17 — Fix: `examples/POSTGRES` / `sless_job` 409 + диагностика FunctionJob
+
+| # | Задача | Статус | Заметки |
+|---|--------|--------|---------|
+| 1 | Идемпотентность `sless_job` при `409 job already exists` | ✅ | `terraform/provider/internal/client/client.go`, `terraform/provider/internal/resources/job_resource.go`: добавлен typed-error `ErrJobAlreadyExists`, в Create при 409 читается существующий Job и продолжается ожидание/синхронизация вместо немедленного падения |
+| 2 | Диагностика падений FunctionJob | ✅ | `controllers/functionjob_controller.go`: labels добавлены в `PodTemplate`, fail-message теперь включает output pod-а (обрезка до 2000), fallback-команда логов по `job-name` |
+| 3 | Root-cause для `examples/POSTGRES` | ✅ | Рабочие `examples/notes-python` используют внутренний DSN (`postgres.sless.svc`), а `examples/POSTGRES` работает через managed Nubes Postgres + динамические креды; критичный UX-дефект был в повторном Create после failed apply |
+

 ## Статусы: ✅ готово | 🔄 в процессе | ⏳ не начато

@@ -16,7 +16,7 @@ crash.log
 # Provider plugins / caches
 .terraform.d/

-#*.tfvars
+*.tfvars

 # Archives and build artifacts
 *.zip
@@ -0,0 +1,129 @@
+# 2026-03-18 (обновлено: фильтрация SLESS_EXCLUDE, читаемый вывод через "#"-ключ)
+# funcs_list.py — HTTP-функция: список всех пользовательских функций с их статусами.
+# Вызывает внутренний REST API оператора (ClusterIP, без TLS).
+# Объединяет данные функций и триггеров в один ответ; скрывает служебные функции.
+#
+# Env vars:
+#   SLESS_API_URL      — URL оператора (http://sless-operator.sless.svc.cluster.local:9090)
+#   SLESS_NAMESPACE    — namespace пользователя (sless-{hex16})
+#   SLESS_TOKEN        — JWT токен для /v1/ API
+#   SLESS_EXTERNAL_URL — публичный базовый URL (https://sless.kube5s.ru), для корректных ссылок
+#   SLESS_EXCLUDE      — comma-separated имена функций, которые не надо показывать
+#                        Пример: "funcs,event-writer,event-monitor,event-cleaner"
+#
+# Формат вывода: JSON-объект, где каждая функция содержит поле "#" — краткий комментарий.
+# При pretty-print (python3 -m json.tool) выглядит как читаемый список с аннотациями.
+
+import os
+import requests
+
+
+def _short_comment(fn, http_triggers, cron_triggers):
+    """Генерирует однострочный комментарий-описание функции по её метаданным."""
+    phase = fn.get("phase", "")
+    runtime = fn.get("runtime", "")
+
+    if http_triggers:
+        active_str = "активна" if http_triggers[0].get("active") else "неактивна"
+        return f"HTTP endpoint ({runtime}) — {phase}, {active_str}"
+    elif cron_triggers:
+        schedule = cron_triggers[0].get("schedule", "?")
+        active_str = "активна" if cron_triggers[0].get("active") else "неактивна"
+        return f"Cron '{schedule}' ({runtime}) — {phase}, {active_str}"
+    else:
+        return f"Job/runner без триггера ({runtime}) — {phase}"
+
+
+def list_all(event):
+    api_url   = os.environ["SLESS_API_URL"].rstrip("/")
+    namespace = os.environ["SLESS_NAMESPACE"]
+    token     = os.environ["SLESS_TOKEN"]
+    ext_url   = os.environ.get("SLESS_EXTERNAL_URL", "").rstrip("/")
+
+    # Имена функций, которые не должны присутствовать в выводе.
+    # Включает саму себя ("funcs") и служебные функции других примеров.
+    exclude = {
+        n.strip()
+        for n in os.environ.get("SLESS_EXCLUDE", "").split(",")
+        if n.strip()
+    }
+
+    headers = {"Authorization": f"Bearer {token}"}
+
+    fns_resp = requests.get(
+        f"{api_url}/v1/namespaces/{namespace}/functions",
+        headers=headers,
+        timeout=10,
+    )
+    fns_resp.raise_for_status()
+
+    trs_resp = requests.get(
+        f"{api_url}/v1/namespaces/{namespace}/triggers",
+        headers=headers,
+        timeout=10,
+    )
+    trs_resp.raise_for_status()
+
+    # Индекс триггеров по имени функции
+    triggers_by_fn = {}
+    for tr in trs_resp.json():
+        fn_name = tr.get("function") or tr.get("functionRef")
+        if fn_name:
+            triggers_by_fn.setdefault(fn_name, []).append(tr)
+
+    result = []
+    for fn in fns_resp.json():
+        name = fn["name"]
+        if name in exclude:
+            continue
+
+        http_triggers = [
+            t for t in triggers_by_fn.get(name, []) if t.get("type") == "http"
+        ]
+        cron_triggers = [
+            t for t in triggers_by_fn.get(name, []) if t.get("type") == "cron"
+        ]
+        is_active = any(
+            t.get("enabled", True) and t.get("active", False)
+            for t in triggers_by_fn.get(name, [])
+        )
+
+        entry = {
+            # "#" — первый ключ: служит визуальным комментарием при pretty-print
+            "#":       _short_comment(fn, http_triggers, cron_triggers),
+            "name":    name,
+            "runtime": fn.get("runtime"),
+            "phase":   fn.get("phase"),
+            "active":  is_active,
+        }
+
+        # URL вычисляем из SLESS_EXTERNAL_URL если задан — state может хранить старый домен
+        if http_triggers:
+            if ext_url:
+                entry["url"] = f"{ext_url}/fn/{namespace}/{name}"
+            else:
+                entry["url"] = http_triggers[0].get("url", "")
+
+        if cron_triggers:
+            entry["cron"] = cron_triggers[0].get("schedule", "")
+
+        if fn.get("message"):
+            entry["message"] = fn["message"]
+
+        # created_at и last_built_at — доступны после обновления оператора до v0.1.32+
+        if fn.get("created_at"):
+            entry["created_at"] = fn["created_at"]
+        if fn.get("last_built_at"):
+            entry["last_built_at"] = fn["last_built_at"]
+
+        result.append(entry)
+
+    # Сортировка: активные вверх, затем по имени
+    result.sort(key=lambda f: (not f["active"], f["name"]))
+
+    return {
+        "namespace": namespace,
+        "count":     len(result),
+        "functions": result,
+    }
+
@@ -0,0 +1 @@
+requests==2.31.0
@@ -0,0 +1,8 @@
+{
+    "name": "pg-info",
+    "version": "1.0.0",
+    "description": "sless nodejs20 function: pg version + table info",
+    "dependencies": {
+        "pg": "8.11.0"
+    }
+}
@@ -0,0 +1,43 @@
+// 2026-03-18
+// pg_info.js — NodeJS-функция: проверка работы JS runtime + чтение мета-данных БД.
+// Подключается к PostgreSQL через пакет pg, возвращает версию сервера и счётчик строк.
+// Демонстрирует: nodejs20 runtime, npm-зависимость (package.json), PG из JS.
+//
+// ENV (те же что у python-функций):
+//   PGHOST, PGPORT, PGDATABASE, PGUSER, PGPASSWORD, PGSSLMODE
+//
+// Entrypoint: pg_info.info
+
+'use strict';
+
+const { Client } = require('pg');
+
+exports.info = async (event) => {
+    const client = new Client({
+        host: process.env.PGHOST,
+        port: parseInt(process.env.PGPORT || '5432'),
+        database: process.env.PGDATABASE,
+        user: process.env.PGUSER,
+        password: process.env.PGPASSWORD,
+        // pg-пакет требует явного ssl-объекта; rejectUnauthorized: false — т.к.
+        // self-signed cert на nubes managed PG, но канал всё равно шифруется.
+        ssl: process.env.PGSSLMODE === 'require' ? { rejectUnauthorized: false } : false,
+    });
+
+    await client.connect();
+    try {
+        const [versionRes, countRes] = await Promise.all([
+            client.query('SELECT version() AS v'),
+            client.query('SELECT COUNT(*) AS cnt FROM terraform_demo_table'),
+        ]);
+
+        return {
+            runtime: 'nodejs20',
+            node_version: process.version,
+            pg_version: versionRes.rows[0].v,
+            table_rows: parseInt(countRes.rows[0].cnt, 10),
+        };
+    } finally {
+        await client.end();
+    }
+};
@@ -0,0 +1,3 @@
+# 2026-03-17 00:00
+# requirements.txt — зависимости для функции запуска SQL.
+psycopg2-binary==2.9.9
@@ -0,0 +1,39 @@
+# 2026-03-17 00:00
+# sql_runner.py — функция для выполнения SQL-операторов из входного события.
+import os
+import psycopg2
+
+
+def run_sql(event):
+    # Выполняет список SQL-операторов в одной транзакции для атомарной инициализации схемы.
+    # Параметры подключения передаются раздельно, чтобы избежать ошибок парсинга DSN при спецсимволах.
+    pg_host = os.environ["PGHOST"]
+    pg_port = os.environ.get("PGPORT", "5432")
+    pg_database = os.environ["PGDATABASE"]
+    pg_user = os.environ["PGUSER"]
+    pg_password = os.environ["PGPASSWORD"]
+    pg_sslmode = os.environ.get("PGSSLMODE", "require")
+    statements = event.get("statements", [])
+
+    if not statements:
+        return {"error": "no statements provided"}
+
+    connection = psycopg2.connect(
+        host=pg_host,
+        port=pg_port,
+        dbname=pg_database,
+        user=pg_user,
+        password=pg_password,
+        sslmode=pg_sslmode,
+    )
+    try:
+        cursor = connection.cursor()
+        for statement in statements:
+            cursor.execute(statement)
+        connection.commit()
+        return {"ok": True, "executed": len(statements)}
+    except Exception as error:
+        connection.rollback()
+        return {"error": str(error)}
+    finally:
+        connection.close()
@@ -0,0 +1 @@
+psycopg2-binary==2.9.9
@@ -0,0 +1,27 @@
+# 2026-03-18
+# table_reader.py — HTTP-функция: читает строки из terraform_demo_table и возвращает JSON.
+# Подключается к Postgres через env vars (те же что у sql-runner).
+import os
+import psycopg2
+import psycopg2.extras
+
+
+def list_rows(event):
+    # Возвращает все строки terraform_demo_table в порядке убывания created_at.
+    connection = psycopg2.connect(
+        host=os.environ["PGHOST"],
+        port=os.environ.get("PGPORT", "5432"),
+        dbname=os.environ["PGDATABASE"],
+        user=os.environ["PGUSER"],
+        password=os.environ["PGPASSWORD"],
+        sslmode=os.environ.get("PGSSLMODE", "require"),
+    )
+    try:
+        cursor = connection.cursor(cursor_factory=psycopg2.extras.RealDictCursor)
+        cursor.execute(
+            "SELECT id, title, created_at::text FROM terraform_demo_table ORDER BY created_at DESC"
+        )
+        rows = [dict(row) for row in cursor.fetchall()]
+        return {"rows": rows, "count": len(rows)}
+    finally:
+        connection.close()
@@ -0,0 +1,129 @@
+# 2026-03-18 (обновлено: фильтрация SLESS_EXCLUDE, читаемый вывод через "#"-ключ)
+# funcs_list.py — HTTP-функция: список всех пользовательских функций с их статусами.
+# Вызывает внутренний REST API оператора (ClusterIP, без TLS).
+# Объединяет данные функций и триггеров в один ответ; скрывает служебные функции.
+#
+# Env vars:
+#   SLESS_API_URL      — URL оператора (http://sless-operator.sless.svc.cluster.local:9090)
+#   SLESS_NAMESPACE    — namespace пользователя (sless-{hex16})
+#   SLESS_TOKEN        — JWT токен для /v1/ API
+#   SLESS_EXTERNAL_URL — публичный базовый URL (https://sless.kube5s.ru), для корректных ссылок
+#   SLESS_EXCLUDE      — comma-separated имена функций, которые не надо показывать
+#                        Пример: "funcs,event-writer,event-monitor,event-cleaner"
+#
+# Формат вывода: JSON-объект, где каждая функция содержит поле "#" — краткий комментарий.
+# При pretty-print (python3 -m json.tool) выглядит как читаемый список с аннотациями.
+
+import os
+import requests
+
+
+def _short_comment(fn, http_triggers, cron_triggers):
+    """Генерирует однострочный комментарий-описание функции по её метаданным."""
+    phase = fn.get("phase", "")
+    runtime = fn.get("runtime", "")
+
+    if http_triggers:
+        active_str = "активна" if http_triggers[0].get("active") else "неактивна"
+        return f"HTTP endpoint ({runtime}) — {phase}, {active_str}"
+    elif cron_triggers:
+        schedule = cron_triggers[0].get("schedule", "?")
+        active_str = "активна" if cron_triggers[0].get("active") else "неактивна"
+        return f"Cron '{schedule}' ({runtime}) — {phase}, {active_str}"
+    else:
+        return f"Job/runner без триггера ({runtime}) — {phase}"
+
+
+def list_all(event):
+    api_url   = os.environ["SLESS_API_URL"].rstrip("/")
+    namespace = os.environ["SLESS_NAMESPACE"]
+    token     = os.environ["SLESS_TOKEN"]
+    ext_url   = os.environ.get("SLESS_EXTERNAL_URL", "").rstrip("/")
+
+    # Имена функций, которые не должны присутствовать в выводе.
+    # Включает саму себя ("funcs") и служебные функции других примеров.
+    exclude = {
+        n.strip()
+        for n in os.environ.get("SLESS_EXCLUDE", "").split(",")
+        if n.strip()
+    }
+
+    headers = {"Authorization": f"Bearer {token}"}
+
+    fns_resp = requests.get(
+        f"{api_url}/v1/namespaces/{namespace}/functions",
+        headers=headers,
+        timeout=10,
+    )
+    fns_resp.raise_for_status()
+
+    trs_resp = requests.get(
+        f"{api_url}/v1/namespaces/{namespace}/triggers",
+        headers=headers,
+        timeout=10,
+    )
+    trs_resp.raise_for_status()
+
+    # Индекс триггеров по имени функции
+    triggers_by_fn = {}
+    for tr in trs_resp.json():
+        fn_name = tr.get("function") or tr.get("functionRef")
+        if fn_name:
+            triggers_by_fn.setdefault(fn_name, []).append(tr)
+
+    result = []
+    for fn in fns_resp.json():
+        name = fn["name"]
+        if name in exclude:
+            continue
+
+        http_triggers = [
+            t for t in triggers_by_fn.get(name, []) if t.get("type") == "http"
+        ]
+        cron_triggers = [
+            t for t in triggers_by_fn.get(name, []) if t.get("type") == "cron"
+        ]
+        is_active = any(
+            t.get("enabled", True) and t.get("active", False)
+            for t in triggers_by_fn.get(name, [])
+        )
+
+        entry = {
+            # "#" — первый ключ: служит визуальным комментарием при pretty-print
+            "#":       _short_comment(fn, http_triggers, cron_triggers),
+            "name":    name,
+            "runtime": fn.get("runtime"),
+            "phase":   fn.get("phase"),
+            "active":  is_active,
+        }
+
+        # URL вычисляем из SLESS_EXTERNAL_URL если задан — state может хранить старый домен
+        if http_triggers:
+            if ext_url:
+                entry["url"] = f"{ext_url}/fn/{namespace}/{name}"
+            else:
+                entry["url"] = http_triggers[0].get("url", "")
+
+        if cron_triggers:
+            entry["cron"] = cron_triggers[0].get("schedule", "")
+
+        if fn.get("message"):
+            entry["message"] = fn["message"]
+
+        # created_at и last_built_at — доступны после обновления оператора до v0.1.32+
+        if fn.get("created_at"):
+            entry["created_at"] = fn["created_at"]
+        if fn.get("last_built_at"):
+            entry["last_built_at"] = fn["last_built_at"]
+
+        result.append(entry)
+
+    # Сортировка: активные вверх, затем по имени
+    result.sort(key=lambda f: (not f["active"], f["name"]))
+
+    return {
+        "namespace": namespace,
+        "count":     len(result),
+        "functions": result,
+    }
+
@@ -0,0 +1,73 @@
+
+# resource "nubes_lucee" "app1" {
+#   # Lucee-приложение, зависит от Postgres
+#   resource_name      = "lucy_teststand_0"
+#   # resource_realm     = "k8s-3.ext.nubes.ru"
+#   resource_realm     =  nubes_postgres.db2.resource_realm
+#   # resource_realm        = "k8s-4-sandbox-nubes-ru"
+#   domain             = "web-test-stand"
+
+#   git_path           = "https://gitea-naeel.giteak8s.services.ngcloud.ru/naeel/testlucee"
+
+# json_env = jsonencode({
+#     # 🔗 Настройки Data Source 'testds' для Lucee (Application.cfc)
+#     testds_class            = "org.postgresql.Driver"      # 📂 Драйвер БД
+#     testds_bundleName       = "org.postgresql.jdbc"        # 📦 Имя бандла JDBC
+#     testds_bundleVersion    = "42.6.0"                    # 🔢 Версия драйвера
+#     testds_connectionString = "jdbc:postgresql://${nubes_postgres.db2.state_out_flat["internalConnect.master"]}:5432/postgres?sslmode=require" # 🚀 Строка подключения
+#     testds_username         = nubes_postgres_user.db2_user.username # 👤 Логин
+#     testds_password         = jsondecode(nubes_postgres.db2.vault_secrets["users"])[nubes_postgres_user.db2_user.username]["password"] # 🔑 Пароль
+#     testds_connectionLimit  = "5"                         # 🚦 Лимит соединений
+#     testds_liveTimeout      = "15"                        # ⏳ Таймаут жизни
+#     testds_validate         = "false"                     # ✅ Валидация при запросе
+#   })
+
+#   resource_c_p_u     = 300
+#   resource_memory    = 512
+#   resource_instances = 1
+#   app_version        = "5.4"
+
+#   depends_on = [nubes_postgres.db2]
+# }
+
+# resource "nubes_nodejs" "app3" {
+# 	# NodeJS демо, работающий с тем же Postgres.
+# 	resource_name   = "node_01"
+# 	resource_realm  = nubes_postgres.db2.resource_realm
+# 	domain          = "node07"
+# 	git_path        = "https://gitea-naeel.giteak8s.services.ngcloud.ru/naeel/testnode.git"
+# 	health_path     = "/healthz"
+# 	app_version     = "23"
+
+# 	json_env = jsonencode({
+# 		# Переменные подключения к Postgres.
+# 		PGHOST       = nubes_postgres.db2.state_out_flat["internalConnect.master"]
+# 		PGPORT       = "5432"
+#     PGUSER       = nubes_postgres_user.db2_user.username
+#     PGPASSWORD   = jsondecode(nubes_postgres.db2.vault_secrets["users"])[nubes_postgres_user.db2_user.username]["password"]
+#     PGDATABASE   = nubes_postgres_database.db2_app.db_name
+# 		PGSSLMODE    = "require"
+# 		DATABASE_URL = format(
+#       "postgresql://%s:%s@%s:5432/%s?sslmode=require",
+#       nubes_postgres_user.db2_user.username,
+#       jsondecode(nubes_postgres.db2.vault_secrets["users"])[nubes_postgres_user.db2_user.username]["password"],
+#       nubes_postgres.db2.state_out_flat["internalConnect.master"],
+#       nubes_postgres_database.db2_app.db_name
+# 		)
+# 	})
+
+# 	resource_c_p_u     = 300
+# 	resource_memory    = 256
+# 	resource_instances = 1
+
+# 	depends_on = [nubes_postgres.db2]
+# }
+
+# output "pg_vault_secrets" {
+#   value     = nubes_postgres.db2.vault_secrets
+#   sensitive = true
+# }
+
+#  terraform output -json pg_vault_secrets
+
+
@@ -0,0 +1,58 @@
+// 2026-03-17 17:05
+// main.tf — провайдеры и переменные для Nubes + sless.
+terraform {
+  required_providers {
+    nubes = {
+      source  = "terra.k8c.ru/nubes/nubes"
+      version = "5.0.19"
+    }
+    sless = {
+      source  = "terra.k8c.ru/naeel/sless"
+      version = "~> 0.1.18"
+    }
+  }
+}
+
+variable "api_token" {
+  type        = string
+  sensitive   = true
+  description = "Nubes API token"
+}
+variable "s3_uid" {
+  type        = string
+  sensitive   = true
+  description = "Nubes S3 UID"
+}
+variable "realm" {
+  type        = string
+  sensitive   = true
+  description = "resource_realm parameter for nubes_postgres resource"
+}
+
+// 2026-03-18 — pg_user/pg_password помечены optional (default="") для сверки.
+//              Реальные credentials берутся из vault_secrets через locals в resources.tf.
+variable "pg_user" {
+  type        = string
+  sensitive   = true
+  default     = ""
+  description = "Только для сверки. Реальный username из nubes_postgres_user.pg_user.username. Должен совпадать с vault."
+}
+
+variable "pg_password" {
+  type        = string
+  sensitive   = true
+  default     = ""
+  description = "Только для сверки. Реальный пароль из vault_secrets. Должен совпадать с tfvars."
+}
+
+provider "nubes" {
+  api_token    = var.api_token
+  api_endpoint = "https://deck-api-test.ngcloud.ru/api/v1/index.cfm"
+}
+
+provider "sless" {
+  endpoint       = "https://sless.kube5s.ru"
+  token          = var.api_token
+  nubes_endpoint = "https://deck-api-test.ngcloud.ru/api/v1"
+}
+
@@ -0,0 +1,164 @@
+// 2026-03-18 — добавлены locals для извлечения credentials из vault_secrets (без хардкода).
+//              Для сверки хардкод остаётся в terraform.tfvars на этапе разработки.
+//              sless_function и sless_job закомментированы — сначала проверяется сетевое соединение.
+
+# Актуальные credentials из vault_secrets (authoritatively) — vault синхронизирован с кластером.
+# Структура vault_secrets["users"]: JSON-строка {"username": {"password": "...", "username": "..."}}
+locals {
+  pg_creds_map = jsondecode(nubes_postgres.npg.vault_secrets["users"])
+  pg_username  = nubes_postgres_user.pg_user.username
+  pg_password  = local.pg_creds_map[local.pg_username]["password"]
+  pg_host      = nubes_postgres.npg.state_out_flat["internalConnect.master"]
+  pg_database  = nubes_postgres_database.db.db_name
+}
+
+resource "nubes_postgres" "npg" {
+  resource_name = "teststand-pg-2"
+  # s3_uid                = "s01325"
+  s3_uid             = var.s3_uid
+  resource_realm     = var.realm
+  resource_instances = 1
+  resource_memory    = 512
+  resource_c_p_u     = 500
+  resource_disk      = "1"
+  app_version        = "17"
+  json_parameters = jsonencode({
+    log_connections    = "off"
+    log_disconnections = "off"
+  })
+  enable_pg_pooler_master      = false
+  enable_pg_pooler_slave       = false
+  allow_no_s_s_l               = false
+  auto_scale                   = false
+  auto_scale_percentage        = 10
+  auto_scale_tech_window       = 0
+  auto_scale_quota_gb          = "1"
+  need_external_address_master = false
+
+  # suspend_on_destroy = false
+  operation_timeout        = "11m"
+  adopt_existing_on_create = true
+}
+
+resource "nubes_postgres_user" "pg_user" {
+  postgres_id              = nubes_postgres.npg.id
+  username                 = "u-user0"
+  role                     = "ddl_user"
+  adopt_existing_on_create = true
+}
+
+resource "nubes_postgres_database" "db" {
+  postgres_id              = nubes_postgres.npg.id
+  db_name                  = "db_terra"
+  db_owner                 = nubes_postgres_user.pg_user.username
+  adopt_existing_on_create = true
+  # suspend_on_destroy = false
+}
+
+# Служебная функция выполняет SQL-операторы из event_json.
+# Credentials берутся из locals (vault_secrets) — без хардкода.
+# Для сверки хардкод остаётся в terraform.tfvars.
+resource "sless_function" "postgres_sql_runner_create_table" {
+  name        = "pg-create-table-runner"
+  runtime     = "python3.11"
+  entrypoint  = "sql_runner.run_sql"
+  memory_mb   = 128
+  timeout_sec = 30
+
+  env_vars = {
+    PGHOST     = local.pg_host
+    PGPORT     = "5432"
+    PGDATABASE = local.pg_database
+    PGUSER     = local.pg_username
+    PGPASSWORD = local.pg_password
+    PGSSLMODE  = "require"
+    # Для сверки (должно совпадать с vault):
+    # PGUSER     = var.pg_user
+    # PGPASSWORD = var.pg_password
+  }
+
+  source_dir = "${path.module}/code/sql-runner"
+}
+
+resource "sless_job" "postgres_table_init_job" {
+  name             = "pg-create-table-job-main-v13"
+  function         = sless_function.postgres_sql_runner_create_table.name
+  wait_timeout_sec = 180
+  run_id           = 13
+
+  event_json = jsonencode({
+    statements = [
+      "CREATE TABLE IF NOT EXISTS terraform_demo_table (id serial PRIMARY KEY, title text NOT NULL, created_at timestamp DEFAULT now())"
+    ]
+  })
+
+  depends_on = [nubes_postgres_database.db]
+}
+
+# HTTP-функция на NodeJS: возвращает версию PG-сервера и счётчик строк в таблице.
+# Единственная функция примера на nodejs20 — проверка что JS runtime работает.
+# Доступна по URL: https://sless.kube5s.ru/fn/<namespace>/pg-info
+resource "sless_function" "pg_info" {
+  name        = "pg-info"
+  runtime     = "nodejs20"
+  entrypoint  = "pg_info.info"
+  memory_mb   = 128
+  timeout_sec = 15
+
+  env_vars = {
+    PGHOST     = local.pg_host
+    PGPORT     = "5432"
+    PGDATABASE = local.pg_database
+    PGUSER     = local.pg_username
+    PGPASSWORD = local.pg_password
+    PGSSLMODE  = "require"
+  }
+
+  source_dir = "${path.module}/code/pg-info"
+
+  depends_on = [sless_job.postgres_table_init_job]
+}
+
+resource "sless_trigger" "pg_info_http" {
+  name     = "pg-info-http"
+  type     = "http"
+  function = sless_function.pg_info.name
+  enabled  = true
+}
+
+# HTTP-функция читает строки из terraform_demo_table и возвращает JSON.
+# Использует те же credentials что и sql-runner.
+# Доступна по URL: https://sless.kube5s.ru/fn/<namespace>/pg-table-reader
+resource "sless_function" "postgres_table_reader" {
+  name        = "pg-table-reader"
+  runtime     = "python3.11"
+  entrypoint  = "table_reader.list_rows"
+  memory_mb   = 128
+  timeout_sec = 30
+
+  env_vars = {
+    PGHOST     = local.pg_host
+    PGPORT     = "5432"
+    PGDATABASE = local.pg_database
+    PGUSER     = local.pg_username
+    PGPASSWORD = local.pg_password
+    PGSSLMODE  = "require"
+  }
+
+  source_dir = "${path.module}/code/table-reader"
+
+  depends_on = [sless_job.postgres_table_init_job]
+}
+
+resource "sless_trigger" "postgres_table_reader_http" {
+  name     = "pg-table-reader-http"
+  type     = "http"
+  function = sless_function.postgres_table_reader.name
+  enabled  = true
+}
+
+output "table_reader_url" {
+  value = sless_trigger.postgres_table_reader_http.url
+}
+
+
@@ -0,0 +1,51 @@
+# 2026-03-18 — debug pod для проверки psql-соединения из namespace функций.
+# Запускается разово. Подключается к тому же postgres, что и sless_function.
+# kubectl apply -f /tmp/pg-debug-pod.yaml
+# kubectl logs -n sless-fn-sless-ffd1f598c169b0ae pg-debug-pod
+
+apiVersion: v1
+kind: Pod
+metadata:
+  name: pg-debug-pod
+  namespace: sless-fn-sless-ffd1f598c169b0ae
+  labels:
+    purpose: debug-postgres-connectivity
+spec:
+  restartPolicy: Never
+  containers:
+  - name: psql
+    image: postgres:17-alpine
+    command:
+      - sh
+      - -c
+      - |
+        echo "=== Testing TCP connectivity to postgres ==="
+        nc -zv -w5 $PGHOST 5432 && echo "TCP OK" || echo "TCP FAILED"
+
+        echo ""
+        echo "=== Testing psql connection ==="
+        PGCONNECT_TIMEOUT=10 psql \
+          "host=$PGHOST port=$PGPORT dbname=$PGDATABASE user=$PGUSER sslmode=$PGSSLMODE" \
+          --command="SELECT current_user, current_database(), version();" \
+          2>&1
+
+        echo ""
+        echo "=== Listing tables ==="
+        PGCONNECT_TIMEOUT=10 psql \
+          "host=$PGHOST port=$PGPORT dbname=$PGDATABASE user=$PGUSER sslmode=$PGSSLMODE" \
+          --command="\dt" \
+          2>&1
+    env:
+    - name: PGHOST
+      value: "postgresqlk8s-master.36875359-dcea-48c4-a593-b4531f20fe96.svc.cluster.local"
+    - name: PGPORT
+      value: "5432"
+    - name: PGDATABASE
+      value: "db_terra"
+    - name: PGUSER
+      value: "u-user0"
+    - name: PGPASSWORD
+      # Актуальный пароль из vault_secrets (совпадает с tfvars.pg_password на 2026-03-18)
+      value: "M03O6fRsngWcVHB2YGivyLfbfxoii2R21nyh2A2r7WSZS5deLwBgLKkc9Wk24Zyl"
+    - name: PGSSLMODE
+      value: "require"
@@ -0,0 +1,40 @@
+# 2026-03-17 13:05
+# read_pg_user_secret.py — читает пароль пользователя managed PostgreSQL из k8s Secret.
+# Используется из Terraform external data source, чтобы apply сам получал актуальный пароль
+# даже для уже существующего пользователя, созданного вне текущего state.
+
+import base64
+import json
+import subprocess
+import sys
+
+
+def main():
+    # Читаем query от Terraform external provider из stdin.
+    query = json.load(sys.stdin)
+    namespace = query["namespace"]
+    secret_name = query["secret"]
+
+    # kubectl уже настроен на удалённой машине; читаем ровно поле data.password.
+    result = subprocess.run(
+        [
+            "kubectl",
+            "get",
+            "secret",
+            "-n",
+            namespace,
+            secret_name,
+            "-o",
+            "jsonpath={.data.password}",
+        ],
+        check=True,
+        capture_output=True,
+        text=True,
+    )
+
+    password = base64.b64decode(result.stdout.strip()).decode()
+    json.dump({"password": password}, sys.stdout)
+
+
+if __name__ == "__main__":
+    main()
@@ -12,7 +12,7 @@
 | `sless_trigger` | Публикует функцию: тип `http` создаёт публичный URL, тип `cron` — запуск по расписанию. |
 | `sless_job` | Запускает функцию однократно и ожидает завершения. Используется для одноразовых операций: инициализация БД, миграции, пакетная обработка. |

-Стандартная связка для HTTP API: `sless_function` + `sless_trigger` с `type = "http"` — в результате функция доступна по URL вида `https://sless-api.kube5s.ru/fn/<namespace>/<имя-функции>`.
+Стандартная связка для HTTP API: `sless_function` + `sless_trigger` с `type = "http"` — в результате функция доступна по URL вида `https://sless.kube5s.ru/fn/<namespace>/<имя-функции>`.

 ---

@@ -20,7 +20,7 @@

 - Terraform >= 1.0
 - JWT-токен для аутентификации в sless API
- Доступ к `https://sless-api.kube5s.ru`
+- Доступ к `https://sless.kube5s.ru`

 ## Конфигурация провайдера

@@ -28,9 +28,9 @@

 ```hcl
 provider "sless" {
-  endpoint       = "https://sless-api.kube5s.ru"
+  endpoint       = "https://sless.kube5s.ru"
  token          = var.token
-  nubes_endpoint = "https://deck-api.ngcloud.ru/api/v1"
+  nubes_endpoint = "https://deck-api-test.ngcloud.ru/api/v1"
 }
 ```

@@ -56,7 +56,7 @@ terraform init
 terraform apply -auto-approve

 # Вызов HTTP-функции с передачей имени:
-curl -s -X POST https://sless-api.kube5s.ru/fn/<namespace>/hello-http \
+curl -s -X POST https://sless.kube5s.ru/fn/<namespace>/hello-http \
  -H 'Content-Type: application/json' -d '{"name":"World"}'

 # Результат задания:
@@ -114,7 +114,7 @@ terraform init
 terraform apply -auto-approve

 terraform output job_result
-curl -s https://sless-api.kube5s.ru/fn/<namespace>/simple-py-time-display
+curl -s https://sless.kube5s.ru/fn/<namespace>/simple-py-time-display
 ```

 ---
@@ -127,7 +127,7 @@ terraform init
 terraform apply -auto-approve

 terraform output job_result
-curl -s https://sless-api.kube5s.ru/fn/<namespace>/simple-node-time-display
+curl -s https://sless.kube5s.ru/fn/<namespace>/simple-node-time-display
 ```

 ---
@@ -0,0 +1,45 @@
+# Изменено: 2026-03-14
+# Функция event-cleaner: удаляет N самых старых строк из таблицы events.
+# Вызывается через HTTP POST из Node-RED (который слушает RabbitMQ).
+# Env: POSTGRES_DSN — строка подключения к PostgreSQL.
+
+import os
+import json
+import psycopg2
+
+def handle(request):
+    """Удаляет N старейших строк из таблицы events."""
+    dsn = os.environ["POSTGRES_DSN"]
+    
+    body = {}
+    if request.get_data():
+        try:
+            body = json.loads(request.get_data())
+        except Exception:
+            pass
+    
+    # Количество строк для удаления — из тела запроса или дефолт 10
+    delete_n = int(body.get("delete_n", 10))
+    # Защита от случайного удаления слишком большого количества строк
+    delete_n = min(delete_n, 100)
+    
+    conn = psycopg2.connect(dsn)
+    try:
+        with conn.cursor() as cur:
+            cur.execute("""
+                DELETE FROM events
+                WHERE id IN (
+                    SELECT id FROM events ORDER BY created_at ASC LIMIT %s
+                )
+            """, (delete_n,))
+            deleted = cur.rowcount
+            cur.execute("SELECT COUNT(*) FROM events")
+            remaining = cur.fetchone()[0]
+            conn.commit()
+        return json.dumps({
+            "ok": True,
+            "deleted": deleted,
+            "remaining": remaining
+        }), 200, {"Content-Type": "application/json"}
+    finally:
+        conn.close()
@@ -0,0 +1,47 @@
+# Изменено: 2026-03-14
+# Функция event-monitor: считает строки в events.
+# Если больше 50 — публикует сообщение в RabbitMQ queue "cleanup-needed".
+# Запускается по cron (каждую минуту).
+# Env:
+#   POSTGRES_DSN   — строка подключения к PostgreSQL
+#   RABBITMQ_URL   — amqp://sless:sless123@rabbitmq.sless.svc.cluster.local:5672/
+
+import os
+import json
+import psycopg2
+import pika
+
+THRESHOLD = 50
+
+def handle(request):
+    """Мониторит таблицу events. При переполнении шлёт в RabbitMQ."""
+    dsn = os.environ["POSTGRES_DSN"]
+    rabbit_url = os.environ["RABBITMQ_URL"]
+    
+    conn = psycopg2.connect(dsn)
+    try:
+        with conn.cursor() as cur:
+            # Считаем количество событий
+            cur.execute("SELECT COUNT(*) FROM events")
+            count = cur.fetchone()[0]
+    finally:
+        conn.close()
+    
+    result = {"count": count, "threshold": THRESHOLD, "action": "none"}
+    
+    if count > THRESHOLD:
+        # Публикуем в очередь — event-cleaner получит и удалит старые строки
+        params = pika.URLParameters(rabbit_url)
+        connection = pika.BlockingConnection(params)
+        channel = connection.channel()
+        channel.queue_declare(queue="cleanup-needed", durable=True)
+        channel.basic_publish(
+            exchange="",
+            routing_key="cleanup-needed",
+            body=json.dumps({"count": count, "delete_n": 10}),
+            properties=pika.BasicProperties(delivery_mode=2)  # persistent
+        )
+        connection.close()
+        result["action"] = "cleanup_requested"
+    
+    return json.dumps(result), 200, {"Content-Type": "application/json"}
@@ -0,0 +1,49 @@
+# Изменено: 2026-03-14
+# Функция event-writer: принимает HTTP POST, пишет одну строку в таблицу events.
+# Таблица создаётся автоматически при первом запуске.
+# Env: POSTGRES_DSN — строка подключения к PostgreSQL.
+
+import os
+import json
+import psycopg2
+from datetime import datetime, timezone
+
+def handle(request):
+    """Записывает одно событие в таблицу events."""
+    dsn = os.environ["POSTGRES_DSN"]
+    
+    body = {}
+    if request.get_data():
+        try:
+            body = json.loads(request.get_data())
+        except Exception:
+            pass
+    
+    source = body.get("source", "node-red")
+    message = body.get("message", "ping")
+    
+    conn = psycopg2.connect(dsn)
+    try:
+        with conn.cursor() as cur:
+            # Создаём таблицу если нет — безопасно вызывать при каждом запросе
+            cur.execute("""
+                CREATE TABLE IF NOT EXISTS events (
+                    id         SERIAL PRIMARY KEY,
+                    source     VARCHAR(100) NOT NULL DEFAULT 'unknown',
+                    message    TEXT NOT NULL DEFAULT '',
+                    created_at TIMESTAMPTZ NOT NULL DEFAULT NOW()
+                )
+            """)
+            cur.execute(
+                "INSERT INTO events (source, message) VALUES (%s, %s) RETURNING id, created_at",
+                (source, message)
+            )
+            row = cur.fetchone()
+            conn.commit()
+        return json.dumps({
+            "ok": True,
+            "id": row[0],
+            "created_at": row[1].isoformat()
+        }), 200, {"Content-Type": "application/json"}
+    finally:
+        conn.close()
@@ -0,0 +1,194 @@
+# Примеры использования sless
+
+## Обзор платформы
+
+**sless** — система управления serverless-функциями на базе Kubernetes. Разработчик загружает код функции, платформа собирает из него Docker-образ, разворачивает его в кластере и предоставляет HTTP-эндпоинт для вызова. Всё описывается декларативно через Terraform.
+
+### Основные ресурсы провайдера
+
+| Ресурс | Назначение |
+|---|---|
+| `sless_function` | Описывает функцию: язык, точку входа, лимиты, переменные окружения. При создании загружает код и запускает его сборку в образ. Сама по себе недоступна снаружи — нужен триггер или задание. |
+| `sless_trigger` | Публикует функцию: тип `http` создаёт публичный URL, тип `cron` — запуск по расписанию. |
+| `sless_job` | Запускает функцию однократно и ожидает завершения. Используется для одноразовых операций: инициализация БД, миграции, пакетная обработка. |
+
+Стандартная связка для HTTP API: `sless_function` + `sless_trigger` с `type = "http"` — в результате функция доступна по URL вида `https://sless.kube5s.ru/fn/<namespace>/<имя-функции>`.
+
+---
+
+## Требования
+
+- Terraform >= 1.0
+- JWT-токен для аутентификации в sless API
+- Доступ к `https://sless.kube5s.ru`
+
+## Конфигурация провайдера
+
+Во всех примерах файл `main.tf` содержит блок провайдера. Токен передаётся через переменную, значение которой задаётся в `terraform.tfvars`:
+
+```hcl
+provider "sless" {
+  endpoint       = "https://sless.kube5s.ru"
+  token          = var.token
+  nubes_endpoint = "https://deck-api-test.ngcloud.ru/api/v1"
+}
+```
+
+Namespace функций вычисляется автоматически из JWT-токена: `sless-{sha256[:8]}`.
+
+> **Перед запуском любого примера** откройте файл `terraform.tfvars` в директории примера и впишите свой токен Nubes API:
+> ```hcl
+> token = "ваш токен Nubes API"
+> ```
+> Токен выдаётся в личном кабинете Nubes. Файл `terraform.tfvars` добавлен в `.gitignore` — он не попадёт в репозиторий.
+
+---
+
+## Примеры
+
+### `hello-node` — минимальный пример на Node.js
+
+Две независимые функции: HTTP-функция, возвращающая приветствие, и одноразовое задание, суммирующее набор чисел. Хорошая отправная точка для знакомства с платформой.
+
+```bash
+cd hello-node
+terraform init
+terraform apply -auto-approve
+
+# Вызов HTTP-функции с передачей имени:
+curl -s -X POST https://sless.kube5s.ru/fn/<namespace>/hello-http \
+  -H 'Content-Type: application/json' -d '{"name":"World"}'
+
+# Результат задания:
+terraform output job_message
+```
+
+---
+
+### `hello-go` — минимальный пример на Go 1.23
+
+Аналог `hello-node`, но на Go. Демонстрирует поддержку Go-рантайма: HTTP-функция и одноразовое задание. Код пользователя оформляется как пакет `handler` с функцией `Handle(event)`.
+
+```bash
+cd hello-go
+terraform init
+terraform apply -auto-approve
+
+terraform output job_message
+terraform output trigger_url
+```
+
+---
+
+### `pg-list-python` — выборка данных из PostgreSQL (Python)
+
+Минимальный пример работы с базой данных: одна HTTP-функция читает список записей из таблицы PostgreSQL и возвращает их в JSON. Таблица с тестовыми данными создаётся автоматически при первом вызове. Нет заданий, нет инициализации — только функция и триггер.
+
+**Переменные:**
+
+| Переменная | Описание | Значение по умолчанию |
+|---|---|---|
+| `pg_dsn` | Строка подключения к PostgreSQL | `postgres://sless:sless-pg-password@postgres.sless.svc.cluster.local:5432/sless?sslmode=disable` |
+
+```bash
+cd pg-list-python
+terraform init
+terraform apply -auto-approve
+
+# URL функции выводится после применения:
+terraform output catalog_url
+
+# Запрос к функции:
+curl -s $(terraform output -raw catalog_url)
+```
+
+---
+
+### `simple-python` — одноразовое задание передаёт данные в HTTP-функцию (Python)
+
+При `apply` выполняется задание, которое фиксирует текущее время. Результат передаётся в HTTP-функцию через переменные окружения и отображается при каждом запросе.
+
+```bash
+cd simple-python
+terraform init
+terraform apply -auto-approve
+
+terraform output job_result
+curl -s https://sless.kube5s.ru/fn/<namespace>/simple-py-time-display
+```
+
+---
+
+### `simple-node` — то же самое на Node.js 20
+
+```bash
+cd simple-node
+terraform init
+terraform apply -auto-approve
+
+terraform output job_result
+curl -s https://sless.kube5s.ru/fn/<namespace>/simple-node-time-display
+```
+
+---
+
+### `notes-python` — CRUD API на Python с PostgreSQL
+
+Полноценное приложение: инициализация схемы базы данных через задания, CRUD-функция для работы с записями, отдельная функция для получения списка.
+
+**Переменные:**
+
+| Переменная | Описание | Значение по умолчанию |
+|---|---|---|
+| `pg_dsn` | Строка подключения к PostgreSQL | `postgres://sless:sless-pg-password@postgres.sless.svc.cluster.local:5432/sless?sslmode=disable` |
+
+```bash
+cd notes-python
+terraform init
+terraform apply -auto-approve
+
+# Статус инициализации базы данных:
+terraform output db_init_table_status
+terraform output db_init_index_status
+
+# Создать запись:
+curl -s -X POST "$(terraform output -raw notes_url)/add?title=Hello&body=World"
+
+# Получить список записей:
+curl -s $(terraform output -raw notes_list_url)
+
+# Обновить запись (id из предыдущего ответа):
+curl -s -X POST "$(terraform output -raw notes_url)/update?id=1&title=Updated&body=New+body"
+
+# Удалить запись:
+curl -s -X POST "$(terraform output -raw notes_url)/delete?id=1"
+```
+
+---
+
+## Полезные команды
+
+```bash
+# Посмотреть текущее состояние задеплоенных ресурсов:
+terraform show
+
+# Принудительно пересобрать функцию (например, после изменения кода):
+terraform apply -replace=sless_function.<имя> -auto-approve
+
+# Повторно запустить задание: увеличить значение run_id в .tf-файле, затем:
+terraform apply -auto-approve
+
+# Удалить все ресурсы примера:
+terraform destroy -auto-approve
+```
+
+## Структура примера
+
+```
+<пример>/
+├── main.tf         — конфигурация провайдера
+├── *.tf            — ресурсы: функции, триггеры, задания
+├── variables.tf    — входные переменные
+├── terraform.tfvars — значения переменных (не коммитится в git)
+└── code/           — исходный код функций
+```
@@ -0,0 +1,26 @@
+# Изменено: 2026-03-14
+# event-cleaner: HTTP функция для демонстрации контролируемого изменения логики.
+# Работает без внешних пакетов.
+
+import json
+from datetime import datetime, timezone
+
+
+def event_cleaner_handle(event_cleaner_event):
+    """Принимает delete_n и возвращает подтверждение обработки."""
+
+    event_cleaner_payload = event_cleaner_event if isinstance(event_cleaner_event, dict) else {}
+
+    event_cleaner_delete_n = int(event_cleaner_payload.get("delete_n", 10))
+    event_cleaner_delete_n = max(1, min(event_cleaner_delete_n, 100))
+
+    event_cleaner_generated_at = datetime.now(timezone.utc).isoformat()
+    # Здесь intentionally имитируем очистку, чтобы показать реакцию на входные параметры.
+    return json.dumps(
+        {
+            "ok": True,
+            "accepted_delete_n": event_cleaner_delete_n,
+            "status": "simulated-cleanup",
+            "generated_at": event_cleaner_generated_at,
+        }
+    ), 200, {"Content-Type": "application/json"}
@@ -0,0 +1,25 @@
+# Изменено: 2026-03-14
+# event-monitor: cron-функция для демонстрации расписания и управления кодом.
+# Работает без внешних библиотек и возвращает диагностический JSON.
+
+import json
+import os
+from datetime import datetime, timezone
+
+
+EVENT_MONITOR_THRESHOLD = 50
+
+
+def event_monitor_handle(event_monitor_event):
+    """Отдаёт heartbeat для cron-запуска и видимой проверки после apply."""
+    event_monitor_rabbitmq_url = os.environ.get("RABBITMQ_URL", "not-set")
+    event_monitor_generated_at = datetime.now(timezone.utc).isoformat()
+    return json.dumps(
+        {
+            "ok": True,
+            "monitor": "alive",
+            "threshold": EVENT_MONITOR_THRESHOLD,
+            "rabbitmq_configured": event_monitor_rabbitmq_url != "not-set",
+            "generated_at": event_monitor_generated_at,
+        }
+    ), 200, {"Content-Type": "application/json"}
@@ -0,0 +1,28 @@
+# Изменено: 2026-03-14
+# event-writer: простая HTTP функция без внешних зависимостей.
+# Правка поля response_tag в коде сразу видна в ответе после terraform apply.
+
+import json
+import os
+from datetime import datetime, timezone
+
+
+def event_writer_handle(event_writer_event):
+    """Возвращает полезный JSON-ответ для визуальной проверки выката кода."""
+    writer_default_message = os.environ.get("DEFAULT_MESSAGE", "writer-default")
+
+    writer_payload = event_writer_event if isinstance(event_writer_event, dict) else {}
+
+    writer_message_value = writer_payload.get("message", writer_default_message)
+    writer_source_name = writer_payload.get("source", "event-writer")
+    writer_generated_at = datetime.now(timezone.utc).isoformat()
+
+    # response_tag удобно менять для демонстрации hot-update кода через terraform apply.
+    writer_response_tag = "writer-v2"
+    return {
+        "ok": True,
+        "source": writer_source_name,
+        "message": writer_message_value,
+        "response_tag": writer_response_tag,
+        "generated_at": writer_generated_at,
+    }
@@ -0,0 +1,77 @@
+# 2026-03-14
+# function.tf — ресурсы managed serverless функций для демонстрации.
+# Пользователь правит код в code/* и запускает terraform apply — провайдер сам пересобирает и выкатывает функции.
+
+resource "sless_function" "event_writer" {
+  name        = "event-writer"
+  runtime     = "python3.11"
+  entrypoint  = "event_writer_handler.event_writer_handle"
+  memory_mb   = 128
+  timeout_sec = 20
+
+  source_dir = "${path.module}/code/event-writer"
+
+  env_vars = {
+    POSTGRES_DSN    = var.pg_dsn
+    DEFAULT_MESSAGE = var.writer_message
+  }
+}
+
+resource "sless_trigger" "event_writer_http" {
+  name     = "event-writer-http"
+  type     = "http"
+  function = sless_function.event_writer.name
+  enabled  = true
+}
+
+resource "sless_function" "event_monitor" {
+  name        = "event-monitor"
+  runtime     = "python3.11"
+  entrypoint  = "event_monitor_handler.event_monitor_handle"
+  memory_mb   = 128
+  timeout_sec = 20
+
+  source_dir = "${path.module}/code/event-monitor"
+
+  env_vars = {
+    POSTGRES_DSN = var.pg_dsn
+    RABBITMQ_URL = var.rabbitmq_url
+  }
+}
+
+resource "sless_trigger" "event_monitor_cron" {
+  name      = "event-monitor-cron"
+  type      = "cron"
+  function  = sless_function.event_monitor.name
+  enabled   = true
+  schedule  = "*/1 * * * *"
+}
+
+resource "sless_function" "event_cleaner" {
+  name        = "event-cleaner"
+  runtime     = "python3.11"
+  entrypoint  = "event_cleaner_handler.event_cleaner_handle"
+  memory_mb   = 128
+  timeout_sec = 20
+
+  source_dir = "${path.module}/code/event-cleaner"
+
+  env_vars = {
+    POSTGRES_DSN = var.pg_dsn
+  }
+}
+
+resource "sless_trigger" "event_cleaner_http" {
+  name     = "event-cleaner-http"
+  type     = "http"
+  function = sless_function.event_cleaner.name
+  enabled  = true
+}
+
+output "event_writer_url" {
+  value = sless_trigger.event_writer_http.url
+}
+
+output "event_cleaner_url" {
+  value = sless_trigger.event_cleaner_http.url
+}
@@ -0,0 +1,18 @@
+# 2026-03-14
+# Terraform demo: managed serverless functions.
+# Здесь управляем ТОЛЬКО функциями/триггерами, внешние сервисы считаем уже поднятыми.
+
+terraform {
+  required_providers {
+    sless = {
+      source  = "terra.k8c.ru/naeel/sless"
+      version = "~> 0.1.18"
+    }
+  }
+}
+
+provider "sless" {
+  endpoint       = var.sless_endpoint
+  token          = var.token
+  nubes_endpoint = var.nubes_endpoint
+}
@@ -0,0 +1,11 @@
+# 2026-03-14
+# Скопируй в terraform.tfvars и подставь актуальный токен.
+
+token          = "PUT_TOKEN_HERE"
+sless_endpoint = "https://sless-api.kube5s.ru"
+nubes_endpoint = "https://deck-api-test.ngcloud.ru/api/v1"
+
+pg_dsn       = "postgres://sless:sless-pg-password@postgres.sless.svc.cluster.local:5432/sless?sslmode=disable"
+rabbitmq_url = "amqp://sless:sless123@rabbitmq.sless.svc.cluster.local:5672/"
+
+writer_message = "writer-default-v1"
@@ -0,0 +1,38 @@
+# 2026-03-14
+# Переменные для demo-managed-functions.
+
+variable "token" {
+  description = "JWT токен API"
+  type        = string
+  sensitive   = true
+}
+
+variable "sless_endpoint" {
+  description = "Endpoint sless API"
+  type        = string
+  default     = "https://sless.kube5s.ru"
+}
+
+variable "nubes_endpoint" {
+  description = "Nubes endpoint (нужен провайдеру)"
+  type        = string
+  default     = "https://deck-api-test.ngcloud.ru/api/v1"
+}
+
+variable "pg_dsn" {
+  description = "PostgreSQL DSN для функций"
+  type        = string
+  default     = "postgres://sless:sless-pg-password@postgres.sless.svc.cluster.local:5432/sless?sslmode=disable"
+}
+
+variable "rabbitmq_url" {
+  description = "RabbitMQ URL для функций"
+  type        = string
+  default     = "amqp://sless:sless123@rabbitmq.sless.svc.cluster.local:5672/"
+}
+
+variable "writer_message" {
+  description = "Сообщение по умолчанию, которое пишет event-writer"
+  type        = string
+  default     = "writer-default-v1"
+}
@@ -5,13 +5,13 @@ terraform {
  required_providers {
    sless = {
      source  = "terra.k8c.ru/naeel/sless"
-      version = "~> 0.1.16"
+      version = "~> 0.1.18"
    }
  }
 }

 provider "sless" {
-  endpoint       = "https://sless-api.kube5s.ru"
+  endpoint       = "https://sless.kube5s.ru"
  token          = var.token
-  nubes_endpoint = "https://deck-api.ngcloud.ru/api/v1"
+  nubes_endpoint = "https://deck-api-test.ngcloud.ru/api/v1"
 }
@@ -11,14 +11,14 @@ terraform {
  required_providers {
    sless = {
      source  = "terra.k8c.ru/naeel/sless"
-      version = "~> 0.1.16"
+      version = "~> 0.1.18"
    }
  }
 }

 provider "sless" {
-  endpoint       = "https://sless-api.kube5s.ru"
+  endpoint       = "https://sless.kube5s.ru"
  token          = var.token
-  nubes_endpoint = "https://deck-api.ngcloud.ru/api/v1"
+  nubes_endpoint = "https://deck-api-test.ngcloud.ru/api/v1"
 }

@@ -14,14 +14,14 @@ terraform {
    # Провайдер для управления serverless функциями через sless API
    sless = {
      source  = "terra.k8c.ru/naeel/sless"
-      version = "~> 0.1.16"
+      version = "~> 0.1.18"
    }
  }
 }

 # sless провайдер подключается к API кластера.
 provider "sless" {
-  endpoint       = "https://sless-api.kube5s.ru"
+  endpoint       = "https://sless.kube5s.ru"
  token          = var.token
-  nubes_endpoint = "https://deck-api.ngcloud.ru/api/v1"
+  nubes_endpoint = "https://deck-api-test.ngcloud.ru/api/v1"
 }
@@ -5,13 +5,13 @@ terraform {
  required_providers {
    sless = {
      source  = "terra.k8c.ru/naeel/sless"
-      version = "~> 0.1.16"
+      version = "~> 0.1.18"
    }
  }
 }

 provider "sless" {
-  endpoint       = "https://sless-api.kube5s.ru"
+  endpoint       = "https://sless.kube5s.ru"
  token          = var.token
-  nubes_endpoint = "https://deck-api.ngcloud.ru/api/v1"
+  nubes_endpoint = "https://deck-api-test.ngcloud.ru/api/v1"
 }
@@ -19,13 +19,13 @@ terraform {
  required_providers {
    sless = {
      source  = "terra.k8c.ru/naeel/sless"
-      version = "~> 0.1.16"
+      version = "~> 0.1.18"
    }
  }
 }

 provider "sless" {
-  endpoint       = "https://sless-api.kube5s.ru"
+  endpoint       = "https://sless.kube5s.ru"
  token          = var.token
-  nubes_endpoint = "https://deck-api.ngcloud.ru/api/v1"
+  nubes_endpoint = "https://deck-api-test.ngcloud.ru/api/v1"
 }
@@ -18,13 +18,13 @@ terraform {
  required_providers {
    sless = {
      source  = "terra.k8c.ru/naeel/sless"
-      version = "~> 0.1.16"
+      version = "~> 0.1.18"
    }
  }
 }

 provider "sless" {
-  endpoint       = "https://sless-api.kube5s.ru"
+  endpoint       = "https://sless.kube5s.ru"
  token          = var.token
-  nubes_endpoint = "https://deck-api.ngcloud.ru/api/v1"
+  nubes_endpoint = "https://deck-api-test.ngcloud.ru/api/v1"
 }
@@ -1,4 +1,4 @@
-// Изменено: 2026-03-11
+// Изменено: 2026-03-18 (добавлены created_at, last_built_at в functionResponse и fnToResponse)
 // functions.go — CRUD handlers для Function CRD.
 // Принимает JSON, создаёт/обновляет/удаляет k8s ресурсы Function.
 // Namespace берётся из URL: /v1/namespaces/{namespace}/functions/{name}
@@ -30,23 +30,29 @@ type functionRequest struct {

 // functionResponse — ответ при чтении функции.
 type functionResponse struct {
-	Name       string                      `json:"name"`
-	Namespace  string                      `json:"namespace"`
-	Runtime    string                      `json:"runtime"`
-	Entrypoint string                      `json:"entrypoint"`
-	MemoryMB   int32                       `json:"memory_mb"`
-	TimeoutSec int32                       `json:"timeout_sec"`
-	Env        map[string]string           `json:"env_vars"`
-	S3Bucket   string                      `json:"s3_bucket"`
-	S3Key      string                      `json:"s3_key"`
-	Phase      slessv1alpha1.FunctionPhase `json:"phase"`
-	ImageRef   string                      `json:"image_ref"`
-	Message    string                      `json:"message,omitempty"`
+	Name        string                      `json:"name"`
+	Namespace   string                      `json:"namespace"`
+	Runtime     string                      `json:"runtime"`
+	Entrypoint  string                      `json:"entrypoint"`
+	MemoryMB    int32                       `json:"memory_mb"`
+	TimeoutSec  int32                       `json:"timeout_sec"`
+	Env         map[string]string           `json:"env_vars"`
+	S3Bucket    string                      `json:"s3_bucket"`
+	S3Key       string                      `json:"s3_key"`
+	Phase       slessv1alpha1.FunctionPhase `json:"phase"`
+	ImageRef    string                      `json:"image_ref"`
+	Message     string                      `json:"message,omitempty"`
+	// CreatedAt — время создания CRD объекта (metadata.creationTimestamp).
+	// Пустое значение = "0001-01-01T00:00:00Z" сериализуется в "", опускаем через omitempty.
+	CreatedAt   string                      `json:"created_at,omitempty"`
+	// LastBuiltAt — время последней успешной сборки образа (status.lastBuiltAt).
+	// nil если сборки ещё не было.
+	LastBuiltAt string                      `json:"last_built_at,omitempty"`
 }

 // fnToResponse конвертирует CRD в ответ API.
 func fnToResponse(fn *slessv1alpha1.Function) functionResponse {
-	return functionResponse{
+	resp := functionResponse{
 		Name:       fn.Name,
 		Namespace:  fn.Namespace,
 		Runtime:    fn.Spec.Runtime,
@@ -60,6 +66,14 @@ func fnToResponse(fn *slessv1alpha1.Function) functionResponse {
 		ImageRef:   fn.Status.ImageRef,
 		Message:    fn.Status.Message,
 	}
+	// creationTimestamp — всегда заполнен k8s, но zero value опускаем.
+	if !fn.CreationTimestamp.IsZero() {
+		resp.CreatedAt = fn.CreationTimestamp.UTC().Format("2006-01-02 15:04:05 UTC")
+	}
+	if fn.Status.LastBuiltAt != nil && !fn.Status.LastBuiltAt.IsZero() {
+		resp.LastBuiltAt = fn.Status.LastBuiltAt.UTC().Format("2006-01-02 15:04:05 UTC")
+	}
+	return resp
 }

 // ListFunctions — GET /v1/namespaces/{namespace}/functions
@@ -115,13 +129,20 @@ func (h *Handler) CreateFunction(w http.ResponseWriter, r *http.Request) {
 	}
 	if err := h.K8s.Create(r.Context(), fn); err != nil {
 		if errors.IsAlreadyExists(err) {
-			// Если существующая функция в статусе Failed (build провалился, terraform не
-			// добавил её в state) — удаляем её и пересоздаём, иначе клиент получит 409 навсегда.
+			// IsAlreadyExists может прийти из кеша controller-runtime (split-brain):
+			// объект удалён из etcd, но кеш informer ещё южив. Делаем uncached Get:
+			// если реально NotFound — кеш устарел, пересоздаём.
+			// если существует и фаза Failed — тоже пересоздаём (build провалился, терраформ не добавил в state).
+			// если существует и фаза Ready/Building — возвращаем 409 (функция реально есть).
 			existing := &slessv1alpha1.Function{}
-			if getErr := h.K8s.Get(r.Context(), client.ObjectKey{Name: req.Name, Namespace: ns}, existing); getErr == nil &&
-				existing.Status.Phase == slessv1alpha1.FunctionPhaseFailed {
-				_ = h.K8s.Delete(r.Context(), existing)
-				// Создаём заново с теми же параметрами
+			getErr := h.K8s.Get(r.Context(), client.ObjectKey{Name: req.Name, Namespace: ns}, existing)
+			shouldRecreate := errors.IsNotFound(getErr) ||
+				(getErr == nil && existing.Status.Phase == slessv1alpha1.FunctionPhaseFailed)
+			if shouldRecreate {
+				if getErr == nil {
+					_ = h.K8s.Delete(r.Context(), existing)
+				}
+				// Сбрасываем ResourceVersion — при split-brain etcd считает объект новым
 				fn.ResourceVersion = ""
 				if createErr := h.K8s.Create(r.Context(), fn); createErr != nil {
 					writeJSON(w, http.StatusInternalServerError, errResp(createErr.Error()))
@@ -121,8 +121,10 @@ func main() {
 	// Builder использует k8s client из manager'а
 	// harborClient — nil если HARBOR_USER/HARBOR_PASS не заданы (EnsureProject пропускается).
 	var harborClient *harbor.Client
+	var harborProjecter builder.Projecter
 	if cfg.HarborUser != "" && cfg.HarborPass != "" {
 		harborClient = harbor.New(cfg.RegistryHost, cfg.HarborUser, cfg.HarborPass)
+		harborProjecter = harborClient
 		log.Info("harbor client configured", "host", cfg.RegistryHost)
 	} else {
 		log.Info("harbor client disabled (HARBOR_USER/HARBOR_PASS not set)")
@@ -137,7 +139,7 @@ func main() {
 		S3SecretKey:    cfg.S3SecretKey,
 		S3Bucket:       cfg.S3Bucket,
 		Namespace:      "sless",
-		HarborClient:   harborClient,
+		HarborClient:   harborProjecter,
 	})

 	if err = (&controllers.FunctionReconciler{
@@ -0,0 +1,15 @@
+# 2026-03-18
+# Dockerfile для sless-funcs-service.
+# Многоэтапная сборка: Go → alpine (минимальный образ).
+# Сервис не нуждается во внешних зависимостях — только stdlib.
+
+FROM golang:1.23-alpine AS builder
+WORKDIR /build
+COPY go.mod main.go ./
+RUN CGO_ENABLED=0 GOOS=linux go build -trimpath -ldflags="-s -w" -o funcs-service .
+
+FROM alpine:3.20
+RUN apk add --no-cache ca-certificates
+COPY --from=builder /build/funcs-service /funcs-service
+EXPOSE 8090
+ENTRYPOINT ["/funcs-service"]
@@ -0,0 +1,3 @@
+module sless/funcs-service
+
+go 1.23
@@ -0,0 +1,300 @@
+// 2026-03-18
+// main.go — глобальный HTTP сервис листинга функций пользователя.
+// Развёрнут ОДИН РАЗ в namespace sless; работает для ВСЕХ пользователей.
+// Не связан с terraform — деплоится манифестом deployments/k8s/funcs-service.yaml.
+//
+// Логика:
+//   1. Принимает Authorization: Bearer {jwt} от пользователя
+//   2. Извлекает sub из JWT (без проверки подписи — trusted perimeter за Ingress)
+//   3. Вычисляет namespace = SHA256(sub)[:8] hex (та же логика что в операторе)
+//   4. Вызывает внутренний API оператора: GET /v1/namespaces/{ns}/functions + /triggers
+//   5. Возвращает plain text — человекочитаемый список
+//
+// Env vars:
+//   SLESS_OPERATOR_URL  — URL оператора внутри кластера (default: http://sless-operator.sless.svc.cluster.local:9090)
+//   SLESS_EXTERNAL_URL  — публичный базовый URL для корректных ссылок на функции
+//   SLESS_EXCLUDE       — comma-separated список имён функций, скрытых из листинга
+//   PORT                — порт сервера (default: 8090)
+
+package main
+
+import (
+	"crypto/sha256"
+	"encoding/base64"
+	"encoding/json"
+	"fmt"
+	"io"
+	"log"
+	"net/http"
+	"os"
+	"sort"
+	"strings"
+)
+
+// fnResponse — ответ /v1/namespaces/{ns}/functions (подмножество полей оператора)
+type fnResponse struct {
+	Name        string `json:"name"`
+	Runtime     string `json:"runtime"`
+	Phase       string `json:"phase"`
+	Message     string `json:"message"`
+	CreatedAt   string `json:"created_at"`
+	LastBuiltAt string `json:"last_built_at"`
+}
+
+// trResponse — ответ /v1/namespaces/{ns}/triggers
+type trResponse struct {
+	Name        string `json:"name"`
+	Type        string `json:"type"`
+	FunctionRef string `json:"function"`
+	Schedule    string `json:"schedule"`
+	Enabled     bool   `json:"enabled"`
+	Active      bool   `json:"active"`
+	URL         string `json:"url"`
+}
+
+func main() {
+	operatorURL := strings.TrimRight(env("SLESS_OPERATOR_URL", "http://sless-operator.sless.svc.cluster.local:9090"), "/")
+	externalURL := strings.TrimRight(env("SLESS_EXTERNAL_URL", ""), "/")
+	port := env("PORT", "8090")
+	// serviceToken — токен сервиса для запросов к оператору по /funcs/<namespace> (без токена пользователя)
+	serviceToken := os.Getenv("SLESS_SERVICE_TOKEN")
+
+	exclude := map[string]bool{}
+	for _, n := range strings.Split(os.Getenv("SLESS_EXCLUDE"), ",") {
+		if n = strings.TrimSpace(n); n != "" {
+			exclude[n] = true
+		}
+	}
+
+	http.HandleFunc("/funcs", handler(operatorURL, externalURL, serviceToken, exclude))
+	// /health — для liveness/readiness probe без Bearer токена
+	http.HandleFunc("/health", func(w http.ResponseWriter, r *http.Request) {
+		w.Header().Set("Content-Type", "text/plain; charset=utf-8")
+		fmt.Fprintln(w, "ok")
+	})
+	// /funcs/<namespace> — без токена, namespace виден в URL всех функций
+	http.HandleFunc("/funcs/", handler(operatorURL, externalURL, serviceToken, exclude))
+
+	log.Printf("sless-funcs-service listening on :%s (operator: %s)", port, operatorURL)
+	log.Fatal(http.ListenAndServe(":"+port, nil))
+}
+
+func handler(operatorURL, externalURL, serviceToken string, exclude map[string]bool) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var namespace, authHeader string
+
+		// Вариант 1: /funcs/<namespace> — namespace прямо в URL, токен не нужен.
+		// Namespace виден в URL каждой функции — не является секретом.
+		if strings.HasPrefix(r.URL.Path, "/funcs/") {
+			namespace = strings.TrimPrefix(r.URL.Path, "/funcs/")
+			namespace = strings.Trim(namespace, "/")
+			if namespace == "" {
+				http.Error(w, "usage: /funcs/<namespace>\n", http.StatusBadRequest)
+				return
+			}
+			// Используем serviceToken сервиса, если задан
+			if serviceToken != "" {
+				authHeader = "Bearer " + serviceToken
+			}
+			// authHeader может остаться пустым — оператор ответит 401 если не настроен
+		} else {
+			// Вариант 2: ?token=<jwt> — токен как query param (можно bookmarkнуть URL)
+			token := r.URL.Query().Get("token")
+			// Вариант 3: Authorization: Bearer <jwt> — стандартный заголовок
+			if token == "" {
+				token = strings.TrimPrefix(r.Header.Get("Authorization"), "Bearer ")
+			}
+			if token == "" {
+				w.Header().Set("Content-Type", "text/plain; charset=utf-8")
+				w.WriteHeader(http.StatusUnauthorized)
+				fmt.Fprintf(w, "Укажите namespace в URL или передайте токен:\n\n")
+				fmt.Fprintf(w, "  %s/funcs/<namespace>\n", externalURL)
+				fmt.Fprintf(w, "  %s/funcs?token=<jwt>\n", externalURL)
+				return
+			}
+			sub, err := subFromJWT(token)
+			if err != nil {
+				http.Error(w, fmt.Sprintf("invalid token: %s\n", err), http.StatusUnauthorized)
+				return
+			}
+			namespace = namespaceFromSub(sub)
+			authHeader = "Bearer " + token
+		}
+
+		fns, err := apiGet[[]fnResponse](operatorURL+"/v1/namespaces/"+namespace+"/functions", authHeader)
+		if err != nil {
+			http.Error(w, fmt.Sprintf("operator error (functions): %s\n", err), http.StatusBadGateway)
+			return
+		}
+		trs, err := apiGet[[]trResponse](operatorURL+"/v1/namespaces/"+namespace+"/triggers", authHeader)
+		if err != nil {
+			http.Error(w, fmt.Sprintf("operator error (triggers): %s\n", err), http.StatusBadGateway)
+			return
+		}
+
+		// Индекс триггеров по имени функции
+		trigIdx := map[string][]trResponse{}
+		for _, tr := range trs {
+			trigIdx[tr.FunctionRef] = append(trigIdx[tr.FunctionRef], tr)
+		}
+
+		// Фильтрация и сортировка: активные вверх, потом по имени
+		type entry struct {
+			fn       fnResponse
+			httpT    []trResponse
+			cronT    []trResponse
+			isActive bool
+		}
+		var items []entry
+		for _, fn := range fns {
+			if exclude[fn.Name] {
+				continue
+			}
+			var httpT, cronT []trResponse
+			isActive := false
+			for _, tr := range trigIdx[fn.Name] {
+				switch tr.Type {
+				case "http":
+					httpT = append(httpT, tr)
+				case "cron":
+					cronT = append(cronT, tr)
+				}
+				if tr.Enabled && tr.Active {
+					isActive = true
+				}
+			}
+			items = append(items, entry{fn, httpT, cronT, isActive})
+		}
+		sort.Slice(items, func(i, j int) bool {
+			if items[i].isActive != items[j].isActive {
+				return items[i].isActive
+			}
+			return items[i].fn.Name < items[j].fn.Name
+		})
+
+		sep := strings.Repeat("─", 52)
+		var sb strings.Builder
+		for _, it := range items {
+			fn := it.fn
+			sb.WriteString(sep + "\n")
+			sb.WriteString("  " + buildComment(fn, it.httpT, it.cronT) + "\n")
+			sb.WriteString(fmt.Sprintf("  name:      %s\n", fn.Name))
+			sb.WriteString(fmt.Sprintf("  runtime:   %s\n", fn.Runtime))
+			sb.WriteString(fmt.Sprintf("  phase:     %s\n", fn.Phase))
+			if it.isActive {
+				sb.WriteString("  active:    да\n")
+			} else {
+				sb.WriteString("  active:    нет\n")
+			}
+			if len(it.httpT) > 0 {
+				url := it.httpT[0].URL
+				if externalURL != "" {
+					url = externalURL + "/fn/" + namespace + "/" + fn.Name
+				}
+				sb.WriteString(fmt.Sprintf("  url:       %s\n", url))
+			}
+			if len(it.cronT) > 0 {
+				sb.WriteString(fmt.Sprintf("  cron:      %s\n", it.cronT[0].Schedule))
+			}
+			if fn.CreatedAt != "" {
+				sb.WriteString(fmt.Sprintf("  created:   %s\n", fn.CreatedAt))
+			}
+			if fn.LastBuiltAt != "" {
+				sb.WriteString(fmt.Sprintf("  built:     %s\n", fn.LastBuiltAt))
+			}
+			if fn.Message != "" {
+				sb.WriteString(fmt.Sprintf("  message:   %s\n", fn.Message))
+			}
+		}
+		sb.WriteString(sep + "\n")
+		sb.WriteString(fmt.Sprintf("  namespace: %s  |  total: %d\n", namespace, len(items)))
+		sb.WriteString(sep + "\n")
+
+		w.Header().Set("Content-Type", "text/plain; charset=utf-8")
+		fmt.Fprint(w, sb.String())
+	}
+}
+
+func buildComment(fn fnResponse, httpT, cronT []trResponse) string {
+	if len(httpT) > 0 {
+		active := "активна"
+		if !httpT[0].Active {
+			active = "неактивна"
+		}
+		return fmt.Sprintf("HTTP endpoint (%s) — %s, %s", fn.Runtime, fn.Phase, active)
+	}
+	if len(cronT) > 0 {
+		active := "активна"
+		if !cronT[0].Active {
+			active = "неактивна"
+		}
+		return fmt.Sprintf("Cron '%s' (%s) — %s, %s", cronT[0].Schedule, fn.Runtime, fn.Phase, active)
+	}
+	return fmt.Sprintf("Job/runner без триггера (%s) — %s", fn.Runtime, fn.Phase)
+}
+
+// subFromJWT декодирует JWT payload (без проверки подписи) и возвращает sub.
+// Подпись не проверяется — trusted perimeter: сервис работает за Ingress.
+func subFromJWT(token string) (string, error) {
+	parts := strings.Split(token, ".")
+	if len(parts) != 3 {
+		return "", fmt.Errorf("invalid jwt: expected 3 parts")
+	}
+	// base64url без паддинга — добавляем паддинг стандартно
+	payload := parts[1]
+	switch len(payload) % 4 {
+	case 2:
+		payload += "=="
+	case 3:
+		payload += "="
+	}
+	data, err := base64.URLEncoding.DecodeString(payload)
+	if err != nil {
+		return "", fmt.Errorf("decode payload: %w", err)
+	}
+	var claims map[string]any
+	if err := json.Unmarshal(data, &claims); err != nil {
+		return "", fmt.Errorf("unmarshal claims: %w", err)
+	}
+	sub, ok := claims["sub"].(string)
+	if !ok || sub == "" {
+		return "", fmt.Errorf("missing sub claim")
+	}
+	return sub, nil
+}
+
+// namespaceFromSub — та же логика что в операторе и terraform провайдере.
+// SHA256(sub) → первые 8 байт → hex → "sless-{16 hex символов}"
+func namespaceFromSub(sub string) string {
+	hash := sha256.Sum256([]byte(sub))
+	return fmt.Sprintf("sless-%x", hash[:8])
+}
+
+func apiGet[T any](url, authHeader string) (T, error) {
+	var zero T
+	req, err := http.NewRequest(http.MethodGet, url, nil)
+	if err != nil {
+		return zero, err
+	}
+	req.Header.Set("Authorization", authHeader)
+	resp, err := http.DefaultClient.Do(req)
+	if err != nil {
+		return zero, err
+	}
+	defer resp.Body.Close()
+	body, _ := io.ReadAll(resp.Body)
+	if resp.StatusCode != http.StatusOK {
+		return zero, fmt.Errorf("status %d: %s", resp.StatusCode, body)
+	}
+	if err := json.Unmarshal(body, &zero); err != nil {
+		return zero, fmt.Errorf("unmarshal: %w", err)
+	}
+	return zero, nil
+}
+
+func env(key, fallback string) string {
+	if v := os.Getenv(key); v != "" {
+		return v
+	}
+	return fallback
+}
Author	SHA1	Message	Date
Naeel	38bb494ed5	feat: funcs-service v0.1.3 — /funcs/<namespace> URL without token - /funcs/<namespace>: user opens URL in browser, no auth needed service uses SLESS_SERVICE_TOKEN to query operator internally - /funcs?token=<jwt>: token as query param (bookmarkable URL) - /funcs: returns usage hint with both URL formats - SLESS_SERVICE_TOKEN set via kubectl set env (not stored in repo)	2026-03-18 16:11:17 +03:00
Naeel	e8cd62e171	feat: funcs as global Go service (sless-funcs-service:v0.1.1) - services/funcs/main.go: standalone Go HTTP server extracts JWT sub -> SHA256[:8] -> namespace -> calls operator API returns plain text list, sorted active first, /health probe endpoint - services/funcs/Dockerfile: multi-stage Go build -> alpine - deployments/k8s/funcs-service.yaml: Deployment+Service+Ingress in sless ns ingress path /funcs -> sless-funcs-service:8090, reuses sless-operator-tls - examples/POSTGRES/resources.tf: removed funcs_list function+trigger+output Image: naeel/sless-funcs-service:v0.1.1	2026-03-18 15:58:08 +03:00
Naeel	9bc91841c8	feat: NodeJS pg-info function; funcs endpoint: filter + created_at/last_built_at; operator v0.1.32	2026-03-18 11:03:58 +03:00
Naeel	6010649e7b	feat: add funcs endpoint — list all functions with triggers for UI	2026-03-18 10:05:15 +03:00
Naeel	ba0375d47e	feat: POSTGRES example — add pg-table-reader HTTP function	2026-03-18 09:23:13 +03:00
Naeel	531a54af5d	docs: 2026-03-18 DNS incident — sless-api→sless.kube5s.ru, POSTGRES E2E PASS	2026-03-18 09:07:47 +03:00
Naeel	cca3a8cdc1	fix: migrate sless endpoint from sless-api.kube5s.ru to sless.kube5s.ru (new cluster ingress 185.247.187.147)	2026-03-18 08:48:50 +03:00
Naeel	8f841e8c81	fix: remove all prod endpoint references from examples (test stand only)	2026-03-18 08:08:20 +03:00
Naeel	5d9045babc	docs: E2E results 2026-03-17 — all 4 examples PASS on test stand	2026-03-18 06:27:57 +03:00
“Naeel”	1294ad993f	0	2026-03-15 09:38:27 +04:00
Naeel	8dd5b676c0	feat: demo managed functions with harbor-backed operator setup	2026-03-14 18:16:53 +03:00
Naeel	cbd2c8c44c	chore: ignore *.tfvars in examples, remove ai_hint_level from pg-list-python	2026-03-12 09:21:20 +03:00
Naeel	2798f3b896	chore: provider v0.1.18, update examples (harbor branch)	2026-03-12 09:19:17 +03:00