Documentation
¶
Index ¶
- func Start(port int, opts ServerOptions) error
- type Server
- type ServerOptions
- type WebSocketReader
- func (wr *WebSocketReader) Close()
- func (wr *WebSocketReader) MessageChan() <-chan types.Message
- func (wr *WebSocketReader) Read(p []byte) (n int, err error)
- func (wr *WebSocketReader) Start()
- func (wr *WebSocketReader) Subscribe(id string) chan types.Message
- func (wr *WebSocketReader) Unsubscribe(id string)
- type WebSocketWriter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Server represents the chat server
type ServerOptions ¶
type ServerOptions struct {
Verbose bool // Enable verbose logging
}
ServerOptions represents the configuration options for the chat server
type WebSocketReader ¶
type WebSocketReader struct {
// contains filtered or unexported fields
}
WebSocketReader implements types.StdinReader for WebSocket connections
func NewWebSocketReader ¶
func NewWebSocketReader(conn *websocket.Conn) *WebSocketReader
NewWebSocketReader creates a new WebSocket reader
func (*WebSocketReader) Close ¶
func (wr *WebSocketReader) Close()
func (*WebSocketReader) MessageChan ¶
func (wr *WebSocketReader) MessageChan() <-chan types.Message
func (*WebSocketReader) Read ¶
func (wr *WebSocketReader) Read(p []byte) (n int, err error)
Read implements io.Reader interface
func (*WebSocketReader) Start ¶
func (wr *WebSocketReader) Start()
func (*WebSocketReader) Subscribe ¶
func (wr *WebSocketReader) Subscribe(id string) chan types.Message
func (*WebSocketReader) Unsubscribe ¶
func (wr *WebSocketReader) Unsubscribe(id string)
type WebSocketWriter ¶
type WebSocketWriter struct {
// contains filtered or unexported fields
}
WebSocketWriter implements io.Writer for WebSocket connections
func NewWebSocketWriter ¶
func NewWebSocketWriter(onWrite func(data []byte) error, verbose bool) *WebSocketWriter
Source Files
Click to show internal directories.
Click to hide internal directories.