Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DataProvider ¶
DataProvider is an autogenerated mock type for the DataProvider type
func NewDataProvider ¶
func NewDataProvider(t interface { mock.TestingT Cleanup(func()) }) *DataProvider
NewDataProvider creates a new instance of DataProvider. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*DataProvider) Arguments ¶
func (_m *DataProvider) Arguments() models.Arguments
Arguments provides a mock function with given fields:
func (*DataProvider) Close ¶
func (_m *DataProvider) Close()
Close provides a mock function with given fields:
func (*DataProvider) ID ¶
func (_m *DataProvider) ID() string
ID provides a mock function with given fields:
func (*DataProvider) Run ¶
func (_m *DataProvider) Run() error
Run provides a mock function with given fields:
func (*DataProvider) Topic ¶
func (_m *DataProvider) Topic() string
Topic provides a mock function with given fields:
type DataProviderFactory ¶
DataProviderFactory is an autogenerated mock type for the DataProviderFactory type
func NewDataProviderFactory ¶
func NewDataProviderFactory(t interface { mock.TestingT Cleanup(func()) }) *DataProviderFactory
NewDataProviderFactory creates a new instance of DataProviderFactory. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*DataProviderFactory) NewDataProvider ¶
func (_m *DataProviderFactory) NewDataProvider(ctx context.Context, subscriptionID string, topic string, args models.Arguments, ch chan<- interface{}) (data_providers.DataProvider, error)
NewDataProvider provides a mock function with given fields: ctx, subscriptionID, topic, args, ch