statistic

Documentation

Index

• Variables
• func Conn2TCPTracker(conn C.Conn) *tcpTracker
• func NewTCPTracker(conn C.Conn, manager *Manager, metadata *C.Metadata, rule C.Rule, ...) *tcpTracker
• func NewUDPTracker(conn C.PacketConn, manager *Manager, metadata *C.Metadata, rule C.Rule, ...) *udpTracker
• type Manager
  • func (m *Manager) Join(c tracker)
  • func (m *Manager) Leave(c tracker)
  • func (m *Manager) Now() (up int64, down int64)
  • func (m *Manager) PushDownloaded(size int64)
  • func (m *Manager) PushUploaded(size int64)
  • func (m *Manager) ResetStatistic()
  • func (m *Manager) Snapshot() *Snapshot
• type Snapshot

Variables

var (
	//ManagerTimeout     = CC.New(CC.Configure().MaxSize(1024 * 1024).ItemsToPrune(500).Buckets(1024 * 1024 / 64))
	//ManagerReadTimeout = CC.New(CC.Configure().MaxSize(1024 * 1024).ItemsToPrune(500).Buckets(1024 * 1024 / 64))
	ManagerTimeout, _ = ristretto.NewCache(&ristretto.Config{
		NumCounters: 1e7,
		MaxCost:     1 << 26,
		BufferItems: 64,
	})

	ManagerReadTimeout, _ = ristretto.NewCache(&ristretto.Config{
		NumCounters: 1e7,
		MaxCost:     1 << 26,
		BufferItems: 64,
	})
)

Functions

func Conn2TCPTracker

func Conn2TCPTracker(conn C.Conn) *tcpTracker

func NewTCPTracker

func NewTCPTracker(conn C.Conn, manager *Manager, metadata *C.Metadata, rule C.Rule, proxy C.Proxy) *tcpTracker

func NewUDPTracker

func NewUDPTracker(conn C.PacketConn, manager *Manager, metadata *C.Metadata, rule C.Rule, proxy C.Proxy) *udpTracker

Types

type Manager

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

var DefaultManager *Manager

func (*Manager) Join

func (m *Manager) Join(c tracker)

func (*Manager) Leave

func (m *Manager) Leave(c tracker)

func (*Manager) Now

func (m *Manager) Now() (up int64, down int64)

func (*Manager) PushDownloaded

func (m *Manager) PushDownloaded(size int64)

func (*Manager) PushUploaded

func (m *Manager) PushUploaded(size int64)

func (*Manager) ResetStatistic

func (m *Manager) ResetStatistic()

func (*Manager) Snapshot

func (m *Manager) Snapshot() *Snapshot

type Snapshot

type Snapshot struct {
	DownloadTotal int64     `json:"downloadTotal"`
	UploadTotal   int64     `json:"uploadTotal"`
	Connections   []tracker `json:"connections"`
}