pub-sub

README

pub-sub

Example of pub-sub in Go using simple maps

How to run

go get
go run main.go

then point your requests at http://localhost:8080

to run the tests:

go test -race

API

Publisher:

• publishing: POST /:topic_name with JSON body as a message (response 204)

Subscriber:

• subscribing: POST /:topic_name/:subscriber_name (response 201)
• unsubscribing: DELETE /:topic_name/:subscriber_name (response 204)
• polling: GET /:topic_name/:subscriber_name (200 with JSON body as a message or 404 if no subscription found or 204 if no new messages are available)

Message format:

{
	"message" : "variable content string",
	"published" : "date" // returned only for polling
}

Improvements

• Make the pub-sub non-locking
• Add tests for concurrency
• Use in a demo chat application