Publish and Subscribe / Process / Store
- Kafka uses ZooKeeper as a distributed backend.
package main | |
import ( | |
"fmt" | |
"log" | |
"strings" | |
"github.com/PuerkitoBio/goquery" | |
) |
let cache = new Map(); | |
let pending = new Map(); | |
function fetchTextSync(url) { | |
if (cache.has(url)) { | |
return cache.get(url); | |
} | |
if (pending.has(url)) { | |
throw pending.get(url); | |
} |