tracker

Documentation

Index

• func InitTrackerManager()
• type Manager
  • func (m *Manager) Now() (up, 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
• type TrackerReader
  • func NewTrackerReader(reader io.ReadCloser, trackerManager *Manager) *TrackerReader
  • func (r *TrackerReader) Close() error
  • func (r *TrackerReader) Read(p []byte) (int, error)
• type TrackerWriter
  • func NewTrackerWriter(writer io.WriteCloser, trackerManager *Manager) *TrackerWriter
  • func (w *TrackerWriter) Close() error
  • func (w *TrackerWriter) Write(p []byte) (int, error)

Functions

func InitTrackerManager

func InitTrackerManager()

Types

type Manager

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

var (
	Trackermanager *Manager
)

func (*Manager) Now

func (m *Manager) Now() (up, 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 {
	UploadBlip   float64 `json:"upload_blip"`
	DownloadBlip float64 `json:"download_blip"`
}

type TrackerReader

type TrackerReader struct {
	Reader io.ReadCloser
	// contains filtered or unexported fields
}

func NewTrackerReader

func NewTrackerReader(reader io.ReadCloser, trackerManager *Manager) *TrackerReader

func (*TrackerReader) Close

func (r *TrackerReader) Close() error

func (*TrackerReader) Read

func (r *TrackerReader) Read(p []byte) (int, error)

type TrackerWriter

type TrackerWriter struct {
	Writer io.WriteCloser
	// contains filtered or unexported fields
}

func NewTrackerWriter

func NewTrackerWriter(writer io.WriteCloser, trackerManager *Manager) *TrackerWriter

func (*TrackerWriter) Close

func (w *TrackerWriter) Close() error

func (*TrackerWriter) Write

func (w *TrackerWriter) Write(p []byte) (int, error)