Uplift from master branch

[nonrtric.git] / dmaap-mediator-producer / mocks / KafkaFactory.go

diff --git a/dmaap-mediator-producer/mocks/KafkaFactory.go b/dmaap-mediator-producer/mocks/KafkaFactory.go
new file mode 100644 (file)
index 0000000..f05457a
--- /dev/null
+++ b/dmaap-mediator-producer/mocks/KafkaFactory.go
@@ -0,0 +1,36 @@
+// Code generated by mockery v1.0.0. DO NOT EDIT.
+
+package mocks
+
+import (
+       mock "github.com/stretchr/testify/mock"
+       "oransc.org/nonrtric/dmaapmediatorproducer/internal/kafkaclient"
+)
+
+// KafkaFactory is an autogenerated mock type for the KafkaFactory type
+type KafkaFactory struct {
+       mock.Mock
+}
+
+// NewKafkaConsumer provides a mock function with given fields: topicID
+func (_m KafkaFactory) NewKafkaConsumer(topicID string) (kafkaclient.KafkaConsumer, error) {
+       ret := _m.Called(topicID)
+
+       var r0 kafkaclient.KafkaConsumer
+       if rf, ok := ret.Get(0).(func(string) kafkaclient.KafkaConsumer); ok {
+               r0 = rf(topicID)
+       } else {
+               if ret.Get(0) != nil {
+                       r0 = ret.Get(0).(kafkaclient.KafkaConsumer)
+               }
+       }
+
+       var r1 error
+       if rf, ok := ret.Get(1).(func(string) error); ok {
+               r1 = rf(topicID)
+       } else {
+               r1 = ret.Error(1)
+       }
+
+       return r0, r1
+}