(seconds int)
| 30 | var baseTime = time.Now() |
| 31 | |
| 32 | func millionMessagesSecondSample(seconds int) *Sample { |
| 33 | messages := Million * seconds |
| 34 | start := baseTime |
| 35 | end := start.Add(time.Second * time.Duration(seconds)) |
| 36 | nc := new(nats.Conn) |
| 37 | |
| 38 | s := NewSample(messages, MsgSize, start, end, nc) |
| 39 | s.MsgCnt = uint64(messages) |
| 40 | s.MsgBytes = uint64(messages * MsgSize) |
| 41 | s.IOBytes = s.MsgBytes |
| 42 | return s |
| 43 | } |
| 44 | |
| 45 | func TestDuration(t *testing.T) { |
| 46 | s := millionMessagesSecondSample(1) |
no test coverage detected