Типы записей

Полный справочник всех типов записей Wippy.

Записи ссылаются друг на друга в формате namespace:name. Реестр автоматически связывает зависимости, обеспечивая правильный порядок инициализации ресурсов.

См. также

• Реестр — хранение и разрешение записей
• Конфигурация — формат YAML

Lua Runtime

- name: handler
  kind: function.lua
  source: file://handler.lua
  method: main
  modules:
    - http
    - json
  imports:
    utils: app.lib:helpers  # Импорт другой записи как модуля

HTTP-сервисы

# HTTP-сервер
- name: gateway
  kind: http.service
  addr: ":8080"
  lifecycle:
    auto_start: true

# Роутер с middleware
- name: api
  kind: http.router
  meta:
    server: gateway
  prefix: /api
  middleware:
    - cors
    - ratelimit

# Эндпоинт
- name: users_list
  kind: http.endpoint
  meta:
    router: app:api
  method: GET
  path: /users
  func: list_handler

Lua API: См. Модуль HTTP

local http = require("http")
local req = http.request()
local resp = http.response()

resp:set_status(200)
resp:write_json({users = get_users()})

Базы данных

SQLite

- name: database
  kind: db.sql.sqlite
  file: "./data/app.db"
  lifecycle:
    auto_start: true

# In-memory для тестов
- name: testdb
  kind: db.sql.sqlite
  file: ":memory:"

PostgreSQL

- name: database
  kind: db.sql.postgres
  host: localhost
  port: 5432
  database: dbname
  username: user
  password: pass
  options:
    sslmode: disable
  pool:
    max_open: 25
    max_idle: 5
    max_lifetime: "30m"
  lifecycle:
    auto_start: true

MySQL

- name: database
  kind: db.sql.mysql
  host: localhost
  port: 3306
  database: dbname
  username: user
  password: pass
  options:
    parseTime: "true"
  lifecycle:
    auto_start: true

См. Database для ссылок на секреты ${env:NAME}, параметров TLS и настройки пула соединений. Когда меняется значение из env, стоящее за записью базы данных, пул переключается на лету — активные заимствования довершаются со старыми настройками соединения.

Lua API: См. Модуль SQL

local sql = require("sql")
local db, err = sql.get("app:database")

local rows, err = db:query("SELECT * FROM users WHERE id = ?", user_id)
db:execute("INSERT INTO logs (msg) VALUES (?)", message)

Key-Value хранилища

# Memory store
- name: cache
  kind: store.memory
  lifecycle:
    auto_start: true

# SQL-backed store
- name: persistent_store
  kind: store.sql
  database: app:database
  table_name: kv_store
  lifecycle:
    auto_start: true

# Cluster-replicated store (requires clustering)
- name: deployments
  kind: store.kv.raft
  namespace: deploy

Типы store.kv.* требуют включённой кластеризации. См. Store для компромиссов согласованности.

Lua API: См. Модуль Store

local store = require("store")
local s, err = store.get("app:cache")

s:set("user:123", user_data, 3600)  -- TTL в секундах
local data = s:get("user:123")

Очереди

# Драйвер
- name: queue_driver
  kind: queue.driver.memory
  lifecycle:
    auto_start: true

# Очередь
- name: jobs
  kind: queue.queue
  driver: queue_driver

# Потребитель
- name: job_consumer
  kind: queue.consumer
  queue: app:jobs
  func: job_handler
  concurrency: 4
  prefetch: 10
  lifecycle:
    auto_start: true

Lua API: См. Модуль Queue

local queue = require("queue")

-- Публикация сообщения
queue.publish("app:jobs", {task = "process", id = 123})

-- В обработчике потребителя: тело сообщения — аргумент обработчика
local function main(data)
    -- доступ к метаданным доставки через текущее сообщение
    local msg = queue.message()
    local id = msg:id()
    local priority = msg:header("priority")
    msg:ack()
end

Управление процессами

# Хост процессов (где выполняются процессы)
- name: processes
  kind: process.host
  host:
    workers: 32             # Горутины-воркеры (по умолчанию: NumCPU)
    queue_size: 1024        # Размер глобальной очереди
    local_queue_size: 256   # Очередь на воркер
  lifecycle:
    auto_start: true

# Определение процесса
- name: worker_process
  kind: process.lua
  source: file://worker.lua
  method: main

# Супервизируемый сервис
- name: worker
  kind: process.service
  process: app:worker_process
  host: app:processes
  input: ["arg1", "arg2"]
  lifecycle:
    auto_start: true
    restart:
      max_attempts: 10

- name: terminal
  kind: terminal.host
  lifecycle:
    auto_start: true

