Versions in this module Expand all Collapse all v0 v0.1.0 Jun 13, 2024 Changes in this version + type MockSubscriber struct + func NewMockSubscriber(ctrl *gomock.Controller) *MockSubscriber + func (m *MockSubscriber) Ack(arg0 context.Context) error + func (m *MockSubscriber) EXPECT() *MockSubscriberMockRecorder + func (m *MockSubscriber) Next(ctx context.Context) (sdk.Record, error) + func (m *MockSubscriber) Stop() error + type MockSubscriberMockRecorder struct + func (mr *MockSubscriberMockRecorder) Ack(arg0 interface{}) *gomock.Call + func (mr *MockSubscriberMockRecorder) Next(ctx interface{}) *gomock.Call + func (mr *MockSubscriberMockRecorder) Stop() *gomock.Call
Go to main page