transport

Documentation

Index

• type Callbacks
  • func NewCallbacks() *Callbacks
  • func (c *Callbacks) OnClose(transportName string, err error)
  • func (c *Callbacks) OnPacket(packet ...*parser.Packet)
  • func (c *Callbacks) Set(onPacket PacketCallback, onClose CloseCallback)
• type CloseCallback
• type PacketCallback
• type RequestHeader
  • func NewRequestHeader(header http.Header) *RequestHeader
  • func (r *RequestHeader) Del(key string)
  • func (r *RequestHeader) Get(key string) string
  • func (r *RequestHeader) Header() http.Header
  • func (r *RequestHeader) Set(key, value string)

Types

type Callbacks

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

func NewCallbacks

func NewCallbacks() *Callbacks

func (*Callbacks) OnClose

func (c *Callbacks) OnClose(transportName string, err error)

func (*Callbacks) OnPacket

func (c *Callbacks) OnPacket(packet ...*parser.Packet)

func (*Callbacks) Set

func (c *Callbacks) Set(onPacket PacketCallback, onClose CloseCallback)

type CloseCallback

type CloseCallback func(transportName string, err error)

type PacketCallback

type PacketCallback func(packet ...*parser.Packet)

type RequestHeader

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

A concurrent HTTP request header.

func NewRequestHeader

func NewRequestHeader(header http.Header) *RequestHeader

func (*RequestHeader) Del

func (r *RequestHeader) Del(key string)

func (*RequestHeader) Get

func (r *RequestHeader) Get(key string) string

func (*RequestHeader) Header

func (r *RequestHeader) Header() http.Header

func (*RequestHeader) Set

func (r *RequestHeader) Set(key, value string)