6 releases
new 0.6.3 | Nov 20, 2024 |
---|---|
0.6.1 | Nov 17, 2024 |
0.4.0 | May 21, 2024 |
0.3.2 | Feb 21, 2024 |
#3 in #acts
148 downloads per month
81KB
2K
SLoC
acts-channel
provides an acts client channel for workflow engine server acts-server
The crate is called acts-channel and you can depend on it via cargo:
[dependencies]
acts-channel = "*"
If you want to use the git version:
[dependencies]
acts-channel = { git = "https://github.com/yaojianpin/acts-channel.git" }
Usage
Before connecting, please download acts-server
and start it
Message
Listening to the message from acts-server
use acts_channel::{ActsChannel, ActsOptions};
let url = format!("http://{hostname}:{port}");
// connect to server
let mut client = ActsChannel::connect(&url).await?;
// subscribe the messages
client
.subscribe(
"client-1",
move |message| {
println!("{message:?}");
},
&ActsOptions::default(),
)
.await;
Action
Executes action to interact with acts-server, such as deploy
, start
, ack
, send
, etc. For more information, please see acts-server
Publish
let yml = r"
id: test
name: model test
steps:
- name: step 1
";
let resp = client
.deploy(yml, Some("custom_model_id")).await?;
assert_eq!(resp.data.unwrap(), true);
Start
let mut vars = Vars::new();
vars.set("var1", true);
client
.submit("pid", "tid", vars).await?;
do act
// set some other vars
let vars = Vars::new();
// combine with pid and tid
let options = Vars::new().with("pid", pid).with("tid", tid).extend(&vars);
// name should be one of complete, submit, back, cancel, error, abort, push and remove
let name = "complete";
client
.send::<()>(name, options)
.await
.map_err(|err| err.message().to_string())?;
Ack a message
let resp = client
// id is message id
.ack(id)
.await
.map_err(|err| err.message().to_string())?;
Dependencies
~11–19MB
~259K SLoC