Async processing #21
Merged
Async processing #21
Conversation
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
* async insert task query * return the number of rows
allow to use transaction to be able to rollback in tests
* fang_tasks queries done * queries with transaction rollback * deleting unused imports * some tests * deleting schema , deleting feature section , updated_at corrected * rollback and commit methods and execute modified * transaction empty message * fix cargo clippy
* 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
* fetch and touch a task inside of db transaction * remove transaction from AsyncQueue * fix `fetch_and_touch` test * uncomment one more test
* Use transaction in all queries * fix clippy
* insert query return task * deleting schema
* fail task returning * fix clippy * state check
* split into async and blocking features * update Cargo.toml file * fix example
* 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>
* 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
* 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>
* Async worker pool draft * ignore all targets * simple worker example * add debug logs * fix * fix tests * remove log * remove debug logs * fix clippy
* AsyncRunnable param in insert_task and insert_periodic_task * fix example
* 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>
* generic async worker pool !! * cfg tests
* 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>
* 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>
fix conflicts with master
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Resolves #20