drop

Documentation

Index

• Variables
• type DropConn
  • func NewDrop(ctx context.Context, timeout time.Duration) *DropConn
  • func (d *DropConn) Close() error
  • func (d *DropConn) LocalAddr() net.Addr
  • func (d *DropConn) Read(b []byte) (n int, err error)
  • func (d *DropConn) ReadFrom(b []byte) (n int, addr net.Addr, err error)
  • func (d *DropConn) RemoteAddr() net.Addr
  • func (d *DropConn) SetDeadline(t time.Time) error
  • func (d *DropConn) SetReadDeadline(t time.Time) error
  • func (d *DropConn) SetWriteDeadline(t time.Time) error
  • func (d *DropConn) Write(b []byte) (n int, err error)
  • func (d *DropConn) WriteTo(b []byte, addr net.Addr) (n int, err error)

Variables

var Drop = &drop{
	lru: lru.New(
		lru.WithCapacity[string, time.Duration](512),
		lru.WithExpireTimeout[string, time.Duration](time.Second*5),
	),
	sf: &singleflight.Group[string, time.Duration]{},
}

Types

type DropConn

type DropConn struct {
	// contains filtered or unexported fields
}

func NewDrop

func NewDrop(ctx context.Context, timeout time.Duration) *DropConn

func (*DropConn) Close

func (d *DropConn) Close() error

func (*DropConn) LocalAddr

func (d *DropConn) LocalAddr() net.Addr

func (*DropConn) Read

func (d *DropConn) Read(b []byte) (n int, err error)

func (*DropConn) ReadFrom

func (d *DropConn) ReadFrom(b []byte) (n int, addr net.Addr, err error)

func (*DropConn) RemoteAddr

func (d *DropConn) RemoteAddr() net.Addr

func (*DropConn) SetDeadline

func (d *DropConn) SetDeadline(t time.Time) error

func (*DropConn) SetReadDeadline

func (d *DropConn) SetReadDeadline(t time.Time) error

func (*DropConn) SetWriteDeadline

func (d *DropConn) SetWriteDeadline(t time.Time) error

func (*DropConn) Write

func (d *DropConn) Write(b []byte) (n int, err error)

func (*DropConn) WriteTo

func (d *DropConn) WriteTo(b []byte, addr net.Addr) (n int, err error)