WASM 関数

インラインの WebAssembly Text ソースには function.wat、コンパイル済みバイナリには function.wasm を使用します。

分類: 関数設定リファレンス。 WAT ブロックは小規模なレジストリ例です。コンパイル済みの例では、外部でのコンポーネントビルド、ファイルシステムエントリ、ゲスト WIT に一致するエクスポートメソッド、および対象バイナリそのものから算出した SHA-256 ダイジェストを前提としています。実在するように見えるサンプルハッシュは例示用です。

インライン WAT 関数

WAT 関数を _index.yaml 内で直接定義します。

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

大きな WAT ソースにはファイル参照を使用します。

  - name: answer
    kind: function.wat
    source: file://answer.wat
    wit: |
      answer: func() -> s32;      
    method: answer
    pool:
      type: inline

WAT 設定フィールド

コンパイル済み WASM 関数

ファイルシステムエントリからコンパイル済みの .wasm バイナリを読み込みます。

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

WASM 設定フィールド

ワーカープール

各 WASM 関数は、事前コンパイル済みインスタンスのプールを使用します。プールの種類により、並行性とリソース使用量が決まります。

プール設定

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

100ワーカーのデフォルトは、暗黙的に選択されたプール（typeが設定されていない場合）にのみ適用されます。max_sizeなしで明示的にtype: lazyまたはtype: adaptiveを設定した場合、デフォルトの最大値は16ワーカーです。

ワーカークラスとコアアフィニティ

pool.worker_class を設定すると、関数は上記の共有プール種別ではなく、OS スレッドに固定された専用ワーカーのプールへルーティングされます（設定時は type が無視されます。慣例的な名前は wasm です）。

pool:
  worker_class: wasm
  workers: 8         # optional; defaults to reserved cores, else min(NumCPU, 4)

コア分離は .wippy.yaml でランタイムごとに有効にします。

scheduler:
  wasm_isolation:
    enabled: true      # default: false
    reserved_cores: 2  # cores reserved for WASM pools (default: 1)

分離を有効にすると、アクタースケジューラと固定 WASM プールは互いに重ならない CPU セット上で実行されます（sched_setaffinity、Linux のみ。他のプラットフォームではプールのサイズは調整されますが、スレッドは固定されません）。これにより、長時間実行される WASM 呼び出しがアクタースケジューリングを枯渇させることはありません。

トランスポート

トランスポートは、ランタイムと WASM モジュールの間で入出力をどのようにマッピングするかを制御します。

ペイロードトランスポート

デフォルトトランスポートは引数を直接渡します。Lua 値は Go 型へトランスコードされ、その後 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)
if err then return nil, err end
-- result: 42

WASI HTTP トランスポート

wasi-http トランスポートは HTTP リクエストを WASM へマッピングし、結果を HTTP レスポンスへ書き戻します。WASM 関数を 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
    meta:
      router: myns:api
    method: POST
    path: /api/greet
    func: greet_wasm

実行制限

options.limitsブロックは、関数の実行時間、ウォームワーカーのメモリ、および開けるソケット数を制限します:

options:
  limits:
    max_execution_ms: 5000
    max_retained_memory_bytes: 134217728
    retained_memory_check_interval: 32
    max_open_sockets: 8
    socket_timeout_ms: 5000

負の値は起動時に拒否されます。

実行時間の上限を超えると、呼び出しはキャンセルされ、エラーを返します。デフォルトの 64 MiB の保持メモリ上限は 16 回の呼び出しごとに確認されます。max_retained_memory_bytes を正の値に明示設定し、間隔を省略した場合、ランタイムは呼び出しごとに確認します。確認のコストを分散するには、正の間隔を設定してください。

WASI 設定

ゲストモジュールの WASI 機能を設定します。

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

環境変数は、呼び出し時に環境レジストリから解決されます。必須変数が見つからない場合はエラーになります。

マウントパスは絶対パスかつ一意でなければなりません。各マウントは、ランタイムのファイルシステムエントリをゲストのディレクトリパスへマッピングします。

例

データ変換パイプライン

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)
if err then return nil, err end

-- Filter: returns only active users
local active, filter_err = funcs.call("myns:filter_active", users)
if filter_err then return nil, filter_err end

WASI クロックによる非同期スリープ

wasi:clocks、wasi:io、wasi:pollをインポートするWASMコンポーネントはクロックとポーリングを使用できます。非同期yieldメカニズムは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:poll
      - wasi:clocks
    pool:
      type: inline

method フィールド内の # 区切りはインターフェースメソッドを参照します。test-sleep#sleep-ms は test-sleep インターフェースの sleep-ms 関数を呼び出します。

関連項目

• 概要 - WebAssembly ランタイムの概要
• ホスト関数 - 利用可能なホストインターフェース
• プロセス - WASM をプロセスとして実行
• エントリ種別 - すべてのレジストリエントリ種別