websocket

Documentation

Index

• type BroadcastInfo
• type Client
  • func NewClient(wss *WebSocketService, conn *websocket.Conn, userId int) *Client
  • func (client *Client) InitReadHandler()
  • func (client *Client) InitWriteHandler()
• type IWebSocketService
  • func NewWebSocketService() IWebSocketService
• type Message
• type WebSocketService
  • func (service *WebSocketService) Broadcast(broadcastInfo *BroadcastInfo)
  • func (service *WebSocketService) InitConnection(connection *websocket.Conn, userData interface{})

Types

type BroadcastInfo

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

type Client

type Client struct {
	Send   chan interface{}
	UserId int
	// contains filtered or unexported fields
}

func NewClient

func NewClient(wss *WebSocketService, conn *websocket.Conn, userId int) *Client

func (*Client) InitReadHandler

func (client *Client) InitReadHandler()

func (*Client) InitWriteHandler

func (client *Client) InitWriteHandler()

type IWebSocketService

type IWebSocketService interface {
	InitConnection(*websocket.Conn, interface{})
	Broadcast(*BroadcastInfo)
}

func NewWebSocketService

func NewWebSocketService() IWebSocketService

type Message

type Message struct {
	Id    int    `json:"id"`
	Event string `json:"event"`
}

type WebSocketService

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

func (*WebSocketService) Broadcast

func (service *WebSocketService) Broadcast(broadcastInfo *BroadcastInfo)

func (*WebSocketService) InitConnection

func (service *WebSocketService) InitConnection(
	connection *websocket.Conn,
	userData interface{},
)