trafficcontrol

Documentation

Index

• type Manager
  • func NewManager[U comparable]() *Manager[U]
  • func (m *Manager[U]) ReadTraffics() map[U]Traffic
  • func (m *Manager[U]) Reset()
  • func (m *Manager[U]) TrackConnection(user U, conn net.Conn) net.Conn
  • func (m *Manager[U]) TrackPacketConnection(user U, conn N.PacketConn) N.PacketConn
• type TrackConn
  • func (c *TrackConn) Read(p []byte) (n int, err error)
  • func (c *TrackConn) ReadFrom(r io.Reader) (n int64, err error)
  • func (c *TrackConn) Upstream() any
  • func (c *TrackConn) Write(p []byte) (n int, err error)
  • func (c *TrackConn) WriteTo(w io.Writer) (n int64, err error)
• type TrackPacketConn
  • func (c *TrackPacketConn) ReadPacket(buffer *buf.Buffer) (M.Socksaddr, error)
  • func (c *TrackPacketConn) Upstream() any
  • func (c *TrackPacketConn) WritePacket(buffer *buf.Buffer, destination M.Socksaddr) error
• type Traffic

Types

type Manager

type Manager[U comparable] struct {
	// contains filtered or unexported fields
}

func NewManager

func NewManager[U comparable]() *Manager[U]

func (*Manager[U]) ReadTraffics

func (m *Manager[U]) ReadTraffics() map[U]Traffic

func (*Manager[U]) Reset

func (m *Manager[U]) Reset()

func (*Manager[U]) TrackConnection

func (m *Manager[U]) TrackConnection(user U, conn net.Conn) net.Conn

func (*Manager[U]) TrackPacketConnection

func (m *Manager[U]) TrackPacketConnection(user U, conn N.PacketConn) N.PacketConn

type TrackConn

type TrackConn struct {
	net.Conn
	*Traffic
}

func (*TrackConn) Read

func (c *TrackConn) Read(p []byte) (n int, err error)

func (*TrackConn) ReadFrom

func (c *TrackConn) ReadFrom(r io.Reader) (n int64, err error)

func (*TrackConn) Upstream

func (c *TrackConn) Upstream() any

func (*TrackConn) Write

func (c *TrackConn) Write(p []byte) (n int, err error)

func (*TrackConn) WriteTo

func (c *TrackConn) WriteTo(w io.Writer) (n int64, err error)

type TrackPacketConn

type TrackPacketConn struct {
	N.PacketConn
	*Traffic
}

func (*TrackPacketConn) ReadPacket

func (c *TrackPacketConn) ReadPacket(buffer *buf.Buffer) (M.Socksaddr, error)

func (*TrackPacketConn) Upstream

func (c *TrackPacketConn) Upstream() any

func (*TrackPacketConn) WritePacket

func (c *TrackPacketConn) WritePacket(buffer *buf.Buffer, destination M.Socksaddr) error

type Traffic

type Traffic struct {
	Upload   uint64
	Download uint64
}