statistic

Documentation

Index

• 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 Metadata
• type Snapshot
• type TcpTracker
  • func NewTCPTracker(conn net.Conn, metadata *Metadata) *TcpTracker
  • func (tt *TcpTracker) Close() error
  • func (tt *TcpTracker) DownloadTotalX() int64
  • func (tt *TcpTracker) ID() string
  • func (tt *TcpTracker) MetadataX() *Metadata
  • func (tt *TcpTracker) Read(b []byte) (int, error)
  • func (tt *TcpTracker) UploadTotalX() int64
  • func (tt *TcpTracker) Write(b []byte) (int, error)

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 Metadata

type Metadata struct {
	ID      string `json:"ID"`
	NetWork string `json:"Network"`
	Type    string `json:"Type"`
	Client  string `json:"Client"`
	Source  string `json:"Source"`
	Target  string `json:"Target"`
}

type Snapshot

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

type TcpTracker

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

func NewTCPTracker

func NewTCPTracker(conn net.Conn, metadata *Metadata) *TcpTracker

func (*TcpTracker) Close

func (tt *TcpTracker) Close() error

func (*TcpTracker) DownloadTotalX

func (tt *TcpTracker) DownloadTotalX() int64

func (*TcpTracker) ID

func (tt *TcpTracker) ID() string

func (*TcpTracker) MetadataX

func (tt *TcpTracker) MetadataX() *Metadata

func (*TcpTracker) Read

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

func (*TcpTracker) UploadTotalX

func (tt *TcpTracker) UploadTotalX() int64

func (*TcpTracker) Write

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