Skip to content
This repository has been archived by the owner on Apr 2, 2024. It is now read-only.

refactor(BUX-411): taskmanager simplification & tasq with redis fixes #510

Merged
merged 20 commits into from
Dec 20, 2023
Merged
Changes from 1 commit
Commits
Show all changes
20 commits
Select commit Hold shift + click to select a range
fd65853
refactor(BUX-411): remove empty taskmanager files
chris-4chain Dec 15, 2023
95e1e6d
refactor(BUX-411): rename files
chris-4chain Dec 15, 2023
26d7c36
refactor(BUX-411): taskq as the only task queue
chris-4chain Dec 15, 2023
60a3fd5
refactor(BUX-411): localCron as the only cron service
chris-4chain Dec 15, 2023
940725b
refactor(BUX-411): unnecessary With* func options - partially removed
chris-4chain Dec 15, 2023
7b94981
refactor(BUX-411): WithTaskQ to WithTaskqConfig
chris-4chain Dec 15, 2023
4d63b33
refactor(BUX-411): redis options by WithRedis
chris-4chain Dec 15, 2023
40b4e33
refactor(BUX-411): rename Client to TaskManager
chris-4chain Dec 15, 2023
51ca270
refactor(BUX-411): taskmanager with redis - tests
chris-4chain Dec 15, 2023
432149f
fix(BUX-411): distributed locking when using taskq-redis with multipl…
chris-4chain Dec 15, 2023
0a04ed1
refactor(BUX-411): defaultOptions moved right into NewTaskManager
chris-4chain Dec 15, 2023
584d09d
refactor(BUX-411): additional redis version comment note
chris-4chain Dec 19, 2023
51318af
refactor(BUX-411): Update version number to v0.9.0
chris-4chain Dec 19, 2023
01d3d8e
refactor(BUX-411): apply suggested comment
chris-4chain Dec 20, 2023
15aec9a
refactor(BUX-411): apply suggested comment
chris-4chain Dec 20, 2023
bb55a2f
refactor(BUX-411): redundant comments & log error if RegisterTask panic
chris-4chain Dec 20, 2023
13d9ba1
Merge branch 'refactor-411-taskmanager-simplification' of https://git…
chris-4chain Dec 20, 2023
e830802
refactor(BUX-411): taskq comments & error if runEveryPeriod < 1sec
chris-4chain Dec 20, 2023
04e02c9
refactor(BUX-411): taskmanager logger
chris-4chain Dec 20, 2023
12a41f8
refactor(BUX-411): Tasker to TaskEngine
chris-4chain Dec 20, 2023
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
refactor(BUX-411): apply suggested comment
Co-authored-by: Damian Orzepowski <damian.orzepowski@4chain.studio>
  • Loading branch information
chris-4chain and dorzepowski authored Dec 20, 2023
commit 01d3d8ef6f567f798b75d792c0e8b6fc3f09a237
2 changes: 1 addition & 1 deletion taskmanager/taskq.go
Original file line number Diff line number Diff line change
@@ -96,7 +96,7 @@ func (c *TaskManager) loadTaskQ(ctx context.Context) error {
return nil
}

// RegisterTask will register a new task using the TaskQ engine
// RegisterTask will register a new task to handle asynchronously
func (c *TaskManager) RegisterTask(name string, handler interface{}) (err error) {
defer func() {
if panicErr := recover(); panicErr != nil {
Loading