Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrChClosed = errors.New("channel closed") ErrBufferToSmall = errors.New("buffer too small for perfect link") )
Functions ¶
This section is empty.
Types ¶
type DropFirstNSent ¶
type DropFirstNSent struct {
// contains filtered or unexported fields
}
DropFirstNSent drops the first targetDropsN datagrams. Safe for concurrent use: a socket writes from more than one goroutine.
type LinkDecider ¶
type LinkDecider interface {
// contains filtered or unexported methods
}
type ManualLinkDecider ¶
type ManualLinkDecider struct {
// contains filtered or unexported fields
}
type MockConnectedPeer ¶
type MockConnectedPeer struct {
// contains filtered or unexported fields
}
func (*MockConnectedPeer) Hash ¶
func (p *MockConnectedPeer) Hash() string
type MockUDPSocket ¶
type MockUDPSocket struct {
// contains filtered or unexported fields
}
func (*MockUDPSocket) Close ¶
func (s *MockUDPSocket) Close() error
func (*MockUDPSocket) Queued ¶
func (s *MockUDPSocket) Queued() int
Queued implements utp.QueuedReader, as a real socket's batched read would.
func (*MockUDPSocket) ReadFrom ¶
func (s *MockUDPSocket) ReadFrom(b []byte) (int, utp.ConnectionPeer, error)
func (*MockUDPSocket) WriteTo ¶
func (s *MockUDPSocket) WriteTo(b []byte, dst utp.ConnectionPeer) (int, error)
Source Files
Click to show internal directories.
Click to hide internal directories.