MCPcopy Create free account
hub / github.com/cloudbase/garm / writeMessage

Method writeMessage

websocket/client.go:197–207  ·  view source on GitHub ↗
(messageType int, message []byte)

Source from the content-addressed store, hash-verified

195}
196
197func (c *Client) writeMessage(messageType int, message []byte) error {
198 c.writeMux.Lock()
199 defer c.writeMux.Unlock()
200 if err := c.conn.SetWriteDeadline(time.Now().Add(writeWait)); err != nil {
201 return fmt.Errorf("failed to set write deadline: %w", err)
202 }
203 if err := c.conn.WriteMessage(messageType, message); err != nil {
204 return fmt.Errorf("failed to write message: %w", err)
205 }
206 return nil
207}
208
209// clientWriter
210func (c *Client) clientWriter() {

Callers 2

StopMethod · 0.95
clientWriterMethod · 0.95

Calls 3

AddMethod · 0.80
LockMethod · 0.65
UnlockMethod · 0.65

Tested by

no test coverage detected