Method End

cmd/test-streammanager/metrics.go:43–47

()

}

func (m *Metrics) End() {
	m.lock.Lock()
	defer m.lock.Unlock()
	m.endTime = time.Now()
}

func (m *Metrics) AddDataPacket() {
	m.lock.Lock()