WebAssembly Compute Jobs

You can run your code compiled to WebAssembly with GridGain 9 Compute API.

Use JobExecutorType.WASM_EMBEDDED to load WebAssembly binaries as deployment units and execute the code on cluster nodes.

Before submitting your compute job, ensure that the required code is deployed to the nodes where it will execute.

GridGain 9 uses Chicory 1.5.1 WebAssembly runtime.
See supported Wasm features here: https://webassembly.org/features/

Build WebAssembly Module

The following sections explain how to build and deploy modules in Rust, Go, and WebAssembly Text Format (Wat).

Rust

Make sure Rust and Cargo are installed.
Install wasm-pack:
```
cargo install wasm-pack
```
Create a new Rust library project:
```
cargo new --lib hello-wasm
```

Replace the contents of Cargo.toml with:

[package]
name = "hello-wasm"
version = "0.1.0"
edition = "2024"

[lib]
crate-type = ["cdylib", "rlib"]

[dependencies]
wasm-bindgen = "0.2.84"

Replace the contents of src/lib.rs with:

use wasm_bindgen::prelude::*;

#[wasm_bindgen]
pub fn hello(arg: String) -> String {
    format!("Hello from Rust, {}!", arg)
}

Build the project with wasm-pack build. This will create a pkg directory with the compiled Wasm module and JavaScript bindings. We only need one .wasm file from this directory: pkg/hello_wasm_bg.wasm.
Deploy the .wasm file as part of a Deployment Unit to your cluster.

Run your Rust job using Compute API:

public class ComputeRustJobExample {

    private static final DeploymentUnit DEPLOYMENT_UNIT = new DeploymentUnit("unit-rust", "1.0.0");

    private static final String HELLO_FUNC = "rust_wasm_bindgen_bg.wasm:hello:string:rust_wasm_bindgen";

    private static final JobExecutionOptions JOB_EXECUTION_OPTIONS = JobExecutionOptions.builder()
            .executorType(JobExecutorType.WASM_EMBEDDED)
            .build();

    public static void main(String[] args) throws ExecutionException, InterruptedException {


        System.out.println("\nConnecting to server...");

        try (IgniteClient client = IgniteClient.builder()
                .addresses("127.0.0.1:10800")
                .build()
        ) {

            IgniteCompute compute = client.compute();


            JobDescriptor<String, String> helloDesc = JobDescriptor.<String, String>builder(HELLO_FUNC)
                    .units(DEPLOYMENT_UNIT)
                    .options(JOB_EXECUTION_OPTIONS)
                    .build();

            JobTarget target = JobTarget.anyNode(client.cluster().nodes());

            String helloRes = compute.execute(target, helloDesc, "World");
            System.out.println("Rust job result: " + helloRes);

        }
    }
}

For more details, refer to Wasm documentation for Rust:

Go

Make sure Go is installed.
Create a new directory for your project:
```
mkdir hello-wasm && cd hello-wasm
```
Initialize a new Go module:
```
go mod init hello-wasm
```

Create a new file hello.go with the following contents:

package main

import (
    "fmt"
    "unsafe"
)

// Store allocated buffers to prevent GC from collecting them.
var buffersSlice = make([][]byte, 0)

func main() {}

//go:wasmexport addOne
func addOne(x int32) int32 {
    return x + 1
}

//go:wasmexport hello
func hello(arg uint64) uint64 {
    if arg == 0 {
        return 0
    }

    argAddr, argLen := unpackPtr(arg)
    argBytes := unsafe.Slice((*byte)(unsafe.Pointer(argAddr)), argLen)
    argStr := string(argBytes)

    resStr := fmt.Sprintf("Hello from Go, %s!", argStr)
    resBytes := []byte(resStr)

    resPtr := uint64(uintptr(unsafe.Pointer(&resBytes[0])))
    resLen := uint64(len(resBytes))

    return packPtr(resLen, resPtr)
}

//go:wasmexport alloc
func alloc(size int32) int32 {
    buffer := make([]byte, size)
    buffersSlice = append(buffersSlice, buffer)
    addr := int32(uintptr(unsafe.Pointer(&buffer[0])))

    return addr
}

