communicator interface done
All checks were successful
continuous-integration/drone/push Build is passing
All checks were successful
continuous-integration/drone/push Build is passing
This commit is contained in:
parent
1b95e08285
commit
e6f4bbdcfe
@ -6,4 +6,4 @@ COPY . ./
|
|||||||
|
|
||||||
RUN pip3 install --no-cache-dir -r requirements.txt
|
RUN pip3 install --no-cache-dir -r requirements.txt
|
||||||
|
|
||||||
CMD ["python3" "app.py"]
|
CMD ["python3", "app.py"]
|
||||||
|
@ -1,5 +1,7 @@
|
|||||||
#!/usr/bin/env python
|
#!/usr/bin/env python
|
||||||
|
|
||||||
|
import requests
|
||||||
|
|
||||||
"""
|
"""
|
||||||
Main Flask RESTful API
|
Main Flask RESTful API
|
||||||
"""
|
"""
|
||||||
@ -8,3 +10,35 @@ __author__ = "@tormakris"
|
|||||||
__copyright__ = "Copyright 2020, GoldenPogácsa Team"
|
__copyright__ = "Copyright 2020, GoldenPogácsa Team"
|
||||||
__module_name__ = "messagesender"
|
__module_name__ = "messagesender"
|
||||||
__version__text__ = "1"
|
__version__text__ = "1"
|
||||||
|
|
||||||
|
class Communicator:
|
||||||
|
"""
|
||||||
|
Class handling low level communication with consumers.
|
||||||
|
"""
|
||||||
|
def __init__(self):
|
||||||
|
"""
|
||||||
|
Initalize class
|
||||||
|
"""
|
||||||
|
pass
|
||||||
|
|
||||||
|
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
|
Reference in New Issue
Block a user