socket

Documentation

Index

• type MSG
• type Message
• type Socket
  • func New(ctx context.Context, socket *websocket.Conn, leave chan *Socket, ...) *Socket
  • func (s *Socket) Close()
  • func (s *Socket) Context() context.Context
  • func (s *Socket) Ping()
  • func (s *Socket) Read() chan []byte
  • func (s *Socket) Write(msg []byte)

Types

type MSG

type MSG struct {
	MT int
	MD []byte
}

type Message

type Message struct {
	Data   []byte
	Socket *Socket
}

type Socket

type Socket struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, socket *websocket.Conn, leave chan *Socket, event chan *Message) *Socket

New - return new Socket connection

func (*Socket) Close

func (s *Socket) Close()

func (*Socket) Context

func (s *Socket) Context() context.Context

func (*Socket) Ping

func (s *Socket) Ping()

Ping connection to be online

func (*Socket) Read

func (s *Socket) Read() chan []byte

func (*Socket) Write

func (s *Socket) Write(msg []byte)