From 699e8407ec7ad976052be0a3034ecd599c346f8a Mon Sep 17 00:00:00 2001 From: SoXX Date: Sun, 1 Sep 2024 19:15:48 +0200 Subject: [PATCH] feat(version): updated for latest release of the Orchestrator --- .openapi-generator/FILES | 1 + README.md | 2 +- api_plug.go | 320 ------------------------- api_user_source.go | 383 ++++++++++++++++++++++++++++++ docs/ModelsOrchestratorTask.md | 93 -------- docs/ModelsPlugTask.md | 103 -------- docs/ModelsPlugTaskState.md | 17 -- docs/PlugAPI.md | 223 ----------------- docs/TaskResponse.md | 82 +++++++ docs/TaskStartTask.md | 108 +++++++++ docs/{UserAPI.md => UserApi.md} | 0 docs/UserSourceApi.md | 229 ++++++++++++++++++ go.mod | 3 +- go.sum | 19 +- model_models_orchestrator_task.go | 213 ----------------- model_models_plug_task.go | 229 ------------------ model_models_plug_task_state.go | 115 --------- model_task_response.go | 150 ++++++++++++ model_task_start_task.go | 186 +++++++++++++++ test/api_plug_test.go | 66 ----- test/api_user_test.go | 38 --- 21 files changed, 1146 insertions(+), 1434 deletions(-) delete mode 100644 api_plug.go create mode 100644 api_user_source.go delete mode 100644 docs/ModelsOrchestratorTask.md delete mode 100644 docs/ModelsPlugTask.md delete mode 100644 docs/ModelsPlugTaskState.md delete mode 100644 docs/PlugAPI.md create mode 100644 docs/TaskResponse.md create mode 100644 docs/TaskStartTask.md rename docs/{UserAPI.md => UserApi.md} (100%) create mode 100644 docs/UserSourceApi.md delete mode 100644 model_models_orchestrator_task.go delete mode 100644 model_models_plug_task.go delete mode 100644 model_models_plug_task_state.go create mode 100644 model_task_response.go create mode 100644 model_task_start_task.go delete mode 100644 test/api_plug_test.go delete mode 100644 test/api_user_test.go diff --git a/.openapi-generator/FILES b/.openapi-generator/FILES index e388a08..1e07d2a 100644 --- a/.openapi-generator/FILES +++ b/.openapi-generator/FILES @@ -1,4 +1,5 @@ .gitignore +.openapi-generator-ignore .travis.yml README.md api/openapi.yaml diff --git a/README.md b/README.md index ad6d704..1f8a5b9 100644 --- a/README.md +++ b/README.md @@ -23,7 +23,7 @@ go get golang.org/x/net/context Put the package under your project folder and add the following in import: ```golang -import openapi "git.anthrove.art/Anthrove/orchestrator-swagger-go-client/v1" +import openapi "git.anthrove.art/Anthrove/orchestrator-swagger-go-client" ``` To use a proxy, set the environment variable `HTTP_PROXY`: diff --git a/api_plug.go b/api_plug.go deleted file mode 100644 index 163c9a9..0000000 --- a/api_plug.go +++ /dev/null @@ -1,320 +0,0 @@ -/* -Anthrove Orchestrator API - -This service handles the communication between the manager and the plugs - -API version: 0.1-PREVIEW -Contact: support@anthrove.art -*/ - -// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT. - -package openapi - -import ( - "bytes" - "context" - "io" - "net/http" - "net/url" - "strings" -) - -// PlugAPIService PlugAPI service -type PlugAPIService service - -type ApiPlugPlugTypePutRequest struct { - ctx context.Context - ApiService *PlugAPIService - plugType string - request *ModelsOrchestratorTask -} - -// aa -func (r ApiPlugPlugTypePutRequest) Request(request ModelsOrchestratorTask) ApiPlugPlugTypePutRequest { - r.request = &request - return r -} - -func (r ApiPlugPlugTypePutRequest) Execute() (*http.Response, error) { - return r.ApiService.PlugPlugTypePutExecute(r) -} - -/* -PlugPlugTypePut Initiates a scraping operation for a user with a specific plug type - -Initiates a scraping operation for a user with a specific plug type returns the created task IDs. - - @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). - @param plugType supported plug type - @return ApiPlugPlugTypePutRequest -*/ -func (a *PlugAPIService) PlugPlugTypePut(ctx context.Context, plugType string) ApiPlugPlugTypePutRequest { - return ApiPlugPlugTypePutRequest{ - ApiService: a, - ctx: ctx, - plugType: plugType, - } -} - -// Execute executes the request -func (a *PlugAPIService) PlugPlugTypePutExecute(r ApiPlugPlugTypePutRequest) (*http.Response, error) { - var ( - localVarHTTPMethod = http.MethodPut - localVarPostBody interface{} - formFiles []formFile - ) - - localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "PlugAPIService.PlugPlugTypePut") - if err != nil { - return nil, &GenericOpenAPIError{error: err.Error()} - } - - localVarPath := localBasePath + "/plug/{plug_type}" - localVarPath = strings.Replace(localVarPath, "{"+"plug_type"+"}", url.PathEscape(parameterValueToString(r.plugType, "plugType")), -1) - - localVarHeaderParams := make(map[string]string) - localVarQueryParams := url.Values{} - localVarFormParams := url.Values{} - if r.request == nil { - return nil, reportError("request is required and must be specified") - } - - // to determine the Content-Type header - localVarHTTPContentTypes := []string{"application/json"} - - // set Content-Type header - localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes) - if localVarHTTPContentType != "" { - localVarHeaderParams["Content-Type"] = localVarHTTPContentType - } - - // to determine the Accept header - localVarHTTPHeaderAccepts := []string{} - - // set Accept header - localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts) - if localVarHTTPHeaderAccept != "" { - localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept - } - // body params - localVarPostBody = r.request - req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles) - if err != nil { - return nil, err - } - - localVarHTTPResponse, err := a.client.callAPI(req) - if err != nil || localVarHTTPResponse == nil { - return localVarHTTPResponse, err - } - - localVarBody, err := io.ReadAll(localVarHTTPResponse.Body) - localVarHTTPResponse.Body.Close() - localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody)) - if err != nil { - return localVarHTTPResponse, err - } - - if localVarHTTPResponse.StatusCode >= 300 { - newErr := &GenericOpenAPIError{ - body: localVarBody, - error: localVarHTTPResponse.Status, - } - return localVarHTTPResponse, newErr - } - - return localVarHTTPResponse, nil -} - -type ApiPlugPlugTypeTaskIdDeleteRequest struct { - ctx context.Context - ApiService *PlugAPIService - plugType string - taskId string -} - -func (r ApiPlugPlugTypeTaskIdDeleteRequest) Execute() (*http.Response, error) { - return r.ApiService.PlugPlugTypeTaskIdDeleteExecute(r) -} - -/* -PlugPlugTypeTaskIdDelete Stops a scraping operation for a user with a specific plug type - -Stops a scraping operation for a user with a specific plug type returns the created task IDs. - - @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). - @param plugType supported plug type - @param taskId id of task - @return ApiPlugPlugTypeTaskIdDeleteRequest -*/ -func (a *PlugAPIService) PlugPlugTypeTaskIdDelete(ctx context.Context, plugType string, taskId string) ApiPlugPlugTypeTaskIdDeleteRequest { - return ApiPlugPlugTypeTaskIdDeleteRequest{ - ApiService: a, - ctx: ctx, - plugType: plugType, - taskId: taskId, - } -} - -// Execute executes the request -func (a *PlugAPIService) PlugPlugTypeTaskIdDeleteExecute(r ApiPlugPlugTypeTaskIdDeleteRequest) (*http.Response, error) { - var ( - localVarHTTPMethod = http.MethodDelete - localVarPostBody interface{} - formFiles []formFile - ) - - localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "PlugAPIService.PlugPlugTypeTaskIdDelete") - if err != nil { - return nil, &GenericOpenAPIError{error: err.Error()} - } - - localVarPath := localBasePath + "/plug/{plug_type}/{task_id}" - localVarPath = strings.Replace(localVarPath, "{"+"plug_type"+"}", url.PathEscape(parameterValueToString(r.plugType, "plugType")), -1) - localVarPath = strings.Replace(localVarPath, "{"+"task_id"+"}", url.PathEscape(parameterValueToString(r.taskId, "taskId")), -1) - - localVarHeaderParams := make(map[string]string) - localVarQueryParams := url.Values{} - localVarFormParams := url.Values{} - - // to determine the Content-Type header - localVarHTTPContentTypes := []string{} - - // set Content-Type header - localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes) - if localVarHTTPContentType != "" { - localVarHeaderParams["Content-Type"] = localVarHTTPContentType - } - - // to determine the Accept header - localVarHTTPHeaderAccepts := []string{} - - // set Accept header - localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts) - if localVarHTTPHeaderAccept != "" { - localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept - } - req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles) - if err != nil { - return nil, err - } - - localVarHTTPResponse, err := a.client.callAPI(req) - if err != nil || localVarHTTPResponse == nil { - return localVarHTTPResponse, err - } - - localVarBody, err := io.ReadAll(localVarHTTPResponse.Body) - localVarHTTPResponse.Body.Close() - localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody)) - if err != nil { - return localVarHTTPResponse, err - } - - if localVarHTTPResponse.StatusCode >= 300 { - newErr := &GenericOpenAPIError{ - body: localVarBody, - error: localVarHTTPResponse.Status, - } - return localVarHTTPResponse, newErr - } - - return localVarHTTPResponse, nil -} - -type ApiPlugPlugTypeTaskIdGetRequest struct { - ctx context.Context - ApiService *PlugAPIService - plugType string - taskId string -} - -func (r ApiPlugPlugTypeTaskIdGetRequest) Execute() (*http.Response, error) { - return r.ApiService.PlugPlugTypeTaskIdGetExecute(r) -} - -/* -PlugPlugTypeTaskIdGet Retrieves the status of a specific task type - -Retrieves the status of a specific task and returns it. - - @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). - @param plugType supported plug type - @param taskId id of task - @return ApiPlugPlugTypeTaskIdGetRequest -*/ -func (a *PlugAPIService) PlugPlugTypeTaskIdGet(ctx context.Context, plugType string, taskId string) ApiPlugPlugTypeTaskIdGetRequest { - return ApiPlugPlugTypeTaskIdGetRequest{ - ApiService: a, - ctx: ctx, - plugType: plugType, - taskId: taskId, - } -} - -// Execute executes the request -func (a *PlugAPIService) PlugPlugTypeTaskIdGetExecute(r ApiPlugPlugTypeTaskIdGetRequest) (*http.Response, error) { - var ( - localVarHTTPMethod = http.MethodGet - localVarPostBody interface{} - formFiles []formFile - ) - - localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "PlugAPIService.PlugPlugTypeTaskIdGet") - if err != nil { - return nil, &GenericOpenAPIError{error: err.Error()} - } - - localVarPath := localBasePath + "/plug/{plug_type}/{task_id}" - localVarPath = strings.Replace(localVarPath, "{"+"plug_type"+"}", url.PathEscape(parameterValueToString(r.plugType, "plugType")), -1) - localVarPath = strings.Replace(localVarPath, "{"+"task_id"+"}", url.PathEscape(parameterValueToString(r.taskId, "taskId")), -1) - - localVarHeaderParams := make(map[string]string) - localVarQueryParams := url.Values{} - localVarFormParams := url.Values{} - - // to determine the Content-Type header - localVarHTTPContentTypes := []string{} - - // set Content-Type header - localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes) - if localVarHTTPContentType != "" { - localVarHeaderParams["Content-Type"] = localVarHTTPContentType - } - - // to determine the Accept header - localVarHTTPHeaderAccepts := []string{} - - // set Accept header - localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts) - if localVarHTTPHeaderAccept != "" { - localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept - } - req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles) - if err != nil { - return nil, err - } - - localVarHTTPResponse, err := a.client.callAPI(req) - if err != nil || localVarHTTPResponse == nil { - return localVarHTTPResponse, err - } - - localVarBody, err := io.ReadAll(localVarHTTPResponse.Body) - localVarHTTPResponse.Body.Close() - localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody)) - if err != nil { - return localVarHTTPResponse, err - } - - if localVarHTTPResponse.StatusCode >= 300 { - newErr := &GenericOpenAPIError{ - body: localVarBody, - error: localVarHTTPResponse.Status, - } - return localVarHTTPResponse, newErr - } - - return localVarHTTPResponse, nil -} diff --git a/api_user_source.go b/api_user_source.go new file mode 100644 index 0000000..6fee609 --- /dev/null +++ b/api_user_source.go @@ -0,0 +1,383 @@ +/* +Anthrove Orchestrator API + +This service handles the communication between the manager and the plugs + +API version: 1.0 +Contact: support@anthrove.art +*/ + +// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT. + +package openapi + +import ( + "bytes" + "context" + "io/ioutil" + "net/http" + "net/url" + "strings" +) + +// UserSourceApiService UserSourceApi service +type UserSourceApiService service + +type ApiPlugTaskPlugIdentifierPostRequest struct { + ctx context.Context + ApiService *UserSourceApiService + plugIdentifier string + task *TaskStartTask +} + +// Task Details +func (r ApiPlugTaskPlugIdentifierPostRequest) Task(task TaskStartTask) ApiPlugTaskPlugIdentifierPostRequest { + r.task = &task + return r +} + +func (r ApiPlugTaskPlugIdentifierPostRequest) Execute() (*TaskResponse, *http.Response, error) { + return r.ApiService.PlugTaskPlugIdentifierPostExecute(r) +} + +/* +PlugTaskPlugIdentifierPost Start a plug task + +Starts a task for the specified plug + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param plugIdentifier Plug Identifier + @return ApiPlugTaskPlugIdentifierPostRequest +*/ +func (a *UserSourceApiService) PlugTaskPlugIdentifierPost(ctx context.Context, plugIdentifier string) ApiPlugTaskPlugIdentifierPostRequest { + return ApiPlugTaskPlugIdentifierPostRequest{ + ApiService: a, + ctx: ctx, + plugIdentifier: plugIdentifier, + } +} + +// Execute executes the request +// +// @return TaskResponse +func (a *UserSourceApiService) PlugTaskPlugIdentifierPostExecute(r ApiPlugTaskPlugIdentifierPostRequest) (*TaskResponse, *http.Response, error) { + var ( + localVarHTTPMethod = http.MethodPost + localVarPostBody interface{} + formFiles []formFile + localVarReturnValue *TaskResponse + ) + + localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "UserSourceApiService.PlugTaskPlugIdentifierPost") + if err != nil { + return localVarReturnValue, nil, &GenericOpenAPIError{error: err.Error()} + } + + localVarPath := localBasePath + "/plug/task/{plug_identifier}" + localVarPath = strings.Replace(localVarPath, "{"+"plug_identifier"+"}", url.PathEscape(parameterToString(r.plugIdentifier, "")), -1) + + localVarHeaderParams := make(map[string]string) + localVarQueryParams := url.Values{} + localVarFormParams := url.Values{} + if r.task == nil { + return localVarReturnValue, nil, reportError("task is required and must be specified") + } + + // to determine the Content-Type header + localVarHTTPContentTypes := []string{} + + // set Content-Type header + localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes) + if localVarHTTPContentType != "" { + localVarHeaderParams["Content-Type"] = localVarHTTPContentType + } + + // to determine the Accept header + localVarHTTPHeaderAccepts := []string{"*/*"} + + // set Accept header + localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts) + if localVarHTTPHeaderAccept != "" { + localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept + } + // body params + localVarPostBody = r.task + req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles) + if err != nil { + return localVarReturnValue, nil, err + } + + localVarHTTPResponse, err := a.client.callAPI(req) + if err != nil || localVarHTTPResponse == nil { + return localVarReturnValue, localVarHTTPResponse, err + } + + localVarBody, err := ioutil.ReadAll(localVarHTTPResponse.Body) + localVarHTTPResponse.Body.Close() + localVarHTTPResponse.Body = ioutil.NopCloser(bytes.NewBuffer(localVarBody)) + if err != nil { + return localVarReturnValue, localVarHTTPResponse, err + } + + if localVarHTTPResponse.StatusCode >= 300 { + newErr := &GenericOpenAPIError{ + body: localVarBody, + error: localVarHTTPResponse.Status, + } + if localVarHTTPResponse.StatusCode == 400 { + var v map[string]map[string]interface{} + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.error = err.Error() + return localVarReturnValue, localVarHTTPResponse, newErr + } + newErr.model = v + } + return localVarReturnValue, localVarHTTPResponse, newErr + } + + err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr := &GenericOpenAPIError{ + body: localVarBody, + error: err.Error(), + } + return localVarReturnValue, localVarHTTPResponse, newErr + } + + return localVarReturnValue, localVarHTTPResponse, nil +} + +type ApiPlugTaskPlugIdentifierTaskIdDeleteRequest struct { + ctx context.Context + ApiService *UserSourceApiService + plugIdentifier string + taskId string +} + +func (r ApiPlugTaskPlugIdentifierTaskIdDeleteRequest) Execute() (*TaskResponse, *http.Response, error) { + return r.ApiService.PlugTaskPlugIdentifierTaskIdDeleteExecute(r) +} + +/* +PlugTaskPlugIdentifierTaskIdDelete Stop a plug task + +Stops a task for the specified plug + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param plugIdentifier Plug Identifier + @param taskId Task ID + @return ApiPlugTaskPlugIdentifierTaskIdDeleteRequest +*/ +func (a *UserSourceApiService) PlugTaskPlugIdentifierTaskIdDelete(ctx context.Context, plugIdentifier string, taskId string) ApiPlugTaskPlugIdentifierTaskIdDeleteRequest { + return ApiPlugTaskPlugIdentifierTaskIdDeleteRequest{ + ApiService: a, + ctx: ctx, + plugIdentifier: plugIdentifier, + taskId: taskId, + } +} + +// Execute executes the request +// +// @return TaskResponse +func (a *UserSourceApiService) PlugTaskPlugIdentifierTaskIdDeleteExecute(r ApiPlugTaskPlugIdentifierTaskIdDeleteRequest) (*TaskResponse, *http.Response, error) { + var ( + localVarHTTPMethod = http.MethodDelete + localVarPostBody interface{} + formFiles []formFile + localVarReturnValue *TaskResponse + ) + + localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "UserSourceApiService.PlugTaskPlugIdentifierTaskIdDelete") + if err != nil { + return localVarReturnValue, nil, &GenericOpenAPIError{error: err.Error()} + } + + localVarPath := localBasePath + "/plug/task/{plug_identifier}/{task_id}" + localVarPath = strings.Replace(localVarPath, "{"+"plug_identifier"+"}", url.PathEscape(parameterToString(r.plugIdentifier, "")), -1) + localVarPath = strings.Replace(localVarPath, "{"+"task_id"+"}", url.PathEscape(parameterToString(r.taskId, "")), -1) + + localVarHeaderParams := make(map[string]string) + localVarQueryParams := url.Values{} + localVarFormParams := url.Values{} + + // to determine the Content-Type header + localVarHTTPContentTypes := []string{} + + // set Content-Type header + localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes) + if localVarHTTPContentType != "" { + localVarHeaderParams["Content-Type"] = localVarHTTPContentType + } + + // to determine the Accept header + localVarHTTPHeaderAccepts := []string{"*/*"} + + // set Accept header + localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts) + if localVarHTTPHeaderAccept != "" { + localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept + } + req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles) + if err != nil { + return localVarReturnValue, nil, err + } + + localVarHTTPResponse, err := a.client.callAPI(req) + if err != nil || localVarHTTPResponse == nil { + return localVarReturnValue, localVarHTTPResponse, err + } + + localVarBody, err := ioutil.ReadAll(localVarHTTPResponse.Body) + localVarHTTPResponse.Body.Close() + localVarHTTPResponse.Body = ioutil.NopCloser(bytes.NewBuffer(localVarBody)) + if err != nil { + return localVarReturnValue, localVarHTTPResponse, err + } + + if localVarHTTPResponse.StatusCode >= 300 { + newErr := &GenericOpenAPIError{ + body: localVarBody, + error: localVarHTTPResponse.Status, + } + if localVarHTTPResponse.StatusCode == 400 { + var v map[string]map[string]interface{} + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.error = err.Error() + return localVarReturnValue, localVarHTTPResponse, newErr + } + newErr.model = v + } + return localVarReturnValue, localVarHTTPResponse, newErr + } + + err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr := &GenericOpenAPIError{ + body: localVarBody, + error: err.Error(), + } + return localVarReturnValue, localVarHTTPResponse, newErr + } + + return localVarReturnValue, localVarHTTPResponse, nil +} + +type ApiPlugTaskPlugIdentifierTaskIdGetRequest struct { + ctx context.Context + ApiService *UserSourceApiService + plugIdentifier string + taskId string +} + +func (r ApiPlugTaskPlugIdentifierTaskIdGetRequest) Execute() (*TaskResponse, *http.Response, error) { + return r.ApiService.PlugTaskPlugIdentifierTaskIdGetExecute(r) +} + +/* +PlugTaskPlugIdentifierTaskIdGet Gets the status of a plug task + +Retrieves the status of a task for the specified plug + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param plugIdentifier Plug Identifier + @param taskId Task ID + @return ApiPlugTaskPlugIdentifierTaskIdGetRequest +*/ +func (a *UserSourceApiService) PlugTaskPlugIdentifierTaskIdGet(ctx context.Context, plugIdentifier string, taskId string) ApiPlugTaskPlugIdentifierTaskIdGetRequest { + return ApiPlugTaskPlugIdentifierTaskIdGetRequest{ + ApiService: a, + ctx: ctx, + plugIdentifier: plugIdentifier, + taskId: taskId, + } +} + +// Execute executes the request +// +// @return TaskResponse +func (a *UserSourceApiService) PlugTaskPlugIdentifierTaskIdGetExecute(r ApiPlugTaskPlugIdentifierTaskIdGetRequest) (*TaskResponse, *http.Response, error) { + var ( + localVarHTTPMethod = http.MethodGet + localVarPostBody interface{} + formFiles []formFile + localVarReturnValue *TaskResponse + ) + + localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "UserSourceApiService.PlugTaskPlugIdentifierTaskIdGet") + if err != nil { + return localVarReturnValue, nil, &GenericOpenAPIError{error: err.Error()} + } + + localVarPath := localBasePath + "/plug/task/{plug_identifier}/{task_id}" + localVarPath = strings.Replace(localVarPath, "{"+"plug_identifier"+"}", url.PathEscape(parameterToString(r.plugIdentifier, "")), -1) + localVarPath = strings.Replace(localVarPath, "{"+"task_id"+"}", url.PathEscape(parameterToString(r.taskId, "")), -1) + + localVarHeaderParams := make(map[string]string) + localVarQueryParams := url.Values{} + localVarFormParams := url.Values{} + + // to determine the Content-Type header + localVarHTTPContentTypes := []string{} + + // set Content-Type header + localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes) + if localVarHTTPContentType != "" { + localVarHeaderParams["Content-Type"] = localVarHTTPContentType + } + + // to determine the Accept header + localVarHTTPHeaderAccepts := []string{"*/*"} + + // set Accept header + localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts) + if localVarHTTPHeaderAccept != "" { + localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept + } + req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles) + if err != nil { + return localVarReturnValue, nil, err + } + + localVarHTTPResponse, err := a.client.callAPI(req) + if err != nil || localVarHTTPResponse == nil { + return localVarReturnValue, localVarHTTPResponse, err + } + + localVarBody, err := ioutil.ReadAll(localVarHTTPResponse.Body) + localVarHTTPResponse.Body.Close() + localVarHTTPResponse.Body = ioutil.NopCloser(bytes.NewBuffer(localVarBody)) + if err != nil { + return localVarReturnValue, localVarHTTPResponse, err + } + + if localVarHTTPResponse.StatusCode >= 300 { + newErr := &GenericOpenAPIError{ + body: localVarBody, + error: localVarHTTPResponse.Status, + } + if localVarHTTPResponse.StatusCode == 400 { + var v map[string]map[string]interface{} + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.error = err.Error() + return localVarReturnValue, localVarHTTPResponse, newErr + } + newErr.model = v + } + return localVarReturnValue, localVarHTTPResponse, newErr + } + + err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr := &GenericOpenAPIError{ + body: localVarBody, + error: err.Error(), + } + return localVarReturnValue, localVarHTTPResponse, newErr + } + + return localVarReturnValue, localVarHTTPResponse, nil +} diff --git a/docs/ModelsOrchestratorTask.md b/docs/ModelsOrchestratorTask.md deleted file mode 100644 index c81bbe0..0000000 --- a/docs/ModelsOrchestratorTask.md +++ /dev/null @@ -1,93 +0,0 @@ -# ModelsOrchestratorTask - -## Properties - -Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- -**AnthroveUserId** | **string** | | -**DeepScrape** | **bool** | | -**PlugTask** | [**ModelsPlugTask**](ModelsPlugTask.md) | | - -## Methods - -### NewModelsOrchestratorTask - -`func NewModelsOrchestratorTask(anthroveUserId string, deepScrape bool, plugTask ModelsPlugTask, ) *ModelsOrchestratorTask` - -NewModelsOrchestratorTask instantiates a new ModelsOrchestratorTask object -This constructor will assign default values to properties that have it defined, -and makes sure properties required by API are set, but the set of arguments -will change when the set of required properties is changed - -### NewModelsOrchestratorTaskWithDefaults - -`func NewModelsOrchestratorTaskWithDefaults() *ModelsOrchestratorTask` - -NewModelsOrchestratorTaskWithDefaults instantiates a new ModelsOrchestratorTask object -This constructor will only assign default values to properties that have it defined, -but it doesn't guarantee that properties required by API are set - -### GetAnthroveUserId - -`func (o *ModelsOrchestratorTask) GetAnthroveUserId() string` - -GetAnthroveUserId returns the AnthroveUserId field if non-nil, zero value otherwise. - -### GetAnthroveUserIdOk - -`func (o *ModelsOrchestratorTask) GetAnthroveUserIdOk() (*string, bool)` - -GetAnthroveUserIdOk returns a tuple with the AnthroveUserId field if it's non-nil, zero value otherwise -and a boolean to check if the value has been set. - -### SetAnthroveUserId - -`func (o *ModelsOrchestratorTask) SetAnthroveUserId(v string)` - -SetAnthroveUserId sets AnthroveUserId field to given value. - - -### GetDeepScrape - -`func (o *ModelsOrchestratorTask) GetDeepScrape() bool` - -GetDeepScrape returns the DeepScrape field if non-nil, zero value otherwise. - -### GetDeepScrapeOk - -`func (o *ModelsOrchestratorTask) GetDeepScrapeOk() (*bool, bool)` - -GetDeepScrapeOk returns a tuple with the DeepScrape field if it's non-nil, zero value otherwise -and a boolean to check if the value has been set. - -### SetDeepScrape - -`func (o *ModelsOrchestratorTask) SetDeepScrape(v bool)` - -SetDeepScrape sets DeepScrape field to given value. - - -### GetPlugTask - -`func (o *ModelsOrchestratorTask) GetPlugTask() ModelsPlugTask` - -GetPlugTask returns the PlugTask field if non-nil, zero value otherwise. - -### GetPlugTaskOk - -`func (o *ModelsOrchestratorTask) GetPlugTaskOk() (*ModelsPlugTask, bool)` - -GetPlugTaskOk returns a tuple with the PlugTask field if it's non-nil, zero value otherwise -and a boolean to check if the value has been set. - -### SetPlugTask - -`func (o *ModelsOrchestratorTask) SetPlugTask(v ModelsPlugTask)` - -SetPlugTask sets PlugTask field to given value. - - - -[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md) - - diff --git a/docs/ModelsPlugTask.md b/docs/ModelsPlugTask.md deleted file mode 100644 index 0707ecf..0000000 --- a/docs/ModelsPlugTask.md +++ /dev/null @@ -1,103 +0,0 @@ -# ModelsPlugTask - -## Properties - -Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- -**Id** | Pointer to **string** | | [optional] -**TaskState** | Pointer to [**ModelsPlugTaskState**](ModelsPlugTaskState.md) | | [optional] -**UserId** | **string** | | - -## Methods - -### NewModelsPlugTask - -`func NewModelsPlugTask(userId string, ) *ModelsPlugTask` - -NewModelsPlugTask instantiates a new ModelsPlugTask object -This constructor will assign default values to properties that have it defined, -and makes sure properties required by API are set, but the set of arguments -will change when the set of required properties is changed - -### NewModelsPlugTaskWithDefaults - -`func NewModelsPlugTaskWithDefaults() *ModelsPlugTask` - -NewModelsPlugTaskWithDefaults instantiates a new ModelsPlugTask object -This constructor will only assign default values to properties that have it defined, -but it doesn't guarantee that properties required by API are set - -### GetId - -`func (o *ModelsPlugTask) GetId() string` - -GetId returns the Id field if non-nil, zero value otherwise. - -### GetIdOk - -`func (o *ModelsPlugTask) GetIdOk() (*string, bool)` - -GetIdOk returns a tuple with the Id field if it's non-nil, zero value otherwise -and a boolean to check if the value has been set. - -### SetId - -`func (o *ModelsPlugTask) SetId(v string)` - -SetId sets Id field to given value. - -### HasId - -`func (o *ModelsPlugTask) HasId() bool` - -HasId returns a boolean if a field has been set. - -### GetTaskState - -`func (o *ModelsPlugTask) GetTaskState() ModelsPlugTaskState` - -GetTaskState returns the TaskState field if non-nil, zero value otherwise. - -### GetTaskStateOk - -`func (o *ModelsPlugTask) GetTaskStateOk() (*ModelsPlugTaskState, bool)` - -GetTaskStateOk returns a tuple with the TaskState field if it's non-nil, zero value otherwise -and a boolean to check if the value has been set. - -### SetTaskState - -`func (o *ModelsPlugTask) SetTaskState(v ModelsPlugTaskState)` - -SetTaskState sets TaskState field to given value. - -### HasTaskState - -`func (o *ModelsPlugTask) HasTaskState() bool` - -HasTaskState returns a boolean if a field has been set. - -### GetUserId - -`func (o *ModelsPlugTask) GetUserId() string` - -GetUserId returns the UserId field if non-nil, zero value otherwise. - -### GetUserIdOk - -`func (o *ModelsPlugTask) GetUserIdOk() (*string, bool)` - -GetUserIdOk returns a tuple with the UserId field if it's non-nil, zero value otherwise -and a boolean to check if the value has been set. - -### SetUserId - -`func (o *ModelsPlugTask) SetUserId(v string)` - -SetUserId sets UserId field to given value. - - - -[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md) - - diff --git a/docs/ModelsPlugTaskState.md b/docs/ModelsPlugTaskState.md deleted file mode 100644 index a6859e5..0000000 --- a/docs/ModelsPlugTaskState.md +++ /dev/null @@ -1,17 +0,0 @@ -# ModelsPlugTaskState - -## Enum - - -* `PlugTaskStateUnknown` (value: `"UNKNOWN"`) - -* `PlugTaskStateStarted` (value: `"STARTED"`) - -* `PlugTaskStateRunning` (value: `"RUNNING"`) - -* `PlugTaskStateStopped` (value: `"STOPPED"`) - - -[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md) - - diff --git a/docs/PlugAPI.md b/docs/PlugAPI.md deleted file mode 100644 index 010d9c1..0000000 --- a/docs/PlugAPI.md +++ /dev/null @@ -1,223 +0,0 @@ -# \PlugAPI - -All URIs are relative to */api/v1* - -Method | HTTP request | Description -------------- | ------------- | ------------- -[**PlugPlugTypePut**](PlugAPI.md#PlugPlugTypePut) | **Put** /plug/{plug_type} | Initiates a scraping operation for a user with a specific plug type -[**PlugPlugTypeTaskIdDelete**](PlugAPI.md#PlugPlugTypeTaskIdDelete) | **Delete** /plug/{plug_type}/{task_id} | Stops a scraping operation for a user with a specific plug type -[**PlugPlugTypeTaskIdGet**](PlugAPI.md#PlugPlugTypeTaskIdGet) | **Get** /plug/{plug_type}/{task_id} | Retrieves the status of a specific task type - - - -## PlugPlugTypePut - -> PlugPlugTypePut(ctx, plugType).Request(request).Execute() - -Initiates a scraping operation for a user with a specific plug type - - - -### Example - -```go -package main - -import ( - "context" - "fmt" - "os" - openapiclient "git.anthrove.art/Anthrove/orchestrator-swagger-go-client/v1" -) - -func main() { - plugType := "plugType_example" // string | supported plug type - request := *openapiclient.NewModelsOrchestratorTask("AnthroveUserId_example", false, *openapiclient.NewModelsPlugTask("UserId_example")) // ModelsOrchestratorTask | aa - - configuration := openapiclient.NewConfiguration() - apiClient := openapiclient.NewAPIClient(configuration) - r, err := apiClient.PlugAPI.PlugPlugTypePut(context.Background(), plugType).Request(request).Execute() - if err != nil { - fmt.Fprintf(os.Stderr, "Error when calling `PlugAPI.PlugPlugTypePut``: %v\n", err) - fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r) - } -} -``` - -### Path Parameters - - -Name | Type | Description | Notes -------------- | ------------- | ------------- | ------------- -**ctx** | **context.Context** | context for authentication, logging, cancellation, deadlines, tracing, etc. -**plugType** | **string** | supported plug type | - -### Other Parameters - -Other parameters are passed through a pointer to a apiPlugPlugTypePutRequest struct via the builder pattern - - -Name | Type | Description | Notes -------------- | ------------- | ------------- | ------------- - - **request** | [**ModelsOrchestratorTask**](ModelsOrchestratorTask.md) | aa | - -### Return type - - (empty response body) - -### Authorization - -No authorization required - -### HTTP request headers - -- **Content-Type**: application/json -- **Accept**: Not defined - -[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) -[[Back to Model list]](../README.md#documentation-for-models) -[[Back to README]](../README.md) - - -## PlugPlugTypeTaskIdDelete - -> PlugPlugTypeTaskIdDelete(ctx, plugType, taskId).Execute() - -Stops a scraping operation for a user with a specific plug type - - - -### Example - -```go -package main - -import ( - "context" - "fmt" - "os" - openapiclient "git.anthrove.art/Anthrove/orchestrator-swagger-go-client/v1" -) - -func main() { - plugType := "plugType_example" // string | supported plug type - taskId := "taskId_example" // string | id of task - - configuration := openapiclient.NewConfiguration() - apiClient := openapiclient.NewAPIClient(configuration) - r, err := apiClient.PlugAPI.PlugPlugTypeTaskIdDelete(context.Background(), plugType, taskId).Execute() - if err != nil { - fmt.Fprintf(os.Stderr, "Error when calling `PlugAPI.PlugPlugTypeTaskIdDelete``: %v\n", err) - fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r) - } -} -``` - -### Path Parameters - - -Name | Type | Description | Notes -------------- | ------------- | ------------- | ------------- -**ctx** | **context.Context** | context for authentication, logging, cancellation, deadlines, tracing, etc. -**plugType** | **string** | supported plug type | -**taskId** | **string** | id of task | - -### Other Parameters - -Other parameters are passed through a pointer to a apiPlugPlugTypeTaskIdDeleteRequest struct via the builder pattern - - -Name | Type | Description | Notes -------------- | ------------- | ------------- | ------------- - - - -### Return type - - (empty response body) - -### Authorization - -No authorization required - -### HTTP request headers - -- **Content-Type**: Not defined -- **Accept**: Not defined - -[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) -[[Back to Model list]](../README.md#documentation-for-models) -[[Back to README]](../README.md) - - -## PlugPlugTypeTaskIdGet - -> PlugPlugTypeTaskIdGet(ctx, plugType, taskId).Execute() - -Retrieves the status of a specific task type - - - -### Example - -```go -package main - -import ( - "context" - "fmt" - "os" - openapiclient "git.anthrove.art/Anthrove/orchestrator-swagger-go-client/v1" -) - -func main() { - plugType := "plugType_example" // string | supported plug type - taskId := "taskId_example" // string | id of task - - configuration := openapiclient.NewConfiguration() - apiClient := openapiclient.NewAPIClient(configuration) - r, err := apiClient.PlugAPI.PlugPlugTypeTaskIdGet(context.Background(), plugType, taskId).Execute() - if err != nil { - fmt.Fprintf(os.Stderr, "Error when calling `PlugAPI.PlugPlugTypeTaskIdGet``: %v\n", err) - fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r) - } -} -``` - -### Path Parameters - - -Name | Type | Description | Notes -------------- | ------------- | ------------- | ------------- -**ctx** | **context.Context** | context for authentication, logging, cancellation, deadlines, tracing, etc. -**plugType** | **string** | supported plug type | -**taskId** | **string** | id of task | - -### Other Parameters - -Other parameters are passed through a pointer to a apiPlugPlugTypeTaskIdGetRequest struct via the builder pattern - - -Name | Type | Description | Notes -------------- | ------------- | ------------- | ------------- - - - -### Return type - - (empty response body) - -### Authorization - -No authorization required - -### HTTP request headers - -- **Content-Type**: Not defined -- **Accept**: Not defined - -[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) -[[Back to Model list]](../README.md#documentation-for-models) -[[Back to README]](../README.md) - diff --git a/docs/TaskResponse.md b/docs/TaskResponse.md new file mode 100644 index 0000000..6d648df --- /dev/null +++ b/docs/TaskResponse.md @@ -0,0 +1,82 @@ +# TaskResponse + +## Properties + +Name | Type | Description | Notes +------------ | ------------- | ------------- | ------------- +**PlugTaskId** | Pointer to **string** | | [optional] +**PlugTaskStatus** | Pointer to **string** | | [optional] + +## Methods + +### NewTaskResponse + +`func NewTaskResponse() *TaskResponse` + +NewTaskResponse instantiates a new TaskResponse object +This constructor will assign default values to properties that have it defined, +and makes sure properties required by API are set, but the set of arguments +will change when the set of required properties is changed + +### NewTaskResponseWithDefaults + +`func NewTaskResponseWithDefaults() *TaskResponse` + +NewTaskResponseWithDefaults instantiates a new TaskResponse object +This constructor will only assign default values to properties that have it defined, +but it doesn't guarantee that properties required by API are set + +### GetPlugTaskId + +`func (o *TaskResponse) GetPlugTaskId() string` + +GetPlugTaskId returns the PlugTaskId field if non-nil, zero value otherwise. + +### GetPlugTaskIdOk + +`func (o *TaskResponse) GetPlugTaskIdOk() (*string, bool)` + +GetPlugTaskIdOk returns a tuple with the PlugTaskId field if it's non-nil, zero value otherwise +and a boolean to check if the value has been set. + +### SetPlugTaskId + +`func (o *TaskResponse) SetPlugTaskId(v string)` + +SetPlugTaskId sets PlugTaskId field to given value. + +### HasPlugTaskId + +`func (o *TaskResponse) HasPlugTaskId() bool` + +HasPlugTaskId returns a boolean if a field has been set. + +### GetPlugTaskStatus + +`func (o *TaskResponse) GetPlugTaskStatus() string` + +GetPlugTaskStatus returns the PlugTaskStatus field if non-nil, zero value otherwise. + +### GetPlugTaskStatusOk + +`func (o *TaskResponse) GetPlugTaskStatusOk() (*string, bool)` + +GetPlugTaskStatusOk returns a tuple with the PlugTaskStatus field if it's non-nil, zero value otherwise +and a boolean to check if the value has been set. + +### SetPlugTaskStatus + +`func (o *TaskResponse) SetPlugTaskStatus(v string)` + +SetPlugTaskStatus sets PlugTaskStatus field to given value. + +### HasPlugTaskStatus + +`func (o *TaskResponse) HasPlugTaskStatus() bool` + +HasPlugTaskStatus returns a boolean if a field has been set. + + +[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md) + + diff --git a/docs/TaskStartTask.md b/docs/TaskStartTask.md new file mode 100644 index 0000000..65160b1 --- /dev/null +++ b/docs/TaskStartTask.md @@ -0,0 +1,108 @@ +# TaskStartTask + +## Properties + +Name | Type | Description | Notes +------------ | ------------- | ------------- | ------------- +**UserApiKey** | Pointer to **string** | | [optional] +**UserId** | Pointer to **string** | | [optional] +**UserSourceId** | Pointer to **string** | | [optional] + +## Methods + +### NewTaskStartTask + +`func NewTaskStartTask() *TaskStartTask` + +NewTaskStartTask instantiates a new TaskStartTask object +This constructor will assign default values to properties that have it defined, +and makes sure properties required by API are set, but the set of arguments +will change when the set of required properties is changed + +### NewTaskStartTaskWithDefaults + +`func NewTaskStartTaskWithDefaults() *TaskStartTask` + +NewTaskStartTaskWithDefaults instantiates a new TaskStartTask object +This constructor will only assign default values to properties that have it defined, +but it doesn't guarantee that properties required by API are set + +### GetUserApiKey + +`func (o *TaskStartTask) GetUserApiKey() string` + +GetUserApiKey returns the UserApiKey field if non-nil, zero value otherwise. + +### GetUserApiKeyOk + +`func (o *TaskStartTask) GetUserApiKeyOk() (*string, bool)` + +GetUserApiKeyOk returns a tuple with the UserApiKey field if it's non-nil, zero value otherwise +and a boolean to check if the value has been set. + +### SetUserApiKey + +`func (o *TaskStartTask) SetUserApiKey(v string)` + +SetUserApiKey sets UserApiKey field to given value. + +### HasUserApiKey + +`func (o *TaskStartTask) HasUserApiKey() bool` + +HasUserApiKey returns a boolean if a field has been set. + +### GetUserId + +`func (o *TaskStartTask) GetUserId() string` + +GetUserId returns the UserId field if non-nil, zero value otherwise. + +### GetUserIdOk + +`func (o *TaskStartTask) GetUserIdOk() (*string, bool)` + +GetUserIdOk returns a tuple with the UserId field if it's non-nil, zero value otherwise +and a boolean to check if the value has been set. + +### SetUserId + +`func (o *TaskStartTask) SetUserId(v string)` + +SetUserId sets UserId field to given value. + +### HasUserId + +`func (o *TaskStartTask) HasUserId() bool` + +HasUserId returns a boolean if a field has been set. + +### GetUserSourceId + +`func (o *TaskStartTask) GetUserSourceId() string` + +GetUserSourceId returns the UserSourceId field if non-nil, zero value otherwise. + +### GetUserSourceIdOk + +`func (o *TaskStartTask) GetUserSourceIdOk() (*string, bool)` + +GetUserSourceIdOk returns a tuple with the UserSourceId field if it's non-nil, zero value otherwise +and a boolean to check if the value has been set. + +### SetUserSourceId + +`func (o *TaskStartTask) SetUserSourceId(v string)` + +SetUserSourceId sets UserSourceId field to given value. + +### HasUserSourceId + +`func (o *TaskStartTask) HasUserSourceId() bool` + +HasUserSourceId returns a boolean if a field has been set. + + +[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md) + + diff --git a/docs/UserAPI.md b/docs/UserApi.md similarity index 100% rename from docs/UserAPI.md rename to docs/UserApi.md diff --git a/docs/UserSourceApi.md b/docs/UserSourceApi.md new file mode 100644 index 0000000..bd0d3a8 --- /dev/null +++ b/docs/UserSourceApi.md @@ -0,0 +1,229 @@ +# \UserSourceApi + +All URIs are relative to */api/v1* + +Method | HTTP request | Description +------------- | ------------- | ------------- +[**PlugTaskPlugIdentifierPost**](UserSourceApi.md#PlugTaskPlugIdentifierPost) | **Post** /plug/task/{plug_identifier} | Start a plug task +[**PlugTaskPlugIdentifierTaskIdDelete**](UserSourceApi.md#PlugTaskPlugIdentifierTaskIdDelete) | **Delete** /plug/task/{plug_identifier}/{task_id} | Stop a plug task +[**PlugTaskPlugIdentifierTaskIdGet**](UserSourceApi.md#PlugTaskPlugIdentifierTaskIdGet) | **Get** /plug/task/{plug_identifier}/{task_id} | Gets the status of a plug task + + + +## PlugTaskPlugIdentifierPost + +> TaskResponse PlugTaskPlugIdentifierPost(ctx, plugIdentifier).Task(task).Execute() + +Start a plug task + + + +### Example + +```go +package main + +import ( + "context" + "fmt" + "os" + openapiclient "./openapi" +) + +func main() { + plugIdentifier := "plugIdentifier_example" // string | Plug Identifier + task := *openapiclient.NewTaskStartTask() // TaskStartTask | Task Details + + configuration := openapiclient.NewConfiguration() + apiClient := openapiclient.NewAPIClient(configuration) + resp, r, err := apiClient.UserSourceApi.PlugTaskPlugIdentifierPost(context.Background(), plugIdentifier).Task(task).Execute() + if err != nil { + fmt.Fprintf(os.Stderr, "Error when calling `UserSourceApi.PlugTaskPlugIdentifierPost``: %v\n", err) + fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r) + } + // response from `PlugTaskPlugIdentifierPost`: TaskResponse + fmt.Fprintf(os.Stdout, "Response from `UserSourceApi.PlugTaskPlugIdentifierPost`: %v\n", resp) +} +``` + +### Path Parameters + + +Name | Type | Description | Notes +------------- | ------------- | ------------- | ------------- +**ctx** | **context.Context** | context for authentication, logging, cancellation, deadlines, tracing, etc. +**plugIdentifier** | **string** | Plug Identifier | + +### Other Parameters + +Other parameters are passed through a pointer to a apiPlugTaskPlugIdentifierPostRequest struct via the builder pattern + + +Name | Type | Description | Notes +------------- | ------------- | ------------- | ------------- + + **task** | [**TaskStartTask**](TaskStartTask.md) | Task Details | + +### Return type + +[**TaskResponse**](TaskResponse.md) + +### Authorization + +No authorization required + +### HTTP request headers + +- **Content-Type**: Not defined +- **Accept**: */* + +[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) +[[Back to Model list]](../README.md#documentation-for-models) +[[Back to README]](../README.md) + + +## PlugTaskPlugIdentifierTaskIdDelete + +> TaskResponse PlugTaskPlugIdentifierTaskIdDelete(ctx, plugIdentifier, taskId).Execute() + +Stop a plug task + + + +### Example + +```go +package main + +import ( + "context" + "fmt" + "os" + openapiclient "./openapi" +) + +func main() { + plugIdentifier := "plugIdentifier_example" // string | Plug Identifier + taskId := "taskId_example" // string | Task ID + + configuration := openapiclient.NewConfiguration() + apiClient := openapiclient.NewAPIClient(configuration) + resp, r, err := apiClient.UserSourceApi.PlugTaskPlugIdentifierTaskIdDelete(context.Background(), plugIdentifier, taskId).Execute() + if err != nil { + fmt.Fprintf(os.Stderr, "Error when calling `UserSourceApi.PlugTaskPlugIdentifierTaskIdDelete``: %v\n", err) + fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r) + } + // response from `PlugTaskPlugIdentifierTaskIdDelete`: TaskResponse + fmt.Fprintf(os.Stdout, "Response from `UserSourceApi.PlugTaskPlugIdentifierTaskIdDelete`: %v\n", resp) +} +``` + +### Path Parameters + + +Name | Type | Description | Notes +------------- | ------------- | ------------- | ------------- +**ctx** | **context.Context** | context for authentication, logging, cancellation, deadlines, tracing, etc. +**plugIdentifier** | **string** | Plug Identifier | +**taskId** | **string** | Task ID | + +### Other Parameters + +Other parameters are passed through a pointer to a apiPlugTaskPlugIdentifierTaskIdDeleteRequest struct via the builder pattern + + +Name | Type | Description | Notes +------------- | ------------- | ------------- | ------------- + + + +### Return type + +[**TaskResponse**](TaskResponse.md) + +### Authorization + +No authorization required + +### HTTP request headers + +- **Content-Type**: Not defined +- **Accept**: */* + +[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) +[[Back to Model list]](../README.md#documentation-for-models) +[[Back to README]](../README.md) + + +## PlugTaskPlugIdentifierTaskIdGet + +> TaskResponse PlugTaskPlugIdentifierTaskIdGet(ctx, plugIdentifier, taskId).Execute() + +Gets the status of a plug task + + + +### Example + +```go +package main + +import ( + "context" + "fmt" + "os" + openapiclient "./openapi" +) + +func main() { + plugIdentifier := "plugIdentifier_example" // string | Plug Identifier + taskId := "taskId_example" // string | Task ID + + configuration := openapiclient.NewConfiguration() + apiClient := openapiclient.NewAPIClient(configuration) + resp, r, err := apiClient.UserSourceApi.PlugTaskPlugIdentifierTaskIdGet(context.Background(), plugIdentifier, taskId).Execute() + if err != nil { + fmt.Fprintf(os.Stderr, "Error when calling `UserSourceApi.PlugTaskPlugIdentifierTaskIdGet``: %v\n", err) + fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r) + } + // response from `PlugTaskPlugIdentifierTaskIdGet`: TaskResponse + fmt.Fprintf(os.Stdout, "Response from `UserSourceApi.PlugTaskPlugIdentifierTaskIdGet`: %v\n", resp) +} +``` + +### Path Parameters + + +Name | Type | Description | Notes +------------- | ------------- | ------------- | ------------- +**ctx** | **context.Context** | context for authentication, logging, cancellation, deadlines, tracing, etc. +**plugIdentifier** | **string** | Plug Identifier | +**taskId** | **string** | Task ID | + +### Other Parameters + +Other parameters are passed through a pointer to a apiPlugTaskPlugIdentifierTaskIdGetRequest struct via the builder pattern + + +Name | Type | Description | Notes +------------- | ------------- | ------------- | ------------- + + + +### Return type + +[**TaskResponse**](TaskResponse.md) + +### Authorization + +No authorization required + +### HTTP request headers + +- **Content-Type**: Not defined +- **Accept**: */* + +[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) +[[Back to Model list]](../README.md#documentation-for-models) +[[Back to README]](../README.md) + diff --git a/go.mod b/go.mod index ecfc49d..85b8044 100644 --- a/go.mod +++ b/go.mod @@ -1,8 +1,7 @@ -module git.anthrove.art/Anthrove/orchestrator-swagger-go-client/v1 +module git.anthrove.art/Anthrove/orchestrator-swagger-go-client go 1.13 require ( - github.com/stretchr/testify v1.4.0 golang.org/x/oauth2 v0.0.0-20210323180902-22b0adad7558 ) diff --git a/go.sum b/go.sum index 0d63dca..3dee6d6 100644 --- a/go.sum +++ b/go.sum @@ -39,7 +39,6 @@ github.com/chzyer/readline v0.0.0-20180603132655-2972be24d48e/go.mod h1:nSuG5e5P github.com/chzyer/test v0.0.0-20180213035817-a1ea475d72b1/go.mod h1:Q3SI9o4m/ZMnBNeIyt5eFwwo7qiLfzFZmjNmxjkiQlU= github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw= github.com/cncf/udpa/go v0.0.0-20191209042840-269d4d468f6f/go.mod h1:M8M6+tZqaGXZJjfX53e64911xZQV5JYwmTeXPW+k8Sc= -github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8= github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/envoyproxy/go-control-plane v0.9.0/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4= github.com/envoyproxy/go-control-plane v0.9.1-0.20191026205805-5f8ba28d4473/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4= @@ -59,6 +58,7 @@ github.com/golang/mock v1.4.0/go.mod h1:UOMv5ysSaYNkG+OFQykRIcU/QvvxJf3p21QfJ2Bt github.com/golang/mock v1.4.1/go.mod h1:UOMv5ysSaYNkG+OFQykRIcU/QvvxJf3p21QfJ2Bt3cw= github.com/golang/mock v1.4.3/go.mod h1:UOMv5ysSaYNkG+OFQykRIcU/QvvxJf3p21QfJ2Bt3cw= github.com/golang/mock v1.4.4/go.mod h1:l3mdAwkq5BuhzHwde/uurv3sEJeZMXNpwsxVWU71h+4= +github.com/golang/protobuf v1.2.0 h1:P3YflyNX/ehuJFLhxviNdFxQPkGK5cDcApsge1SqnvM= github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= github.com/golang/protobuf v1.3.1/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= github.com/golang/protobuf v1.3.2/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= @@ -71,7 +71,6 @@ github.com/golang/protobuf v1.4.0-rc.2/go.mod h1:LlEzMj4AhA7rCAGe4KMBDvJI+AwstrU github.com/golang/protobuf v1.4.0-rc.4.0.20200313231945-b860323f09d0/go.mod h1:WU3c8KckQ9AFe+yFwt9sWVRKCVIyN9cPHBJSNnbL67w= github.com/golang/protobuf v1.4.0/go.mod h1:jodUvKwWbYaEsadDk5Fwe5c77LiNKVO9IDvqG2KuDX0= github.com/golang/protobuf v1.4.1/go.mod h1:U8fpvMrcmy5pZrNK1lt4xCsGvpyWQ/VVv6QDs8UjoX8= -github.com/golang/protobuf v1.4.2 h1:+Z5KGCizgyZCbGh1KZqA0fcLLkwbsjIzS4aV2v7wJX0= github.com/golang/protobuf v1.4.2/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI= github.com/google/btree v0.0.0-20180813153112-4030bb1f1f0c/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ= github.com/google/btree v1.0.0/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ= @@ -81,7 +80,6 @@ github.com/google/go-cmp v0.3.1/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMyw github.com/google/go-cmp v0.4.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.4.1/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= -github.com/google/go-cmp v0.5.1 h1:JFrFEBb2xKufg6XkJsJr+WbKb4FQlURi5RUcBveYu9k= github.com/google/go-cmp v0.5.1/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/martian v2.1.0+incompatible/go.mod h1:9I4somxYTbIHy5NJKHRl3wXiIaQGbYVAs8BPL6v8lEs= github.com/google/martian/v3 v3.0.0/go.mod h1:y5Zk1BBys9G+gd6Jrk0W3cC1+ELVxBWuIGO+w/tUAp0= @@ -101,17 +99,13 @@ github.com/ianlancetaylor/demangle v0.0.0-20181102032728-5e5cf60278f6/go.mod h1: github.com/jstemmer/go-junit-report v0.0.0-20190106144839-af01ea7f8024/go.mod h1:6v2b51hI/fHJwM22ozAgKL4VKDeJcHhJFhtBdhmNjmU= github.com/jstemmer/go-junit-report v0.9.1/go.mod h1:Brl9GWCQeLvo8nXZwPNNblvFj/XSXhF0NWZEnDohbsk= github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck= -github.com/kr/pretty v0.1.0 h1:L/CwN0zerZDmRFUapSPitk6f+Q3+0za1rQkzVuMiMFI= github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo= github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ= -github.com/kr/text v0.1.0 h1:45sCR5RtlFHMR4UwH9sdQ5TC8v0qDQCHnXt+kaKSTVE= github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI= -github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA= github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4= github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= -github.com/stretchr/testify v1.4.0 h1:2E4SXV/wtOkTonXsotYi4li6zVWxYlZuYNCXe9XRJyk= github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4= github.com/yuin/goldmark v1.1.25/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74= github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74= @@ -158,6 +152,7 @@ golang.org/x/mod v0.2.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA= golang.org/x/mod v0.3.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA= golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= +golang.org/x/net v0.0.0-20190108225652-1e06a53dbb7e h1:bRhVy7zSSasaqNksaRZiA5EEI+Ei4I1nO5Jh72wfHlg= golang.org/x/net v0.0.0-20190108225652-1e06a53dbb7e/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= golang.org/x/net v0.0.0-20190213061140-3a22650c66bd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg= @@ -181,17 +176,17 @@ golang.org/x/net v0.0.0-20200513185701-a91f0712d120/go.mod h1:qpuaurCH72eLCgpAm/ golang.org/x/net v0.0.0-20200520182314-0ba52f642ac2/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A= golang.org/x/net v0.0.0-20200625001655-4c5254603344/go.mod h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA= golang.org/x/net v0.0.0-20200707034311-ab3426394381/go.mod h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA= -golang.org/x/net v0.0.0-20200822124328-c89045814202 h1:VvcQYSHwXgi7W+TpUR6A9g6Up98WAHf3f/ulnJ62IyA= golang.org/x/net v0.0.0-20200822124328-c89045814202/go.mod h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA= golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U= golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw= +golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45 h1:SVwTIAaPC2U/AvvLNZ2a7OVsmBpC8L5BlwK1whH3hm0= golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw= golang.org/x/oauth2 v0.0.0-20191202225959-858c2ad4c8b6/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw= golang.org/x/oauth2 v0.0.0-20200107190931-bf48bf16ab8d/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw= -golang.org/x/oauth2 v0.0.0-20210323180902-22b0adad7558 h1:D7nTwh4J0i+5mW4Zjzn5omvlr6YBcWywE6KOcatyNxY= golang.org/x/oauth2 v0.0.0-20210323180902-22b0adad7558/go.mod h1:KelEdhl1UZF7XfJ4dDtk6s++YSgaE7mD/BuKKDLBl4A= golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= +golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4 h1:YUO/7uOKsKeq9UokNS62b8FYywz3ker1l1vDZRCRefw= golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20190227155943-e225da77a7e6/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= @@ -274,7 +269,6 @@ golang.org/x/tools v0.0.0-20200825202427-b303f430e36d/go.mod h1:njjCfa9FT2d7l9Bc golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= -golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 h1:go1bK/D/BFZV2I8cIQd1NKEZ+0owSTG1fDTci4IqFcE= golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= google.golang.org/api v0.4.0/go.mod h1:8k5glujaEP+g9n7WNsDg8QP6cUVNI86fCNMcbazEtwE= google.golang.org/api v0.7.0/go.mod h1:WtwebWUNSVBH/HAw79HIFXZNqEvBhG+Ra+ax0hx3E3M= @@ -293,11 +287,11 @@ google.golang.org/api v0.28.0/go.mod h1:lIXQywCXRcnZPGlsd8NbLnOjtAoL6em04bJ9+z0M google.golang.org/api v0.29.0/go.mod h1:Lcubydp8VUV7KeIHD9z2Bys/sm/vGKnG1UHuDBSrHWM= google.golang.org/api v0.30.0/go.mod h1:QGmEvQ87FHZNiUVJkT14jQNYJ4ZJjdRF23ZXz5138Fc= google.golang.org/appengine v1.1.0/go.mod h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM= +google.golang.org/appengine v1.4.0 h1:/wp5JvzpHIxhs/dumFmF7BXTf3Z+dd4uXta4kVyO508= google.golang.org/appengine v1.4.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4= google.golang.org/appengine v1.5.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4= google.golang.org/appengine v1.6.1/go.mod h1:i06prIuMbXzDqacNJfV5OdTW448YApPu5ww/cMBSeb0= google.golang.org/appengine v1.6.5/go.mod h1:8WjMMxjGQR8xUklV/ARdw2HLXBOI7O7uCIDZVag1xfc= -google.golang.org/appengine v1.6.6 h1:lMO5rYAqUxkmaj76jAkRUvt5JZgFymx/+Q5Mzfivuhc= google.golang.org/appengine v1.6.6/go.mod h1:8WjMMxjGQR8xUklV/ARdw2HLXBOI7O7uCIDZVag1xfc= google.golang.org/genproto v0.0.0-20180817151627-c66870c02cf8/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc= google.golang.org/genproto v0.0.0-20190307195333-5fe7a883aa19/go.mod h1:VzzqZJRnGkLBvHegQrXjBqPurQTc5/KpmUdxsrq26oE= @@ -349,13 +343,10 @@ google.golang.org/protobuf v1.22.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2 google.golang.org/protobuf v1.23.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU= google.golang.org/protobuf v1.23.1-0.20200526195155-81db48ad09cc/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU= google.golang.org/protobuf v1.24.0/go.mod h1:r/3tXBNzIEhYS9I1OUVjXDlt8tc493IdKGjtUeSXeh4= -google.golang.org/protobuf v1.25.0 h1:Ejskq+SyPohKW+1uil0JJMtmHCgJPJ/qWTxr8qp+R4c= google.golang.org/protobuf v1.25.0/go.mod h1:9JNX74DMeImyA3h4bdi1ymwjUzf21/xIlbajtzgsN7c= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= -gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127 h1:qIbj1fsPNlZgppZ+VLlY7N33q108Sa+fhmuc+sWQYwY= gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= gopkg.in/errgo.v2 v2.1.0/go.mod h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI= -gopkg.in/yaml.v2 v2.2.2 h1:ZCJp+EgiOT7lHqUV2J862kp8Qj64Jo6az82+3Td9dZw= gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4= honnef.co/go/tools v0.0.0-20190106161140-3f1c8253044a/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4= diff --git a/model_models_orchestrator_task.go b/model_models_orchestrator_task.go deleted file mode 100644 index 2b0ae53..0000000 --- a/model_models_orchestrator_task.go +++ /dev/null @@ -1,213 +0,0 @@ -/* -Anthrove Orchestrator API - -This service handles the communication between the manager and the plugs - -API version: 0.1-PREVIEW -Contact: support@anthrove.art -*/ - -// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT. - -package openapi - -import ( - "bytes" - "encoding/json" - "fmt" -) - -// checks if the ModelsOrchestratorTask type satisfies the MappedNullable interface at compile time -var _ MappedNullable = &ModelsOrchestratorTask{} - -// ModelsOrchestratorTask struct for ModelsOrchestratorTask -type ModelsOrchestratorTask struct { - AnthroveUserId string `json:"anthrove_user_id"` - DeepScrape bool `json:"deep_scrape"` - PlugTask ModelsPlugTask `json:"plug_task"` -} - -type _ModelsOrchestratorTask ModelsOrchestratorTask - -// NewModelsOrchestratorTask instantiates a new ModelsOrchestratorTask object -// This constructor will assign default values to properties that have it defined, -// and makes sure properties required by API are set, but the set of arguments -// will change when the set of required properties is changed -func NewModelsOrchestratorTask(anthroveUserId string, deepScrape bool, plugTask ModelsPlugTask) *ModelsOrchestratorTask { - this := ModelsOrchestratorTask{} - this.AnthroveUserId = anthroveUserId - this.DeepScrape = deepScrape - this.PlugTask = plugTask - return &this -} - -// NewModelsOrchestratorTaskWithDefaults instantiates a new ModelsOrchestratorTask object -// This constructor will only assign default values to properties that have it defined, -// but it doesn't guarantee that properties required by API are set -func NewModelsOrchestratorTaskWithDefaults() *ModelsOrchestratorTask { - this := ModelsOrchestratorTask{} - return &this -} - -// GetAnthroveUserId returns the AnthroveUserId field value -func (o *ModelsOrchestratorTask) GetAnthroveUserId() string { - if o == nil { - var ret string - return ret - } - - return o.AnthroveUserId -} - -// GetAnthroveUserIdOk returns a tuple with the AnthroveUserId field value -// and a boolean to check if the value has been set. -func (o *ModelsOrchestratorTask) GetAnthroveUserIdOk() (*string, bool) { - if o == nil { - return nil, false - } - return &o.AnthroveUserId, true -} - -// SetAnthroveUserId sets field value -func (o *ModelsOrchestratorTask) SetAnthroveUserId(v string) { - o.AnthroveUserId = v -} - -// GetDeepScrape returns the DeepScrape field value -func (o *ModelsOrchestratorTask) GetDeepScrape() bool { - if o == nil { - var ret bool - return ret - } - - return o.DeepScrape -} - -// GetDeepScrapeOk returns a tuple with the DeepScrape field value -// and a boolean to check if the value has been set. -func (o *ModelsOrchestratorTask) GetDeepScrapeOk() (*bool, bool) { - if o == nil { - return nil, false - } - return &o.DeepScrape, true -} - -// SetDeepScrape sets field value -func (o *ModelsOrchestratorTask) SetDeepScrape(v bool) { - o.DeepScrape = v -} - -// GetPlugTask returns the PlugTask field value -func (o *ModelsOrchestratorTask) GetPlugTask() ModelsPlugTask { - if o == nil { - var ret ModelsPlugTask - return ret - } - - return o.PlugTask -} - -// GetPlugTaskOk returns a tuple with the PlugTask field value -// and a boolean to check if the value has been set. -func (o *ModelsOrchestratorTask) GetPlugTaskOk() (*ModelsPlugTask, bool) { - if o == nil { - return nil, false - } - return &o.PlugTask, true -} - -// SetPlugTask sets field value -func (o *ModelsOrchestratorTask) SetPlugTask(v ModelsPlugTask) { - o.PlugTask = v -} - -func (o ModelsOrchestratorTask) MarshalJSON() ([]byte, error) { - toSerialize, err := o.ToMap() - if err != nil { - return []byte{}, err - } - return json.Marshal(toSerialize) -} - -func (o ModelsOrchestratorTask) ToMap() (map[string]interface{}, error) { - toSerialize := map[string]interface{}{} - toSerialize["anthrove_user_id"] = o.AnthroveUserId - toSerialize["deep_scrape"] = o.DeepScrape - toSerialize["plug_task"] = o.PlugTask - return toSerialize, nil -} - -func (o *ModelsOrchestratorTask) UnmarshalJSON(data []byte) (err error) { - // This validates that all required properties are included in the JSON object - // by unmarshalling the object into a generic map with string keys and checking - // that every required field exists as a key in the generic map. - requiredProperties := []string{ - "anthrove_user_id", - "deep_scrape", - "plug_task", - } - - allProperties := make(map[string]interface{}) - - err = json.Unmarshal(data, &allProperties) - - if err != nil { - return err - } - - for _, requiredProperty := range requiredProperties { - if _, exists := allProperties[requiredProperty]; !exists { - return fmt.Errorf("no value given for required property %v", requiredProperty) - } - } - - varModelsOrchestratorTask := _ModelsOrchestratorTask{} - - decoder := json.NewDecoder(bytes.NewReader(data)) - decoder.DisallowUnknownFields() - err = decoder.Decode(&varModelsOrchestratorTask) - - if err != nil { - return err - } - - *o = ModelsOrchestratorTask(varModelsOrchestratorTask) - - return err -} - -type NullableModelsOrchestratorTask struct { - value *ModelsOrchestratorTask - isSet bool -} - -func (v NullableModelsOrchestratorTask) Get() *ModelsOrchestratorTask { - return v.value -} - -func (v *NullableModelsOrchestratorTask) Set(val *ModelsOrchestratorTask) { - v.value = val - v.isSet = true -} - -func (v NullableModelsOrchestratorTask) IsSet() bool { - return v.isSet -} - -func (v *NullableModelsOrchestratorTask) Unset() { - v.value = nil - v.isSet = false -} - -func NewNullableModelsOrchestratorTask(val *ModelsOrchestratorTask) *NullableModelsOrchestratorTask { - return &NullableModelsOrchestratorTask{value: val, isSet: true} -} - -func (v NullableModelsOrchestratorTask) MarshalJSON() ([]byte, error) { - return json.Marshal(v.value) -} - -func (v *NullableModelsOrchestratorTask) UnmarshalJSON(src []byte) error { - v.isSet = true - return json.Unmarshal(src, &v.value) -} diff --git a/model_models_plug_task.go b/model_models_plug_task.go deleted file mode 100644 index ab5ffcf..0000000 --- a/model_models_plug_task.go +++ /dev/null @@ -1,229 +0,0 @@ -/* -Anthrove Orchestrator API - -This service handles the communication between the manager and the plugs - -API version: 0.1-PREVIEW -Contact: support@anthrove.art -*/ - -// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT. - -package openapi - -import ( - "bytes" - "encoding/json" - "fmt" -) - -// checks if the ModelsPlugTask type satisfies the MappedNullable interface at compile time -var _ MappedNullable = &ModelsPlugTask{} - -// ModelsPlugTask struct for ModelsPlugTask -type ModelsPlugTask struct { - Id *string `json:"id,omitempty"` - TaskState *ModelsPlugTaskState `json:"task_state,omitempty"` - UserId string `json:"user_id"` -} - -type _ModelsPlugTask ModelsPlugTask - -// NewModelsPlugTask instantiates a new ModelsPlugTask object -// This constructor will assign default values to properties that have it defined, -// and makes sure properties required by API are set, but the set of arguments -// will change when the set of required properties is changed -func NewModelsPlugTask(userId string) *ModelsPlugTask { - this := ModelsPlugTask{} - this.UserId = userId - return &this -} - -// NewModelsPlugTaskWithDefaults instantiates a new ModelsPlugTask object -// This constructor will only assign default values to properties that have it defined, -// but it doesn't guarantee that properties required by API are set -func NewModelsPlugTaskWithDefaults() *ModelsPlugTask { - this := ModelsPlugTask{} - return &this -} - -// GetId returns the Id field value if set, zero value otherwise. -func (o *ModelsPlugTask) GetId() string { - if o == nil || IsNil(o.Id) { - var ret string - return ret - } - return *o.Id -} - -// GetIdOk returns a tuple with the Id field value if set, nil otherwise -// and a boolean to check if the value has been set. -func (o *ModelsPlugTask) GetIdOk() (*string, bool) { - if o == nil || IsNil(o.Id) { - return nil, false - } - return o.Id, true -} - -// HasId returns a boolean if a field has been set. -func (o *ModelsPlugTask) HasId() bool { - if o != nil && !IsNil(o.Id) { - return true - } - - return false -} - -// SetId gets a reference to the given string and assigns it to the Id field. -func (o *ModelsPlugTask) SetId(v string) { - o.Id = &v -} - -// GetTaskState returns the TaskState field value if set, zero value otherwise. -func (o *ModelsPlugTask) GetTaskState() ModelsPlugTaskState { - if o == nil || IsNil(o.TaskState) { - var ret ModelsPlugTaskState - return ret - } - return *o.TaskState -} - -// GetTaskStateOk returns a tuple with the TaskState field value if set, nil otherwise -// and a boolean to check if the value has been set. -func (o *ModelsPlugTask) GetTaskStateOk() (*ModelsPlugTaskState, bool) { - if o == nil || IsNil(o.TaskState) { - return nil, false - } - return o.TaskState, true -} - -// HasTaskState returns a boolean if a field has been set. -func (o *ModelsPlugTask) HasTaskState() bool { - if o != nil && !IsNil(o.TaskState) { - return true - } - - return false -} - -// SetTaskState gets a reference to the given ModelsPlugTaskState and assigns it to the TaskState field. -func (o *ModelsPlugTask) SetTaskState(v ModelsPlugTaskState) { - o.TaskState = &v -} - -// GetUserId returns the UserId field value -func (o *ModelsPlugTask) GetUserId() string { - if o == nil { - var ret string - return ret - } - - return o.UserId -} - -// GetUserIdOk returns a tuple with the UserId field value -// and a boolean to check if the value has been set. -func (o *ModelsPlugTask) GetUserIdOk() (*string, bool) { - if o == nil { - return nil, false - } - return &o.UserId, true -} - -// SetUserId sets field value -func (o *ModelsPlugTask) SetUserId(v string) { - o.UserId = v -} - -func (o ModelsPlugTask) MarshalJSON() ([]byte, error) { - toSerialize, err := o.ToMap() - if err != nil { - return []byte{}, err - } - return json.Marshal(toSerialize) -} - -func (o ModelsPlugTask) ToMap() (map[string]interface{}, error) { - toSerialize := map[string]interface{}{} - if !IsNil(o.Id) { - toSerialize["id"] = o.Id - } - if !IsNil(o.TaskState) { - toSerialize["task_state"] = o.TaskState - } - toSerialize["user_id"] = o.UserId - return toSerialize, nil -} - -func (o *ModelsPlugTask) UnmarshalJSON(data []byte) (err error) { - // This validates that all required properties are included in the JSON object - // by unmarshalling the object into a generic map with string keys and checking - // that every required field exists as a key in the generic map. - requiredProperties := []string{ - "user_id", - } - - allProperties := make(map[string]interface{}) - - err = json.Unmarshal(data, &allProperties) - - if err != nil { - return err - } - - for _, requiredProperty := range requiredProperties { - if _, exists := allProperties[requiredProperty]; !exists { - return fmt.Errorf("no value given for required property %v", requiredProperty) - } - } - - varModelsPlugTask := _ModelsPlugTask{} - - decoder := json.NewDecoder(bytes.NewReader(data)) - decoder.DisallowUnknownFields() - err = decoder.Decode(&varModelsPlugTask) - - if err != nil { - return err - } - - *o = ModelsPlugTask(varModelsPlugTask) - - return err -} - -type NullableModelsPlugTask struct { - value *ModelsPlugTask - isSet bool -} - -func (v NullableModelsPlugTask) Get() *ModelsPlugTask { - return v.value -} - -func (v *NullableModelsPlugTask) Set(val *ModelsPlugTask) { - v.value = val - v.isSet = true -} - -func (v NullableModelsPlugTask) IsSet() bool { - return v.isSet -} - -func (v *NullableModelsPlugTask) Unset() { - v.value = nil - v.isSet = false -} - -func NewNullableModelsPlugTask(val *ModelsPlugTask) *NullableModelsPlugTask { - return &NullableModelsPlugTask{value: val, isSet: true} -} - -func (v NullableModelsPlugTask) MarshalJSON() ([]byte, error) { - return json.Marshal(v.value) -} - -func (v *NullableModelsPlugTask) UnmarshalJSON(src []byte) error { - v.isSet = true - return json.Unmarshal(src, &v.value) -} diff --git a/model_models_plug_task_state.go b/model_models_plug_task_state.go deleted file mode 100644 index f13c782..0000000 --- a/model_models_plug_task_state.go +++ /dev/null @@ -1,115 +0,0 @@ -/* -Anthrove Orchestrator API - -This service handles the communication between the manager and the plugs - -API version: 0.1-PREVIEW -Contact: support@anthrove.art -*/ - -// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT. - -package openapi - -import ( - "encoding/json" - "fmt" -) - -// ModelsPlugTaskState the model 'ModelsPlugTaskState' -type ModelsPlugTaskState string - -// List of models.PlugTaskState -const ( - PlugTaskStateUnknown ModelsPlugTaskState = "UNKNOWN" - PlugTaskStateStarted ModelsPlugTaskState = "STARTED" - PlugTaskStateRunning ModelsPlugTaskState = "RUNNING" - PlugTaskStateStopped ModelsPlugTaskState = "STOPPED" -) - -// All allowed values of ModelsPlugTaskState enum -var AllowedModelsPlugTaskStateEnumValues = []ModelsPlugTaskState{ - "UNKNOWN", - "STARTED", - "RUNNING", - "STOPPED", -} - -func (v *ModelsPlugTaskState) UnmarshalJSON(src []byte) error { - var value string - err := json.Unmarshal(src, &value) - if err != nil { - return err - } - enumTypeValue := ModelsPlugTaskState(value) - for _, existing := range AllowedModelsPlugTaskStateEnumValues { - if existing == enumTypeValue { - *v = enumTypeValue - return nil - } - } - - return fmt.Errorf("%+v is not a valid ModelsPlugTaskState", value) -} - -// NewModelsPlugTaskStateFromValue returns a pointer to a valid ModelsPlugTaskState -// for the value passed as argument, or an error if the value passed is not allowed by the enum -func NewModelsPlugTaskStateFromValue(v string) (*ModelsPlugTaskState, error) { - ev := ModelsPlugTaskState(v) - if ev.IsValid() { - return &ev, nil - } else { - return nil, fmt.Errorf("invalid value '%v' for ModelsPlugTaskState: valid values are %v", v, AllowedModelsPlugTaskStateEnumValues) - } -} - -// IsValid return true if the value is valid for the enum, false otherwise -func (v ModelsPlugTaskState) IsValid() bool { - for _, existing := range AllowedModelsPlugTaskStateEnumValues { - if existing == v { - return true - } - } - return false -} - -// Ptr returns reference to models.PlugTaskState value -func (v ModelsPlugTaskState) Ptr() *ModelsPlugTaskState { - return &v -} - -type NullableModelsPlugTaskState struct { - value *ModelsPlugTaskState - isSet bool -} - -func (v NullableModelsPlugTaskState) Get() *ModelsPlugTaskState { - return v.value -} - -func (v *NullableModelsPlugTaskState) Set(val *ModelsPlugTaskState) { - v.value = val - v.isSet = true -} - -func (v NullableModelsPlugTaskState) IsSet() bool { - return v.isSet -} - -func (v *NullableModelsPlugTaskState) Unset() { - v.value = nil - v.isSet = false -} - -func NewNullableModelsPlugTaskState(val *ModelsPlugTaskState) *NullableModelsPlugTaskState { - return &NullableModelsPlugTaskState{value: val, isSet: true} -} - -func (v NullableModelsPlugTaskState) MarshalJSON() ([]byte, error) { - return json.Marshal(v.value) -} - -func (v *NullableModelsPlugTaskState) UnmarshalJSON(src []byte) error { - v.isSet = true - return json.Unmarshal(src, &v.value) -} diff --git a/model_task_response.go b/model_task_response.go new file mode 100644 index 0000000..31feda8 --- /dev/null +++ b/model_task_response.go @@ -0,0 +1,150 @@ +/* +Anthrove Orchestrator API + +This service handles the communication between the manager and the plugs + +API version: 1.0 +Contact: support@anthrove.art +*/ + +// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT. + +package openapi + +import ( + "encoding/json" +) + +// TaskResponse struct for TaskResponse +type TaskResponse struct { + PlugTaskId *string `json:"plug_task_id,omitempty"` + PlugTaskStatus *string `json:"plug_task_status,omitempty"` +} + +// NewTaskResponse instantiates a new TaskResponse object +// This constructor will assign default values to properties that have it defined, +// and makes sure properties required by API are set, but the set of arguments +// will change when the set of required properties is changed +func NewTaskResponse() *TaskResponse { + this := TaskResponse{} + return &this +} + +// NewTaskResponseWithDefaults instantiates a new TaskResponse object +// This constructor will only assign default values to properties that have it defined, +// but it doesn't guarantee that properties required by API are set +func NewTaskResponseWithDefaults() *TaskResponse { + this := TaskResponse{} + return &this +} + +// GetPlugTaskId returns the PlugTaskId field value if set, zero value otherwise. +func (o *TaskResponse) GetPlugTaskId() string { + if o == nil || o.PlugTaskId == nil { + var ret string + return ret + } + return *o.PlugTaskId +} + +// GetPlugTaskIdOk returns a tuple with the PlugTaskId field value if set, nil otherwise +// and a boolean to check if the value has been set. +func (o *TaskResponse) GetPlugTaskIdOk() (*string, bool) { + if o == nil || o.PlugTaskId == nil { + return nil, false + } + return o.PlugTaskId, true +} + +// HasPlugTaskId returns a boolean if a field has been set. +func (o *TaskResponse) HasPlugTaskId() bool { + if o != nil && o.PlugTaskId != nil { + return true + } + + return false +} + +// SetPlugTaskId gets a reference to the given string and assigns it to the PlugTaskId field. +func (o *TaskResponse) SetPlugTaskId(v string) { + o.PlugTaskId = &v +} + +// GetPlugTaskStatus returns the PlugTaskStatus field value if set, zero value otherwise. +func (o *TaskResponse) GetPlugTaskStatus() string { + if o == nil || o.PlugTaskStatus == nil { + var ret string + return ret + } + return *o.PlugTaskStatus +} + +// GetPlugTaskStatusOk returns a tuple with the PlugTaskStatus field value if set, nil otherwise +// and a boolean to check if the value has been set. +func (o *TaskResponse) GetPlugTaskStatusOk() (*string, bool) { + if o == nil || o.PlugTaskStatus == nil { + return nil, false + } + return o.PlugTaskStatus, true +} + +// HasPlugTaskStatus returns a boolean if a field has been set. +func (o *TaskResponse) HasPlugTaskStatus() bool { + if o != nil && o.PlugTaskStatus != nil { + return true + } + + return false +} + +// SetPlugTaskStatus gets a reference to the given string and assigns it to the PlugTaskStatus field. +func (o *TaskResponse) SetPlugTaskStatus(v string) { + o.PlugTaskStatus = &v +} + +func (o TaskResponse) MarshalJSON() ([]byte, error) { + toSerialize := map[string]interface{}{} + if o.PlugTaskId != nil { + toSerialize["plug_task_id"] = o.PlugTaskId + } + if o.PlugTaskStatus != nil { + toSerialize["plug_task_status"] = o.PlugTaskStatus + } + return json.Marshal(toSerialize) +} + +type NullableTaskResponse struct { + value *TaskResponse + isSet bool +} + +func (v NullableTaskResponse) Get() *TaskResponse { + return v.value +} + +func (v *NullableTaskResponse) Set(val *TaskResponse) { + v.value = val + v.isSet = true +} + +func (v NullableTaskResponse) IsSet() bool { + return v.isSet +} + +func (v *NullableTaskResponse) Unset() { + v.value = nil + v.isSet = false +} + +func NewNullableTaskResponse(val *TaskResponse) *NullableTaskResponse { + return &NullableTaskResponse{value: val, isSet: true} +} + +func (v NullableTaskResponse) MarshalJSON() ([]byte, error) { + return json.Marshal(v.value) +} + +func (v *NullableTaskResponse) UnmarshalJSON(src []byte) error { + v.isSet = true + return json.Unmarshal(src, &v.value) +} diff --git a/model_task_start_task.go b/model_task_start_task.go new file mode 100644 index 0000000..5b7f153 --- /dev/null +++ b/model_task_start_task.go @@ -0,0 +1,186 @@ +/* +Anthrove Orchestrator API + +This service handles the communication between the manager and the plugs + +API version: 1.0 +Contact: support@anthrove.art +*/ + +// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT. + +package openapi + +import ( + "encoding/json" +) + +// TaskStartTask struct for TaskStartTask +type TaskStartTask struct { + UserApiKey *string `json:"user_api_key,omitempty"` + UserId *string `json:"user_id,omitempty"` + UserSourceId *string `json:"user_source_id,omitempty"` +} + +// NewTaskStartTask instantiates a new TaskStartTask object +// This constructor will assign default values to properties that have it defined, +// and makes sure properties required by API are set, but the set of arguments +// will change when the set of required properties is changed +func NewTaskStartTask() *TaskStartTask { + this := TaskStartTask{} + return &this +} + +// NewTaskStartTaskWithDefaults instantiates a new TaskStartTask object +// This constructor will only assign default values to properties that have it defined, +// but it doesn't guarantee that properties required by API are set +func NewTaskStartTaskWithDefaults() *TaskStartTask { + this := TaskStartTask{} + return &this +} + +// GetUserApiKey returns the UserApiKey field value if set, zero value otherwise. +func (o *TaskStartTask) GetUserApiKey() string { + if o == nil || o.UserApiKey == nil { + var ret string + return ret + } + return *o.UserApiKey +} + +// GetUserApiKeyOk returns a tuple with the UserApiKey field value if set, nil otherwise +// and a boolean to check if the value has been set. +func (o *TaskStartTask) GetUserApiKeyOk() (*string, bool) { + if o == nil || o.UserApiKey == nil { + return nil, false + } + return o.UserApiKey, true +} + +// HasUserApiKey returns a boolean if a field has been set. +func (o *TaskStartTask) HasUserApiKey() bool { + if o != nil && o.UserApiKey != nil { + return true + } + + return false +} + +// SetUserApiKey gets a reference to the given string and assigns it to the UserApiKey field. +func (o *TaskStartTask) SetUserApiKey(v string) { + o.UserApiKey = &v +} + +// GetUserId returns the UserId field value if set, zero value otherwise. +func (o *TaskStartTask) GetUserId() string { + if o == nil || o.UserId == nil { + var ret string + return ret + } + return *o.UserId +} + +// GetUserIdOk returns a tuple with the UserId field value if set, nil otherwise +// and a boolean to check if the value has been set. +func (o *TaskStartTask) GetUserIdOk() (*string, bool) { + if o == nil || o.UserId == nil { + return nil, false + } + return o.UserId, true +} + +// HasUserId returns a boolean if a field has been set. +func (o *TaskStartTask) HasUserId() bool { + if o != nil && o.UserId != nil { + return true + } + + return false +} + +// SetUserId gets a reference to the given string and assigns it to the UserId field. +func (o *TaskStartTask) SetUserId(v string) { + o.UserId = &v +} + +// GetUserSourceId returns the UserSourceId field value if set, zero value otherwise. +func (o *TaskStartTask) GetUserSourceId() string { + if o == nil || o.UserSourceId == nil { + var ret string + return ret + } + return *o.UserSourceId +} + +// GetUserSourceIdOk returns a tuple with the UserSourceId field value if set, nil otherwise +// and a boolean to check if the value has been set. +func (o *TaskStartTask) GetUserSourceIdOk() (*string, bool) { + if o == nil || o.UserSourceId == nil { + return nil, false + } + return o.UserSourceId, true +} + +// HasUserSourceId returns a boolean if a field has been set. +func (o *TaskStartTask) HasUserSourceId() bool { + if o != nil && o.UserSourceId != nil { + return true + } + + return false +} + +// SetUserSourceId gets a reference to the given string and assigns it to the UserSourceId field. +func (o *TaskStartTask) SetUserSourceId(v string) { + o.UserSourceId = &v +} + +func (o TaskStartTask) MarshalJSON() ([]byte, error) { + toSerialize := map[string]interface{}{} + if o.UserApiKey != nil { + toSerialize["user_api_key"] = o.UserApiKey + } + if o.UserId != nil { + toSerialize["user_id"] = o.UserId + } + if o.UserSourceId != nil { + toSerialize["user_source_id"] = o.UserSourceId + } + return json.Marshal(toSerialize) +} + +type NullableTaskStartTask struct { + value *TaskStartTask + isSet bool +} + +func (v NullableTaskStartTask) Get() *TaskStartTask { + return v.value +} + +func (v *NullableTaskStartTask) Set(val *TaskStartTask) { + v.value = val + v.isSet = true +} + +func (v NullableTaskStartTask) IsSet() bool { + return v.isSet +} + +func (v *NullableTaskStartTask) Unset() { + v.value = nil + v.isSet = false +} + +func NewNullableTaskStartTask(val *TaskStartTask) *NullableTaskStartTask { + return &NullableTaskStartTask{value: val, isSet: true} +} + +func (v NullableTaskStartTask) MarshalJSON() ([]byte, error) { + return json.Marshal(v.value) +} + +func (v *NullableTaskStartTask) UnmarshalJSON(src []byte) error { + v.isSet = true + return json.Unmarshal(src, &v.value) +} diff --git a/test/api_plug_test.go b/test/api_plug_test.go deleted file mode 100644 index 857fe3b..0000000 --- a/test/api_plug_test.go +++ /dev/null @@ -1,66 +0,0 @@ -/* -Anthrove Orchestrator API - -Testing PlugAPIService - -*/ - -// Code generated by OpenAPI Generator (https://openapi-generator.tech); - -package openapi - -import ( - "context" - openapiclient "git.anthrove.art/Anthrove/orchestrator-swagger-go-client/v1" - "github.com/stretchr/testify/assert" - "github.com/stretchr/testify/require" - "testing" -) - -func Test_openapi_PlugAPIService(t *testing.T) { - - configuration := openapiclient.NewConfiguration() - apiClient := openapiclient.NewAPIClient(configuration) - - t.Run("Test PlugAPIService PlugPlugTypePut", func(t *testing.T) { - - t.Skip("skip test") // remove to run test - - var plugType string - - httpRes, err := apiClient.PlugAPI.PlugPlugTypePut(context.Background(), plugType).Execute() - - require.Nil(t, err) - assert.Equal(t, 200, httpRes.StatusCode) - - }) - - t.Run("Test PlugAPIService PlugPlugTypeTaskIdDelete", func(t *testing.T) { - - t.Skip("skip test") // remove to run test - - var plugType string - var taskId string - - httpRes, err := apiClient.PlugAPI.PlugPlugTypeTaskIdDelete(context.Background(), plugType, taskId).Execute() - - require.Nil(t, err) - assert.Equal(t, 200, httpRes.StatusCode) - - }) - - t.Run("Test PlugAPIService PlugPlugTypeTaskIdGet", func(t *testing.T) { - - t.Skip("skip test") // remove to run test - - var plugType string - var taskId string - - httpRes, err := apiClient.PlugAPI.PlugPlugTypeTaskIdGet(context.Background(), plugType, taskId).Execute() - - require.Nil(t, err) - assert.Equal(t, 200, httpRes.StatusCode) - - }) - -} diff --git a/test/api_user_test.go b/test/api_user_test.go deleted file mode 100644 index 93948dd..0000000 --- a/test/api_user_test.go +++ /dev/null @@ -1,38 +0,0 @@ -/* -Anthrove Orchestrator API - -Testing UserAPIService - -*/ - -// Code generated by OpenAPI Generator (https://openapi-generator.tech); - -package openapi - -import ( - "context" - openapiclient "git.anthrove.art/Anthrove/orchestrator-swagger-go-client/v1" - "github.com/stretchr/testify/assert" - "github.com/stretchr/testify/require" - "testing" -) - -func Test_openapi_UserAPIService(t *testing.T) { - - configuration := openapiclient.NewConfiguration() - apiClient := openapiclient.NewAPIClient(configuration) - - t.Run("Test UserAPIService UserUserIdPut", func(t *testing.T) { - - t.Skip("skip test") // remove to run test - - var userId string - - httpRes, err := apiClient.UserAPI.UserUserIdPut(context.Background(), userId).Execute() - - require.Nil(t, err) - assert.Equal(t, 200, httpRes.StatusCode) - - }) - -}