Anthrove/orchestrator-swagger-go-client
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 3 Wiki Activity

Compare commits

base: Anthrove:6a34afab9bbb0a0716a4e48c48a77997aa83427d
Branches Tags
Anthrove:main
Anthrove:release/v1.1.0
Anthrove:release/v1.0.0
Anthrove:release/v0.0.8
Anthrove:v1.1.0
Anthrove:v1.0.0
Anthrove:v0.0.8
..
compare: Anthrove:bb85c18c6f9757622c48bdf220b449dd8e6a82c5
Branches Tags
Anthrove:main
Anthrove:release/v1.1.0
Anthrove:release/v1.0.0
Anthrove:release/v0.0.8
Anthrove:v1.1.0
Anthrove:v1.0.0
Anthrove:v0.0.8

No commits in common. "6a34afab9bbb0a0716a4e48c48a77997aa83427d" and "bb85c18c6f9757622c48bdf220b449dd8e6a82c5" have entirely different histories.
6a34afab9b ... bb85c18c6f

21 changed files with 1430 additions and 1142 deletions
Show Stats Expand all files Collapse all files

1
.openapi-generator/FILES
View File

@ -1,5 +1,4 @@
.gitignore .gitignore
.openapi-generator-ignore
.travis.yml .travis.yml
README.md README.md
api/openapi.yaml api/openapi.yaml

2
README.md
View File

@ -23,7 +23,7 @@ go get golang.org/x/net/context
Put the package under your project folder and add the following in import: Put the package under your project folder and add the following in import:
```golang ```golang
import openapi "git.anthrove.art/Anthrove/orchestrator-swagger-go-client" import openapi "git.anthrove.art/Anthrove/orchestrator-swagger-go-client/v1"
``` ```
To use a proxy, set the environment variable `HTTP_PROXY`: To use a proxy, set the environment variable `HTTP_PROXY`:

320
api_plug.go Normal file
View File

@ -0,0 +1,320 @@
/*
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
}

383
api_user_source.go
View File

@ -1,383 +0,0 @@
/*
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
}

93
docs/ModelsOrchestratorTask.md Normal file
View File

@ -0,0 +1,93 @@
# 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)

103
docs/ModelsPlugTask.md Normal file
View File

@ -0,0 +1,103 @@
# 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)

17
docs/ModelsPlugTaskState.md Normal file
View File

@ -0,0 +1,17 @@
# 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)

223
docs/PlugAPI.md Normal file
View File

@ -0,0 +1,223 @@
# \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)

82
docs/TaskResponse.md
View File

@ -1,82 +0,0 @@
# 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)

108
docs/TaskStartTask.md
View File

@ -1,108 +0,0 @@
# 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)

0
docs/UserApi.md → docs/UserAPI.md
View File

229
docs/UserSourceApi.md
View File

@ -1,229 +0,0 @@
# \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)

7
go.mod
View File

@ -1,5 +1,8 @@
module git.anthrove.art/Anthrove/orchestrator-swagger-go-client module git.anthrove.art/Anthrove/orchestrator-swagger-go-client/v1
go 1.13 go 1.13
require golang.org/x/oauth2 v0.0.0-20210323180902-22b0adad7558 require (
github.com/stretchr/testify v1.4.0
golang.org/x/oauth2 v0.0.0-20210323180902-22b0adad7558
)

7
go.sum
View File

@ -39,6 +39,7 @@ 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/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/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/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/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.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= github.com/envoyproxy/go-control-plane v0.9.1-0.20191026205805-5f8ba28d4473/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4=
@ -100,13 +101,17 @@ 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.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/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/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/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ= 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/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/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/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/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/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/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.25/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74= github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
@ -347,8 +352,10 @@ google.golang.org/protobuf v1.24.0/go.mod h1:r/3tXBNzIEhYS9I1OUVjXDlt8tc493IdKGj
google.golang.org/protobuf v1.25.0 h1:Ejskq+SyPohKW+1uil0JJMtmHCgJPJ/qWTxr8qp+R4c= 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= 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 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/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/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= 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-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
honnef.co/go/tools v0.0.0-20190106161140-3f1c8253044a/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4= honnef.co/go/tools v0.0.0-20190106161140-3f1c8253044a/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=

213
model_models_orchestrator_task.go Normal file
View File

@ -0,0 +1,213 @@
/*
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)
}

229
model_models_plug_task.go Normal file
View File

@ -0,0 +1,229 @@
/*
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)
}

115
model_models_plug_task_state.go Normal file
View File

@ -0,0 +1,115 @@
/*
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)
}

150
model_task_response.go
View File

@ -1,150 +0,0 @@
/*
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)
}

186
model_task_start_task.go
View File

@ -1,186 +0,0 @@
/*
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)
}

66
test/api_plug_test.go Normal file
View File

@ -0,0 +1,66 @@
/*
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)
})
}

38
test/api_user_test.go Normal file
View File

@ -0,0 +1,38 @@
/*
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)
})
}