pham

Documentation

Index

• func SSEHandler(w http.ResponseWriter, r *http.Request)
• func WSHandler(w http.ResponseWriter, r *http.Request)
• type Connection
• type ConnectionManager
  • func NewConnectionManager() (connectionManager *ConnectionManager)
  • func (manager *ConnectionManager) AddConnection(conn Connection)
  • func (manager *ConnectionManager) Broadcast(data JSON) (length int, err error)
  • func (manager *ConnectionManager) ConnEach(f func([]Connection))
  • func (manager *ConnectionManager) DelConnection(conn Connection)
• type JSON
• type Message

Functions

func SSEHandler

func SSEHandler(w http.ResponseWriter, r *http.Request)

SSEHandler for gin framework route handler

func WSHandler

func WSHandler(w http.ResponseWriter, r *http.Request)

WSHandler is websocket end point

Types

type Connection

type Connection interface {
	Send(data []byte) (err error)
}

Connection interface

type ConnectionManager

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

ConnectionManager structure

func NewConnectionManager

func NewConnectionManager() (connectionManager *ConnectionManager)

NewConnectionManager is ConnectionManager constructor

func (*ConnectionManager) AddConnection

func (manager *ConnectionManager) AddConnection(conn Connection)

AddConnection add connection to connections

func (*ConnectionManager) Broadcast

func (manager *ConnectionManager) Broadcast(data JSON) (length int, err error)

Broadcast message

func (*ConnectionManager) ConnEach

func (manager *ConnectionManager) ConnEach(f func([]Connection))

ConnEach get connections safety

func (*ConnectionManager) DelConnection

func (manager *ConnectionManager) DelConnection(conn Connection)

DelConnection delete connection from connections

type JSON

type JSON map[string]interface{}

JSON is json type

type Message

type Message struct {
	Channel string
	TTL     int
	Data    JSON
}

Message is JSON structure