counter

package

v1.0.0 Latest Latest Go to latest Published: Oct 27, 2025 License: MPL-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/perfect-panel/ppanel-node

Links

Open Source Insights

Documentation ¶

Index ¶

func NewConnCounter(conn net.Conn, s *TrafficStorage) net.Conn
func NewPacketConnCounter(conn network.PacketConn, s *TrafficStorage) network.PacketConn
type ConnCounter
type PacketConnCounter
type TrafficCounter
- func NewTrafficCounter() *TrafficCounter
type TrafficStorage
type XrayTrafficCounter

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewConnCounter ¶

func NewConnCounter(conn net.Conn, s *TrafficStorage) net.Conn

func NewPacketConnCounter ¶

func NewPacketConnCounter(conn network.PacketConn, s *TrafficStorage) network.PacketConn

Types ¶

type ConnCounter ¶

type ConnCounter struct {
	network.ExtendedConn
	// contains filtered or unexported fields
}

func (*ConnCounter) Read ¶

func (c *ConnCounter) Read(b []byte) (n int, err error)

func (*ConnCounter) ReadBuffer ¶

func (c *ConnCounter) ReadBuffer(buffer *buf.Buffer) error

func (*ConnCounter) UnwrapReader ¶

func (c *ConnCounter) UnwrapReader() (io.Reader, []network.CountFunc)

func (*ConnCounter) UnwrapWriter ¶

func (c *ConnCounter) UnwrapWriter() (io.Writer, []network.CountFunc)

func (*ConnCounter) Upstream ¶

func (c *ConnCounter) Upstream() any

func (*ConnCounter) Write ¶

func (c *ConnCounter) Write(b []byte) (n int, err error)

func (*ConnCounter) WriteBuffer ¶

func (c *ConnCounter) WriteBuffer(buffer *buf.Buffer) error

type PacketConnCounter ¶

type PacketConnCounter struct {
	network.PacketConn
	// contains filtered or unexported fields
}

func (*PacketConnCounter) ReadPacket ¶

func (p *PacketConnCounter) ReadPacket(buff *buf.Buffer) (destination M.Socksaddr, err error)

func (*PacketConnCounter) UnwrapPacketReader ¶

func (p *PacketConnCounter) UnwrapPacketReader() (network.PacketReader, []network.CountFunc)

func (*PacketConnCounter) UnwrapPacketWriter ¶

func (p *PacketConnCounter) UnwrapPacketWriter() (network.PacketWriter, []network.CountFunc)

func (*PacketConnCounter) Upstream ¶

func (p *PacketConnCounter) Upstream() any

func (*PacketConnCounter) WritePacket ¶

func (p *PacketConnCounter) WritePacket(buff *buf.Buffer, destination M.Socksaddr) (err error)

type TrafficCounter ¶

type TrafficCounter struct {
	Counters sync.Map
}

func NewTrafficCounter ¶

func NewTrafficCounter() *TrafficCounter

func (*TrafficCounter) Delete ¶

func (c *TrafficCounter) Delete(uuid string)

func (*TrafficCounter) GetCounter ¶

func (c *TrafficCounter) GetCounter(uuid string) *TrafficStorage

func (*TrafficCounter) GetDownCount ¶

func (c *TrafficCounter) GetDownCount(uuid string) int64

func (*TrafficCounter) GetUpCount ¶

func (c *TrafficCounter) GetUpCount(uuid string) int64

func (*TrafficCounter) Len ¶

func (c *TrafficCounter) Len() int

func (*TrafficCounter) Reset ¶

func (c *TrafficCounter) Reset(uuid string)

func (*TrafficCounter) Rx ¶

func (c *TrafficCounter) Rx(uuid string, n int)

func (*TrafficCounter) Tx ¶

func (c *TrafficCounter) Tx(uuid string, n int)

type TrafficStorage ¶

type TrafficStorage struct {
	UpCounter   atomic.Int64
	DownCounter atomic.Int64
}

type XrayTrafficCounter ¶

type XrayTrafficCounter struct {
	V *atomic.Int64
}

func (*XrayTrafficCounter) Add ¶

func (c *XrayTrafficCounter) Add(delta int64) int64

func (*XrayTrafficCounter) Set ¶

func (c *XrayTrafficCounter) Set(newValue int64) int64

func (*XrayTrafficCounter) Value ¶

func (c *XrayTrafficCounter) Value() int64

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL