cryto-status/cstatsd/cstatsd

#!/usr/bin/env python2

import zmq, yaml

ctx = zmq.Context()

with open("config/cstatsd.yaml", "r") as cfile:
	config = yaml.safe_load(cfile)

collector = ctx.socket(zmq.PULL)
collector.bind("ipc:///tmp/cstatsd")

shipper = ctx.socket(zmq.PUSH)
shipper.bind(config["endpoint"])

while True:
	#print msgpack.unpackb(collector.recv())
	shipper.send(collector.recv())
First commit 11 years ago			`#!/usr/bin/env python2`

Add process watch, write code for ccollectd, implement ZeroMQ timer class, add dep installation script 11 years ago			`import zmq, yaml`
First commit 11 years ago
			`ctx = zmq.Context()`

Add process watch, write code for ccollectd, implement ZeroMQ timer class, add dep installation script 11 years ago			`with open("config/cstatsd.yaml", "r") as cfile:`
			`config = yaml.safe_load(cfile)`

First commit 11 years ago			`collector = ctx.socket(zmq.PULL)`
			`collector.bind("ipc:///tmp/cstatsd")`

Add process watch, write code for ccollectd, implement ZeroMQ timer class, add dep installation script 11 years ago			`shipper = ctx.socket(zmq.PUSH)`
			`shipper.bind(config["endpoint"])`

First commit 11 years ago			`while True:`
Add process watch, write code for ccollectd, implement ZeroMQ timer class, add dep installation script 11 years ago			`#print msgpack.unpackb(collector.recv())`
			`shipper.send(collector.recv())`