Versions in this module Expand all Collapse all v0 v0.1.0 Dec 19, 2023 Changes in this version + var ErrConnectionWriteTimeout = &Error + var ErrDuplicateStream = &Error + var ErrInvalidMsgType = &Error + var ErrInvalidVersion = &Error + var ErrKeepAliveTimeout = &Error + var ErrRecvWindowExceeded = &Error + var ErrRemoteGoAway = &Error + var ErrSessionShutdown = &Error + var ErrStreamClosed = &Error + var ErrStreamReset = &Error + var ErrStreamsExhausted = &Error + var ErrTimeout = &Error + var ErrUnexpectedFlag = &Error + func VerifyConfig(config *Config) error + type Config struct + AcceptBacklog int + ConnectionWriteTimeout time.Duration + EnableKeepAlive bool + InitialStreamWindowSize uint32 + KeepAliveInterval time.Duration + LogOutput io.Writer + MaxIncomingStreams uint32 + MaxMessageSize uint32 + MaxStreamWindowSize uint32 + MeasureRTTInterval time.Duration + PingBacklog int + ReadBufSize int + WriteCoalesceDelay time.Duration + func DefaultConfig() *Config + type Error struct + func (ye *Error) Error() string + func (ye *Error) Temporary() bool + func (ye *Error) Timeout() bool + type MemoryManager interface + Done func() + ReleaseMemory func(size int) + ReserveMemory func(size int, prio uint8) error + type Session struct + func Client(conn net.Conn, config *Config, mm func() (MemoryManager, error)) (*Session, error) + func Server(conn net.Conn, config *Config, mm func() (MemoryManager, error)) (*Session, error) + func (s *Session) Accept() (net.Conn, error) + func (s *Session) AcceptStream() (*Stream, error) + func (s *Session) Addr() net.Addr + func (s *Session) Close() error + func (s *Session) CloseChan() <-chan struct{} + func (s *Session) GoAway() error + func (s *Session) IsClosed() bool + func (s *Session) LocalAddr() net.Addr + func (s *Session) NumStreams() int + func (s *Session) Open(ctx context.Context) (net.Conn, error) + func (s *Session) OpenStream(ctx context.Context) (*Stream, error) + func (s *Session) Ping() (dur time.Duration, err error) + func (s *Session) RemoteAddr() net.Addr + type Stream struct + func (s *Stream) Close() error + func (s *Stream) CloseRead() error + func (s *Stream) CloseWrite() error + func (s *Stream) LocalAddr() net.Addr + func (s *Stream) Read(b []byte) (n int, err error) + func (s *Stream) RemoteAddr() net.Addr + func (s *Stream) Reset() error + func (s *Stream) Session() *Session + func (s *Stream) SetDeadline(t time.Time) error + func (s *Stream) SetReadDeadline(t time.Time) error + func (s *Stream) SetWriteDeadline(t time.Time) error + func (s *Stream) StreamID() uint32 + func (s *Stream) Write(b []byte) (int, error)
Go to main page