23 lines
654 B
Python
23 lines
654 B
Python
import threading
|
|
import time
|
|
|
|
import compLib.CompLib_pb2 as CompLib_pb2
|
|
from compLib.CompLibClient import CompLibClient
|
|
|
|
|
|
class HealthUpdater(object):
|
|
started = False
|
|
|
|
@staticmethod
|
|
def start():
|
|
if not HealthUpdater.started:
|
|
threading.Thread(target=HealthUpdater.loop, daemon=True).start()
|
|
HealthUpdater.started = True
|
|
|
|
@staticmethod
|
|
def loop():
|
|
while True:
|
|
request = CompLib_pb2.HealthUpdateRequest()
|
|
request.header.message_type = request.DESCRIPTOR.full_name
|
|
CompLibClient.send(request.SerializeToString(), request.ByteSize())
|
|
time.sleep(0.25)
|