multicast

Documentation

Index

• Constants
• type Client
• type ConnPassTrough
  • func (u ConnPassTrough) Read(b []byte) (int, error)
  • func (u ConnPassTrough) ReadFrom(b []byte) (int, net.Addr, error)
  • func (u ConnPassTrough) ReadFromUDP(b []byte) (int, net.Addr, error)
  • func (u ConnPassTrough) ReadMsgUDP(b []byte, oob []byte) (n int, oobn int, flags int, addr *net.UDPAddr, err error)
  • func (u ConnPassTrough) Write(b []byte) (int, error)
  • func (u ConnPassTrough) WriteMsgUDP(b []byte, oob []byte, addr *net.UDPAddr) (n int, oobn int, err error)
  • func (u ConnPassTrough) WriteTo(b []byte, addr net.Addr) (int, error)
  • func (u ConnPassTrough) WriteToUDP(b []byte, addr *net.UDPAddr) (int, error)
• type MulticastServer
  • func (s *MulticastServer) ListenAndServeTLSKencastFolder(certFile, keyFile, addr, multiACKAddr string, kencastWriter *net.UDPConn, ...) error
  • func (s *MulticastServer) ListenAndServeTLSMultiFolder(certFile, keyFile, addr, multiACKAddr, multiAddr string, ifat *net.Interface, ...) error
  • func (s *MulticastServer) ServeFolder(conn *net.UDPConn, ackConn *net.UDPConn, folder chan string) error
• type PassThru
  • func (pt *PassThru) Read(p []byte) (int, error)
  • func (pt *PassThru) Write(p []byte) (int, error)
• type RoundTripper

Constants

const MethodGet0RTT = "GET_0RTT"

MethodGet0RTT allows a GET request to be sent using 0-RTT. Note that 0-RTT data doesn't provide replay protection.

Types

type Client

type Client struct {
	*http3.Client
	// contains filtered or unexported fields
}

type ConnPassTrough

type ConnPassTrough struct {
	*net.UDPConn
	DataWriteStream chan []byte
	DataReadStream  chan []byte
}

func (ConnPassTrough) Read

func (u ConnPassTrough) Read(b []byte) (int, error)

func (ConnPassTrough) ReadFrom

func (u ConnPassTrough) ReadFrom(b []byte) (int, net.Addr, error)

func (ConnPassTrough) ReadFromUDP

func (u ConnPassTrough) ReadFromUDP(b []byte) (int, net.Addr, error)

func (ConnPassTrough) ReadMsgUDP

func (u ConnPassTrough) ReadMsgUDP(b []byte, oob []byte) (n int, oobn int, flags int, addr *net.UDPAddr, err error)

func (ConnPassTrough) Write

func (u ConnPassTrough) Write(b []byte) (int, error)

func (ConnPassTrough) WriteMsgUDP

func (u ConnPassTrough) WriteMsgUDP(b []byte, oob []byte, addr *net.UDPAddr) (n int, oobn int, err error)

func (ConnPassTrough) WriteTo

func (u ConnPassTrough) WriteTo(b []byte, addr net.Addr) (int, error)

func (ConnPassTrough) WriteToUDP

func (u ConnPassTrough) WriteToUDP(b []byte, addr *net.UDPAddr) (int, error)

type MulticastServer

type MulticastServer struct {
	*http3.Server
	Multicast  *http.Server
	QuicConfig *quic.Config

	RetransmissionQueue *quic.RetransmissionQueue

	RemoteAddr net.Addr
	// contains filtered or unexported fields
}

Server is a mHTTP/3 Multicastserver.

func (*MulticastServer) ListenAndServeTLSKencastFolder

func (s *MulticastServer) ListenAndServeTLSKencastFolder(certFile, keyFile, addr, multiACKAddr string, kencastWriter *net.UDPConn, ifat *net.Interface, handler http.Handler, files chan string) error

ListenAndServeTLS listens on the UDP address s.Addr and calls s.Handler to handle HTTP/3 requests on incoming connections.

func (*MulticastServer) ListenAndServeTLSMultiFolder

func (s *MulticastServer) ListenAndServeTLSMultiFolder(certFile, keyFile, addr, multiACKAddr, multiAddr string, ifat *net.Interface, handler http.Handler, files chan string) error

ListenAndServeTLS listens on the UDP address s.Addr and calls s.Handler to handle HTTP/3 requests on incoming connections.

func (*MulticastServer) ServeFolder

func (s *MulticastServer) ServeFolder(conn *net.UDPConn, ackConn *net.UDPConn, folder chan string) error

Serve an existing UDP connection. It is possible to reuse the same connection for outgoing connections. Closing the server does not close the packet conn.

type PassThru

type PassThru struct {
	Reader io.Reader
	Writer io.Writer
	// contains filtered or unexported fields
}

func (*PassThru) Read

func (pt *PassThru) Read(p []byte) (int, error)

func (*PassThru) Write

func (pt *PassThru) Write(p []byte) (int, error)

type RoundTripper

type RoundTripper struct {
	*http3.RoundTripper

	MultiAddr string

	Ifat *net.Interface

	// TLSClientConfig specifies the TLS configuration to use with
	// tls.Client. If nil, the default configuration is used.
	TLSClientConfig *tls.Config

	// QuicConfig is the quic.Config used for dialing new connections.
	// If nil, reasonable default values will be used.
	QuicConfig *quic.Config
}