mux

Mar 18, 2024

Changes in this version

+ var NoopLogger = &noopLoggerImpl

+ var StandardLogger = &standardLoggerImpl

+ type Logger interface

+ Debugf func(_ string, _ ...interface{})

+ Errorf func(_ string, _ ...interface{})

+ Infof func(_ string, _ ...interface{})

+ Warnf func(_ string, _ ...interface{})

type Option

+ func WithLogger(logger Logger) Option

Mar 8, 2024

Changes in this version

+ var ErrBufferLimited = errors.New("buffer length limited")

type Option

+ func WithMetrics(...) Option

Jun 12, 2023

Changes in this version

type Session

+ func (session *Session) Err() error

Jun 11, 2023

Changes in this version

type Option

+ func WithFinalizer(finalizer func()) Option

May 16, 2023

Changes in this version

type Option

+ func WithHeartBeatTTL(ttl time.Duration) Option

May 12, 2023

Changes in this version

type Option

+ func WithTransportRtoBound(min, max time.Duration) Option

May 11, 2023

Changes in this version

type Session

+ func (session *Session) Rto() time.Duration

+ func (session *Session) Rtt() time.Duration

+ func (session *Session) RttVar() time.Duration

+ func (session *Session) SRtt() time.Duration

Apr 17, 2023

Changes in this version

+ type NoneType struct

type Session

+ func (session *Session) BusyTrigger() <-chan NoneType

+ func (session *Session) IdleTrigger() <-chan NoneType

Apr 16, 2023

Changes in this version

type Session

+ func (session *Session) AcquireBusyFlag()

+ func (session *Session) ReleaseBusyFlag()

Apr 14, 2023

Changes in this version

type Session

+ func (session *Session) OpenStreamNoDelay(ctx context.Context) (*Stream, error)

type Stream

+ func (stream *Stream) Lifetime() time.Duration

Mar 4, 2023

Changes in this version

type Option

+ func WithMetricsTag(key, value string) Option

Mar 4, 2023

Changes in this version

+ var DispatchFrameDuration = promauto.NewHistogram(prometheus.HistogramOpts{ ... })

+ var SendFrameDuration = promauto.NewHistogram(prometheus.HistogramOpts{ ... })

type Session

+ func (session *Session) IsBusy() bool

Nov 27, 2022

Changes in this version

+ var GetDataFrameDuration = promauto.NewHistogram(prometheus.HistogramOpts{ ... })

+ var PreciseBuckets = []float64

Nov 8, 2022

Changes in this version

type Option

+ func WithBufferManager(allocFunc BufferAllocFunc, recycleFunc BufferRecycleFunc) Option

Jul 21, 2022

Changes in this version

type Stream

+ func (stream *Stream) ReadContext(ctx context.Context, buffer []byte) (int, error)

+ func (stream *Stream) WriteContext(ctx context.Context, buffer []byte) (int, error)

May 27, 2022

Changes in this version

+ var ErrConnReadWriteOps = errors.New("conn read write ops err")

+ var ErrSessionClosed = errors.New("session closed")

+ var ErrSessionTTLExceed = errors.New("session ttl exceed")

+ var ErrStreamIdDup = errors.New("stream id duplicated err")

+ var ErrStreamIdNotFound = errors.New("stream id not found")

May 27, 2022

Changes in this version

type Option

+ func WithHeartBeatInterval(interval time.Duration) Option

+ func WithHeartBeatSwitch(choose bool) Option

+ func WithReadTimeout(readTimeout time.Duration) Option

+ func WithReadWriteTimeout(readWriteTimeout time.Duration) Option

+ func WithTTL(ttl time.Duration) Option

+ func WithWriteTimeout(writeTimeout time.Duration) Option

type Session

+ func (session *Session) RTT() time.Duration

May 13, 2022

Changes in this version

type Frame

+ func (frame *Frame) MarshalHeader(buffer []byte) (int, error)

+ func (frame *Frame) UnMarshalHeader(buffer []byte) (int, error)

May 8, 2022

Changes in this version

+ var ErrReadBufferLimited = errors.New("read buffer limited")

+ var ErrReadTimeout = errors.New("read timeout")

+ var ErrStreamClosed = errors.New("stream has been closed")

+ var ErrWriteTimeout = errors.New("write timeout")

+ type Addr struct

+ func (addr *Addr) Network() string

