core

Documentation

Index

• Variables
• type Client
  • func NewClient(serverAddr string, auth []byte, tlsConfig *tls.Config, quicConfig *quic.Config, ...) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) DialTCP(addr string) (net.Conn, error)
  • func (c *Client) DialUDP() (HyUDPConn, error)
• type ConnectFunc
• type DisconnectFunc
• type HyUDPConn
• type Server
  • func NewServer(tlsConfig *tls.Config, quicConfig *quic.Config, pktConn net.PacketConn, ...) (*Server, error)
  • func (s *Server) Close() error
  • func (s *Server) Serve() error
• type TCPErrorFunc
• type TCPRequestFunc
• type UDPErrorFunc
• type UDPRequestFunc

Variables

var ErrClosed = errors.New("closed")

Types

type Client

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

func NewClient

func NewClient(serverAddr string, auth []byte, tlsConfig *tls.Config, quicConfig *quic.Config,
	pktConnFunc pktconns.ClientPacketConnFunc, sendBPS uint64, recvBPS uint64, quicReconnectFunc func(err error),
) (*Client, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) DialTCP

func (c *Client) DialTCP(addr string) (net.Conn, error)

func (*Client) DialUDP

func (c *Client) DialUDP() (HyUDPConn, error)

type ConnectFunc

type ConnectFunc func(addr net.Addr, auth []byte, sSend uint64, sRecv uint64) (bool, string)

type DisconnectFunc

type DisconnectFunc func(addr net.Addr, auth []byte, err error)

type HyUDPConn

type HyUDPConn interface {
	ReadFrom() ([]byte, string, error)
	WriteTo([]byte, string) error
	Close() error
}

type Server

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

func NewServer

func NewServer(tlsConfig *tls.Config, quicConfig *quic.Config,
	pktConn net.PacketConn, transport *transport.ServerTransport,
	sendBPS uint64, recvBPS uint64, disableUDP bool, aclEngine *acl.Engine,
	connectFunc ConnectFunc, disconnectFunc DisconnectFunc,
	tcpRequestFunc TCPRequestFunc, tcpErrorFunc TCPErrorFunc,
	udpRequestFunc UDPRequestFunc, udpErrorFunc UDPErrorFunc, promRegistry *prometheus.Registry,
) (*Server, error)

func (*Server) Close

func (s *Server) Close() error

func (*Server) Serve

func (s *Server) Serve() error

type TCPErrorFunc

type TCPErrorFunc func(addr net.Addr, auth []byte, reqAddr string, err error)

type TCPRequestFunc

type TCPRequestFunc func(addr net.Addr, auth []byte, reqAddr string, action acl.Action, arg string)

type UDPErrorFunc

type UDPErrorFunc func(addr net.Addr, auth []byte, sessionID uint32, err error)

type UDPRequestFunc

type UDPRequestFunc func(addr net.Addr, auth []byte, sessionID uint32)