example

package
v0.18.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 7, 2026 License: MIT Imports: 8 Imported by: 0

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

  1. git clone https://github.com/pancsta/asyncmachine-go.git
  2. cd asyncmachine-go/examples/wasm
  3. 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

monorepo

Go back to the monorepo root to continue reading.

Documentation

Index

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.ArgsAPrefix.

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.