(insertIndex int)
| 164 | } |
| 165 | |
| 166 | func (tracker *RequestTracker) Delete(insertIndex int) { |
| 167 | copy(tracker.mmappedFile[insertIndex:], strings.Repeat("\x00", maxEntrySize)) |
| 168 | tracker.getNextIndex <- insertIndex |
| 169 | } |
| 170 | |
| 171 | func (tracker *RequestTracker) Insert(ctx context.Context, entry []byte) (int, error) { |
| 172 | if len(entry) > maxEntrySize { |
no outgoing calls