Samples . Getting Started . Packages . Apps . Docs . Dev . FAQ . Changes

asyncmachine-go

Note

State machines communicate through states (mutations, checking, and waiting).

asyncmachine-go is a batteries-included graph control flow library implementing AOP and Actor Model through a clock-based state-machine. It features atomic transitions, transparent RPC, TUI debugger, telemetry, REPL, remote workers, and diagrams.

As a control flow library, it decides about running of predefined bits of code (transition handlers) - their order and which ones to run, according to currently active states (flags). Thanks to a novel state machine, the number of handlers can be minimized while maximizing scenario coverage. It's lightweight, fault-tolerant by design, has rule-based mutations, and can be used to target virtually any step-in-time, in any workflow.

asyncmachine-go takes care of context, select, and panic, while allowing for graph-structured concurrency with goroutine cancellation. The history log and relations have vector formats.

It aims to create autonomous workflows with organic control flow and stateful APIs:

• autonomous - automatic states, relations, context-based decisions
• organic - relations, negotiation, cancellation
• stateful - maintaining context, responsive, atomic

Each state represents:

• binary flag
• node in a multigraph
• AOP aspect
• metric
• trace
• subscription topic
• multiple methods
• breakpoint

Besides workflows, it can be used for stateful applications of any size - daemons, UIs, configs, bots, firewalls, synchronization consensus, games, smart graphs, microservice orchestration, contracts, simulators, as well as "real-time" systems which rely on instant cancellations.

Stack

The top layers depend on the bottom ones.

.

.

.

.

.

.

PubSub

.

.

.

.

.

.

.

.

.

.

.

Workers

.

.

.

.

.

.

.

.

.

RPC

.

.

.

.

.

.

.

Handlers

.

.

.

.

.

🐇 Machine API

.

.

.

Relations

.

States

Samples

Minimal - an untyped definition of 2 states and 1 relation, then 1 mutation and a check.

import am "github.com/pancsta/asyncmachine-go/pkg/machine"
// ...
mach := am.New(nil, am.Schema{
    "Foo": {Require: am.S{"Bar"}},
    "Bar": {},
}, nil)
mach.Add1("Foo", nil)
mach.Is1("Foo") // false

Complicated - wait on a multi state (event) and the Ready state with a 1s timeout, then mutate with typed args, on top of a state context.

// state ctx is an expiration ctx
ctx := client.Mach.NewStateCtx(ssC.WorkerReady)
// clock-based subscription
whenPayload := client.Mach.WhenTicks(ssC.WorkerPayload, 1, ctx)
// state mutation
client.WorkerRpc.Worker.Add1(ssW.WorkRequested, Pass(&A{
    Input: 2}))
// WaitFor* wraps select statements
err := amhelp.WaitForAll(ctx, time.Second,
    // post-mutation subscription
    mach.When1(ss.BasicStatesDef.Ready, nil),
    // pre-mutation subscription
    whenPayload)
// check cancellation
if ctx.Err() != nil {
    return // state ctx expired
}
// check error
if err != nil {
    // err state mutation
    client.Mach.AddErr(err, nil)
    return // no err required
}
// client/WorkerPayload and mach/Ready activated

Handlers - Aspect Oriented transition handlers.

// can Foo activate?
func (h *Handlers) FooEnter(e *am.Event) bool {
    return true
}
// with Foo active, can Bar activate?
func (h *Handlers) FooBar(e *am.Event) bool {
    return true
}
// Foo activates
func (h *Handlers) FooState(e *am.Event) {
    h.foo = NewConn()
}
// Foo de-activates
func (h *Handlers) FooEnd(e *am.Event) {
    h.foo.Close()
}

Schema - states of a node worker.

type WorkerStatesDef struct {
    ErrWork        string
    ErrWorkTimeout string
    ErrClient      string
    ErrSupervisor  string

    LocalRpcReady     string
    PublicRpcReady    string
    RpcReady          string
    SuperConnected    string
    ServeClient       string
    ClientConnected   string
    ClientSendPayload string
    SuperSendPayload  string

    Idle          string
    WorkRequested string
    Working       string
    WorkReady     string

    // inherit from rpc worker
    *ssrpc.WorkerStatesDef
}

All examples and benchmarks can be found in /examples.

Getting Started

• 🦾 /pkg/machine is the main package
• /pkg/node shows a high-level usage
• examples in /examples are good for a general grasp
• /docs/manual.md and /docs/diagrams.md go deeper into implementation details
• /tools/cmd/am-gen will bootstrap
• /examples/mach_template is copy-paste ready
• /tools/cmd/am-dbg records every detail
• reading tests is always a good idea

Packages

This monorepo offers the following importable packages and runnable tools, especially:

• 🦾 /pkg/machine State machine, dependency free, semver compatible.
• /pkg/states Reusable state schemas, handlers, and piping.
• /pkg/helpers Useful functions when working with async state machines.
• /pkg/telemetry Telemetry exporters for dbg, metrics, traces, and logs.

Remaining packages:

• /pkg/graph Multigraph of interconnected state machines.
• /pkg/history History tracking and traversal.
• /pkg/integrations NATS and other JSON integrations.
• /pkg/node Distributed worker pools with supervisors.
• /pkg/rpc Remote state machines, with the same API as local ones.
• /pkg/pubsub Decentralized PubSub based on libp2p gossipsub.
• /tools/cmd/am-dbg Multi-client TUI debugger.
• /tools/cmd/am-gen Generates schema files and Grafana dashboards.
• /tools/cmd/am-vis Generates diagrams of interconnected state machines.
• /tools/cmd/arpc Network-native REPL and CLI.

Apps

• secai AI Agents framework.
• arpc REPL Cobra-based REPL.
• am-dbg TUI Debugger Single state-machine TUI app.
• libp2p PubSub Simulator Sandbox simulator for libp2p-pubsub.
• libp2p PubSub Benchmark Benchmark of libp2p-pubsub ported to asyncmachine-go.

Documentation

• API
• diagrams | cookbook
• manual.md | manual.pdf
  • Machine and States
  • Changing State
  • Advanced Topics
  • Cheatsheet

Community

• GitHub discussions
• Matrix chat

Status

Under development, status depends on each package. The bottom layers seem prod grade, the top ones are alpha or testing.

Development

• before
  • ./scripts/dep-taskfile.sh
  • task install-deps
• after
  • task test
  • task format
  • task lint
  • task precommit
• good first issues

FAQ

How does asyncmachine work?

It calls struct methods according to conventions, a schema, and currently active states (eg BarEnter, FooFoo, FooBar, BarState). It tackles nondeterminism by embracing it - like an UDP event stream with structure.

What is a "state" in asyncmachine?

State is a binary name as in status / switch / flag, eg "process RUNNING" or "car BROKEN".

What does "clock-based" mean?

Each state has a counter of activations & deactivations, and all state counters create "machine time". It's a logical clock.

What's the difference between states and events?

The same event happening many times will cause only 1 state activation, until the state becomes inactive.

The complete FAQ is available at FAQ.md.

Changes

• Changelog
• Breaking Changes
• Roadmap