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