From 052ea3b2913d5291dfc6a5de58db39fb5350a109 Mon Sep 17 00:00:00 2001 From: Leonard Goodell Date: Thu, 26 Aug 2021 13:15:53 -0700 Subject: [PATCH] fix: Updated ApplicationService mock Signed-off-by: Leonard Goodell --- pkg/interfaces/mocks/ApplicationService.go | 22 +++++++++++++++++++++- 1 file changed, 21 insertions(+), 1 deletion(-) diff --git a/pkg/interfaces/mocks/ApplicationService.go b/pkg/interfaces/mocks/ApplicationService.go index 53066ed9e..ddd32a022 100644 --- a/pkg/interfaces/mocks/ApplicationService.go +++ b/pkg/interfaces/mocks/ApplicationService.go @@ -67,7 +67,7 @@ func (_m *ApplicationService) AddBackgroundPublisherWithTopic(capacity int, topi return r0, r1 } -// AddFunctionsPipelineByTopic provides a mock function with given fields: id, topic, transforms +// AddFunctionsPipelineForTopic provides a mock function with given fields: id, topic, transforms func (_m *ApplicationService) AddFunctionsPipelineForTopic(id string, topic string, transforms ...func(interfaces.AppFunctionContext, interface{}) (bool, interface{})) error { _va := make([]interface{}, len(transforms)) for _i := range transforms { @@ -450,6 +450,26 @@ func (_m *ApplicationService) RegistryClient() registry.Client { return r0 } +// SetDefaultFunctionsPipeline provides a mock function with given fields: transforms +func (_m *ApplicationService) SetDefaultFunctionsPipeline(transforms ...func(interfaces.AppFunctionContext, interface{}) (bool, interface{})) error { + _va := make([]interface{}, len(transforms)) + for _i := range transforms { + _va[_i] = transforms[_i] + } + var _ca []interface{} + _ca = append(_ca, _va...) + ret := _m.Called(_ca...) + + var r0 error + if rf, ok := ret.Get(0).(func(...func(interfaces.AppFunctionContext, interface{}) (bool, interface{})) error); ok { + r0 = rf(transforms...) + } else { + r0 = ret.Error(0) + } + + return r0 +} + // SetFunctionsPipeline provides a mock function with given fields: transforms func (_m *ApplicationService) SetFunctionsPipeline(transforms ...func(interfaces.AppFunctionContext, interface{}) (bool, interface{})) error { _va := make([]interface{}, len(transforms))