Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type StatsDeadlineRW ¶
type StatsDeadlineRW struct {
i.DeadlineRW
// contains filtered or unexported fields
}
func NewStatsDeadlineRW ¶
func NewStatsDeadlineRW(rw i.DeadlineRW, upCounter session.UpCounter, downCounter session.DownCounter, activeChecker *atomic.Value) *StatsDeadlineRW
func (*StatsDeadlineRW) ReadMultiBuffer ¶
func (w *StatsDeadlineRW) ReadMultiBuffer() (buf.MultiBuffer, error)
func (*StatsDeadlineRW) WriteMultiBuffer ¶
func (w *StatsDeadlineRW) WriteMultiBuffer(mb buf.MultiBuffer) error
type StatsPacketConn ¶
type StatsPacketConn struct {
udp.PacketReaderWriter
// contains filtered or unexported fields
}
func NewStatsPacketConn ¶
func NewStatsPacketConn(prw udp.PacketReaderWriter, upCounter session.UpCounter, downCounter session.DownCounter, activeChecker *atomic.Value) *StatsPacketConn
func (*StatsPacketConn) ReadPacket ¶
func (p *StatsPacketConn) ReadPacket() (*udp.Packet, error)
func (*StatsPacketConn) WritePacket ¶
func (p *StatsPacketConn) WritePacket(packet *udp.Packet) error
type StatsReaderWriter ¶
type StatsReaderWriter struct {
buf.ReaderWriter
// contains filtered or unexported fields
}
func NewStatsReaderWriter ¶
func NewStatsReaderWriter(rw buf.ReaderWriter, upCounter session.UpCounter, downCounter session.DownCounter, activeChecker *atomic.Value) *StatsReaderWriter
func (*StatsReaderWriter) ReadMultiBuffer ¶
func (w *StatsReaderWriter) ReadMultiBuffer() (buf.MultiBuffer, error)
func (*StatsReaderWriter) WriteMultiBuffer ¶
func (w *StatsReaderWriter) WriteMultiBuffer(mb buf.MultiBuffer) error
type TimeoutDeadlineRW ¶
type TimeoutDeadlineRW struct {
i.DeadlineRW
Timeout i.TimeoutSetting
Idle *signal.ActivityChecker
UpOnly bool
Ctx context.Context
}
func (*TimeoutDeadlineRW) CloseWrite ¶
func (w *TimeoutDeadlineRW) CloseWrite() error
func (*TimeoutDeadlineRW) ReadMultiBuffer ¶
func (w *TimeoutDeadlineRW) ReadMultiBuffer() (buf.MultiBuffer, error)
func (*TimeoutDeadlineRW) WriteMultiBuffer ¶
func (w *TimeoutDeadlineRW) WriteMultiBuffer(mb buf.MultiBuffer) error
type TimeoutPacketConn ¶
type TimeoutPacketConn struct {
Idle *signal.ActivityChecker
udp.PacketReaderWriter
}
func (*TimeoutPacketConn) ReadPacket ¶
func (p *TimeoutPacketConn) ReadPacket() (*udp.Packet, error)
func (*TimeoutPacketConn) WritePacket ¶
func (p *TimeoutPacketConn) WritePacket(packet *udp.Packet) error
type TimeoutReaderWriter ¶
type TimeoutReaderWriter struct {
buf.ReaderWriter
Timeout i.TimeoutSetting
Idle *signal.ActivityChecker
UpOnly bool
Ctx context.Context
}
func (*TimeoutReaderWriter) CloseWrite ¶
func (w *TimeoutReaderWriter) CloseWrite() error
func (*TimeoutReaderWriter) ReadMultiBuffer ¶
func (w *TimeoutReaderWriter) ReadMultiBuffer() (buf.MultiBuffer, error)
func (*TimeoutReaderWriter) WriteMultiBuffer ¶
func (w *TimeoutReaderWriter) WriteMultiBuffer(mb buf.MultiBuffer) error
Source Files
Click to show internal directories.
Click to hide internal directories.