This repository has been archived on 2020-09-24. You can view files and clone it, but cannot push or open issues or pull requests.
producer/communicator.py

49 lines
1017 B
Python

#!/usr/bin/env python
import requests
from singleton import Singleton
"""
Communicator module
"""
__author__ = "@tormakris"
__copyright__ = "Copyright 2020, GoldenPogácsa Team"
__module_name__ = "messagesender"
__version__text__ = "1"
class Communicator(Singleton):
"""
Class handling low level communication with consumers.
"""
def sendmessage(self, message: str) -> None:
"""
Send message to consumer.
:param message:
:return: none
"""
pass
def discoveravailableconsumers(self) -> list:
"""
Get the list of available consumer from the current primary consumer.
:return:
"""
pass
def isconsumeravailable(self) -> bool:
"""
Readiness probe primary consumer.
:return:
"""
pass
def checkconsumer(self, consumer: str) -> bool:
"""
Readiness probe of a prticular consumer.
:param consumer:
:return:
"""
pass