subscription

Documentation

Index

• type Handler
  • func NewHandler(database *bun.DB) *Handler
  • func (h *Handler) AddUserChannel(userId string) error
  • func (h *Handler) PublishMessage(message *db.ChatMessage) error
  • func (h *Handler) PublishMessageToUser(message *db.ChatMessage, id string)
  • func (h *Handler) RemoveChatChannel(userId string, userChannel chan *db.ChatMessage) error

Types

type Handler

type Handler struct {
	UserChannel map[string][]chan *db.ChatMessage
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler(database *bun.DB) *Handler

func (*Handler) AddUserChannel

func (h *Handler) AddUserChannel(userId string) error

func (*Handler) PublishMessage

func (h *Handler) PublishMessage(message *db.ChatMessage) error

func (*Handler) PublishMessageToUser

func (h *Handler) PublishMessageToUser(message *db.ChatMessage, id string)

func (*Handler) RemoveChatChannel

func (h *Handler) RemoveChatChannel(userId string, userChannel chan *db.ChatMessage) error