//go:wasmexport dealloc
func dealloc(address uint64, size uint32) {
    // No-op.
}

func packPtr(resLen uint64, resPtr uint64) uint64 {
    return (resLen << 32) | resPtr
}

func unpackPtr(arg uint64) (uintptr, uintptr) {
    argAddr := uintptr(arg & 0xFFFFFFFF)
    argLen := uintptr(arg >> 32)
    return argAddr, argLen
}

Build the project:

GOOS=wasip1 GOARCH=wasm go build -buildmode=c-shared -o go_hello.wasm

Deploy the .wasm file as part of a Deployment Unit to your cluster.

Run your Go job using Compute API:

public class ComputeGoJobExample {

    private static final DeploymentUnit DEPLOYMENT_UNIT = new DeploymentUnit("unit-go", "1.0.0");

    private static final String HELLO_FUNC = "go-test-wasi.wasm:hello:string:go_wasi_reactor";

    private static final JobExecutionOptions JOB_EXECUTION_OPTIONS = JobExecutionOptions.builder()
            .executorType(JobExecutorType.WASM_EMBEDDED)
            .build();

    public static void main(String[] args) throws ExecutionException, InterruptedException {


        System.out.println("\nConnecting to server...");

        try (IgniteClient client = IgniteClient.builder()
                .addresses("127.0.0.1:10800")
                .build()
        ) {

            IgniteCompute compute = client.compute();


            JobDescriptor<String, String> helloDesc = JobDescriptor.<String, String>builder(HELLO_FUNC)
                    .units(DEPLOYMENT_UNIT)
                    .options(JOB_EXECUTION_OPTIONS)
                    .build();

            JobTarget target = JobTarget.anyNode(client.cluster().nodes());

            String helloRes = compute.execute(target, helloDesc, "World");
            System.out.println("Go job result: " + helloRes);

        }
    }
}

For more details, refer to Wasm documentation for Go:

https://go.dev/wiki/WebAssembly

WebAssembly Text Format

Go to https://webassembly.github.io/wabt/demo/wat2wasm/ and paste the following code into the left pane:

(module
    (memory (export "memory") 10)
    (func (export "addOne") (param i32) (result i32)
        local.get 0
        i32.const 1 ;; Value to add
        i32.add
    )
)

Click the Download button.
Deploy the downloaded .wasm file as part of a Deployment Unit to the cluster.

Invoke the functions with Compute API:

public class ComputeWasmJobExample {

    private static final DeploymentUnit DEPLOYMENT_UNIT = new DeploymentUnit("unit-wasm", "1.0.0");

    private static final String HELLO_FUNC = "test-module.wasm:addOne:int32";

    private static final JobExecutionOptions JOB_EXECUTION_OPTIONS = JobExecutionOptions.builder()
            .executorType(JobExecutorType.WASM_EMBEDDED)
            .build();

    public static void main(String[] args) throws ExecutionException, InterruptedException {


        System.out.println("\nConnecting to server...");

        try (IgniteClient client = IgniteClient.builder()
                .addresses("127.0.0.1:10800")
                .build()
        ) {

            IgniteCompute compute = client.compute();


            JobDescriptor<Integer, Integer> helloDesc = JobDescriptor.<Integer, Integer>builder(HELLO_FUNC)
                    .units(DEPLOYMENT_UNIT)
                    .options(JOB_EXECUTION_OPTIONS)
                    .build();

            JobTarget target = JobTarget.anyNode(client.cluster().nodes());

            Integer helloRes = compute.execute(target, helloDesc, 42);
            System.out.println("WASM job result: " + helloRes);

        }
    }
}

For more details, refer to Wasm documentation for WebAssembly:

https://developer.mozilla.org/en-US/docs/WebAssembly/Guides/Understanding_the_text_format

© 2025 GridGain Systems, Inc. All Rights Reserved. Privacy Policy | Legal Notices. GridGain® is a registered trademark of GridGain Systems, Inc.
Apache, Apache Ignite, the Apache feather and the Apache Ignite logo are either registered trademarks or trademarks of The Apache Software Foundation.

Last updated on Sep 29, 2025