smgr

Documentation

Index

• Constants
• type GetFuncEx
• type PoolManager
  • func (mgr *PoolManager) Destroy()
• type Session
  • func (s *Session) AcceptStream() (*Stream, error)
  • func (s *Session) Close() error
  • func (s *Session) OpenStreamSync(streamUse api.UseType) (*Stream, error)
• type Stream
• type StreamManager
  • func NewStreamManager(streamMax int, autoFree bool, session quic.Session) *StreamManager
  • func (mgr *StreamManager) AddStream(stream *Stream)
  • func (mgr *StreamManager) Destroy()
  • func (mgr *StreamManager) FreeStream(stream *Stream)
  • func (mgr *StreamManager) GetStream(useType api.UseType, autoDispatch bool, getFuncEx GetFuncEx) (quic.Stream, error)
  • func (mgr *StreamManager) ReleaseStream(useType api.UseType, stream quic.Stream)

Constants

const (
	NumStreamsMax = 99

	PoolStreamMinDefault = 2
	ThresholdDefault     = 0.8
)

Types

type GetFuncEx

type GetFuncEx func(api.UseType, bool) (*Stream, error)

get stream from session AcceptStream or OpenStreamXX

type PoolManager

type PoolManager struct {
	// contains filtered or unexported fields
}

func (*PoolManager) Destroy

func (mgr *PoolManager) Destroy()

type Session

type Session struct {
	Sess quic.Session
}

func (*Session) AcceptStream

func (s *Session) AcceptStream() (*Stream, error)

func (*Session) Close

func (s *Session) Close() error

func (*Session) OpenStreamSync

func (s *Session) OpenStreamSync(streamUse api.UseType) (*Stream, error)

type Stream

type Stream struct {
	// the use type of stream only be stream or message
	UseType api.UseType
	// quic stream
	Stream quic.Stream
}

wrapper for session manager

type StreamManager

type StreamManager struct {
	NumStreamsMax int
	Session       *Session
	// contains filtered or unexported fields
}

func NewStreamManager

func NewStreamManager(streamMax int, autoFree bool, session quic.Session) *StreamManager

func (*StreamManager) AddStream

func (mgr *StreamManager) AddStream(stream *Stream)

func (*StreamManager) Destroy

func (mgr *StreamManager) Destroy()

func (*StreamManager) FreeStream

func (mgr *StreamManager) FreeStream(stream *Stream)

func (*StreamManager) GetStream

func (mgr *StreamManager) GetStream(useType api.UseType, autoDispatch bool, getFuncEx GetFuncEx) (quic.Stream, error)

func (*StreamManager) ReleaseStream

func (mgr *StreamManager) ReleaseStream(useType api.UseType, stream quic.Stream)