Documentation ¶
Index ¶
- Constants
- func NewPollingTransport(ival time.Duration) func(SessionID, Codec) Transporter
- func NewWebsocketTransport() func(SessionID, Codec) Transporter
- type Codec
- type HTTPCompressionKind
- type Name
- type Option
- type PollingTransport
- type SessionID
- type Transport
- type Transporter
- type WebsocketTransport
Constants ¶
View Source
const ( ErrTransportDecode errStr = "[%s] transport decode: %w" ErrTransportEncode errStr = "[%s] transport encode: %w" ErrUnsupportedMethod errStr = "%s not supported" )
Variables ¶
This section is empty.
Functions ¶
func NewPollingTransport ¶
func NewPollingTransport(ival time.Duration) func(SessionID, Codec) Transporter
func NewWebsocketTransport ¶
func NewWebsocketTransport() func(SessionID, Codec) Transporter
Types ¶
type Codec ¶
type Codec struct { eiop.PacketEncoder eiop.PacketDecoder eiop.PayloadEncoder eiop.PayloadDecoder }
type HTTPCompressionKind ¶
type HTTPCompressionKind string
const (
CompressGZIP HTTPCompressionKind = "gzip"
)
type Option ¶
type Option func(Transporter)
func WithHTTPCompression ¶
func WithHTTPCompression(kind HTTPCompressionKind) Option
func WithPerMessageDeflate ¶
func WithPerMessageDeflate(kind HTTPCompressionKind) Option
type PollingTransport ¶
type PollingTransport struct { *Transport // contains filtered or unexported fields }
func (*PollingTransport) Run ¶
func (t *PollingTransport) Run(_w http.ResponseWriter, r *http.Request, opts ...Option) (err error)
type Transporter ¶
type WebsocketTransport ¶
type WebsocketTransport struct { *Transport PingMsg string // contains filtered or unexported fields }
func (*WebsocketTransport) Run ¶
func (t *WebsocketTransport) Run(w http.ResponseWriter, r *http.Request, opts ...Option) (err error)
Click to show internal directories.
Click to hide internal directories.