Simplee.Intelligence.Distributed 1.0.2

Boole |> Borg

Library which implements distributed algortihms.

Logger Agent

The library implements a logging agent which can receive messages with logging payload. These messages are stored internally and can be retrieved at any moment by using the LOGS message. Find below an example (please note the error identifier in the error log):

open Simplee.Distributed

let lgr = Log.create "lg"

async {
    do! lgr |> Log.info    ("a1" |> AgentID) ("s1" |> SessionID)   "hello info"
    do! lgr |> Log.warning ("a1" |> AgentID) ("s1" |> SessionID)   "hello warn"
    do! lgr |> Log.error   ("a1" |> AgentID) ("s1" |> SessionID) 0 "hello err"
    do! Async.Sleep 1000
    return! lgr |> Log.logs
}
|> Async.RunSynchronously
|> List.iter(printfn "%O")

Graph Learning Agent

This agent implements the Graph Learning (GL) distributed algorithm. In the first step you configure the graph by using the ADDCHANNEL message which creates a communication channel between two agents. The algortihm is then initiated by sending START message to one of the graph's agents. Find an example below:

open Simplee.Distributed
open Simplee.Distributed.Traversals.GL

let lg = Log.create "lg"
let gl = GL.controller (lg)
let a1, a2, a3 = "a1" |> gl.Create, "a2" |> gl.Create, "a3" |> gl.Create

async {
    // Configure the graph (connect the agents)
    do! a1 |> GL.sysAddCh ("a2" |> AgentID |> ChannelID)
    do! a2 |> GL.sysAddCh ("a3" |> AgentID |> ChannelID)
    do! a2 |> GL.sysAddCh ("a1" |> AgentID |> ChannelID)
    do! a3 |> GL.sysAddCh ("a1" |> AgentID |> ChannelID)
    do! Async.Sleep 1000

    // Start the GL algorithm.
    do! a1 |> GL.run ("s1" |> SessionID)
    do! Async.Sleep 1000

    // Collect the logs.
    return! lg |> Log.logs
}
|> Async.RunSynchronously
|> List.iter(printfn "%O")