Versions in this module Expand all Collapse all v0 v0.1.1 Oct 15, 2023 Changes in this version + const Version1 + const Version2 + const VersionDraft29 + const VersionTLS + func UnlinkUdsFile(network, addr string) error + type ApplicationError interface + ErrCode func() uint64 + type Conn interface + SetReadTimeout func(t time.Duration) error + SetWriteTimeout func(t time.Duration) error + type ConnTLSer interface + ConnectionState func() tls.ConnectionState + Handshake func() error + type DialFunc func(addr string) (Conn, error) + type Dialer interface + AddTLS func(conn Conn, tlsConfig *tls.Config) (Conn, error) + DialConnection func(network, address string, timeout time.Duration, tlsConfig *tls.Config) (conn Conn, err error) + DialTimeout func(network, address string, timeout time.Duration, tlsConfig *tls.Config) (conn net.Conn, err error) + type ErrorNormalization interface + ToHertzError func(err error) error + type ExtWriter interface + Finalize func() error + Flush func() error + type HandleSpecificError interface + HandleSpecificError func(err error, rip string) (needIgnore bool) + type OnData func(ctx context.Context, conn interface{}) error + type ReadWriter interface + type Reader interface + Len func() int + Peek func(n int) ([]byte, error) + ReadBinary func(n int) (p []byte, err error) + ReadByte func() (byte, error) + Release func() error + Skip func(n int) error + type ReceiveStream interface + CancelRead func(err ApplicationError) + SetReadDeadline func(t time.Time) error + StreamID func() int64 + type SendStream interface + CancelWrite func(err ApplicationError) + Context func() context.Context + SetWriteDeadline func(t time.Time) error + StreamID func() int64 + type Stream interface + type StreamConn interface + CloseWithError func(err ApplicationError, errMsg string) error + Context func() context.Context + GetRawConnection func() interface{} + GetVersion func() uint32 + HandshakeComplete func() context.Context + LocalAddr func() net.Addr + RemoteAddr func() net.Addr + type Streamer interface + AcceptStream func(context.Context) (Stream, error) + AcceptUniStream func(context.Context) (ReceiveStream, error) + OpenStream func() (Stream, error) + OpenStreamSync func(context.Context) (Stream, error) + OpenUniStream func() (SendStream, error) + OpenUniStreamSync func(context.Context) (SendStream, error) + type Transporter interface + Close func() error + ListenAndServe func(onData OnData) error + Shutdown func(ctx context.Context) error + type Writer interface + Flush func() error + Malloc func(n int) (buf []byte, err error) + WriteBinary func(b []byte) (n int, err error) + func NewWriter(w io.Writer) Writer