1 files changed, 19 insertions, 19 deletions
diff --git a/internal/distributor/mock_Distributor.go b/internal/distributor/mock_Distributor.go
index 93d7dd8d2..42248c3f2 100644
--- a/internal/distributor/mock_Distributor.go
+++ b/internal/distributor/mock_Distributor.go
@@ -9,40 +9,38 @@ type MockDistributor struct {
 	mock.Mock
 }
 
-// ClientAPIIn provides a mock function with given fields:
-func (_m *MockDistributor) ClientAPIIn() chan interface{} {
+// FromClientAPI provides a mock function with given fields:
+func (_m *MockDistributor) FromClientAPI() chan FromClientAPI {
 	ret := _m.Called()
 
-	var r0 chan interface{}
-	if rf, ok := ret.Get(0).(func() chan interface{}); ok {
+	var r0 chan FromClientAPI
+	if rf, ok := ret.Get(0).(func() chan FromClientAPI); ok {
 		r0 = rf()
 	} else {
 		if ret.Get(0) != nil {
-			r0 = ret.Get(0).(chan interface{})
+			r0 = ret.Get(0).(chan FromClientAPI)
 		}
 	}
 
 	return r0
 }
 
-// ClientAPIOut provides a mock function with given fields:
-func (_m *MockDistributor) ClientAPIOut() chan interface{} {
+// Start provides a mock function with given fields:
+func (_m *MockDistributor) Start() error {
 	ret := _m.Called()
 
-	var r0 chan interface{}
-	if rf, ok := ret.Get(0).(func() chan interface{}); ok {
+	var r0 error
+	if rf, ok := ret.Get(0).(func() error); ok {
 		r0 = rf()
 	} else {
-		if ret.Get(0) != nil {
-			r0 = ret.Get(0).(chan interface{})
-		}
+		r0 = ret.Error(0)
 	}
 
 	return r0
 }
 
-// Start provides a mock function with given fields:
-func (_m *MockDistributor) Start() error {
+// Stop provides a mock function with given fields:
+func (_m *MockDistributor) Stop() error {
 	ret := _m.Called()
 
 	var r0 error
@@ -55,15 +53,17 @@ func (_m *MockDistributor) Start() error {
 	return r0
 }
 
-// Stop provides a mock function with given fields:
-func (_m *MockDistributor) Stop() error {
+// ToClientAPI provides a mock function with given fields:
+func (_m *MockDistributor) ToClientAPI() chan ToClientAPI {
 	ret := _m.Called()
 
-	var r0 error
-	if rf, ok := ret.Get(0).(func() error); ok {
+	var r0 chan ToClientAPI
+	if rf, ok := ret.Get(0).(func() chan ToClientAPI); ok {
 		r0 = rf()
 	} else {
-		r0 = ret.Error(0)
+		if ret.Get(0) != nil {
+			r0 = ret.Get(0).(chan ToClientAPI)
+		}
 	}
 
 	return r0