trafficontrol

Documentation

Index

• func NewTCPTracker(conn net.Conn, manager *Manager, metadata Metadata, router adapter.Router, ...) *tcpTracker
• func NewUDPTracker(conn N.PacketConn, manager *Manager, metadata Metadata, router adapter.Router, ...) *udpTracker
• type Manager
  • func NewManager() *Manager
  • func (m *Manager) Close() error
  • func (m *Manager) Connections() int
  • 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
  • func (m *Manager) Total() (up int64, down int64)
• type Metadata
• type Snapshot

Functions

func NewTCPTracker

func NewTCPTracker(conn net.Conn, manager *Manager, metadata Metadata, router adapter.Router, rule adapter.Rule) *tcpTracker

func NewUDPTracker

func NewUDPTracker(conn N.PacketConn, manager *Manager, metadata Metadata, router adapter.Router, rule adapter.Rule) *udpTracker

Types

type Manager

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

func NewManager

func NewManager() *Manager

func (*Manager) Close

func (m *Manager) Close() error

func (*Manager) Connections

func (m *Manager) Connections() int

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

func (*Manager) Total

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

type Metadata

type Metadata struct {
	NetWork     string     `json:"network"`
	Type        string     `json:"type"`
	SrcIP       netip.Addr `json:"sourceIP"`
	DstIP       netip.Addr `json:"destinationIP"`
	SrcPort     string     `json:"sourcePort"`
	DstPort     string     `json:"destinationPort"`
	Host        string     `json:"host"`
	DNSMode     string     `json:"dnsMode"`
	ProcessPath string     `json:"processPath"`
}

type Snapshot

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