counter

package

v0.0.0-...-794c571 Latest Latest Go to latest Published: May 29, 2026 License: GPL-3.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type StatReader struct {
	Reader  buf.TimeoutReader
	Storage *TrafficStorage
}

func (r *StatReader) Interrupt()

func (r *StatReader) ReadMultiBuffer() (buf.MultiBuffer, error)

func (r *StatReader) ReadMultiBufferTimeout(d interface{ Nanoseconds() int64 }) (buf.MultiBuffer, error)

type StatWriter struct {
	Writer  buf.Writer
	Storage *TrafficStorage
}

func (w *StatWriter) Close() error

func (w *StatWriter) Interrupt()

func (w *StatWriter) WriteMultiBuffer(mb buf.MultiBuffer) error

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

TrafficCounter holds per-user storage, keyed by email.

func NewTrafficCounter() *TrafficCounter

func (c *TrafficCounter) Delete(email string)

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

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

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

func (c *TrafficCounter) Len() int

func (c *TrafficCounter) Reset(email string)

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

TrafficStorage holds atomic byte counters for one user.