Documentation
¶
Index ¶
- type ChatHandler
- func (c *ChatHandler) HandleBotMessages(w http.ResponseWriter, r *http.Request)
- func (c *ChatHandler) HandleConnections(w http.ResponseWriter, r *http.Request)
- func (c *ChatHandler) HandleMessages()
- func (c *ChatHandler) HandleStockCommand(msg entityPkg.ChatMessage)
- func (c *ChatHandler) PostMessageToChatroom(msg entityPkg.ChatMessage)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChatHandler ¶
type ChatHandler struct {
Upgrader websocket.Upgrader
Broadcast chan entityPkg.ChatMessage
Mutex sync.Mutex
Chatrooms map[string]map[*websocket.Conn]bool
UserDB repository.UserInterface
MessageDB repository.MessageInterface
RabbitMQQueueCH *amqp.Channel
}
func NewChatWebsocket ¶
func NewChatWebsocket(userDB repository.UserInterface, messageDB repository.MessageInterface, rabbitMQQueueCH *amqp.Channel) *ChatHandler
func (*ChatHandler) HandleBotMessages ¶
func (c *ChatHandler) HandleBotMessages(w http.ResponseWriter, r *http.Request)
func (*ChatHandler) HandleConnections ¶
func (c *ChatHandler) HandleConnections(w http.ResponseWriter, r *http.Request)
func (*ChatHandler) HandleMessages ¶
func (c *ChatHandler) HandleMessages()
func (*ChatHandler) HandleStockCommand ¶
func (c *ChatHandler) HandleStockCommand(msg entityPkg.ChatMessage)
func (*ChatHandler) PostMessageToChatroom ¶
func (c *ChatHandler) PostMessageToChatroom(msg entityPkg.ChatMessage)
Source Files
Click to show internal directories.
Click to hide internal directories.