wsocket

README

wsocket

una implementación del protocolo WebSocket un poco diferente escrita en Go

para uso general chat o x sistema. en la carpeta test hay un ejemplo de su uso.

saludos# wsocket

wsocket

Documentation

Index

• type BinaryHandler
• type WebSocket
  • func New(models []model.Object, buffer_size, concurrency_max int, ...) *WebSocket
  • func (h *WebSocket) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (h *WebSocket) StartBroadcasting(in <-chan *model.Request)
  • func (h *WebSocket) UserAdd(users ...*model.User)
  • func (hub *WebSocket) UserRemove(a *model.User)

Types

type BinaryHandler

type BinaryHandler interface {
	BinaryHandler(data_in []byte, out chan<- *model.Request)
}

type WebSocket

type WebSocket struct {

	//canal de entrada nuevas solicitudes.
	REQUESTS_IN chan *model.Request

	// canal salida de solicitudes
	REQUESTS_OUT chan *model.Request

	// canal que avisa el cierre de las conexiones
	CLOSED_CONNECTION chan *model.User

	*cutkey.Cut
	// contains filtered or unexported fields
}

concentrador de solicitantes para websocket

func New

func New(models []model.Object, buffer_size, concurrency_max int, allowed_origins ...string) *WebSocket

models mapa con los modelos de objetos que utiliza el sistema allowed_origins ej: "http://localhost", "http://127.0.0.1", "http://example.com", "https://example.com" buffer_size ej: 1024 concurrency_max Limitar la concurrencia de conexiones simultáneas ej 100

func (*WebSocket) ServeHTTP

func (h *WebSocket) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*WebSocket) StartBroadcasting

func (h *WebSocket) StartBroadcasting(in <-chan *model.Request)

func (*WebSocket) UserAdd

func (h *WebSocket) UserAdd(users ...*model.User)

func (*WebSocket) UserRemove

func (hub *WebSocket) UserRemove(a *model.User)