router

package

v0.0.0-...-59da782 Latest Latest Go to latest Published: Jul 30, 2020 License: GPL-3.0 Imports: 2 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/33cn/chat33

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AddUser(u *User)
func AppendChannel(key string, value *Channel)
func DeleteChannel(key string)
func GetUserClientNums() int
func GetUserNums() int
func IsUserOnline(userId string) bool
type Channel
- func GetChannel(key string) (*Channel, bool)
- func NewChannel(route string) *Channel
- func (cl *Channel) Broadcast(msg interface{})
- func (cl *Channel) GetRegisterNumber() int
- func (cl *Channel) Register(userId string, client *Client)
- func (cl *Channel) UnRegister(userId string, client *Client)
type Client
- func NewClient(id, device, uuid string, createTime, loginTime int64, conn Connection, u *User) *Client
- func (c *Client) Close(code int, msg string) error
- func (c *Client) GetCreateTime() int64
- func (c *Client) GetDevice() string
- func (c *Client) GetId() string
- func (c *Client) GetLoginTime() int64
- func (c *Client) GetUUID() string
- func (c *Client) GetUser() *User
- func (c *Client) Run() error
- func (c *Client) Send(msg interface{})
type Connection
type Hub
- func NewHub() *Hub
- func (h *Hub) GetAllClients() []*Client
- func (h *Hub) IsExist(key *Client) bool
- func (h *Hub) Run()
type User
- func GetUser(key string) (*User, bool)
- func NewUser(userId string, level int) *User
- func (u *User) AppendClient(c *Client)
- func (u *User) ClientUnRegister(clientId string, channel *Channel)
- func (u *User) DeleteClient(clientId string)
- func (u *User) GetClient(clientId string) (*Client, bool)
- func (u *User) GetClients() map[string]*Client
- func (u *User) SendToAllClients(msg interface{})
- func (u *User) Subscribe(channel *Channel)
- func (u *User) UnSubscribe(channel *Channel)

Constants ¶

View Source

const (
	VISITOR   = 0
	NOMALUSER = 1
	MANAGER   = 2
)

Variables ¶

This section is empty.

Functions ¶

func AddUser ¶

func AddUser(u *User)

func AppendChannel ¶

func AppendChannel(key string, value *Channel)

func DeleteChannel ¶

func DeleteChannel(key string)

func GetUserClientNums ¶

func GetUserClientNums() int

func GetUserNums ¶

func GetUserNums() int

func IsUserOnline ¶

func IsUserOnline(userId string) bool

Types ¶

type Channel ¶

type Channel struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Channel struct of room or personal chan dec

func GetChannel ¶

func GetChannel(key string) (*Channel, bool)

func NewChannel ¶

func NewChannel(route string) *Channel

func (*Channel) Broadcast ¶

func (cl *Channel) Broadcast(msg interface{})

func (*Channel) GetRegisterNumber ¶

func (cl *Channel) GetRegisterNumber() int

func (*Channel) Register ¶

func (cl *Channel) Register(userId string, client *Client)

func (*Channel) UnRegister ¶

func (cl *Channel) UnRegister(userId string, client *Client)

type Client ¶

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

Client is a middleman between the websocket connection and the hub

func NewClient ¶

func NewClient(id, device, uuid string, createTime, loginTime int64, conn Connection, u *User) *Client

func (*Client) Close ¶

func (c *Client) Close(code int, msg string) error

func (*Client) GetCreateTime ¶

func (c *Client) GetCreateTime() int64

func (*Client) GetDevice ¶

func (c *Client) GetDevice() string

func (*Client) GetId ¶

func (c *Client) GetId() string

func (*Client) GetLoginTime ¶

func (c *Client) GetLoginTime() int64

func (*Client) GetUUID ¶

func (c *Client) GetUUID() string

func (*Client) GetUser ¶

func (c *Client) GetUser() *User

func (*Client) Run ¶

func (c *Client) Run() error

func (*Client) Send ¶

func (c *Client) Send(msg interface{})

type Connection ¶

type Connection interface {
	WriteResponse(interface{})
	Args() interface{}
	Start() error
	Close(...interface{}) error
}

type Hub ¶

type Hub struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

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

func NewHub ¶

func NewHub() *Hub

func (*Hub) GetAllClients ¶

func (h *Hub) GetAllClients() []*Client

func (*Hub) IsExist ¶

func (h *Hub) IsExist(key *Client) bool

func (*Hub) Run ¶

func (h *Hub) Run()

type User ¶

type User struct {
	sync.RWMutex

	Id    string
	Level int
	// contains filtered or unexported fields
}

User struct

func GetUser ¶

func GetUser(key string) (*User, bool)

func NewUser ¶

func NewUser(userId string, level int) *User

func (*User) AppendClient ¶

func (u *User) AppendClient(c *Client)

func (*User) ClientUnRegister ¶

func (u *User) ClientUnRegister(clientId string, channel *Channel)

func (*User) DeleteClient ¶

func (u *User) DeleteClient(clientId string)

func (*User) GetClient ¶

func (u *User) GetClient(clientId string) (*Client, bool)

func (*User) GetClients ¶

func (u *User) GetClients() map[string]*Client

func (*User) SendToAllClients ¶

func (u *User) SendToAllClients(msg interface{})

func (u *User) Subscribe(channel *Channel)

all client regist current channel

func (*User) UnSubscribe ¶

func (u *User) UnSubscribe(channel *Channel)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL