Skip to content
This repository has been archived by the owner on Dec 22, 2023. It is now read-only.

Use channel in messging between goroutine in stead of zmq.REQ #167

Closed
wants to merge 12 commits into from
Closed

Use channel in messging between goroutine in stead of zmq.REQ #167

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
b2829c8
Remove eaddr from zmq transport
rickmak Oct 13, 2016
6e0f637
Remove the frontend zmq router and replace with go chan
rickmak Oct 13, 2016
233c676
Add mulitple messge and plugin test
rickmak Oct 14, 2016
cff6a78
Use string address in go space do the conversation on the zmq boundary
rickmak Oct 14, 2016
ea6e19a
Remove heartbeat logs
rickmak Oct 14, 2016
b4c4dc8
Properly break the channler on exit
rickmak Oct 17, 2016
986b64f
Add RPC timeout and retry on no worker ready yet
rickmak Oct 17, 2016
637b2ef
Fix goroutine halt on multiple worker land with init
rickmak Oct 19, 2016
740bffa
Correct spelling Channler -> Channeler
rickmak Oct 18, 2016
71ea472
Comment on workerQueue behaviour
rickmak Oct 18, 2016
60ca9f1
Make the broker channler and Run goroutine safe
rickmak Oct 19, 2016
2c9eda0
Kick start the go routine within NewBroker
rickmak Oct 19, 2016
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
Loading