Files @ 62b832e9aac5
Branch filter:

Location: light9/light9/collector/collector_client.py

drewp@bigasterisk.com
use zmq pubsub between clients and collector
from light9 import networking
from light9.effect.settings import DeviceSettings
from light9.metrics import metrics
from twisted.internet import defer
from txzmq import ZmqEndpoint, ZmqFactory, ZmqPushConnection
import json, time, logging
import treq

log = logging.getLogger('coll_client')


        # d = treq.put(networking.collector.path('attrs'), data=msg, timeout=1)