Versions in this module Expand all Collapse all v0 v0.1.1 Jul 5, 2022 Changes in this version + type MockIterator struct + func NewMockIterator(ctrl *gomock.Controller) *MockIterator + func (m *MockIterator) Ack(ctx context.Context, rp sdk.Position) error + func (m *MockIterator) EXPECT() *MockIteratorMockRecorder + func (m *MockIterator) HasNext(ctx context.Context) (bool, error) + func (m *MockIterator) Next(ctx context.Context) (sdk.Record, error) + func (m *MockIterator) Stop() error + type MockIteratorMockRecorder struct + func (mr *MockIteratorMockRecorder) Ack(ctx, rp interface{}) *gomock.Call + func (mr *MockIteratorMockRecorder) HasNext(ctx interface{}) *gomock.Call + func (mr *MockIteratorMockRecorder) Next(ctx interface{}) *gomock.Call + func (mr *MockIteratorMockRecorder) Stop() *gomock.Call