statistic

Documentation

Index

• type Manager
  • func (m *Manager) CloseAllConnections()
  • func (m *Manager) Connections() []tracker
  • func (m *Manager) GetTotal() *Total
  • func (m *Manager) Join(c tracker)
  • func (m *Manager) Leave(c tracker)
  • func (m *Manager) Now(rule constants.IpRule) (up int64, down int64)
  • func (m *Manager) PushDownloaded(size int64, rule constants.IpRule)
  • func (m *Manager) PushUploaded(size int64, rule constants.IpRule)
  • func (m *Manager) ResetStatistic(rule constants.IpRule)
• type SnapshotStatistic
• type Statistic
• type TcpTracker
  • func NewTCPTracker(conn net.Conn, manager *Manager, metadata *C.Metadata, rule constants.IpRule) *TcpTracker
  • func (tt *TcpTracker) Close() error
  • func (tt *TcpTracker) ID() string
  • func (tt *TcpTracker) Read(b []byte) (int, error)
  • func (tt *TcpTracker) Write(b []byte) (int, error)
• type Total
• type UdpTracker
  • func NewUDPTracker(conn net.PacketConn, manager *Manager, metadata *C.Metadata, ...) *UdpTracker
  • func (ut *UdpTracker) Close() error
  • func (ut *UdpTracker) ID() string
  • func (ut *UdpTracker) ReadFrom(b []byte) (int, net.Addr, error)
  • func (ut *UdpTracker) WriteTo(b []byte, addr net.Addr) (int, error)

Types

type Manager

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

var DefaultManager *Manager

func (*Manager) CloseAllConnections

func (m *Manager) CloseAllConnections()

func (*Manager) Connections

func (m *Manager) Connections() []tracker

func (*Manager) GetTotal

func (m *Manager) GetTotal() *Total

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(rule constants.IpRule) (up int64, down int64)

func (*Manager) PushDownloaded

func (m *Manager) PushDownloaded(size int64, rule constants.IpRule)

func (*Manager) PushUploaded

func (m *Manager) PushUploaded(size int64, rule constants.IpRule)

func (*Manager) ResetStatistic

func (m *Manager) ResetStatistic(rule constants.IpRule)

type SnapshotStatistic

type SnapshotStatistic struct {
	DownloadTotal int64 `json:"download"`
	UploadTotal   int64 `json:"upload"`
}

type Statistic

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

type TcpTracker

type TcpTracker struct {
	net.Conn `json:"-"`
	// contains filtered or unexported fields
}

func NewTCPTracker

func NewTCPTracker(conn net.Conn, manager *Manager, metadata *C.Metadata, rule constants.IpRule) *TcpTracker

func (*TcpTracker) Close

func (tt *TcpTracker) Close() error

func (*TcpTracker) ID

func (tt *TcpTracker) ID() string

func (*TcpTracker) Read

func (tt *TcpTracker) Read(b []byte) (int, error)

func (*TcpTracker) Write

func (tt *TcpTracker) Write(b []byte) (int, error)

type Total

type Total struct {
	Proxy  SnapshotStatistic `json:"proxy"`
	Direct SnapshotStatistic `json:"direct"`
}

type UdpTracker

type UdpTracker struct {
	net.PacketConn `json:"-"`
	// contains filtered or unexported fields
}

func NewUDPTracker

func NewUDPTracker(conn net.PacketConn, manager *Manager, metadata *C.Metadata, rule constants.IpRule) *UdpTracker

func (*UdpTracker) Close

func (ut *UdpTracker) Close() error

func (*UdpTracker) ID

func (ut *UdpTracker) ID() string

func (*UdpTracker) ReadFrom

func (ut *UdpTracker) ReadFrom(b []byte) (int, net.Addr, error)

func (*UdpTracker) WriteTo

func (ut *UdpTracker) WriteTo(b []byte, addr net.Addr) (int, error)