chat

Documentation

Index

• Constants
• type Chat
  • func NewChat() *Chat
• type Client
  • func NewClient(w *websocket.Conn) *Client
  • func (cl *Client) HasJoined(room string) bool
  • func (cl *Client) SendJSON(m *Message) error
• type Message
• type MsgStream
  • func NewMsgStream() *MsgStream
• type Room
  • func NewRoom(name string) *Room
  • func (room *Room) ListenToStream(s *MsgStream, c *Client)
  • func (r *Room) MarshalJSON() ([]byte, error)
  • func (room *Room) SendMsgs()

Constants

const (
	TalkAction  = "talk"
	JoinAction  = "join"
	LeaveAction = "leave"
	ErrorAction = "error"
)

Types

type Chat

type Chat struct {
	sync.Mutex
	Rooms map[string]*Room
}

func NewChat

func NewChat() *Chat

type Client

type Client struct {
	sync.Mutex
	RoomStreams map[string]*MsgStream
	// contains filtered or unexported fields
}

func NewClient

func NewClient(w *websocket.Conn) *Client

func (*Client) HasJoined

func (cl *Client) HasJoined(room string) bool

func (*Client) SendJSON

func (cl *Client) SendJSON(m *Message) error

type Message

type Message struct {
	Action     string
	Room       string
	Username   string
	Content    string
	HTTPstatus int
}

type MsgStream

type MsgStream struct {
	SentMsgs    chan Message
	DoneSending chan bool
}

func NewMsgStream

func NewMsgStream() *MsgStream

type Room

type Room struct {
	Name string `json:"name"`

	sync.Mutex
	// contains filtered or unexported fields
}

func NewRoom

func NewRoom(name string) *Room

func (*Room) ListenToStream

func (room *Room) ListenToStream(s *MsgStream, c *Client)

func (*Room) MarshalJSON

func (r *Room) MarshalJSON() ([]byte, error)

func (*Room) SendMsgs

func (room *Room) SendMsgs()