Versions in this module Expand all Collapse all v1 v1.0.0 Jun 9, 2023 Changes in this version + type Config struct + AcceptBacklog uint32 + MaxWindowSize uint32 + NewFramer func(io.Reader, io.Writer) frame.Framer + type ErrorCode uint32 + const AcceptQueueFull + const EnhanceYourCalm + const ErrorUnknown + const FlowControlError + const FrameSizeError + const InternalError + const NoError + const PeerEOF + const ProtocolError + const RemoteGoneAway + const SessionClosed + const StreamCancelled + const StreamClosed + const StreamRefused + const StreamReset + const StreamsExhausted + const WriteTimeout + func GetError(err error) (ErrorCode, error) + type Heartbeat struct + func NewHeartbeat(sess TypedStreamSession, cb func(time.Duration), config *HeartbeatConfig) *Heartbeat + func (h *Heartbeat) Accept() (net.Conn, error) + func (h *Heartbeat) AcceptStream() (Stream, error) + func (h *Heartbeat) AcceptTypedStream() (TypedStream, error) + func (h *Heartbeat) Beat() time.Duration + func (h *Heartbeat) Close() error + func (h *Heartbeat) SetInterval(d time.Duration) + func (h *Heartbeat) SetTolerance(d time.Duration) + func (h *Heartbeat) Start() + type HeartbeatConfig struct + Interval time.Duration + Tolerance time.Duration + Type StreamType + func NewHeartbeatConfig() *HeartbeatConfig + type HeartbeatSession interface + Beat func() time.Duration + SetInterval func(d time.Duration) + SetTolerance func(d time.Duration) + Start func() + type Session interface + Accept func() (net.Conn, error) + AcceptStream func() (Stream, error) + Addr func() net.Addr + Close func() error + LocalAddr func() net.Addr + Open func() (net.Conn, error) + OpenStream func() (Stream, error) + RemoteAddr func() net.Addr + Wait func() (error, error, []byte) + func Client(trans io.ReadWriteCloser, config *Config) Session + func Server(trans io.ReadWriteCloser, config *Config) Session + type Stream interface + Close func() error + CloseWrite func() error + Id func() uint32 + LocalAddr func() net.Addr + Read func([]byte) (int, error) + RemoteAddr func() net.Addr + Session func() Session + SetDeadline func(time.Time) error + SetReadDeadline func(time.Time) error + SetWriteDeadline func(time.Time) error + Write func([]byte) (int, error) + type StreamType uint32 + type TypedStream interface + StreamType func() StreamType + type TypedStreamSession interface + AcceptTypedStream func() (TypedStream, error) + OpenTypedStream func(stype StreamType) (Stream, error) + func NewTypedStreamSession(s Session) TypedStreamSession Other modules containing this package golang.ngrok.com/muxado/v2
Go to main page