Versions in this module Expand all Collapse all v1 v1.1.1 Feb 22, 2024 Changes in this version + func NewConnCounter(conn net.Conn, s *TrafficStorage) net.Conn + func NewPacketConnCounter(conn network.PacketConn, s *TrafficStorage) network.PacketConn + type ConnCounter struct + func (c *ConnCounter) Read(b []byte) (n int, err error) + func (c *ConnCounter) ReadBuffer(buffer *buf.Buffer) error + func (c *ConnCounter) UnwrapReader() (io.Reader, []network.CountFunc) + func (c *ConnCounter) UnwrapWriter() (io.Writer, []network.CountFunc) + func (c *ConnCounter) Upstream() any + func (c *ConnCounter) Write(b []byte) (n int, err error) + func (c *ConnCounter) WriteBuffer(buffer *buf.Buffer) error + type PacketConnCounter struct + func (p *PacketConnCounter) ReadPacket(buff *buf.Buffer) (destination M.Socksaddr, err error) + func (p *PacketConnCounter) UnwrapPacketReader() (network.PacketReader, []network.CountFunc) + func (p *PacketConnCounter) UnwrapPacketWriter() (network.PacketWriter, []network.CountFunc) + func (p *PacketConnCounter) Upstream() any + func (p *PacketConnCounter) WritePacket(buff *buf.Buffer, destination M.Socksaddr) (err error) + type TrafficCounter struct + func NewTrafficCounter() *TrafficCounter + func (c *TrafficCounter) DecConn(auth string) + func (c *TrafficCounter) Delete(id string) + func (c *TrafficCounter) GetCounter(id string) *TrafficStorage + func (c *TrafficCounter) GetDownCount(id string) int64 + func (c *TrafficCounter) GetUpCount(id string) int64 + func (c *TrafficCounter) IncConn(auth string) + func (c *TrafficCounter) Len() int + func (c *TrafficCounter) Reset(id string) + func (c *TrafficCounter) Rx(id string, n int) + func (c *TrafficCounter) Tx(id string, n int) + type TrafficStorage struct + DownCounter atomic.Int64 + UpCounter atomic.Int64
Go to main page