self/queues-go
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: self:71e40b932c9e0fdef87fc94748bcbc1edb591952
Branches Tags
self:master
self:prod
self:dev
..
compare: self:39829a734811871c33368fe23c2dae85e95f5e35
Branches Tags
self:prod
self:master
self:dev

No commits in common. "71e40b932c9e0fdef87fc94748bcbc1edb591952" and "39829a734811871c33368fe23c2dae85e95f5e35" have entirely different histories.
71e40b932c ... 39829a7348

2 changed files with 10 additions and 12 deletions
Show Stats Expand all files Collapse all files

8
app/routers/put.go
View File

@ -5,14 +5,12 @@ import (
"net/http" "net/http"
tasks "queues-go/app/storage/mongo/collections" tasks "queues-go/app/storage/mongo/collections"
"time" "time"
"go.mongodb.org/mongo-driver/bson"
) )
type PutRequestBody struct { type PutRequestBody struct {
Payload bson.M `json:"payload"` Payload json.RawMessage `json:"payload"`
SecondsToExecute int `json:"seconds_to_execute"` SecondsToExecute int `json:"seconds_to_execute"`
Delay *int `json:"delay"` Delay *int `json:"delay"`
} }
func Put(w http.ResponseWriter, r *http.Request) { func Put(w http.ResponseWriter, r *http.Request) {

14
app/storage/mongo/collections/tasks.go
View File

@ -23,13 +23,13 @@ type Task struct {
} }
type InsertedTask struct { type InsertedTask struct {
Queue string `bson:"queue"` Queue string `bson:"queue"`
Payload bson.M `bson:"payload"` Payload interface{} `bson:"payload"`
PutAt time.Time `bson:"put_at"` PutAt time.Time `bson:"put_at"`
AvailableFrom time.Time `bson:"available_from"` AvailableFrom time.Time `bson:"available_from"`
SecondsToExecute int `bson:"seconds_to_execute"` SecondsToExecute int `bson:"seconds_to_execute"`
TakenAt *time.Time `bson:"taken_at"` TakenAt *time.Time `bson:"taken_at"`
Attempts int `bson:"attempts"` Attempts int `bson:"attempts"`
} }
func Add(task InsertedTask) error { func Add(task InsertedTask) error {