dmaap-mediator-producer/mocks/KafkaFactory.go

   1 // Code generated by mockery v1.0.0. DO NOT EDIT.
   2
   3 package mocks
   4
   5 import (
   6         mock "github.com/stretchr/testify/mock"
   7         "oransc.org/nonrtric/dmaapmediatorproducer/internal/kafkaclient"
   8 )
   9
  10 // KafkaFactory is an autogenerated mock type for the KafkaFactory type
  11 type KafkaFactory struct {
  12         mock.Mock
  13 }
  14
  15 // NewKafkaConsumer provides a mock function with given fields: topicID
  16 func (_m KafkaFactory) NewKafkaConsumer(topicID string) (kafkaclient.KafkaConsumer, error) {
  17         ret := _m.Called(topicID)
  18
  19         var r0 kafkaclient.KafkaConsumer
  20         if rf, ok := ret.Get(0).(func(string) kafkaclient.KafkaConsumer); ok {
  21                 r0 = rf(topicID)
  22         } else {
  23                 if ret.Get(0) != nil {
  24                         r0 = ret.Get(0).(kafkaclient.KafkaConsumer)
  25                 }
  26         }
  27
  28         var r1 error
  29         if rf, ok := ret.Get(1).(func(string) error); ok {
  30                 r1 = rf(topicID)
  31         } else {
  32                 r1 = ret.Error(1)
  33         }
  34
  35         return r0, r1
  36 }