Обновление живой записи process.host перемасштабирует host.workers на месте — работающие процессы, PID и очереди сохраняются. host.queue_size, host.local_queue_size и lifecycle фиксируются при создании: живое обновление, меняющее их, отклоняется, как и изменение числа воркеров у хоста, воркеры которого управляются аффинностью.

Безопасность процесса

Записи process.lua и process.lua.bc принимают блок security: верхнего уровня. Он входит в состав записи, поэтому применяется к каждому запуску этого процесса — как на process.host, так и на terminal.host:

- name: worker_process
  kind: process.lua
  source: file://worker.lua
  method: main
  security:
    actor:
      id: system.worker
      meta:
        tenant: acme
    policies:
      - app.security:worker_policy
    groups:
      - app.security:background_jobs

Разрешение происходит при старте процесса и атомарно: если какую-либо из перечисленных политик или групп разрешить не удаётся, spawn завершается неудачей и частичный контекст не устанавливается. Опущенный actor наследует актора порождающей стороны; опущенные одновременно policies и groups наследуют её область. Блок принимают function.lua, function.lua.bc, process.lua и process.lua.bc.

Запись-команда может дополнительно объявить meta.command.security, который применяется только при запуске записи как CLI-команды — см. Безопасность команд. На обычные spawn он не влияет.

См. Безопасность.

Temporal (Workflows)

- name: temporal_client
  kind: temporal.client
  address: "localhost:7233"
  namespace: "default"
  auth:
    type: none  # none, api_key, mtls
  lifecycle:
    auto_start: true

- name: temporal_worker
  kind: temporal.worker
  client: temporal_client
  task_queue: "main-queue"
  lifecycle:
    auto_start: true

Облачное хранилище

- name: aws
  kind: config.aws
  region: "us-east-1"
  access_key_id: ${env:AWS_ACCESS_KEY_ID}
  secret_access_key: ${env:AWS_SECRET_ACCESS_KEY}

- name: uploads
  kind: cloudstorage.s3
  config: app:aws
  bucket: "my-uploads"
  endpoint: ""  # Опционально, для S3-совместимых сервисов

Lua API: См. Модуль Cloud Storage

local cloudstorage = require("cloudstorage")
local storage, err = cloudstorage.get("app:uploads")

storage:upload_object("files/doc.pdf", file_content)
local url = storage:presigned_get_url("files/doc.pdf", {expiration = 3600})  -- в секундах, по умолчанию 3600

Файловые системы

- name: data_dir
  kind: fs.directory
  directory: "./data"
  auto_init: true   # Создать, если не существует
  mode: "0755"      # Права доступа

Lua API: См. Модуль Filesystem

local fs = require("fs")
local filesystem, err = fs.get("app:data_dir")

local file = filesystem:open("output.txt", "w")
file:write("Hello, World!")
file:close()

Окружение

- name: os_env
  kind: env.storage.os

- name: file_env
  kind: env.storage.file
  file_path: ".env"
  auto_create: true

- name: defaults
  kind: env.storage.static
  values:
    PUBLIC_API_HOST: "https://api.example.com"
    APP_ENV: "production"

- name: app_env
  kind: env.storage.router
  storages:
    - app:os_env
    - app:file_env
    - app:defaults

Lua API: См. Модуль Env

local env = require("env")

local api_key = env.get("API_KEY")
env.set("CACHE_TTL", "3600")

Шаблоны

# Набор шаблонов с настройками движка
- name: templates
  kind: template.set
  engine:
    development_mode: false
    extensions:
      - ".jet"
      - ".html.jet"

# Отдельный шаблон
- name: email_template
  kind: template.jet
  source: file://templates/email.jet
  set: app:templates

Lua API: См. Модуль Template

local templates = require("templates")
local set, err = templates.get("app:templates")

local html = set:render("email", {
    user = "Alice",
    message = "Welcome!"
})

Безопасность

# Политика с условиями
- name: admin_policy
  kind: security.policy
  policy:
    actions: "*"
    resources: "*"
    effect: allow
    conditions:
      - field: "actor.meta.role"
        operator: eq
        value: "admin"

# Политика на основе выражений
- name: owner_policy
  kind: security.policy.expr
  policy:
    actions: "*"
    resources: "*"
    effect: allow
    expression: 'actor.id == meta.owner_id || actor.meta.role == "admin"'
  groups:
    - operators

Группы политик образуются самими политиками: политика перечисляет под groups: ID групп, к которым принадлежит, а группа — это множество политик, назвавших её. Отдельного типа записи для группы нет. ID групп — это Registry ID: голое имя разрешается в пространстве имён объявляющей политики, поэтому operators выше становится app.security:operators при объявлении в пространстве имён app.security. Записи ссылаются на группы по полному namespace:name.

