chat

Documentation

Index

• func Route(router *gin.Engine, token *config.Token)
• type Client
  • func NewClient(hub *Hub, connection *websocket.Conn, clientUser *user.User) *Client
  • func (client *Client) Read()
  • func (client *Client) Write()
• type ClientMessage
• type Hub
  • func NewHub(token *config.Token) Hub
  • func (hub *Hub) Run()
  • func (hub *Hub) Serve(ctx *gin.Context)
• type Message
  • func NewMessage(sender *user.User, message string) Message
  • func NewVideoMessage(sender *user.User, videoId string) (Message, error)

Functions

func Route

func Route(router *gin.Engine, token *config.Token)

Types

type Client

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

func NewClient

func NewClient(hub *Hub, connection *websocket.Conn, clientUser *user.User) *Client

func (*Client) Read

func (client *Client) Read()

func (*Client) Write

func (client *Client) Write()

type ClientMessage

type ClientMessage struct {
	Message []byte
	Sender  *Client
}

type Hub

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

func NewHub

func NewHub(token *config.Token) Hub

func (*Hub) Run

func (hub *Hub) Run()

func (*Hub) Serve

func (hub *Hub) Serve(ctx *gin.Context)

type Message

type Message struct {
	Type string `json:"type"`

	// message
	AvatarUrl string `json:"avatar_url,omitempty"`
	Message   string `json:"message,omitempty"`

	// video
	Audio string `json:"audio,omitempty"`
	Video string `json:"video,omitempty"`
}

func NewMessage

func NewMessage(sender *user.User, message string) Message

func NewVideoMessage

func NewVideoMessage(sender *user.User, videoId string) (Message, error)