engineio_v4_client_transport

Documentation

Index

• type EngineTransportOption
  • func WithLogger(logger Logger) EngineTransportOption
  • func WithOrigin(origin *url.URL) EngineTransportOption
  • func WithWebSocket(ws WebSocket) EngineTransportOption
• type Logger
• type Transport
  • func NewTransport(options ...EngineTransportOption) (*Transport, error)
  • func (c *Transport) RequestHandshake() error
  • func (c *Transport) Run(ctx context.Context, url *url.URL, sid string, messagesChan chan<- []byte, ...) error
  • func (c *Transport) SendMessage(msg []byte) error
  • func (c *Transport) SetHandshake(handshake *engineio_v4.HandshakeResponse)
  • func (c *Transport) Stop() (err error)
  • func (c *Transport) Transport() engineio_v4.EngineIOTransport
• type WebSocket

Types

type EngineTransportOption

type EngineTransportOption func(*Transport) error

func WithLogger

func WithLogger(logger Logger) EngineTransportOption

func WithOrigin

func WithOrigin(origin *url.URL) EngineTransportOption

func WithWebSocket

func WithWebSocket(ws WebSocket) EngineTransportOption

type Logger

type Logger interface {
	Debugf(format string, v ...any)
	Infof(format string, v ...any)
	Warnf(format string, v ...any)
	Errorf(format string, v ...any)
}

type Transport

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

func NewTransport

func NewTransport(options ...EngineTransportOption) (*Transport, error)

func (*Transport) RequestHandshake

func (c *Transport) RequestHandshake() error

func (*Transport) Run

func (c *Transport) Run(
	ctx context.Context,
	url *url.URL,
	sid string,
	messagesChan chan<- []byte,
	onClose chan<- error,
) error

func (*Transport) SendMessage

func (c *Transport) SendMessage(msg []byte) error

func (*Transport) SetHandshake

func (c *Transport) SetHandshake(handshake *engineio_v4.HandshakeResponse)

func (*Transport) Stop

func (c *Transport) Stop() (err error)

func (*Transport) Transport

func (c *Transport) Transport() engineio_v4.EngineIOTransport

type WebSocket

type WebSocket interface {
	Dial(ctx context.Context, url *url.URL, origin *url.URL) (err error)
	Send(v []byte) (err error)
	Receive(v *[]byte) (err error)
	Close() error
}