Documentation
¶
Index ¶
- func AddClient(r *http.Request, w http.ResponseWriter, endpoint string)
- func CreateNewFileListener(c *gin.Context)
- func CreateNewHTTPListener(c *gin.Context)
- func GetAllListeners(c *gin.Context)
- func GetAllTopics(c *gin.Context)
- func PostMessageOnTopic(c *gin.Context)
- func StartHTTPServer(port int, endpoint string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddClient ¶
func AddClient(r *http.Request, w http.ResponseWriter, endpoint string)
AddClient must be called from HTTP endpoints with the new clients connected through websocket
func CreateNewFileListener ¶
CreateNewFileListener will add to the listener queue a new listener that will write to a file
func CreateNewHTTPListener ¶
CretaeNewHTTPListener will add to the listeners queue a new listener that will execute an HTTP request to a specified point
func GetAllListeners ¶
GetAllListeners is the "GET /listener" REST handler to return all connected listeners
func GetAllTopics ¶
GetAllTopics is the "GET /topic" REST handler that will return all available topics in the session
func PostMessageOnTopic ¶
PostMessageOnTopic is the "POST /topic/[a topic]/message" REST handler to insert messages in the queue
func StartHTTPServer ¶
StartHTTPServer is the starting point of the application. It is called from the main package and will configure all needed endpoints as well as the "default" endpoint to receive messages
Types ¶
This section is empty.
Source Files