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