Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrFullBuffer = errors.New("full buffer") ErrClosed = errors.New("closed") )
Functions ¶
Types ¶
type ConnChecker ¶
func NewConnChecker ¶
func NewConnChecker(c net.Conn) (cc *ConnChecker)
NewConnChecker creates a ConnChecker cc that periodically checks if c is no longer readable (closed or lost); if yes, it cancels cc.Context.
c must not be used afterward (use cc instead).
func (*ConnChecker) Close ¶
func (c *ConnChecker) Close() error
func (*ConnChecker) SetDeadline ¶
func (c *ConnChecker) SetDeadline(t time.Time) error
func (*ConnChecker) SetReadDeadline ¶
func (c *ConnChecker) SetReadDeadline(t time.Time) error
func (*ConnChecker) Stop ¶
func (c *ConnChecker) Stop()
type ConnReplayer ¶
func NewConnReplayer ¶
func NewConnReplayer(c net.Conn) *ConnReplayer
func (*ConnReplayer) Replay ¶
func (c *ConnReplayer) Replay() bool
func (*ConnReplayer) Stop ¶
func (c *ConnReplayer) Stop()
func (*ConnReplayer) Stopped ¶
func (c *ConnReplayer) Stopped() bool
Click to show internal directories.
Click to hide internal directories.