go-pkg/asynqmon
1
0
Fork 0
mirror of https://github.com/hibiken/asynqmon.git synced 2025-09-22 06:46:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

Add API endpoints to batch delete scheduled, retry tasks

Browse Source
This commit is contained in:
Ken Hibino
2020-12-17 16:05:22 -08:00
parent bf81787115
commit fa1c9ee7ef
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
task_handlers.go
View File

@@ -280,7 +280,7 @@ type batchDeleteTasksResponse struct {
// Allow up to 1MB in size.
const maxRequestBodySize = 1000000
func newBatchDeleteDeadTasksHandlerFunc(inspector *asynq.Inspector) http.HandlerFunc {
func newBatchDeleteTasksHandlerFunc(inspector *asynq.Inspector) http.HandlerFunc {
return func(w http.ResponseWriter, r *http.Request) {
r.Body = http.MaxBytesReader(w, r.Body, maxRequestBodySize)
dec := json.NewDecoder(r.Body)