(pendingLogs LogPriorityQueue)
| 3233 | } |
| 3234 | |
| 3235 | func pendingLogsAsString(pendingLogs LogPriorityQueue) string { |
| 3236 | count := len(pendingLogs) |
| 3237 | result := "{" |
| 3238 | delimiter := "" |
| 3239 | for i := 0; i < count; i++ { |
| 3240 | pendingEntry := heap.Pop(&pendingLogs).(*LogEntry) |
| 3241 | result += fmt.Sprintf("%s[%d, %d]", delimiter, pendingEntry.Sequence, pendingEntry.EndSequence) |
| 3242 | delimiter = "," |
| 3243 | } |
| 3244 | result += "}" |
| 3245 | return result |
| 3246 | } |
no test coverage detected