Lua API: См. Модуль Security

local security = require("security")

-- Проверка разрешения перед действием
if security.can("delete", "users", {user_id = id}) then
    delete_user(id)
end

-- Получить текущего актора
local actor = security.actor()

Контракты (Dependency Injection)

# Определение интерфейса
- name: greeter
  kind: contract.definition
  methods:
    - name: greet
      description: Возвращает приветствие
    - name: greet_with_name
      description: Возвращает персональное приветствие
      input_schemas:
        - format: "application/schema+json"
          definition: {"type": "string"}
      output_schemas:
        - format: "application/schema+json"
          definition: {"type": "string"}

# Функции-реализации
- name: greeter_greet
  kind: function.lua
  source: file://greeter_greet.lua
  method: main

- name: greeter_greet_name
  kind: function.lua
  source: file://greeter_greet_name.lua
  method: main

# Связывание методов контракта с реализациями
- name: greeter_impl
  kind: contract.binding
  contracts:
    - contract: app:greeter
      default: true
      methods:
        greet: app:greeter_greet
        greet_with_name: app:greeter_greet_name

Использование в Lua:

local contract = require("contract")

-- Открыть binding по ID
local greeter, err = contract.open("app:greeter_impl")

-- Вызов методов
local result = greeter:greet()
local personalized = greeter:greet_with_name("Alice")

-- Проверка, реализует ли экземпляр контракт
local is_greeter = contract.is(greeter, "app:greeter")

Lua API: См. Модуль Contract

Выполнение команд

- name: native_exec
  kind: exec.native
  default_work_dir: "/app"
  command_whitelist:
    - "ls"
    - "cat"

- name: docker_exec
  kind: exec.docker
  image: "python:3.11-slim"
  default_work_dir: "/workspace"
  auto_remove: true
  memory_limit: 536870912  # 512MB
  command_whitelist:
    - "python"

WASM Runtime

# Текст WAT — это inline-исходник
- name: sum_wat
  kind: function.wat
  source: file://sum.wat
  method: sum
  transport: payload   # или wasi-http

# Бинарный WASM загружается из записи файловой системы и проверяется по хэшу
- name: sum
  kind: function.wasm
  fs: app:modules
  path: sum.wasm
  hash: sha256:2c26b46b68ffc68ff99b453c1d30413413422d706483bfa0f98a5e886266e7ae
  method: sum
  transport: payload

function.wasm и process.wasm принимают fs, path и hash — поля source у бинарной записи нет; source относится только к function.wat. hash обязателен и должен иметь вид sha256:<hex>; модуль отклоняется, если байты не совпадают.

См. Обзор WASM.

Сети

Используется в http.service через network:, в funcs/process через опцию network и в http_client через опцию overlay_network. См. Сеть.

Примитивы реестра

Типы ns.* пишутся так же, как любые другие записи: компонент объявляет ns.definition и ns.requirement, а хост объявляет ns.dependency. См. Создание компонентов.

Настройка жизненного цикла

Большинство записей поддерживают настройку жизненного цикла:

- name: service
  kind: some.kind
  lifecycle:
    auto_start: true          # Запускать автоматически
    start_timeout: 10s        # Максимальное время запуска
    stop_timeout: 10s         # Максимальное время остановки
    stable_threshold: 5s      # Время до признания стабильным
    depends_on:
      - app:database
    restart:                  # Политика перезапуска
      initial_delay: 1s
      max_delay: 90s
      backoff_factor: 2.0
      max_attempts: 0         # 0 = бесконечно

Формат ссылок на записи

Записи указываются в формате namespace:name:

# Определение
namespace: app.users
entries:
  - name: handler
    kind: function.lua

# Ссылка из другой записи
func: app.users:handler

Переопределение записей {id="overriding-entries"}

Любые поля записи — включая её kind — можно переопределить при запуске без редактирования исходного YAML, используя секцию конфигурации override: или CLI-флаг -o. Ключи используют формат namespace:entry:path:

override:
  app:gateway:addr: ":9090"        # data field (a bare path targets data.*)
  app:worker:meta.priority: high    # meta field
  app:db:kind: db.sql.postgres      # the entry's typed kind
  app:db:data.kind: custom          # a payload field literally named "kind"

Те же переопределения работают из CLI:

wippy run -o app:db:kind=db.sql.postgres -o app:gateway:addr=:9090

Значения CLI (-o) приводятся по форме (true/false в bool, числа в числа, иначе строка); значения секции override: сохраняют свой YAML-тип. Чтобы переопределить глобальные секции конфигурации, а не записи, используйте --set.