diff --git a/go/tasks/pluginmachinery/catalog/mocks/async_client.go b/go/tasks/pluginmachinery/catalog/mocks/async_client.go index 2cad94426..242d01f85 100644 --- a/go/tasks/pluginmachinery/catalog/mocks/async_client.go +++ b/go/tasks/pluginmachinery/catalog/mocks/async_client.go @@ -24,13 +24,13 @@ func (_m AsyncClient_Download) Return(outputFuture catalog.DownloadFuture, err e } func (_m *AsyncClient) OnDownload(ctx context.Context, requests ...catalog.DownloadRequest) *AsyncClient_Download { - c := _m.On("Download", ctx, requests) - return &AsyncClient_Download{Call: c} + c_call := _m.On("Download", ctx, requests) + return &AsyncClient_Download{Call: c_call} } func (_m *AsyncClient) OnDownloadMatch(matchers ...interface{}) *AsyncClient_Download { - c := _m.On("Download", matchers...) - return &AsyncClient_Download{Call: c} + c_call := _m.On("Download", matchers...) + return &AsyncClient_Download{Call: c_call} } // Download provides a mock function with given fields: ctx, requests @@ -72,13 +72,13 @@ func (_m AsyncClient_Upload) Return(putFuture catalog.UploadFuture, err error) * } func (_m *AsyncClient) OnUpload(ctx context.Context, requests ...catalog.UploadRequest) *AsyncClient_Upload { - c := _m.On("Upload", ctx, requests) - return &AsyncClient_Upload{Call: c} + c_call := _m.On("Upload", ctx, requests) + return &AsyncClient_Upload{Call: c_call} } func (_m *AsyncClient) OnUploadMatch(matchers ...interface{}) *AsyncClient_Upload { - c := _m.On("Upload", matchers...) - return &AsyncClient_Upload{Call: c} + c_call := _m.On("Upload", matchers...) + return &AsyncClient_Upload{Call: c_call} } // Upload provides a mock function with given fields: ctx, requests diff --git a/go/tasks/pluginmachinery/catalog/mocks/client.go b/go/tasks/pluginmachinery/catalog/mocks/client.go index c96507f36..8ad5f6243 100644 --- a/go/tasks/pluginmachinery/catalog/mocks/client.go +++ b/go/tasks/pluginmachinery/catalog/mocks/client.go @@ -30,13 +30,13 @@ func (_m Client_Get) Return(_a0 catalog.Entry, _a1 error) *Client_Get { } func (_m *Client) OnGet(ctx context.Context, key catalog.Key) *Client_Get { - c := _m.On("Get", ctx, key) - return &Client_Get{Call: c} + c_call := _m.On("Get", ctx, key) + return &Client_Get{Call: c_call} } func (_m *Client) OnGetMatch(matchers ...interface{}) *Client_Get { - c := _m.On("Get", matchers...) - return &Client_Get{Call: c} + c_call := _m.On("Get", matchers...) + return &Client_Get{Call: c_call} } // Get provides a mock function with given fields: ctx, key @@ -69,13 +69,13 @@ func (_m Client_GetOrExtendReservation) Return(_a0 *datacatalog.Reservation, _a1 } func (_m *Client) OnGetOrExtendReservation(ctx context.Context, key catalog.Key, ownerID string, heartbeatInterval time.Duration) *Client_GetOrExtendReservation { - c := _m.On("GetOrExtendReservation", ctx, key, ownerID, heartbeatInterval) - return &Client_GetOrExtendReservation{Call: c} + c_call := _m.On("GetOrExtendReservation", ctx, key, ownerID, heartbeatInterval) + return &Client_GetOrExtendReservation{Call: c_call} } func (_m *Client) OnGetOrExtendReservationMatch(matchers ...interface{}) *Client_GetOrExtendReservation { - c := _m.On("GetOrExtendReservation", matchers...) - return &Client_GetOrExtendReservation{Call: c} + c_call := _m.On("GetOrExtendReservation", matchers...) + return &Client_GetOrExtendReservation{Call: c_call} } // GetOrExtendReservation provides a mock function with given fields: ctx, key, ownerID, heartbeatInterval @@ -110,13 +110,13 @@ func (_m Client_Put) Return(_a0 catalog.Status, _a1 error) *Client_Put { } func (_m *Client) OnPut(ctx context.Context, key catalog.Key, reader io.OutputReader, metadata catalog.Metadata) *Client_Put { - c := _m.On("Put", ctx, key, reader, metadata) - return &Client_Put{Call: c} + c_call := _m.On("Put", ctx, key, reader, metadata) + return &Client_Put{Call: c_call} } func (_m *Client) OnPutMatch(matchers ...interface{}) *Client_Put { - c := _m.On("Put", matchers...) - return &Client_Put{Call: c} + c_call := _m.On("Put", matchers...) + return &Client_Put{Call: c_call} } // Put provides a mock function with given fields: ctx, key, reader, metadata @@ -149,13 +149,13 @@ func (_m Client_ReleaseReservation) Return(_a0 error) *Client_ReleaseReservation } func (_m *Client) OnReleaseReservation(ctx context.Context, key catalog.Key, ownerID string) *Client_ReleaseReservation { - c := _m.On("ReleaseReservation", ctx, key, ownerID) - return &Client_ReleaseReservation{Call: c} + c_call := _m.On("ReleaseReservation", ctx, key, ownerID) + return &Client_ReleaseReservation{Call: c_call} } func (_m *Client) OnReleaseReservationMatch(matchers ...interface{}) *Client_ReleaseReservation { - c := _m.On("ReleaseReservation", matchers...) - return &Client_ReleaseReservation{Call: c} + c_call := _m.On("ReleaseReservation", matchers...) + return &Client_ReleaseReservation{Call: c_call} } // ReleaseReservation provides a mock function with given fields: ctx, key, ownerID diff --git a/go/tasks/pluginmachinery/catalog/mocks/download_future.go b/go/tasks/pluginmachinery/catalog/mocks/download_future.go index 536a186b4..b7a068498 100644 --- a/go/tasks/pluginmachinery/catalog/mocks/download_future.go +++ b/go/tasks/pluginmachinery/catalog/mocks/download_future.go @@ -21,13 +21,13 @@ func (_m DownloadFuture_GetResponse) Return(_a0 catalog.DownloadResponse, _a1 er } func (_m *DownloadFuture) OnGetResponse() *DownloadFuture_GetResponse { - c := _m.On("GetResponse") - return &DownloadFuture_GetResponse{Call: c} + c_call := _m.On("GetResponse") + return &DownloadFuture_GetResponse{Call: c_call} } func (_m *DownloadFuture) OnGetResponseMatch(matchers ...interface{}) *DownloadFuture_GetResponse { - c := _m.On("GetResponse", matchers...) - return &DownloadFuture_GetResponse{Call: c} + c_call := _m.On("GetResponse", matchers...) + return &DownloadFuture_GetResponse{Call: c_call} } // GetResponse provides a mock function with given fields: @@ -62,13 +62,13 @@ func (_m DownloadFuture_GetResponseError) Return(_a0 error) *DownloadFuture_GetR } func (_m *DownloadFuture) OnGetResponseError() *DownloadFuture_GetResponseError { - c := _m.On("GetResponseError") - return &DownloadFuture_GetResponseError{Call: c} + c_call := _m.On("GetResponseError") + return &DownloadFuture_GetResponseError{Call: c_call} } func (_m *DownloadFuture) OnGetResponseErrorMatch(matchers ...interface{}) *DownloadFuture_GetResponseError { - c := _m.On("GetResponseError", matchers...) - return &DownloadFuture_GetResponseError{Call: c} + c_call := _m.On("GetResponseError", matchers...) + return &DownloadFuture_GetResponseError{Call: c_call} } // GetResponseError provides a mock function with given fields: @@ -94,13 +94,13 @@ func (_m DownloadFuture_GetResponseStatus) Return(_a0 catalog.ResponseStatus) *D } func (_m *DownloadFuture) OnGetResponseStatus() *DownloadFuture_GetResponseStatus { - c := _m.On("GetResponseStatus") - return &DownloadFuture_GetResponseStatus{Call: c} + c_call := _m.On("GetResponseStatus") + return &DownloadFuture_GetResponseStatus{Call: c_call} } func (_m *DownloadFuture) OnGetResponseStatusMatch(matchers ...interface{}) *DownloadFuture_GetResponseStatus { - c := _m.On("GetResponseStatus", matchers...) - return &DownloadFuture_GetResponseStatus{Call: c} + c_call := _m.On("GetResponseStatus", matchers...) + return &DownloadFuture_GetResponseStatus{Call: c_call} } // GetResponseStatus provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/catalog/mocks/download_response.go b/go/tasks/pluginmachinery/catalog/mocks/download_response.go index 6699f2a99..5a9d6c907 100644 --- a/go/tasks/pluginmachinery/catalog/mocks/download_response.go +++ b/go/tasks/pluginmachinery/catalog/mocks/download_response.go @@ -22,13 +22,13 @@ func (_m DownloadResponse_GetCachedCount) Return(_a0 int) *DownloadResponse_GetC } func (_m *DownloadResponse) OnGetCachedCount() *DownloadResponse_GetCachedCount { - c := _m.On("GetCachedCount") - return &DownloadResponse_GetCachedCount{Call: c} + c_call := _m.On("GetCachedCount") + return &DownloadResponse_GetCachedCount{Call: c_call} } func (_m *DownloadResponse) OnGetCachedCountMatch(matchers ...interface{}) *DownloadResponse_GetCachedCount { - c := _m.On("GetCachedCount", matchers...) - return &DownloadResponse_GetCachedCount{Call: c} + c_call := _m.On("GetCachedCount", matchers...) + return &DownloadResponse_GetCachedCount{Call: c_call} } // GetCachedCount provides a mock function with given fields: @@ -54,13 +54,13 @@ func (_m DownloadResponse_GetCachedResults) Return(_a0 *bitarray.BitSet) *Downlo } func (_m *DownloadResponse) OnGetCachedResults() *DownloadResponse_GetCachedResults { - c := _m.On("GetCachedResults") - return &DownloadResponse_GetCachedResults{Call: c} + c_call := _m.On("GetCachedResults") + return &DownloadResponse_GetCachedResults{Call: c_call} } func (_m *DownloadResponse) OnGetCachedResultsMatch(matchers ...interface{}) *DownloadResponse_GetCachedResults { - c := _m.On("GetCachedResults", matchers...) - return &DownloadResponse_GetCachedResults{Call: c} + c_call := _m.On("GetCachedResults", matchers...) + return &DownloadResponse_GetCachedResults{Call: c_call} } // GetCachedResults provides a mock function with given fields: @@ -88,13 +88,13 @@ func (_m DownloadResponse_GetResultsSize) Return(_a0 int) *DownloadResponse_GetR } func (_m *DownloadResponse) OnGetResultsSize() *DownloadResponse_GetResultsSize { - c := _m.On("GetResultsSize") - return &DownloadResponse_GetResultsSize{Call: c} + c_call := _m.On("GetResultsSize") + return &DownloadResponse_GetResultsSize{Call: c_call} } func (_m *DownloadResponse) OnGetResultsSizeMatch(matchers ...interface{}) *DownloadResponse_GetResultsSize { - c := _m.On("GetResultsSize", matchers...) - return &DownloadResponse_GetResultsSize{Call: c} + c_call := _m.On("GetResultsSize", matchers...) + return &DownloadResponse_GetResultsSize{Call: c_call} } // GetResultsSize provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/catalog/mocks/future.go b/go/tasks/pluginmachinery/catalog/mocks/future.go index 8e7a2acb3..e62b17d66 100644 --- a/go/tasks/pluginmachinery/catalog/mocks/future.go +++ b/go/tasks/pluginmachinery/catalog/mocks/future.go @@ -21,13 +21,13 @@ func (_m Future_GetResponseError) Return(_a0 error) *Future_GetResponseError { } func (_m *Future) OnGetResponseError() *Future_GetResponseError { - c := _m.On("GetResponseError") - return &Future_GetResponseError{Call: c} + c_call := _m.On("GetResponseError") + return &Future_GetResponseError{Call: c_call} } func (_m *Future) OnGetResponseErrorMatch(matchers ...interface{}) *Future_GetResponseError { - c := _m.On("GetResponseError", matchers...) - return &Future_GetResponseError{Call: c} + c_call := _m.On("GetResponseError", matchers...) + return &Future_GetResponseError{Call: c_call} } // GetResponseError provides a mock function with given fields: @@ -53,13 +53,13 @@ func (_m Future_GetResponseStatus) Return(_a0 catalog.ResponseStatus) *Future_Ge } func (_m *Future) OnGetResponseStatus() *Future_GetResponseStatus { - c := _m.On("GetResponseStatus") - return &Future_GetResponseStatus{Call: c} + c_call := _m.On("GetResponseStatus") + return &Future_GetResponseStatus{Call: c_call} } func (_m *Future) OnGetResponseStatusMatch(matchers ...interface{}) *Future_GetResponseStatus { - c := _m.On("GetResponseStatus", matchers...) - return &Future_GetResponseStatus{Call: c} + c_call := _m.On("GetResponseStatus", matchers...) + return &Future_GetResponseStatus{Call: c_call} } // GetResponseStatus provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/catalog/mocks/upload_future.go b/go/tasks/pluginmachinery/catalog/mocks/upload_future.go index 706ee3b2c..b9a254d6a 100644 --- a/go/tasks/pluginmachinery/catalog/mocks/upload_future.go +++ b/go/tasks/pluginmachinery/catalog/mocks/upload_future.go @@ -21,13 +21,13 @@ func (_m UploadFuture_GetResponseError) Return(_a0 error) *UploadFuture_GetRespo } func (_m *UploadFuture) OnGetResponseError() *UploadFuture_GetResponseError { - c := _m.On("GetResponseError") - return &UploadFuture_GetResponseError{Call: c} + c_call := _m.On("GetResponseError") + return &UploadFuture_GetResponseError{Call: c_call} } func (_m *UploadFuture) OnGetResponseErrorMatch(matchers ...interface{}) *UploadFuture_GetResponseError { - c := _m.On("GetResponseError", matchers...) - return &UploadFuture_GetResponseError{Call: c} + c_call := _m.On("GetResponseError", matchers...) + return &UploadFuture_GetResponseError{Call: c_call} } // GetResponseError provides a mock function with given fields: @@ -53,13 +53,13 @@ func (_m UploadFuture_GetResponseStatus) Return(_a0 catalog.ResponseStatus) *Upl } func (_m *UploadFuture) OnGetResponseStatus() *UploadFuture_GetResponseStatus { - c := _m.On("GetResponseStatus") - return &UploadFuture_GetResponseStatus{Call: c} + c_call := _m.On("GetResponseStatus") + return &UploadFuture_GetResponseStatus{Call: c_call} } func (_m *UploadFuture) OnGetResponseStatusMatch(matchers ...interface{}) *UploadFuture_GetResponseStatus { - c := _m.On("GetResponseStatus", matchers...) - return &UploadFuture_GetResponseStatus{Call: c} + c_call := _m.On("GetResponseStatus", matchers...) + return &UploadFuture_GetResponseStatus{Call: c_call} } // GetResponseStatus provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/core/mocks/events_recorder.go b/go/tasks/pluginmachinery/core/mocks/events_recorder.go index 994991094..8f846198c 100644 --- a/go/tasks/pluginmachinery/core/mocks/events_recorder.go +++ b/go/tasks/pluginmachinery/core/mocks/events_recorder.go @@ -23,13 +23,13 @@ func (_m EventsRecorder_RecordRaw) Return(_a0 error) *EventsRecorder_RecordRaw { } func (_m *EventsRecorder) OnRecordRaw(ctx context.Context, ev core.PhaseInfo) *EventsRecorder_RecordRaw { - c := _m.On("RecordRaw", ctx, ev) - return &EventsRecorder_RecordRaw{Call: c} + c_call := _m.On("RecordRaw", ctx, ev) + return &EventsRecorder_RecordRaw{Call: c_call} } func (_m *EventsRecorder) OnRecordRawMatch(matchers ...interface{}) *EventsRecorder_RecordRaw { - c := _m.On("RecordRaw", matchers...) - return &EventsRecorder_RecordRaw{Call: c} + c_call := _m.On("RecordRaw", matchers...) + return &EventsRecorder_RecordRaw{Call: c_call} } // RecordRaw provides a mock function with given fields: ctx, ev diff --git a/go/tasks/pluginmachinery/core/mocks/kube_client.go b/go/tasks/pluginmachinery/core/mocks/kube_client.go index 1404b317b..e437c6c58 100644 --- a/go/tasks/pluginmachinery/core/mocks/kube_client.go +++ b/go/tasks/pluginmachinery/core/mocks/kube_client.go @@ -23,13 +23,13 @@ func (_m KubeClient_GetCache) Return(_a0 cache.Cache) *KubeClient_GetCache { } func (_m *KubeClient) OnGetCache() *KubeClient_GetCache { - c := _m.On("GetCache") - return &KubeClient_GetCache{Call: c} + c_call := _m.On("GetCache") + return &KubeClient_GetCache{Call: c_call} } func (_m *KubeClient) OnGetCacheMatch(matchers ...interface{}) *KubeClient_GetCache { - c := _m.On("GetCache", matchers...) - return &KubeClient_GetCache{Call: c} + c_call := _m.On("GetCache", matchers...) + return &KubeClient_GetCache{Call: c_call} } // GetCache provides a mock function with given fields: @@ -57,13 +57,13 @@ func (_m KubeClient_GetClient) Return(_a0 client.Client) *KubeClient_GetClient { } func (_m *KubeClient) OnGetClient() *KubeClient_GetClient { - c := _m.On("GetClient") - return &KubeClient_GetClient{Call: c} + c_call := _m.On("GetClient") + return &KubeClient_GetClient{Call: c_call} } func (_m *KubeClient) OnGetClientMatch(matchers ...interface{}) *KubeClient_GetClient { - c := _m.On("GetClient", matchers...) - return &KubeClient_GetClient{Call: c} + c_call := _m.On("GetClient", matchers...) + return &KubeClient_GetClient{Call: c_call} } // GetClient provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/core/mocks/plugin.go b/go/tasks/pluginmachinery/core/mocks/plugin.go index 5750d0f15..813cdaa3a 100644 --- a/go/tasks/pluginmachinery/core/mocks/plugin.go +++ b/go/tasks/pluginmachinery/core/mocks/plugin.go @@ -23,13 +23,13 @@ func (_m Plugin_Abort) Return(_a0 error) *Plugin_Abort { } func (_m *Plugin) OnAbort(ctx context.Context, tCtx core.TaskExecutionContext) *Plugin_Abort { - c := _m.On("Abort", ctx, tCtx) - return &Plugin_Abort{Call: c} + c_call := _m.On("Abort", ctx, tCtx) + return &Plugin_Abort{Call: c_call} } func (_m *Plugin) OnAbortMatch(matchers ...interface{}) *Plugin_Abort { - c := _m.On("Abort", matchers...) - return &Plugin_Abort{Call: c} + c_call := _m.On("Abort", matchers...) + return &Plugin_Abort{Call: c_call} } // Abort provides a mock function with given fields: ctx, tCtx @@ -55,13 +55,13 @@ func (_m Plugin_Finalize) Return(_a0 error) *Plugin_Finalize { } func (_m *Plugin) OnFinalize(ctx context.Context, tCtx core.TaskExecutionContext) *Plugin_Finalize { - c := _m.On("Finalize", ctx, tCtx) - return &Plugin_Finalize{Call: c} + c_call := _m.On("Finalize", ctx, tCtx) + return &Plugin_Finalize{Call: c_call} } func (_m *Plugin) OnFinalizeMatch(matchers ...interface{}) *Plugin_Finalize { - c := _m.On("Finalize", matchers...) - return &Plugin_Finalize{Call: c} + c_call := _m.On("Finalize", matchers...) + return &Plugin_Finalize{Call: c_call} } // Finalize provides a mock function with given fields: ctx, tCtx @@ -87,13 +87,13 @@ func (_m Plugin_GetID) Return(_a0 string) *Plugin_GetID { } func (_m *Plugin) OnGetID() *Plugin_GetID { - c := _m.On("GetID") - return &Plugin_GetID{Call: c} + c_call := _m.On("GetID") + return &Plugin_GetID{Call: c_call} } func (_m *Plugin) OnGetIDMatch(matchers ...interface{}) *Plugin_GetID { - c := _m.On("GetID", matchers...) - return &Plugin_GetID{Call: c} + c_call := _m.On("GetID", matchers...) + return &Plugin_GetID{Call: c_call} } // GetID provides a mock function with given fields: @@ -119,13 +119,13 @@ func (_m Plugin_GetProperties) Return(_a0 core.PluginProperties) *Plugin_GetProp } func (_m *Plugin) OnGetProperties() *Plugin_GetProperties { - c := _m.On("GetProperties") - return &Plugin_GetProperties{Call: c} + c_call := _m.On("GetProperties") + return &Plugin_GetProperties{Call: c_call} } func (_m *Plugin) OnGetPropertiesMatch(matchers ...interface{}) *Plugin_GetProperties { - c := _m.On("GetProperties", matchers...) - return &Plugin_GetProperties{Call: c} + c_call := _m.On("GetProperties", matchers...) + return &Plugin_GetProperties{Call: c_call} } // GetProperties provides a mock function with given fields: @@ -151,13 +151,13 @@ func (_m Plugin_Handle) Return(_a0 core.Transition, _a1 error) *Plugin_Handle { } func (_m *Plugin) OnHandle(ctx context.Context, tCtx core.TaskExecutionContext) *Plugin_Handle { - c := _m.On("Handle", ctx, tCtx) - return &Plugin_Handle{Call: c} + c_call := _m.On("Handle", ctx, tCtx) + return &Plugin_Handle{Call: c_call} } func (_m *Plugin) OnHandleMatch(matchers ...interface{}) *Plugin_Handle { - c := _m.On("Handle", matchers...) - return &Plugin_Handle{Call: c} + c_call := _m.On("Handle", matchers...) + return &Plugin_Handle{Call: c_call} } // Handle provides a mock function with given fields: ctx, tCtx diff --git a/go/tasks/pluginmachinery/core/mocks/plugin_state_reader.go b/go/tasks/pluginmachinery/core/mocks/plugin_state_reader.go index 31d18a403..ffbb8e982 100644 --- a/go/tasks/pluginmachinery/core/mocks/plugin_state_reader.go +++ b/go/tasks/pluginmachinery/core/mocks/plugin_state_reader.go @@ -18,13 +18,13 @@ func (_m PluginStateReader_Get) Return(stateVersion uint8, err error) *PluginSta } func (_m *PluginStateReader) OnGet(t interface{}) *PluginStateReader_Get { - c := _m.On("Get", t) - return &PluginStateReader_Get{Call: c} + c_call := _m.On("Get", t) + return &PluginStateReader_Get{Call: c_call} } func (_m *PluginStateReader) OnGetMatch(matchers ...interface{}) *PluginStateReader_Get { - c := _m.On("Get", matchers...) - return &PluginStateReader_Get{Call: c} + c_call := _m.On("Get", matchers...) + return &PluginStateReader_Get{Call: c_call} } // Get provides a mock function with given fields: t @@ -57,13 +57,13 @@ func (_m PluginStateReader_GetStateVersion) Return(_a0 uint8) *PluginStateReader } func (_m *PluginStateReader) OnGetStateVersion() *PluginStateReader_GetStateVersion { - c := _m.On("GetStateVersion") - return &PluginStateReader_GetStateVersion{Call: c} + c_call := _m.On("GetStateVersion") + return &PluginStateReader_GetStateVersion{Call: c_call} } func (_m *PluginStateReader) OnGetStateVersionMatch(matchers ...interface{}) *PluginStateReader_GetStateVersion { - c := _m.On("GetStateVersion", matchers...) - return &PluginStateReader_GetStateVersion{Call: c} + c_call := _m.On("GetStateVersion", matchers...) + return &PluginStateReader_GetStateVersion{Call: c_call} } // GetStateVersion provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/core/mocks/plugin_state_writer.go b/go/tasks/pluginmachinery/core/mocks/plugin_state_writer.go index 32ad348fd..b0ec62e5f 100644 --- a/go/tasks/pluginmachinery/core/mocks/plugin_state_writer.go +++ b/go/tasks/pluginmachinery/core/mocks/plugin_state_writer.go @@ -18,13 +18,13 @@ func (_m PluginStateWriter_Put) Return(_a0 error) *PluginStateWriter_Put { } func (_m *PluginStateWriter) OnPut(stateVersion uint8, v interface{}) *PluginStateWriter_Put { - c := _m.On("Put", stateVersion, v) - return &PluginStateWriter_Put{Call: c} + c_call := _m.On("Put", stateVersion, v) + return &PluginStateWriter_Put{Call: c_call} } func (_m *PluginStateWriter) OnPutMatch(matchers ...interface{}) *PluginStateWriter_Put { - c := _m.On("Put", matchers...) - return &PluginStateWriter_Put{Call: c} + c_call := _m.On("Put", matchers...) + return &PluginStateWriter_Put{Call: c_call} } // Put provides a mock function with given fields: stateVersion, v @@ -50,13 +50,13 @@ func (_m PluginStateWriter_Reset) Return(_a0 error) *PluginStateWriter_Reset { } func (_m *PluginStateWriter) OnReset() *PluginStateWriter_Reset { - c := _m.On("Reset") - return &PluginStateWriter_Reset{Call: c} + c_call := _m.On("Reset") + return &PluginStateWriter_Reset{Call: c_call} } func (_m *PluginStateWriter) OnResetMatch(matchers ...interface{}) *PluginStateWriter_Reset { - c := _m.On("Reset", matchers...) - return &PluginStateWriter_Reset{Call: c} + c_call := _m.On("Reset", matchers...) + return &PluginStateWriter_Reset{Call: c_call} } // Reset provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/core/mocks/resource_manager.go b/go/tasks/pluginmachinery/core/mocks/resource_manager.go index 744220308..0ef3c6735 100644 --- a/go/tasks/pluginmachinery/core/mocks/resource_manager.go +++ b/go/tasks/pluginmachinery/core/mocks/resource_manager.go @@ -23,13 +23,13 @@ func (_m ResourceManager_AllocateResource) Return(_a0 core.AllocationStatus, _a1 } func (_m *ResourceManager) OnAllocateResource(ctx context.Context, namespace core.ResourceNamespace, allocationToken string, constraintsSpec core.ResourceConstraintsSpec) *ResourceManager_AllocateResource { - c := _m.On("AllocateResource", ctx, namespace, allocationToken, constraintsSpec) - return &ResourceManager_AllocateResource{Call: c} + c_call := _m.On("AllocateResource", ctx, namespace, allocationToken, constraintsSpec) + return &ResourceManager_AllocateResource{Call: c_call} } func (_m *ResourceManager) OnAllocateResourceMatch(matchers ...interface{}) *ResourceManager_AllocateResource { - c := _m.On("AllocateResource", matchers...) - return &ResourceManager_AllocateResource{Call: c} + c_call := _m.On("AllocateResource", matchers...) + return &ResourceManager_AllocateResource{Call: c_call} } // AllocateResource provides a mock function with given fields: ctx, namespace, allocationToken, constraintsSpec @@ -62,13 +62,13 @@ func (_m ResourceManager_GetID) Return(_a0 string) *ResourceManager_GetID { } func (_m *ResourceManager) OnGetID() *ResourceManager_GetID { - c := _m.On("GetID") - return &ResourceManager_GetID{Call: c} + c_call := _m.On("GetID") + return &ResourceManager_GetID{Call: c_call} } func (_m *ResourceManager) OnGetIDMatch(matchers ...interface{}) *ResourceManager_GetID { - c := _m.On("GetID", matchers...) - return &ResourceManager_GetID{Call: c} + c_call := _m.On("GetID", matchers...) + return &ResourceManager_GetID{Call: c_call} } // GetID provides a mock function with given fields: @@ -94,13 +94,13 @@ func (_m ResourceManager_ReleaseResource) Return(_a0 error) *ResourceManager_Rel } func (_m *ResourceManager) OnReleaseResource(ctx context.Context, namespace core.ResourceNamespace, allocationToken string) *ResourceManager_ReleaseResource { - c := _m.On("ReleaseResource", ctx, namespace, allocationToken) - return &ResourceManager_ReleaseResource{Call: c} + c_call := _m.On("ReleaseResource", ctx, namespace, allocationToken) + return &ResourceManager_ReleaseResource{Call: c_call} } func (_m *ResourceManager) OnReleaseResourceMatch(matchers ...interface{}) *ResourceManager_ReleaseResource { - c := _m.On("ReleaseResource", matchers...) - return &ResourceManager_ReleaseResource{Call: c} + c_call := _m.On("ReleaseResource", matchers...) + return &ResourceManager_ReleaseResource{Call: c_call} } // ReleaseResource provides a mock function with given fields: ctx, namespace, allocationToken diff --git a/go/tasks/pluginmachinery/core/mocks/resource_registrar.go b/go/tasks/pluginmachinery/core/mocks/resource_registrar.go index 7aec68996..101f255ba 100644 --- a/go/tasks/pluginmachinery/core/mocks/resource_registrar.go +++ b/go/tasks/pluginmachinery/core/mocks/resource_registrar.go @@ -23,13 +23,13 @@ func (_m ResourceRegistrar_RegisterResourceQuota) Return(_a0 error) *ResourceReg } func (_m *ResourceRegistrar) OnRegisterResourceQuota(ctx context.Context, namespace core.ResourceNamespace, quota int) *ResourceRegistrar_RegisterResourceQuota { - c := _m.On("RegisterResourceQuota", ctx, namespace, quota) - return &ResourceRegistrar_RegisterResourceQuota{Call: c} + c_call := _m.On("RegisterResourceQuota", ctx, namespace, quota) + return &ResourceRegistrar_RegisterResourceQuota{Call: c_call} } func (_m *ResourceRegistrar) OnRegisterResourceQuotaMatch(matchers ...interface{}) *ResourceRegistrar_RegisterResourceQuota { - c := _m.On("RegisterResourceQuota", matchers...) - return &ResourceRegistrar_RegisterResourceQuota{Call: c} + c_call := _m.On("RegisterResourceQuota", matchers...) + return &ResourceRegistrar_RegisterResourceQuota{Call: c_call} } // RegisterResourceQuota provides a mock function with given fields: ctx, namespace, quota diff --git a/go/tasks/pluginmachinery/core/mocks/secret_manager.go b/go/tasks/pluginmachinery/core/mocks/secret_manager.go index 84953489b..9b882aaf2 100644 --- a/go/tasks/pluginmachinery/core/mocks/secret_manager.go +++ b/go/tasks/pluginmachinery/core/mocks/secret_manager.go @@ -22,13 +22,13 @@ func (_m SecretManager_Get) Return(_a0 string, _a1 error) *SecretManager_Get { } func (_m *SecretManager) OnGet(ctx context.Context, key string) *SecretManager_Get { - c := _m.On("Get", ctx, key) - return &SecretManager_Get{Call: c} + c_call := _m.On("Get", ctx, key) + return &SecretManager_Get{Call: c_call} } func (_m *SecretManager) OnGetMatch(matchers ...interface{}) *SecretManager_Get { - c := _m.On("Get", matchers...) - return &SecretManager_Get{Call: c} + c_call := _m.On("Get", matchers...) + return &SecretManager_Get{Call: c_call} } // Get provides a mock function with given fields: ctx, key diff --git a/go/tasks/pluginmachinery/core/mocks/setup_context.go b/go/tasks/pluginmachinery/core/mocks/setup_context.go index 898631013..d1a647426 100644 --- a/go/tasks/pluginmachinery/core/mocks/setup_context.go +++ b/go/tasks/pluginmachinery/core/mocks/setup_context.go @@ -23,13 +23,13 @@ func (_m SetupContext_EnqueueOwner) Return(_a0 core.EnqueueOwner) *SetupContext_ } func (_m *SetupContext) OnEnqueueOwner() *SetupContext_EnqueueOwner { - c := _m.On("EnqueueOwner") - return &SetupContext_EnqueueOwner{Call: c} + c_call := _m.On("EnqueueOwner") + return &SetupContext_EnqueueOwner{Call: c_call} } func (_m *SetupContext) OnEnqueueOwnerMatch(matchers ...interface{}) *SetupContext_EnqueueOwner { - c := _m.On("EnqueueOwner", matchers...) - return &SetupContext_EnqueueOwner{Call: c} + c_call := _m.On("EnqueueOwner", matchers...) + return &SetupContext_EnqueueOwner{Call: c_call} } // EnqueueOwner provides a mock function with given fields: @@ -57,13 +57,13 @@ func (_m SetupContext_KubeClient) Return(_a0 core.KubeClient) *SetupContext_Kube } func (_m *SetupContext) OnKubeClient() *SetupContext_KubeClient { - c := _m.On("KubeClient") - return &SetupContext_KubeClient{Call: c} + c_call := _m.On("KubeClient") + return &SetupContext_KubeClient{Call: c_call} } func (_m *SetupContext) OnKubeClientMatch(matchers ...interface{}) *SetupContext_KubeClient { - c := _m.On("KubeClient", matchers...) - return &SetupContext_KubeClient{Call: c} + c_call := _m.On("KubeClient", matchers...) + return &SetupContext_KubeClient{Call: c_call} } // KubeClient provides a mock function with given fields: @@ -91,13 +91,13 @@ func (_m SetupContext_MetricsScope) Return(_a0 promutils.Scope) *SetupContext_Me } func (_m *SetupContext) OnMetricsScope() *SetupContext_MetricsScope { - c := _m.On("MetricsScope") - return &SetupContext_MetricsScope{Call: c} + c_call := _m.On("MetricsScope") + return &SetupContext_MetricsScope{Call: c_call} } func (_m *SetupContext) OnMetricsScopeMatch(matchers ...interface{}) *SetupContext_MetricsScope { - c := _m.On("MetricsScope", matchers...) - return &SetupContext_MetricsScope{Call: c} + c_call := _m.On("MetricsScope", matchers...) + return &SetupContext_MetricsScope{Call: c_call} } // MetricsScope provides a mock function with given fields: @@ -125,13 +125,13 @@ func (_m SetupContext_OwnerKind) Return(_a0 string) *SetupContext_OwnerKind { } func (_m *SetupContext) OnOwnerKind() *SetupContext_OwnerKind { - c := _m.On("OwnerKind") - return &SetupContext_OwnerKind{Call: c} + c_call := _m.On("OwnerKind") + return &SetupContext_OwnerKind{Call: c_call} } func (_m *SetupContext) OnOwnerKindMatch(matchers ...interface{}) *SetupContext_OwnerKind { - c := _m.On("OwnerKind", matchers...) - return &SetupContext_OwnerKind{Call: c} + c_call := _m.On("OwnerKind", matchers...) + return &SetupContext_OwnerKind{Call: c_call} } // OwnerKind provides a mock function with given fields: @@ -157,13 +157,13 @@ func (_m SetupContext_ResourceRegistrar) Return(_a0 core.ResourceRegistrar) *Set } func (_m *SetupContext) OnResourceRegistrar() *SetupContext_ResourceRegistrar { - c := _m.On("ResourceRegistrar") - return &SetupContext_ResourceRegistrar{Call: c} + c_call := _m.On("ResourceRegistrar") + return &SetupContext_ResourceRegistrar{Call: c_call} } func (_m *SetupContext) OnResourceRegistrarMatch(matchers ...interface{}) *SetupContext_ResourceRegistrar { - c := _m.On("ResourceRegistrar", matchers...) - return &SetupContext_ResourceRegistrar{Call: c} + c_call := _m.On("ResourceRegistrar", matchers...) + return &SetupContext_ResourceRegistrar{Call: c_call} } // ResourceRegistrar provides a mock function with given fields: @@ -191,13 +191,13 @@ func (_m SetupContext_SecretManager) Return(_a0 core.SecretManager) *SetupContex } func (_m *SetupContext) OnSecretManager() *SetupContext_SecretManager { - c := _m.On("SecretManager") - return &SetupContext_SecretManager{Call: c} + c_call := _m.On("SecretManager") + return &SetupContext_SecretManager{Call: c_call} } func (_m *SetupContext) OnSecretManagerMatch(matchers ...interface{}) *SetupContext_SecretManager { - c := _m.On("SecretManager", matchers...) - return &SetupContext_SecretManager{Call: c} + c_call := _m.On("SecretManager", matchers...) + return &SetupContext_SecretManager{Call: c_call} } // SecretManager provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/core/mocks/task_execution_context.go b/go/tasks/pluginmachinery/core/mocks/task_execution_context.go index 2a8aaa6ce..c7ff4961c 100644 --- a/go/tasks/pluginmachinery/core/mocks/task_execution_context.go +++ b/go/tasks/pluginmachinery/core/mocks/task_execution_context.go @@ -27,13 +27,13 @@ func (_m TaskExecutionContext_Catalog) Return(_a0 catalog.AsyncClient) *TaskExec } func (_m *TaskExecutionContext) OnCatalog() *TaskExecutionContext_Catalog { - c := _m.On("Catalog") - return &TaskExecutionContext_Catalog{Call: c} + c_call := _m.On("Catalog") + return &TaskExecutionContext_Catalog{Call: c_call} } func (_m *TaskExecutionContext) OnCatalogMatch(matchers ...interface{}) *TaskExecutionContext_Catalog { - c := _m.On("Catalog", matchers...) - return &TaskExecutionContext_Catalog{Call: c} + c_call := _m.On("Catalog", matchers...) + return &TaskExecutionContext_Catalog{Call: c_call} } // Catalog provides a mock function with given fields: @@ -61,13 +61,13 @@ func (_m TaskExecutionContext_DataStore) Return(_a0 *storage.DataStore) *TaskExe } func (_m *TaskExecutionContext) OnDataStore() *TaskExecutionContext_DataStore { - c := _m.On("DataStore") - return &TaskExecutionContext_DataStore{Call: c} + c_call := _m.On("DataStore") + return &TaskExecutionContext_DataStore{Call: c_call} } func (_m *TaskExecutionContext) OnDataStoreMatch(matchers ...interface{}) *TaskExecutionContext_DataStore { - c := _m.On("DataStore", matchers...) - return &TaskExecutionContext_DataStore{Call: c} + c_call := _m.On("DataStore", matchers...) + return &TaskExecutionContext_DataStore{Call: c_call} } // DataStore provides a mock function with given fields: @@ -95,13 +95,13 @@ func (_m TaskExecutionContext_EventsRecorder) Return(_a0 core.EventsRecorder) *T } func (_m *TaskExecutionContext) OnEventsRecorder() *TaskExecutionContext_EventsRecorder { - c := _m.On("EventsRecorder") - return &TaskExecutionContext_EventsRecorder{Call: c} + c_call := _m.On("EventsRecorder") + return &TaskExecutionContext_EventsRecorder{Call: c_call} } func (_m *TaskExecutionContext) OnEventsRecorderMatch(matchers ...interface{}) *TaskExecutionContext_EventsRecorder { - c := _m.On("EventsRecorder", matchers...) - return &TaskExecutionContext_EventsRecorder{Call: c} + c_call := _m.On("EventsRecorder", matchers...) + return &TaskExecutionContext_EventsRecorder{Call: c_call} } // EventsRecorder provides a mock function with given fields: @@ -129,13 +129,13 @@ func (_m TaskExecutionContext_InputReader) Return(_a0 io.InputReader) *TaskExecu } func (_m *TaskExecutionContext) OnInputReader() *TaskExecutionContext_InputReader { - c := _m.On("InputReader") - return &TaskExecutionContext_InputReader{Call: c} + c_call := _m.On("InputReader") + return &TaskExecutionContext_InputReader{Call: c_call} } func (_m *TaskExecutionContext) OnInputReaderMatch(matchers ...interface{}) *TaskExecutionContext_InputReader { - c := _m.On("InputReader", matchers...) - return &TaskExecutionContext_InputReader{Call: c} + c_call := _m.On("InputReader", matchers...) + return &TaskExecutionContext_InputReader{Call: c_call} } // InputReader provides a mock function with given fields: @@ -163,13 +163,13 @@ func (_m TaskExecutionContext_MaxDatasetSizeBytes) Return(_a0 int64) *TaskExecut } func (_m *TaskExecutionContext) OnMaxDatasetSizeBytes() *TaskExecutionContext_MaxDatasetSizeBytes { - c := _m.On("MaxDatasetSizeBytes") - return &TaskExecutionContext_MaxDatasetSizeBytes{Call: c} + c_call := _m.On("MaxDatasetSizeBytes") + return &TaskExecutionContext_MaxDatasetSizeBytes{Call: c_call} } func (_m *TaskExecutionContext) OnMaxDatasetSizeBytesMatch(matchers ...interface{}) *TaskExecutionContext_MaxDatasetSizeBytes { - c := _m.On("MaxDatasetSizeBytes", matchers...) - return &TaskExecutionContext_MaxDatasetSizeBytes{Call: c} + c_call := _m.On("MaxDatasetSizeBytes", matchers...) + return &TaskExecutionContext_MaxDatasetSizeBytes{Call: c_call} } // MaxDatasetSizeBytes provides a mock function with given fields: @@ -195,13 +195,13 @@ func (_m TaskExecutionContext_OutputWriter) Return(_a0 io.OutputWriter) *TaskExe } func (_m *TaskExecutionContext) OnOutputWriter() *TaskExecutionContext_OutputWriter { - c := _m.On("OutputWriter") - return &TaskExecutionContext_OutputWriter{Call: c} + c_call := _m.On("OutputWriter") + return &TaskExecutionContext_OutputWriter{Call: c_call} } func (_m *TaskExecutionContext) OnOutputWriterMatch(matchers ...interface{}) *TaskExecutionContext_OutputWriter { - c := _m.On("OutputWriter", matchers...) - return &TaskExecutionContext_OutputWriter{Call: c} + c_call := _m.On("OutputWriter", matchers...) + return &TaskExecutionContext_OutputWriter{Call: c_call} } // OutputWriter provides a mock function with given fields: @@ -229,13 +229,13 @@ func (_m TaskExecutionContext_PluginStateReader) Return(_a0 core.PluginStateRead } func (_m *TaskExecutionContext) OnPluginStateReader() *TaskExecutionContext_PluginStateReader { - c := _m.On("PluginStateReader") - return &TaskExecutionContext_PluginStateReader{Call: c} + c_call := _m.On("PluginStateReader") + return &TaskExecutionContext_PluginStateReader{Call: c_call} } func (_m *TaskExecutionContext) OnPluginStateReaderMatch(matchers ...interface{}) *TaskExecutionContext_PluginStateReader { - c := _m.On("PluginStateReader", matchers...) - return &TaskExecutionContext_PluginStateReader{Call: c} + c_call := _m.On("PluginStateReader", matchers...) + return &TaskExecutionContext_PluginStateReader{Call: c_call} } // PluginStateReader provides a mock function with given fields: @@ -263,13 +263,13 @@ func (_m TaskExecutionContext_PluginStateWriter) Return(_a0 core.PluginStateWrit } func (_m *TaskExecutionContext) OnPluginStateWriter() *TaskExecutionContext_PluginStateWriter { - c := _m.On("PluginStateWriter") - return &TaskExecutionContext_PluginStateWriter{Call: c} + c_call := _m.On("PluginStateWriter") + return &TaskExecutionContext_PluginStateWriter{Call: c_call} } func (_m *TaskExecutionContext) OnPluginStateWriterMatch(matchers ...interface{}) *TaskExecutionContext_PluginStateWriter { - c := _m.On("PluginStateWriter", matchers...) - return &TaskExecutionContext_PluginStateWriter{Call: c} + c_call := _m.On("PluginStateWriter", matchers...) + return &TaskExecutionContext_PluginStateWriter{Call: c_call} } // PluginStateWriter provides a mock function with given fields: @@ -297,13 +297,13 @@ func (_m TaskExecutionContext_ResourceManager) Return(_a0 core.ResourceManager) } func (_m *TaskExecutionContext) OnResourceManager() *TaskExecutionContext_ResourceManager { - c := _m.On("ResourceManager") - return &TaskExecutionContext_ResourceManager{Call: c} + c_call := _m.On("ResourceManager") + return &TaskExecutionContext_ResourceManager{Call: c_call} } func (_m *TaskExecutionContext) OnResourceManagerMatch(matchers ...interface{}) *TaskExecutionContext_ResourceManager { - c := _m.On("ResourceManager", matchers...) - return &TaskExecutionContext_ResourceManager{Call: c} + c_call := _m.On("ResourceManager", matchers...) + return &TaskExecutionContext_ResourceManager{Call: c_call} } // ResourceManager provides a mock function with given fields: @@ -331,13 +331,13 @@ func (_m TaskExecutionContext_SecretManager) Return(_a0 core.SecretManager) *Tas } func (_m *TaskExecutionContext) OnSecretManager() *TaskExecutionContext_SecretManager { - c := _m.On("SecretManager") - return &TaskExecutionContext_SecretManager{Call: c} + c_call := _m.On("SecretManager") + return &TaskExecutionContext_SecretManager{Call: c_call} } func (_m *TaskExecutionContext) OnSecretManagerMatch(matchers ...interface{}) *TaskExecutionContext_SecretManager { - c := _m.On("SecretManager", matchers...) - return &TaskExecutionContext_SecretManager{Call: c} + c_call := _m.On("SecretManager", matchers...) + return &TaskExecutionContext_SecretManager{Call: c_call} } // SecretManager provides a mock function with given fields: @@ -365,13 +365,13 @@ func (_m TaskExecutionContext_TaskExecutionMetadata) Return(_a0 core.TaskExecuti } func (_m *TaskExecutionContext) OnTaskExecutionMetadata() *TaskExecutionContext_TaskExecutionMetadata { - c := _m.On("TaskExecutionMetadata") - return &TaskExecutionContext_TaskExecutionMetadata{Call: c} + c_call := _m.On("TaskExecutionMetadata") + return &TaskExecutionContext_TaskExecutionMetadata{Call: c_call} } func (_m *TaskExecutionContext) OnTaskExecutionMetadataMatch(matchers ...interface{}) *TaskExecutionContext_TaskExecutionMetadata { - c := _m.On("TaskExecutionMetadata", matchers...) - return &TaskExecutionContext_TaskExecutionMetadata{Call: c} + c_call := _m.On("TaskExecutionMetadata", matchers...) + return &TaskExecutionContext_TaskExecutionMetadata{Call: c_call} } // TaskExecutionMetadata provides a mock function with given fields: @@ -399,13 +399,13 @@ func (_m TaskExecutionContext_TaskReader) Return(_a0 core.TaskReader) *TaskExecu } func (_m *TaskExecutionContext) OnTaskReader() *TaskExecutionContext_TaskReader { - c := _m.On("TaskReader") - return &TaskExecutionContext_TaskReader{Call: c} + c_call := _m.On("TaskReader") + return &TaskExecutionContext_TaskReader{Call: c_call} } func (_m *TaskExecutionContext) OnTaskReaderMatch(matchers ...interface{}) *TaskExecutionContext_TaskReader { - c := _m.On("TaskReader", matchers...) - return &TaskExecutionContext_TaskReader{Call: c} + c_call := _m.On("TaskReader", matchers...) + return &TaskExecutionContext_TaskReader{Call: c_call} } // TaskReader provides a mock function with given fields: @@ -433,13 +433,13 @@ func (_m TaskExecutionContext_TaskRefreshIndicator) Return(_a0 core.SignalAsync) } func (_m *TaskExecutionContext) OnTaskRefreshIndicator() *TaskExecutionContext_TaskRefreshIndicator { - c := _m.On("TaskRefreshIndicator") - return &TaskExecutionContext_TaskRefreshIndicator{Call: c} + c_call := _m.On("TaskRefreshIndicator") + return &TaskExecutionContext_TaskRefreshIndicator{Call: c_call} } func (_m *TaskExecutionContext) OnTaskRefreshIndicatorMatch(matchers ...interface{}) *TaskExecutionContext_TaskRefreshIndicator { - c := _m.On("TaskRefreshIndicator", matchers...) - return &TaskExecutionContext_TaskRefreshIndicator{Call: c} + c_call := _m.On("TaskRefreshIndicator", matchers...) + return &TaskExecutionContext_TaskRefreshIndicator{Call: c_call} } // TaskRefreshIndicator provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/core/mocks/task_execution_id.go b/go/tasks/pluginmachinery/core/mocks/task_execution_id.go index d0a50a1e6..ef75d6bac 100644 --- a/go/tasks/pluginmachinery/core/mocks/task_execution_id.go +++ b/go/tasks/pluginmachinery/core/mocks/task_execution_id.go @@ -21,13 +21,13 @@ func (_m TaskExecutionID_GetGeneratedName) Return(_a0 string) *TaskExecutionID_G } func (_m *TaskExecutionID) OnGetGeneratedName() *TaskExecutionID_GetGeneratedName { - c := _m.On("GetGeneratedName") - return &TaskExecutionID_GetGeneratedName{Call: c} + c_call := _m.On("GetGeneratedName") + return &TaskExecutionID_GetGeneratedName{Call: c_call} } func (_m *TaskExecutionID) OnGetGeneratedNameMatch(matchers ...interface{}) *TaskExecutionID_GetGeneratedName { - c := _m.On("GetGeneratedName", matchers...) - return &TaskExecutionID_GetGeneratedName{Call: c} + c_call := _m.On("GetGeneratedName", matchers...) + return &TaskExecutionID_GetGeneratedName{Call: c_call} } // GetGeneratedName provides a mock function with given fields: @@ -53,13 +53,13 @@ func (_m TaskExecutionID_GetGeneratedNameWith) Return(_a0 string, _a1 error) *Ta } func (_m *TaskExecutionID) OnGetGeneratedNameWith(minLength int, maxLength int) *TaskExecutionID_GetGeneratedNameWith { - c := _m.On("GetGeneratedNameWith", minLength, maxLength) - return &TaskExecutionID_GetGeneratedNameWith{Call: c} + c_call := _m.On("GetGeneratedNameWith", minLength, maxLength) + return &TaskExecutionID_GetGeneratedNameWith{Call: c_call} } func (_m *TaskExecutionID) OnGetGeneratedNameWithMatch(matchers ...interface{}) *TaskExecutionID_GetGeneratedNameWith { - c := _m.On("GetGeneratedNameWith", matchers...) - return &TaskExecutionID_GetGeneratedNameWith{Call: c} + c_call := _m.On("GetGeneratedNameWith", matchers...) + return &TaskExecutionID_GetGeneratedNameWith{Call: c_call} } // GetGeneratedNameWith provides a mock function with given fields: minLength, maxLength @@ -92,13 +92,13 @@ func (_m TaskExecutionID_GetID) Return(_a0 flyteidlcore.TaskExecutionIdentifier) } func (_m *TaskExecutionID) OnGetID() *TaskExecutionID_GetID { - c := _m.On("GetID") - return &TaskExecutionID_GetID{Call: c} + c_call := _m.On("GetID") + return &TaskExecutionID_GetID{Call: c_call} } func (_m *TaskExecutionID) OnGetIDMatch(matchers ...interface{}) *TaskExecutionID_GetID { - c := _m.On("GetID", matchers...) - return &TaskExecutionID_GetID{Call: c} + c_call := _m.On("GetID", matchers...) + return &TaskExecutionID_GetID{Call: c_call} } // GetID provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/core/mocks/task_execution_metadata.go b/go/tasks/pluginmachinery/core/mocks/task_execution_metadata.go index e851cb7aa..41af602a6 100644 --- a/go/tasks/pluginmachinery/core/mocks/task_execution_metadata.go +++ b/go/tasks/pluginmachinery/core/mocks/task_execution_metadata.go @@ -29,13 +29,13 @@ func (_m TaskExecutionMetadata_GetAnnotations) Return(_a0 map[string]string) *Ta } func (_m *TaskExecutionMetadata) OnGetAnnotations() *TaskExecutionMetadata_GetAnnotations { - c := _m.On("GetAnnotations") - return &TaskExecutionMetadata_GetAnnotations{Call: c} + c_call := _m.On("GetAnnotations") + return &TaskExecutionMetadata_GetAnnotations{Call: c_call} } func (_m *TaskExecutionMetadata) OnGetAnnotationsMatch(matchers ...interface{}) *TaskExecutionMetadata_GetAnnotations { - c := _m.On("GetAnnotations", matchers...) - return &TaskExecutionMetadata_GetAnnotations{Call: c} + c_call := _m.On("GetAnnotations", matchers...) + return &TaskExecutionMetadata_GetAnnotations{Call: c_call} } // GetAnnotations provides a mock function with given fields: @@ -63,13 +63,13 @@ func (_m TaskExecutionMetadata_GetInterruptibleFailureThreshold) Return(_a0 uint } func (_m *TaskExecutionMetadata) OnGetInterruptibleFailureThreshold() *TaskExecutionMetadata_GetInterruptibleFailureThreshold { - c := _m.On("GetInterruptibleFailureThreshold") - return &TaskExecutionMetadata_GetInterruptibleFailureThreshold{Call: c} + c_call := _m.On("GetInterruptibleFailureThreshold") + return &TaskExecutionMetadata_GetInterruptibleFailureThreshold{Call: c_call} } func (_m *TaskExecutionMetadata) OnGetInterruptibleFailureThresholdMatch(matchers ...interface{}) *TaskExecutionMetadata_GetInterruptibleFailureThreshold { - c := _m.On("GetInterruptibleFailureThreshold", matchers...) - return &TaskExecutionMetadata_GetInterruptibleFailureThreshold{Call: c} + c_call := _m.On("GetInterruptibleFailureThreshold", matchers...) + return &TaskExecutionMetadata_GetInterruptibleFailureThreshold{Call: c_call} } // GetInterruptibleFailureThreshold provides a mock function with given fields: @@ -95,13 +95,13 @@ func (_m TaskExecutionMetadata_GetK8sServiceAccount) Return(_a0 string) *TaskExe } func (_m *TaskExecutionMetadata) OnGetK8sServiceAccount() *TaskExecutionMetadata_GetK8sServiceAccount { - c := _m.On("GetK8sServiceAccount") - return &TaskExecutionMetadata_GetK8sServiceAccount{Call: c} + c_call := _m.On("GetK8sServiceAccount") + return &TaskExecutionMetadata_GetK8sServiceAccount{Call: c_call} } func (_m *TaskExecutionMetadata) OnGetK8sServiceAccountMatch(matchers ...interface{}) *TaskExecutionMetadata_GetK8sServiceAccount { - c := _m.On("GetK8sServiceAccount", matchers...) - return &TaskExecutionMetadata_GetK8sServiceAccount{Call: c} + c_call := _m.On("GetK8sServiceAccount", matchers...) + return &TaskExecutionMetadata_GetK8sServiceAccount{Call: c_call} } // GetK8sServiceAccount provides a mock function with given fields: @@ -127,13 +127,13 @@ func (_m TaskExecutionMetadata_GetLabels) Return(_a0 map[string]string) *TaskExe } func (_m *TaskExecutionMetadata) OnGetLabels() *TaskExecutionMetadata_GetLabels { - c := _m.On("GetLabels") - return &TaskExecutionMetadata_GetLabels{Call: c} + c_call := _m.On("GetLabels") + return &TaskExecutionMetadata_GetLabels{Call: c_call} } func (_m *TaskExecutionMetadata) OnGetLabelsMatch(matchers ...interface{}) *TaskExecutionMetadata_GetLabels { - c := _m.On("GetLabels", matchers...) - return &TaskExecutionMetadata_GetLabels{Call: c} + c_call := _m.On("GetLabels", matchers...) + return &TaskExecutionMetadata_GetLabels{Call: c_call} } // GetLabels provides a mock function with given fields: @@ -161,13 +161,13 @@ func (_m TaskExecutionMetadata_GetMaxAttempts) Return(_a0 uint32) *TaskExecution } func (_m *TaskExecutionMetadata) OnGetMaxAttempts() *TaskExecutionMetadata_GetMaxAttempts { - c := _m.On("GetMaxAttempts") - return &TaskExecutionMetadata_GetMaxAttempts{Call: c} + c_call := _m.On("GetMaxAttempts") + return &TaskExecutionMetadata_GetMaxAttempts{Call: c_call} } func (_m *TaskExecutionMetadata) OnGetMaxAttemptsMatch(matchers ...interface{}) *TaskExecutionMetadata_GetMaxAttempts { - c := _m.On("GetMaxAttempts", matchers...) - return &TaskExecutionMetadata_GetMaxAttempts{Call: c} + c_call := _m.On("GetMaxAttempts", matchers...) + return &TaskExecutionMetadata_GetMaxAttempts{Call: c_call} } // GetMaxAttempts provides a mock function with given fields: @@ -193,13 +193,13 @@ func (_m TaskExecutionMetadata_GetNamespace) Return(_a0 string) *TaskExecutionMe } func (_m *TaskExecutionMetadata) OnGetNamespace() *TaskExecutionMetadata_GetNamespace { - c := _m.On("GetNamespace") - return &TaskExecutionMetadata_GetNamespace{Call: c} + c_call := _m.On("GetNamespace") + return &TaskExecutionMetadata_GetNamespace{Call: c_call} } func (_m *TaskExecutionMetadata) OnGetNamespaceMatch(matchers ...interface{}) *TaskExecutionMetadata_GetNamespace { - c := _m.On("GetNamespace", matchers...) - return &TaskExecutionMetadata_GetNamespace{Call: c} + c_call := _m.On("GetNamespace", matchers...) + return &TaskExecutionMetadata_GetNamespace{Call: c_call} } // GetNamespace provides a mock function with given fields: @@ -225,13 +225,13 @@ func (_m TaskExecutionMetadata_GetOverrides) Return(_a0 core.TaskOverrides) *Tas } func (_m *TaskExecutionMetadata) OnGetOverrides() *TaskExecutionMetadata_GetOverrides { - c := _m.On("GetOverrides") - return &TaskExecutionMetadata_GetOverrides{Call: c} + c_call := _m.On("GetOverrides") + return &TaskExecutionMetadata_GetOverrides{Call: c_call} } func (_m *TaskExecutionMetadata) OnGetOverridesMatch(matchers ...interface{}) *TaskExecutionMetadata_GetOverrides { - c := _m.On("GetOverrides", matchers...) - return &TaskExecutionMetadata_GetOverrides{Call: c} + c_call := _m.On("GetOverrides", matchers...) + return &TaskExecutionMetadata_GetOverrides{Call: c_call} } // GetOverrides provides a mock function with given fields: @@ -259,13 +259,13 @@ func (_m TaskExecutionMetadata_GetOwnerID) Return(_a0 types.NamespacedName) *Tas } func (_m *TaskExecutionMetadata) OnGetOwnerID() *TaskExecutionMetadata_GetOwnerID { - c := _m.On("GetOwnerID") - return &TaskExecutionMetadata_GetOwnerID{Call: c} + c_call := _m.On("GetOwnerID") + return &TaskExecutionMetadata_GetOwnerID{Call: c_call} } func (_m *TaskExecutionMetadata) OnGetOwnerIDMatch(matchers ...interface{}) *TaskExecutionMetadata_GetOwnerID { - c := _m.On("GetOwnerID", matchers...) - return &TaskExecutionMetadata_GetOwnerID{Call: c} + c_call := _m.On("GetOwnerID", matchers...) + return &TaskExecutionMetadata_GetOwnerID{Call: c_call} } // GetOwnerID provides a mock function with given fields: @@ -291,13 +291,13 @@ func (_m TaskExecutionMetadata_GetOwnerReference) Return(_a0 v1.OwnerReference) } func (_m *TaskExecutionMetadata) OnGetOwnerReference() *TaskExecutionMetadata_GetOwnerReference { - c := _m.On("GetOwnerReference") - return &TaskExecutionMetadata_GetOwnerReference{Call: c} + c_call := _m.On("GetOwnerReference") + return &TaskExecutionMetadata_GetOwnerReference{Call: c_call} } func (_m *TaskExecutionMetadata) OnGetOwnerReferenceMatch(matchers ...interface{}) *TaskExecutionMetadata_GetOwnerReference { - c := _m.On("GetOwnerReference", matchers...) - return &TaskExecutionMetadata_GetOwnerReference{Call: c} + c_call := _m.On("GetOwnerReference", matchers...) + return &TaskExecutionMetadata_GetOwnerReference{Call: c_call} } // GetOwnerReference provides a mock function with given fields: @@ -323,13 +323,13 @@ func (_m TaskExecutionMetadata_GetPlatformResources) Return(_a0 *corev1.Resource } func (_m *TaskExecutionMetadata) OnGetPlatformResources() *TaskExecutionMetadata_GetPlatformResources { - c := _m.On("GetPlatformResources") - return &TaskExecutionMetadata_GetPlatformResources{Call: c} + c_call := _m.On("GetPlatformResources") + return &TaskExecutionMetadata_GetPlatformResources{Call: c_call} } func (_m *TaskExecutionMetadata) OnGetPlatformResourcesMatch(matchers ...interface{}) *TaskExecutionMetadata_GetPlatformResources { - c := _m.On("GetPlatformResources", matchers...) - return &TaskExecutionMetadata_GetPlatformResources{Call: c} + c_call := _m.On("GetPlatformResources", matchers...) + return &TaskExecutionMetadata_GetPlatformResources{Call: c_call} } // GetPlatformResources provides a mock function with given fields: @@ -357,13 +357,13 @@ func (_m TaskExecutionMetadata_GetSecurityContext) Return(_a0 flyteidlcore.Secur } func (_m *TaskExecutionMetadata) OnGetSecurityContext() *TaskExecutionMetadata_GetSecurityContext { - c := _m.On("GetSecurityContext") - return &TaskExecutionMetadata_GetSecurityContext{Call: c} + c_call := _m.On("GetSecurityContext") + return &TaskExecutionMetadata_GetSecurityContext{Call: c_call} } func (_m *TaskExecutionMetadata) OnGetSecurityContextMatch(matchers ...interface{}) *TaskExecutionMetadata_GetSecurityContext { - c := _m.On("GetSecurityContext", matchers...) - return &TaskExecutionMetadata_GetSecurityContext{Call: c} + c_call := _m.On("GetSecurityContext", matchers...) + return &TaskExecutionMetadata_GetSecurityContext{Call: c_call} } // GetSecurityContext provides a mock function with given fields: @@ -389,13 +389,13 @@ func (_m TaskExecutionMetadata_GetTaskExecutionID) Return(_a0 core.TaskExecution } func (_m *TaskExecutionMetadata) OnGetTaskExecutionID() *TaskExecutionMetadata_GetTaskExecutionID { - c := _m.On("GetTaskExecutionID") - return &TaskExecutionMetadata_GetTaskExecutionID{Call: c} + c_call := _m.On("GetTaskExecutionID") + return &TaskExecutionMetadata_GetTaskExecutionID{Call: c_call} } func (_m *TaskExecutionMetadata) OnGetTaskExecutionIDMatch(matchers ...interface{}) *TaskExecutionMetadata_GetTaskExecutionID { - c := _m.On("GetTaskExecutionID", matchers...) - return &TaskExecutionMetadata_GetTaskExecutionID{Call: c} + c_call := _m.On("GetTaskExecutionID", matchers...) + return &TaskExecutionMetadata_GetTaskExecutionID{Call: c_call} } // GetTaskExecutionID provides a mock function with given fields: @@ -423,13 +423,13 @@ func (_m TaskExecutionMetadata_IsInterruptible) Return(_a0 bool) *TaskExecutionM } func (_m *TaskExecutionMetadata) OnIsInterruptible() *TaskExecutionMetadata_IsInterruptible { - c := _m.On("IsInterruptible") - return &TaskExecutionMetadata_IsInterruptible{Call: c} + c_call := _m.On("IsInterruptible") + return &TaskExecutionMetadata_IsInterruptible{Call: c_call} } func (_m *TaskExecutionMetadata) OnIsInterruptibleMatch(matchers ...interface{}) *TaskExecutionMetadata_IsInterruptible { - c := _m.On("IsInterruptible", matchers...) - return &TaskExecutionMetadata_IsInterruptible{Call: c} + c_call := _m.On("IsInterruptible", matchers...) + return &TaskExecutionMetadata_IsInterruptible{Call: c_call} } // IsInterruptible provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/core/mocks/task_overrides.go b/go/tasks/pluginmachinery/core/mocks/task_overrides.go index dc35666c7..d40f1461d 100644 --- a/go/tasks/pluginmachinery/core/mocks/task_overrides.go +++ b/go/tasks/pluginmachinery/core/mocks/task_overrides.go @@ -21,13 +21,13 @@ func (_m TaskOverrides_GetConfig) Return(_a0 *v1.ConfigMap) *TaskOverrides_GetCo } func (_m *TaskOverrides) OnGetConfig() *TaskOverrides_GetConfig { - c := _m.On("GetConfig") - return &TaskOverrides_GetConfig{Call: c} + c_call := _m.On("GetConfig") + return &TaskOverrides_GetConfig{Call: c_call} } func (_m *TaskOverrides) OnGetConfigMatch(matchers ...interface{}) *TaskOverrides_GetConfig { - c := _m.On("GetConfig", matchers...) - return &TaskOverrides_GetConfig{Call: c} + c_call := _m.On("GetConfig", matchers...) + return &TaskOverrides_GetConfig{Call: c_call} } // GetConfig provides a mock function with given fields: @@ -55,13 +55,13 @@ func (_m TaskOverrides_GetResources) Return(_a0 *v1.ResourceRequirements) *TaskO } func (_m *TaskOverrides) OnGetResources() *TaskOverrides_GetResources { - c := _m.On("GetResources") - return &TaskOverrides_GetResources{Call: c} + c_call := _m.On("GetResources") + return &TaskOverrides_GetResources{Call: c_call} } func (_m *TaskOverrides) OnGetResourcesMatch(matchers ...interface{}) *TaskOverrides_GetResources { - c := _m.On("GetResources", matchers...) - return &TaskOverrides_GetResources{Call: c} + c_call := _m.On("GetResources", matchers...) + return &TaskOverrides_GetResources{Call: c_call} } // GetResources provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/core/mocks/task_reader.go b/go/tasks/pluginmachinery/core/mocks/task_reader.go index b7aef61a2..ab95a4020 100644 --- a/go/tasks/pluginmachinery/core/mocks/task_reader.go +++ b/go/tasks/pluginmachinery/core/mocks/task_reader.go @@ -26,13 +26,13 @@ func (_m TaskReader_Path) Return(_a0 storage.DataReference, _a1 error) *TaskRead } func (_m *TaskReader) OnPath(ctx context.Context) *TaskReader_Path { - c := _m.On("Path", ctx) - return &TaskReader_Path{Call: c} + c_call := _m.On("Path", ctx) + return &TaskReader_Path{Call: c_call} } func (_m *TaskReader) OnPathMatch(matchers ...interface{}) *TaskReader_Path { - c := _m.On("Path", matchers...) - return &TaskReader_Path{Call: c} + c_call := _m.On("Path", matchers...) + return &TaskReader_Path{Call: c_call} } // Path provides a mock function with given fields: ctx @@ -65,13 +65,13 @@ func (_m TaskReader_Read) Return(_a0 *flyteidlcore.TaskTemplate, _a1 error) *Tas } func (_m *TaskReader) OnRead(ctx context.Context) *TaskReader_Read { - c := _m.On("Read", ctx) - return &TaskReader_Read{Call: c} + c_call := _m.On("Read", ctx) + return &TaskReader_Read{Call: c_call} } func (_m *TaskReader) OnReadMatch(matchers ...interface{}) *TaskReader_Read { - c := _m.On("Read", matchers...) - return &TaskReader_Read{Call: c} + c_call := _m.On("Read", matchers...) + return &TaskReader_Read{Call: c_call} } // Read provides a mock function with given fields: ctx diff --git a/go/tasks/pluginmachinery/core/mocks/task_template_path.go b/go/tasks/pluginmachinery/core/mocks/task_template_path.go index 245517849..2d445b552 100644 --- a/go/tasks/pluginmachinery/core/mocks/task_template_path.go +++ b/go/tasks/pluginmachinery/core/mocks/task_template_path.go @@ -24,13 +24,13 @@ func (_m TaskTemplatePath_Path) Return(_a0 storage.DataReference, _a1 error) *Ta } func (_m *TaskTemplatePath) OnPath(ctx context.Context) *TaskTemplatePath_Path { - c := _m.On("Path", ctx) - return &TaskTemplatePath_Path{Call: c} + c_call := _m.On("Path", ctx) + return &TaskTemplatePath_Path{Call: c_call} } func (_m *TaskTemplatePath) OnPathMatch(matchers ...interface{}) *TaskTemplatePath_Path { - c := _m.On("Path", matchers...) - return &TaskTemplatePath_Path{Call: c} + c_call := _m.On("Path", matchers...) + return &TaskTemplatePath_Path{Call: c_call} } // Path provides a mock function with given fields: ctx diff --git a/go/tasks/pluginmachinery/internal/webapi/mocks/client.go b/go/tasks/pluginmachinery/internal/webapi/mocks/client.go index f441f5133..19d91ad79 100644 --- a/go/tasks/pluginmachinery/internal/webapi/mocks/client.go +++ b/go/tasks/pluginmachinery/internal/webapi/mocks/client.go @@ -26,13 +26,13 @@ func (_m Client_Get) Return(latest interface{}, err error) *Client_Get { } func (_m *Client) OnGet(ctx context.Context, tCtx webapi.GetContext) *Client_Get { - c := _m.On("Get", ctx, tCtx) - return &Client_Get{Call: c} + c_call := _m.On("Get", ctx, tCtx) + return &Client_Get{Call: c_call} } func (_m *Client) OnGetMatch(matchers ...interface{}) *Client_Get { - c := _m.On("Get", matchers...) - return &Client_Get{Call: c} + c_call := _m.On("Get", matchers...) + return &Client_Get{Call: c_call} } // Get provides a mock function with given fields: ctx, tCtx @@ -67,13 +67,13 @@ func (_m Client_Status) Return(phase core.PhaseInfo, err error) *Client_Status { } func (_m *Client) OnStatus(ctx context.Context, tCtx webapi.StatusContext) *Client_Status { - c := _m.On("Status", ctx, tCtx) - return &Client_Status{Call: c} + c_call := _m.On("Status", ctx, tCtx) + return &Client_Status{Call: c_call} } func (_m *Client) OnStatusMatch(matchers ...interface{}) *Client_Status { - c := _m.On("Status", matchers...) - return &Client_Status{Call: c} + c_call := _m.On("Status", matchers...) + return &Client_Status{Call: c_call} } // Status provides a mock function with given fields: ctx, tCtx diff --git a/go/tasks/pluginmachinery/io/mocks/checkpoint_paths.go b/go/tasks/pluginmachinery/io/mocks/checkpoint_paths.go index f66d89bed..5d7c25f3a 100644 --- a/go/tasks/pluginmachinery/io/mocks/checkpoint_paths.go +++ b/go/tasks/pluginmachinery/io/mocks/checkpoint_paths.go @@ -21,13 +21,13 @@ func (_m CheckpointPaths_GetCheckpointPrefix) Return(_a0 storage.DataReference) } func (_m *CheckpointPaths) OnGetCheckpointPrefix() *CheckpointPaths_GetCheckpointPrefix { - c := _m.On("GetCheckpointPrefix") - return &CheckpointPaths_GetCheckpointPrefix{Call: c} + c_call := _m.On("GetCheckpointPrefix") + return &CheckpointPaths_GetCheckpointPrefix{Call: c_call} } func (_m *CheckpointPaths) OnGetCheckpointPrefixMatch(matchers ...interface{}) *CheckpointPaths_GetCheckpointPrefix { - c := _m.On("GetCheckpointPrefix", matchers...) - return &CheckpointPaths_GetCheckpointPrefix{Call: c} + c_call := _m.On("GetCheckpointPrefix", matchers...) + return &CheckpointPaths_GetCheckpointPrefix{Call: c_call} } // GetCheckpointPrefix provides a mock function with given fields: @@ -53,13 +53,13 @@ func (_m CheckpointPaths_GetPreviousCheckpointsPrefix) Return(_a0 storage.DataRe } func (_m *CheckpointPaths) OnGetPreviousCheckpointsPrefix() *CheckpointPaths_GetPreviousCheckpointsPrefix { - c := _m.On("GetPreviousCheckpointsPrefix") - return &CheckpointPaths_GetPreviousCheckpointsPrefix{Call: c} + c_call := _m.On("GetPreviousCheckpointsPrefix") + return &CheckpointPaths_GetPreviousCheckpointsPrefix{Call: c_call} } func (_m *CheckpointPaths) OnGetPreviousCheckpointsPrefixMatch(matchers ...interface{}) *CheckpointPaths_GetPreviousCheckpointsPrefix { - c := _m.On("GetPreviousCheckpointsPrefix", matchers...) - return &CheckpointPaths_GetPreviousCheckpointsPrefix{Call: c} + c_call := _m.On("GetPreviousCheckpointsPrefix", matchers...) + return &CheckpointPaths_GetPreviousCheckpointsPrefix{Call: c_call} } // GetPreviousCheckpointsPrefix provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/io/mocks/input_file_paths.go b/go/tasks/pluginmachinery/io/mocks/input_file_paths.go index 55f9ade50..0a3a3d9e3 100644 --- a/go/tasks/pluginmachinery/io/mocks/input_file_paths.go +++ b/go/tasks/pluginmachinery/io/mocks/input_file_paths.go @@ -21,13 +21,13 @@ func (_m InputFilePaths_GetInputPath) Return(_a0 storage.DataReference) *InputFi } func (_m *InputFilePaths) OnGetInputPath() *InputFilePaths_GetInputPath { - c := _m.On("GetInputPath") - return &InputFilePaths_GetInputPath{Call: c} + c_call := _m.On("GetInputPath") + return &InputFilePaths_GetInputPath{Call: c_call} } func (_m *InputFilePaths) OnGetInputPathMatch(matchers ...interface{}) *InputFilePaths_GetInputPath { - c := _m.On("GetInputPath", matchers...) - return &InputFilePaths_GetInputPath{Call: c} + c_call := _m.On("GetInputPath", matchers...) + return &InputFilePaths_GetInputPath{Call: c_call} } // GetInputPath provides a mock function with given fields: @@ -53,13 +53,13 @@ func (_m InputFilePaths_GetInputPrefixPath) Return(_a0 storage.DataReference) *I } func (_m *InputFilePaths) OnGetInputPrefixPath() *InputFilePaths_GetInputPrefixPath { - c := _m.On("GetInputPrefixPath") - return &InputFilePaths_GetInputPrefixPath{Call: c} + c_call := _m.On("GetInputPrefixPath") + return &InputFilePaths_GetInputPrefixPath{Call: c_call} } func (_m *InputFilePaths) OnGetInputPrefixPathMatch(matchers ...interface{}) *InputFilePaths_GetInputPrefixPath { - c := _m.On("GetInputPrefixPath", matchers...) - return &InputFilePaths_GetInputPrefixPath{Call: c} + c_call := _m.On("GetInputPrefixPath", matchers...) + return &InputFilePaths_GetInputPrefixPath{Call: c_call} } // GetInputPrefixPath provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/io/mocks/input_reader.go b/go/tasks/pluginmachinery/io/mocks/input_reader.go index ff6eea2e2..f53b15472 100644 --- a/go/tasks/pluginmachinery/io/mocks/input_reader.go +++ b/go/tasks/pluginmachinery/io/mocks/input_reader.go @@ -26,13 +26,13 @@ func (_m InputReader_Get) Return(_a0 *core.LiteralMap, _a1 error) *InputReader_G } func (_m *InputReader) OnGet(ctx context.Context) *InputReader_Get { - c := _m.On("Get", ctx) - return &InputReader_Get{Call: c} + c_call := _m.On("Get", ctx) + return &InputReader_Get{Call: c_call} } func (_m *InputReader) OnGetMatch(matchers ...interface{}) *InputReader_Get { - c := _m.On("Get", matchers...) - return &InputReader_Get{Call: c} + c_call := _m.On("Get", matchers...) + return &InputReader_Get{Call: c_call} } // Get provides a mock function with given fields: ctx @@ -67,13 +67,13 @@ func (_m InputReader_GetInputPath) Return(_a0 storage.DataReference) *InputReade } func (_m *InputReader) OnGetInputPath() *InputReader_GetInputPath { - c := _m.On("GetInputPath") - return &InputReader_GetInputPath{Call: c} + c_call := _m.On("GetInputPath") + return &InputReader_GetInputPath{Call: c_call} } func (_m *InputReader) OnGetInputPathMatch(matchers ...interface{}) *InputReader_GetInputPath { - c := _m.On("GetInputPath", matchers...) - return &InputReader_GetInputPath{Call: c} + c_call := _m.On("GetInputPath", matchers...) + return &InputReader_GetInputPath{Call: c_call} } // GetInputPath provides a mock function with given fields: @@ -99,13 +99,13 @@ func (_m InputReader_GetInputPrefixPath) Return(_a0 storage.DataReference) *Inpu } func (_m *InputReader) OnGetInputPrefixPath() *InputReader_GetInputPrefixPath { - c := _m.On("GetInputPrefixPath") - return &InputReader_GetInputPrefixPath{Call: c} + c_call := _m.On("GetInputPrefixPath") + return &InputReader_GetInputPrefixPath{Call: c_call} } func (_m *InputReader) OnGetInputPrefixPathMatch(matchers ...interface{}) *InputReader_GetInputPrefixPath { - c := _m.On("GetInputPrefixPath", matchers...) - return &InputReader_GetInputPrefixPath{Call: c} + c_call := _m.On("GetInputPrefixPath", matchers...) + return &InputReader_GetInputPrefixPath{Call: c_call} } // GetInputPrefixPath provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/io/mocks/output_file_paths.go b/go/tasks/pluginmachinery/io/mocks/output_file_paths.go index 5ff4e24f8..1b97dbf8c 100644 --- a/go/tasks/pluginmachinery/io/mocks/output_file_paths.go +++ b/go/tasks/pluginmachinery/io/mocks/output_file_paths.go @@ -21,13 +21,13 @@ func (_m OutputFilePaths_GetCheckpointPrefix) Return(_a0 storage.DataReference) } func (_m *OutputFilePaths) OnGetCheckpointPrefix() *OutputFilePaths_GetCheckpointPrefix { - c := _m.On("GetCheckpointPrefix") - return &OutputFilePaths_GetCheckpointPrefix{Call: c} + c_call := _m.On("GetCheckpointPrefix") + return &OutputFilePaths_GetCheckpointPrefix{Call: c_call} } func (_m *OutputFilePaths) OnGetCheckpointPrefixMatch(matchers ...interface{}) *OutputFilePaths_GetCheckpointPrefix { - c := _m.On("GetCheckpointPrefix", matchers...) - return &OutputFilePaths_GetCheckpointPrefix{Call: c} + c_call := _m.On("GetCheckpointPrefix", matchers...) + return &OutputFilePaths_GetCheckpointPrefix{Call: c_call} } // GetCheckpointPrefix provides a mock function with given fields: @@ -53,13 +53,13 @@ func (_m OutputFilePaths_GetErrorPath) Return(_a0 storage.DataReference) *Output } func (_m *OutputFilePaths) OnGetErrorPath() *OutputFilePaths_GetErrorPath { - c := _m.On("GetErrorPath") - return &OutputFilePaths_GetErrorPath{Call: c} + c_call := _m.On("GetErrorPath") + return &OutputFilePaths_GetErrorPath{Call: c_call} } func (_m *OutputFilePaths) OnGetErrorPathMatch(matchers ...interface{}) *OutputFilePaths_GetErrorPath { - c := _m.On("GetErrorPath", matchers...) - return &OutputFilePaths_GetErrorPath{Call: c} + c_call := _m.On("GetErrorPath", matchers...) + return &OutputFilePaths_GetErrorPath{Call: c_call} } // GetErrorPath provides a mock function with given fields: @@ -85,13 +85,13 @@ func (_m OutputFilePaths_GetOutputPath) Return(_a0 storage.DataReference) *Outpu } func (_m *OutputFilePaths) OnGetOutputPath() *OutputFilePaths_GetOutputPath { - c := _m.On("GetOutputPath") - return &OutputFilePaths_GetOutputPath{Call: c} + c_call := _m.On("GetOutputPath") + return &OutputFilePaths_GetOutputPath{Call: c_call} } func (_m *OutputFilePaths) OnGetOutputPathMatch(matchers ...interface{}) *OutputFilePaths_GetOutputPath { - c := _m.On("GetOutputPath", matchers...) - return &OutputFilePaths_GetOutputPath{Call: c} + c_call := _m.On("GetOutputPath", matchers...) + return &OutputFilePaths_GetOutputPath{Call: c_call} } // GetOutputPath provides a mock function with given fields: @@ -117,13 +117,13 @@ func (_m OutputFilePaths_GetOutputPrefixPath) Return(_a0 storage.DataReference) } func (_m *OutputFilePaths) OnGetOutputPrefixPath() *OutputFilePaths_GetOutputPrefixPath { - c := _m.On("GetOutputPrefixPath") - return &OutputFilePaths_GetOutputPrefixPath{Call: c} + c_call := _m.On("GetOutputPrefixPath") + return &OutputFilePaths_GetOutputPrefixPath{Call: c_call} } func (_m *OutputFilePaths) OnGetOutputPrefixPathMatch(matchers ...interface{}) *OutputFilePaths_GetOutputPrefixPath { - c := _m.On("GetOutputPrefixPath", matchers...) - return &OutputFilePaths_GetOutputPrefixPath{Call: c} + c_call := _m.On("GetOutputPrefixPath", matchers...) + return &OutputFilePaths_GetOutputPrefixPath{Call: c_call} } // GetOutputPrefixPath provides a mock function with given fields: @@ -149,13 +149,13 @@ func (_m OutputFilePaths_GetPreviousCheckpointsPrefix) Return(_a0 storage.DataRe } func (_m *OutputFilePaths) OnGetPreviousCheckpointsPrefix() *OutputFilePaths_GetPreviousCheckpointsPrefix { - c := _m.On("GetPreviousCheckpointsPrefix") - return &OutputFilePaths_GetPreviousCheckpointsPrefix{Call: c} + c_call := _m.On("GetPreviousCheckpointsPrefix") + return &OutputFilePaths_GetPreviousCheckpointsPrefix{Call: c_call} } func (_m *OutputFilePaths) OnGetPreviousCheckpointsPrefixMatch(matchers ...interface{}) *OutputFilePaths_GetPreviousCheckpointsPrefix { - c := _m.On("GetPreviousCheckpointsPrefix", matchers...) - return &OutputFilePaths_GetPreviousCheckpointsPrefix{Call: c} + c_call := _m.On("GetPreviousCheckpointsPrefix", matchers...) + return &OutputFilePaths_GetPreviousCheckpointsPrefix{Call: c_call} } // GetPreviousCheckpointsPrefix provides a mock function with given fields: @@ -181,13 +181,13 @@ func (_m OutputFilePaths_GetRawOutputPrefix) Return(_a0 storage.DataReference) * } func (_m *OutputFilePaths) OnGetRawOutputPrefix() *OutputFilePaths_GetRawOutputPrefix { - c := _m.On("GetRawOutputPrefix") - return &OutputFilePaths_GetRawOutputPrefix{Call: c} + c_call := _m.On("GetRawOutputPrefix") + return &OutputFilePaths_GetRawOutputPrefix{Call: c_call} } func (_m *OutputFilePaths) OnGetRawOutputPrefixMatch(matchers ...interface{}) *OutputFilePaths_GetRawOutputPrefix { - c := _m.On("GetRawOutputPrefix", matchers...) - return &OutputFilePaths_GetRawOutputPrefix{Call: c} + c_call := _m.On("GetRawOutputPrefix", matchers...) + return &OutputFilePaths_GetRawOutputPrefix{Call: c_call} } // GetRawOutputPrefix provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/io/mocks/output_reader.go b/go/tasks/pluginmachinery/io/mocks/output_reader.go index f48b51aca..04f040599 100644 --- a/go/tasks/pluginmachinery/io/mocks/output_reader.go +++ b/go/tasks/pluginmachinery/io/mocks/output_reader.go @@ -25,13 +25,13 @@ func (_m OutputReader_Exists) Return(_a0 bool, _a1 error) *OutputReader_Exists { } func (_m *OutputReader) OnExists(ctx context.Context) *OutputReader_Exists { - c := _m.On("Exists", ctx) - return &OutputReader_Exists{Call: c} + c_call := _m.On("Exists", ctx) + return &OutputReader_Exists{Call: c_call} } func (_m *OutputReader) OnExistsMatch(matchers ...interface{}) *OutputReader_Exists { - c := _m.On("Exists", matchers...) - return &OutputReader_Exists{Call: c} + c_call := _m.On("Exists", matchers...) + return &OutputReader_Exists{Call: c_call} } // Exists provides a mock function with given fields: ctx @@ -64,13 +64,13 @@ func (_m OutputReader_IsError) Return(_a0 bool, _a1 error) *OutputReader_IsError } func (_m *OutputReader) OnIsError(ctx context.Context) *OutputReader_IsError { - c := _m.On("IsError", ctx) - return &OutputReader_IsError{Call: c} + c_call := _m.On("IsError", ctx) + return &OutputReader_IsError{Call: c_call} } func (_m *OutputReader) OnIsErrorMatch(matchers ...interface{}) *OutputReader_IsError { - c := _m.On("IsError", matchers...) - return &OutputReader_IsError{Call: c} + c_call := _m.On("IsError", matchers...) + return &OutputReader_IsError{Call: c_call} } // IsError provides a mock function with given fields: ctx @@ -103,13 +103,13 @@ func (_m OutputReader_IsFile) Return(_a0 bool) *OutputReader_IsFile { } func (_m *OutputReader) OnIsFile(ctx context.Context) *OutputReader_IsFile { - c := _m.On("IsFile", ctx) - return &OutputReader_IsFile{Call: c} + c_call := _m.On("IsFile", ctx) + return &OutputReader_IsFile{Call: c_call} } func (_m *OutputReader) OnIsFileMatch(matchers ...interface{}) *OutputReader_IsFile { - c := _m.On("IsFile", matchers...) - return &OutputReader_IsFile{Call: c} + c_call := _m.On("IsFile", matchers...) + return &OutputReader_IsFile{Call: c_call} } // IsFile provides a mock function with given fields: ctx @@ -135,13 +135,13 @@ func (_m OutputReader_Read) Return(_a0 *core.LiteralMap, _a1 *io.ExecutionError, } func (_m *OutputReader) OnRead(ctx context.Context) *OutputReader_Read { - c := _m.On("Read", ctx) - return &OutputReader_Read{Call: c} + c_call := _m.On("Read", ctx) + return &OutputReader_Read{Call: c_call} } func (_m *OutputReader) OnReadMatch(matchers ...interface{}) *OutputReader_Read { - c := _m.On("Read", matchers...) - return &OutputReader_Read{Call: c} + c_call := _m.On("Read", matchers...) + return &OutputReader_Read{Call: c_call} } // Read provides a mock function with given fields: ctx @@ -185,13 +185,13 @@ func (_m OutputReader_ReadError) Return(_a0 io.ExecutionError, _a1 error) *Outpu } func (_m *OutputReader) OnReadError(ctx context.Context) *OutputReader_ReadError { - c := _m.On("ReadError", ctx) - return &OutputReader_ReadError{Call: c} + c_call := _m.On("ReadError", ctx) + return &OutputReader_ReadError{Call: c_call} } func (_m *OutputReader) OnReadErrorMatch(matchers ...interface{}) *OutputReader_ReadError { - c := _m.On("ReadError", matchers...) - return &OutputReader_ReadError{Call: c} + c_call := _m.On("ReadError", matchers...) + return &OutputReader_ReadError{Call: c_call} } // ReadError provides a mock function with given fields: ctx diff --git a/go/tasks/pluginmachinery/io/mocks/output_writer.go b/go/tasks/pluginmachinery/io/mocks/output_writer.go index 4fb079d68..e377b9388 100644 --- a/go/tasks/pluginmachinery/io/mocks/output_writer.go +++ b/go/tasks/pluginmachinery/io/mocks/output_writer.go @@ -25,13 +25,13 @@ func (_m OutputWriter_GetCheckpointPrefix) Return(_a0 storage.DataReference) *Ou } func (_m *OutputWriter) OnGetCheckpointPrefix() *OutputWriter_GetCheckpointPrefix { - c := _m.On("GetCheckpointPrefix") - return &OutputWriter_GetCheckpointPrefix{Call: c} + c_call := _m.On("GetCheckpointPrefix") + return &OutputWriter_GetCheckpointPrefix{Call: c_call} } func (_m *OutputWriter) OnGetCheckpointPrefixMatch(matchers ...interface{}) *OutputWriter_GetCheckpointPrefix { - c := _m.On("GetCheckpointPrefix", matchers...) - return &OutputWriter_GetCheckpointPrefix{Call: c} + c_call := _m.On("GetCheckpointPrefix", matchers...) + return &OutputWriter_GetCheckpointPrefix{Call: c_call} } // GetCheckpointPrefix provides a mock function with given fields: @@ -57,13 +57,13 @@ func (_m OutputWriter_GetErrorPath) Return(_a0 storage.DataReference) *OutputWri } func (_m *OutputWriter) OnGetErrorPath() *OutputWriter_GetErrorPath { - c := _m.On("GetErrorPath") - return &OutputWriter_GetErrorPath{Call: c} + c_call := _m.On("GetErrorPath") + return &OutputWriter_GetErrorPath{Call: c_call} } func (_m *OutputWriter) OnGetErrorPathMatch(matchers ...interface{}) *OutputWriter_GetErrorPath { - c := _m.On("GetErrorPath", matchers...) - return &OutputWriter_GetErrorPath{Call: c} + c_call := _m.On("GetErrorPath", matchers...) + return &OutputWriter_GetErrorPath{Call: c_call} } // GetErrorPath provides a mock function with given fields: @@ -89,13 +89,13 @@ func (_m OutputWriter_GetOutputPath) Return(_a0 storage.DataReference) *OutputWr } func (_m *OutputWriter) OnGetOutputPath() *OutputWriter_GetOutputPath { - c := _m.On("GetOutputPath") - return &OutputWriter_GetOutputPath{Call: c} + c_call := _m.On("GetOutputPath") + return &OutputWriter_GetOutputPath{Call: c_call} } func (_m *OutputWriter) OnGetOutputPathMatch(matchers ...interface{}) *OutputWriter_GetOutputPath { - c := _m.On("GetOutputPath", matchers...) - return &OutputWriter_GetOutputPath{Call: c} + c_call := _m.On("GetOutputPath", matchers...) + return &OutputWriter_GetOutputPath{Call: c_call} } // GetOutputPath provides a mock function with given fields: @@ -121,13 +121,13 @@ func (_m OutputWriter_GetOutputPrefixPath) Return(_a0 storage.DataReference) *Ou } func (_m *OutputWriter) OnGetOutputPrefixPath() *OutputWriter_GetOutputPrefixPath { - c := _m.On("GetOutputPrefixPath") - return &OutputWriter_GetOutputPrefixPath{Call: c} + c_call := _m.On("GetOutputPrefixPath") + return &OutputWriter_GetOutputPrefixPath{Call: c_call} } func (_m *OutputWriter) OnGetOutputPrefixPathMatch(matchers ...interface{}) *OutputWriter_GetOutputPrefixPath { - c := _m.On("GetOutputPrefixPath", matchers...) - return &OutputWriter_GetOutputPrefixPath{Call: c} + c_call := _m.On("GetOutputPrefixPath", matchers...) + return &OutputWriter_GetOutputPrefixPath{Call: c_call} } // GetOutputPrefixPath provides a mock function with given fields: @@ -153,13 +153,13 @@ func (_m OutputWriter_GetPreviousCheckpointsPrefix) Return(_a0 storage.DataRefer } func (_m *OutputWriter) OnGetPreviousCheckpointsPrefix() *OutputWriter_GetPreviousCheckpointsPrefix { - c := _m.On("GetPreviousCheckpointsPrefix") - return &OutputWriter_GetPreviousCheckpointsPrefix{Call: c} + c_call := _m.On("GetPreviousCheckpointsPrefix") + return &OutputWriter_GetPreviousCheckpointsPrefix{Call: c_call} } func (_m *OutputWriter) OnGetPreviousCheckpointsPrefixMatch(matchers ...interface{}) *OutputWriter_GetPreviousCheckpointsPrefix { - c := _m.On("GetPreviousCheckpointsPrefix", matchers...) - return &OutputWriter_GetPreviousCheckpointsPrefix{Call: c} + c_call := _m.On("GetPreviousCheckpointsPrefix", matchers...) + return &OutputWriter_GetPreviousCheckpointsPrefix{Call: c_call} } // GetPreviousCheckpointsPrefix provides a mock function with given fields: @@ -185,13 +185,13 @@ func (_m OutputWriter_GetRawOutputPrefix) Return(_a0 storage.DataReference) *Out } func (_m *OutputWriter) OnGetRawOutputPrefix() *OutputWriter_GetRawOutputPrefix { - c := _m.On("GetRawOutputPrefix") - return &OutputWriter_GetRawOutputPrefix{Call: c} + c_call := _m.On("GetRawOutputPrefix") + return &OutputWriter_GetRawOutputPrefix{Call: c_call} } func (_m *OutputWriter) OnGetRawOutputPrefixMatch(matchers ...interface{}) *OutputWriter_GetRawOutputPrefix { - c := _m.On("GetRawOutputPrefix", matchers...) - return &OutputWriter_GetRawOutputPrefix{Call: c} + c_call := _m.On("GetRawOutputPrefix", matchers...) + return &OutputWriter_GetRawOutputPrefix{Call: c_call} } // GetRawOutputPrefix provides a mock function with given fields: @@ -217,13 +217,13 @@ func (_m OutputWriter_Put) Return(_a0 error) *OutputWriter_Put { } func (_m *OutputWriter) OnPut(ctx context.Context, reader io.OutputReader) *OutputWriter_Put { - c := _m.On("Put", ctx, reader) - return &OutputWriter_Put{Call: c} + c_call := _m.On("Put", ctx, reader) + return &OutputWriter_Put{Call: c_call} } func (_m *OutputWriter) OnPutMatch(matchers ...interface{}) *OutputWriter_Put { - c := _m.On("Put", matchers...) - return &OutputWriter_Put{Call: c} + c_call := _m.On("Put", matchers...) + return &OutputWriter_Put{Call: c_call} } // Put provides a mock function with given fields: ctx, reader diff --git a/go/tasks/pluginmachinery/io/mocks/raw_output_paths.go b/go/tasks/pluginmachinery/io/mocks/raw_output_paths.go index 82d12dccc..b444e2a28 100644 --- a/go/tasks/pluginmachinery/io/mocks/raw_output_paths.go +++ b/go/tasks/pluginmachinery/io/mocks/raw_output_paths.go @@ -21,13 +21,13 @@ func (_m RawOutputPaths_GetRawOutputPrefix) Return(_a0 storage.DataReference) *R } func (_m *RawOutputPaths) OnGetRawOutputPrefix() *RawOutputPaths_GetRawOutputPrefix { - c := _m.On("GetRawOutputPrefix") - return &RawOutputPaths_GetRawOutputPrefix{Call: c} + c_call := _m.On("GetRawOutputPrefix") + return &RawOutputPaths_GetRawOutputPrefix{Call: c_call} } func (_m *RawOutputPaths) OnGetRawOutputPrefixMatch(matchers ...interface{}) *RawOutputPaths_GetRawOutputPrefix { - c := _m.On("GetRawOutputPrefix", matchers...) - return &RawOutputPaths_GetRawOutputPrefix{Call: c} + c_call := _m.On("GetRawOutputPrefix", matchers...) + return &RawOutputPaths_GetRawOutputPrefix{Call: c_call} } // GetRawOutputPrefix provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/k8s/mocks/plugin.go b/go/tasks/pluginmachinery/k8s/mocks/plugin.go index 085945827..16849663d 100644 --- a/go/tasks/pluginmachinery/k8s/mocks/plugin.go +++ b/go/tasks/pluginmachinery/k8s/mocks/plugin.go @@ -28,13 +28,13 @@ func (_m Plugin_BuildIdentityResource) Return(_a0 client.Object, _a1 error) *Plu } func (_m *Plugin) OnBuildIdentityResource(ctx context.Context, taskCtx core.TaskExecutionMetadata) *Plugin_BuildIdentityResource { - c := _m.On("BuildIdentityResource", ctx, taskCtx) - return &Plugin_BuildIdentityResource{Call: c} + c_call := _m.On("BuildIdentityResource", ctx, taskCtx) + return &Plugin_BuildIdentityResource{Call: c_call} } func (_m *Plugin) OnBuildIdentityResourceMatch(matchers ...interface{}) *Plugin_BuildIdentityResource { - c := _m.On("BuildIdentityResource", matchers...) - return &Plugin_BuildIdentityResource{Call: c} + c_call := _m.On("BuildIdentityResource", matchers...) + return &Plugin_BuildIdentityResource{Call: c_call} } // BuildIdentityResource provides a mock function with given fields: ctx, taskCtx @@ -69,13 +69,13 @@ func (_m Plugin_BuildResource) Return(_a0 client.Object, _a1 error) *Plugin_Buil } func (_m *Plugin) OnBuildResource(ctx context.Context, taskCtx core.TaskExecutionContext) *Plugin_BuildResource { - c := _m.On("BuildResource", ctx, taskCtx) - return &Plugin_BuildResource{Call: c} + c_call := _m.On("BuildResource", ctx, taskCtx) + return &Plugin_BuildResource{Call: c_call} } func (_m *Plugin) OnBuildResourceMatch(matchers ...interface{}) *Plugin_BuildResource { - c := _m.On("BuildResource", matchers...) - return &Plugin_BuildResource{Call: c} + c_call := _m.On("BuildResource", matchers...) + return &Plugin_BuildResource{Call: c_call} } // BuildResource provides a mock function with given fields: ctx, taskCtx @@ -110,13 +110,13 @@ func (_m Plugin_GetProperties) Return(_a0 k8s.PluginProperties) *Plugin_GetPrope } func (_m *Plugin) OnGetProperties() *Plugin_GetProperties { - c := _m.On("GetProperties") - return &Plugin_GetProperties{Call: c} + c_call := _m.On("GetProperties") + return &Plugin_GetProperties{Call: c_call} } func (_m *Plugin) OnGetPropertiesMatch(matchers ...interface{}) *Plugin_GetProperties { - c := _m.On("GetProperties", matchers...) - return &Plugin_GetProperties{Call: c} + c_call := _m.On("GetProperties", matchers...) + return &Plugin_GetProperties{Call: c_call} } // GetProperties provides a mock function with given fields: @@ -142,13 +142,13 @@ func (_m Plugin_GetTaskPhase) Return(_a0 core.PhaseInfo, _a1 error) *Plugin_GetT } func (_m *Plugin) OnGetTaskPhase(ctx context.Context, pluginContext k8s.PluginContext, resource client.Object) *Plugin_GetTaskPhase { - c := _m.On("GetTaskPhase", ctx, pluginContext, resource) - return &Plugin_GetTaskPhase{Call: c} + c_call := _m.On("GetTaskPhase", ctx, pluginContext, resource) + return &Plugin_GetTaskPhase{Call: c_call} } func (_m *Plugin) OnGetTaskPhaseMatch(matchers ...interface{}) *Plugin_GetTaskPhase { - c := _m.On("GetTaskPhase", matchers...) - return &Plugin_GetTaskPhase{Call: c} + c_call := _m.On("GetTaskPhase", matchers...) + return &Plugin_GetTaskPhase{Call: c_call} } // GetTaskPhase provides a mock function with given fields: ctx, pluginContext, resource diff --git a/go/tasks/pluginmachinery/k8s/mocks/plugin_abort_override.go b/go/tasks/pluginmachinery/k8s/mocks/plugin_abort_override.go index 41463d103..c2223edcb 100644 --- a/go/tasks/pluginmachinery/k8s/mocks/plugin_abort_override.go +++ b/go/tasks/pluginmachinery/k8s/mocks/plugin_abort_override.go @@ -28,13 +28,13 @@ func (_m PluginAbortOverride_OnAbort) Return(behavior k8s.AbortBehavior, err err } func (_m *PluginAbortOverride) OnOnAbort(ctx context.Context, tCtx core.TaskExecutionContext, resource client.Object) *PluginAbortOverride_OnAbort { - c := _m.On("OnAbort", ctx, tCtx, resource) - return &PluginAbortOverride_OnAbort{Call: c} + c_call := _m.On("OnAbort", ctx, tCtx, resource) + return &PluginAbortOverride_OnAbort{Call: c_call} } func (_m *PluginAbortOverride) OnOnAbortMatch(matchers ...interface{}) *PluginAbortOverride_OnAbort { - c := _m.On("OnAbort", matchers...) - return &PluginAbortOverride_OnAbort{Call: c} + c_call := _m.On("OnAbort", matchers...) + return &PluginAbortOverride_OnAbort{Call: c_call} } // OnAbort provides a mock function with given fields: ctx, tCtx, resource diff --git a/go/tasks/pluginmachinery/k8s/mocks/plugin_context.go b/go/tasks/pluginmachinery/k8s/mocks/plugin_context.go index bdf3cbcae..10e969a03 100644 --- a/go/tasks/pluginmachinery/k8s/mocks/plugin_context.go +++ b/go/tasks/pluginmachinery/k8s/mocks/plugin_context.go @@ -25,13 +25,13 @@ func (_m PluginContext_DataStore) Return(_a0 *storage.DataStore) *PluginContext_ } func (_m *PluginContext) OnDataStore() *PluginContext_DataStore { - c := _m.On("DataStore") - return &PluginContext_DataStore{Call: c} + c_call := _m.On("DataStore") + return &PluginContext_DataStore{Call: c_call} } func (_m *PluginContext) OnDataStoreMatch(matchers ...interface{}) *PluginContext_DataStore { - c := _m.On("DataStore", matchers...) - return &PluginContext_DataStore{Call: c} + c_call := _m.On("DataStore", matchers...) + return &PluginContext_DataStore{Call: c_call} } // DataStore provides a mock function with given fields: @@ -59,13 +59,13 @@ func (_m PluginContext_InputReader) Return(_a0 io.InputReader) *PluginContext_In } func (_m *PluginContext) OnInputReader() *PluginContext_InputReader { - c := _m.On("InputReader") - return &PluginContext_InputReader{Call: c} + c_call := _m.On("InputReader") + return &PluginContext_InputReader{Call: c_call} } func (_m *PluginContext) OnInputReaderMatch(matchers ...interface{}) *PluginContext_InputReader { - c := _m.On("InputReader", matchers...) - return &PluginContext_InputReader{Call: c} + c_call := _m.On("InputReader", matchers...) + return &PluginContext_InputReader{Call: c_call} } // InputReader provides a mock function with given fields: @@ -93,13 +93,13 @@ func (_m PluginContext_MaxDatasetSizeBytes) Return(_a0 int64) *PluginContext_Max } func (_m *PluginContext) OnMaxDatasetSizeBytes() *PluginContext_MaxDatasetSizeBytes { - c := _m.On("MaxDatasetSizeBytes") - return &PluginContext_MaxDatasetSizeBytes{Call: c} + c_call := _m.On("MaxDatasetSizeBytes") + return &PluginContext_MaxDatasetSizeBytes{Call: c_call} } func (_m *PluginContext) OnMaxDatasetSizeBytesMatch(matchers ...interface{}) *PluginContext_MaxDatasetSizeBytes { - c := _m.On("MaxDatasetSizeBytes", matchers...) - return &PluginContext_MaxDatasetSizeBytes{Call: c} + c_call := _m.On("MaxDatasetSizeBytes", matchers...) + return &PluginContext_MaxDatasetSizeBytes{Call: c_call} } // MaxDatasetSizeBytes provides a mock function with given fields: @@ -125,13 +125,13 @@ func (_m PluginContext_OutputWriter) Return(_a0 io.OutputWriter) *PluginContext_ } func (_m *PluginContext) OnOutputWriter() *PluginContext_OutputWriter { - c := _m.On("OutputWriter") - return &PluginContext_OutputWriter{Call: c} + c_call := _m.On("OutputWriter") + return &PluginContext_OutputWriter{Call: c_call} } func (_m *PluginContext) OnOutputWriterMatch(matchers ...interface{}) *PluginContext_OutputWriter { - c := _m.On("OutputWriter", matchers...) - return &PluginContext_OutputWriter{Call: c} + c_call := _m.On("OutputWriter", matchers...) + return &PluginContext_OutputWriter{Call: c_call} } // OutputWriter provides a mock function with given fields: @@ -159,13 +159,13 @@ func (_m PluginContext_TaskExecutionMetadata) Return(_a0 core.TaskExecutionMetad } func (_m *PluginContext) OnTaskExecutionMetadata() *PluginContext_TaskExecutionMetadata { - c := _m.On("TaskExecutionMetadata") - return &PluginContext_TaskExecutionMetadata{Call: c} + c_call := _m.On("TaskExecutionMetadata") + return &PluginContext_TaskExecutionMetadata{Call: c_call} } func (_m *PluginContext) OnTaskExecutionMetadataMatch(matchers ...interface{}) *PluginContext_TaskExecutionMetadata { - c := _m.On("TaskExecutionMetadata", matchers...) - return &PluginContext_TaskExecutionMetadata{Call: c} + c_call := _m.On("TaskExecutionMetadata", matchers...) + return &PluginContext_TaskExecutionMetadata{Call: c_call} } // TaskExecutionMetadata provides a mock function with given fields: @@ -193,13 +193,13 @@ func (_m PluginContext_TaskReader) Return(_a0 core.TaskReader) *PluginContext_Ta } func (_m *PluginContext) OnTaskReader() *PluginContext_TaskReader { - c := _m.On("TaskReader") - return &PluginContext_TaskReader{Call: c} + c_call := _m.On("TaskReader") + return &PluginContext_TaskReader{Call: c_call} } func (_m *PluginContext) OnTaskReaderMatch(matchers ...interface{}) *PluginContext_TaskReader { - c := _m.On("TaskReader", matchers...) - return &PluginContext_TaskReader{Call: c} + c_call := _m.On("TaskReader", matchers...) + return &PluginContext_TaskReader{Call: c_call} } // TaskReader provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/webapi/mocks/async_plugin.go b/go/tasks/pluginmachinery/webapi/mocks/async_plugin.go index 6be8f798f..50376b7d0 100644 --- a/go/tasks/pluginmachinery/webapi/mocks/async_plugin.go +++ b/go/tasks/pluginmachinery/webapi/mocks/async_plugin.go @@ -25,13 +25,13 @@ func (_m AsyncPlugin_Create) Return(resourceMeta interface{}, optionalResource i } func (_m *AsyncPlugin) OnCreate(ctx context.Context, tCtx webapi.TaskExecutionContextReader) *AsyncPlugin_Create { - c := _m.On("Create", ctx, tCtx) - return &AsyncPlugin_Create{Call: c} + c_call := _m.On("Create", ctx, tCtx) + return &AsyncPlugin_Create{Call: c_call} } func (_m *AsyncPlugin) OnCreateMatch(matchers ...interface{}) *AsyncPlugin_Create { - c := _m.On("Create", matchers...) - return &AsyncPlugin_Create{Call: c} + c_call := _m.On("Create", matchers...) + return &AsyncPlugin_Create{Call: c_call} } // Create provides a mock function with given fields: ctx, tCtx @@ -75,13 +75,13 @@ func (_m AsyncPlugin_Delete) Return(_a0 error) *AsyncPlugin_Delete { } func (_m *AsyncPlugin) OnDelete(ctx context.Context, tCtx webapi.DeleteContext) *AsyncPlugin_Delete { - c := _m.On("Delete", ctx, tCtx) - return &AsyncPlugin_Delete{Call: c} + c_call := _m.On("Delete", ctx, tCtx) + return &AsyncPlugin_Delete{Call: c_call} } func (_m *AsyncPlugin) OnDeleteMatch(matchers ...interface{}) *AsyncPlugin_Delete { - c := _m.On("Delete", matchers...) - return &AsyncPlugin_Delete{Call: c} + c_call := _m.On("Delete", matchers...) + return &AsyncPlugin_Delete{Call: c_call} } // Delete provides a mock function with given fields: ctx, tCtx @@ -107,13 +107,13 @@ func (_m AsyncPlugin_Get) Return(latest interface{}, err error) *AsyncPlugin_Get } func (_m *AsyncPlugin) OnGet(ctx context.Context, tCtx webapi.GetContext) *AsyncPlugin_Get { - c := _m.On("Get", ctx, tCtx) - return &AsyncPlugin_Get{Call: c} + c_call := _m.On("Get", ctx, tCtx) + return &AsyncPlugin_Get{Call: c_call} } func (_m *AsyncPlugin) OnGetMatch(matchers ...interface{}) *AsyncPlugin_Get { - c := _m.On("Get", matchers...) - return &AsyncPlugin_Get{Call: c} + c_call := _m.On("Get", matchers...) + return &AsyncPlugin_Get{Call: c_call} } // Get provides a mock function with given fields: ctx, tCtx @@ -148,13 +148,13 @@ func (_m AsyncPlugin_GetConfig) Return(_a0 webapi.PluginConfig) *AsyncPlugin_Get } func (_m *AsyncPlugin) OnGetConfig() *AsyncPlugin_GetConfig { - c := _m.On("GetConfig") - return &AsyncPlugin_GetConfig{Call: c} + c_call := _m.On("GetConfig") + return &AsyncPlugin_GetConfig{Call: c_call} } func (_m *AsyncPlugin) OnGetConfigMatch(matchers ...interface{}) *AsyncPlugin_GetConfig { - c := _m.On("GetConfig", matchers...) - return &AsyncPlugin_GetConfig{Call: c} + c_call := _m.On("GetConfig", matchers...) + return &AsyncPlugin_GetConfig{Call: c_call} } // GetConfig provides a mock function with given fields: @@ -180,13 +180,13 @@ func (_m AsyncPlugin_ResourceRequirements) Return(namespace core.ResourceNamespa } func (_m *AsyncPlugin) OnResourceRequirements(ctx context.Context, tCtx webapi.TaskExecutionContextReader) *AsyncPlugin_ResourceRequirements { - c := _m.On("ResourceRequirements", ctx, tCtx) - return &AsyncPlugin_ResourceRequirements{Call: c} + c_call := _m.On("ResourceRequirements", ctx, tCtx) + return &AsyncPlugin_ResourceRequirements{Call: c_call} } func (_m *AsyncPlugin) OnResourceRequirementsMatch(matchers ...interface{}) *AsyncPlugin_ResourceRequirements { - c := _m.On("ResourceRequirements", matchers...) - return &AsyncPlugin_ResourceRequirements{Call: c} + c_call := _m.On("ResourceRequirements", matchers...) + return &AsyncPlugin_ResourceRequirements{Call: c_call} } // ResourceRequirements provides a mock function with given fields: ctx, tCtx @@ -226,13 +226,13 @@ func (_m AsyncPlugin_Status) Return(phase core.PhaseInfo, err error) *AsyncPlugi } func (_m *AsyncPlugin) OnStatus(ctx context.Context, tCtx webapi.StatusContext) *AsyncPlugin_Status { - c := _m.On("Status", ctx, tCtx) - return &AsyncPlugin_Status{Call: c} + c_call := _m.On("Status", ctx, tCtx) + return &AsyncPlugin_Status{Call: c_call} } func (_m *AsyncPlugin) OnStatusMatch(matchers ...interface{}) *AsyncPlugin_Status { - c := _m.On("Status", matchers...) - return &AsyncPlugin_Status{Call: c} + c_call := _m.On("Status", matchers...) + return &AsyncPlugin_Status{Call: c_call} } // Status provides a mock function with given fields: ctx, tCtx diff --git a/go/tasks/pluginmachinery/webapi/mocks/delete_context.go b/go/tasks/pluginmachinery/webapi/mocks/delete_context.go index 527a18e2d..c6be7e5c6 100644 --- a/go/tasks/pluginmachinery/webapi/mocks/delete_context.go +++ b/go/tasks/pluginmachinery/webapi/mocks/delete_context.go @@ -18,13 +18,13 @@ func (_m DeleteContext_Reason) Return(_a0 string) *DeleteContext_Reason { } func (_m *DeleteContext) OnReason() *DeleteContext_Reason { - c := _m.On("Reason") - return &DeleteContext_Reason{Call: c} + c_call := _m.On("Reason") + return &DeleteContext_Reason{Call: c_call} } func (_m *DeleteContext) OnReasonMatch(matchers ...interface{}) *DeleteContext_Reason { - c := _m.On("Reason", matchers...) - return &DeleteContext_Reason{Call: c} + c_call := _m.On("Reason", matchers...) + return &DeleteContext_Reason{Call: c_call} } // Reason provides a mock function with given fields: @@ -50,13 +50,13 @@ func (_m DeleteContext_ResourceMeta) Return(_a0 interface{}) *DeleteContext_Reso } func (_m *DeleteContext) OnResourceMeta() *DeleteContext_ResourceMeta { - c := _m.On("ResourceMeta") - return &DeleteContext_ResourceMeta{Call: c} + c_call := _m.On("ResourceMeta") + return &DeleteContext_ResourceMeta{Call: c_call} } func (_m *DeleteContext) OnResourceMetaMatch(matchers ...interface{}) *DeleteContext_ResourceMeta { - c := _m.On("ResourceMeta", matchers...) - return &DeleteContext_ResourceMeta{Call: c} + c_call := _m.On("ResourceMeta", matchers...) + return &DeleteContext_ResourceMeta{Call: c_call} } // ResourceMeta provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/webapi/mocks/get_context.go b/go/tasks/pluginmachinery/webapi/mocks/get_context.go index 4c403a1a4..c0dcbcd19 100644 --- a/go/tasks/pluginmachinery/webapi/mocks/get_context.go +++ b/go/tasks/pluginmachinery/webapi/mocks/get_context.go @@ -18,13 +18,13 @@ func (_m GetContext_ResourceMeta) Return(_a0 interface{}) *GetContext_ResourceMe } func (_m *GetContext) OnResourceMeta() *GetContext_ResourceMeta { - c := _m.On("ResourceMeta") - return &GetContext_ResourceMeta{Call: c} + c_call := _m.On("ResourceMeta") + return &GetContext_ResourceMeta{Call: c_call} } func (_m *GetContext) OnResourceMetaMatch(matchers ...interface{}) *GetContext_ResourceMeta { - c := _m.On("ResourceMeta", matchers...) - return &GetContext_ResourceMeta{Call: c} + c_call := _m.On("ResourceMeta", matchers...) + return &GetContext_ResourceMeta{Call: c_call} } // ResourceMeta provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/webapi/mocks/plugin_setup_context.go b/go/tasks/pluginmachinery/webapi/mocks/plugin_setup_context.go index b8824370f..06013e55a 100644 --- a/go/tasks/pluginmachinery/webapi/mocks/plugin_setup_context.go +++ b/go/tasks/pluginmachinery/webapi/mocks/plugin_setup_context.go @@ -21,13 +21,13 @@ func (_m PluginSetupContext_MetricsScope) Return(_a0 promutils.Scope) *PluginSet } func (_m *PluginSetupContext) OnMetricsScope() *PluginSetupContext_MetricsScope { - c := _m.On("MetricsScope") - return &PluginSetupContext_MetricsScope{Call: c} + c_call := _m.On("MetricsScope") + return &PluginSetupContext_MetricsScope{Call: c_call} } func (_m *PluginSetupContext) OnMetricsScopeMatch(matchers ...interface{}) *PluginSetupContext_MetricsScope { - c := _m.On("MetricsScope", matchers...) - return &PluginSetupContext_MetricsScope{Call: c} + c_call := _m.On("MetricsScope", matchers...) + return &PluginSetupContext_MetricsScope{Call: c_call} } // MetricsScope provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/webapi/mocks/status_context.go b/go/tasks/pluginmachinery/webapi/mocks/status_context.go index e2bf48943..5e3510a0b 100644 --- a/go/tasks/pluginmachinery/webapi/mocks/status_context.go +++ b/go/tasks/pluginmachinery/webapi/mocks/status_context.go @@ -25,13 +25,13 @@ func (_m StatusContext_DataStore) Return(_a0 *storage.DataStore) *StatusContext_ } func (_m *StatusContext) OnDataStore() *StatusContext_DataStore { - c := _m.On("DataStore") - return &StatusContext_DataStore{Call: c} + c_call := _m.On("DataStore") + return &StatusContext_DataStore{Call: c_call} } func (_m *StatusContext) OnDataStoreMatch(matchers ...interface{}) *StatusContext_DataStore { - c := _m.On("DataStore", matchers...) - return &StatusContext_DataStore{Call: c} + c_call := _m.On("DataStore", matchers...) + return &StatusContext_DataStore{Call: c_call} } // DataStore provides a mock function with given fields: @@ -59,13 +59,13 @@ func (_m StatusContext_InputReader) Return(_a0 io.InputReader) *StatusContext_In } func (_m *StatusContext) OnInputReader() *StatusContext_InputReader { - c := _m.On("InputReader") - return &StatusContext_InputReader{Call: c} + c_call := _m.On("InputReader") + return &StatusContext_InputReader{Call: c_call} } func (_m *StatusContext) OnInputReaderMatch(matchers ...interface{}) *StatusContext_InputReader { - c := _m.On("InputReader", matchers...) - return &StatusContext_InputReader{Call: c} + c_call := _m.On("InputReader", matchers...) + return &StatusContext_InputReader{Call: c_call} } // InputReader provides a mock function with given fields: @@ -93,13 +93,13 @@ func (_m StatusContext_MaxDatasetSizeBytes) Return(_a0 int64) *StatusContext_Max } func (_m *StatusContext) OnMaxDatasetSizeBytes() *StatusContext_MaxDatasetSizeBytes { - c := _m.On("MaxDatasetSizeBytes") - return &StatusContext_MaxDatasetSizeBytes{Call: c} + c_call := _m.On("MaxDatasetSizeBytes") + return &StatusContext_MaxDatasetSizeBytes{Call: c_call} } func (_m *StatusContext) OnMaxDatasetSizeBytesMatch(matchers ...interface{}) *StatusContext_MaxDatasetSizeBytes { - c := _m.On("MaxDatasetSizeBytes", matchers...) - return &StatusContext_MaxDatasetSizeBytes{Call: c} + c_call := _m.On("MaxDatasetSizeBytes", matchers...) + return &StatusContext_MaxDatasetSizeBytes{Call: c_call} } // MaxDatasetSizeBytes provides a mock function with given fields: @@ -125,13 +125,13 @@ func (_m StatusContext_OutputWriter) Return(_a0 io.OutputWriter) *StatusContext_ } func (_m *StatusContext) OnOutputWriter() *StatusContext_OutputWriter { - c := _m.On("OutputWriter") - return &StatusContext_OutputWriter{Call: c} + c_call := _m.On("OutputWriter") + return &StatusContext_OutputWriter{Call: c_call} } func (_m *StatusContext) OnOutputWriterMatch(matchers ...interface{}) *StatusContext_OutputWriter { - c := _m.On("OutputWriter", matchers...) - return &StatusContext_OutputWriter{Call: c} + c_call := _m.On("OutputWriter", matchers...) + return &StatusContext_OutputWriter{Call: c_call} } // OutputWriter provides a mock function with given fields: @@ -159,13 +159,13 @@ func (_m StatusContext_Resource) Return(_a0 interface{}) *StatusContext_Resource } func (_m *StatusContext) OnResource() *StatusContext_Resource { - c := _m.On("Resource") - return &StatusContext_Resource{Call: c} + c_call := _m.On("Resource") + return &StatusContext_Resource{Call: c_call} } func (_m *StatusContext) OnResourceMatch(matchers ...interface{}) *StatusContext_Resource { - c := _m.On("Resource", matchers...) - return &StatusContext_Resource{Call: c} + c_call := _m.On("Resource", matchers...) + return &StatusContext_Resource{Call: c_call} } // Resource provides a mock function with given fields: @@ -193,13 +193,13 @@ func (_m StatusContext_ResourceMeta) Return(_a0 interface{}) *StatusContext_Reso } func (_m *StatusContext) OnResourceMeta() *StatusContext_ResourceMeta { - c := _m.On("ResourceMeta") - return &StatusContext_ResourceMeta{Call: c} + c_call := _m.On("ResourceMeta") + return &StatusContext_ResourceMeta{Call: c_call} } func (_m *StatusContext) OnResourceMetaMatch(matchers ...interface{}) *StatusContext_ResourceMeta { - c := _m.On("ResourceMeta", matchers...) - return &StatusContext_ResourceMeta{Call: c} + c_call := _m.On("ResourceMeta", matchers...) + return &StatusContext_ResourceMeta{Call: c_call} } // ResourceMeta provides a mock function with given fields: @@ -227,13 +227,13 @@ func (_m StatusContext_SecretManager) Return(_a0 core.SecretManager) *StatusCont } func (_m *StatusContext) OnSecretManager() *StatusContext_SecretManager { - c := _m.On("SecretManager") - return &StatusContext_SecretManager{Call: c} + c_call := _m.On("SecretManager") + return &StatusContext_SecretManager{Call: c_call} } func (_m *StatusContext) OnSecretManagerMatch(matchers ...interface{}) *StatusContext_SecretManager { - c := _m.On("SecretManager", matchers...) - return &StatusContext_SecretManager{Call: c} + c_call := _m.On("SecretManager", matchers...) + return &StatusContext_SecretManager{Call: c_call} } // SecretManager provides a mock function with given fields: @@ -261,13 +261,13 @@ func (_m StatusContext_TaskExecutionMetadata) Return(_a0 core.TaskExecutionMetad } func (_m *StatusContext) OnTaskExecutionMetadata() *StatusContext_TaskExecutionMetadata { - c := _m.On("TaskExecutionMetadata") - return &StatusContext_TaskExecutionMetadata{Call: c} + c_call := _m.On("TaskExecutionMetadata") + return &StatusContext_TaskExecutionMetadata{Call: c_call} } func (_m *StatusContext) OnTaskExecutionMetadataMatch(matchers ...interface{}) *StatusContext_TaskExecutionMetadata { - c := _m.On("TaskExecutionMetadata", matchers...) - return &StatusContext_TaskExecutionMetadata{Call: c} + c_call := _m.On("TaskExecutionMetadata", matchers...) + return &StatusContext_TaskExecutionMetadata{Call: c_call} } // TaskExecutionMetadata provides a mock function with given fields: @@ -295,13 +295,13 @@ func (_m StatusContext_TaskReader) Return(_a0 core.TaskReader) *StatusContext_Ta } func (_m *StatusContext) OnTaskReader() *StatusContext_TaskReader { - c := _m.On("TaskReader") - return &StatusContext_TaskReader{Call: c} + c_call := _m.On("TaskReader") + return &StatusContext_TaskReader{Call: c_call} } func (_m *StatusContext) OnTaskReaderMatch(matchers ...interface{}) *StatusContext_TaskReader { - c := _m.On("TaskReader", matchers...) - return &StatusContext_TaskReader{Call: c} + c_call := _m.On("TaskReader", matchers...) + return &StatusContext_TaskReader{Call: c_call} } // TaskReader provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/webapi/mocks/sync_plugin.go b/go/tasks/pluginmachinery/webapi/mocks/sync_plugin.go index f991f3f71..eaa35e42c 100644 --- a/go/tasks/pluginmachinery/webapi/mocks/sync_plugin.go +++ b/go/tasks/pluginmachinery/webapi/mocks/sync_plugin.go @@ -25,13 +25,13 @@ func (_m SyncPlugin_Do) Return(phase core.PhaseInfo, err error) *SyncPlugin_Do { } func (_m *SyncPlugin) OnDo(ctx context.Context, tCtx webapi.TaskExecutionContext) *SyncPlugin_Do { - c := _m.On("Do", ctx, tCtx) - return &SyncPlugin_Do{Call: c} + c_call := _m.On("Do", ctx, tCtx) + return &SyncPlugin_Do{Call: c_call} } func (_m *SyncPlugin) OnDoMatch(matchers ...interface{}) *SyncPlugin_Do { - c := _m.On("Do", matchers...) - return &SyncPlugin_Do{Call: c} + c_call := _m.On("Do", matchers...) + return &SyncPlugin_Do{Call: c_call} } // Do provides a mock function with given fields: ctx, tCtx @@ -64,13 +64,13 @@ func (_m SyncPlugin_GetConfig) Return(_a0 webapi.PluginConfig) *SyncPlugin_GetCo } func (_m *SyncPlugin) OnGetConfig() *SyncPlugin_GetConfig { - c := _m.On("GetConfig") - return &SyncPlugin_GetConfig{Call: c} + c_call := _m.On("GetConfig") + return &SyncPlugin_GetConfig{Call: c_call} } func (_m *SyncPlugin) OnGetConfigMatch(matchers ...interface{}) *SyncPlugin_GetConfig { - c := _m.On("GetConfig", matchers...) - return &SyncPlugin_GetConfig{Call: c} + c_call := _m.On("GetConfig", matchers...) + return &SyncPlugin_GetConfig{Call: c_call} } // GetConfig provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/webapi/mocks/task_execution_context.go b/go/tasks/pluginmachinery/webapi/mocks/task_execution_context.go index 715641ef5..62714cb2d 100644 --- a/go/tasks/pluginmachinery/webapi/mocks/task_execution_context.go +++ b/go/tasks/pluginmachinery/webapi/mocks/task_execution_context.go @@ -25,13 +25,13 @@ func (_m TaskExecutionContext_DataStore) Return(_a0 *storage.DataStore) *TaskExe } func (_m *TaskExecutionContext) OnDataStore() *TaskExecutionContext_DataStore { - c := _m.On("DataStore") - return &TaskExecutionContext_DataStore{Call: c} + c_call := _m.On("DataStore") + return &TaskExecutionContext_DataStore{Call: c_call} } func (_m *TaskExecutionContext) OnDataStoreMatch(matchers ...interface{}) *TaskExecutionContext_DataStore { - c := _m.On("DataStore", matchers...) - return &TaskExecutionContext_DataStore{Call: c} + c_call := _m.On("DataStore", matchers...) + return &TaskExecutionContext_DataStore{Call: c_call} } // DataStore provides a mock function with given fields: @@ -59,13 +59,13 @@ func (_m TaskExecutionContext_InputReader) Return(_a0 io.InputReader) *TaskExecu } func (_m *TaskExecutionContext) OnInputReader() *TaskExecutionContext_InputReader { - c := _m.On("InputReader") - return &TaskExecutionContext_InputReader{Call: c} + c_call := _m.On("InputReader") + return &TaskExecutionContext_InputReader{Call: c_call} } func (_m *TaskExecutionContext) OnInputReaderMatch(matchers ...interface{}) *TaskExecutionContext_InputReader { - c := _m.On("InputReader", matchers...) - return &TaskExecutionContext_InputReader{Call: c} + c_call := _m.On("InputReader", matchers...) + return &TaskExecutionContext_InputReader{Call: c_call} } // InputReader provides a mock function with given fields: @@ -93,13 +93,13 @@ func (_m TaskExecutionContext_MaxDatasetSizeBytes) Return(_a0 int64) *TaskExecut } func (_m *TaskExecutionContext) OnMaxDatasetSizeBytes() *TaskExecutionContext_MaxDatasetSizeBytes { - c := _m.On("MaxDatasetSizeBytes") - return &TaskExecutionContext_MaxDatasetSizeBytes{Call: c} + c_call := _m.On("MaxDatasetSizeBytes") + return &TaskExecutionContext_MaxDatasetSizeBytes{Call: c_call} } func (_m *TaskExecutionContext) OnMaxDatasetSizeBytesMatch(matchers ...interface{}) *TaskExecutionContext_MaxDatasetSizeBytes { - c := _m.On("MaxDatasetSizeBytes", matchers...) - return &TaskExecutionContext_MaxDatasetSizeBytes{Call: c} + c_call := _m.On("MaxDatasetSizeBytes", matchers...) + return &TaskExecutionContext_MaxDatasetSizeBytes{Call: c_call} } // MaxDatasetSizeBytes provides a mock function with given fields: @@ -125,13 +125,13 @@ func (_m TaskExecutionContext_OutputWriter) Return(_a0 io.OutputWriter) *TaskExe } func (_m *TaskExecutionContext) OnOutputWriter() *TaskExecutionContext_OutputWriter { - c := _m.On("OutputWriter") - return &TaskExecutionContext_OutputWriter{Call: c} + c_call := _m.On("OutputWriter") + return &TaskExecutionContext_OutputWriter{Call: c_call} } func (_m *TaskExecutionContext) OnOutputWriterMatch(matchers ...interface{}) *TaskExecutionContext_OutputWriter { - c := _m.On("OutputWriter", matchers...) - return &TaskExecutionContext_OutputWriter{Call: c} + c_call := _m.On("OutputWriter", matchers...) + return &TaskExecutionContext_OutputWriter{Call: c_call} } // OutputWriter provides a mock function with given fields: @@ -159,13 +159,13 @@ func (_m TaskExecutionContext_SecretManager) Return(_a0 core.SecretManager) *Tas } func (_m *TaskExecutionContext) OnSecretManager() *TaskExecutionContext_SecretManager { - c := _m.On("SecretManager") - return &TaskExecutionContext_SecretManager{Call: c} + c_call := _m.On("SecretManager") + return &TaskExecutionContext_SecretManager{Call: c_call} } func (_m *TaskExecutionContext) OnSecretManagerMatch(matchers ...interface{}) *TaskExecutionContext_SecretManager { - c := _m.On("SecretManager", matchers...) - return &TaskExecutionContext_SecretManager{Call: c} + c_call := _m.On("SecretManager", matchers...) + return &TaskExecutionContext_SecretManager{Call: c_call} } // SecretManager provides a mock function with given fields: @@ -193,13 +193,13 @@ func (_m TaskExecutionContext_TaskExecutionMetadata) Return(_a0 core.TaskExecuti } func (_m *TaskExecutionContext) OnTaskExecutionMetadata() *TaskExecutionContext_TaskExecutionMetadata { - c := _m.On("TaskExecutionMetadata") - return &TaskExecutionContext_TaskExecutionMetadata{Call: c} + c_call := _m.On("TaskExecutionMetadata") + return &TaskExecutionContext_TaskExecutionMetadata{Call: c_call} } func (_m *TaskExecutionContext) OnTaskExecutionMetadataMatch(matchers ...interface{}) *TaskExecutionContext_TaskExecutionMetadata { - c := _m.On("TaskExecutionMetadata", matchers...) - return &TaskExecutionContext_TaskExecutionMetadata{Call: c} + c_call := _m.On("TaskExecutionMetadata", matchers...) + return &TaskExecutionContext_TaskExecutionMetadata{Call: c_call} } // TaskExecutionMetadata provides a mock function with given fields: @@ -227,13 +227,13 @@ func (_m TaskExecutionContext_TaskReader) Return(_a0 core.TaskReader) *TaskExecu } func (_m *TaskExecutionContext) OnTaskReader() *TaskExecutionContext_TaskReader { - c := _m.On("TaskReader") - return &TaskExecutionContext_TaskReader{Call: c} + c_call := _m.On("TaskReader") + return &TaskExecutionContext_TaskReader{Call: c_call} } func (_m *TaskExecutionContext) OnTaskReaderMatch(matchers ...interface{}) *TaskExecutionContext_TaskReader { - c := _m.On("TaskReader", matchers...) - return &TaskExecutionContext_TaskReader{Call: c} + c_call := _m.On("TaskReader", matchers...) + return &TaskExecutionContext_TaskReader{Call: c_call} } // TaskReader provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/webapi/mocks/task_execution_context_reader.go b/go/tasks/pluginmachinery/webapi/mocks/task_execution_context_reader.go index 8a8bc7b55..72c1bdc36 100644 --- a/go/tasks/pluginmachinery/webapi/mocks/task_execution_context_reader.go +++ b/go/tasks/pluginmachinery/webapi/mocks/task_execution_context_reader.go @@ -23,13 +23,13 @@ func (_m TaskExecutionContextReader_InputReader) Return(_a0 io.InputReader) *Tas } func (_m *TaskExecutionContextReader) OnInputReader() *TaskExecutionContextReader_InputReader { - c := _m.On("InputReader") - return &TaskExecutionContextReader_InputReader{Call: c} + c_call := _m.On("InputReader") + return &TaskExecutionContextReader_InputReader{Call: c_call} } func (_m *TaskExecutionContextReader) OnInputReaderMatch(matchers ...interface{}) *TaskExecutionContextReader_InputReader { - c := _m.On("InputReader", matchers...) - return &TaskExecutionContextReader_InputReader{Call: c} + c_call := _m.On("InputReader", matchers...) + return &TaskExecutionContextReader_InputReader{Call: c_call} } // InputReader provides a mock function with given fields: @@ -57,13 +57,13 @@ func (_m TaskExecutionContextReader_OutputWriter) Return(_a0 io.OutputWriter) *T } func (_m *TaskExecutionContextReader) OnOutputWriter() *TaskExecutionContextReader_OutputWriter { - c := _m.On("OutputWriter") - return &TaskExecutionContextReader_OutputWriter{Call: c} + c_call := _m.On("OutputWriter") + return &TaskExecutionContextReader_OutputWriter{Call: c_call} } func (_m *TaskExecutionContextReader) OnOutputWriterMatch(matchers ...interface{}) *TaskExecutionContextReader_OutputWriter { - c := _m.On("OutputWriter", matchers...) - return &TaskExecutionContextReader_OutputWriter{Call: c} + c_call := _m.On("OutputWriter", matchers...) + return &TaskExecutionContextReader_OutputWriter{Call: c_call} } // OutputWriter provides a mock function with given fields: @@ -91,13 +91,13 @@ func (_m TaskExecutionContextReader_SecretManager) Return(_a0 core.SecretManager } func (_m *TaskExecutionContextReader) OnSecretManager() *TaskExecutionContextReader_SecretManager { - c := _m.On("SecretManager") - return &TaskExecutionContextReader_SecretManager{Call: c} + c_call := _m.On("SecretManager") + return &TaskExecutionContextReader_SecretManager{Call: c_call} } func (_m *TaskExecutionContextReader) OnSecretManagerMatch(matchers ...interface{}) *TaskExecutionContextReader_SecretManager { - c := _m.On("SecretManager", matchers...) - return &TaskExecutionContextReader_SecretManager{Call: c} + c_call := _m.On("SecretManager", matchers...) + return &TaskExecutionContextReader_SecretManager{Call: c_call} } // SecretManager provides a mock function with given fields: @@ -125,13 +125,13 @@ func (_m TaskExecutionContextReader_TaskExecutionMetadata) Return(_a0 core.TaskE } func (_m *TaskExecutionContextReader) OnTaskExecutionMetadata() *TaskExecutionContextReader_TaskExecutionMetadata { - c := _m.On("TaskExecutionMetadata") - return &TaskExecutionContextReader_TaskExecutionMetadata{Call: c} + c_call := _m.On("TaskExecutionMetadata") + return &TaskExecutionContextReader_TaskExecutionMetadata{Call: c_call} } func (_m *TaskExecutionContextReader) OnTaskExecutionMetadataMatch(matchers ...interface{}) *TaskExecutionContextReader_TaskExecutionMetadata { - c := _m.On("TaskExecutionMetadata", matchers...) - return &TaskExecutionContextReader_TaskExecutionMetadata{Call: c} + c_call := _m.On("TaskExecutionMetadata", matchers...) + return &TaskExecutionContextReader_TaskExecutionMetadata{Call: c_call} } // TaskExecutionMetadata provides a mock function with given fields: @@ -159,13 +159,13 @@ func (_m TaskExecutionContextReader_TaskReader) Return(_a0 core.TaskReader) *Tas } func (_m *TaskExecutionContextReader) OnTaskReader() *TaskExecutionContextReader_TaskReader { - c := _m.On("TaskReader") - return &TaskExecutionContextReader_TaskReader{Call: c} + c_call := _m.On("TaskReader") + return &TaskExecutionContextReader_TaskReader{Call: c_call} } func (_m *TaskExecutionContextReader) OnTaskReaderMatch(matchers ...interface{}) *TaskExecutionContextReader_TaskReader { - c := _m.On("TaskReader", matchers...) - return &TaskExecutionContextReader_TaskReader{Call: c} + c_call := _m.On("TaskReader", matchers...) + return &TaskExecutionContextReader_TaskReader{Call: c_call} } // TaskReader provides a mock function with given fields: diff --git a/go/tasks/pluginmachinery/workqueue/mocks/indexed_work_queue.go b/go/tasks/pluginmachinery/workqueue/mocks/indexed_work_queue.go index 4b4d9421f..d0ef3a6e1 100644 --- a/go/tasks/pluginmachinery/workqueue/mocks/indexed_work_queue.go +++ b/go/tasks/pluginmachinery/workqueue/mocks/indexed_work_queue.go @@ -23,13 +23,13 @@ func (_m IndexedWorkQueue_Get) Return(info workqueue.WorkItemInfo, found bool, e } func (_m *IndexedWorkQueue) OnGet(id string) *IndexedWorkQueue_Get { - c := _m.On("Get", id) - return &IndexedWorkQueue_Get{Call: c} + c_call := _m.On("Get", id) + return &IndexedWorkQueue_Get{Call: c_call} } func (_m *IndexedWorkQueue) OnGetMatch(matchers ...interface{}) *IndexedWorkQueue_Get { - c := _m.On("Get", matchers...) - return &IndexedWorkQueue_Get{Call: c} + c_call := _m.On("Get", matchers...) + return &IndexedWorkQueue_Get{Call: c_call} } // Get provides a mock function with given fields: id @@ -71,13 +71,13 @@ func (_m IndexedWorkQueue_Queue) Return(_a0 error) *IndexedWorkQueue_Queue { } func (_m *IndexedWorkQueue) OnQueue(ctx context.Context, id string, once workqueue.WorkItem) *IndexedWorkQueue_Queue { - c := _m.On("Queue", ctx, id, once) - return &IndexedWorkQueue_Queue{Call: c} + c_call := _m.On("Queue", ctx, id, once) + return &IndexedWorkQueue_Queue{Call: c_call} } func (_m *IndexedWorkQueue) OnQueueMatch(matchers ...interface{}) *IndexedWorkQueue_Queue { - c := _m.On("Queue", matchers...) - return &IndexedWorkQueue_Queue{Call: c} + c_call := _m.On("Queue", matchers...) + return &IndexedWorkQueue_Queue{Call: c_call} } // Queue provides a mock function with given fields: ctx, id, once @@ -103,13 +103,13 @@ func (_m IndexedWorkQueue_Start) Return(_a0 error) *IndexedWorkQueue_Start { } func (_m *IndexedWorkQueue) OnStart(ctx context.Context) *IndexedWorkQueue_Start { - c := _m.On("Start", ctx) - return &IndexedWorkQueue_Start{Call: c} + c_call := _m.On("Start", ctx) + return &IndexedWorkQueue_Start{Call: c_call} } func (_m *IndexedWorkQueue) OnStartMatch(matchers ...interface{}) *IndexedWorkQueue_Start { - c := _m.On("Start", matchers...) - return &IndexedWorkQueue_Start{Call: c} + c_call := _m.On("Start", matchers...) + return &IndexedWorkQueue_Start{Call: c_call} } // Start provides a mock function with given fields: ctx diff --git a/go/tasks/pluginmachinery/workqueue/mocks/processor.go b/go/tasks/pluginmachinery/workqueue/mocks/processor.go index deb327266..42bd29ac1 100644 --- a/go/tasks/pluginmachinery/workqueue/mocks/processor.go +++ b/go/tasks/pluginmachinery/workqueue/mocks/processor.go @@ -23,13 +23,13 @@ func (_m Processor_Process) Return(_a0 workqueue.WorkStatus, _a1 error) *Process } func (_m *Processor) OnProcess(ctx context.Context, workItem workqueue.WorkItem) *Processor_Process { - c := _m.On("Process", ctx, workItem) - return &Processor_Process{Call: c} + c_call := _m.On("Process", ctx, workItem) + return &Processor_Process{Call: c_call} } func (_m *Processor) OnProcessMatch(matchers ...interface{}) *Processor_Process { - c := _m.On("Process", matchers...) - return &Processor_Process{Call: c} + c_call := _m.On("Process", matchers...) + return &Processor_Process{Call: c_call} } // Process provides a mock function with given fields: ctx, workItem diff --git a/go/tasks/pluginmachinery/workqueue/mocks/work_item_info.go b/go/tasks/pluginmachinery/workqueue/mocks/work_item_info.go index 02e83d759..71f99f64a 100644 --- a/go/tasks/pluginmachinery/workqueue/mocks/work_item_info.go +++ b/go/tasks/pluginmachinery/workqueue/mocks/work_item_info.go @@ -21,13 +21,13 @@ func (_m WorkItemInfo_Error) Return(_a0 error) *WorkItemInfo_Error { } func (_m *WorkItemInfo) OnError() *WorkItemInfo_Error { - c := _m.On("Error") - return &WorkItemInfo_Error{Call: c} + c_call := _m.On("Error") + return &WorkItemInfo_Error{Call: c_call} } func (_m *WorkItemInfo) OnErrorMatch(matchers ...interface{}) *WorkItemInfo_Error { - c := _m.On("Error", matchers...) - return &WorkItemInfo_Error{Call: c} + c_call := _m.On("Error", matchers...) + return &WorkItemInfo_Error{Call: c_call} } // Error provides a mock function with given fields: @@ -53,13 +53,13 @@ func (_m WorkItemInfo_ID) Return(_a0 string) *WorkItemInfo_ID { } func (_m *WorkItemInfo) OnID() *WorkItemInfo_ID { - c := _m.On("ID") - return &WorkItemInfo_ID{Call: c} + c_call := _m.On("ID") + return &WorkItemInfo_ID{Call: c_call} } func (_m *WorkItemInfo) OnIDMatch(matchers ...interface{}) *WorkItemInfo_ID { - c := _m.On("ID", matchers...) - return &WorkItemInfo_ID{Call: c} + c_call := _m.On("ID", matchers...) + return &WorkItemInfo_ID{Call: c_call} } // ID provides a mock function with given fields: @@ -85,13 +85,13 @@ func (_m WorkItemInfo_Item) Return(_a0 workqueue.WorkItem) *WorkItemInfo_Item { } func (_m *WorkItemInfo) OnItem() *WorkItemInfo_Item { - c := _m.On("Item") - return &WorkItemInfo_Item{Call: c} + c_call := _m.On("Item") + return &WorkItemInfo_Item{Call: c_call} } func (_m *WorkItemInfo) OnItemMatch(matchers ...interface{}) *WorkItemInfo_Item { - c := _m.On("Item", matchers...) - return &WorkItemInfo_Item{Call: c} + c_call := _m.On("Item", matchers...) + return &WorkItemInfo_Item{Call: c_call} } // Item provides a mock function with given fields: @@ -119,13 +119,13 @@ func (_m WorkItemInfo_Status) Return(_a0 workqueue.WorkStatus) *WorkItemInfo_Sta } func (_m *WorkItemInfo) OnStatus() *WorkItemInfo_Status { - c := _m.On("Status") - return &WorkItemInfo_Status{Call: c} + c_call := _m.On("Status") + return &WorkItemInfo_Status{Call: c_call} } func (_m *WorkItemInfo) OnStatusMatch(matchers ...interface{}) *WorkItemInfo_Status { - c := _m.On("Status", matchers...) - return &WorkItemInfo_Status{Call: c} + c_call := _m.On("Status", matchers...) + return &WorkItemInfo_Status{Call: c_call} } // Status provides a mock function with given fields: diff --git a/go/tasks/plugins/array/awsbatch/mocks/batch_service_client.go b/go/tasks/plugins/array/awsbatch/mocks/batch_service_client.go index 810ded0a6..80d211ae9 100644 --- a/go/tasks/plugins/array/awsbatch/mocks/batch_service_client.go +++ b/go/tasks/plugins/array/awsbatch/mocks/batch_service_client.go @@ -26,13 +26,13 @@ func (_m BatchServiceClient_DescribeJobsWithContext) Return(_a0 *batch.DescribeJ } func (_m *BatchServiceClient) OnDescribeJobsWithContext(ctx context.Context, input *batch.DescribeJobsInput, opts ...request.Option) *BatchServiceClient_DescribeJobsWithContext { - c := _m.On("DescribeJobsWithContext", ctx, input, opts) - return &BatchServiceClient_DescribeJobsWithContext{Call: c} + c_call := _m.On("DescribeJobsWithContext", ctx, input, opts) + return &BatchServiceClient_DescribeJobsWithContext{Call: c_call} } func (_m *BatchServiceClient) OnDescribeJobsWithContextMatch(matchers ...interface{}) *BatchServiceClient_DescribeJobsWithContext { - c := _m.On("DescribeJobsWithContext", matchers...) - return &BatchServiceClient_DescribeJobsWithContext{Call: c} + c_call := _m.On("DescribeJobsWithContext", matchers...) + return &BatchServiceClient_DescribeJobsWithContext{Call: c_call} } // DescribeJobsWithContext provides a mock function with given fields: ctx, input, opts @@ -74,13 +74,13 @@ func (_m BatchServiceClient_RegisterJobDefinitionWithContext) Return(_a0 *batch. } func (_m *BatchServiceClient) OnRegisterJobDefinitionWithContext(ctx context.Context, input *batch.RegisterJobDefinitionInput, opts ...request.Option) *BatchServiceClient_RegisterJobDefinitionWithContext { - c := _m.On("RegisterJobDefinitionWithContext", ctx, input, opts) - return &BatchServiceClient_RegisterJobDefinitionWithContext{Call: c} + c_call := _m.On("RegisterJobDefinitionWithContext", ctx, input, opts) + return &BatchServiceClient_RegisterJobDefinitionWithContext{Call: c_call} } func (_m *BatchServiceClient) OnRegisterJobDefinitionWithContextMatch(matchers ...interface{}) *BatchServiceClient_RegisterJobDefinitionWithContext { - c := _m.On("RegisterJobDefinitionWithContext", matchers...) - return &BatchServiceClient_RegisterJobDefinitionWithContext{Call: c} + c_call := _m.On("RegisterJobDefinitionWithContext", matchers...) + return &BatchServiceClient_RegisterJobDefinitionWithContext{Call: c_call} } // RegisterJobDefinitionWithContext provides a mock function with given fields: ctx, input, opts @@ -122,13 +122,13 @@ func (_m BatchServiceClient_SubmitJobWithContext) Return(_a0 *batch.SubmitJobOut } func (_m *BatchServiceClient) OnSubmitJobWithContext(ctx context.Context, input *batch.SubmitJobInput, opts ...request.Option) *BatchServiceClient_SubmitJobWithContext { - c := _m.On("SubmitJobWithContext", ctx, input, opts) - return &BatchServiceClient_SubmitJobWithContext{Call: c} + c_call := _m.On("SubmitJobWithContext", ctx, input, opts) + return &BatchServiceClient_SubmitJobWithContext{Call: c_call} } func (_m *BatchServiceClient) OnSubmitJobWithContextMatch(matchers ...interface{}) *BatchServiceClient_SubmitJobWithContext { - c := _m.On("SubmitJobWithContext", matchers...) - return &BatchServiceClient_SubmitJobWithContext{Call: c} + c_call := _m.On("SubmitJobWithContext", matchers...) + return &BatchServiceClient_SubmitJobWithContext{Call: c_call} } // SubmitJobWithContext provides a mock function with given fields: ctx, input, opts @@ -170,13 +170,13 @@ func (_m BatchServiceClient_TerminateJobWithContext) Return(_a0 *batch.Terminate } func (_m *BatchServiceClient) OnTerminateJobWithContext(ctx context.Context, input *batch.TerminateJobInput, opts ...request.Option) *BatchServiceClient_TerminateJobWithContext { - c := _m.On("TerminateJobWithContext", ctx, input, opts) - return &BatchServiceClient_TerminateJobWithContext{Call: c} + c_call := _m.On("TerminateJobWithContext", ctx, input, opts) + return &BatchServiceClient_TerminateJobWithContext{Call: c_call} } func (_m *BatchServiceClient) OnTerminateJobWithContextMatch(matchers ...interface{}) *BatchServiceClient_TerminateJobWithContext { - c := _m.On("TerminateJobWithContext", matchers...) - return &BatchServiceClient_TerminateJobWithContext{Call: c} + c_call := _m.On("TerminateJobWithContext", matchers...) + return &BatchServiceClient_TerminateJobWithContext{Call: c_call} } // TerminateJobWithContext provides a mock function with given fields: ctx, input, opts diff --git a/go/tasks/plugins/array/awsbatch/mocks/cache.go b/go/tasks/plugins/array/awsbatch/mocks/cache.go index 388f293bc..d37bed19f 100644 --- a/go/tasks/plugins/array/awsbatch/mocks/cache.go +++ b/go/tasks/plugins/array/awsbatch/mocks/cache.go @@ -21,13 +21,13 @@ func (_m Cache_Get) Return(jobDefinition string, found bool) *Cache_Get { } func (_m *Cache) OnGet(key definition.CacheKey) *Cache_Get { - c := _m.On("Get", key) - return &Cache_Get{Call: c} + c_call := _m.On("Get", key) + return &Cache_Get{Call: c_call} } func (_m *Cache) OnGetMatch(matchers ...interface{}) *Cache_Get { - c := _m.On("Get", matchers...) - return &Cache_Get{Call: c} + c_call := _m.On("Get", matchers...) + return &Cache_Get{Call: c_call} } // Get provides a mock function with given fields: key @@ -60,13 +60,13 @@ func (_m Cache_Put) Return(_a0 error) *Cache_Put { } func (_m *Cache) OnPut(key definition.CacheKey, _a1 string) *Cache_Put { - c := _m.On("Put", key, _a1) - return &Cache_Put{Call: c} + c_call := _m.On("Put", key, _a1) + return &Cache_Put{Call: c_call} } func (_m *Cache) OnPutMatch(matchers ...interface{}) *Cache_Put { - c := _m.On("Put", matchers...) - return &Cache_Put{Call: c} + c_call := _m.On("Put", matchers...) + return &Cache_Put{Call: c_call} } // Put provides a mock function with given fields: key, _a1 diff --git a/go/tasks/plugins/array/awsbatch/mocks/cache_key.go b/go/tasks/plugins/array/awsbatch/mocks/cache_key.go index 33ec137a6..bfb229e45 100644 --- a/go/tasks/plugins/array/awsbatch/mocks/cache_key.go +++ b/go/tasks/plugins/array/awsbatch/mocks/cache_key.go @@ -18,13 +18,13 @@ func (_m CacheKey_String) Return(_a0 string) *CacheKey_String { } func (_m *CacheKey) OnString() *CacheKey_String { - c := _m.On("String") - return &CacheKey_String{Call: c} + c_call := _m.On("String") + return &CacheKey_String{Call: c_call} } func (_m *CacheKey) OnStringMatch(matchers ...interface{}) *CacheKey_String { - c := _m.On("String", matchers...) - return &CacheKey_String{Call: c} + c_call := _m.On("String", matchers...) + return &CacheKey_String{Call: c_call} } // String provides a mock function with given fields: diff --git a/go/tasks/plugins/array/awsbatch/mocks/client.go b/go/tasks/plugins/array/awsbatch/mocks/client.go index 6e82c518d..9d22878e0 100644 --- a/go/tasks/plugins/array/awsbatch/mocks/client.go +++ b/go/tasks/plugins/array/awsbatch/mocks/client.go @@ -24,13 +24,13 @@ func (_m Client_GetAccountID) Return(_a0 string) *Client_GetAccountID { } func (_m *Client) OnGetAccountID() *Client_GetAccountID { - c := _m.On("GetAccountID") - return &Client_GetAccountID{Call: c} + c_call := _m.On("GetAccountID") + return &Client_GetAccountID{Call: c_call} } func (_m *Client) OnGetAccountIDMatch(matchers ...interface{}) *Client_GetAccountID { - c := _m.On("GetAccountID", matchers...) - return &Client_GetAccountID{Call: c} + c_call := _m.On("GetAccountID", matchers...) + return &Client_GetAccountID{Call: c_call} } // GetAccountID provides a mock function with given fields: @@ -56,13 +56,13 @@ func (_m Client_GetJobDetailsBatch) Return(_a0 []*batch.JobDetail, _a1 error) *C } func (_m *Client) OnGetJobDetailsBatch(ctx context.Context, ids []string) *Client_GetJobDetailsBatch { - c := _m.On("GetJobDetailsBatch", ctx, ids) - return &Client_GetJobDetailsBatch{Call: c} + c_call := _m.On("GetJobDetailsBatch", ctx, ids) + return &Client_GetJobDetailsBatch{Call: c_call} } func (_m *Client) OnGetJobDetailsBatchMatch(matchers ...interface{}) *Client_GetJobDetailsBatch { - c := _m.On("GetJobDetailsBatch", matchers...) - return &Client_GetJobDetailsBatch{Call: c} + c_call := _m.On("GetJobDetailsBatch", matchers...) + return &Client_GetJobDetailsBatch{Call: c_call} } // GetJobDetailsBatch provides a mock function with given fields: ctx, ids @@ -97,13 +97,13 @@ func (_m Client_GetRegion) Return(_a0 string) *Client_GetRegion { } func (_m *Client) OnGetRegion() *Client_GetRegion { - c := _m.On("GetRegion") - return &Client_GetRegion{Call: c} + c_call := _m.On("GetRegion") + return &Client_GetRegion{Call: c_call} } func (_m *Client) OnGetRegionMatch(matchers ...interface{}) *Client_GetRegion { - c := _m.On("GetRegion", matchers...) - return &Client_GetRegion{Call: c} + c_call := _m.On("GetRegion", matchers...) + return &Client_GetRegion{Call: c_call} } // GetRegion provides a mock function with given fields: @@ -129,13 +129,13 @@ func (_m Client_RegisterJobDefinition) Return(arn string, err error) *Client_Reg } func (_m *Client) OnRegisterJobDefinition(ctx context.Context, name string, image string, role string, platformCapabilities string) *Client_RegisterJobDefinition { - c := _m.On("RegisterJobDefinition", ctx, name, image, role, platformCapabilities) - return &Client_RegisterJobDefinition{Call: c} + c_call := _m.On("RegisterJobDefinition", ctx, name, image, role, platformCapabilities) + return &Client_RegisterJobDefinition{Call: c_call} } func (_m *Client) OnRegisterJobDefinitionMatch(matchers ...interface{}) *Client_RegisterJobDefinition { - c := _m.On("RegisterJobDefinition", matchers...) - return &Client_RegisterJobDefinition{Call: c} + c_call := _m.On("RegisterJobDefinition", matchers...) + return &Client_RegisterJobDefinition{Call: c_call} } // RegisterJobDefinition provides a mock function with given fields: ctx, name, image, role, platformCapabilities @@ -168,13 +168,13 @@ func (_m Client_SubmitJob) Return(jobID string, err error) *Client_SubmitJob { } func (_m *Client) OnSubmitJob(ctx context.Context, input *batch.SubmitJobInput) *Client_SubmitJob { - c := _m.On("SubmitJob", ctx, input) - return &Client_SubmitJob{Call: c} + c_call := _m.On("SubmitJob", ctx, input) + return &Client_SubmitJob{Call: c_call} } func (_m *Client) OnSubmitJobMatch(matchers ...interface{}) *Client_SubmitJob { - c := _m.On("SubmitJob", matchers...) - return &Client_SubmitJob{Call: c} + c_call := _m.On("SubmitJob", matchers...) + return &Client_SubmitJob{Call: c_call} } // SubmitJob provides a mock function with given fields: ctx, input @@ -207,13 +207,13 @@ func (_m Client_TerminateJob) Return(_a0 error) *Client_TerminateJob { } func (_m *Client) OnTerminateJob(ctx context.Context, jobID string, reason string) *Client_TerminateJob { - c := _m.On("TerminateJob", ctx, jobID, reason) - return &Client_TerminateJob{Call: c} + c_call := _m.On("TerminateJob", ctx, jobID, reason) + return &Client_TerminateJob{Call: c_call} } func (_m *Client) OnTerminateJobMatch(matchers ...interface{}) *Client_TerminateJob { - c := _m.On("TerminateJob", matchers...) - return &Client_TerminateJob{Call: c} + c_call := _m.On("TerminateJob", matchers...) + return &Client_TerminateJob{Call: c_call} } // TerminateJob provides a mock function with given fields: ctx, jobID, reason diff --git a/go/tasks/plugins/hive/client/mocks/qubole_client.go b/go/tasks/plugins/hive/client/mocks/qubole_client.go index 0ad881473..61d33f2eb 100644 --- a/go/tasks/plugins/hive/client/mocks/qubole_client.go +++ b/go/tasks/plugins/hive/client/mocks/qubole_client.go @@ -24,13 +24,13 @@ func (_m QuboleClient_ExecuteHiveCommand) Return(_a0 *client.QuboleCommandDetail } func (_m *QuboleClient) OnExecuteHiveCommand(ctx context.Context, commandStr string, timeoutVal uint32, clusterPrimaryLabel string, accountKey string, tags []string, commandMetadata client.CommandMetadata) *QuboleClient_ExecuteHiveCommand { - c := _m.On("ExecuteHiveCommand", ctx, commandStr, timeoutVal, clusterPrimaryLabel, accountKey, tags, commandMetadata) - return &QuboleClient_ExecuteHiveCommand{Call: c} + c_call := _m.On("ExecuteHiveCommand", ctx, commandStr, timeoutVal, clusterPrimaryLabel, accountKey, tags, commandMetadata) + return &QuboleClient_ExecuteHiveCommand{Call: c_call} } func (_m *QuboleClient) OnExecuteHiveCommandMatch(matchers ...interface{}) *QuboleClient_ExecuteHiveCommand { - c := _m.On("ExecuteHiveCommand", matchers...) - return &QuboleClient_ExecuteHiveCommand{Call: c} + c_call := _m.On("ExecuteHiveCommand", matchers...) + return &QuboleClient_ExecuteHiveCommand{Call: c_call} } // ExecuteHiveCommand provides a mock function with given fields: ctx, commandStr, timeoutVal, clusterPrimaryLabel, accountKey, tags, commandMetadata @@ -65,13 +65,13 @@ func (_m QuboleClient_GetCommandStatus) Return(_a0 client.QuboleStatus, _a1 erro } func (_m *QuboleClient) OnGetCommandStatus(ctx context.Context, commandID string, accountKey string) *QuboleClient_GetCommandStatus { - c := _m.On("GetCommandStatus", ctx, commandID, accountKey) - return &QuboleClient_GetCommandStatus{Call: c} + c_call := _m.On("GetCommandStatus", ctx, commandID, accountKey) + return &QuboleClient_GetCommandStatus{Call: c_call} } func (_m *QuboleClient) OnGetCommandStatusMatch(matchers ...interface{}) *QuboleClient_GetCommandStatus { - c := _m.On("GetCommandStatus", matchers...) - return &QuboleClient_GetCommandStatus{Call: c} + c_call := _m.On("GetCommandStatus", matchers...) + return &QuboleClient_GetCommandStatus{Call: c_call} } // GetCommandStatus provides a mock function with given fields: ctx, commandID, accountKey @@ -104,13 +104,13 @@ func (_m QuboleClient_KillCommand) Return(_a0 error) *QuboleClient_KillCommand { } func (_m *QuboleClient) OnKillCommand(ctx context.Context, commandID string, accountKey string) *QuboleClient_KillCommand { - c := _m.On("KillCommand", ctx, commandID, accountKey) - return &QuboleClient_KillCommand{Call: c} + c_call := _m.On("KillCommand", ctx, commandID, accountKey) + return &QuboleClient_KillCommand{Call: c_call} } func (_m *QuboleClient) OnKillCommandMatch(matchers ...interface{}) *QuboleClient_KillCommand { - c := _m.On("KillCommand", matchers...) - return &QuboleClient_KillCommand{Call: c} + c_call := _m.On("KillCommand", matchers...) + return &QuboleClient_KillCommand{Call: c_call} } // KillCommand provides a mock function with given fields: ctx, commandID, accountKey diff --git a/go/tasks/plugins/presto/client/mocks/presto_client.go b/go/tasks/plugins/presto/client/mocks/presto_client.go index 34431dd5f..09f62c345 100644 --- a/go/tasks/plugins/presto/client/mocks/presto_client.go +++ b/go/tasks/plugins/presto/client/mocks/presto_client.go @@ -24,13 +24,13 @@ func (_m PrestoClient_ExecuteCommand) Return(_a0 client.PrestoExecuteResponse, _ } func (_m *PrestoClient) OnExecuteCommand(ctx context.Context, commandStr string, executeArgs client.PrestoExecuteArgs) *PrestoClient_ExecuteCommand { - c := _m.On("ExecuteCommand", ctx, commandStr, executeArgs) - return &PrestoClient_ExecuteCommand{Call: c} + c_call := _m.On("ExecuteCommand", ctx, commandStr, executeArgs) + return &PrestoClient_ExecuteCommand{Call: c_call} } func (_m *PrestoClient) OnExecuteCommandMatch(matchers ...interface{}) *PrestoClient_ExecuteCommand { - c := _m.On("ExecuteCommand", matchers...) - return &PrestoClient_ExecuteCommand{Call: c} + c_call := _m.On("ExecuteCommand", matchers...) + return &PrestoClient_ExecuteCommand{Call: c_call} } // ExecuteCommand provides a mock function with given fields: ctx, commandStr, executeArgs @@ -63,13 +63,13 @@ func (_m PrestoClient_GetCommandStatus) Return(_a0 client.PrestoStatus, _a1 erro } func (_m *PrestoClient) OnGetCommandStatus(ctx context.Context, commandID string) *PrestoClient_GetCommandStatus { - c := _m.On("GetCommandStatus", ctx, commandID) - return &PrestoClient_GetCommandStatus{Call: c} + c_call := _m.On("GetCommandStatus", ctx, commandID) + return &PrestoClient_GetCommandStatus{Call: c_call} } func (_m *PrestoClient) OnGetCommandStatusMatch(matchers ...interface{}) *PrestoClient_GetCommandStatus { - c := _m.On("GetCommandStatus", matchers...) - return &PrestoClient_GetCommandStatus{Call: c} + c_call := _m.On("GetCommandStatus", matchers...) + return &PrestoClient_GetCommandStatus{Call: c_call} } // GetCommandStatus provides a mock function with given fields: ctx, commandID @@ -102,13 +102,13 @@ func (_m PrestoClient_KillCommand) Return(_a0 error) *PrestoClient_KillCommand { } func (_m *PrestoClient) OnKillCommand(ctx context.Context, commandID string) *PrestoClient_KillCommand { - c := _m.On("KillCommand", ctx, commandID) - return &PrestoClient_KillCommand{Call: c} + c_call := _m.On("KillCommand", ctx, commandID) + return &PrestoClient_KillCommand{Call: c_call} } func (_m *PrestoClient) OnKillCommandMatch(matchers ...interface{}) *PrestoClient_KillCommand { - c := _m.On("KillCommand", matchers...) - return &PrestoClient_KillCommand{Call: c} + c_call := _m.On("KillCommand", matchers...) + return &PrestoClient_KillCommand{Call: c_call} } // KillCommand provides a mock function with given fields: ctx, commandID