webtrans

Documentation

Index

• type Session
  • func NewSession(id string, quicSession quic.Session, signal *Signal) *Session
  • func (s *Session) Close()
  • func (s *Session) Emit(header string, body string) error
  • func (s *Session) HandleBidStream(origin, path string)
  • func (s *Session) HandleWebTrans()
  • func (s *Session) ID() string
  • func (s *Session) On(header string, cb proto.SessionCallback)
• type Signal
  • func NewSignal(port int, certFile, keyFile string) *Signal
  • func (s *Signal) OnAuth(cb proto.AuthCallback)
  • func (s *Signal) OnClose(cb proto.SignalCallback)
  • func (s *Signal) OnConnect(cb proto.SignalCallback)
  • func (s *Signal) Run() error

Types

type Session

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

func NewSession

func NewSession(id string, quicSession quic.Session, signal *Signal) *Session

func (*Session) Close

func (s *Session) Close()

func (*Session) Emit

func (s *Session) Emit(header string, body string) error

func (*Session) HandleBidStream

func (s *Session) HandleBidStream(origin, path string)

func (*Session) HandleWebTrans

func (s *Session) HandleWebTrans()

HandleWebTrans 处理webTransport相关逻辑

func (*Session) ID

func (s *Session) ID() string

func (*Session) On

func (s *Session) On(header string, cb proto.SessionCallback)

type Signal

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

func NewSignal

func NewSignal(port int, certFile, keyFile string) *Signal

func (*Signal) OnAuth

func (s *Signal) OnAuth(cb proto.AuthCallback)

func (*Signal) OnClose

func (s *Signal) OnClose(cb proto.SignalCallback)

func (*Signal) OnConnect

func (s *Signal) OnConnect(cb proto.SignalCallback)

func (*Signal) Run

func (s *Signal) Run() error