quicx

Documentation

Overview

Package quicx Create on 2023/8/5 @author xuzhuoxi

Index

• Variables
• type IQUICServer
  • func NewQuicServer() IQUICServer
• type IQuicClient
  • func NewQUICClient() IQuicClient
• type QUICClient
  • func (c *QUICClient) CloseClient() error
  • func (c *QUICClient) OpenClient(params netx.SockParams) error
• type QUICServer
  • func (s *QUICServer) CloseConnection(address string) (err error, ok bool)
  • func (s *QUICServer) Connections() int
  • func (s *QUICServer) FindConnection(address string) (conn netx.IServerConn, ok bool)
  • func (s *QUICServer) SendBytesTo(data []byte, rAddress ...string) error
  • func (s *QUICServer) SendPackTo(pack []byte, rAddress ...string) error
  • func (s *QUICServer) SetMaxConn(max int)
  • func (s *QUICServer) StartServer(params netx.SockParams) error
  • func (s *QUICServer) StopServer() error
• type QUICStreamAdapter
  • func (rw *QUICStreamAdapter) ReadBytes(bytes []byte) (n int, address string, err error)
  • func (rw *QUICStreamAdapter) RemoteAddress() string
  • func (rw *QUICStreamAdapter) WriteBytes(bytes []byte, rAddress ...string) (n int, err error)
• type QuicSockConn
  • func (o *QuicSockConn) ClientAddress() string
  • func (o *QuicSockConn) CloseConn() error
  • func (o *QuicSockConn) SendBytes(bytes []byte) error
  • func (o *QuicSockConn) SendPack(data []byte) error

Variables

var QuicDataBlockHandler = bytex.NewDefaultDataBlockHandler()

Types

type IQUICServer

type IQUICServer interface {
	netx.ISockServer
	eventx.IEventDispatcher
}

func NewQuicServer

func NewQuicServer() IQUICServer

type IQuicClient

type IQuicClient interface {
	netx.ISockClient
}

func NewQUICClient

func NewQUICClient() IQuicClient

type QUICClient

type QUICClient struct {
	netx.SockClientBase
	// contains filtered or unexported fields
}

func (*QUICClient) CloseClient

func (c *QUICClient) CloseClient() error

func (*QUICClient) OpenClient

func (c *QUICClient) OpenClient(params netx.SockParams) error

type QUICServer

type QUICServer struct {
	eventx.EventDispatcher
	netx.SockServerBase
	// contains filtered or unexported fields
}

func (*QUICServer) CloseConnection

func (s *QUICServer) CloseConnection(address string) (err error, ok bool)

func (*QUICServer) Connections

func (s *QUICServer) Connections() int

func (*QUICServer) FindConnection

func (s *QUICServer) FindConnection(address string) (conn netx.IServerConn, ok bool)

func (*QUICServer) SendBytesTo

func (s *QUICServer) SendBytesTo(data []byte, rAddress ...string) error

func (*QUICServer) SendPackTo

func (s *QUICServer) SendPackTo(pack []byte, rAddress ...string) error

func (*QUICServer) SetMaxConn

func (s *QUICServer) SetMaxConn(max int)

func (*QUICServer) StartServer

func (s *QUICServer) StartServer(params netx.SockParams) error

func (*QUICServer) StopServer

func (s *QUICServer) StopServer() error

type QUICStreamAdapter

type QUICStreamAdapter struct {
	RemoteAddr net.Addr
	Reader     quic.ReceiveStream
	Writer     quic.SendStream
}

func (*QUICStreamAdapter) ReadBytes

func (rw *QUICStreamAdapter) ReadBytes(bytes []byte) (n int, address string, err error)

func (*QUICStreamAdapter) RemoteAddress

func (rw *QUICStreamAdapter) RemoteAddress() string

func (*QUICStreamAdapter) WriteBytes

func (rw *QUICStreamAdapter) WriteBytes(bytes []byte, rAddress ...string) (n int, err error)

type QuicSockConn

type QuicSockConn struct {
	Address string
	SRProxy netx.IPackSendReceiver
	Session quic.Session
	Stream  quic.Stream
}

func (*QuicSockConn) ClientAddress

func (o *QuicSockConn) ClientAddress() string

func (*QuicSockConn) CloseConn

func (o *QuicSockConn) CloseConn() error

func (*QuicSockConn) SendBytes

func (o *QuicSockConn) SendBytes(bytes []byte) error

func (*QuicSockConn) SendPack

func (o *QuicSockConn) SendPack(data []byte) error