quiclylib

package

v0.0.0-...-db8bf72 Latest Latest Go to latest Published: Jan 2, 2024 License: BSD-3-Clause Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Project-Faster/quicly-go

Documentation ¶

Index ¶

Constants
func QuiclyCloseEngine() int
func QuiclyInitializeEngine(options types.Options) int
type QClientSession
type QServerConnection
type QServerSession
type QStream

Constants ¶

View Source

const (
	READ_SIZE         = 512 * 1024
	SMALL_BUFFER_SIZE = 4 * 1024
)

View Source

const (
	MAX_CONNECTIONS = 8192
)

Variables ¶

This section is empty.

Functions ¶

func QuiclyCloseEngine ¶

func QuiclyCloseEngine() int

func QuiclyInitializeEngine ¶

func QuiclyInitializeEngine(options types.Options) int

Types ¶

type QClientSession ¶

type QClientSession struct {
	// exported fields
	Conn   *net.UDPConn
	Ctx    context.Context
	Logger log.Logger

	// callback
	types.Callbacks
	// contains filtered or unexported fields
}

func (*QClientSession) Accept ¶

func (s *QClientSession) Accept() (net.Conn, error)

func (*QClientSession) Addr ¶

func (s *QClientSession) Addr() net.Addr

func (*QClientSession) Close ¶

func (s *QClientSession) Close() error

func (*QClientSession) GetStream ¶

func (s *QClientSession) GetStream(id uint64) types.Stream

func (*QClientSession) ID ¶

func (s *QClientSession) ID() uint64

func (*QClientSession) OnStreamClose ¶

func (s *QClientSession) OnStreamClose(streamId uint64, error int)

func (*QClientSession) OnStreamOpen ¶

func (s *QClientSession) OnStreamOpen(streamId uint64)

func (*QClientSession) OpenStream ¶

func (s *QClientSession) OpenStream() types.Stream

func (*QClientSession) StreamPacket ¶

func (s *QClientSession) StreamPacket(packet *types.Packet)

type QServerConnection ¶

type QServerConnection struct {
	// exported fields
	Ctx     context.Context
	NetConn *net.UDPConn
	Logger  log.Logger
	// contains filtered or unexported fields
}

func (*QServerConnection) Accept ¶

func (r *QServerConnection) Accept() (types.Stream, error)

func (*QServerConnection) Addr ¶

func (r *QServerConnection) Addr() net.Addr

func (*QServerConnection) Close ¶

func (r *QServerConnection) Close() error

func (*QServerConnection) GetStream ¶

func (r *QServerConnection) GetStream(id uint64) types.Stream

func (*QServerConnection) ID ¶

func (r *QServerConnection) ID() uint64

func (*QServerConnection) OnStreamClose ¶

func (r *QServerConnection) OnStreamClose(streamId uint64, code int)

func (*QServerConnection) OnStreamOpen ¶

func (r *QServerConnection) OnStreamOpen(streamId uint64)

func (*QServerConnection) OpenStream ¶

func (r *QServerConnection) OpenStream() types.Stream

func (*QServerConnection) StreamPacket ¶

func (r *QServerConnection) StreamPacket(packet *types.Packet)

type QServerSession ¶

type QServerSession struct {
	// exported fields
	NetConn *net.UDPConn
	Ctx     context.Context
	Logger  log.Logger

	// callback
	types.Callbacks
	// contains filtered or unexported fields
}

func (*QServerSession) Accept ¶

func (s *QServerSession) Accept() (types.ServerConnection, error)

func (*QServerSession) Addr ¶

func (s *QServerSession) Addr() net.Addr

func (*QServerSession) Close ¶

func (s *QServerSession) Close() error

func (*QServerSession) GetStream ¶

func (s *QServerSession) GetStream(id uint64) types.Stream

func (*QServerSession) ID ¶

func (s *QServerSession) ID() uint64

func (*QServerSession) OnStreamClose ¶

func (s *QServerSession) OnStreamClose(streamId uint64, error int)

func (*QServerSession) OnStreamOpen ¶

func (s *QServerSession) OnStreamOpen(streamId uint64)

func (*QServerSession) OpenStream ¶

func (s *QServerSession) OpenStream() types.Stream

func (*QServerSession) StreamPacket ¶

func (s *QServerSession) StreamPacket(packet *types.Packet)

type QStream ¶

type QStream struct {
	Logger log.Logger
	// contains filtered or unexported fields
}

func (*QStream) Close ¶

func (s *QStream) Close() error

func (*QStream) ID ¶

func (s *QStream) ID() uint64

func (*QStream) IsClosed ¶

func (s *QStream) IsClosed() bool

func (*QStream) LocalAddr ¶

func (s *QStream) LocalAddr() net.Addr

func (*QStream) OnClosed ¶

func (s *QStream) OnClosed() error

func (*QStream) OnOpened ¶

func (s *QStream) OnOpened()

func (*QStream) OnReceived ¶

func (s *QStream) OnReceived(data []byte, dataLen int)

func (*QStream) Read ¶

func (s *QStream) Read(b []byte) (n int, err error)

func (*QStream) RemoteAddr ¶

func (s *QStream) RemoteAddr() net.Addr

func (*QStream) SetDeadline ¶

func (s *QStream) SetDeadline(t time.Time) error

func (*QStream) SetReadDeadline ¶

func (s *QStream) SetReadDeadline(t time.Time) error

func (*QStream) SetWriteDeadline ¶

func (s *QStream) SetWriteDeadline(t time.Time) error

func (*QStream) Write ¶

func (s *QStream) Write(b []byte) (n int, err error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
errors quicly-errors	quicly-errors
types

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL