blob: 9a08e70ce0203e67bd99c1230bff66e5aeba87c7 [file] [log] [blame]
ssiddiquif076cb82021-04-23 10:47:04 +05301/*
2 * Copyright 2021-present Open Networking Foundation
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
17// Code generated by MockGen. DO NOT EDIT.
18// Source: github.com/opencord/voltha-lib-go/v4/pkg/kafka (interfaces: InterContainerProxy)
19
20// Package device is a generated GoMock package.
21package device
22
23import (
24 context "context"
25 reflect "reflect"
26
27 gomock "github.com/golang/mock/gomock"
28 any "github.com/golang/protobuf/ptypes/any"
29 kafka "github.com/opencord/voltha-lib-go/v4/pkg/kafka"
30)
31
32// MockInterContainerProxy is a mock of InterContainerProxy interface.
33type MockInterContainerProxy struct {
34 ctrl *gomock.Controller
35 recorder *MockInterContainerProxyMockRecorder
36}
37
38// MockInterContainerProxyMockRecorder is the mock recorder for MockInterContainerProxy.
39type MockInterContainerProxyMockRecorder struct {
40 mock *MockInterContainerProxy
41}
42
43// NewMockInterContainerProxy creates a new mock instance.
44func NewMockInterContainerProxy(ctrl *gomock.Controller) *MockInterContainerProxy {
45 mock := &MockInterContainerProxy{ctrl: ctrl}
46 mock.recorder = &MockInterContainerProxyMockRecorder{mock}
47 return mock
48}
49
50// EXPECT returns an object that allows the caller to indicate expected use.
51func (m *MockInterContainerProxy) EXPECT() *MockInterContainerProxyMockRecorder {
52 return m.recorder
53}
54
55// DeleteTopic mocks base method.
56func (m *MockInterContainerProxy) DeleteTopic(arg0 context.Context, arg1 kafka.Topic) error {
57 m.ctrl.T.Helper()
58 ret := m.ctrl.Call(m, "DeleteTopic", arg0, arg1)
59 ret0, _ := ret[0].(error)
60 return ret0
61}
62
63// DeleteTopic indicates an expected call of DeleteTopic.
64func (mr *MockInterContainerProxyMockRecorder) DeleteTopic(arg0, arg1 interface{}) *gomock.Call {
65 mr.mock.ctrl.T.Helper()
66 return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteTopic", reflect.TypeOf((*MockInterContainerProxy)(nil).DeleteTopic), arg0, arg1)
67}
68
69// EnableLivenessChannel mocks base method.
70func (m *MockInterContainerProxy) EnableLivenessChannel(arg0 context.Context, arg1 bool) chan bool {
71 m.ctrl.T.Helper()
72 ret := m.ctrl.Call(m, "EnableLivenessChannel", arg0, arg1)
73 ret0, _ := ret[0].(chan bool)
74 return ret0
75}
76
77// EnableLivenessChannel indicates an expected call of EnableLivenessChannel.
78func (mr *MockInterContainerProxyMockRecorder) EnableLivenessChannel(arg0, arg1 interface{}) *gomock.Call {
79 mr.mock.ctrl.T.Helper()
80 return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "EnableLivenessChannel", reflect.TypeOf((*MockInterContainerProxy)(nil).EnableLivenessChannel), arg0, arg1)
81}
82
83// GetDefaultTopic mocks base method.
84func (m *MockInterContainerProxy) GetDefaultTopic() *kafka.Topic {
85 m.ctrl.T.Helper()
86 ret := m.ctrl.Call(m, "GetDefaultTopic")
87 ret0, _ := ret[0].(*kafka.Topic)
88 return ret0
89}
90
91// GetDefaultTopic indicates an expected call of GetDefaultTopic.
92func (mr *MockInterContainerProxyMockRecorder) GetDefaultTopic() *gomock.Call {
93 mr.mock.ctrl.T.Helper()
94 return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetDefaultTopic", reflect.TypeOf((*MockInterContainerProxy)(nil).GetDefaultTopic))
95}
96
97// InvokeAsyncRPC mocks base method.
98func (m *MockInterContainerProxy) InvokeAsyncRPC(arg0 context.Context, arg1 string, arg2, arg3 *kafka.Topic, arg4 bool, arg5 string, arg6 ...*kafka.KVArg) chan *kafka.RpcResponse {
99 m.ctrl.T.Helper()
100 varargs := []interface{}{arg0, arg1, arg2, arg3, arg4, arg5}
101 for _, a := range arg6 {
102 varargs = append(varargs, a)
103 }
104 ret := m.ctrl.Call(m, "InvokeAsyncRPC", varargs...)
105 ret0, _ := ret[0].(chan *kafka.RpcResponse)
106 return ret0
107}
108
109// InvokeAsyncRPC indicates an expected call of InvokeAsyncRPC.
110func (mr *MockInterContainerProxyMockRecorder) InvokeAsyncRPC(arg0, arg1, arg2, arg3, arg4, arg5 interface{}, arg6 ...interface{}) *gomock.Call {
111 mr.mock.ctrl.T.Helper()
112 varargs := append([]interface{}{arg0, arg1, arg2, arg3, arg4, arg5}, arg6...)
113 return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InvokeAsyncRPC", reflect.TypeOf((*MockInterContainerProxy)(nil).InvokeAsyncRPC), varargs...)
114}
115
116// InvokeRPC mocks base method.
117func (m *MockInterContainerProxy) InvokeRPC(arg0 context.Context, arg1 string, arg2, arg3 *kafka.Topic, arg4 bool, arg5 string, arg6 ...*kafka.KVArg) (bool, *any.Any) {
118 m.ctrl.T.Helper()
119 varargs := []interface{}{arg0, arg1, arg2, arg3, arg4, arg5}
120 for _, a := range arg6 {
121 varargs = append(varargs, a)
122 }
123 ret := m.ctrl.Call(m, "InvokeRPC", varargs...)
124 ret0, _ := ret[0].(bool)
125 ret1, _ := ret[1].(*any.Any)
126 return ret0, ret1
127}
128
129// InvokeRPC indicates an expected call of InvokeRPC.
130func (mr *MockInterContainerProxyMockRecorder) InvokeRPC(arg0, arg1, arg2, arg3, arg4, arg5 interface{}, arg6 ...interface{}) *gomock.Call {
131 mr.mock.ctrl.T.Helper()
132 varargs := append([]interface{}{arg0, arg1, arg2, arg3, arg4, arg5}, arg6...)
133 return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InvokeRPC", reflect.TypeOf((*MockInterContainerProxy)(nil).InvokeRPC), varargs...)
134}
135
136// SendLiveness mocks base method.
137func (m *MockInterContainerProxy) SendLiveness(arg0 context.Context) error {
138 m.ctrl.T.Helper()
139 ret := m.ctrl.Call(m, "SendLiveness", arg0)
140 ret0, _ := ret[0].(error)
141 return ret0
142}
143
144// SendLiveness indicates an expected call of SendLiveness.
145func (mr *MockInterContainerProxyMockRecorder) SendLiveness(arg0 interface{}) *gomock.Call {
146 mr.mock.ctrl.T.Helper()
147 return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SendLiveness", reflect.TypeOf((*MockInterContainerProxy)(nil).SendLiveness), arg0)
148}
149
150// Start mocks base method.
151func (m *MockInterContainerProxy) Start(arg0 context.Context) error {
152 m.ctrl.T.Helper()
153 ret := m.ctrl.Call(m, "Start", arg0)
154 ret0, _ := ret[0].(error)
155 return ret0
156}
157
158// Start indicates an expected call of Start.
159func (mr *MockInterContainerProxyMockRecorder) Start(arg0 interface{}) *gomock.Call {
160 mr.mock.ctrl.T.Helper()
161 return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Start", reflect.TypeOf((*MockInterContainerProxy)(nil).Start), arg0)
162}
163
164// Stop mocks base method.
165func (m *MockInterContainerProxy) Stop(arg0 context.Context) {
166 m.ctrl.T.Helper()
167 m.ctrl.Call(m, "Stop", arg0)
168}
169
170// Stop indicates an expected call of Stop.
171func (mr *MockInterContainerProxyMockRecorder) Stop(arg0 interface{}) *gomock.Call {
172 mr.mock.ctrl.T.Helper()
173 return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Stop", reflect.TypeOf((*MockInterContainerProxy)(nil).Stop), arg0)
174}
175
176// SubscribeWithDefaultRequestHandler mocks base method.
177func (m *MockInterContainerProxy) SubscribeWithDefaultRequestHandler(arg0 context.Context, arg1 kafka.Topic, arg2 int64) error {
178 m.ctrl.T.Helper()
179 ret := m.ctrl.Call(m, "SubscribeWithDefaultRequestHandler", arg0, arg1, arg2)
180 ret0, _ := ret[0].(error)
181 return ret0
182}
183
184// SubscribeWithDefaultRequestHandler indicates an expected call of SubscribeWithDefaultRequestHandler.
185func (mr *MockInterContainerProxyMockRecorder) SubscribeWithDefaultRequestHandler(arg0, arg1, arg2 interface{}) *gomock.Call {
186 mr.mock.ctrl.T.Helper()
187 return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SubscribeWithDefaultRequestHandler", reflect.TypeOf((*MockInterContainerProxy)(nil).SubscribeWithDefaultRequestHandler), arg0, arg1, arg2)
188}
189
190// SubscribeWithRequestHandlerInterface mocks base method.
191func (m *MockInterContainerProxy) SubscribeWithRequestHandlerInterface(arg0 context.Context, arg1 kafka.Topic, arg2 interface{}) error {
192 m.ctrl.T.Helper()
193 ret := m.ctrl.Call(m, "SubscribeWithRequestHandlerInterface", arg0, arg1, arg2)
194 ret0, _ := ret[0].(error)
195 return ret0
196}
197
198// SubscribeWithRequestHandlerInterface indicates an expected call of SubscribeWithRequestHandlerInterface.
199func (mr *MockInterContainerProxyMockRecorder) SubscribeWithRequestHandlerInterface(arg0, arg1, arg2 interface{}) *gomock.Call {
200 mr.mock.ctrl.T.Helper()
201 return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SubscribeWithRequestHandlerInterface", reflect.TypeOf((*MockInterContainerProxy)(nil).SubscribeWithRequestHandlerInterface), arg0, arg1, arg2)
202}
203
204// UnSubscribeFromRequestHandler mocks base method.
205func (m *MockInterContainerProxy) UnSubscribeFromRequestHandler(arg0 context.Context, arg1 kafka.Topic) error {
206 m.ctrl.T.Helper()
207 ret := m.ctrl.Call(m, "UnSubscribeFromRequestHandler", arg0, arg1)
208 ret0, _ := ret[0].(error)
209 return ret0
210}
211
212// UnSubscribeFromRequestHandler indicates an expected call of UnSubscribeFromRequestHandler.
213func (mr *MockInterContainerProxyMockRecorder) UnSubscribeFromRequestHandler(arg0, arg1 interface{}) *gomock.Call {
214 mr.mock.ctrl.T.Helper()
215 return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UnSubscribeFromRequestHandler", reflect.TypeOf((*MockInterContainerProxy)(nil).UnSubscribeFromRequestHandler), arg0, arg1)
216}