freconn

Documentation

Index

• Constants
• type Conn
  • func UpgradeConn(c net.Conn) *Conn
  • func (c *Conn) Close() error
  • func (c *Conn) EnableStat(stat *Stat)
  • func (c *Conn) Read(b []byte) (int, error)
  • func (c *Conn) Write(b []byte) (int, error)
• type PacketConn
  • func UpgradePacketConn(pc net.PacketConn) *PacketConn
  • func (c *PacketConn) EnableStat(stat *Stat)
  • func (c *PacketConn) ReadFrom(b []byte) (int, net.Addr, error)
  • func (c *PacketConn) WriteTo(b []byte, addr net.Addr) (int, error)
• type Stat
  • func NewStat() *Stat
  • func (s *Stat) AddRx(len uint64)
  • func (s *Stat) AddTx(len uint64)
  • func (s *Stat) Bandwidth1() (r, t uint64, lastTime time.Time)
  • func (s *Stat) Bandwidth10() (r, t uint64, lastTime time.Time)
  • func (s *Stat) Reset()
  • func (s *Stat) RunBandwidthIn1()
  • func (s *Stat) RunBandwidthIn10()
  • func (s *Stat) StopBandwidthIn1()
• type StatStatus
  • func (s *StatStatus) Reset()

Constants

const (
	FlagRatelimit = 1 << iota
	FlagStat
)

Types

type Conn

type Conn struct {
	net.Conn
	Flag     int
	TxBucket *ratelimit.Bucket
	RxBucket *ratelimit.Bucket
	*Stat
}

func UpgradeConn

func UpgradeConn(c net.Conn) *Conn

func (*Conn) Close

func (c *Conn) Close() error

func (*Conn) EnableStat

func (c *Conn) EnableStat(stat *Stat)

func (*Conn) Read

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

func (*Conn) Write

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

type PacketConn

type PacketConn struct {
	net.PacketConn
	Flag     int
	TxBucket *ratelimit.Bucket
	RxBucket *ratelimit.Bucket
	Stat     *Stat
}

func UpgradePacketConn

func UpgradePacketConn(pc net.PacketConn) *PacketConn

func (*PacketConn) EnableStat

func (c *PacketConn) EnableStat(stat *Stat)

func (*PacketConn) ReadFrom

func (c *PacketConn) ReadFrom(b []byte) (int, net.Addr, error)

func (*PacketConn) WriteTo

func (c *PacketConn) WriteTo(b []byte, addr net.Addr) (int, error)

type Stat

type Stat struct {
	Rx uint64 `json:"rx"`
	Tx uint64 `json:"tx"`

	In1  StatStatus `json:"in1"`
	In10 StatStatus `json:"in10"`
	// contains filtered or unexported fields
}

func NewStat

func NewStat() *Stat

func (*Stat) AddRx

func (s *Stat) AddRx(len uint64)

func (*Stat) AddTx

func (s *Stat) AddTx(len uint64)

func (*Stat) Bandwidth1

func (s *Stat) Bandwidth1() (r, t uint64, lastTime time.Time)

func (*Stat) Bandwidth10

func (s *Stat) Bandwidth10() (r, t uint64, lastTime time.Time)

func (*Stat) Reset

func (s *Stat) Reset()

func (*Stat) RunBandwidthIn1

func (s *Stat) RunBandwidthIn1()

func (*Stat) RunBandwidthIn10

func (s *Stat) RunBandwidthIn10()

func (*Stat) StopBandwidthIn1

func (s *Stat) StopBandwidthIn1()

type StatStatus

type StatStatus struct {
	Time        time.Time
	Rx          uint64 `json:"rx"`
	Tx          uint64 `json:"tx"`
	BandwidthRx uint64 `json:"bandwidth_rx"`
	BandwidthTx uint64 `json:"bandwidth_tx"`
}

func (*StatStatus) Reset

func (s *StatStatus) Reset()