Method
getError
(group, topic string, partition int32)
Source from the content-addressed store, hash-verified
| 536 | } |
| 537 | |
| 538 | func (mr *MockOffsetCommitResponse) getError(group, topic string, partition int32) KError { |
| 539 | topics := mr.errors[group] |
| 540 | if topics == nil { |
| 541 | return ErrNoError |
| 542 | } |
| 543 | partitions := topics[topic] |
| 544 | if partitions == nil { |
| 545 | return ErrNoError |
| 546 | } |
| 547 | kerror, ok := partitions[partition] |
| 548 | if !ok { |
| 549 | return ErrNoError |
| 550 | } |
| 551 | return kerror |
| 552 | } |
| 553 | |
| 554 | // MockProduceResponse is a `ProduceResponse` builder. |
| 555 | type MockProduceResponse struct { |
Tested by
no test coverage detected