socketio

Documentation

Index

• Variables
• func EncodePacket(p Packet) (string, error)
• type Client
  • func NewClient(url string, logger *logrus.Logger) *Client
  • func (c *Client) Handle(h Handler)
  • func (c *Client) HandleFunc(fn func(p *Packet))
  • func (c *Client) HandleMessage(msg string) error
  • func (c *Client) NextReqID() int
  • func (c *Client) Open() error
  • func (c *Client) Send(data []interface{}) error
  • func (c *Client) SendAck(data []interface{}) ([]interface{}, error)
  • func (c *Client) SendPacket(p Packet) error
  • func (c *Client) SendPacketAck(p Packet) ([]interface{}, error)
• type Handler
• type HandlerFunc
  • func (f HandlerFunc) HandleMessage(packet *Packet)
• type Packet
  • func DecodePacket(data string) (Packet, error)
  • func NewAckPacket(p *Packet, data []interface{}) Packet
• type PacketType
  • func (pt PacketType) String() string

Variables

var (
	ErrorEmptyPacket = errors.New("packet length should be at least 1 byte")
	ErrorNullPacket  = errors.New("packet length should be at least 1")
)

Functions

func EncodePacket

func EncodePacket(p Packet) (string, error)

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(url string, logger *logrus.Logger) *Client

func (*Client) Handle

func (c *Client) Handle(h Handler)

func (*Client) HandleFunc

func (c *Client) HandleFunc(fn func(p *Packet))

func (*Client) HandleMessage

func (c *Client) HandleMessage(msg string) error

HandleMessage handles Event.IO Message.

func (*Client) NextReqID

func (c *Client) NextReqID() int

func (*Client) Open

func (c *Client) Open() error

func (*Client) Send

func (c *Client) Send(data []interface{}) error

func (*Client) SendAck

func (c *Client) SendAck(data []interface{}) ([]interface{}, error)

func (*Client) SendPacket

func (c *Client) SendPacket(p Packet) error

func (*Client) SendPacketAck

func (c *Client) SendPacketAck(p Packet) ([]interface{}, error)

type Handler

type Handler interface {
	HandleMessage(packet *Packet)
}

type HandlerFunc

type HandlerFunc func(packet *Packet)

func (HandlerFunc) HandleMessage

func (f HandlerFunc) HandleMessage(packet *Packet)

type Packet

type Packet struct {
	Type PacketType
	ID   *int
	Data []interface{}
}

func DecodePacket

func DecodePacket(data string) (Packet, error)

func NewAckPacket

func NewAckPacket(p *Packet, data []interface{}) Packet

type PacketType

type PacketType int

const (
	Connect PacketType = iota
	Disconnect
	Event
	Ack
	Error
	BinaryEvent
	BinaryAck
)

func (PacketType) String

func (pt PacketType) String() string