socket

package

v0.0.0-...-b3031ee Latest Latest Go to latest Published: Sep 29, 2021 License: MIT Imports: 25 Imported by: 0

Details

This section is empty.

This section is empty.

func ServeWs(hub *Hub, w http.ResponseWriter, r *http.Request)

ServeWs handles websocket requests from the peer.

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

Client is a middleman between the websocket connection and the hub.

func NewClient(hub *Hub, conn *websocket.Conn) *Client

type ErrorCode int

const (
	BadLogin ErrorCode = iota + 1
	HighSchoolNightClub
	MissingProjectForm
	HighSchoolSponsorQueue
	MissingSurveyResponse
	NonMitMisti
)

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

Hub maintains the set of active clients and broadcasts messages to the clients

func (h *Hub) Init() *Hub

func (h *Hub) ProcessRedisMessage(msg []byte)

Processes an incoming message from Redis

func (h *Hub) Run()

Listens for messages from websocket clients

func (h *Hub) Send(msg encoding.BinaryMarshaler)

Sends a message to all of our clients

func (h *Hub) SendBytes(room string, msg []byte)

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

SocketMessage stores messages sent over WS with the client who sent it

func (m SocketMessage) MarshalBinary() ([]byte, error)

func (m SocketMessage) UnmarshalBinary(data []byte) error

Path	Synopsis
packet