MCPcopy
hub / github.com/IBM/sarama / NewMockOffsetFetchResponse

Function NewMockOffsetFetchResponse

mockresponses.go:618–620  ·  view source on GitHub ↗
(t TestReporter)

Source from the content-addressed store, hash-verified

616}
617
618func NewMockOffsetFetchResponse(t TestReporter) *MockOffsetFetchResponse {
619 return &MockOffsetFetchResponse{t: t}
620}
621
622func (mr *MockOffsetFetchResponse) SetOffset(group, topic string, partition int32, offset int64, metadata string, kerror KError) *MockOffsetFetchResponse {
623 if mr.offsets == nil {

Callers 6

TestConsumerGroupNewSessionDuringOffsetLoadFunction · 0.85
TestConsume_RaceTestFunction · 0.85
TestConsumerGroupSessionCancelCause_RebalanceFunction · 0.85
TestConsumerGroupReasonFunction · 0.85
TestListConsumerGroupOffsetsFunction · 0.85
TestListConsumerGroupOffsetsBatchFunction · 0.85

Calls

no outgoing calls

Tested by 6

TestConsumerGroupNewSessionDuringOffsetLoadFunction · 0.68
TestConsume_RaceTestFunction · 0.68
TestConsumerGroupSessionCancelCause_RebalanceFunction · 0.68
TestConsumerGroupReasonFunction · 0.68
TestListConsumerGroupOffsetsFunction · 0.68
TestListConsumerGroupOffsetsBatchFunction · 0.68