dimas 0.5.1

dimas - a framework for Distributed Multi Agent Systems
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

//! `DiMAS` query example
//! Copyright © 2024 Stephan Kunz

use dimas::prelude::*;

#[derive(Debug)]
struct AgentProps {}

async fn query_callback(_ctx: Context<AgentProps>, response: QueryableMsg) -> Result<()> {
	let message: u128 = response.decode()?;
	println!("Response 1 is '{message}'");
	Ok(())
}

#[dimas::main]
async fn main() -> Result<()> {
	// create & initialize agents properties
	let properties = AgentProps {};

	// create an agent with the properties and the prefix 'examples'
	let mut agent = Agent::new(properties)
		.prefix("examples")
		.name("querier")
		.config(&Config::default())?;

	// create querier for topic "query"
	agent
		.querier()
		.topic("query")
		.callback(query_callback)
		.add()?;

	// timer for regular querying
	let interval = Duration::from_secs(1);
	let mut counter1 = 0i128;
	agent
		.timer()
		.name("timer")
		.interval(interval)
		.callback(move |ctx| -> Result<()> {
			println!("Querying [{counter1}]");
			let message = Message::encode(&counter1);
			// querying with stored query
			ctx.get("query", Some(message), None)?;
			counter1 += 1;
			Ok(())
		})
		.add()?;

	// activate liveliness
	agent.liveliness(true);
	// run agent
	agent.start().await?;

	Ok(())
}