rafaelcaricio/backie
rafaelcaricio/backie
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Examples fixed

Browse source
This commit is contained in:
pxp9 2022-09-01 19:16:18 +02:00
parent f2ca0c046d
commit ac45f36819
No known key found for this signature in database
GPG key ID: 2DC73C49C2A9A6D4
5 changed files with 13 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
fang_examples/blocking/simple_cron_worker/Cargo.toml
View file

@ -1,7 +1,7 @@
[package] [package]
name = "simple_worker" name = "simple_cron_worker"
version = "0.1.0" version = "0.1.0"
edition = "2018" edition = "2021"
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
@ -10,4 +10,4 @@ fang = { path = "../../../" , features = ["blocking"]}
dotenv = "0.15.0" dotenv = "0.15.0"
env_logger = "0.9.0" env_logger = "0.9.0"
log = "0.4.0" log = "0.4.0"
diesel = "1.4.8" diesel = { version = "2", features = ["postgres", "r2d2"] }

4
fang_examples/blocking/simple_cron_worker/src/lib.rs
View file

@ -1,7 +1,7 @@
use fang::runnable::Runnable; use fang::runnable::Runnable;
use fang::serde::{Deserialize, Serialize}; use fang::serde::{Deserialize, Serialize};
use fang::typetag; use fang::typetag;
use fang::Error; use fang::FangError;
use fang::Queueable; use fang::Queueable;
use fang::Scheduled; use fang::Scheduled;
@ -11,7 +11,7 @@ pub struct MyCronTask {}
#[typetag::serde] #[typetag::serde]
impl Runnable for MyCronTask { impl Runnable for MyCronTask {
fn run(&self, _queue: &dyn Queueable) -> Result<(), Error> { fn run(&self, _queue: &dyn Queueable) -> Result<(), FangError> {
log::info!("CRON !!!!!!!!!!!!!!!!!"); log::info!("CRON !!!!!!!!!!!!!!!!!");
Ok(()) Ok(())

2
fang_examples/blocking/simple_cron_worker/src/main.rs
View file

@ -5,7 +5,7 @@ use fang::Queue;
use fang::Queueable; use fang::Queueable;
use fang::RetentionMode; use fang::RetentionMode;
use fang::WorkerPool; use fang::WorkerPool;
use simple_worker::MyCronTask; use simple_cron_worker::MyCronTask;
use std::env; use std::env;
use std::thread::sleep; use std::thread::sleep;
use std::time::Duration; use std::time::Duration;

4
fang_examples/blocking/simple_worker/Cargo.toml
View file

@ -1,7 +1,7 @@
[package] [package]
name = "simple_worker" name = "simple_worker"
version = "0.1.0" version = "0.1.0"
edition = "2018" edition = "2021"
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
@ -10,4 +10,4 @@ fang = { path = "../../../" , features = ["blocking"]}
dotenv = "0.15.0" dotenv = "0.15.0"
env_logger = "0.9.0" env_logger = "0.9.0"
log = "0.4.0" log = "0.4.0"
diesel = "1.4.8" diesel = { version = "2", features = ["postgres", "r2d2"] }

10
fang_examples/blocking/simple_worker/src/lib.rs
View file

@ -1,7 +1,7 @@
use fang::runnable::Runnable; use fang::runnable::Runnable;
use fang::serde::{Deserialize, Serialize}; use fang::serde::{Deserialize, Serialize};
use fang::typetag; use fang::typetag;
use fang::Error; use fang::FangError;
use fang::Queueable; use fang::Queueable;
use std::thread; use std::thread;
use std::time::Duration; use std::time::Duration;
@ -27,9 +27,7 @@ impl MyTask {
#[typetag::serde] #[typetag::serde]
impl Runnable for MyTask { impl Runnable for MyTask {
fn run(&self, queue: &dyn Queueable) -> Result<(), Error> { fn run(&self, queue: &dyn Queueable) -> Result<(), FangError> {
thread::sleep(Duration::from_secs(3));
let new_task = MyTask::new(self.number + 1); let new_task = MyTask::new(self.number + 1);
log::info!( log::info!(
@ -40,6 +38,8 @@ impl Runnable for MyTask {
queue.insert_task(&new_task).unwrap(); queue.insert_task(&new_task).unwrap();
thread::sleep(Duration::from_secs(2));
Ok(()) Ok(())
} }
@ -68,7 +68,7 @@ impl MyFailingTask {
#[typetag::serde] #[typetag::serde]
impl Runnable for MyFailingTask { impl Runnable for MyFailingTask {
fn run(&self, queue: &dyn Queueable) -> Result<(), Error> { fn run(&self, queue: &dyn Queueable) -> Result<(), FangError> {
let new_task = MyFailingTask::new(self.number + 1); let new_task = MyFailingTask::new(self.number + 1);
queue.insert_task(&new_task).unwrap(); queue.insert_task(&new_task).unwrap();