engineio

package

v0.0.4 Latest Latest Go to latest Published: Apr 18, 2021 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

func Connect(ctx context.Context, conn gomasio.Conn, handler Handler) error

func NewWriter(wf gomasio.WriteFlusher, packetType PacketType) gomasio.WriteFlusher

func NewWriterFactory(wf gomasio.WriterFactory) gomasio.WriterFactory

func WritePing(w io.Writer) error

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

func NewDecoder(r io.Reader) *Decoder

func (d *Decoder) Decode() (*Packet, error)

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

func NewEncoder(w io.Writer) *Encoder

func (e *Encoder) Encode(packet *Packet) error

type HandleFunc func(wf gomasio.WriterFactory, body io.Reader)

func (f HandleFunc) HandleMessage(wf gomasio.WriterFactory, body io.Reader)

type Handler interface {
	HandleMessage(wf gomasio.WriterFactory, body io.Reader)
}

type Packet struct {
	Type PacketType
	Body io.Reader
}

type PacketType int

const (
	OPEN PacketType = iota
	CLOSE
	PING
	PONG
	MESSAGE
	UPGRADE
	NOOP

	INVALID PacketType = -1
)

type Session struct {
	ID           string `json:"sid"`
	PingInterval int    `json:"pingInterval"`
	PingTimeout  int    `json:"pingTimeout"`
}