example

package

v0.18.8 Latest Latest Go to latest Published: Apr 23, 2026 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/pancsta/asyncmachine-go

Links

Open Source Insights

README ¶

/examples/WASM

cd /

[!NOTE] asyncmachine-go is a pathless control-flow graph with a consensus (AOP, actor model, state-machine).

This is a simple example of WASM interop and communication between two distributed async state machines (foo and bar). The complete WASM support allows having a single state-machine which is fully (or selectively) distributed across n servers and m browsers, using efficient diff-based synchronization.

Running

git clone https://github.com/pancsta/asyncmachine-go.git
cd asyncmachine-go/examples/wasm
../../scripts/dep-taskfile.sh
task start

Implementation

cenkalti/rpc2 (fork of net/rpc), and coder/websocket with TCP-over-WebSocket bridged using /tools/cmd/am-relay. The connection between foo and bar machines is full-duplex, meaning each side is both a client and a server for the other one. This allows for mutations passing both sides.

logical diagram

[!NOTE]

Blue - real state machine

Blue+orange - real state machine and state source

Green - network state machine (mirror)

Grey - regular struct with methods

Debugging

Both server-foo and browser-bar connect to a single am-dbg instance running on the server and can be stepped through, with context from all the other machines.

Both server-foo and browser-bar expose REPLs.

am-dbg WASM

Interactively use the TUI debugger with data pre-generated by this example:

go run github.com/pancsta/asyncmachine-go/tools/cmd/am-dbg@latest \
  --import-data https://assets.asyncmachine.dev/am-dbg-exports/wasm.gob.br \
  mach://server-foo

Machine Diagrams

# render
am-vis --bird render-dump am-dbg-dump.gob.br

am-dbg WASM

Extended Network Diagram

The extended machine diagram additionally contains RPC clients and servers (aka noise).

# generate with .env
AM_RPC_LOG_SERVER=1
AM_RPC_LOG_CLIENT=1
AM_RPC_LOG_MUX=1
AM_RPC_DBG=1

# render
am-vis --bird render-dump am-dbg-dump.gob.br

Click to expand the diagram

am-dbg WASM

Commands

$ task --list-all

task: Available tasks for this project:
* build:            Development build
* build-prod:       Optimized build
* deps:             List dependencies in deps.md
* deps-graph:       Render dependencies graph in deps-graph.svg
* repl:             Start REPL for both server and browser
* start:            Build and start server

Practical Implementation

This architecture was used to create an RPC-driven WASM PWA for the secai project. Opening the webapp in multiple tabs will keep all UI instances synchronized, driven by server's state mutations over aRPC.

monorepo

Go back to the monorepo root to continue reading.

Documentation ¶

Index ¶

Constants
Variables
func LogArgs(args am.A) map[string]string
func ParseRpc(args am.A) am.A
func Pass(args *A) am.A
func PassRpc(args *A) am.A
type A
- func ParseArgs(args am.A) *A
type ARpc

Constants ¶

View Source

const APrefix = "wasm"

Variables ¶

View Source

var (
	EnvFooTcpAddr  string
	EnvFooReplAddr string
)

View Source

var (
	EnvBarTcpAddr  string
	EnvBarReplAddr string
)

View Source

var (
	EnvRelayHttpAddr string
	EnvReplDir       string
)

Functions ¶

func LogArgs ¶

func LogArgs(args am.A) map[string]string

LogArgs is an args logger for A.

func ParseRpc ¶

func ParseRpc(args am.A) am.A

ParseRpc parses am.A to *ARpc wrapped in am.A. Useful for REPLs.

func Pass ¶

func Pass(args *A) am.A

Pass prepares am.A from A to pass to further mutations.

func PassRpc ¶

func PassRpc(args *A) am.A

PassRpc prepares am.A from A to pass over RPC.

Types ¶

type A ¶

type A struct {
	Msg string `log:"msg"`

	ReturnCh chan<- []string
}

A is a struct for node arguments. It's a typesafe alternative to am.A.

func ParseArgs ¶

func ParseArgs(args am.A) *A

ParseArgs extracts A from am.Event.Args APrefix.

type ARpc ¶

type ARpc struct {
	Msg string `log:"msg"`
}

ARpc is a subset of A, that can be passed over RPC.

Source Files ¶

View all Source files

wasm_example.go

Directories ¶

Path	Synopsis
client
server
states

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL