fanout   38

Dynamiq is a distributed databag, acting as a queue. It's written in golang, and run in a cluster ontop of Riak 2.0.

It exposes a simple REST API for publishing to topics and directly enqueueing to queues, as well as receiving batches of messages at a time.

Dynamiq acts as both a simple queueing application, as well as a topic-fanout system. Simply, you can create topics and queues, subscribe queues to topics, and publish messages either to topics (which will fanout to all of their queues) or to queues directly (which will only enqueue to that specific queue).
go  golang  queue  fanout  topic 
may 2015 by vonc
proxy  reverseproxy  realtime  http  websocket  sse  streaming  server  fanout 
february 2015 by wjy
This code is port from sample code of Go blog post Go Concurrency Patterns: Pipelines and cancellation's Bounded parallelism section sample code

I made the fanout pattern sample code reusable, So you can easily write parallel code without worry about fatal error: all goroutines are asleep - deadlock!, Which I encountered quite often when trying to write parallel code, and difficult to figure out why.
go  golang  parallel  fanout  channel  concurrency  pipeline 
january 2015 by vonc

related tags

*toread  activerecord  activity  activityfeed  admin  administration  advice  aggregation  aggregator  algorithm  algorithms  amqp  analytics  api  app  application  apps  architecture  article  aws  bga  bitmap  bookmarking  broadcast  browser  cdn  channel  cluster  coding  comet  commandline  concurrency  data  design  direct  disqus  distributed  django  electronics  engineering  eventvault  example  exchange  fanin  fanterm  feeds  go  golang  google  hdi  headers  http  important  indirection  interesting  javascript  lambda  layout  linux  load  longpoll  machines  management  messaging  metaapi  micro-via  mq  multiple  nginx  node.js  openamqp  opensource  parallel  pattern  patterns  pcb  perfomance  performance  pipeline  presentation  productivity  programming  proxy  push  pushpin  python  queue  rabbitmq  realtime  redis  reverse  reverseproxy  routing  rubyonrails  scalability  scaling  segment  server  serverless  serverpush  service  shell  social  software  sse  ssh  stackup  streaming  sysadmin  tcpip  terminal  test  to_read  tools  topic  tracking  tutorial  types  unix  utility  web  websocket  websockets  xmpp  yahoo  zeromq 

Copy this bookmark: