websockets

Documentation

Index

• type BroadcastServer
  • func NewBroadcastServer(ctx context.Context, source <-chan Message) BroadcastServer
• type Client
• type Message
• type Server
  • func NewServer() *Server
  • func (s *Server) HandleClientConnection(w http.ResponseWriter, r *http.Request)
  • func (s *Server) RemoveClient(clientID string)
  • func (s *Server) SendCommand(clientID string, msg Message) error
  • func (s *Server) SendCommandWithBroadcast(clientID string, msg Message) (BroadcastServer, error)

Types

type BroadcastServer

type BroadcastServer interface {
	Subscribe() <-chan Message
	CancelSubscription(<-chan Message)
	Close()
}

func NewBroadcastServer

func NewBroadcastServer(ctx context.Context, source <-chan Message) BroadcastServer

type Client

type Client struct {
	ID        string
	Conn      *websocket.Conn
	Broadcast BroadcastServer
}

type Message

type Message struct {
	ClientID string
	Type     string `json:"type"` // e.g., "command", "response"
	Content  string `json:"content"`
}

type Server

type Server struct {
	Clients    map[string]*Client
	ClientsMux sync.Mutex
}

func NewServer

func NewServer() *Server

func (*Server) HandleClientConnection

func (s *Server) HandleClientConnection(w http.ResponseWriter, r *http.Request)

func (*Server) RemoveClient

func (s *Server) RemoveClient(clientID string)

func (*Server) SendCommand

func (s *Server) SendCommand(clientID string, msg Message) error

func (*Server) SendCommandWithBroadcast

func (s *Server) SendCommandWithBroadcast(clientID string, msg Message) (BroadcastServer, error)