472 lines
16 KiB
Go
472 lines
16 KiB
Go
|
|
||
|
/*
|
||
|
* oc-catalog API
|
||
|
*
|
||
|
* Backend of the oc-search project
|
||
|
*
|
||
|
* API version: 1.0.0
|
||
|
* Contact: valentin.kivachuk@irt-saintexupery.com
|
||
|
* Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)
|
||
|
*/
|
||
|
|
||
|
package swagger
|
||
|
|
||
|
import (
|
||
|
"context"
|
||
|
"io/ioutil"
|
||
|
"net/http"
|
||
|
"net/url"
|
||
|
"strings"
|
||
|
)
|
||
|
|
||
|
// Linger please
|
||
|
var (
|
||
|
_ context.Context
|
||
|
)
|
||
|
|
||
|
type ScheduleApiService service
|
||
|
|
||
|
/*
|
||
|
ScheduleApiService
|
||
|
Check for availability of this DC
|
||
|
* @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
|
||
|
* @param cron Cron syntax
|
||
|
* @param duration Duration in seconds
|
||
|
* @param startDate RFC3339 time for startDate
|
||
|
* @param stopDate RFC3339 time for stopDate
|
||
|
* @param requirements The object content
|
||
|
|
||
|
|
||
|
*/
|
||
|
func (a *ScheduleApiService) ScheduleControllerCheckIfScheduleCanBeCreatedInThisDC(ctx context.Context, cron string, duration int32, startDate interface{}, stopDate interface{}, requirements ModelsExecutionRequirementsModel) (*http.Response, error) {
|
||
|
var (
|
||
|
localVarHttpMethod = strings.ToUpper("Post")
|
||
|
localVarPostBody interface{}
|
||
|
localVarFileName string
|
||
|
localVarFileBytes []byte
|
||
|
|
||
|
)
|
||
|
|
||
|
// create path and map variables
|
||
|
localVarPath := a.client.cfg.BasePath + "/schedule/check"
|
||
|
|
||
|
localVarHeaderParams := make(map[string]string)
|
||
|
localVarQueryParams := url.Values{}
|
||
|
localVarFormParams := url.Values{}
|
||
|
|
||
|
localVarQueryParams.Add("cron", parameterToString(cron, ""))
|
||
|
localVarQueryParams.Add("duration", parameterToString(duration, ""))
|
||
|
localVarQueryParams.Add("startDate", parameterToString(startDate, ""))
|
||
|
localVarQueryParams.Add("stopDate", parameterToString(stopDate, ""))
|
||
|
// 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 = &requirements
|
||
|
r, err := a.client.prepareRequest(ctx, localVarPath, localVarHttpMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, localVarFileName, localVarFileBytes)
|
||
|
if err != nil {
|
||
|
return nil, err
|
||
|
}
|
||
|
|
||
|
localVarHttpResponse, err := a.client.callAPI(r)
|
||
|
if err != nil || localVarHttpResponse == nil {
|
||
|
return localVarHttpResponse, err
|
||
|
}
|
||
|
|
||
|
localVarBody, err := ioutil.ReadAll(localVarHttpResponse.Body)
|
||
|
localVarHttpResponse.Body.Close()
|
||
|
if err != nil {
|
||
|
return localVarHttpResponse, err
|
||
|
}
|
||
|
|
||
|
|
||
|
if localVarHttpResponse.StatusCode >= 300 {
|
||
|
newErr := GenericSwaggerError{
|
||
|
body: localVarBody,
|
||
|
error: localVarHttpResponse.Status,
|
||
|
}
|
||
|
|
||
|
return localVarHttpResponse, newErr
|
||
|
}
|
||
|
|
||
|
return localVarHttpResponse, nil
|
||
|
}
|
||
|
|
||
|
/*
|
||
|
ScheduleApiService
|
||
|
Create schedule for a workflow. It will return some future executions just as information
|
||
|
* @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
|
||
|
* @param dcName Name of the node (oc-catalog) from where the workflow comes.
|
||
|
* @param workflowName Workflow Name
|
||
|
* @param cron Cron syntax with year. If no year is specified, will use the current
|
||
|
* @param duration Duration in seconds
|
||
|
* @param startDate RFC3339 time for startDate
|
||
|
* @param stopDate RFC3339 time for stopDate
|
||
|
* @param requirements The object content
|
||
|
|
||
|
@return ModelsScheduleInfo
|
||
|
*/
|
||
|
func (a *ScheduleApiService) ScheduleControllerCreateSchedule(ctx context.Context, dcName string, workflowName string, cron string, duration int32, startDate interface{}, stopDate interface{}, requirements ModelsExecutionRequirementsModel) (ModelsScheduleInfo, *http.Response, error) {
|
||
|
var (
|
||
|
localVarHttpMethod = strings.ToUpper("Post")
|
||
|
localVarPostBody interface{}
|
||
|
localVarFileName string
|
||
|
localVarFileBytes []byte
|
||
|
localVarReturnValue ModelsScheduleInfo
|
||
|
)
|
||
|
|
||
|
// create path and map variables
|
||
|
localVarPath := a.client.cfg.BasePath + "/schedule/book"
|
||
|
|
||
|
localVarHeaderParams := make(map[string]string)
|
||
|
localVarQueryParams := url.Values{}
|
||
|
localVarFormParams := url.Values{}
|
||
|
|
||
|
localVarQueryParams.Add("dcName", parameterToString(dcName, ""))
|
||
|
localVarQueryParams.Add("workflowName", parameterToString(workflowName, ""))
|
||
|
localVarQueryParams.Add("cron", parameterToString(cron, ""))
|
||
|
localVarQueryParams.Add("duration", parameterToString(duration, ""))
|
||
|
localVarQueryParams.Add("startDate", parameterToString(startDate, ""))
|
||
|
localVarQueryParams.Add("stopDate", parameterToString(stopDate, ""))
|
||
|
// 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 = &requirements
|
||
|
r, err := a.client.prepareRequest(ctx, localVarPath, localVarHttpMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, localVarFileName, localVarFileBytes)
|
||
|
if err != nil {
|
||
|
return localVarReturnValue, nil, err
|
||
|
}
|
||
|
|
||
|
localVarHttpResponse, err := a.client.callAPI(r)
|
||
|
if err != nil || localVarHttpResponse == nil {
|
||
|
return localVarReturnValue, localVarHttpResponse, err
|
||
|
}
|
||
|
|
||
|
localVarBody, err := ioutil.ReadAll(localVarHttpResponse.Body)
|
||
|
localVarHttpResponse.Body.Close()
|
||
|
if err != nil {
|
||
|
return localVarReturnValue, localVarHttpResponse, err
|
||
|
}
|
||
|
|
||
|
if localVarHttpResponse.StatusCode < 300 {
|
||
|
// If we succeed, return the data, otherwise pass on to decode error.
|
||
|
err = a.client.decode(&localVarReturnValue, localVarBody, localVarHttpResponse.Header.Get("Content-Type"));
|
||
|
return localVarReturnValue, localVarHttpResponse, err
|
||
|
}
|
||
|
|
||
|
if localVarHttpResponse.StatusCode >= 300 {
|
||
|
newErr := GenericSwaggerError{
|
||
|
body: localVarBody,
|
||
|
error: localVarHttpResponse.Status,
|
||
|
}
|
||
|
|
||
|
if localVarHttpResponse.StatusCode == 200 {
|
||
|
var v ModelsScheduleInfo
|
||
|
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
|
||
|
}
|
||
|
|
||
|
return localVarReturnValue, localVarHttpResponse, newErr
|
||
|
}
|
||
|
|
||
|
return localVarReturnValue, localVarHttpResponse, nil
|
||
|
}
|
||
|
|
||
|
/*
|
||
|
ScheduleApiService
|
||
|
Give a date, get the next date where there are at least on schedule. If no hours specified, will assume 00:00
|
||
|
* @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
|
||
|
* @param baseDate Base date
|
||
|
|
||
|
@return TimeTime
|
||
|
*/
|
||
|
func (a *ScheduleApiService) ScheduleControllerGetNextSchedule(ctx context.Context, baseDate interface{}) (TimeTime, *http.Response, error) {
|
||
|
var (
|
||
|
localVarHttpMethod = strings.ToUpper("Get")
|
||
|
localVarPostBody interface{}
|
||
|
localVarFileName string
|
||
|
localVarFileBytes []byte
|
||
|
localVarReturnValue TimeTime
|
||
|
)
|
||
|
|
||
|
// create path and map variables
|
||
|
localVarPath := a.client.cfg.BasePath + "/schedule/next"
|
||
|
|
||
|
localVarHeaderParams := make(map[string]string)
|
||
|
localVarQueryParams := url.Values{}
|
||
|
localVarFormParams := url.Values{}
|
||
|
|
||
|
localVarQueryParams.Add("baseDate", parameterToString(baseDate, ""))
|
||
|
// 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
|
||
|
}
|
||
|
r, err := a.client.prepareRequest(ctx, localVarPath, localVarHttpMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, localVarFileName, localVarFileBytes)
|
||
|
if err != nil {
|
||
|
return localVarReturnValue, nil, err
|
||
|
}
|
||
|
|
||
|
localVarHttpResponse, err := a.client.callAPI(r)
|
||
|
if err != nil || localVarHttpResponse == nil {
|
||
|
return localVarReturnValue, localVarHttpResponse, err
|
||
|
}
|
||
|
|
||
|
localVarBody, err := ioutil.ReadAll(localVarHttpResponse.Body)
|
||
|
localVarHttpResponse.Body.Close()
|
||
|
if err != nil {
|
||
|
return localVarReturnValue, localVarHttpResponse, err
|
||
|
}
|
||
|
|
||
|
if localVarHttpResponse.StatusCode < 300 {
|
||
|
// If we succeed, return the data, otherwise pass on to decode error.
|
||
|
err = a.client.decode(&localVarReturnValue, localVarBody, localVarHttpResponse.Header.Get("Content-Type"));
|
||
|
return localVarReturnValue, localVarHttpResponse, err
|
||
|
}
|
||
|
|
||
|
if localVarHttpResponse.StatusCode >= 300 {
|
||
|
newErr := GenericSwaggerError{
|
||
|
body: localVarBody,
|
||
|
error: localVarHttpResponse.Status,
|
||
|
}
|
||
|
|
||
|
if localVarHttpResponse.StatusCode == 200 {
|
||
|
var v TimeTime
|
||
|
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
|
||
|
}
|
||
|
|
||
|
return localVarReturnValue, localVarHttpResponse, newErr
|
||
|
}
|
||
|
|
||
|
return localVarReturnValue, localVarHttpResponse, nil
|
||
|
}
|
||
|
|
||
|
/*
|
||
|
ScheduleApiService
|
||
|
Give a date, get the previous date where there are at least on schedule. If no hours specified, will assume 00:00
|
||
|
* @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
|
||
|
* @param baseDate Base date
|
||
|
|
||
|
@return TimeTime
|
||
|
*/
|
||
|
func (a *ScheduleApiService) ScheduleControllerGetPreviousSchedule(ctx context.Context, baseDate interface{}) (TimeTime, *http.Response, error) {
|
||
|
var (
|
||
|
localVarHttpMethod = strings.ToUpper("Get")
|
||
|
localVarPostBody interface{}
|
||
|
localVarFileName string
|
||
|
localVarFileBytes []byte
|
||
|
localVarReturnValue TimeTime
|
||
|
)
|
||
|
|
||
|
// create path and map variables
|
||
|
localVarPath := a.client.cfg.BasePath + "/schedule/previous"
|
||
|
|
||
|
localVarHeaderParams := make(map[string]string)
|
||
|
localVarQueryParams := url.Values{}
|
||
|
localVarFormParams := url.Values{}
|
||
|
|
||
|
localVarQueryParams.Add("baseDate", parameterToString(baseDate, ""))
|
||
|
// 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
|
||
|
}
|
||
|
r, err := a.client.prepareRequest(ctx, localVarPath, localVarHttpMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, localVarFileName, localVarFileBytes)
|
||
|
if err != nil {
|
||
|
return localVarReturnValue, nil, err
|
||
|
}
|
||
|
|
||
|
localVarHttpResponse, err := a.client.callAPI(r)
|
||
|
if err != nil || localVarHttpResponse == nil {
|
||
|
return localVarReturnValue, localVarHttpResponse, err
|
||
|
}
|
||
|
|
||
|
localVarBody, err := ioutil.ReadAll(localVarHttpResponse.Body)
|
||
|
localVarHttpResponse.Body.Close()
|
||
|
if err != nil {
|
||
|
return localVarReturnValue, localVarHttpResponse, err
|
||
|
}
|
||
|
|
||
|
if localVarHttpResponse.StatusCode < 300 {
|
||
|
// If we succeed, return the data, otherwise pass on to decode error.
|
||
|
err = a.client.decode(&localVarReturnValue, localVarBody, localVarHttpResponse.Header.Get("Content-Type"));
|
||
|
return localVarReturnValue, localVarHttpResponse, err
|
||
|
}
|
||
|
|
||
|
if localVarHttpResponse.StatusCode >= 300 {
|
||
|
newErr := GenericSwaggerError{
|
||
|
body: localVarBody,
|
||
|
error: localVarHttpResponse.Status,
|
||
|
}
|
||
|
|
||
|
if localVarHttpResponse.StatusCode == 200 {
|
||
|
var v TimeTime
|
||
|
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
|
||
|
}
|
||
|
|
||
|
return localVarReturnValue, localVarHttpResponse, newErr
|
||
|
}
|
||
|
|
||
|
return localVarReturnValue, localVarHttpResponse, nil
|
||
|
}
|
||
|
|
||
|
/*
|
||
|
ScheduleApiService
|
||
|
Get a list of next startDates schedules (inclusive). If timezone is not specified, will assume UTC
|
||
|
* @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
|
||
|
* @param startDate Start date
|
||
|
* @param stopDate End date
|
||
|
|
||
|
@return []ModelsScheduleDb
|
||
|
*/
|
||
|
func (a *ScheduleApiService) ScheduleControllerGetSchedules(ctx context.Context, startDate interface{}, stopDate interface{}) ([]ModelsScheduleDb, *http.Response, error) {
|
||
|
var (
|
||
|
localVarHttpMethod = strings.ToUpper("Get")
|
||
|
localVarPostBody interface{}
|
||
|
localVarFileName string
|
||
|
localVarFileBytes []byte
|
||
|
localVarReturnValue []ModelsScheduleDb
|
||
|
)
|
||
|
|
||
|
// create path and map variables
|
||
|
localVarPath := a.client.cfg.BasePath + "/schedule/"
|
||
|
|
||
|
localVarHeaderParams := make(map[string]string)
|
||
|
localVarQueryParams := url.Values{}
|
||
|
localVarFormParams := url.Values{}
|
||
|
|
||
|
localVarQueryParams.Add("startDate", parameterToString(startDate, ""))
|
||
|
localVarQueryParams.Add("stopDate", parameterToString(stopDate, ""))
|
||
|
// 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
|
||
|
}
|
||
|
r, err := a.client.prepareRequest(ctx, localVarPath, localVarHttpMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, localVarFileName, localVarFileBytes)
|
||
|
if err != nil {
|
||
|
return localVarReturnValue, nil, err
|
||
|
}
|
||
|
|
||
|
localVarHttpResponse, err := a.client.callAPI(r)
|
||
|
if err != nil || localVarHttpResponse == nil {
|
||
|
return localVarReturnValue, localVarHttpResponse, err
|
||
|
}
|
||
|
|
||
|
localVarBody, err := ioutil.ReadAll(localVarHttpResponse.Body)
|
||
|
localVarHttpResponse.Body.Close()
|
||
|
if err != nil {
|
||
|
return localVarReturnValue, localVarHttpResponse, err
|
||
|
}
|
||
|
|
||
|
if localVarHttpResponse.StatusCode < 300 {
|
||
|
// If we succeed, return the data, otherwise pass on to decode error.
|
||
|
err = a.client.decode(&localVarReturnValue, localVarBody, localVarHttpResponse.Header.Get("Content-Type"));
|
||
|
return localVarReturnValue, localVarHttpResponse, err
|
||
|
}
|
||
|
|
||
|
if localVarHttpResponse.StatusCode >= 300 {
|
||
|
newErr := GenericSwaggerError{
|
||
|
body: localVarBody,
|
||
|
error: localVarHttpResponse.Status,
|
||
|
}
|
||
|
|
||
|
if localVarHttpResponse.StatusCode == 200 {
|
||
|
var v []ModelsScheduleDb
|
||
|
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
|
||
|
}
|
||
|
|
||
|
return localVarReturnValue, localVarHttpResponse, newErr
|
||
|
}
|
||
|
|
||
|
return localVarReturnValue, localVarHttpResponse, nil
|
||
|
}
|
||
|
|