(t TestReporter)
| 227 | } |
| 228 | |
| 229 | func NewMockOffsetResponse(t TestReporter) *MockOffsetResponse { |
| 230 | return &MockOffsetResponse{ |
| 231 | offsets: make(map[string]map[int32]map[int64]int64), |
| 232 | t: t, |
| 233 | } |
| 234 | } |
| 235 | |
| 236 | func (mor *MockOffsetResponse) SetOffset(topic string, partition int32, time, offset int64) *MockOffsetResponse { |
| 237 | partitions := mor.offsets[topic] |
no outgoing calls