From d6bc0265888c7b2a1cb05f543e8fafb34b4119cb Mon Sep 17 00:00:00 2001 From: "dependabot[bot]" <49699333+dependabot[bot]@users.noreply.github.com> Date: Mon, 18 Sep 2023 09:26:44 +0000 Subject: [PATCH 1/3] go.mod: bump go.uber.org/mock from 0.2.0 to 0.3.0 Bumps [go.uber.org/mock](https://github.com/uber/mock) from 0.2.0 to 0.3.0. - [Release notes](https://github.com/uber/mock/releases) - [Changelog](https://github.com/uber-go/mock/blob/main/CHANGELOG.md) - [Commits](https://github.com/uber/mock/compare/v0.2.0...v0.3.0) --- updated-dependencies: - dependency-name: go.uber.org/mock dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] --- go.mod | 2 +- go.sum | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/go.mod b/go.mod index 4c355965f..d6fd2b880 100644 --- a/go.mod +++ b/go.mod @@ -43,7 +43,7 @@ require ( github.com/rs/zerolog v1.30.0 github.com/twmb/go-cache v1.2.0 go.uber.org/goleak v1.2.1 - go.uber.org/mock v0.2.0 + go.uber.org/mock v0.3.0 golang.org/x/exp v0.0.0-20230713183714-613f0c0eb8a1 golang.org/x/tools v0.13.0 golang.org/x/xerrors v0.0.0-20220907171357-04be3eba64a2 diff --git a/go.sum b/go.sum index b38e3b151..1954a6a1f 100644 --- a/go.sum +++ b/go.sum @@ -690,8 +690,8 @@ go.uber.org/atomic v1.11.0 h1:ZvwS0R+56ePWxUNi+Atn9dWONBPp/AUETXlHW0DxSjE= go.uber.org/atomic v1.11.0/go.mod h1:LUxbIzbOniOlMKjJjyPfpl4v+PKK2cNJn91OQbhoJI0= go.uber.org/goleak v1.2.1 h1:NBol2c7O1ZokfZ0LEU9K6Whx/KnwvepVetCUhtKja4A= go.uber.org/goleak v1.2.1/go.mod h1:qlT2yGI9QafXHhZZLxlSuNsMw3FFLxBr+tBRlmO1xH4= -go.uber.org/mock v0.2.0 h1:TaP3xedm7JaAgScZO7tlvlKrqT0p7I6OsdGB5YNSMDU= -go.uber.org/mock v0.2.0/go.mod h1:J0y0rp9L3xiff1+ZBfKxlC1fz2+aO16tw0tsDOixfuM= +go.uber.org/mock v0.3.0 h1:3mUxI1No2/60yUYax92Pt8eNOEecx2D3lcXZh2NEZJo= +go.uber.org/mock v0.3.0/go.mod h1:a6FSlNadKUHUa9IP5Vyt1zh4fC7uAwxMutEAscFbkZc= go.uber.org/multierr v1.1.0/go.mod h1:wR5kodmAFQ0UK8QlbwjlSNy0Z68gJhDJUG5sjR94q/0= go.uber.org/multierr v1.3.0/go.mod h1:VgVr7evmIr6uPjLBxg28wmKNXyqE9akIJ5XnfpiKl+4= go.uber.org/multierr v1.5.0/go.mod h1:FeouvMocqHpRaaGuG9EjoKcStLC43Zu/fmqdUMPcKYU= From b9de6243bf75e30c7870d012988822d9f156ebe7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lovro=20Ma=C5=BEgon?= Date: Mon, 18 Sep 2023 13:35:34 +0200 Subject: [PATCH 2/3] regenerate mocks, fix issues --- .golangci.yml | 1 + pkg/foundation/database/mock/database.go | 16 +++-- pkg/foundation/log/ctxlogger_test.go | 2 +- pkg/foundation/semaphore/semaphore_test.go | 1 - pkg/orchestrator/mock/orchestrator.go | 62 +++++++++--------- pkg/pipeline/stream/mock/destination.go | 16 +++-- pkg/pipeline/stream/mock/dlq.go | 12 ++-- pkg/pipeline/stream/mock/source.go | 16 +++-- pkg/pipeline/stream/source_acker_test.go | 16 +++-- pkg/plugin/mock/plugin.go | 42 ++++++------ pkg/processor/mock/processor.go | 12 ++-- pkg/provisioning/mock/provisioning.go | 52 ++++++++------- pkg/record/schema/mock/mutable.go | 74 ++++++++++++---------- pkg/record/schema/mock/schema.go | 44 +++++++------ pkg/web/api/mock/connector.go | 20 +++--- pkg/web/api/mock/connector_service.go | 22 ++++--- pkg/web/api/mock/pipeline.go | 22 ++++--- pkg/web/api/mock/plugin.go | 8 ++- pkg/web/api/mock/processor.go | 20 +++--- pkg/web/api/mock/processor_service_in.go | 22 ++++--- pkg/web/api/mock/processor_service_out.go | 22 ++++--- 21 files changed, 289 insertions(+), 213 deletions(-) diff --git a/.golangci.yml b/.golangci.yml index 0a00f3018..1f75ec46d 100644 --- a/.golangci.yml +++ b/.golangci.yml @@ -42,6 +42,7 @@ issues: - path: _test\.go linters: - dogsled + - gosec linters: # please, do not use `enable-all`: it's deprecated and will be removed soon. diff --git a/pkg/foundation/database/mock/database.go b/pkg/foundation/database/mock/database.go index da288758d..9bc554126 100644 --- a/pkg/foundation/database/mock/database.go +++ b/pkg/foundation/database/mock/database.go @@ -1,6 +1,10 @@ // Code generated by MockGen. DO NOT EDIT. // Source: github.com/conduitio/conduit/pkg/foundation/database (interfaces: DB) - +// +// Generated by this command: +// +// mockgen -destination=mock/database.go -package=mock -mock_names=DB=DB . DB +// // Package mock is a generated GoMock package. package mock @@ -59,7 +63,7 @@ func (m *DB) Get(arg0 context.Context, arg1 string) ([]byte, error) { } // Get indicates an expected call of Get. -func (mr *DBMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call { +func (mr *DBMockRecorder) Get(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Get", reflect.TypeOf((*DB)(nil).Get), arg0, arg1) } @@ -74,7 +78,7 @@ func (m *DB) GetKeys(arg0 context.Context, arg1 string) ([]string, error) { } // GetKeys indicates an expected call of GetKeys. -func (mr *DBMockRecorder) GetKeys(arg0, arg1 interface{}) *gomock.Call { +func (mr *DBMockRecorder) GetKeys(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetKeys", reflect.TypeOf((*DB)(nil).GetKeys), arg0, arg1) } @@ -90,7 +94,7 @@ func (m *DB) NewTransaction(arg0 context.Context, arg1 bool) (database.Transacti } // NewTransaction indicates an expected call of NewTransaction. -func (mr *DBMockRecorder) NewTransaction(arg0, arg1 interface{}) *gomock.Call { +func (mr *DBMockRecorder) NewTransaction(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "NewTransaction", reflect.TypeOf((*DB)(nil).NewTransaction), arg0, arg1) } @@ -104,7 +108,7 @@ func (m *DB) Ping(arg0 context.Context) error { } // Ping indicates an expected call of Ping. -func (mr *DBMockRecorder) Ping(arg0 interface{}) *gomock.Call { +func (mr *DBMockRecorder) Ping(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Ping", reflect.TypeOf((*DB)(nil).Ping), arg0) } @@ -118,7 +122,7 @@ func (m *DB) Set(arg0 context.Context, arg1 string, arg2 []byte) error { } // Set indicates an expected call of Set. -func (mr *DBMockRecorder) Set(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *DBMockRecorder) Set(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Set", reflect.TypeOf((*DB)(nil).Set), arg0, arg1, arg2) } diff --git a/pkg/foundation/log/ctxlogger_test.go b/pkg/foundation/log/ctxlogger_test.go index fd41bf8dc..5e4edb80e 100644 --- a/pkg/foundation/log/ctxlogger_test.go +++ b/pkg/foundation/log/ctxlogger_test.go @@ -488,7 +488,7 @@ func TestCtxLoggerFatal(t *testing.T) { t.Fatal("should not reach code after emitting fatal log") return } - cmd := exec.Command(os.Args[0], "-test.run=TestCtxLoggerFatal") //nolint:gosec // only a test + cmd := exec.Command(os.Args[0], "-test.run=TestCtxLoggerFatal") cmd.Env = append(os.Environ(), "CTXLOGGER_FATAL=1") err := cmd.Run() if e, ok := err.(*exec.ExitError); !ok || e.ExitCode() != 1 { diff --git a/pkg/foundation/semaphore/semaphore_test.go b/pkg/foundation/semaphore/semaphore_test.go index 9ab4ba021..7c3bdff73 100644 --- a/pkg/foundation/semaphore/semaphore_test.go +++ b/pkg/foundation/semaphore/semaphore_test.go @@ -33,7 +33,6 @@ func HammerSimple(sem *semaphore.Simple, loops int, mu *sync.Mutex) { tkn := sem.Enqueue() mu.Unlock() lock := sem.Acquire(tkn) - //nolint:gosec // math/rand is good enough for a test time.Sleep(time.Duration(rand.Int63n(int64(maxSleep/time.Nanosecond))) * time.Nanosecond) sem.Release(lock) } diff --git a/pkg/orchestrator/mock/orchestrator.go b/pkg/orchestrator/mock/orchestrator.go index 53b30cb2c..98c5df6eb 100644 --- a/pkg/orchestrator/mock/orchestrator.go +++ b/pkg/orchestrator/mock/orchestrator.go @@ -1,6 +1,10 @@ // Code generated by MockGen. DO NOT EDIT. // Source: github.com/conduitio/conduit/pkg/orchestrator (interfaces: PipelineService,ConnectorService,ProcessorService,PluginService) - +// +// Generated by this command: +// +// mockgen -destination=mock/orchestrator.go -package=mock -mock_names=PipelineService=PipelineService,ConnectorService=ConnectorService,ProcessorService=ProcessorService,PluginService=PluginService . PipelineService,ConnectorService,ProcessorService,PluginService +// // Package mock is a generated GoMock package. package mock @@ -49,7 +53,7 @@ func (m *PipelineService) AddConnector(arg0 context.Context, arg1, arg2 string) } // AddConnector indicates an expected call of AddConnector. -func (mr *PipelineServiceMockRecorder) AddConnector(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) AddConnector(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "AddConnector", reflect.TypeOf((*PipelineService)(nil).AddConnector), arg0, arg1, arg2) } @@ -64,7 +68,7 @@ func (m *PipelineService) AddProcessor(arg0 context.Context, arg1, arg2 string) } // AddProcessor indicates an expected call of AddProcessor. -func (mr *PipelineServiceMockRecorder) AddProcessor(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) AddProcessor(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "AddProcessor", reflect.TypeOf((*PipelineService)(nil).AddProcessor), arg0, arg1, arg2) } @@ -79,7 +83,7 @@ func (m *PipelineService) Create(arg0 context.Context, arg1 string, arg2 pipelin } // Create indicates an expected call of Create. -func (mr *PipelineServiceMockRecorder) Create(arg0, arg1, arg2, arg3 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) Create(arg0, arg1, arg2, arg3 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Create", reflect.TypeOf((*PipelineService)(nil).Create), arg0, arg1, arg2, arg3) } @@ -93,7 +97,7 @@ func (m *PipelineService) Delete(arg0 context.Context, arg1 string) error { } // Delete indicates an expected call of Delete. -func (mr *PipelineServiceMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) Delete(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*PipelineService)(nil).Delete), arg0, arg1) } @@ -108,7 +112,7 @@ func (m *PipelineService) Get(arg0 context.Context, arg1 string) (*pipeline.Inst } // Get indicates an expected call of Get. -func (mr *PipelineServiceMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) Get(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Get", reflect.TypeOf((*PipelineService)(nil).Get), arg0, arg1) } @@ -122,7 +126,7 @@ func (m *PipelineService) List(arg0 context.Context) map[string]*pipeline.Instan } // List indicates an expected call of List. -func (mr *PipelineServiceMockRecorder) List(arg0 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) List(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "List", reflect.TypeOf((*PipelineService)(nil).List), arg0) } @@ -137,7 +141,7 @@ func (m *PipelineService) RemoveConnector(arg0 context.Context, arg1, arg2 strin } // RemoveConnector indicates an expected call of RemoveConnector. -func (mr *PipelineServiceMockRecorder) RemoveConnector(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) RemoveConnector(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RemoveConnector", reflect.TypeOf((*PipelineService)(nil).RemoveConnector), arg0, arg1, arg2) } @@ -152,7 +156,7 @@ func (m *PipelineService) RemoveProcessor(arg0 context.Context, arg1, arg2 strin } // RemoveProcessor indicates an expected call of RemoveProcessor. -func (mr *PipelineServiceMockRecorder) RemoveProcessor(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) RemoveProcessor(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RemoveProcessor", reflect.TypeOf((*PipelineService)(nil).RemoveProcessor), arg0, arg1, arg2) } @@ -166,7 +170,7 @@ func (m *PipelineService) Start(arg0 context.Context, arg1 pipeline.ConnectorFet } // Start indicates an expected call of Start. -func (mr *PipelineServiceMockRecorder) Start(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) Start(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Start", reflect.TypeOf((*PipelineService)(nil).Start), arg0, arg1, arg2, arg3, arg4) } @@ -180,7 +184,7 @@ func (m *PipelineService) Stop(arg0 context.Context, arg1 string, arg2 bool) err } // Stop indicates an expected call of Stop. -func (mr *PipelineServiceMockRecorder) Stop(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) Stop(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Stop", reflect.TypeOf((*PipelineService)(nil).Stop), arg0, arg1, arg2) } @@ -195,7 +199,7 @@ func (m *PipelineService) Update(arg0 context.Context, arg1 string, arg2 pipelin } // Update indicates an expected call of Update. -func (mr *PipelineServiceMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) Update(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Update", reflect.TypeOf((*PipelineService)(nil).Update), arg0, arg1, arg2) } @@ -210,7 +214,7 @@ func (m *PipelineService) UpdateDLQ(arg0 context.Context, arg1 string, arg2 pipe } // UpdateDLQ indicates an expected call of UpdateDLQ. -func (mr *PipelineServiceMockRecorder) UpdateDLQ(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) UpdateDLQ(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateDLQ", reflect.TypeOf((*PipelineService)(nil).UpdateDLQ), arg0, arg1, arg2) } @@ -248,7 +252,7 @@ func (m *ConnectorService) AddProcessor(arg0 context.Context, arg1, arg2 string) } // AddProcessor indicates an expected call of AddProcessor. -func (mr *ConnectorServiceMockRecorder) AddProcessor(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *ConnectorServiceMockRecorder) AddProcessor(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "AddProcessor", reflect.TypeOf((*ConnectorService)(nil).AddProcessor), arg0, arg1, arg2) } @@ -263,7 +267,7 @@ func (m *ConnectorService) Create(arg0 context.Context, arg1 string, arg2 connec } // Create indicates an expected call of Create. -func (mr *ConnectorServiceMockRecorder) Create(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call { +func (mr *ConnectorServiceMockRecorder) Create(arg0, arg1, arg2, arg3, arg4, arg5, arg6 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Create", reflect.TypeOf((*ConnectorService)(nil).Create), arg0, arg1, arg2, arg3, arg4, arg5, arg6) } @@ -277,7 +281,7 @@ func (m *ConnectorService) Delete(arg0 context.Context, arg1 string, arg2 connec } // Delete indicates an expected call of Delete. -func (mr *ConnectorServiceMockRecorder) Delete(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *ConnectorServiceMockRecorder) Delete(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*ConnectorService)(nil).Delete), arg0, arg1, arg2) } @@ -292,7 +296,7 @@ func (m *ConnectorService) Get(arg0 context.Context, arg1 string) (*connector.In } // Get indicates an expected call of Get. -func (mr *ConnectorServiceMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call { +func (mr *ConnectorServiceMockRecorder) Get(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Get", reflect.TypeOf((*ConnectorService)(nil).Get), arg0, arg1) } @@ -306,7 +310,7 @@ func (m *ConnectorService) List(arg0 context.Context) map[string]*connector.Inst } // List indicates an expected call of List. -func (mr *ConnectorServiceMockRecorder) List(arg0 interface{}) *gomock.Call { +func (mr *ConnectorServiceMockRecorder) List(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "List", reflect.TypeOf((*ConnectorService)(nil).List), arg0) } @@ -321,7 +325,7 @@ func (m *ConnectorService) RemoveProcessor(arg0 context.Context, arg1, arg2 stri } // RemoveProcessor indicates an expected call of RemoveProcessor. -func (mr *ConnectorServiceMockRecorder) RemoveProcessor(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *ConnectorServiceMockRecorder) RemoveProcessor(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RemoveProcessor", reflect.TypeOf((*ConnectorService)(nil).RemoveProcessor), arg0, arg1, arg2) } @@ -336,7 +340,7 @@ func (m *ConnectorService) Update(arg0 context.Context, arg1 string, arg2 connec } // Update indicates an expected call of Update. -func (mr *ConnectorServiceMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *ConnectorServiceMockRecorder) Update(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Update", reflect.TypeOf((*ConnectorService)(nil).Update), arg0, arg1, arg2) } @@ -374,7 +378,7 @@ func (m *ProcessorService) Create(arg0 context.Context, arg1, arg2 string, arg3 } // Create indicates an expected call of Create. -func (mr *ProcessorServiceMockRecorder) Create(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call { +func (mr *ProcessorServiceMockRecorder) Create(arg0, arg1, arg2, arg3, arg4, arg5 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Create", reflect.TypeOf((*ProcessorService)(nil).Create), arg0, arg1, arg2, arg3, arg4, arg5) } @@ -388,7 +392,7 @@ func (m *ProcessorService) Delete(arg0 context.Context, arg1 string) error { } // Delete indicates an expected call of Delete. -func (mr *ProcessorServiceMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call { +func (mr *ProcessorServiceMockRecorder) Delete(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*ProcessorService)(nil).Delete), arg0, arg1) } @@ -403,7 +407,7 @@ func (m *ProcessorService) Get(arg0 context.Context, arg1 string) (*processor.In } // Get indicates an expected call of Get. -func (mr *ProcessorServiceMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call { +func (mr *ProcessorServiceMockRecorder) Get(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Get", reflect.TypeOf((*ProcessorService)(nil).Get), arg0, arg1) } @@ -417,7 +421,7 @@ func (m *ProcessorService) List(arg0 context.Context) map[string]*processor.Inst } // List indicates an expected call of List. -func (mr *ProcessorServiceMockRecorder) List(arg0 interface{}) *gomock.Call { +func (mr *ProcessorServiceMockRecorder) List(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "List", reflect.TypeOf((*ProcessorService)(nil).List), arg0) } @@ -432,7 +436,7 @@ func (m *ProcessorService) Update(arg0 context.Context, arg1 string, arg2 proces } // Update indicates an expected call of Update. -func (mr *ProcessorServiceMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *ProcessorServiceMockRecorder) Update(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Update", reflect.TypeOf((*ProcessorService)(nil).Update), arg0, arg1, arg2) } @@ -470,7 +474,7 @@ func (m *PluginService) List(arg0 context.Context) (map[string]plugin.Specificat } // List indicates an expected call of List. -func (mr *PluginServiceMockRecorder) List(arg0 interface{}) *gomock.Call { +func (mr *PluginServiceMockRecorder) List(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "List", reflect.TypeOf((*PluginService)(nil).List), arg0) } @@ -485,7 +489,7 @@ func (m *PluginService) NewDispenser(arg0 log.CtxLogger, arg1 string) (plugin.Di } // NewDispenser indicates an expected call of NewDispenser. -func (mr *PluginServiceMockRecorder) NewDispenser(arg0, arg1 interface{}) *gomock.Call { +func (mr *PluginServiceMockRecorder) NewDispenser(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "NewDispenser", reflect.TypeOf((*PluginService)(nil).NewDispenser), arg0, arg1) } @@ -499,7 +503,7 @@ func (m *PluginService) ValidateDestinationConfig(arg0 context.Context, arg1 plu } // ValidateDestinationConfig indicates an expected call of ValidateDestinationConfig. -func (mr *PluginServiceMockRecorder) ValidateDestinationConfig(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *PluginServiceMockRecorder) ValidateDestinationConfig(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ValidateDestinationConfig", reflect.TypeOf((*PluginService)(nil).ValidateDestinationConfig), arg0, arg1, arg2) } @@ -513,7 +517,7 @@ func (m *PluginService) ValidateSourceConfig(arg0 context.Context, arg1 plugin.D } // ValidateSourceConfig indicates an expected call of ValidateSourceConfig. -func (mr *PluginServiceMockRecorder) ValidateSourceConfig(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *PluginServiceMockRecorder) ValidateSourceConfig(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ValidateSourceConfig", reflect.TypeOf((*PluginService)(nil).ValidateSourceConfig), arg0, arg1, arg2) } diff --git a/pkg/pipeline/stream/mock/destination.go b/pkg/pipeline/stream/mock/destination.go index b2d4b5db4..cb2ad781f 100644 --- a/pkg/pipeline/stream/mock/destination.go +++ b/pkg/pipeline/stream/mock/destination.go @@ -1,6 +1,10 @@ // Code generated by MockGen. DO NOT EDIT. // Source: github.com/conduitio/conduit/pkg/pipeline/stream (interfaces: Destination) - +// +// Generated by this command: +// +// mockgen -destination=mock/destination.go -package=mock -mock_names=Destination=Destination . Destination +// // Package mock is a generated GoMock package. package mock @@ -45,7 +49,7 @@ func (m *Destination) Ack(arg0 context.Context) (record.Position, error) { } // Ack indicates an expected call of Ack. -func (mr *DestinationMockRecorder) Ack(arg0 interface{}) *gomock.Call { +func (mr *DestinationMockRecorder) Ack(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Ack", reflect.TypeOf((*Destination)(nil).Ack), arg0) } @@ -87,7 +91,7 @@ func (m *Destination) Open(arg0 context.Context) error { } // Open indicates an expected call of Open. -func (mr *DestinationMockRecorder) Open(arg0 interface{}) *gomock.Call { +func (mr *DestinationMockRecorder) Open(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Open", reflect.TypeOf((*Destination)(nil).Open), arg0) } @@ -101,7 +105,7 @@ func (m *Destination) Stop(arg0 context.Context, arg1 record.Position) error { } // Stop indicates an expected call of Stop. -func (mr *DestinationMockRecorder) Stop(arg0, arg1 interface{}) *gomock.Call { +func (mr *DestinationMockRecorder) Stop(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Stop", reflect.TypeOf((*Destination)(nil).Stop), arg0, arg1) } @@ -115,7 +119,7 @@ func (m *Destination) Teardown(arg0 context.Context) error { } // Teardown indicates an expected call of Teardown. -func (mr *DestinationMockRecorder) Teardown(arg0 interface{}) *gomock.Call { +func (mr *DestinationMockRecorder) Teardown(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Teardown", reflect.TypeOf((*Destination)(nil).Teardown), arg0) } @@ -129,7 +133,7 @@ func (m *Destination) Write(arg0 context.Context, arg1 record.Record) error { } // Write indicates an expected call of Write. -func (mr *DestinationMockRecorder) Write(arg0, arg1 interface{}) *gomock.Call { +func (mr *DestinationMockRecorder) Write(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Write", reflect.TypeOf((*Destination)(nil).Write), arg0, arg1) } diff --git a/pkg/pipeline/stream/mock/dlq.go b/pkg/pipeline/stream/mock/dlq.go index 308583562..c5f44d085 100644 --- a/pkg/pipeline/stream/mock/dlq.go +++ b/pkg/pipeline/stream/mock/dlq.go @@ -1,6 +1,10 @@ // Code generated by MockGen. DO NOT EDIT. // Source: github.com/conduitio/conduit/pkg/pipeline/stream (interfaces: DLQHandler) - +// +// Generated by this command: +// +// mockgen -destination=mock/dlq.go -package=mock -mock_names=DLQHandler=DLQHandler . DLQHandler +// // Package mock is a generated GoMock package. package mock @@ -44,7 +48,7 @@ func (m *DLQHandler) Close(arg0 context.Context) error { } // Close indicates an expected call of Close. -func (mr *DLQHandlerMockRecorder) Close(arg0 interface{}) *gomock.Call { +func (mr *DLQHandlerMockRecorder) Close(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Close", reflect.TypeOf((*DLQHandler)(nil).Close), arg0) } @@ -58,7 +62,7 @@ func (m *DLQHandler) Open(arg0 context.Context) error { } // Open indicates an expected call of Open. -func (mr *DLQHandlerMockRecorder) Open(arg0 interface{}) *gomock.Call { +func (mr *DLQHandlerMockRecorder) Open(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Open", reflect.TypeOf((*DLQHandler)(nil).Open), arg0) } @@ -72,7 +76,7 @@ func (m *DLQHandler) Write(arg0 context.Context, arg1 record.Record) error { } // Write indicates an expected call of Write. -func (mr *DLQHandlerMockRecorder) Write(arg0, arg1 interface{}) *gomock.Call { +func (mr *DLQHandlerMockRecorder) Write(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Write", reflect.TypeOf((*DLQHandler)(nil).Write), arg0, arg1) } diff --git a/pkg/pipeline/stream/mock/source.go b/pkg/pipeline/stream/mock/source.go index e50a2e1d8..9fefda5c8 100644 --- a/pkg/pipeline/stream/mock/source.go +++ b/pkg/pipeline/stream/mock/source.go @@ -1,6 +1,10 @@ // Code generated by MockGen. DO NOT EDIT. // Source: github.com/conduitio/conduit/pkg/pipeline/stream (interfaces: Source) - +// +// Generated by this command: +// +// mockgen -destination=mock/source.go -package=mock -mock_names=Source=Source . Source +// // Package mock is a generated GoMock package. package mock @@ -44,7 +48,7 @@ func (m *Source) Ack(arg0 context.Context, arg1 record.Position) error { } // Ack indicates an expected call of Ack. -func (mr *SourceMockRecorder) Ack(arg0, arg1 interface{}) *gomock.Call { +func (mr *SourceMockRecorder) Ack(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Ack", reflect.TypeOf((*Source)(nil).Ack), arg0, arg1) } @@ -86,7 +90,7 @@ func (m *Source) Open(arg0 context.Context) error { } // Open indicates an expected call of Open. -func (mr *SourceMockRecorder) Open(arg0 interface{}) *gomock.Call { +func (mr *SourceMockRecorder) Open(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Open", reflect.TypeOf((*Source)(nil).Open), arg0) } @@ -101,7 +105,7 @@ func (m *Source) Read(arg0 context.Context) (record.Record, error) { } // Read indicates an expected call of Read. -func (mr *SourceMockRecorder) Read(arg0 interface{}) *gomock.Call { +func (mr *SourceMockRecorder) Read(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Read", reflect.TypeOf((*Source)(nil).Read), arg0) } @@ -116,7 +120,7 @@ func (m *Source) Stop(arg0 context.Context) (record.Position, error) { } // Stop indicates an expected call of Stop. -func (mr *SourceMockRecorder) Stop(arg0 interface{}) *gomock.Call { +func (mr *SourceMockRecorder) Stop(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Stop", reflect.TypeOf((*Source)(nil).Stop), arg0) } @@ -130,7 +134,7 @@ func (m *Source) Teardown(arg0 context.Context) error { } // Teardown indicates an expected call of Teardown. -func (mr *SourceMockRecorder) Teardown(arg0 interface{}) *gomock.Call { +func (mr *SourceMockRecorder) Teardown(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Teardown", reflect.TypeOf((*Source)(nil).Teardown), arg0) } diff --git a/pkg/pipeline/stream/source_acker_test.go b/pkg/pipeline/stream/source_acker_test.go index 1004e0e66..96fb99bb2 100644 --- a/pkg/pipeline/stream/source_acker_test.go +++ b/pkg/pipeline/stream/source_acker_test.go @@ -73,7 +73,7 @@ func TestSourceAckerNode_AckOrder(t *testing.T) { messages := helper.sendMessages(ctx, 1000, in, out) // expect all messages to be acked expectedCalls := helper.expectAcks(ctx, messages, src) - gomock.InOrder(expectedCalls...) // enforce order of acks + inOrder(expectedCalls) // enforce order of acks // ack messages concurrently in random order, expect no errors var wg sync.WaitGroup @@ -104,7 +104,7 @@ func TestSourceAckerNode_FailedAck(t *testing.T) { messages := helper.sendMessages(ctx, 1000, in, out) // expect first 500 to be acked successfully expectedCalls := helper.expectAcks(ctx, messages[:500], src) - gomock.InOrder(expectedCalls...) // enforce order of acks + inOrder(expectedCalls) // enforce order of acks // the 500th message should be acked unsuccessfully wantErr := cerrors.New("test error") src.EXPECT(). @@ -150,7 +150,7 @@ func TestSourceAckerNode_FailedNack(t *testing.T) { messages := helper.sendMessages(ctx, 1000, in, out) // expect first 500 to be acked successfully expectedCalls := helper.expectAcks(ctx, messages[:500], src) - gomock.InOrder(expectedCalls...) // enforce order of acks + inOrder(expectedCalls) // enforce order of acks // the 500th message will be nacked unsuccessfully, no more acks should be received after that // ack messages concurrently in random order @@ -292,10 +292,18 @@ func (sourceAckerNodeTestHelper) ackMessagesConcurrently( go func(msg *Message) { defer wg.Done() // sleep for a random amount of time and ack the message - //nolint:gosec // math/rand is good enough for a test time.Sleep(time.Duration(rand.Int63n(int64(maxSleep/time.Nanosecond))) * time.Nanosecond) err := msg.Ack() assertAckErr(msg, err) }(messages[i]) } } + +// inOrder is a utility method that passes []*gomock.Call to gomock.InOrder as []any. +func inOrder(calls []*gomock.Call) { + callsRepacked := make([]any, len(calls)) + for k, v := range calls { + callsRepacked[k] = v + } + gomock.InOrder(callsRepacked) +} diff --git a/pkg/plugin/mock/plugin.go b/pkg/plugin/mock/plugin.go index dd3752816..c6f665216 100644 --- a/pkg/plugin/mock/plugin.go +++ b/pkg/plugin/mock/plugin.go @@ -1,6 +1,10 @@ // Code generated by MockGen. DO NOT EDIT. // Source: github.com/conduitio/conduit/pkg/plugin (interfaces: Dispenser,DestinationPlugin,SourcePlugin,SpecifierPlugin) - +// +// Generated by this command: +// +// mockgen -destination=mock/plugin.go -package=mock -mock_names=Dispenser=Dispenser,SourcePlugin=SourcePlugin,DestinationPlugin=DestinationPlugin,SpecifierPlugin=SpecifierPlugin . Dispenser,DestinationPlugin,SourcePlugin,SpecifierPlugin +// // Package mock is a generated GoMock package. package mock @@ -114,7 +118,7 @@ func (m *DestinationPlugin) Ack(arg0 context.Context) (record.Position, error) { } // Ack indicates an expected call of Ack. -func (mr *DestinationPluginMockRecorder) Ack(arg0 interface{}) *gomock.Call { +func (mr *DestinationPluginMockRecorder) Ack(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Ack", reflect.TypeOf((*DestinationPlugin)(nil).Ack), arg0) } @@ -128,7 +132,7 @@ func (m *DestinationPlugin) Configure(arg0 context.Context, arg1 map[string]stri } // Configure indicates an expected call of Configure. -func (mr *DestinationPluginMockRecorder) Configure(arg0, arg1 interface{}) *gomock.Call { +func (mr *DestinationPluginMockRecorder) Configure(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Configure", reflect.TypeOf((*DestinationPlugin)(nil).Configure), arg0, arg1) } @@ -142,7 +146,7 @@ func (m *DestinationPlugin) LifecycleOnCreated(arg0 context.Context, arg1 map[st } // LifecycleOnCreated indicates an expected call of LifecycleOnCreated. -func (mr *DestinationPluginMockRecorder) LifecycleOnCreated(arg0, arg1 interface{}) *gomock.Call { +func (mr *DestinationPluginMockRecorder) LifecycleOnCreated(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "LifecycleOnCreated", reflect.TypeOf((*DestinationPlugin)(nil).LifecycleOnCreated), arg0, arg1) } @@ -156,7 +160,7 @@ func (m *DestinationPlugin) LifecycleOnDeleted(arg0 context.Context, arg1 map[st } // LifecycleOnDeleted indicates an expected call of LifecycleOnDeleted. -func (mr *DestinationPluginMockRecorder) LifecycleOnDeleted(arg0, arg1 interface{}) *gomock.Call { +func (mr *DestinationPluginMockRecorder) LifecycleOnDeleted(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "LifecycleOnDeleted", reflect.TypeOf((*DestinationPlugin)(nil).LifecycleOnDeleted), arg0, arg1) } @@ -170,7 +174,7 @@ func (m *DestinationPlugin) LifecycleOnUpdated(arg0 context.Context, arg1, arg2 } // LifecycleOnUpdated indicates an expected call of LifecycleOnUpdated. -func (mr *DestinationPluginMockRecorder) LifecycleOnUpdated(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *DestinationPluginMockRecorder) LifecycleOnUpdated(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "LifecycleOnUpdated", reflect.TypeOf((*DestinationPlugin)(nil).LifecycleOnUpdated), arg0, arg1, arg2) } @@ -184,7 +188,7 @@ func (m *DestinationPlugin) Start(arg0 context.Context) error { } // Start indicates an expected call of Start. -func (mr *DestinationPluginMockRecorder) Start(arg0 interface{}) *gomock.Call { +func (mr *DestinationPluginMockRecorder) Start(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Start", reflect.TypeOf((*DestinationPlugin)(nil).Start), arg0) } @@ -198,7 +202,7 @@ func (m *DestinationPlugin) Stop(arg0 context.Context, arg1 record.Position) err } // Stop indicates an expected call of Stop. -func (mr *DestinationPluginMockRecorder) Stop(arg0, arg1 interface{}) *gomock.Call { +func (mr *DestinationPluginMockRecorder) Stop(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Stop", reflect.TypeOf((*DestinationPlugin)(nil).Stop), arg0, arg1) } @@ -212,7 +216,7 @@ func (m *DestinationPlugin) Teardown(arg0 context.Context) error { } // Teardown indicates an expected call of Teardown. -func (mr *DestinationPluginMockRecorder) Teardown(arg0 interface{}) *gomock.Call { +func (mr *DestinationPluginMockRecorder) Teardown(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Teardown", reflect.TypeOf((*DestinationPlugin)(nil).Teardown), arg0) } @@ -226,7 +230,7 @@ func (m *DestinationPlugin) Write(arg0 context.Context, arg1 record.Record) erro } // Write indicates an expected call of Write. -func (mr *DestinationPluginMockRecorder) Write(arg0, arg1 interface{}) *gomock.Call { +func (mr *DestinationPluginMockRecorder) Write(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Write", reflect.TypeOf((*DestinationPlugin)(nil).Write), arg0, arg1) } @@ -263,7 +267,7 @@ func (m *SourcePlugin) Ack(arg0 context.Context, arg1 record.Position) error { } // Ack indicates an expected call of Ack. -func (mr *SourcePluginMockRecorder) Ack(arg0, arg1 interface{}) *gomock.Call { +func (mr *SourcePluginMockRecorder) Ack(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Ack", reflect.TypeOf((*SourcePlugin)(nil).Ack), arg0, arg1) } @@ -277,7 +281,7 @@ func (m *SourcePlugin) Configure(arg0 context.Context, arg1 map[string]string) e } // Configure indicates an expected call of Configure. -func (mr *SourcePluginMockRecorder) Configure(arg0, arg1 interface{}) *gomock.Call { +func (mr *SourcePluginMockRecorder) Configure(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Configure", reflect.TypeOf((*SourcePlugin)(nil).Configure), arg0, arg1) } @@ -291,7 +295,7 @@ func (m *SourcePlugin) LifecycleOnCreated(arg0 context.Context, arg1 map[string] } // LifecycleOnCreated indicates an expected call of LifecycleOnCreated. -func (mr *SourcePluginMockRecorder) LifecycleOnCreated(arg0, arg1 interface{}) *gomock.Call { +func (mr *SourcePluginMockRecorder) LifecycleOnCreated(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "LifecycleOnCreated", reflect.TypeOf((*SourcePlugin)(nil).LifecycleOnCreated), arg0, arg1) } @@ -305,7 +309,7 @@ func (m *SourcePlugin) LifecycleOnDeleted(arg0 context.Context, arg1 map[string] } // LifecycleOnDeleted indicates an expected call of LifecycleOnDeleted. -func (mr *SourcePluginMockRecorder) LifecycleOnDeleted(arg0, arg1 interface{}) *gomock.Call { +func (mr *SourcePluginMockRecorder) LifecycleOnDeleted(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "LifecycleOnDeleted", reflect.TypeOf((*SourcePlugin)(nil).LifecycleOnDeleted), arg0, arg1) } @@ -319,7 +323,7 @@ func (m *SourcePlugin) LifecycleOnUpdated(arg0 context.Context, arg1, arg2 map[s } // LifecycleOnUpdated indicates an expected call of LifecycleOnUpdated. -func (mr *SourcePluginMockRecorder) LifecycleOnUpdated(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *SourcePluginMockRecorder) LifecycleOnUpdated(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "LifecycleOnUpdated", reflect.TypeOf((*SourcePlugin)(nil).LifecycleOnUpdated), arg0, arg1, arg2) } @@ -334,7 +338,7 @@ func (m *SourcePlugin) Read(arg0 context.Context) (record.Record, error) { } // Read indicates an expected call of Read. -func (mr *SourcePluginMockRecorder) Read(arg0 interface{}) *gomock.Call { +func (mr *SourcePluginMockRecorder) Read(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Read", reflect.TypeOf((*SourcePlugin)(nil).Read), arg0) } @@ -348,7 +352,7 @@ func (m *SourcePlugin) Start(arg0 context.Context, arg1 record.Position) error { } // Start indicates an expected call of Start. -func (mr *SourcePluginMockRecorder) Start(arg0, arg1 interface{}) *gomock.Call { +func (mr *SourcePluginMockRecorder) Start(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Start", reflect.TypeOf((*SourcePlugin)(nil).Start), arg0, arg1) } @@ -363,7 +367,7 @@ func (m *SourcePlugin) Stop(arg0 context.Context) (record.Position, error) { } // Stop indicates an expected call of Stop. -func (mr *SourcePluginMockRecorder) Stop(arg0 interface{}) *gomock.Call { +func (mr *SourcePluginMockRecorder) Stop(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Stop", reflect.TypeOf((*SourcePlugin)(nil).Stop), arg0) } @@ -377,7 +381,7 @@ func (m *SourcePlugin) Teardown(arg0 context.Context) error { } // Teardown indicates an expected call of Teardown. -func (mr *SourcePluginMockRecorder) Teardown(arg0 interface{}) *gomock.Call { +func (mr *SourcePluginMockRecorder) Teardown(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Teardown", reflect.TypeOf((*SourcePlugin)(nil).Teardown), arg0) } diff --git a/pkg/processor/mock/processor.go b/pkg/processor/mock/processor.go index 4ec8c8caf..4297903df 100644 --- a/pkg/processor/mock/processor.go +++ b/pkg/processor/mock/processor.go @@ -1,6 +1,10 @@ // Code generated by MockGen. DO NOT EDIT. // Source: github.com/conduitio/conduit/pkg/processor (interfaces: Interface) - +// +// Generated by this command: +// +// mockgen -destination=mock/processor.go -package=mock -mock_names=Interface=Processor . Interface +// // Package mock is a generated GoMock package. package mock @@ -57,7 +61,7 @@ func (m *Processor) InspectIn(arg0 context.Context, arg1 string) *inspector.Sess } // InspectIn indicates an expected call of InspectIn. -func (mr *ProcessorMockRecorder) InspectIn(arg0, arg1 interface{}) *gomock.Call { +func (mr *ProcessorMockRecorder) InspectIn(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InspectIn", reflect.TypeOf((*Processor)(nil).InspectIn), arg0, arg1) } @@ -71,7 +75,7 @@ func (m *Processor) InspectOut(arg0 context.Context, arg1 string) *inspector.Ses } // InspectOut indicates an expected call of InspectOut. -func (mr *ProcessorMockRecorder) InspectOut(arg0, arg1 interface{}) *gomock.Call { +func (mr *ProcessorMockRecorder) InspectOut(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InspectOut", reflect.TypeOf((*Processor)(nil).InspectOut), arg0, arg1) } @@ -86,7 +90,7 @@ func (m *Processor) Process(arg0 context.Context, arg1 record.Record) (record.Re } // Process indicates an expected call of Process. -func (mr *ProcessorMockRecorder) Process(arg0, arg1 interface{}) *gomock.Call { +func (mr *ProcessorMockRecorder) Process(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Process", reflect.TypeOf((*Processor)(nil).Process), arg0, arg1) } diff --git a/pkg/provisioning/mock/provisioning.go b/pkg/provisioning/mock/provisioning.go index d6a714f8f..eaa29d920 100644 --- a/pkg/provisioning/mock/provisioning.go +++ b/pkg/provisioning/mock/provisioning.go @@ -1,6 +1,10 @@ // Code generated by MockGen. DO NOT EDIT. // Source: github.com/conduitio/conduit/pkg/provisioning (interfaces: PipelineService,ConnectorService,ProcessorService,PluginService) - +// +// Generated by this command: +// +// mockgen -destination=mock/provisioning.go -package=mock -mock_names=PipelineService=PipelineService,ConnectorService=ConnectorService,ProcessorService=ProcessorService,PluginService=PluginService . PipelineService,ConnectorService,ProcessorService,PluginService +// // Package mock is a generated GoMock package. package mock @@ -49,7 +53,7 @@ func (m *PipelineService) AddConnector(arg0 context.Context, arg1, arg2 string) } // AddConnector indicates an expected call of AddConnector. -func (mr *PipelineServiceMockRecorder) AddConnector(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) AddConnector(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "AddConnector", reflect.TypeOf((*PipelineService)(nil).AddConnector), arg0, arg1, arg2) } @@ -64,7 +68,7 @@ func (m *PipelineService) AddProcessor(arg0 context.Context, arg1, arg2 string) } // AddProcessor indicates an expected call of AddProcessor. -func (mr *PipelineServiceMockRecorder) AddProcessor(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) AddProcessor(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "AddProcessor", reflect.TypeOf((*PipelineService)(nil).AddProcessor), arg0, arg1, arg2) } @@ -79,7 +83,7 @@ func (m *PipelineService) Create(arg0 context.Context, arg1 string, arg2 pipelin } // Create indicates an expected call of Create. -func (mr *PipelineServiceMockRecorder) Create(arg0, arg1, arg2, arg3 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) Create(arg0, arg1, arg2, arg3 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Create", reflect.TypeOf((*PipelineService)(nil).Create), arg0, arg1, arg2, arg3) } @@ -93,7 +97,7 @@ func (m *PipelineService) Delete(arg0 context.Context, arg1 string) error { } // Delete indicates an expected call of Delete. -func (mr *PipelineServiceMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) Delete(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*PipelineService)(nil).Delete), arg0, arg1) } @@ -108,7 +112,7 @@ func (m *PipelineService) Get(arg0 context.Context, arg1 string) (*pipeline.Inst } // Get indicates an expected call of Get. -func (mr *PipelineServiceMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) Get(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Get", reflect.TypeOf((*PipelineService)(nil).Get), arg0, arg1) } @@ -122,7 +126,7 @@ func (m *PipelineService) List(arg0 context.Context) map[string]*pipeline.Instan } // List indicates an expected call of List. -func (mr *PipelineServiceMockRecorder) List(arg0 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) List(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "List", reflect.TypeOf((*PipelineService)(nil).List), arg0) } @@ -137,7 +141,7 @@ func (m *PipelineService) RemoveConnector(arg0 context.Context, arg1, arg2 strin } // RemoveConnector indicates an expected call of RemoveConnector. -func (mr *PipelineServiceMockRecorder) RemoveConnector(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) RemoveConnector(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RemoveConnector", reflect.TypeOf((*PipelineService)(nil).RemoveConnector), arg0, arg1, arg2) } @@ -152,7 +156,7 @@ func (m *PipelineService) RemoveProcessor(arg0 context.Context, arg1, arg2 strin } // RemoveProcessor indicates an expected call of RemoveProcessor. -func (mr *PipelineServiceMockRecorder) RemoveProcessor(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) RemoveProcessor(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RemoveProcessor", reflect.TypeOf((*PipelineService)(nil).RemoveProcessor), arg0, arg1, arg2) } @@ -166,7 +170,7 @@ func (m *PipelineService) Start(arg0 context.Context, arg1 pipeline.ConnectorFet } // Start indicates an expected call of Start. -func (mr *PipelineServiceMockRecorder) Start(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) Start(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Start", reflect.TypeOf((*PipelineService)(nil).Start), arg0, arg1, arg2, arg3, arg4) } @@ -180,7 +184,7 @@ func (m *PipelineService) Stop(arg0 context.Context, arg1 string, arg2 bool) err } // Stop indicates an expected call of Stop. -func (mr *PipelineServiceMockRecorder) Stop(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) Stop(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Stop", reflect.TypeOf((*PipelineService)(nil).Stop), arg0, arg1, arg2) } @@ -195,7 +199,7 @@ func (m *PipelineService) Update(arg0 context.Context, arg1 string, arg2 pipelin } // Update indicates an expected call of Update. -func (mr *PipelineServiceMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) Update(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Update", reflect.TypeOf((*PipelineService)(nil).Update), arg0, arg1, arg2) } @@ -210,7 +214,7 @@ func (m *PipelineService) UpdateDLQ(arg0 context.Context, arg1 string, arg2 pipe } // UpdateDLQ indicates an expected call of UpdateDLQ. -func (mr *PipelineServiceMockRecorder) UpdateDLQ(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *PipelineServiceMockRecorder) UpdateDLQ(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateDLQ", reflect.TypeOf((*PipelineService)(nil).UpdateDLQ), arg0, arg1, arg2) } @@ -248,7 +252,7 @@ func (m *ConnectorService) AddProcessor(arg0 context.Context, arg1, arg2 string) } // AddProcessor indicates an expected call of AddProcessor. -func (mr *ConnectorServiceMockRecorder) AddProcessor(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *ConnectorServiceMockRecorder) AddProcessor(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "AddProcessor", reflect.TypeOf((*ConnectorService)(nil).AddProcessor), arg0, arg1, arg2) } @@ -263,7 +267,7 @@ func (m *ConnectorService) Create(arg0 context.Context, arg1 string, arg2 connec } // Create indicates an expected call of Create. -func (mr *ConnectorServiceMockRecorder) Create(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call { +func (mr *ConnectorServiceMockRecorder) Create(arg0, arg1, arg2, arg3, arg4, arg5, arg6 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Create", reflect.TypeOf((*ConnectorService)(nil).Create), arg0, arg1, arg2, arg3, arg4, arg5, arg6) } @@ -277,7 +281,7 @@ func (m *ConnectorService) Delete(arg0 context.Context, arg1 string, arg2 connec } // Delete indicates an expected call of Delete. -func (mr *ConnectorServiceMockRecorder) Delete(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *ConnectorServiceMockRecorder) Delete(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*ConnectorService)(nil).Delete), arg0, arg1, arg2) } @@ -292,7 +296,7 @@ func (m *ConnectorService) Get(arg0 context.Context, arg1 string) (*connector.In } // Get indicates an expected call of Get. -func (mr *ConnectorServiceMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call { +func (mr *ConnectorServiceMockRecorder) Get(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Get", reflect.TypeOf((*ConnectorService)(nil).Get), arg0, arg1) } @@ -307,7 +311,7 @@ func (m *ConnectorService) RemoveProcessor(arg0 context.Context, arg1, arg2 stri } // RemoveProcessor indicates an expected call of RemoveProcessor. -func (mr *ConnectorServiceMockRecorder) RemoveProcessor(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *ConnectorServiceMockRecorder) RemoveProcessor(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RemoveProcessor", reflect.TypeOf((*ConnectorService)(nil).RemoveProcessor), arg0, arg1, arg2) } @@ -322,7 +326,7 @@ func (m *ConnectorService) Update(arg0 context.Context, arg1 string, arg2 connec } // Update indicates an expected call of Update. -func (mr *ConnectorServiceMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *ConnectorServiceMockRecorder) Update(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Update", reflect.TypeOf((*ConnectorService)(nil).Update), arg0, arg1, arg2) } @@ -360,7 +364,7 @@ func (m *ProcessorService) Create(arg0 context.Context, arg1, arg2 string, arg3 } // Create indicates an expected call of Create. -func (mr *ProcessorServiceMockRecorder) Create(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call { +func (mr *ProcessorServiceMockRecorder) Create(arg0, arg1, arg2, arg3, arg4, arg5 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Create", reflect.TypeOf((*ProcessorService)(nil).Create), arg0, arg1, arg2, arg3, arg4, arg5) } @@ -374,7 +378,7 @@ func (m *ProcessorService) Delete(arg0 context.Context, arg1 string) error { } // Delete indicates an expected call of Delete. -func (mr *ProcessorServiceMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call { +func (mr *ProcessorServiceMockRecorder) Delete(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*ProcessorService)(nil).Delete), arg0, arg1) } @@ -389,7 +393,7 @@ func (m *ProcessorService) Get(arg0 context.Context, arg1 string) (*processor.In } // Get indicates an expected call of Get. -func (mr *ProcessorServiceMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call { +func (mr *ProcessorServiceMockRecorder) Get(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Get", reflect.TypeOf((*ProcessorService)(nil).Get), arg0, arg1) } @@ -404,7 +408,7 @@ func (m *ProcessorService) Update(arg0 context.Context, arg1 string, arg2 proces } // Update indicates an expected call of Update. -func (mr *ProcessorServiceMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *ProcessorServiceMockRecorder) Update(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Update", reflect.TypeOf((*ProcessorService)(nil).Update), arg0, arg1, arg2) } @@ -442,7 +446,7 @@ func (m *PluginService) NewDispenser(arg0 log.CtxLogger, arg1 string) (plugin.Di } // NewDispenser indicates an expected call of NewDispenser. -func (mr *PluginServiceMockRecorder) NewDispenser(arg0, arg1 interface{}) *gomock.Call { +func (mr *PluginServiceMockRecorder) NewDispenser(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "NewDispenser", reflect.TypeOf((*PluginService)(nil).NewDispenser), arg0, arg1) } diff --git a/pkg/record/schema/mock/mutable.go b/pkg/record/schema/mock/mutable.go index cf9897dea..9cdb1e8e2 100644 --- a/pkg/record/schema/mock/mutable.go +++ b/pkg/record/schema/mock/mutable.go @@ -1,6 +1,10 @@ // Code generated by MockGen. DO NOT EDIT. // Source: github.com/conduitio/conduit/pkg/record/schema (interfaces: MutableSchema,MutableStructDescriptor,MutableField,MutableMapDescriptor,MutableArrayDescriptor,MutablePrimitiveDescriptor,MutableEnumDescriptor,MutableEnumValueDescriptor) - +// +// Generated by this command: +// +// mockgen -destination=mock/mutable.go -package=mock -mock_names=MutableSchema=MutableSchema,MutableStructDescriptor=MutableStructDescriptor,MutableField=MutableField,MutableMapDescriptor=MutableMapDescriptor,MutableArrayDescriptor=MutableArrayDescriptor,MutablePrimitiveDescriptor=MutablePrimitiveDescriptor,MutableEnumDescriptor=MutableEnumDescriptor,MutableEnumValueDescriptor=MutableEnumValueDescriptor . MutableSchema,MutableStructDescriptor,MutableField,MutableMapDescriptor,MutableArrayDescriptor,MutablePrimitiveDescriptor,MutableEnumDescriptor,MutableEnumValueDescriptor +// // Package mock is a generated GoMock package. package mock @@ -70,7 +74,7 @@ func (m *MutableSchema) SetDescriptors(arg0 []schema.MutableDescriptor) { } // SetDescriptors indicates an expected call of SetDescriptors. -func (mr *MutableSchemaMockRecorder) SetDescriptors(arg0 interface{}) *gomock.Call { +func (mr *MutableSchemaMockRecorder) SetDescriptors(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetDescriptors", reflect.TypeOf((*MutableSchema)(nil).SetDescriptors), arg0) } @@ -82,7 +86,7 @@ func (m *MutableSchema) SetVersion(arg0 int) { } // SetVersion indicates an expected call of SetVersion. -func (mr *MutableSchemaMockRecorder) SetVersion(arg0 interface{}) *gomock.Call { +func (mr *MutableSchemaMockRecorder) SetVersion(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetVersion", reflect.TypeOf((*MutableSchema)(nil).SetVersion), arg0) } @@ -145,7 +149,7 @@ func (m *MutableStructDescriptor) DescriptorType(arg0 schema.StructDescriptor) { } // DescriptorType indicates an expected call of DescriptorType. -func (mr *MutableStructDescriptorMockRecorder) DescriptorType(arg0 interface{}) *gomock.Call { +func (mr *MutableStructDescriptorMockRecorder) DescriptorType(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescriptorType", reflect.TypeOf((*MutableStructDescriptor)(nil).DescriptorType), arg0) } @@ -179,10 +183,10 @@ func (mr *MutableStructDescriptorMockRecorder) Name() *gomock.Call { } // Parameters mocks base method. -func (m *MutableStructDescriptor) Parameters() map[string]interface{} { +func (m *MutableStructDescriptor) Parameters() map[string]any { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Parameters") - ret0, _ := ret[0].(map[string]interface{}) + ret0, _ := ret[0].(map[string]any) return ret0 } @@ -199,7 +203,7 @@ func (m *MutableStructDescriptor) SetFields(arg0 []schema.MutableField) { } // SetFields indicates an expected call of SetFields. -func (mr *MutableStructDescriptorMockRecorder) SetFields(arg0 interface{}) *gomock.Call { +func (mr *MutableStructDescriptorMockRecorder) SetFields(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetFields", reflect.TypeOf((*MutableStructDescriptor)(nil).SetFields), arg0) } @@ -211,7 +215,7 @@ func (m *MutableStructDescriptor) SetName(arg0 string) { } // SetName indicates an expected call of SetName. -func (mr *MutableStructDescriptorMockRecorder) SetName(arg0 interface{}) *gomock.Call { +func (mr *MutableStructDescriptorMockRecorder) SetName(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetName", reflect.TypeOf((*MutableStructDescriptor)(nil).SetName), arg0) } @@ -260,7 +264,7 @@ func (m *MutableField) DescriptorType(arg0 schema.Field) { } // DescriptorType indicates an expected call of DescriptorType. -func (mr *MutableFieldMockRecorder) DescriptorType(arg0 interface{}) *gomock.Call { +func (mr *MutableFieldMockRecorder) DescriptorType(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescriptorType", reflect.TypeOf((*MutableField)(nil).DescriptorType), arg0) } @@ -300,7 +304,7 @@ func (m *MutableField) SetDescriptor(arg0 schema.MutableDescriptor) { } // SetDescriptor indicates an expected call of SetDescriptor. -func (mr *MutableFieldMockRecorder) SetDescriptor(arg0 interface{}) *gomock.Call { +func (mr *MutableFieldMockRecorder) SetDescriptor(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetDescriptor", reflect.TypeOf((*MutableField)(nil).SetDescriptor), arg0) } @@ -312,7 +316,7 @@ func (m *MutableField) SetIndex(arg0 int) { } // SetIndex indicates an expected call of SetIndex. -func (mr *MutableFieldMockRecorder) SetIndex(arg0 interface{}) *gomock.Call { +func (mr *MutableFieldMockRecorder) SetIndex(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetIndex", reflect.TypeOf((*MutableField)(nil).SetIndex), arg0) } @@ -324,7 +328,7 @@ func (m *MutableField) SetName(arg0 string) { } // SetName indicates an expected call of SetName. -func (mr *MutableFieldMockRecorder) SetName(arg0 interface{}) *gomock.Call { +func (mr *MutableFieldMockRecorder) SetName(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetName", reflect.TypeOf((*MutableField)(nil).SetName), arg0) } @@ -359,7 +363,7 @@ func (m *MutableMapDescriptor) DescriptorType(arg0 schema.MapDescriptor) { } // DescriptorType indicates an expected call of DescriptorType. -func (mr *MutableMapDescriptorMockRecorder) DescriptorType(arg0 interface{}) *gomock.Call { +func (mr *MutableMapDescriptorMockRecorder) DescriptorType(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescriptorType", reflect.TypeOf((*MutableMapDescriptor)(nil).DescriptorType), arg0) } @@ -379,10 +383,10 @@ func (mr *MutableMapDescriptorMockRecorder) KeyDescriptor() *gomock.Call { } // Parameters mocks base method. -func (m *MutableMapDescriptor) Parameters() map[string]interface{} { +func (m *MutableMapDescriptor) Parameters() map[string]any { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Parameters") - ret0, _ := ret[0].(map[string]interface{}) + ret0, _ := ret[0].(map[string]any) return ret0 } @@ -399,7 +403,7 @@ func (m *MutableMapDescriptor) SetKeyDescriptor(arg0 schema.MutableDescriptor) { } // SetKeyDescriptor indicates an expected call of SetKeyDescriptor. -func (mr *MutableMapDescriptorMockRecorder) SetKeyDescriptor(arg0 interface{}) *gomock.Call { +func (mr *MutableMapDescriptorMockRecorder) SetKeyDescriptor(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetKeyDescriptor", reflect.TypeOf((*MutableMapDescriptor)(nil).SetKeyDescriptor), arg0) } @@ -411,7 +415,7 @@ func (m *MutableMapDescriptor) SetValueDescriptor(arg0 schema.MutableDescriptor) } // SetValueDescriptor indicates an expected call of SetValueDescriptor. -func (mr *MutableMapDescriptorMockRecorder) SetValueDescriptor(arg0 interface{}) *gomock.Call { +func (mr *MutableMapDescriptorMockRecorder) SetValueDescriptor(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetValueDescriptor", reflect.TypeOf((*MutableMapDescriptor)(nil).SetValueDescriptor), arg0) } @@ -460,16 +464,16 @@ func (m *MutableArrayDescriptor) DescriptorType(arg0 schema.ArrayDescriptor) { } // DescriptorType indicates an expected call of DescriptorType. -func (mr *MutableArrayDescriptorMockRecorder) DescriptorType(arg0 interface{}) *gomock.Call { +func (mr *MutableArrayDescriptorMockRecorder) DescriptorType(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescriptorType", reflect.TypeOf((*MutableArrayDescriptor)(nil).DescriptorType), arg0) } // Parameters mocks base method. -func (m *MutableArrayDescriptor) Parameters() map[string]interface{} { +func (m *MutableArrayDescriptor) Parameters() map[string]any { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Parameters") - ret0, _ := ret[0].(map[string]interface{}) + ret0, _ := ret[0].(map[string]any) return ret0 } @@ -486,7 +490,7 @@ func (m *MutableArrayDescriptor) SetValueDescriptor(arg0 schema.MutableDescripto } // SetValueDescriptor indicates an expected call of SetValueDescriptor. -func (mr *MutableArrayDescriptorMockRecorder) SetValueDescriptor(arg0 interface{}) *gomock.Call { +func (mr *MutableArrayDescriptorMockRecorder) SetValueDescriptor(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetValueDescriptor", reflect.TypeOf((*MutableArrayDescriptor)(nil).SetValueDescriptor), arg0) } @@ -535,16 +539,16 @@ func (m *MutablePrimitiveDescriptor) DescriptorType(arg0 schema.PrimitiveDescrip } // DescriptorType indicates an expected call of DescriptorType. -func (mr *MutablePrimitiveDescriptorMockRecorder) DescriptorType(arg0 interface{}) *gomock.Call { +func (mr *MutablePrimitiveDescriptorMockRecorder) DescriptorType(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescriptorType", reflect.TypeOf((*MutablePrimitiveDescriptor)(nil).DescriptorType), arg0) } // Parameters mocks base method. -func (m *MutablePrimitiveDescriptor) Parameters() map[string]interface{} { +func (m *MutablePrimitiveDescriptor) Parameters() map[string]any { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Parameters") - ret0, _ := ret[0].(map[string]interface{}) + ret0, _ := ret[0].(map[string]any) return ret0 } @@ -561,7 +565,7 @@ func (m *MutablePrimitiveDescriptor) SetType(arg0 schema.PrimitiveDescriptorType } // SetType indicates an expected call of SetType. -func (mr *MutablePrimitiveDescriptorMockRecorder) SetType(arg0 interface{}) *gomock.Call { +func (mr *MutablePrimitiveDescriptorMockRecorder) SetType(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetType", reflect.TypeOf((*MutablePrimitiveDescriptor)(nil).SetType), arg0) } @@ -610,7 +614,7 @@ func (m *MutableEnumDescriptor) DescriptorType(arg0 schema.EnumDescriptor) { } // DescriptorType indicates an expected call of DescriptorType. -func (mr *MutableEnumDescriptorMockRecorder) DescriptorType(arg0 interface{}) *gomock.Call { +func (mr *MutableEnumDescriptorMockRecorder) DescriptorType(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescriptorType", reflect.TypeOf((*MutableEnumDescriptor)(nil).DescriptorType), arg0) } @@ -630,10 +634,10 @@ func (mr *MutableEnumDescriptorMockRecorder) Name() *gomock.Call { } // Parameters mocks base method. -func (m *MutableEnumDescriptor) Parameters() map[string]interface{} { +func (m *MutableEnumDescriptor) Parameters() map[string]any { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Parameters") - ret0, _ := ret[0].(map[string]interface{}) + ret0, _ := ret[0].(map[string]any) return ret0 } @@ -650,7 +654,7 @@ func (m *MutableEnumDescriptor) SetName(arg0 string) { } // SetName indicates an expected call of SetName. -func (mr *MutableEnumDescriptorMockRecorder) SetName(arg0 interface{}) *gomock.Call { +func (mr *MutableEnumDescriptorMockRecorder) SetName(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetName", reflect.TypeOf((*MutableEnumDescriptor)(nil).SetName), arg0) } @@ -662,7 +666,7 @@ func (m *MutableEnumDescriptor) SetValueDescriptors(arg0 []schema.MutableEnumVal } // SetValueDescriptors indicates an expected call of SetValueDescriptors. -func (mr *MutableEnumDescriptorMockRecorder) SetValueDescriptors(arg0 interface{}) *gomock.Call { +func (mr *MutableEnumDescriptorMockRecorder) SetValueDescriptors(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetValueDescriptors", reflect.TypeOf((*MutableEnumDescriptor)(nil).SetValueDescriptors), arg0) } @@ -711,7 +715,7 @@ func (m *MutableEnumValueDescriptor) DescriptorType(arg0 schema.EnumValueDescrip } // DescriptorType indicates an expected call of DescriptorType. -func (mr *MutableEnumValueDescriptorMockRecorder) DescriptorType(arg0 interface{}) *gomock.Call { +func (mr *MutableEnumValueDescriptorMockRecorder) DescriptorType(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescriptorType", reflect.TypeOf((*MutableEnumValueDescriptor)(nil).DescriptorType), arg0) } @@ -731,10 +735,10 @@ func (mr *MutableEnumValueDescriptorMockRecorder) Name() *gomock.Call { } // Parameters mocks base method. -func (m *MutableEnumValueDescriptor) Parameters() map[string]interface{} { +func (m *MutableEnumValueDescriptor) Parameters() map[string]any { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Parameters") - ret0, _ := ret[0].(map[string]interface{}) + ret0, _ := ret[0].(map[string]any) return ret0 } @@ -751,7 +755,7 @@ func (m *MutableEnumValueDescriptor) SetName(arg0 string) { } // SetName indicates an expected call of SetName. -func (mr *MutableEnumValueDescriptorMockRecorder) SetName(arg0 interface{}) *gomock.Call { +func (mr *MutableEnumValueDescriptorMockRecorder) SetName(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetName", reflect.TypeOf((*MutableEnumValueDescriptor)(nil).SetName), arg0) } @@ -763,7 +767,7 @@ func (m *MutableEnumValueDescriptor) SetValue(arg0 string) { } // SetValue indicates an expected call of SetValue. -func (mr *MutableEnumValueDescriptorMockRecorder) SetValue(arg0 interface{}) *gomock.Call { +func (mr *MutableEnumValueDescriptorMockRecorder) SetValue(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetValue", reflect.TypeOf((*MutableEnumValueDescriptor)(nil).SetValue), arg0) } diff --git a/pkg/record/schema/mock/schema.go b/pkg/record/schema/mock/schema.go index e56f2f598..f98a19a25 100644 --- a/pkg/record/schema/mock/schema.go +++ b/pkg/record/schema/mock/schema.go @@ -1,6 +1,10 @@ // Code generated by MockGen. DO NOT EDIT. // Source: github.com/conduitio/conduit/pkg/record/schema (interfaces: Schema,StructDescriptor,Field,MapDescriptor,ArrayDescriptor,PrimitiveDescriptor,EnumDescriptor,EnumValueDescriptor) - +// +// Generated by this command: +// +// mockgen -destination=mock/schema.go -package=mock -mock_names=Schema=Schema,StructDescriptor=StructDescriptor,Field=Field,MapDescriptor=MapDescriptor,ArrayDescriptor=ArrayDescriptor,PrimitiveDescriptor=PrimitiveDescriptor,EnumDescriptor=EnumDescriptor,EnumValueDescriptor=EnumValueDescriptor . Schema,StructDescriptor,Field,MapDescriptor,ArrayDescriptor,PrimitiveDescriptor,EnumDescriptor,EnumValueDescriptor +// // Package mock is a generated GoMock package. package mock @@ -120,7 +124,7 @@ func (m *StructDescriptor) DescriptorType(arg0 schema.StructDescriptor) { } // DescriptorType indicates an expected call of DescriptorType. -func (mr *StructDescriptorMockRecorder) DescriptorType(arg0 interface{}) *gomock.Call { +func (mr *StructDescriptorMockRecorder) DescriptorType(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescriptorType", reflect.TypeOf((*StructDescriptor)(nil).DescriptorType), arg0) } @@ -154,10 +158,10 @@ func (mr *StructDescriptorMockRecorder) Name() *gomock.Call { } // Parameters mocks base method. -func (m *StructDescriptor) Parameters() map[string]interface{} { +func (m *StructDescriptor) Parameters() map[string]any { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Parameters") - ret0, _ := ret[0].(map[string]interface{}) + ret0, _ := ret[0].(map[string]any) return ret0 } @@ -211,7 +215,7 @@ func (m *Field) DescriptorType(arg0 schema.Field) { } // DescriptorType indicates an expected call of DescriptorType. -func (mr *FieldMockRecorder) DescriptorType(arg0 interface{}) *gomock.Call { +func (mr *FieldMockRecorder) DescriptorType(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescriptorType", reflect.TypeOf((*Field)(nil).DescriptorType), arg0) } @@ -274,7 +278,7 @@ func (m *MapDescriptor) DescriptorType(arg0 schema.MapDescriptor) { } // DescriptorType indicates an expected call of DescriptorType. -func (mr *MapDescriptorMockRecorder) DescriptorType(arg0 interface{}) *gomock.Call { +func (mr *MapDescriptorMockRecorder) DescriptorType(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescriptorType", reflect.TypeOf((*MapDescriptor)(nil).DescriptorType), arg0) } @@ -294,10 +298,10 @@ func (mr *MapDescriptorMockRecorder) KeyDescriptor() *gomock.Call { } // Parameters mocks base method. -func (m *MapDescriptor) Parameters() map[string]interface{} { +func (m *MapDescriptor) Parameters() map[string]any { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Parameters") - ret0, _ := ret[0].(map[string]interface{}) + ret0, _ := ret[0].(map[string]any) return ret0 } @@ -351,16 +355,16 @@ func (m *ArrayDescriptor) DescriptorType(arg0 schema.ArrayDescriptor) { } // DescriptorType indicates an expected call of DescriptorType. -func (mr *ArrayDescriptorMockRecorder) DescriptorType(arg0 interface{}) *gomock.Call { +func (mr *ArrayDescriptorMockRecorder) DescriptorType(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescriptorType", reflect.TypeOf((*ArrayDescriptor)(nil).DescriptorType), arg0) } // Parameters mocks base method. -func (m *ArrayDescriptor) Parameters() map[string]interface{} { +func (m *ArrayDescriptor) Parameters() map[string]any { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Parameters") - ret0, _ := ret[0].(map[string]interface{}) + ret0, _ := ret[0].(map[string]any) return ret0 } @@ -414,16 +418,16 @@ func (m *PrimitiveDescriptor) DescriptorType(arg0 schema.PrimitiveDescriptor) { } // DescriptorType indicates an expected call of DescriptorType. -func (mr *PrimitiveDescriptorMockRecorder) DescriptorType(arg0 interface{}) *gomock.Call { +func (mr *PrimitiveDescriptorMockRecorder) DescriptorType(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescriptorType", reflect.TypeOf((*PrimitiveDescriptor)(nil).DescriptorType), arg0) } // Parameters mocks base method. -func (m *PrimitiveDescriptor) Parameters() map[string]interface{} { +func (m *PrimitiveDescriptor) Parameters() map[string]any { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Parameters") - ret0, _ := ret[0].(map[string]interface{}) + ret0, _ := ret[0].(map[string]any) return ret0 } @@ -477,7 +481,7 @@ func (m *EnumDescriptor) DescriptorType(arg0 schema.EnumDescriptor) { } // DescriptorType indicates an expected call of DescriptorType. -func (mr *EnumDescriptorMockRecorder) DescriptorType(arg0 interface{}) *gomock.Call { +func (mr *EnumDescriptorMockRecorder) DescriptorType(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescriptorType", reflect.TypeOf((*EnumDescriptor)(nil).DescriptorType), arg0) } @@ -497,10 +501,10 @@ func (mr *EnumDescriptorMockRecorder) Name() *gomock.Call { } // Parameters mocks base method. -func (m *EnumDescriptor) Parameters() map[string]interface{} { +func (m *EnumDescriptor) Parameters() map[string]any { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Parameters") - ret0, _ := ret[0].(map[string]interface{}) + ret0, _ := ret[0].(map[string]any) return ret0 } @@ -554,7 +558,7 @@ func (m *EnumValueDescriptor) DescriptorType(arg0 schema.EnumValueDescriptor) { } // DescriptorType indicates an expected call of DescriptorType. -func (mr *EnumValueDescriptorMockRecorder) DescriptorType(arg0 interface{}) *gomock.Call { +func (mr *EnumValueDescriptorMockRecorder) DescriptorType(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescriptorType", reflect.TypeOf((*EnumValueDescriptor)(nil).DescriptorType), arg0) } @@ -574,10 +578,10 @@ func (mr *EnumValueDescriptorMockRecorder) Name() *gomock.Call { } // Parameters mocks base method. -func (m *EnumValueDescriptor) Parameters() map[string]interface{} { +func (m *EnumValueDescriptor) Parameters() map[string]any { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Parameters") - ret0, _ := ret[0].(map[string]interface{}) + ret0, _ := ret[0].(map[string]any) return ret0 } diff --git a/pkg/web/api/mock/connector.go b/pkg/web/api/mock/connector.go index e12c0450d..1fef554bd 100644 --- a/pkg/web/api/mock/connector.go +++ b/pkg/web/api/mock/connector.go @@ -1,6 +1,10 @@ // Code generated by MockGen. DO NOT EDIT. // Source: github.com/conduitio/conduit/pkg/web/api (interfaces: ConnectorOrchestrator) - +// +// Generated by this command: +// +// mockgen -destination=mock/connector.go -package=mock -mock_names=ConnectorOrchestrator=ConnectorOrchestrator . ConnectorOrchestrator +// // Package mock is a generated GoMock package. package mock @@ -46,7 +50,7 @@ func (m *ConnectorOrchestrator) Create(arg0 context.Context, arg1 connector.Type } // Create indicates an expected call of Create. -func (mr *ConnectorOrchestratorMockRecorder) Create(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call { +func (mr *ConnectorOrchestratorMockRecorder) Create(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Create", reflect.TypeOf((*ConnectorOrchestrator)(nil).Create), arg0, arg1, arg2, arg3, arg4) } @@ -60,7 +64,7 @@ func (m *ConnectorOrchestrator) Delete(arg0 context.Context, arg1 string) error } // Delete indicates an expected call of Delete. -func (mr *ConnectorOrchestratorMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call { +func (mr *ConnectorOrchestratorMockRecorder) Delete(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*ConnectorOrchestrator)(nil).Delete), arg0, arg1) } @@ -75,7 +79,7 @@ func (m *ConnectorOrchestrator) Get(arg0 context.Context, arg1 string) (*connect } // Get indicates an expected call of Get. -func (mr *ConnectorOrchestratorMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call { +func (mr *ConnectorOrchestratorMockRecorder) Get(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Get", reflect.TypeOf((*ConnectorOrchestrator)(nil).Get), arg0, arg1) } @@ -90,7 +94,7 @@ func (m *ConnectorOrchestrator) Inspect(arg0 context.Context, arg1 string) (*ins } // Inspect indicates an expected call of Inspect. -func (mr *ConnectorOrchestratorMockRecorder) Inspect(arg0, arg1 interface{}) *gomock.Call { +func (mr *ConnectorOrchestratorMockRecorder) Inspect(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Inspect", reflect.TypeOf((*ConnectorOrchestrator)(nil).Inspect), arg0, arg1) } @@ -104,7 +108,7 @@ func (m *ConnectorOrchestrator) List(arg0 context.Context) map[string]*connector } // List indicates an expected call of List. -func (mr *ConnectorOrchestratorMockRecorder) List(arg0 interface{}) *gomock.Call { +func (mr *ConnectorOrchestratorMockRecorder) List(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "List", reflect.TypeOf((*ConnectorOrchestrator)(nil).List), arg0) } @@ -119,7 +123,7 @@ func (m *ConnectorOrchestrator) Update(arg0 context.Context, arg1 string, arg2 c } // Update indicates an expected call of Update. -func (mr *ConnectorOrchestratorMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *ConnectorOrchestratorMockRecorder) Update(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Update", reflect.TypeOf((*ConnectorOrchestrator)(nil).Update), arg0, arg1, arg2) } @@ -133,7 +137,7 @@ func (m *ConnectorOrchestrator) Validate(arg0 context.Context, arg1 connector.Ty } // Validate indicates an expected call of Validate. -func (mr *ConnectorOrchestratorMockRecorder) Validate(arg0, arg1, arg2, arg3 interface{}) *gomock.Call { +func (mr *ConnectorOrchestratorMockRecorder) Validate(arg0, arg1, arg2, arg3 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Validate", reflect.TypeOf((*ConnectorOrchestrator)(nil).Validate), arg0, arg1, arg2, arg3) } diff --git a/pkg/web/api/mock/connector_service.go b/pkg/web/api/mock/connector_service.go index a79801afa..ffe3469f5 100644 --- a/pkg/web/api/mock/connector_service.go +++ b/pkg/web/api/mock/connector_service.go @@ -1,6 +1,10 @@ // Code generated by MockGen. DO NOT EDIT. // Source: github.com/conduitio/conduit/proto/api/v1 (interfaces: ConnectorService_InspectConnectorServer) - +// +// Generated by this command: +// +// mockgen -destination=mock/connector_service.go -package=mock -mock_names=ConnectorService_InspectConnectorServer=ConnectorService_InspectConnectorServer github.com/conduitio/conduit/proto/api/v1 ConnectorService_InspectConnectorServer +// // Package mock is a generated GoMock package. package mock @@ -51,7 +55,7 @@ func (mr *ConnectorService_InspectConnectorServerMockRecorder) Context() *gomock } // RecvMsg mocks base method. -func (m *ConnectorService_InspectConnectorServer) RecvMsg(arg0 interface{}) error { +func (m *ConnectorService_InspectConnectorServer) RecvMsg(arg0 any) error { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "RecvMsg", arg0) ret0, _ := ret[0].(error) @@ -59,7 +63,7 @@ func (m *ConnectorService_InspectConnectorServer) RecvMsg(arg0 interface{}) erro } // RecvMsg indicates an expected call of RecvMsg. -func (mr *ConnectorService_InspectConnectorServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call { +func (mr *ConnectorService_InspectConnectorServerMockRecorder) RecvMsg(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RecvMsg", reflect.TypeOf((*ConnectorService_InspectConnectorServer)(nil).RecvMsg), arg0) } @@ -73,7 +77,7 @@ func (m *ConnectorService_InspectConnectorServer) Send(arg0 *apiv1.InspectConnec } // Send indicates an expected call of Send. -func (mr *ConnectorService_InspectConnectorServerMockRecorder) Send(arg0 interface{}) *gomock.Call { +func (mr *ConnectorService_InspectConnectorServerMockRecorder) Send(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Send", reflect.TypeOf((*ConnectorService_InspectConnectorServer)(nil).Send), arg0) } @@ -87,13 +91,13 @@ func (m *ConnectorService_InspectConnectorServer) SendHeader(arg0 metadata.MD) e } // SendHeader indicates an expected call of SendHeader. -func (mr *ConnectorService_InspectConnectorServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call { +func (mr *ConnectorService_InspectConnectorServerMockRecorder) SendHeader(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SendHeader", reflect.TypeOf((*ConnectorService_InspectConnectorServer)(nil).SendHeader), arg0) } // SendMsg mocks base method. -func (m *ConnectorService_InspectConnectorServer) SendMsg(arg0 interface{}) error { +func (m *ConnectorService_InspectConnectorServer) SendMsg(arg0 any) error { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "SendMsg", arg0) ret0, _ := ret[0].(error) @@ -101,7 +105,7 @@ func (m *ConnectorService_InspectConnectorServer) SendMsg(arg0 interface{}) erro } // SendMsg indicates an expected call of SendMsg. -func (mr *ConnectorService_InspectConnectorServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call { +func (mr *ConnectorService_InspectConnectorServerMockRecorder) SendMsg(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SendMsg", reflect.TypeOf((*ConnectorService_InspectConnectorServer)(nil).SendMsg), arg0) } @@ -115,7 +119,7 @@ func (m *ConnectorService_InspectConnectorServer) SetHeader(arg0 metadata.MD) er } // SetHeader indicates an expected call of SetHeader. -func (mr *ConnectorService_InspectConnectorServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call { +func (mr *ConnectorService_InspectConnectorServerMockRecorder) SetHeader(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetHeader", reflect.TypeOf((*ConnectorService_InspectConnectorServer)(nil).SetHeader), arg0) } @@ -127,7 +131,7 @@ func (m *ConnectorService_InspectConnectorServer) SetTrailer(arg0 metadata.MD) { } // SetTrailer indicates an expected call of SetTrailer. -func (mr *ConnectorService_InspectConnectorServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call { +func (mr *ConnectorService_InspectConnectorServerMockRecorder) SetTrailer(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetTrailer", reflect.TypeOf((*ConnectorService_InspectConnectorServer)(nil).SetTrailer), arg0) } diff --git a/pkg/web/api/mock/pipeline.go b/pkg/web/api/mock/pipeline.go index e939187f6..2fdac6528 100644 --- a/pkg/web/api/mock/pipeline.go +++ b/pkg/web/api/mock/pipeline.go @@ -1,6 +1,10 @@ // Code generated by MockGen. DO NOT EDIT. // Source: github.com/conduitio/conduit/pkg/web/api (interfaces: PipelineOrchestrator) - +// +// Generated by this command: +// +// mockgen -destination=mock/pipeline.go -package=mock -mock_names=PipelineOrchestrator=PipelineOrchestrator . PipelineOrchestrator +// // Package mock is a generated GoMock package. package mock @@ -45,7 +49,7 @@ func (m *PipelineOrchestrator) Create(arg0 context.Context, arg1 pipeline.Config } // Create indicates an expected call of Create. -func (mr *PipelineOrchestratorMockRecorder) Create(arg0, arg1 interface{}) *gomock.Call { +func (mr *PipelineOrchestratorMockRecorder) Create(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Create", reflect.TypeOf((*PipelineOrchestrator)(nil).Create), arg0, arg1) } @@ -59,7 +63,7 @@ func (m *PipelineOrchestrator) Delete(arg0 context.Context, arg1 string) error { } // Delete indicates an expected call of Delete. -func (mr *PipelineOrchestratorMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call { +func (mr *PipelineOrchestratorMockRecorder) Delete(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*PipelineOrchestrator)(nil).Delete), arg0, arg1) } @@ -74,7 +78,7 @@ func (m *PipelineOrchestrator) Get(arg0 context.Context, arg1 string) (*pipeline } // Get indicates an expected call of Get. -func (mr *PipelineOrchestratorMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call { +func (mr *PipelineOrchestratorMockRecorder) Get(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Get", reflect.TypeOf((*PipelineOrchestrator)(nil).Get), arg0, arg1) } @@ -88,7 +92,7 @@ func (m *PipelineOrchestrator) List(arg0 context.Context) map[string]*pipeline.I } // List indicates an expected call of List. -func (mr *PipelineOrchestratorMockRecorder) List(arg0 interface{}) *gomock.Call { +func (mr *PipelineOrchestratorMockRecorder) List(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "List", reflect.TypeOf((*PipelineOrchestrator)(nil).List), arg0) } @@ -102,7 +106,7 @@ func (m *PipelineOrchestrator) Start(arg0 context.Context, arg1 string) error { } // Start indicates an expected call of Start. -func (mr *PipelineOrchestratorMockRecorder) Start(arg0, arg1 interface{}) *gomock.Call { +func (mr *PipelineOrchestratorMockRecorder) Start(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Start", reflect.TypeOf((*PipelineOrchestrator)(nil).Start), arg0, arg1) } @@ -116,7 +120,7 @@ func (m *PipelineOrchestrator) Stop(arg0 context.Context, arg1 string, arg2 bool } // Stop indicates an expected call of Stop. -func (mr *PipelineOrchestratorMockRecorder) Stop(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *PipelineOrchestratorMockRecorder) Stop(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Stop", reflect.TypeOf((*PipelineOrchestrator)(nil).Stop), arg0, arg1, arg2) } @@ -131,7 +135,7 @@ func (m *PipelineOrchestrator) Update(arg0 context.Context, arg1 string, arg2 pi } // Update indicates an expected call of Update. -func (mr *PipelineOrchestratorMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *PipelineOrchestratorMockRecorder) Update(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Update", reflect.TypeOf((*PipelineOrchestrator)(nil).Update), arg0, arg1, arg2) } @@ -146,7 +150,7 @@ func (m *PipelineOrchestrator) UpdateDLQ(arg0 context.Context, arg1 string, arg2 } // UpdateDLQ indicates an expected call of UpdateDLQ. -func (mr *PipelineOrchestratorMockRecorder) UpdateDLQ(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *PipelineOrchestratorMockRecorder) UpdateDLQ(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateDLQ", reflect.TypeOf((*PipelineOrchestrator)(nil).UpdateDLQ), arg0, arg1, arg2) } diff --git a/pkg/web/api/mock/plugin.go b/pkg/web/api/mock/plugin.go index 3ff834cd2..7120171bb 100644 --- a/pkg/web/api/mock/plugin.go +++ b/pkg/web/api/mock/plugin.go @@ -1,6 +1,10 @@ // Code generated by MockGen. DO NOT EDIT. // Source: github.com/conduitio/conduit/pkg/web/api (interfaces: PluginOrchestrator) - +// +// Generated by this command: +// +// mockgen -destination=mock/plugin.go -package=mock -mock_names=PluginOrchestrator=PluginOrchestrator . PluginOrchestrator +// // Package mock is a generated GoMock package. package mock @@ -45,7 +49,7 @@ func (m *PluginOrchestrator) List(arg0 context.Context) (map[string]plugin.Speci } // List indicates an expected call of List. -func (mr *PluginOrchestratorMockRecorder) List(arg0 interface{}) *gomock.Call { +func (mr *PluginOrchestratorMockRecorder) List(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "List", reflect.TypeOf((*PluginOrchestrator)(nil).List), arg0) } diff --git a/pkg/web/api/mock/processor.go b/pkg/web/api/mock/processor.go index ea48b015c..ff31df5ea 100644 --- a/pkg/web/api/mock/processor.go +++ b/pkg/web/api/mock/processor.go @@ -1,6 +1,10 @@ // Code generated by MockGen. DO NOT EDIT. // Source: github.com/conduitio/conduit/pkg/web/api (interfaces: ProcessorOrchestrator) - +// +// Generated by this command: +// +// mockgen -destination=mock/processor.go -package=mock -mock_names=ProcessorOrchestrator=ProcessorOrchestrator . ProcessorOrchestrator +// // Package mock is a generated GoMock package. package mock @@ -46,7 +50,7 @@ func (m *ProcessorOrchestrator) Create(arg0 context.Context, arg1 string, arg2 p } // Create indicates an expected call of Create. -func (mr *ProcessorOrchestratorMockRecorder) Create(arg0, arg1, arg2, arg3 interface{}) *gomock.Call { +func (mr *ProcessorOrchestratorMockRecorder) Create(arg0, arg1, arg2, arg3 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Create", reflect.TypeOf((*ProcessorOrchestrator)(nil).Create), arg0, arg1, arg2, arg3) } @@ -60,7 +64,7 @@ func (m *ProcessorOrchestrator) Delete(arg0 context.Context, arg1 string) error } // Delete indicates an expected call of Delete. -func (mr *ProcessorOrchestratorMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call { +func (mr *ProcessorOrchestratorMockRecorder) Delete(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*ProcessorOrchestrator)(nil).Delete), arg0, arg1) } @@ -75,7 +79,7 @@ func (m *ProcessorOrchestrator) Get(arg0 context.Context, arg1 string) (*process } // Get indicates an expected call of Get. -func (mr *ProcessorOrchestratorMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call { +func (mr *ProcessorOrchestratorMockRecorder) Get(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Get", reflect.TypeOf((*ProcessorOrchestrator)(nil).Get), arg0, arg1) } @@ -90,7 +94,7 @@ func (m *ProcessorOrchestrator) InspectIn(arg0 context.Context, arg1 string) (*i } // InspectIn indicates an expected call of InspectIn. -func (mr *ProcessorOrchestratorMockRecorder) InspectIn(arg0, arg1 interface{}) *gomock.Call { +func (mr *ProcessorOrchestratorMockRecorder) InspectIn(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InspectIn", reflect.TypeOf((*ProcessorOrchestrator)(nil).InspectIn), arg0, arg1) } @@ -105,7 +109,7 @@ func (m *ProcessorOrchestrator) InspectOut(arg0 context.Context, arg1 string) (* } // InspectOut indicates an expected call of InspectOut. -func (mr *ProcessorOrchestratorMockRecorder) InspectOut(arg0, arg1 interface{}) *gomock.Call { +func (mr *ProcessorOrchestratorMockRecorder) InspectOut(arg0, arg1 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InspectOut", reflect.TypeOf((*ProcessorOrchestrator)(nil).InspectOut), arg0, arg1) } @@ -119,7 +123,7 @@ func (m *ProcessorOrchestrator) List(arg0 context.Context) map[string]*processor } // List indicates an expected call of List. -func (mr *ProcessorOrchestratorMockRecorder) List(arg0 interface{}) *gomock.Call { +func (mr *ProcessorOrchestratorMockRecorder) List(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "List", reflect.TypeOf((*ProcessorOrchestrator)(nil).List), arg0) } @@ -134,7 +138,7 @@ func (m *ProcessorOrchestrator) Update(arg0 context.Context, arg1 string, arg2 p } // Update indicates an expected call of Update. -func (mr *ProcessorOrchestratorMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call { +func (mr *ProcessorOrchestratorMockRecorder) Update(arg0, arg1, arg2 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Update", reflect.TypeOf((*ProcessorOrchestrator)(nil).Update), arg0, arg1, arg2) } diff --git a/pkg/web/api/mock/processor_service_in.go b/pkg/web/api/mock/processor_service_in.go index e00ea3bd0..cda71ae28 100644 --- a/pkg/web/api/mock/processor_service_in.go +++ b/pkg/web/api/mock/processor_service_in.go @@ -1,6 +1,10 @@ // Code generated by MockGen. DO NOT EDIT. // Source: github.com/conduitio/conduit/proto/api/v1 (interfaces: ProcessorService_InspectProcessorInServer) - +// +// Generated by this command: +// +// mockgen -destination=mock/processor_service_in.go -package=mock -mock_names=ProcessorService_InspectProcessorInServer=ProcessorService_InspectProcessorInServer github.com/conduitio/conduit/proto/api/v1 ProcessorService_InspectProcessorInServer +// // Package mock is a generated GoMock package. package mock @@ -51,7 +55,7 @@ func (mr *ProcessorService_InspectProcessorInServerMockRecorder) Context() *gomo } // RecvMsg mocks base method. -func (m *ProcessorService_InspectProcessorInServer) RecvMsg(arg0 interface{}) error { +func (m *ProcessorService_InspectProcessorInServer) RecvMsg(arg0 any) error { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "RecvMsg", arg0) ret0, _ := ret[0].(error) @@ -59,7 +63,7 @@ func (m *ProcessorService_InspectProcessorInServer) RecvMsg(arg0 interface{}) er } // RecvMsg indicates an expected call of RecvMsg. -func (mr *ProcessorService_InspectProcessorInServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call { +func (mr *ProcessorService_InspectProcessorInServerMockRecorder) RecvMsg(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RecvMsg", reflect.TypeOf((*ProcessorService_InspectProcessorInServer)(nil).RecvMsg), arg0) } @@ -73,7 +77,7 @@ func (m *ProcessorService_InspectProcessorInServer) Send(arg0 *apiv1.InspectProc } // Send indicates an expected call of Send. -func (mr *ProcessorService_InspectProcessorInServerMockRecorder) Send(arg0 interface{}) *gomock.Call { +func (mr *ProcessorService_InspectProcessorInServerMockRecorder) Send(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Send", reflect.TypeOf((*ProcessorService_InspectProcessorInServer)(nil).Send), arg0) } @@ -87,13 +91,13 @@ func (m *ProcessorService_InspectProcessorInServer) SendHeader(arg0 metadata.MD) } // SendHeader indicates an expected call of SendHeader. -func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call { +func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SendHeader(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SendHeader", reflect.TypeOf((*ProcessorService_InspectProcessorInServer)(nil).SendHeader), arg0) } // SendMsg mocks base method. -func (m *ProcessorService_InspectProcessorInServer) SendMsg(arg0 interface{}) error { +func (m *ProcessorService_InspectProcessorInServer) SendMsg(arg0 any) error { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "SendMsg", arg0) ret0, _ := ret[0].(error) @@ -101,7 +105,7 @@ func (m *ProcessorService_InspectProcessorInServer) SendMsg(arg0 interface{}) er } // SendMsg indicates an expected call of SendMsg. -func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call { +func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SendMsg(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SendMsg", reflect.TypeOf((*ProcessorService_InspectProcessorInServer)(nil).SendMsg), arg0) } @@ -115,7 +119,7 @@ func (m *ProcessorService_InspectProcessorInServer) SetHeader(arg0 metadata.MD) } // SetHeader indicates an expected call of SetHeader. -func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call { +func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SetHeader(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetHeader", reflect.TypeOf((*ProcessorService_InspectProcessorInServer)(nil).SetHeader), arg0) } @@ -127,7 +131,7 @@ func (m *ProcessorService_InspectProcessorInServer) SetTrailer(arg0 metadata.MD) } // SetTrailer indicates an expected call of SetTrailer. -func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call { +func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SetTrailer(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetTrailer", reflect.TypeOf((*ProcessorService_InspectProcessorInServer)(nil).SetTrailer), arg0) } diff --git a/pkg/web/api/mock/processor_service_out.go b/pkg/web/api/mock/processor_service_out.go index 387fa686d..c252dd144 100644 --- a/pkg/web/api/mock/processor_service_out.go +++ b/pkg/web/api/mock/processor_service_out.go @@ -1,6 +1,10 @@ // Code generated by MockGen. DO NOT EDIT. // Source: github.com/conduitio/conduit/proto/api/v1 (interfaces: ProcessorService_InspectProcessorOutServer) - +// +// Generated by this command: +// +// mockgen -destination=mock/processor_service_out.go -package=mock -mock_names=ProcessorService_InspectProcessorOutServer=ProcessorService_InspectProcessorOutServer github.com/conduitio/conduit/proto/api/v1 ProcessorService_InspectProcessorOutServer +// // Package mock is a generated GoMock package. package mock @@ -51,7 +55,7 @@ func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) Context() *gom } // RecvMsg mocks base method. -func (m *ProcessorService_InspectProcessorOutServer) RecvMsg(arg0 interface{}) error { +func (m *ProcessorService_InspectProcessorOutServer) RecvMsg(arg0 any) error { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "RecvMsg", arg0) ret0, _ := ret[0].(error) @@ -59,7 +63,7 @@ func (m *ProcessorService_InspectProcessorOutServer) RecvMsg(arg0 interface{}) e } // RecvMsg indicates an expected call of RecvMsg. -func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call { +func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) RecvMsg(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RecvMsg", reflect.TypeOf((*ProcessorService_InspectProcessorOutServer)(nil).RecvMsg), arg0) } @@ -73,7 +77,7 @@ func (m *ProcessorService_InspectProcessorOutServer) Send(arg0 *apiv1.InspectPro } // Send indicates an expected call of Send. -func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) Send(arg0 interface{}) *gomock.Call { +func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) Send(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Send", reflect.TypeOf((*ProcessorService_InspectProcessorOutServer)(nil).Send), arg0) } @@ -87,13 +91,13 @@ func (m *ProcessorService_InspectProcessorOutServer) SendHeader(arg0 metadata.MD } // SendHeader indicates an expected call of SendHeader. -func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call { +func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SendHeader(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SendHeader", reflect.TypeOf((*ProcessorService_InspectProcessorOutServer)(nil).SendHeader), arg0) } // SendMsg mocks base method. -func (m *ProcessorService_InspectProcessorOutServer) SendMsg(arg0 interface{}) error { +func (m *ProcessorService_InspectProcessorOutServer) SendMsg(arg0 any) error { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "SendMsg", arg0) ret0, _ := ret[0].(error) @@ -101,7 +105,7 @@ func (m *ProcessorService_InspectProcessorOutServer) SendMsg(arg0 interface{}) e } // SendMsg indicates an expected call of SendMsg. -func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call { +func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SendMsg(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SendMsg", reflect.TypeOf((*ProcessorService_InspectProcessorOutServer)(nil).SendMsg), arg0) } @@ -115,7 +119,7 @@ func (m *ProcessorService_InspectProcessorOutServer) SetHeader(arg0 metadata.MD) } // SetHeader indicates an expected call of SetHeader. -func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call { +func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SetHeader(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetHeader", reflect.TypeOf((*ProcessorService_InspectProcessorOutServer)(nil).SetHeader), arg0) } @@ -127,7 +131,7 @@ func (m *ProcessorService_InspectProcessorOutServer) SetTrailer(arg0 metadata.MD } // SetTrailer indicates an expected call of SetTrailer. -func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call { +func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SetTrailer(arg0 any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetTrailer", reflect.TypeOf((*ProcessorService_InspectProcessorOutServer)(nil).SetTrailer), arg0) } From 2d43e6f51f4d33bb54f5aaa0fd6fc35ae18235ff Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lovro=20Ma=C5=BEgon?= Date: Mon, 18 Sep 2023 13:53:23 +0200 Subject: [PATCH 3/3] fix test --- pkg/pipeline/stream/source_acker_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/pipeline/stream/source_acker_test.go b/pkg/pipeline/stream/source_acker_test.go index 96fb99bb2..045d9d902 100644 --- a/pkg/pipeline/stream/source_acker_test.go +++ b/pkg/pipeline/stream/source_acker_test.go @@ -305,5 +305,5 @@ func inOrder(calls []*gomock.Call) { for k, v := range calls { callsRepacked[k] = v } - gomock.InOrder(callsRepacked) + gomock.InOrder(callsRepacked...) }