stream

Feb 13, 2020

Changes in this version

type Client

+ func NewClient(ctx *gin.Context, clientId, token string, clientType ClientType) (client *Client, err error)

+ type ClientType string

type Hub

+ func (h *Hub) GetClientServer(clientId string) (client *Client, err error)

+ func (h *Hub) GetCommandFromSubscribers(cmd string) func(client *Client, msg Message)

+ func (h *Hub) GetServer(cli *Client) (server *Client, err error)

+ func (h *Hub) GetServerClients(cli *Client) (clients []*Client, err error)

+ func (h *Hub) Shutdown()

+ type Stat struct

Oct 7, 2019

Changes in this version

type Message

+ Type string

Aug 22, 2019

Changes in this version

+ const ClientTypeMobile

+ const ClientTypeServer

+ const Request

+ const Response

+ const StatusError

+ const StatusSuccess

+ type Client struct

+ Connect *websocket.Conn

+ Id string

+ Ip string

+ Send chan []byte

+ Token string

+ Type string

+ func (c *Client) Close()

+ func (c *Client) Notify(t, b string)

+ func (c *Client) Write(opCode int, payload []byte) error

+ func (c *Client) WritePump()

+ type Hub struct

+ func NewHub() *Hub

+ func (h *Hub) AddClient(client *Client)

+ func (h *Hub) Broadcast(message []byte)

+ func (h *Hub) Clients() (clients []*Client)

+ func (h *Hub) GetClientByIdAndType(clientId, clientType string) (client *Client, err error)

+ func (h *Hub) Recv(client *Client, b []byte)

+ func (h *Hub) Run()

+ func (h *Hub) Send(client *Client, message []byte)

+ func (h *Hub) Subscribe(command string, f func(client *Client, msg Message))

+ func (h *Hub) UnSubscribe(command string)

+ type Message struct

+ Command string

+ Forward string

+ Id uuid.UUID

+ Payload map[string]interface{}

+ Status string

+ func NewMessage(b []byte) (message Message, err error)

+ func (m *Message) Error(err error) *Message

+ func (m *Message) IsError() (err error)

+ func (m *Message) Pack() []byte

+ func (m *Message) Response(payload map[string]interface{}) *Message

+ func (m *Message) Success() *Message

+ type StreamService struct

+ Hub *Hub

+ func NewStreamService(hub *Hub, adaptors *adaptors.Adaptors) *StreamService

+ func (s *StreamService) Broadcast(message []byte)

+ func (s *StreamService) GetClientByIdAndType(clientId, clientType string) (client *Client, err error)

+ func (s *StreamService) Subscribe(command string, f func(client *Client, msg Message))

+ func (s *StreamService) UnSubscribe(command string)

+ func (w *StreamService) Ws(ctx *gin.Context)