socket

Feb 22, 2024

Changes in this version

type Socket

+ func (s *Socket) OnBeforeConnect(cb func(s *Socket))

Feb 21, 2024

Changes in this version

type Option

+ func WithAuthTokenFn(tokenGen func() string) Option

Feb 21, 2024

Changes in this version

+ type Option = func(*Socket)

+ func WithAuth(auth map[string]any) Option

+ func WithAuthToken(token string) Option

Feb 21, 2024

Changes in this version

type Socket

+ func (s *Socket) IO() *engine.Socket

Feb 3, 2024

Changes in this version

+ type Buffer struct

+ B []byte

+ func (b *Buffer) UnmarshalJSON(data []byte) (err error)

+ func (b Buffer) MarshalJSON() ([]byte, error)

+ type ConnectError struct

+ Reason string

+ func (e *ConnectError) Error() string

+ type Packet struct

+ func (p *Packet) Attachments() [][]byte

+ func (p *Packet) Id() int

+ func (p *Packet) SetData(args ...any) (err error)

+ func (p *Packet) SetId(id int)

+ func (p *Packet) String() string

+ func (p *Packet) Type() PacketType

+ func (p *Packet) UnmarshalBinary(data []byte) (err error)

+ func (p *Packet) UnmarshalData(ptr any) (err error)

+ func (p *Packet) WriteTo(w io.Writer) (n int64, err error)

+ type PacketType int8

+ const ACK

+ const BINARY_ACK

+ const BINARY_EVENT

+ const CONNECT

+ const CONNECT_ERROR

+ const DISCONNECT

+ const EVENT

+ func (t PacketType) ID() byte

+ func (t PacketType) String() string

+ type Socket struct

+ func NewSocket(io *engine.Socket) (s *Socket)

+ func (s *Socket) Close() (err error)

+ func (s *Socket) Connect(namespace string) (err error)

+ func (s *Socket) Emit(event string, args ...any) (err error)

+ func (s *Socket) EmitWithAck(event string, args ...any) (<-chan []any, error)

+ func (s *Socket) ID() string

+ func (s *Socket) Namespace() string

+ func (s *Socket) OnConnect(cb func(s *Socket, namespace string))

+ func (s *Socket) OnDisconnect(cb func(s *Socket, namespace string))

+ func (s *Socket) OnError(cb func(s *Socket, err error))

+ func (s *Socket) OnMessage(cb func(event string, args []any))

+ func (s *Socket) OnPacket(cb func(s *Socket, pkt *Packet))

+ func (s *Socket) OnceConnect(cb func(s *Socket, namespace string))

+ func (s *Socket) OnceDisconnect(cb func(s *Socket, namespace string))

+ func (s *Socket) OnceError(cb func(s *Socket, err error))

+ func (s *Socket) OnceMessage(cb func(event string, args []any))

+ func (s *Socket) OncePacket(cb func(s *Socket, pkt *Packet))

+ func (s *Socket) Status() SocketStatus

+ type SocketStatus = int32

+ const SocketClosed

+ const SocketConnected

+ const SocketOpening

+ type UnexpectedPacketTypeError struct

+ Type PacketType

+ func (e *UnexpectedPacketTypeError) Error() string

+ type UnexpectedTokenError struct

+ Token byte

+ func (e *UnexpectedTokenError) Error() string