websocketserver

README

WebSocketServer

Documentation

Overview

@Time : 2019-07-12 12:38 @Author : zr

Index

• type Center
  • func NewCenter(msgHandler func(ClientInterface, []byte)) *Center
  • func (c *Center) AddClient(client ClientInterface, w http.ResponseWriter, r *http.Request) error
  • func (c *Center) Clients() Clients
  • func (c *Center) Run()
• type Client
  • func (c Client) Delete()
  • func (c Client) GetId() uint64
  • func (c *Client) Send(message []byte)
• type ClientInterface
• type Clients
• type MsgHandler

Types

type Center

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

Center maintains the set of active Clients and broadcasts messages to the Clients.

func NewCenter

func NewCenter(msgHandler func(ClientInterface, []byte)) *Center

func (*Center) AddClient

func (c *Center) AddClient(client ClientInterface, w http.ResponseWriter, r *http.Request) error

serveWs handles websocket requests from the peer.

func (*Center) Clients

func (c *Center) Clients() Clients

func (*Center) Run

func (c *Center) Run()

type Client

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

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

func (Client) Delete

func (c Client) Delete()

func (Client) GetId

func (c Client) GetId() uint64

func (*Client) Send

func (c *Client) Send(message []byte)

type ClientInterface

type ClientInterface interface {
	GetId() uint64
	Delete()
	// contains filtered or unexported methods
}

type Clients

type Clients map[uint64]ClientInterface

type MsgHandler

type MsgHandler func(ClientInterface, []byte)