+ func (addr *Addr) String() string

type Frame

+ func NewFrameContext(ctx context.Context, cmd cmdType, streamId uint32, data []byte) *Frame

type Option

+ func WithBufferSize(sizeLimit int) Option

type Stream

+ func (stream *Stream) LocalAddr() net.Addr

+ func (stream *Stream) RemoteAddr() net.Addr

+ func (stream *Stream) SetDeadline(t time.Time) error

+ func (stream *Stream) SetReadDeadline(t time.Time) error

+ func (stream *Stream) SetWriteDeadline(t time.Time) error

Mar 1, 2022

Changes in this version

type Session

+ func (session *Session) StreamCount() int

Feb 28, 2022

Changes in this version

type Option

+ func WithBufferSizeLimit(sizeLimit int) Option

Feb 20, 2022

Changes in this version

type Session

+ func (session *Session) Lifetime() time.Duration

Sep 8, 2021

Changes in this version

type Session

+ func (session *Session) Ctx() context.Context

Aug 30, 2021

Changes in this version

type Session

+ func NewSessionContext(ctx context.Context, conn io.ReadWriteCloser, options ...Option) *Session

+ func (session *Session) CreatedAt() time.Time

+ func (session *Session) Done() <-chan struct{}

type Stream

+ func (stream *Stream) Done() <-chan struct{}

Aug 1, 2021

Changes in this version

+ type BufferAllocFunc func() []byte

+ type BufferRecycleFunc func([]byte)

+ type Option func(*Session)

+ func WithBufferAllocFunc(f BufferAllocFunc) Option

+ func WithBufferRecycleFunc(f BufferRecycleFunc) Option

+ func WithKeepAliveInterval(interval uint8) Option

+ func WithKeepAliveSwitch(choose bool) Option

+ func WithKeepAliveTTL(ttl uint8) Option

+ func WithRole(role roleType) Option

Jul 23, 2021

Changes in this version

+ var SessionNilErr = errors.New("nil session ops err")

Jul 20, 2021

Changes in this version

type Session

+ func (session *Session) StreamsCounter() int

Jun 17, 2021

Changes in this version

type Session

+ func (session *Session) PutBuffer(buffer []byte)

Apr 19, 2021

Changes in this version

+ var SessionTTLExceed = errors.New("session ttl exceed")

Apr 13, 2021

Changes in this version

+ const BufferLength

+ const BufferLimit

+ const RoleClient

+ const RoleServer

+ var BufferSizeLimitErr = errors.New("buffer size limit err")

+ var ConnReadWriteOpsErr = errors.New("conn read write ops err")

+ var SessionClosedErr = errors.New("session closed")

+ var StreamClosedErr = errors.New("stream has been closed")

+ var StreamIdDupErr = errors.New("stream id duplicated err")

+ var StreamIdNotFoundErr = errors.New("stream id not found")

+ var StreamNotFoundErr = errors.New("stream not found")

+ var UnknownCmdErr = errors.New("cmd unknown err")

+ func GetBuffer() []byte

+ func PutBuffer(buffer []byte)

+ type Frame struct

+ func NewFrame(cmd cmdType, streamId uint32, data []byte) *Frame

+ func (frame *Frame) Close() error

+ func (frame *Frame) Cmd() byte

+ func (frame *Frame) Marshal(buffer []byte) (int, error)

+ func (frame *Frame) StreamId() uint32

+ func (frame *Frame) UnMarshal(buffer []byte) (int, error)

+ type Session struct

+ func NewSession(conn io.ReadWriteCloser, role roleType, configPtr *SessionConfig) *Session

+ func (session *Session) Accept() (io.ReadWriteCloser, error)

+ func (session *Session) AcceptStream() (*Stream, error)

+ func (session *Session) Close() error

+ func (session *Session) CloseWithErr(err error)

+ func (session *Session) IsClose() bool

+ func (session *Session) Open() (io.ReadWriteCloser, error)

+ func (session *Session) OpenStream() (*Stream, error)

+ type SessionConfig struct

+ type Stream struct

+ func NewStream(streamId uint32, session *Session) *Stream

+ func (stream *Stream) Close() error

+ func (stream *Stream) IsClose() bool

+ func (stream *Stream) Read(buffer []byte) (int, error)

+ func (stream *Stream) Write(buffer []byte) (int, error)