mirror of
https://github.com/nats-io/nats.go.git
synced 2025-09-26 20:41:41 +08:00
[IMPROVED] Fixed typos in comments (#1581)
Co-authored-by: Paolo TETI <paolo.teti@alstomgroup.com>
This commit is contained in:
@@ -36,7 +36,7 @@ type Sample struct {
|
||||
End time.Time
|
||||
}
|
||||
|
||||
// SampleGroup for a number of samples, the group is a Sample itself agregating the values the Samples
|
||||
// SampleGroup for a number of samples, the group is a Sample itself aggregating the values the Samples
|
||||
type SampleGroup struct {
|
||||
Sample
|
||||
Samples []*Sample
|
||||
@@ -156,7 +156,7 @@ func (s *Sample) Throughput() float64 {
|
||||
return float64(s.MsgBytes) / s.Duration().Seconds()
|
||||
}
|
||||
|
||||
// Rate of meessages in the job per second
|
||||
// Rate of messages in the job per second
|
||||
func (s *Sample) Rate() int64 {
|
||||
return int64(float64(s.JobMsgCnt) / s.Duration().Seconds())
|
||||
}
|
||||
|
@@ -116,7 +116,7 @@ func TestGroupThoughput(t *testing.T) {
|
||||
sg.AddSample(millionMessagesSecondSample(2))
|
||||
sg.AddSample(millionMessagesSecondSample(3))
|
||||
if sg.Throughput() != 2*Million*MsgSize {
|
||||
t.Fatalf("Expected througput at %d million bytes/sec", 2*MsgSize)
|
||||
t.Fatalf("Expected throughput at %d million bytes/sec", 2*MsgSize)
|
||||
}
|
||||
}
|
||||
|
||||
|
Reference in New Issue
Block a user