transport

package

Go to main page

Versions in this module

v0

v0.0.8

Sep 18, 2021

Changes in this version

+ const EventDatagramOpen

type LogEvent

+ Data []byte

+ Name string

type Stream

+ func (s *Stream) WriteTo(w io.Writer) (int64, error)

v0.0.7

Jul 4, 2021

Changes in this version

+ const AEADLimitReached

+ const KeyUpdateError

type Config

+ MaxPacketsPerKey uint64

type Conn

+ func (s *Conn) Delay() time.Duration

+ func (s *Conn) HandshakeComplete() bool

type ConnectionState

+ LocalError error

+ LostBytes uint64

+ LostPackets uint64

+ PeerError error

+ PeerParams Parameters

+ RecvBytes uint64

+ RecvPackets uint64

+ SentBytes uint64

+ SentPackets uint64

+ State string

+ TLS tls.ConnectionState

type Error

+ App bool

+ Reason string

type LogEvent

+ Message []byte

type Parameters

+ MaxDatagramFramePayloadSize uint64

+ func (s *Parameters) String() string

v0.0.6

May 31, 2021

Changes in this version

+ const EventConnClosed

+ const EventConnOpen

+ const EventDatagramWritable

+ const EventStreamClosed

+ const EventStreamOpen

+ func IsVersionSupported(version uint32) bool

type Conn

+ func (s *Conn) HandshakeState() tls.ConnectionState

v0.0.5

Dec 10, 2020

Changes in this version

+ func IsPacketDropped(err error) (string, bool)

+ func VersionSupported(version uint32) bool

v0.0.4

Aug 30, 2020

Changes in this version

+ const EventDatagramReadable

+ const EventStreamComplete

+ const EventStreamCreatable

+ const EventStreamReadable

+ const EventStreamReset

+ const EventStreamStop

+ const EventStreamWritable

+ var ErrKeysUnavailable = errors.New("keys unavailable")

+ var ErrPacketDropped = errors.New("packet dropped")

type Conn

+ func (s *Conn) ConnectionState() ConnectionState

+ func (s *Conn) Datagram() *Datagram

+ func (s *Conn) SetLogger(fn func(LogEvent))

+ type ConnectionState uint8

+ const StateActive

+ const StateAttempted

+ const StateClosed

+ const StateDraining

+ const StateHandshake

+ func (s ConnectionState) String() string

+ type Datagram struct

+ func (s *Datagram) Pop() []byte

+ func (s *Datagram) Push(b []byte) error

+ func (s *Datagram) Read(b []byte) (int, error)

+ func (s *Datagram) Write(b []byte) (int, error)

+ type Event struct

+ Data uint64

+ ID uint64

+ Type string

+ func (s Event) String() string

+ type LogEvent struct

+ Fields []LogField

+ Time time.Time

+ Type string

+ func (s LogEvent) String() string

+ type LogField struct

+ Key string

+ Num uint64

+ Str string

+ func (s LogField) String() string

type Parameters

+ ActiveConnectionIDLimit uint64

+ DisableActiveMigration bool

+ MaxDatagramPayloadSize uint64

type Stream

+ func (s *Stream) CloseRead(errorCode uint64) error

+ func (s *Stream) CloseWrite(errorCode uint64) error

+ func (s *Stream) WriteString(b string) (int, error)

v0.0.3

Jul 5, 2020

Changes in this version

+ const ApplicationError

+ const ConnectionIDLimitError

+ const ConnectionRefused

+ const InvalidToken

type Parameters

+ InitialSourceCID []byte

+ OriginalDestinationCID []byte

+ RetrySourceCID []byte

+ type StreamComplete struct

+ StreamID uint64

+ type StreamRecvEvent struct

+ StreamID uint64

+ type StreamResetEvent struct

+ ErrorCode uint64

+ StreamID uint64

+ type StreamStopEvent struct

+ ErrorCode uint64

+ StreamID uint64

v0.0.2

May 6, 2020

Changes in this version

+ type AddressValidator struct

+ func NewAddressValidator() (*AddressValidator, error)

+ func (s *AddressValidator) Generate(addr, odcid []byte) []byte

+ func (s *AddressValidator) Validate(addr, token []byte) []byte

type Header

+ Token []byte

+ Type int

+ func (s *Header) Decode(b []byte, dcil int) (int, error)

type Parameters

+ MaxIdleTimeout time.Duration

+ MaxUDPPayloadSize uint64

v0.0.1

Nov 27, 2019

Changes in this version

+ const CryptoBufferExceeded

+ const CryptoError

+ const FinalSizeError

+ const FlowControlError

+ const FrameEncodingError

+ const InternalError

+ const MaxCIDLength

+ const MaxIPv4PacketSize

+ const MaxIPv6PacketSize

+ const MaxPacketSize

+ const MinInitialPacketSize

+ const NoError

+ const ProtocolVersion

+ const ProtocolViolation

+ const ServerBusy

+ const StreamLimitError

+ const StreamStateError

+ const TransportParameterError

+ func NegotiateVersion(b, dcid, scid []byte) (int, error)

+ func Retry(b, dcid, scid, odcid, token []byte) (int, error)

+ type Config struct

+ Params Parameters

+ TLS *tls.Config

+ Version uint32

+ func NewConfig() *Config

+ type Conn struct

+ func Accept(scid, odcid []byte, config *Config) (*Conn, error)

+ func Connect(scid []byte, config *Config) (*Conn, error)

+ func (s *Conn) Close(app bool, errCode uint64, reason string)

+ func (s *Conn) Events() []interface{}

+ func (s *Conn) IsClosed() bool

+ func (s *Conn) IsEstablished() bool

+ func (s *Conn) Read(b []byte) (int, error)

+ func (s *Conn) Stream(id uint64) *Stream

+ func (s *Conn) Timeout() time.Duration

+ func (s *Conn) Write(b []byte) (int, error)

+ type Error struct

+ Code uint64

+ Message string

+ func (e *Error) Error() string

+ type Header struct

+ DCID []byte

+ Flags uint8

+ SCID []byte

+ Version uint32

+ func DecodeHeader(b []byte, dcil int) (*Header, error)

+ func (s *Header) String() string

+ type Parameters struct

+ AckDelayExponent uint64

+ IdleTimeout time.Duration

+ InitialMaxData uint64

+ InitialMaxStreamDataBidiLocal uint64

+ InitialMaxStreamDataBidiRemote uint64

+ InitialMaxStreamDataUni uint64

+ InitialMaxStreamsBidi uint64

+ InitialMaxStreamsUni uint64

+ MaxAckDelay time.Duration

+ MaxPacketSize uint64

+ OriginalCID []byte

+ StatelessResetToken []byte

+ type ResetStreamEvent struct

+ ErrorCode uint64

+ StreamID uint64

+ type StopSendingEvent struct

+ ErrorCode uint64

+ StreamID uint64

+ type Stream struct

+ func (s *Stream) Close() error

+ func (s *Stream) Read(b []byte) (int, error)

+ func (s *Stream) String() string

+ func (s *Stream) Write(b []byte) (int, error)

+ type StreamEvent struct

+ StreamID uint64

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