examples/

/examples

cd /

[!NOTE] Asyncmachine-go is an AOP Actor Model library for distributed workflows, built on top of a lightweight state machine. It has atomic transitions, RPC, logging, TUI debugger, metrics, tracing, and soon diagrams.

Table of contents:

• Examples
  • aRPC Setup
  • DAG Dependency Graph
  • FSM - Finite State Machine
  • NFA - Nondeterministic Finite Automaton
  • PATH Watcher
  • Pipes
  • Raw Strings
  • Relations Playground
  • Subscriptions
  • Temporal Expense Workflow
  • Temporal FileProcessing Workflow
  • Tree State Source
• Benchmarks
  • Benchmark gRPC
  • Benchmark libp2p PubSub
  • Benchmark State Source
• Demos
• Debugging Sessions
• Case Studies

Examples

aRPC Setup

• #rpc #client #server
• origin

DAG Dependency Graph

• #relations #handlers #async #auto #dependency-graph

Fan Out Fan In

• #relations #handlers #async #auto #concurrency

FSM - Finite State Machine

• #relations #handlers #negotiation #auto
• origin

NFA - Nondeterministic Finite Automaton

• #relations #handlers #async #multi
• origin

PATH Watcher

• #relations #handlers #async #negotiation #multi
• origin

Pipes

• #handlers #composition
• origin

Raw Strings

• #relations #handlers #async #negotiation #auto
• origin

Relations Playground

• #relations
• origin

Subscriptions

• #waiting
• origin

Temporal Expense Workflow

• #relations #handlers #async #negotiation #auto #temporal
• origin

Temporal FileProcessing Workflow

• #relations #handlers #async #auto #temporal
• origin
• Asynq worker version

Tree State Source

• #relations #negotiation #auto #arpc #otel #metrics #grafana #generator #data
• origin

Benchmarks

Benchmark gRPC

• #relations #handlers #negotiation #arpc #grpc
• origin

Benchmark libp2p PubSub

• #relations #handlers #async #negotiation #libp2p

Benchmark State Source

• #docker #go-wrt #caddy
• origin

Demos

• RPC integration tests tutorial
• Jaeger traces JSON file

Debugging Sessions

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

• libp2p-pubsub-simulator
  • web terminal: http://188.166.101.108:8080/wetty/ssh
  • remote terminal: ssh 188.166.101.108 -p 4444
  • local terminal: go run github.com/pancsta/asyncmachine-go/tools/cmd/am-dbg@latest --import-data https://pancsta.github.io/assets/asyncmachine-go/am-dbg-exports/pubsub-sim.gob.br
• remote integration tests
  • web terminal: http://188.166.101.108:8081/wetty/ssh
  • remote terminal: ssh 188.166.101.108 -p 4445
  • local terminal: go run github.com/pancsta/asyncmachine-go/tools/cmd/am-dbg@latest --import-data https://pancsta.github.io/assets/asyncmachine-go/am-dbg-exports/remote-tests.gob.br

Case Studies

Bigger implementations worth reading:

• libp2p PubSub Simulator Sandbox simulator for libp2p-pubsub.
• libp2p PubSub Benchmark Benchmark of libp2p-pubsub ported to asyncmachine-go.
• am-dbg TUI Debugger Single state machine TUI app.

monorepo

Go back to the monorepo root to continue reading.