Go to file
2020-12-02 18:47:14 +03:00
.circleci New data format (#12) 2020-10-30 20:29:05 +03:00
.github/workflows Automatically build aquamarine.wasm & publish to NPM as base64 (#29) 2020-11-17 12:02:43 +03:00
crates Add function to return AST as json (#35) 2020-12-02 18:47:14 +03:00
images Add more images to readme (#27) 2020-11-12 18:04:36 +03:00
stepper Add function to return AST as json (#35) 2020-12-02 18:47:14 +03:00
stepper-lib Add function to return AST as json (#35) 2020-12-02 18:47:14 +03:00
.gitignore add bencher 2020-11-01 17:23:27 +03:00
Cargo.lock Add function to return AST as json (#35) 2020-12-02 18:47:14 +03:00
Cargo.toml LALRPOP parser for AIR (#13) 2020-11-03 17:43:58 +03:00
CHANGELOG.md release 0.1.3 (#25) 2020-11-11 14:43:26 +03:00
Config.toml Introduce Seq, Par, Fold instructions (#5) 2020-10-08 12:43:23 +03:00
LICENSE Initial commit 2020-09-18 14:05:43 +03:00
README.md Update readme (#28) 2020-11-12 18:25:34 +03:00

Aquamarine

  • composability medium
  • allows developers to express network choreography in a script
  • moves script & data from peer to peer in a single-use logical network with checking merkle proofs and signatures.

aquamarine scheme


Fluence stack

Fluence nodes use aquamarine to coordinate requests between different services run by FCE:


aquamarine scheme


Aquamarine Intermediate Representation

AIR: What is it?

  • S-expression-based low-level language
  • Controls Fluence network and its peers
  • Inspired by WAT (WebAssembly Text Format)
  • Meant to be a compile target
  • Development meant to happen in a higher-level language
  • Syntax is in flux, will change

Scripts written in AIR look like this:

fold example
  1. Gather chat members by calling chat.members
  2. Iterate through elements in members array, m = element
  3. Each m is an object, represented as array; [0] is the first field
  4. (next m) triggers next iteration

AIR: Instructions

call: execution

call structure
  • call commands the execution
  • moves execution to a peer, specified by location
  • peer is expected to have specified WASM service
  • the service must have specified function available to be called
  • argument list is given to the function
  • result of the function is saved and available under output name
  • example call could be thought of as data.result = dht.put(key, value)

seq: sequential

seq structure
  • seq takes two instructions
  • executes them sequentially

par: parallel

par structure
  • par takes two instructions
  • executes them in parallel

fold: iteration

fold structure
  • fold takes an array, a variable and an instruction
  • iterates through the array, assigning each element to the variable
  • on each iteration instruction is executed
  • instruction can read the variable
  • next triggers next iteration

xor: branching & error handling

xor structure
  • xor takes two instructions
  • iff first instruction fails, second one is executed

null

null structure
  • null takes no arguments
  • does nothing, useful for code generation