Mercurial > code > home > repos > light9

view light9/collector/collector_client.py @ 2287:62b832e9aac5

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
use zmq pubsub between clients and collector
author drewp@bigasterisk.com
date Mon, 29 May 2023 21:31:41 -0700
parents ccdfdc8183ad
children
line wrap: on
line source

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)