Merge remote-tracking branch 'origin/master'
This commit is contained in:
		@@ -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