Commit 08c6ea4c authored by Michel Roy's avatar Michel Roy Committed by Kevin Di Lallo
Browse files

ctrl engine client swagger update

parent 8d349381

go-packages/meep-ctrl-engine-client/README.md

+2 −2
Original line number Diff line number Diff line
@@ -11,8 +11,8 @@ This API client was generated by the [swagger-codegen](https://github.com/swagge 


## Installation

Put the package under your project folder and add the following in import:

```

    "./client"

```golang

import "./client"

```



## Documentation for API Endpoints

go-packages/meep-ctrl-engine-client/api/swagger.yaml

+7 −13
Original line number Diff line number Diff line
@@ -18,7 +18,6 @@ basePath: "/v1" 
tags:

- name: "Scenario Configuration"

- name: "Scenario Execution"

- name: "MEEP Settings"

- name: "Pod States"

schemes:

- "http"
@@ -227,18 +226,21 @@ paths: 
        required: false

        type: "string"

        x-exportParamName: "Node"

        x-optionalDataType: "String"

      - name: "type"

        in: "query"

        description: "Exposed service type (ingress or egress)"

        required: false

        type: "string"

        x-exportParamName: "Type_"

        x-optionalDataType: "String"

      - name: "service"

        in: "query"

        description: "Exposed service name"

        required: false

        type: "string"

        x-exportParamName: "Service"

        x-optionalDataType: "String"

      responses:

        200:

          description: "OK"
@@ -292,17 +294,17 @@ paths: 
        required: false

        type: "string"

        x-exportParamName: "Long"

        x-optionalDataType: "String"

      - name: "type"

        in: "query"

        description: "Pod type"

        required: false

        type: "string"

        x-exportParamName: "Type_"

        x-optionalDataType: "String"

      responses:

        200:

          description: "successful operation"

          schema:

            $ref: "#/definitions/PodsStatus"

          examples:

            application/json:

              podsStatus:
@@ -317,12 +319,13 @@ paths: 
                podScheduled: "True"

                podUnschedulable: "False"

                podConditionError: "containers with unready status: [myshel]"

                containerStatusesMsg: null

                nbOkContainers: "0"

                nbTotalContainers: "1"

                nbPodRestart: "15005"

                logicalState: "Terminating"

                startTime: "2018-09-10 14:24:00 +0000 UTC"

          schema:

            $ref: "#/definitions/PodsStatus"

definitions:

  ScenarioList:

    type: "object"
@@ -991,7 +994,6 @@ definitions: 
        podScheduled: "True"

        podUnschedulable: "False"

        podConditionError: "containers with unready status: [myshel]"

        containerStatusesMsg: null

        nbOkContainers: "0"

        nbTotalContainers: "1"

        nbPodRestart: "15005"
@@ -1027,14 +1029,6 @@ parameters: 
    schema:

      $ref: "http://localhost:8291/meep-model.yaml#/definitions/Event"

    x-exportParamName: "Event"

  Settings:

    in: "body"

    name: "settings"

    description: "MEEP Settings"

    required: true

    schema:

      $ref: "http://localhost:8291/meep-model.yaml#/definitions/Settings"

    x-exportParamName: "Settings"

responses:

  Std200:

    description: "OK"

go-packages/meep-ctrl-engine-client/pod_states_api.go→go-packages/meep-ctrl-engine-client/api_pod_states.go

+129 −0
Original line number Diff line number Diff line
@@ -10,13 +10,13 @@ 
package client



import (

	"encoding/json"

	"context"

	"io/ioutil"

	"net/http"

	"net/url"

	"strings"



	"golang.org/x/net/context"

	"github.com/antihax/optional"

)



// Linger please
@@ -26,20 +26,29 @@ var ( 


type PodStatesApiService service



/* PodStatesApiService This operation returns status information for pods

/*

PodStatesApiService This operation returns status information for pods

Returns pod status info for a list of pods

* @param ctx context.Context for authentication, logging, tracing, etc.

@param optional (nil or map[string]interface{}) with one or more of:

    @param "long" (string) Enables detailed stats if true

    @param "type_" (string) Pod type

@return PodsStatus*/

func (a *PodStatesApiService) GetStates(ctx context.Context, localVarOptionals map[string]interface{}) (PodsStatus, *http.Response, error) {

 * @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

 * @param optional nil or *GetStatesOpts - Optional Parameters:

     * @param "Long" (optional.String) -  Enables detailed stats if true

     * @param "Type_" (optional.String) -  Pod type



@return PodsStatus

*/



type GetStatesOpts struct {

	Long  optional.String

	Type_ optional.String

}



func (a *PodStatesApiService) GetStates(ctx context.Context, localVarOptionals *GetStatesOpts) (PodsStatus, *http.Response, error) {

	var (

		localVarHttpMethod  = strings.ToUpper("Get")

		localVarPostBody    interface{}

		localVarFileName    string

		localVarFileBytes   []byte

		successPayload     PodsStatus

		localVarReturnValue PodsStatus

	)



	// create path and map variables
@@ -49,18 +58,11 @@ func (a *PodStatesApiService) GetStates(ctx context.Context, localVarOptionals m 
	localVarQueryParams := url.Values{}

	localVarFormParams := url.Values{}



	if err := typeCheckParameter(localVarOptionals["long"], "string", "long"); err != nil {

		return successPayload, nil, err

	if localVarOptionals != nil && localVarOptionals.Long.IsSet() {

		localVarQueryParams.Add("long", parameterToString(localVarOptionals.Long.Value(), ""))

	}

	if err := typeCheckParameter(localVarOptionals["type_"], "string", "type_"); err != nil {

		return successPayload, nil, err

	}



	if localVarTempParam, localVarOk := localVarOptionals["long"].(string); localVarOk {

		localVarQueryParams.Add("long", parameterToString(localVarTempParam, ""))

	}

	if localVarTempParam, localVarOk := localVarOptionals["type_"].(string); localVarOk {

		localVarQueryParams.Add("type", parameterToString(localVarTempParam, ""))

	if localVarOptionals != nil && localVarOptionals.Type_.IsSet() {

		localVarQueryParams.Add("type", parameterToString(localVarOptionals.Type_.Value(), ""))

	}

	// to determine the Content-Type header

	localVarHttpContentTypes := []string{}
@@ -72,9 +74,7 @@ func (a *PodStatesApiService) GetStates(ctx context.Context, localVarOptionals m 
	}



	// to determine the Accept header

	localVarHttpHeaderAccepts := []string{

		"application/json",

	}

	localVarHttpHeaderAccepts := []string{"application/json"}



	// set Accept header

	localVarHttpHeaderAccept := selectHeaderAccept(localVarHttpHeaderAccepts)
@@ -83,22 +83,47 @@ func (a *PodStatesApiService) GetStates(ctx context.Context, localVarOptionals m 
	}

	r, err := a.client.prepareRequest(ctx, localVarPath, localVarHttpMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, localVarFileName, localVarFileBytes)

	if err != nil {

		return successPayload, nil, err

		return localVarReturnValue, nil, err

	}



	localVarHttpResponse, err := a.client.callAPI(r)

	if err != nil || localVarHttpResponse == nil {

		return successPayload, localVarHttpResponse, err

		return localVarReturnValue, localVarHttpResponse, err

	}

	defer localVarHttpResponse.Body.Close()



	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"))

		if err == nil {

			return localVarReturnValue, localVarHttpResponse, err

		}

	}



	if localVarHttpResponse.StatusCode >= 300 {

		bodyBytes, _ := ioutil.ReadAll(localVarHttpResponse.Body)

		return successPayload, localVarHttpResponse, reportError("Status: %v, Body: %s", localVarHttpResponse.Status, bodyBytes)

		newErr := GenericSwaggerError{

			body:  localVarBody,

			error: localVarHttpResponse.Status,

		}



		if localVarHttpResponse.StatusCode == 200 {

			var v PodsStatus

			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

		}



	if err = json.NewDecoder(localVarHttpResponse.Body).Decode(&successPayload); err != nil {

		return successPayload, localVarHttpResponse, err

		return localVarReturnValue, localVarHttpResponse, newErr

	}



	return successPayload, localVarHttpResponse, err

	return localVarReturnValue, localVarHttpResponse, nil

}

go-packages/meep-ctrl-engine-client/scenario_configuration_api.go→go-packages/meep-ctrl-engine-client/api_scenario_configuration.go

+183 −89
Original line number Diff line number Diff line
@@ -10,14 +10,12 @@ 
package client



import (

	"encoding/json"

	"context"

	"fmt"

	"io/ioutil"

	"net/http"

	"net/url"

	"strings"



	"golang.org/x/net/context"

)



// Linger please
@@ -27,12 +25,15 @@ var ( 


type ScenarioConfigurationApiService service



/* ScenarioConfigurationApiService Add new scenario to MEEP store

/*

ScenarioConfigurationApiService Add new scenario to MEEP store



 * @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

 * @param name Scenario name

 * @param scenario Scenario to add to MEEP store



* @param ctx context.Context for authentication, logging, tracing, etc.

@param name Scenario name

@param scenario Scenario to add to MEEP store

@return */



*/

func (a *ScenarioConfigurationApiService) CreateScenario(ctx context.Context, name string, scenario Scenario) (*http.Response, error) {

	var (

		localVarHttpMethod = strings.ToUpper("Post")
@@ -59,9 +60,7 @@ func (a *ScenarioConfigurationApiService) CreateScenario(ctx context.Context, na 
	}



	// to determine the Accept header

	localVarHttpHeaderAccepts := []string{

		"application/json",

	}

	localVarHttpHeaderAccepts := []string{"application/json"}



	// set Accept header

	localVarHttpHeaderAccept := selectHeaderAccept(localVarHttpHeaderAccepts)
@@ -79,20 +78,33 @@ func (a *ScenarioConfigurationApiService) CreateScenario(ctx context.Context, na 
	if err != nil || localVarHttpResponse == nil {

		return localVarHttpResponse, err

	}

	defer localVarHttpResponse.Body.Close()



	localVarBody, err := ioutil.ReadAll(localVarHttpResponse.Body)

	localVarHttpResponse.Body.Close()

	if err != nil {

		return localVarHttpResponse, err

	}



	if localVarHttpResponse.StatusCode >= 300 {

		bodyBytes, _ := ioutil.ReadAll(localVarHttpResponse.Body)

		return localVarHttpResponse, reportError("Status: %v, Body: %s", localVarHttpResponse.Status, bodyBytes)

		newErr := GenericSwaggerError{

			body:  localVarBody,

			error: localVarHttpResponse.Status,

		}



	return localVarHttpResponse, err

		return localVarHttpResponse, newErr

	}



	return localVarHttpResponse, nil

}



/* ScenarioConfigurationApiService Delete scenario from MEEP store

/*

ScenarioConfigurationApiService Delete scenario from MEEP store



 * @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

 * @param name Scenario name



* @param ctx context.Context for authentication, logging, tracing, etc.

@param name Scenario name

@return */



*/

func (a *ScenarioConfigurationApiService) DeleteScenario(ctx context.Context, name string) (*http.Response, error) {

	var (

		localVarHttpMethod = strings.ToUpper("Delete")
@@ -119,9 +131,7 @@ func (a *ScenarioConfigurationApiService) DeleteScenario(ctx context.Context, na 
	}



	// to determine the Accept header

	localVarHttpHeaderAccepts := []string{

		"application/json",

	}

	localVarHttpHeaderAccepts := []string{"application/json"}



	// set Accept header

	localVarHttpHeaderAccept := selectHeaderAccept(localVarHttpHeaderAccepts)
@@ -137,19 +147,32 @@ func (a *ScenarioConfigurationApiService) DeleteScenario(ctx context.Context, na 
	if err != nil || localVarHttpResponse == nil {

		return localVarHttpResponse, err

	}

	defer localVarHttpResponse.Body.Close()



	localVarBody, err := ioutil.ReadAll(localVarHttpResponse.Body)

	localVarHttpResponse.Body.Close()

	if err != nil {

		return localVarHttpResponse, err

	}



	if localVarHttpResponse.StatusCode >= 300 {

		bodyBytes, _ := ioutil.ReadAll(localVarHttpResponse.Body)

		return localVarHttpResponse, reportError("Status: %v, Body: %s", localVarHttpResponse.Status, bodyBytes)

		newErr := GenericSwaggerError{

			body:  localVarBody,

			error: localVarHttpResponse.Status,

		}



	return localVarHttpResponse, err

		return localVarHttpResponse, newErr

	}



/* ScenarioConfigurationApiService Delete all scenarios in MEEP store

	return localVarHttpResponse, nil

}



 * @param ctx context.Context for authentication, logging, tracing, etc.

 @return */

/*

ScenarioConfigurationApiService Delete all scenarios in MEEP store



 * @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().





*/

func (a *ScenarioConfigurationApiService) DeleteScenarioList(ctx context.Context) (*http.Response, error) {

	var (

		localVarHttpMethod = strings.ToUpper("Delete")
@@ -175,9 +198,7 @@ func (a *ScenarioConfigurationApiService) DeleteScenarioList(ctx context.Context 
	}



	// to determine the Accept header

	localVarHttpHeaderAccepts := []string{

		"application/json",

	}

	localVarHttpHeaderAccepts := []string{"application/json"}



	// set Accept header

	localVarHttpHeaderAccept := selectHeaderAccept(localVarHttpHeaderAccepts)
@@ -193,27 +214,40 @@ func (a *ScenarioConfigurationApiService) DeleteScenarioList(ctx context.Context 
	if err != nil || localVarHttpResponse == nil {

		return localVarHttpResponse, err

	}

	defer localVarHttpResponse.Body.Close()



	localVarBody, err := ioutil.ReadAll(localVarHttpResponse.Body)

	localVarHttpResponse.Body.Close()

	if err != nil {

		return localVarHttpResponse, err

	}



	if localVarHttpResponse.StatusCode >= 300 {

		bodyBytes, _ := ioutil.ReadAll(localVarHttpResponse.Body)

		return localVarHttpResponse, reportError("Status: %v, Body: %s", localVarHttpResponse.Status, bodyBytes)

		newErr := GenericSwaggerError{

			body:  localVarBody,

			error: localVarHttpResponse.Status,

		}



	return localVarHttpResponse, err

		return localVarHttpResponse, newErr

	}



	return localVarHttpResponse, nil

}



/* ScenarioConfigurationApiService Retrieve scenario from MEEP store

/*

ScenarioConfigurationApiService Retrieve scenario from MEEP store



 * @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

 * @param name Scenario name



* @param ctx context.Context for authentication, logging, tracing, etc.

@param name Scenario name

@return Scenario*/

@return Scenario

*/

func (a *ScenarioConfigurationApiService) GetScenario(ctx context.Context, name string) (Scenario, *http.Response, error) {

	var (

		localVarHttpMethod  = strings.ToUpper("Get")

		localVarPostBody    interface{}

		localVarFileName    string

		localVarFileBytes   []byte

		successPayload     Scenario

		localVarReturnValue Scenario

	)



	// create path and map variables
@@ -234,9 +268,7 @@ func (a *ScenarioConfigurationApiService) GetScenario(ctx context.Context, name 
	}



	// to determine the Accept header

	localVarHttpHeaderAccepts := []string{

		"application/json",

	}

	localVarHttpHeaderAccepts := []string{"application/json"}



	// set Accept header

	localVarHttpHeaderAccept := selectHeaderAccept(localVarHttpHeaderAccepts)
@@ -245,37 +277,65 @@ func (a *ScenarioConfigurationApiService) GetScenario(ctx context.Context, name 
	}

	r, err := a.client.prepareRequest(ctx, localVarPath, localVarHttpMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, localVarFileName, localVarFileBytes)

	if err != nil {

		return successPayload, nil, err

		return localVarReturnValue, nil, err

	}



	localVarHttpResponse, err := a.client.callAPI(r)

	if err != nil || localVarHttpResponse == nil {

		return successPayload, localVarHttpResponse, err

		return localVarReturnValue, localVarHttpResponse, err

	}



	localVarBody, err := ioutil.ReadAll(localVarHttpResponse.Body)

	localVarHttpResponse.Body.Close()

	if err != nil {

		return localVarReturnValue, localVarHttpResponse, err

	}

	defer localVarHttpResponse.Body.Close()



	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"))

		if err == nil {

			return localVarReturnValue, localVarHttpResponse, err

		}

	}



	if localVarHttpResponse.StatusCode >= 300 {

		bodyBytes, _ := ioutil.ReadAll(localVarHttpResponse.Body)

		return successPayload, localVarHttpResponse, reportError("Status: %v, Body: %s", localVarHttpResponse.Status, bodyBytes)

		newErr := GenericSwaggerError{

			body:  localVarBody,

			error: localVarHttpResponse.Status,

		}



	if err = json.NewDecoder(localVarHttpResponse.Body).Decode(&successPayload); err != nil {

		return successPayload, localVarHttpResponse, err

		if localVarHttpResponse.StatusCode == 200 {

			var v Scenario

			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 successPayload, localVarHttpResponse, err

		return localVarReturnValue, localVarHttpResponse, newErr

	}



/* ScenarioConfigurationApiService Retrieve list of scenarios in MEEP store

	return localVarReturnValue, localVarHttpResponse, nil

}



/*

ScenarioConfigurationApiService Retrieve list of scenarios in MEEP store



 * @param ctx context.Context for authentication, logging, tracing, etc.

 @return ScenarioList*/

 * @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().



@return ScenarioList

*/

func (a *ScenarioConfigurationApiService) GetScenarioList(ctx context.Context) (ScenarioList, *http.Response, error) {

	var (

		localVarHttpMethod  = strings.ToUpper("Get")

		localVarPostBody    interface{}

		localVarFileName    string

		localVarFileBytes   []byte

		successPayload     ScenarioList

		localVarReturnValue ScenarioList

	)



	// create path and map variables
@@ -295,9 +355,7 @@ func (a *ScenarioConfigurationApiService) GetScenarioList(ctx context.Context) ( 
	}



	// to determine the Accept header

	localVarHttpHeaderAccepts := []string{

		"application/json",

	}

	localVarHttpHeaderAccepts := []string{"application/json"}



	// set Accept header

	localVarHttpHeaderAccept := selectHeaderAccept(localVarHttpHeaderAccepts)
@@ -306,32 +364,60 @@ func (a *ScenarioConfigurationApiService) GetScenarioList(ctx context.Context) ( 
	}

	r, err := a.client.prepareRequest(ctx, localVarPath, localVarHttpMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, localVarFileName, localVarFileBytes)

	if err != nil {

		return successPayload, nil, err

		return localVarReturnValue, nil, err

	}



	localVarHttpResponse, err := a.client.callAPI(r)

	if err != nil || localVarHttpResponse == nil {

		return successPayload, localVarHttpResponse, err

		return localVarReturnValue, localVarHttpResponse, err

	}

	defer localVarHttpResponse.Body.Close()



	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"))

		if err == nil {

			return localVarReturnValue, localVarHttpResponse, err

		}

	}



	if localVarHttpResponse.StatusCode >= 300 {

		bodyBytes, _ := ioutil.ReadAll(localVarHttpResponse.Body)

		return successPayload, localVarHttpResponse, reportError("Status: %v, Body: %s", localVarHttpResponse.Status, bodyBytes)

		newErr := GenericSwaggerError{

			body:  localVarBody,

			error: localVarHttpResponse.Status,

		}



		if localVarHttpResponse.StatusCode == 200 {

			var v ScenarioList

			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

		}



	if err = json.NewDecoder(localVarHttpResponse.Body).Decode(&successPayload); err != nil {

		return successPayload, localVarHttpResponse, err

		return localVarReturnValue, localVarHttpResponse, newErr

	}



	return successPayload, localVarHttpResponse, err

	return localVarReturnValue, localVarHttpResponse, nil

}



/* ScenarioConfigurationApiService Update scenario in MEEP store

/*

ScenarioConfigurationApiService Update scenario in MEEP store



 * @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

 * @param name Scenario name

 * @param scenario Scenario to add to MEEP store





* @param ctx context.Context for authentication, logging, tracing, etc.

@param name Scenario name

@param scenario Scenario to add to MEEP store

@return */

*/

func (a *ScenarioConfigurationApiService) SetScenario(ctx context.Context, name string, scenario Scenario) (*http.Response, error) {

	var (

		localVarHttpMethod = strings.ToUpper("Put")
@@ -358,9 +444,7 @@ func (a *ScenarioConfigurationApiService) SetScenario(ctx context.Context, name 
	}



	// to determine the Accept header

	localVarHttpHeaderAccepts := []string{

		"application/json",

	}

	localVarHttpHeaderAccepts := []string{"application/json"}



	// set Accept header

	localVarHttpHeaderAccept := selectHeaderAccept(localVarHttpHeaderAccepts)
@@ -378,11 +462,21 @@ func (a *ScenarioConfigurationApiService) SetScenario(ctx context.Context, name 
	if err != nil || localVarHttpResponse == nil {

		return localVarHttpResponse, err

	}

	defer localVarHttpResponse.Body.Close()



	localVarBody, err := ioutil.ReadAll(localVarHttpResponse.Body)

	localVarHttpResponse.Body.Close()

	if err != nil {

		return localVarHttpResponse, err

	}



	if localVarHttpResponse.StatusCode >= 300 {

		bodyBytes, _ := ioutil.ReadAll(localVarHttpResponse.Body)

		return localVarHttpResponse, reportError("Status: %v, Body: %s", localVarHttpResponse.Status, bodyBytes)

		newErr := GenericSwaggerError{

			body:  localVarBody,

			error: localVarHttpResponse.Status,

		}



	return localVarHttpResponse, err

		return localVarHttpResponse, newErr

	}



	return localVarHttpResponse, nil

}