Skip to content

Implement HTTP GET /status to get the State of the Queue #12

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 10 commits into
base: master
Choose a base branch
from
Open

Implement HTTP GET /status to get the State of the Queue #12

Changes from 1 commit
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
f583c86
Add a message for status
MatonAnthony Feb 15, 2017
45eca18
Add tags for json marshaler
MatonAnthony Feb 15, 2017
0f67df8
Add CreationDate to the queue for monitoring purposes
MatonAnthony Feb 15, 2017
963fb06
Debugging instructions
MatonAnthony Feb 16, 2017
f8a5293
Add possibility to get status via a TCP Message
MatonAnthony Feb 16, 2017
597ca04
Implement TCP Message Status
MatonAnthony Feb 17, 2017
5288416
Add an HTTP GET Route on /status to get Queue status
MatonAnthony Feb 17, 2017
df713c1
Unit test regarding QueueStatus
MatonAnthony Feb 20, 2017
88c7f52
Remove dead code
MatonAnthony Feb 20, 2017
bcf60dd
Remove unecessary comment
MatonAnthony Feb 20, 2017
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
Debugging instructions
  • Loading branch information
@MatonAnthony
MatonAnthony committed Feb 16, 2017
commit 963fb069236327a5e7ea4f4a2564d1da02ba71ec
7 changes: 7 additions & 0 deletions go/src/pythia/backend/queue.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,8 @@ import (
"strings"
"sync"
"time"

"encoding/json"
)

func init() {
Expand Down Expand Up @@ -154,6 +156,11 @@ func (queue *Queue) Run() {
closing := false
master := make(chan queueMessage)
queue.master = master

/* DEBUG */
json, err := json.Marshal(queue)
fmt.Println(string(json))
/* END DEBUG */
go func() {
<-queue.quit
closing = true
Expand Down