Commit graph

155 commits

Author SHA1 Message Date
Ayrat Badykov
7c0aa2fab9
Retries (#92)
* add retries and errors fields

* Exponential backoff

* async retries (#93)
2022-09-17 19:39:47 +03:00
Ayrat Badykov
b76e134ca1 bump version to 0.9.1 2022-09-14 14:45:01 +03:00
Pmarquez
fed5b9f363
Remove Task by uniq hash (#90)
* Change asynk remove_task API (just uuid needed)

* Add headers to traits

* Remove task by uniq hash (asynk module)

* Remove task by uniq hash (blocking module)

* Error if task is not uniq

* Rename to remove_task_by_metadata

* Testing remove by metadata query
2022-09-14 14:28:31 +03:00
Pmarquez
f4a2c55000
Fang 0.9 article (#83)
* Starting fang 0.9 article

* Fixing some errors

* Blocking refactor explained

* improve

* update timestamp

Co-authored-by: Ayrat Badykov <ayratin555@gmail.com>
2022-09-09 18:24:08 +00:00
Pmarquez
8b6e5c19b8
Docs site (#82)
* init static site

* add index

* changes footer

* remove search

* add docs workflows

* remove unused pages

* remove commit step

* README and CHANGELOG added, also fix cron typo

* Sorry ayrat my bad xd

* little glitch

* fix base url

* dates modify

* fix authors

* change structure

* don't remove docs :]

* remove rust code for static site

* copy recursively

* add random attribute

* remove submodules

* more fixes

* master branch

* CHANGELOG AND README update automated

* fix ref

* Icons may be work ?

* fix deploy bug

* i think fix the deploy bug

* gitignore README and CHANGELOG

* delete -f

* delete desc

* delete lead

Co-authored-by: Ayrat Badykov <ayratin555@gmail.com>
2022-09-07 19:24:17 +03:00
Ayrat Badykov
020ac943b5
documentation site (#81)
* init static site

* add index

* changes footer

* remove search

* add docs workflows

* remove unused pages
2022-09-06 00:06:15 +03:00
Pmarquez
d3fc479b68
Docs improvement (#80)
* I little bit improve docs

* README

* disable tests for docs
2022-09-03 14:05:58 +03:00
Pmarquez
7fb4423bf5
update README and CHANGELOG, bump version (#79)
* README and CHANGELOG

* FUNDING

* bump version

Co-authored-by: Ayrat Badykov <ayratin555@gmail.com>
2022-09-03 11:27:03 +03:00
Ayrat Badykov
2b0eb0627d
Merge pull request #69 from ayrat555/ayrat555/change-schema
Change schema to improve scheduler
2022-09-02 19:19:16 +03:00
pxp9
ac45f36819
Examples fixed 2022-09-01 19:16:18 +02:00
Pmarquez
f2ca0c046d
Diesel and Uuid updated, it was not hard xd (#78) 2022-09-01 15:54:04 +00:00
pxp9
553f5f7de1
remove all scheduled tasks, necessary for El Monitorro bot 2022-09-01 01:01:15 +02:00
Pmarquez
b975e893e2
From db errors (#77)
* Re-work errors

* delete aliases
2022-08-31 17:45:13 +00:00
pxp9
076d89e866
export Runnable 2022-08-31 12:05:56 +02:00
Pmarquez
91f2fdf330
Update asynk.rs 2022-08-29 22:28:43 +02:00
Pmarquez
05632a48ce
Update blocking.rs 2022-08-29 22:27:22 +02:00
Pmarquez
ebe67a1e18
Update asynk.rs 2022-08-29 22:26:12 +02:00
Pmarquez
a0cb08ab53
Merge branch 'master' into ayrat555/change-schema 2022-08-29 20:24:06 +00:00
Pmarquez
360140d064
Blocking refactor (#74)
* Adapting code to new Fang tables structure and refactoring to make it more generic (Not finished)

* Refactoring of the blocking module

* Finishing blocking module, starting to modify tests

* Worker tests done, Queue tests left

* Maybe all tests done ??

* Makefile clippy

* Examples fixed

* asynk feature

Co-authored-by: Ayrat Badykov <ayratin555@gmail.com>
2022-08-29 16:59:22 +00:00
Pmarquez
dffee33b9c
Asynk change schema (#75)
* add uniq method for AsyncRunnable trait (#70)

* add uniq method for asyncrunnable

* add hash enum

* remove string

* return bool values

* Task struct modified (#71)

* Task struct modified

* asynk module try to adapt new scheme

* delete period in millis

* delete period in millis completed

* Cron support :D

* Cron and single Schedule support :D

* Current timestamp value

* fix bug and new test that confirms that it was a bug

* fix a call

* Update Cargo.toml

Co-authored-by: Ayrat Badykov <ayratin555@gmail.com>

* comments suggestions

* fix clippy

* Better user api for schedule with cron

* Cron tested with example

* Comments adressed

* Comments adressed

Co-authored-by: Ayrat Badykov <ayratin555@gmail.com>

Co-authored-by: Ayrat Badykov <ayratin555@gmail.com>
2022-08-27 15:58:38 +00:00
Pmarquez
ccd900dbae
Mod model 2018 (#73)
mod model 2018
2022-08-23 17:39:06 +03:00
Ayrat Badykov
fc935f487e
add rollback query 2022-08-20 18:54:19 +03:00
Ayrat Badykov
c24b92e349
change schema 2022-08-20 18:52:33 +03:00
Pmarquez
691cba40d4
Weather bot example (#68)
* Weather bot example

* my bad xd
2022-08-18 14:59:58 +00:00
Ayrat Badykov
8eaf4e6786
bump version 2022-08-18 14:45:28 +03:00
Pmarquez
1dc513c4a7
Sleep with Duration (#67)
* Sleep in millis

* SleepParams Duration :D

* Readme updated!

* Changing Schedule and SleepParams to std::time::Duration

* Millis period in Periodic tasks

* Readme!

* Error management

* period_in_millis i64

* fix clippy
2022-08-18 14:39:10 +03:00
Ayrat Badykov
32b12182e0
Set task_type when starting a worker pool (#64) (#66)
* Set task_type when starting a worker pool (#64)

* make queue fields public

* Set task_type when starting a worker pool

* make fields private again

* bump version
2022-08-16 13:25:19 +03:00
Ayrat Badykov
2bf660c9ee
fix Error struct export for asynk (#61)
* fix Error struct export for `asynk`

* fix imports in tests

* bump version
2022-08-05 10:06:32 +03:00
Pmarquez
3f8b189f90
README improvements (#60)
improvements
2022-08-04 17:11:58 +00:00
Pmarquez
179af40899
Changelog , Readme , cargo.toml (#59)
* Changelog , Readme , cargo.toml

* Update CHANGELOG.md

Co-authored-by: Ayrat Badykov <ayratin555@gmail.com>

* Update CHANGELOG.md

Co-authored-by: Ayrat Badykov <ayratin555@gmail.com>

* delete one

Co-authored-by: Ayrat Badykov <ayratin555@gmail.com>
2022-08-04 16:47:17 +00:00
Ayrat Badykov
28da86e878
Merge pull request #21 from ayrat555/ayrat555/async
Async processing
2022-08-04 18:27:15 +03:00
Ayrat Badykov
a113fb9b90
Merge pull request #58 from ayrat555/ayrat555/fix-conflicts-with-master
fix conflicts with master
2022-08-04 18:25:33 +03:00
Ayrat Badykov
a050af57f3
Merge remote-tracking branch 'origin/master' into ayrat555/fix-conflicts-with-master 2022-08-04 18:23:04 +03:00
Ayrat Badykov
ead367d33f
Recover from panics draft (#57)
* Recover from panics draft

* Handling worker pool panics and Scheduler panics , fix clippy also

* Update src/asynk/async_scheduler.rs

Co-authored-by: Ayrat Badykov <ayratin555@gmail.com>

* add new task

Co-authored-by: pxp9 <48651252+pxp9@users.noreply.github.com>
2022-08-04 15:22:53 +00:00
Pmarquez
cf2ce19c97
Handle imports and dependencies (#56)
* imports, exports and README

* serde_json not necessay

* deleting tokio_postgres

* authors

* blocking example

* Update fang_examples/simple_async_worker/src/lib.rs

Co-authored-by: Ayrat Badykov <ayratin555@gmail.com>
2022-08-03 08:37:53 +00:00
Pmarquez
140b19e6e4
Generic Worker Pool (#55)
* generic async worker pool !!

* cfg tests
2022-08-02 14:32:58 +00:00
Pmarquez
549f5a1c4b
Max number of conns (#54)
* Max number of conns

* fixing builder , connect and example

* fix comments

* fix comments

* Update src/asynk/async_queue.rs

Co-authored-by: Ayrat Badykov <ayratin555@gmail.com>
2022-08-01 19:37:32 +00:00
Ayrat Badykov
36393676e7
limit the number of features for tokio (#53) 2022-08-01 19:57:17 +03:00
Pmarquez
785dc88b8f
configure workers (#52) 2022-08-01 16:55:36 +00:00
Pmarquez
7e66196373
Async Improvements AsyncRunnable param (#51)
* AsyncRunnable param in insert_task and insert_periodic_task

* fix example
2022-07-31 15:15:00 +00:00
Ayrat Badykov
133d142761
Async worker pool draft (#49)
* Async worker pool draft

* ignore all targets

* simple worker example

* add debug logs

* fix

* fix tests

* remove log

* remove debug logs

* fix clippy
2022-07-31 13:32:37 +00:00
Pmarquez
6222c15d99
Async scheduled tasks (#47)
* preparing queries for periodic tasks

* fixing clippy and some other things

* delete src/schema

* ignoring src/schema.rs

* fix compile error

* fix clippy

* Scheduler

* Scheduler done ??

* improve scheduler (#48)

* improve scheduler

* add number of restarts

* fix clippy

* add into attribute

* make number of restarts pub

* fixing bugs and start async scheduler tests

* fixing insert periodic task bug and scheduler tests bug

* fix clippy

* fix clippy tests

* fix clippy tests again

* fix task type :D

* Builder AsyncQueueTest and sleep in start

Co-authored-by: Ayrat Badykov <ayratin555@gmail.com>
2022-07-31 11:40:24 +00:00
Pmarquez
2d724c3776
Async worker test (#46)
* preparing code to tests

* changing queue tests and starting worker tests with new struct AsyncQueueTest

* fix clippy and delete Debug trait

* fix warnings

* Get task by id in worker tests and AsyncQueueTest #[cfg(test)]

* Defaults and AsyncWorker Builder

* Testing :D

* Execute task specific type

* deleting Options and comment

* insert task is back git !!

* Test remove tasks and changing insert task auxiliar func
2022-07-27 17:05:05 +00:00
Pmarquez
8d0a23e2f9
Async Worker (#44)
* stating with async worker

* async sleep solve and update state test

* uncomenting line

* retention mode and sleep params in lib.rs

* fixing code style

* trying to solve

* dont like changes

* Add AsyncQueueable trait (#45)

* add trait

* update runnable trait

* fix test

Co-authored-by: Ayrat Badykov <ayratin555@gmail.com>
2022-07-23 17:24:22 +03:00
Ayrat Badykov
d585bde870
split into async and blocking features (#36)
* split into async and blocking features

* update Cargo.toml file

* fix example
2022-07-20 16:08:02 +00:00
Pmarquez
d3805cd562
Returning fail task (#35)
* fail task returning

* fix clippy

* state check
2022-07-20 15:26:11 +00:00
Pmarquez
f56792a558
Returning Insert query (#34)
* insert query return task

* deleting schema
2022-07-20 14:27:01 +00:00
Ayrat Badykov
8f6f905fe9
Use transaction in all queries (#33)
* Use transaction in all queries

* fix clippy
2022-07-20 10:01:33 +00:00
Ayrat Badykov
3602097fb6
fetch_task static and AsyncQueue method (#32)
* fetch and touch a task inside of db transaction

* remove transaction from AsyncQueue

* fix `fetch_and_touch` test

* uncomment one more test
2022-07-19 20:05:09 +00:00
Pmarquez
abe324fc57
Fetch task (#26)
* fetch task async and renaming every Job/job to Task/task

* fixing cargo clippy

* Task instead Job in readme

* change one task because if not test will fail, redefined all tasks structs

* derive feature

* deleting schema

* changing query

* task builder

* fix bug enum fang task state

* fetch_test based on metadata, good improve testing fetch_task

* deleting toSql FromSql derives that are useless for Task

* builders and fail_task change
2022-07-19 13:49:43 +00:00