chat

Documentation

Index

• func ServeWs(h *Hub, conn *websocket.Conn, room string)
• type Hub
  • func NewHub(bus event.Bus, logger log.Logger, chatbotSvc pb.ChatbotSvcClient, ...) *Hub
  • func (h *Hub) EventHandle()
  • func (h *Hub) Run()

Functions

func ServeWs

func ServeWs(h *Hub, conn *websocket.Conn, room string)

ServeWs handles websocket requests from the peer.

Types

type Hub

type Hub struct {
	// contains filtered or unexported fields
}

Hub maintains the set of active connections and broadcasts messages to the connections.

func NewHub

func NewHub(bus event.Bus, logger log.Logger, chatbotSvc pb.ChatbotSvcClient, messageSvc pb.MessageSvcClient) *Hub

func (*Hub) EventHandle

func (h *Hub) EventHandle()

func (*Hub) Run

func (h *Hub) Run()