(jobID int64, stepNumber int)
| 170 | } |
| 171 | |
| 172 | func (l *zipLogMap) forStep(jobID int64, stepNumber int) (*zip.File, bool) { |
| 173 | logFetcherKey := fmt.Sprintf("%d/%d", jobID, stepNumber) |
| 174 | f, ok := l.steps[logFetcherKey] |
| 175 | return f, ok |
| 176 | } |
| 177 | |
| 178 | func (l *zipLogMap) addStep(jobID int64, stepNumber int, zf *zip.File) { |
| 179 | logFetcherKey := fmt.Sprintf("%d/%d", jobID, stepNumber) |
no outgoing calls