Funciones WASM
Las funciones WASM son entradas del registro que ejecutan codigo WebAssembly. Hay dos tipos de entrada disponibles: function.wat para fuente WAT en linea y function.wasm para binarios precompilados.
Funciones WAT en Linea
Define funciones WASM pequenas directamente en tu _index.yaml usando el formato WebAssembly Text:
entries:
- name: answer
kind: function.wat
source: |
(module
(func (export "answer") (result i32)
i32.const 42
)
)
wit: |
answer: func() -> s32;
method: answer
pool:
type: inline
Para fuentes WAT mas grandes, usa una referencia a archivo:
- name: answer
kind: function.wat
source: file://answer.wat
wit: |
answer: func() -> s32;
method: answer
pool:
type: inline
Campos de Configuracion WAT
| Field | Required | Description |
|---|---|---|
source |
Yes | Fuente WAT en linea o referencia file:// |
method |
Yes | Nombre de la funcion exportada a invocar |
wit |
No | Firma WIT para modulos raw/core |
pool |
No | Configuracion del pool de workers |
transport |
No | Mapeo de entrada/salida (por defecto: payload) |
imports |
No | Imports del host a habilitar (ej., wasi:cli, wasi:io) |
wasi |
No | Configuracion WASI (args, env, mounts) |
limits |
No | Limites de ejecucion |
Funciones WASM Precompiladas
Carga binarios .wasm compilados desde una entrada del sistema de archivos:
entries:
- name: assets
kind: fs.directory
directory: ./wasm
- name: compute
kind: function.wasm
fs: myns:assets
path: /compute.wasm
hash: sha256:292b796376f8b4cc360acf2ea6b82d1084871c3607a079f30b446da8e5c984a4
method: compute
pool:
type: lazy
max_size: 4
Campos de Configuracion WASM
| Field | Required | Description |
|---|---|---|
fs |
Yes | ID de la entrada del sistema de archivos que contiene el binario |
path |
Yes | Ruta al archivo .wasm dentro del sistema de archivos |
hash |
Yes | Hash SHA-256 para verificacion de integridad (sha256:...) |
method |
Yes | Nombre de la funcion exportada a invocar |
wit |
No | Firma WIT para modulos raw/core |
pool |
No | Configuracion del pool de workers |
transport |
No | Mapeo de entrada/salida (por defecto: payload) |
imports |
No | Imports del host a habilitar |
wasi |
No | Configuracion WASI |
limits |
No | Limites de ejecucion |
Pools de Workers
Cada funcion WASM usa un pool de instancias precompiladas. El tipo de pool controla la concurrencia y el uso de recursos.
| Type | Description |
|---|---|
inline |
Sincronico, un solo hilo. Nueva instancia por llamada. |
lazy |
Cero workers inactivos. Escala bajo demanda hasta max_size. |
static |
Numero fijo de workers con cola de solicitudes. |
adaptive |
Pool elastico con auto-escalado. |
Configuracion del Pool
pool:
type: static
size: 4 # Total pool size
workers: 2 # Worker threads
buffer: 16 # Request queue buffer (default: workers * 64)
pool:
type: lazy
max_size: 8 # Maximum concurrent instances
pool:
type: adaptive
max_size: 16 # Upper scaling bound
warm_start: true # Pre-instantiate initial workers
El maximo por defecto del pool elastico es 100 workers cuando max_size no esta especificado.
Transportes
Los transportes controlan como se mapean la entrada y salida entre el runtime y el modulo WASM.
| Transport | Description |
|---|---|
payload |
Mapea los payloads del runtime directamente a los argumentos de la llamada WASM (por defecto) |
wasi-http |
Mapea el contexto de solicitud/respuesta HTTP a los argumentos y resultados WASM |
Transporte Payload
El transporte por defecto pasa los argumentos directamente. Los valores Lua se transcodifican a tipos Go, luego se reducen a tipos WIT:
- name: compute
kind: function.wasm
fs: myns:assets
path: /compute.wasm
hash: sha256:...
method: compute
pool:
type: inline
-- Arguments passed directly as WASM function parameters
local result, err = funcs.call("myns:compute", 6, 7)
-- result: 42
Transporte WASI HTTP
El transporte wasi-http mapea solicitudes HTTP a WASM y escribe los resultados de vuelta en la respuesta HTTP. Usa esto para exponer funciones WASM como endpoints HTTP:
- name: greet_wasm
kind: function.wasm
fs: myns:assets
path: /greet.wasm
hash: sha256:...
method: greet
transport: wasi-http
pool:
type: inline
- name: greet_endpoint
kind: http.endpoint
method: POST
path: /api/greet
func: greet_wasm
Limites de Ejecucion
Establece un tiempo maximo de ejecucion para una funcion:
limits:
max_execution_ms: 5000 # 5 second timeout
Cuando se excede el limite, la ejecucion se cancela y se retorna un error.
Configuracion WASI
Configura las capacidades WASI para el modulo guest:
wasi:
args: ["--verbose"]
cwd: "/app"
env:
- id: myns:api_key
name: API_KEY
required: true
- id: myns:debug_mode
name: DEBUG
mounts:
- fs: myns:data_files
guest: /data
read_only: true
- fs: myns:output
guest: /output
| Field | Description |
|---|---|
args |
Argumentos de linea de comandos pasados al guest |
cwd |
Directorio de trabajo dentro del guest (debe ser absoluto) |
env |
Variables de entorno mapeadas desde entradas env del registro |
mounts |
Montajes del sistema de archivos desde entradas filesystem del registro |
Las variables de entorno se resuelven desde el registro de entorno en el momento de la llamada. Las variables requeridas causan un error si no se encuentran.
Las rutas de montaje deben ser absolutas y unicas. Cada montaje mapea una entrada del sistema de archivos del runtime a una ruta de directorio del guest.
Ejemplos
Pipeline de Transformacion de Datos
entries:
- name: wasm_binaries
kind: fs.directory
directory: ./wasm
- name: transform_users
kind: function.wasm
fs: myns:wasm_binaries
path: /mapper.wasm
hash: sha256:7304fc7d19778605458ae5804dae9a7343dcd3f5fc22bcc9415e98b5047192dd
method: transform-users
pool:
type: lazy
max_size: 4
- name: filter_active
kind: function.wasm
fs: myns:wasm_binaries
path: /mapper.wasm
hash: sha256:7304fc7d19778605458ae5804dae9a7343dcd3f5fc22bcc9415e98b5047192dd
method: filter-active
pool:
type: lazy
max_size: 4
local funcs = require("funcs")
local users = {
{id = 1, name = "Alice", tags = {"admin", "dev"}, active = true},
{id = 2, name = "Bob", tags = {"user"}, active = false},
{id = 3, name = "Carol", tags = {"dev"}, active = true},
}
-- Transform: adds display field and tag count
local transformed, err = funcs.call("myns:transform_users", users)
-- Filter: returns only active users
local active, err = funcs.call("myns:filter_active", users)
Sleep Asincrono con WASI Clocks
Los componentes WASM que importan wasi:clocks y wasi:io pueden usar relojes y polling. El mecanismo de yield asincrono se integra con el dispatcher de Wippy:
- name: sleep_ms
kind: function.wasm
fs: myns:wasm_binaries
path: /sleep_test.wasm
hash: sha256:...
method: "test-sleep#sleep-ms"
imports:
- wasi:io
- wasi:clocks
pool:
type: inline
El separador # en el campo method referencia un metodo de interfaz: test-sleep#sleep-ms invoca la funcion sleep-ms de la interfaz test-sleep.
Ver Tambien
- Descripcion general - Descripcion general del runtime WebAssembly
- Funciones Host - Interfaces host disponibles
- Procesos - Ejecucion de WASM como procesos
- Tipos de Entradas - Todos los tipos de entradas del registro