connection

Documentation

Index

• Constants
• type Connection
  • func NewConnection(wsConn net.Conn, log *zap.Logger) *Connection
  • func (c *Connection) Close() error
  • func (c *Connection) Read() ([]byte, ws.OpCode, error)
  • func (c *Connection) Write(data []byte) error

Constants

const EOF string = "EOF"

Types

type Connection

type Connection struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Connection represents wrapped and safe to use from the different threads websocket connection

func NewConnection

func NewConnection(wsConn net.Conn, log *zap.Logger) *Connection

func (*Connection) Close

func (c *Connection) Close() error

func (*Connection) Read

func (c *Connection) Read() ([]byte, ws.OpCode, error)

func (*Connection) Write

func (c *Connection) Write(data []byte) error