diff --git a/services/telemetrylink/oas_commit b/services/telemetrylink/oas_commit index b2db84d556..285dd15d0e 100644 --- a/services/telemetrylink/oas_commit +++ b/services/telemetrylink/oas_commit @@ -1 +1 @@ -9b983fefc1a52d2b7fdc9df6376424c944a044bb +6511dc62dcbbded601fdca534eff79f7bfa7977d diff --git a/services/telemetrylink/v1api/api_default.go b/services/telemetrylink/v1api/api_default.go index 83df2923d6..46c5b82c41 100644 --- a/services/telemetrylink/v1api/api_default.go +++ b/services/telemetrylink/v1api/api_default.go @@ -23,6 +23,22 @@ import ( type DefaultAPI interface { + /* + CreateFolderBackflushJob Method for CreateFolderBackflushJob + + Creates a new Backflush Job for the folder. + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param folderId The STACKIT portal folder UUID the resource is located in. + @param regionId The STACKIT region name the resource is located in. + @return ApiCreateFolderBackflushJobRequest + */ + CreateFolderBackflushJob(ctx context.Context, folderId string, regionId string) ApiCreateFolderBackflushJobRequest + + // CreateFolderBackflushJobExecute executes the request + // @return BackflushJobResponse + CreateFolderBackflushJobExecute(r ApiCreateFolderBackflushJobRequest) (*BackflushJobResponse, error) + /* CreateOrUpdateFolderTelemetryLink Method for CreateOrUpdateFolderTelemetryLink @@ -71,6 +87,38 @@ type DefaultAPI interface { // @return TelemetryLinkResponse CreateOrUpdateProjectTelemetryLinkExecute(r ApiCreateOrUpdateProjectTelemetryLinkRequest) (*TelemetryLinkResponse, error) + /* + CreateOrganizationBackflushJob Method for CreateOrganizationBackflushJob + + Creates a new Backflush Job for the organization. + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param organizationId The STACKIT portal organization UUID the resource is located in. + @param regionId The STACKIT region name the resource is located in. + @return ApiCreateOrganizationBackflushJobRequest + */ + CreateOrganizationBackflushJob(ctx context.Context, organizationId string, regionId string) ApiCreateOrganizationBackflushJobRequest + + // CreateOrganizationBackflushJobExecute executes the request + // @return BackflushJobResponse + CreateOrganizationBackflushJobExecute(r ApiCreateOrganizationBackflushJobRequest) (*BackflushJobResponse, error) + + /* + CreateProjectBackflushJob Method for CreateProjectBackflushJob + + Creates a new Backflush Job for the project. + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param projectId The STACKIT portal project UUID the resource is located in. + @param regionId The STACKIT region name the resource is located in. + @return ApiCreateProjectBackflushJobRequest + */ + CreateProjectBackflushJob(ctx context.Context, projectId string, regionId string) ApiCreateProjectBackflushJobRequest + + // CreateProjectBackflushJobExecute executes the request + // @return BackflushJobResponse + CreateProjectBackflushJobExecute(r ApiCreateProjectBackflushJobRequest) (*BackflushJobResponse, error) + /* DeleteFolderTelemetryLink Method for DeleteFolderTelemetryLink @@ -116,6 +164,23 @@ type DefaultAPI interface { // DeleteProjectTelemetryLinkExecute executes the request DeleteProjectTelemetryLinkExecute(r ApiDeleteProjectTelemetryLinkRequest) error + /* + GetFolderBackflushJob Method for GetFolderBackflushJob + + Returns the details for the given Backflush Job in a folder. + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param folderId The STACKIT portal folder UUID the resource is located in. + @param regionId The STACKIT region name the resource is located in. + @param backflushJobId The Backflush Job UUID. + @return ApiGetFolderBackflushJobRequest + */ + GetFolderBackflushJob(ctx context.Context, folderId string, regionId string, backflushJobId string) ApiGetFolderBackflushJobRequest + + // GetFolderBackflushJobExecute executes the request + // @return BackflushJobResponse + GetFolderBackflushJobExecute(r ApiGetFolderBackflushJobRequest) (*BackflushJobResponse, error) + /* GetFolderTelemetryLink Method for GetFolderTelemetryLink @@ -132,6 +197,23 @@ type DefaultAPI interface { // @return TelemetryLinkResponse GetFolderTelemetryLinkExecute(r ApiGetFolderTelemetryLinkRequest) (*TelemetryLinkResponse, error) + /* + GetOrganizationBackflushJob Method for GetOrganizationBackflushJob + + Returns the details for the given Backflush Job in a organization. + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param organizationId The STACKIT portal organization UUID the resource is located in. + @param regionId The STACKIT region name the resource is located in. + @param backflushJobId The Backflush Job UUID. + @return ApiGetOrganizationBackflushJobRequest + */ + GetOrganizationBackflushJob(ctx context.Context, organizationId string, regionId string, backflushJobId string) ApiGetOrganizationBackflushJobRequest + + // GetOrganizationBackflushJobExecute executes the request + // @return BackflushJobResponse + GetOrganizationBackflushJobExecute(r ApiGetOrganizationBackflushJobRequest) (*BackflushJobResponse, error) + /* GetOrganizationTelemetryLink Method for GetOrganizationTelemetryLink @@ -148,6 +230,23 @@ type DefaultAPI interface { // @return TelemetryLinkResponse GetOrganizationTelemetryLinkExecute(r ApiGetOrganizationTelemetryLinkRequest) (*TelemetryLinkResponse, error) + /* + GetProjectBackflushJob Method for GetProjectBackflushJob + + Returns the details for the given Backflush Job in a project. + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param projectId The STACKIT portal project UUID the resource is located in. + @param regionId The STACKIT region name the resource is located in. + @param backflushJobId The Backflush Job UUID. + @return ApiGetProjectBackflushJobRequest + */ + GetProjectBackflushJob(ctx context.Context, projectId string, regionId string, backflushJobId string) ApiGetProjectBackflushJobRequest + + // GetProjectBackflushJobExecute executes the request + // @return BackflushJobResponse + GetProjectBackflushJobExecute(r ApiGetProjectBackflushJobRequest) (*BackflushJobResponse, error) + /* GetProjectTelemetryLink Method for GetProjectTelemetryLink @@ -164,6 +263,54 @@ type DefaultAPI interface { // @return TelemetryLinkResponse GetProjectTelemetryLinkExecute(r ApiGetProjectTelemetryLinkRequest) (*TelemetryLinkResponse, error) + /* + ListFolderBackflushJobs Method for ListFolderBackflushJobs + + Returns a list of all Backflush Jobs for the folder. + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param folderId The STACKIT portal folder UUID the resource is located in. + @param regionId The STACKIT region name the resource is located in. + @return ApiListFolderBackflushJobsRequest + */ + ListFolderBackflushJobs(ctx context.Context, folderId string, regionId string) ApiListFolderBackflushJobsRequest + + // ListFolderBackflushJobsExecute executes the request + // @return ListBackflushJobsResponse + ListFolderBackflushJobsExecute(r ApiListFolderBackflushJobsRequest) (*ListBackflushJobsResponse, error) + + /* + ListOrganizationBackflushJobs Method for ListOrganizationBackflushJobs + + Returns a list of all Backflush Jobs for the organization. + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param organizationId The STACKIT portal organization UUID the resource is located in. + @param regionId The STACKIT region name the resource is located in. + @return ApiListOrganizationBackflushJobsRequest + */ + ListOrganizationBackflushJobs(ctx context.Context, organizationId string, regionId string) ApiListOrganizationBackflushJobsRequest + + // ListOrganizationBackflushJobsExecute executes the request + // @return ListBackflushJobsResponse + ListOrganizationBackflushJobsExecute(r ApiListOrganizationBackflushJobsRequest) (*ListBackflushJobsResponse, error) + + /* + ListProjectBackflushJobs Method for ListProjectBackflushJobs + + Returns a list of all Backflush Jobs for the project. + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param projectId The STACKIT portal project UUID the resource is located in. + @param regionId The STACKIT region name the resource is located in. + @return ApiListProjectBackflushJobsRequest + */ + ListProjectBackflushJobs(ctx context.Context, projectId string, regionId string) ApiListProjectBackflushJobsRequest + + // ListProjectBackflushJobsExecute executes the request + // @return ListBackflushJobsResponse + ListProjectBackflushJobsExecute(r ApiListProjectBackflushJobsRequest) (*ListBackflushJobsResponse, error) + /* PartialUpdateFolderTelemetryLink Method for PartialUpdateFolderTelemetryLink @@ -216,6 +363,169 @@ type DefaultAPI interface { // DefaultAPIService DefaultAPI service type DefaultAPIService service +type ApiCreateFolderBackflushJobRequest struct { + ctx context.Context + ApiService DefaultAPI + folderId string + regionId string + createFolderBackflushJobPayload *CreateFolderBackflushJobPayload +} + +func (r ApiCreateFolderBackflushJobRequest) CreateFolderBackflushJobPayload(createFolderBackflushJobPayload CreateFolderBackflushJobPayload) ApiCreateFolderBackflushJobRequest { + r.createFolderBackflushJobPayload = &createFolderBackflushJobPayload + return r +} + +func (r ApiCreateFolderBackflushJobRequest) Execute() (*BackflushJobResponse, error) { + return r.ApiService.CreateFolderBackflushJobExecute(r) +} + +/* +CreateFolderBackflushJob Method for CreateFolderBackflushJob + +Creates a new Backflush Job for the folder. + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param folderId The STACKIT portal folder UUID the resource is located in. + @param regionId The STACKIT region name the resource is located in. + @return ApiCreateFolderBackflushJobRequest +*/ +func (a *DefaultAPIService) CreateFolderBackflushJob(ctx context.Context, folderId string, regionId string) ApiCreateFolderBackflushJobRequest { + return ApiCreateFolderBackflushJobRequest{ + ApiService: a, + ctx: ctx, + folderId: folderId, + regionId: regionId, + } +} + +// Execute executes the request +// +// @return BackflushJobResponse +func (a *DefaultAPIService) CreateFolderBackflushJobExecute(r ApiCreateFolderBackflushJobRequest) (*BackflushJobResponse, error) { + var ( + localVarHTTPMethod = http.MethodPost + localVarPostBody interface{} + formFiles []formFile + localVarReturnValue *BackflushJobResponse + ) + + localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.CreateFolderBackflushJob") + if err != nil { + return localVarReturnValue, &oapierror.GenericOpenAPIError{ErrorMessage: err.Error()} + } + + localVarPath := localBasePath + "/v1/folders/{folderId}/regions/{regionId}/telemetry-link/backflush-jobs" + localVarPath = strings.Replace(localVarPath, "{"+"folderId"+"}", url.PathEscape(parameterValueToString(r.folderId, "folderId")), -1) + localVarPath = strings.Replace(localVarPath, "{"+"regionId"+"}", url.PathEscape(parameterValueToString(r.regionId, "regionId")), -1) + + localVarHeaderParams := make(map[string]string) + localVarQueryParams := url.Values{} + localVarFormParams := url.Values{} + if r.createFolderBackflushJobPayload == nil { + return localVarReturnValue, reportError("createFolderBackflushJobPayload 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{"application/json"} + + // set Accept header + localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts) + if localVarHTTPHeaderAccept != "" { + localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept + } + // body params + localVarPostBody = r.createFolderBackflushJobPayload + req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles) + if err != nil { + return localVarReturnValue, err + } + + contextHTTPRequest, ok := r.ctx.Value(config.ContextHTTPRequest).(**http.Request) + if ok { + *contextHTTPRequest = req + } + + localVarHTTPResponse, err := a.client.callAPI(req) + contextHTTPResponse, ok := r.ctx.Value(config.ContextHTTPResponse).(**http.Response) + if ok { + *contextHTTPResponse = localVarHTTPResponse + } + if err != nil || localVarHTTPResponse == nil { + return localVarReturnValue, err + } + + localVarBody, err := io.ReadAll(localVarHTTPResponse.Body) + localVarHTTPResponse.Body.Close() + localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody)) + if err != nil { + return localVarReturnValue, err + } + + if localVarHTTPResponse.StatusCode >= 300 { + newErr := &oapierror.GenericOpenAPIError{ + Body: localVarBody, + ErrorMessage: localVarHTTPResponse.Status, + StatusCode: localVarHTTPResponse.StatusCode, + } + if localVarHTTPResponse.StatusCode == 400 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return localVarReturnValue, newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return localVarReturnValue, newErr + } + if localVarHTTPResponse.StatusCode == 401 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return localVarReturnValue, newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return localVarReturnValue, newErr + } + if localVarHTTPResponse.StatusCode == 409 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return localVarReturnValue, newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return localVarReturnValue, newErr + } + return localVarReturnValue, newErr + } + + err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr := &oapierror.GenericOpenAPIError{ + StatusCode: localVarHTTPResponse.StatusCode, + Body: localVarBody, + ErrorMessage: err.Error(), + } + return localVarReturnValue, newErr + } + + return localVarReturnValue, nil +} + type ApiCreateOrUpdateFolderTelemetryLinkRequest struct { ctx context.Context ApiService DefaultAPI @@ -768,50 +1078,941 @@ func (a *DefaultAPIService) CreateOrUpdateProjectTelemetryLinkExecute(r ApiCreat return localVarReturnValue, nil } -type ApiDeleteFolderTelemetryLinkRequest struct { - ctx context.Context - ApiService DefaultAPI - folderId string - regionId string +type ApiCreateOrganizationBackflushJobRequest struct { + ctx context.Context + ApiService DefaultAPI + organizationId string + regionId string + createOrganizationBackflushJobPayload *CreateOrganizationBackflushJobPayload } -func (r ApiDeleteFolderTelemetryLinkRequest) Execute() error { - return r.ApiService.DeleteFolderTelemetryLinkExecute(r) +func (r ApiCreateOrganizationBackflushJobRequest) CreateOrganizationBackflushJobPayload(createOrganizationBackflushJobPayload CreateOrganizationBackflushJobPayload) ApiCreateOrganizationBackflushJobRequest { + r.createOrganizationBackflushJobPayload = &createOrganizationBackflushJobPayload + return r +} + +func (r ApiCreateOrganizationBackflushJobRequest) Execute() (*BackflushJobResponse, error) { + return r.ApiService.CreateOrganizationBackflushJobExecute(r) } /* -DeleteFolderTelemetryLink Method for DeleteFolderTelemetryLink +CreateOrganizationBackflushJob Method for CreateOrganizationBackflushJob -Deletes the given Telemetry Link within the folder. +Creates a new Backflush Job for the organization. @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). - @param folderId The STACKIT portal folder UUID the resource is located in. + @param organizationId The STACKIT portal organization UUID the resource is located in. @param regionId The STACKIT region name the resource is located in. - @return ApiDeleteFolderTelemetryLinkRequest + @return ApiCreateOrganizationBackflushJobRequest */ -func (a *DefaultAPIService) DeleteFolderTelemetryLink(ctx context.Context, folderId string, regionId string) ApiDeleteFolderTelemetryLinkRequest { - return ApiDeleteFolderTelemetryLinkRequest{ - ApiService: a, - ctx: ctx, - folderId: folderId, - regionId: regionId, +func (a *DefaultAPIService) CreateOrganizationBackflushJob(ctx context.Context, organizationId string, regionId string) ApiCreateOrganizationBackflushJobRequest { + return ApiCreateOrganizationBackflushJobRequest{ + ApiService: a, + ctx: ctx, + organizationId: organizationId, + regionId: regionId, } } // Execute executes the request -func (a *DefaultAPIService) DeleteFolderTelemetryLinkExecute(r ApiDeleteFolderTelemetryLinkRequest) error { +// +// @return BackflushJobResponse +func (a *DefaultAPIService) CreateOrganizationBackflushJobExecute(r ApiCreateOrganizationBackflushJobRequest) (*BackflushJobResponse, error) { var ( - localVarHTTPMethod = http.MethodDelete - localVarPostBody interface{} - formFiles []formFile + localVarHTTPMethod = http.MethodPost + localVarPostBody interface{} + formFiles []formFile + localVarReturnValue *BackflushJobResponse ) - localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.DeleteFolderTelemetryLink") + localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.CreateOrganizationBackflushJob") if err != nil { - return &oapierror.GenericOpenAPIError{ErrorMessage: err.Error()} + return localVarReturnValue, &oapierror.GenericOpenAPIError{ErrorMessage: err.Error()} } - localVarPath := localBasePath + "/v1/folders/{folderId}/regions/{regionId}/telemetry-link" + localVarPath := localBasePath + "/v1/organizations/{organizationId}/regions/{regionId}/telemetry-link/backflush-jobs" + localVarPath = strings.Replace(localVarPath, "{"+"organizationId"+"}", url.PathEscape(parameterValueToString(r.organizationId, "organizationId")), -1) + localVarPath = strings.Replace(localVarPath, "{"+"regionId"+"}", url.PathEscape(parameterValueToString(r.regionId, "regionId")), -1) + + localVarHeaderParams := make(map[string]string) + localVarQueryParams := url.Values{} + localVarFormParams := url.Values{} + if r.createOrganizationBackflushJobPayload == nil { + return localVarReturnValue, reportError("createOrganizationBackflushJobPayload 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{"application/json"} + + // set Accept header + localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts) + if localVarHTTPHeaderAccept != "" { + localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept + } + // body params + localVarPostBody = r.createOrganizationBackflushJobPayload + req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles) + if err != nil { + return localVarReturnValue, err + } + + contextHTTPRequest, ok := r.ctx.Value(config.ContextHTTPRequest).(**http.Request) + if ok { + *contextHTTPRequest = req + } + + localVarHTTPResponse, err := a.client.callAPI(req) + contextHTTPResponse, ok := r.ctx.Value(config.ContextHTTPResponse).(**http.Response) + if ok { + *contextHTTPResponse = localVarHTTPResponse + } + if err != nil || localVarHTTPResponse == nil { + return localVarReturnValue, err + } + + localVarBody, err := io.ReadAll(localVarHTTPResponse.Body) + localVarHTTPResponse.Body.Close() + localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody)) + if err != nil { + return localVarReturnValue, err + } + + if localVarHTTPResponse.StatusCode >= 300 { + newErr := &oapierror.GenericOpenAPIError{ + Body: localVarBody, + ErrorMessage: localVarHTTPResponse.Status, + StatusCode: localVarHTTPResponse.StatusCode, + } + if localVarHTTPResponse.StatusCode == 400 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return localVarReturnValue, newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return localVarReturnValue, newErr + } + if localVarHTTPResponse.StatusCode == 401 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return localVarReturnValue, newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return localVarReturnValue, newErr + } + if localVarHTTPResponse.StatusCode == 409 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return localVarReturnValue, newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return localVarReturnValue, newErr + } + return localVarReturnValue, newErr + } + + err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr := &oapierror.GenericOpenAPIError{ + StatusCode: localVarHTTPResponse.StatusCode, + Body: localVarBody, + ErrorMessage: err.Error(), + } + return localVarReturnValue, newErr + } + + return localVarReturnValue, nil +} + +type ApiCreateProjectBackflushJobRequest struct { + ctx context.Context + ApiService DefaultAPI + projectId string + regionId string + createProjectBackflushJobPayload *CreateProjectBackflushJobPayload +} + +func (r ApiCreateProjectBackflushJobRequest) CreateProjectBackflushJobPayload(createProjectBackflushJobPayload CreateProjectBackflushJobPayload) ApiCreateProjectBackflushJobRequest { + r.createProjectBackflushJobPayload = &createProjectBackflushJobPayload + return r +} + +func (r ApiCreateProjectBackflushJobRequest) Execute() (*BackflushJobResponse, error) { + return r.ApiService.CreateProjectBackflushJobExecute(r) +} + +/* +CreateProjectBackflushJob Method for CreateProjectBackflushJob + +Creates a new Backflush Job for the project. + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param projectId The STACKIT portal project UUID the resource is located in. + @param regionId The STACKIT region name the resource is located in. + @return ApiCreateProjectBackflushJobRequest +*/ +func (a *DefaultAPIService) CreateProjectBackflushJob(ctx context.Context, projectId string, regionId string) ApiCreateProjectBackflushJobRequest { + return ApiCreateProjectBackflushJobRequest{ + ApiService: a, + ctx: ctx, + projectId: projectId, + regionId: regionId, + } +} + +// Execute executes the request +// +// @return BackflushJobResponse +func (a *DefaultAPIService) CreateProjectBackflushJobExecute(r ApiCreateProjectBackflushJobRequest) (*BackflushJobResponse, error) { + var ( + localVarHTTPMethod = http.MethodPost + localVarPostBody interface{} + formFiles []formFile + localVarReturnValue *BackflushJobResponse + ) + + localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.CreateProjectBackflushJob") + if err != nil { + return localVarReturnValue, &oapierror.GenericOpenAPIError{ErrorMessage: err.Error()} + } + + localVarPath := localBasePath + "/v1/projects/{projectId}/regions/{regionId}/telemetry-link/backflush-jobs" + localVarPath = strings.Replace(localVarPath, "{"+"projectId"+"}", url.PathEscape(parameterValueToString(r.projectId, "projectId")), -1) + localVarPath = strings.Replace(localVarPath, "{"+"regionId"+"}", url.PathEscape(parameterValueToString(r.regionId, "regionId")), -1) + + localVarHeaderParams := make(map[string]string) + localVarQueryParams := url.Values{} + localVarFormParams := url.Values{} + if r.createProjectBackflushJobPayload == nil { + return localVarReturnValue, reportError("createProjectBackflushJobPayload 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{"application/json"} + + // set Accept header + localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts) + if localVarHTTPHeaderAccept != "" { + localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept + } + // body params + localVarPostBody = r.createProjectBackflushJobPayload + req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles) + if err != nil { + return localVarReturnValue, err + } + + contextHTTPRequest, ok := r.ctx.Value(config.ContextHTTPRequest).(**http.Request) + if ok { + *contextHTTPRequest = req + } + + localVarHTTPResponse, err := a.client.callAPI(req) + contextHTTPResponse, ok := r.ctx.Value(config.ContextHTTPResponse).(**http.Response) + if ok { + *contextHTTPResponse = localVarHTTPResponse + } + if err != nil || localVarHTTPResponse == nil { + return localVarReturnValue, err + } + + localVarBody, err := io.ReadAll(localVarHTTPResponse.Body) + localVarHTTPResponse.Body.Close() + localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody)) + if err != nil { + return localVarReturnValue, err + } + + if localVarHTTPResponse.StatusCode >= 300 { + newErr := &oapierror.GenericOpenAPIError{ + Body: localVarBody, + ErrorMessage: localVarHTTPResponse.Status, + StatusCode: localVarHTTPResponse.StatusCode, + } + if localVarHTTPResponse.StatusCode == 400 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return localVarReturnValue, newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return localVarReturnValue, newErr + } + if localVarHTTPResponse.StatusCode == 401 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return localVarReturnValue, newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return localVarReturnValue, newErr + } + if localVarHTTPResponse.StatusCode == 409 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return localVarReturnValue, newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return localVarReturnValue, newErr + } + return localVarReturnValue, newErr + } + + err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr := &oapierror.GenericOpenAPIError{ + StatusCode: localVarHTTPResponse.StatusCode, + Body: localVarBody, + ErrorMessage: err.Error(), + } + return localVarReturnValue, newErr + } + + return localVarReturnValue, nil +} + +type ApiDeleteFolderTelemetryLinkRequest struct { + ctx context.Context + ApiService DefaultAPI + folderId string + regionId string +} + +func (r ApiDeleteFolderTelemetryLinkRequest) Execute() error { + return r.ApiService.DeleteFolderTelemetryLinkExecute(r) +} + +/* +DeleteFolderTelemetryLink Method for DeleteFolderTelemetryLink + +Deletes the given Telemetry Link within the folder. + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param folderId The STACKIT portal folder UUID the resource is located in. + @param regionId The STACKIT region name the resource is located in. + @return ApiDeleteFolderTelemetryLinkRequest +*/ +func (a *DefaultAPIService) DeleteFolderTelemetryLink(ctx context.Context, folderId string, regionId string) ApiDeleteFolderTelemetryLinkRequest { + return ApiDeleteFolderTelemetryLinkRequest{ + ApiService: a, + ctx: ctx, + folderId: folderId, + regionId: regionId, + } +} + +// Execute executes the request +func (a *DefaultAPIService) DeleteFolderTelemetryLinkExecute(r ApiDeleteFolderTelemetryLinkRequest) error { + var ( + localVarHTTPMethod = http.MethodDelete + localVarPostBody interface{} + formFiles []formFile + ) + + localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.DeleteFolderTelemetryLink") + if err != nil { + return &oapierror.GenericOpenAPIError{ErrorMessage: err.Error()} + } + + localVarPath := localBasePath + "/v1/folders/{folderId}/regions/{regionId}/telemetry-link" + localVarPath = strings.Replace(localVarPath, "{"+"folderId"+"}", url.PathEscape(parameterValueToString(r.folderId, "folderId")), -1) + localVarPath = strings.Replace(localVarPath, "{"+"regionId"+"}", url.PathEscape(parameterValueToString(r.regionId, "regionId")), -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{"application/json"} + + // 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 err + } + + contextHTTPRequest, ok := r.ctx.Value(config.ContextHTTPRequest).(**http.Request) + if ok { + *contextHTTPRequest = req + } + + localVarHTTPResponse, err := a.client.callAPI(req) + contextHTTPResponse, ok := r.ctx.Value(config.ContextHTTPResponse).(**http.Response) + if ok { + *contextHTTPResponse = localVarHTTPResponse + } + if err != nil || localVarHTTPResponse == nil { + return err + } + + localVarBody, err := io.ReadAll(localVarHTTPResponse.Body) + localVarHTTPResponse.Body.Close() + localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody)) + if err != nil { + return err + } + + if localVarHTTPResponse.StatusCode >= 300 { + newErr := &oapierror.GenericOpenAPIError{ + Body: localVarBody, + ErrorMessage: localVarHTTPResponse.Status, + StatusCode: localVarHTTPResponse.StatusCode, + } + if localVarHTTPResponse.StatusCode == 400 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return newErr + } + if localVarHTTPResponse.StatusCode == 401 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return newErr + } + if localVarHTTPResponse.StatusCode == 409 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return newErr + } + return newErr + } + + return nil +} + +type ApiDeleteOrganizationTelemetryLinkRequest struct { + ctx context.Context + ApiService DefaultAPI + organizationId string + regionId string +} + +func (r ApiDeleteOrganizationTelemetryLinkRequest) Execute() error { + return r.ApiService.DeleteOrganizationTelemetryLinkExecute(r) +} + +/* +DeleteOrganizationTelemetryLink Method for DeleteOrganizationTelemetryLink + +Deletes the given Telemetry Link within the organization. + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param organizationId The STACKIT portal organization UUID the resource is located in. + @param regionId The STACKIT region name the resource is located in. + @return ApiDeleteOrganizationTelemetryLinkRequest +*/ +func (a *DefaultAPIService) DeleteOrganizationTelemetryLink(ctx context.Context, organizationId string, regionId string) ApiDeleteOrganizationTelemetryLinkRequest { + return ApiDeleteOrganizationTelemetryLinkRequest{ + ApiService: a, + ctx: ctx, + organizationId: organizationId, + regionId: regionId, + } +} + +// Execute executes the request +func (a *DefaultAPIService) DeleteOrganizationTelemetryLinkExecute(r ApiDeleteOrganizationTelemetryLinkRequest) error { + var ( + localVarHTTPMethod = http.MethodDelete + localVarPostBody interface{} + formFiles []formFile + ) + + localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.DeleteOrganizationTelemetryLink") + if err != nil { + return &oapierror.GenericOpenAPIError{ErrorMessage: err.Error()} + } + + localVarPath := localBasePath + "/v1/organizations/{organizationId}/regions/{regionId}/telemetry-link" + localVarPath = strings.Replace(localVarPath, "{"+"organizationId"+"}", url.PathEscape(parameterValueToString(r.organizationId, "organizationId")), -1) + localVarPath = strings.Replace(localVarPath, "{"+"regionId"+"}", url.PathEscape(parameterValueToString(r.regionId, "regionId")), -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{"application/json"} + + // 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 err + } + + contextHTTPRequest, ok := r.ctx.Value(config.ContextHTTPRequest).(**http.Request) + if ok { + *contextHTTPRequest = req + } + + localVarHTTPResponse, err := a.client.callAPI(req) + contextHTTPResponse, ok := r.ctx.Value(config.ContextHTTPResponse).(**http.Response) + if ok { + *contextHTTPResponse = localVarHTTPResponse + } + if err != nil || localVarHTTPResponse == nil { + return err + } + + localVarBody, err := io.ReadAll(localVarHTTPResponse.Body) + localVarHTTPResponse.Body.Close() + localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody)) + if err != nil { + return err + } + + if localVarHTTPResponse.StatusCode >= 300 { + newErr := &oapierror.GenericOpenAPIError{ + Body: localVarBody, + ErrorMessage: localVarHTTPResponse.Status, + StatusCode: localVarHTTPResponse.StatusCode, + } + if localVarHTTPResponse.StatusCode == 400 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return newErr + } + if localVarHTTPResponse.StatusCode == 401 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return newErr + } + if localVarHTTPResponse.StatusCode == 409 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return newErr + } + return newErr + } + + return nil +} + +type ApiDeleteProjectTelemetryLinkRequest struct { + ctx context.Context + ApiService DefaultAPI + projectId string + regionId string +} + +func (r ApiDeleteProjectTelemetryLinkRequest) Execute() error { + return r.ApiService.DeleteProjectTelemetryLinkExecute(r) +} + +/* +DeleteProjectTelemetryLink Method for DeleteProjectTelemetryLink + +Deletes the given Telemetry Link within the project. + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param projectId The STACKIT portal project UUID the resource is located in. + @param regionId The STACKIT region name the resource is located in. + @return ApiDeleteProjectTelemetryLinkRequest +*/ +func (a *DefaultAPIService) DeleteProjectTelemetryLink(ctx context.Context, projectId string, regionId string) ApiDeleteProjectTelemetryLinkRequest { + return ApiDeleteProjectTelemetryLinkRequest{ + ApiService: a, + ctx: ctx, + projectId: projectId, + regionId: regionId, + } +} + +// Execute executes the request +func (a *DefaultAPIService) DeleteProjectTelemetryLinkExecute(r ApiDeleteProjectTelemetryLinkRequest) error { + var ( + localVarHTTPMethod = http.MethodDelete + localVarPostBody interface{} + formFiles []formFile + ) + + localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.DeleteProjectTelemetryLink") + if err != nil { + return &oapierror.GenericOpenAPIError{ErrorMessage: err.Error()} + } + + localVarPath := localBasePath + "/v1/projects/{projectId}/regions/{regionId}/telemetry-link" + localVarPath = strings.Replace(localVarPath, "{"+"projectId"+"}", url.PathEscape(parameterValueToString(r.projectId, "projectId")), -1) + localVarPath = strings.Replace(localVarPath, "{"+"regionId"+"}", url.PathEscape(parameterValueToString(r.regionId, "regionId")), -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{"application/json"} + + // 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 err + } + + contextHTTPRequest, ok := r.ctx.Value(config.ContextHTTPRequest).(**http.Request) + if ok { + *contextHTTPRequest = req + } + + localVarHTTPResponse, err := a.client.callAPI(req) + contextHTTPResponse, ok := r.ctx.Value(config.ContextHTTPResponse).(**http.Response) + if ok { + *contextHTTPResponse = localVarHTTPResponse + } + if err != nil || localVarHTTPResponse == nil { + return err + } + + localVarBody, err := io.ReadAll(localVarHTTPResponse.Body) + localVarHTTPResponse.Body.Close() + localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody)) + if err != nil { + return err + } + + if localVarHTTPResponse.StatusCode >= 300 { + newErr := &oapierror.GenericOpenAPIError{ + Body: localVarBody, + ErrorMessage: localVarHTTPResponse.Status, + StatusCode: localVarHTTPResponse.StatusCode, + } + if localVarHTTPResponse.StatusCode == 400 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return newErr + } + if localVarHTTPResponse.StatusCode == 401 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return newErr + } + if localVarHTTPResponse.StatusCode == 409 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return newErr + } + return newErr + } + + return nil +} + +type ApiGetFolderBackflushJobRequest struct { + ctx context.Context + ApiService DefaultAPI + folderId string + regionId string + backflushJobId string +} + +func (r ApiGetFolderBackflushJobRequest) Execute() (*BackflushJobResponse, error) { + return r.ApiService.GetFolderBackflushJobExecute(r) +} + +/* +GetFolderBackflushJob Method for GetFolderBackflushJob + +Returns the details for the given Backflush Job in a folder. + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param folderId The STACKIT portal folder UUID the resource is located in. + @param regionId The STACKIT region name the resource is located in. + @param backflushJobId The Backflush Job UUID. + @return ApiGetFolderBackflushJobRequest +*/ +func (a *DefaultAPIService) GetFolderBackflushJob(ctx context.Context, folderId string, regionId string, backflushJobId string) ApiGetFolderBackflushJobRequest { + return ApiGetFolderBackflushJobRequest{ + ApiService: a, + ctx: ctx, + folderId: folderId, + regionId: regionId, + backflushJobId: backflushJobId, + } +} + +// Execute executes the request +// +// @return BackflushJobResponse +func (a *DefaultAPIService) GetFolderBackflushJobExecute(r ApiGetFolderBackflushJobRequest) (*BackflushJobResponse, error) { + var ( + localVarHTTPMethod = http.MethodGet + localVarPostBody interface{} + formFiles []formFile + localVarReturnValue *BackflushJobResponse + ) + + localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.GetFolderBackflushJob") + if err != nil { + return localVarReturnValue, &oapierror.GenericOpenAPIError{ErrorMessage: err.Error()} + } + + localVarPath := localBasePath + "/v1/folders/{folderId}/regions/{regionId}/telemetry-link/backflush-jobs/{backflushJobId}" + localVarPath = strings.Replace(localVarPath, "{"+"folderId"+"}", url.PathEscape(parameterValueToString(r.folderId, "folderId")), -1) + localVarPath = strings.Replace(localVarPath, "{"+"regionId"+"}", url.PathEscape(parameterValueToString(r.regionId, "regionId")), -1) + localVarPath = strings.Replace(localVarPath, "{"+"backflushJobId"+"}", url.PathEscape(parameterValueToString(r.backflushJobId, "backflushJobId")), -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{"application/json"} + + // 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, err + } + + contextHTTPRequest, ok := r.ctx.Value(config.ContextHTTPRequest).(**http.Request) + if ok { + *contextHTTPRequest = req + } + + localVarHTTPResponse, err := a.client.callAPI(req) + contextHTTPResponse, ok := r.ctx.Value(config.ContextHTTPResponse).(**http.Response) + if ok { + *contextHTTPResponse = localVarHTTPResponse + } + if err != nil || localVarHTTPResponse == nil { + return localVarReturnValue, err + } + + localVarBody, err := io.ReadAll(localVarHTTPResponse.Body) + localVarHTTPResponse.Body.Close() + localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody)) + if err != nil { + return localVarReturnValue, err + } + + if localVarHTTPResponse.StatusCode >= 300 { + newErr := &oapierror.GenericOpenAPIError{ + Body: localVarBody, + ErrorMessage: localVarHTTPResponse.Status, + StatusCode: localVarHTTPResponse.StatusCode, + } + if localVarHTTPResponse.StatusCode == 400 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return localVarReturnValue, newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return localVarReturnValue, newErr + } + if localVarHTTPResponse.StatusCode == 401 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return localVarReturnValue, newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return localVarReturnValue, newErr + } + return localVarReturnValue, newErr + } + + err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr := &oapierror.GenericOpenAPIError{ + StatusCode: localVarHTTPResponse.StatusCode, + Body: localVarBody, + ErrorMessage: err.Error(), + } + return localVarReturnValue, newErr + } + + return localVarReturnValue, nil +} + +type ApiGetFolderTelemetryLinkRequest struct { + ctx context.Context + ApiService DefaultAPI + folderId string + regionId string +} + +func (r ApiGetFolderTelemetryLinkRequest) Execute() (*TelemetryLinkResponse, error) { + return r.ApiService.GetFolderTelemetryLinkExecute(r) +} + +/* +GetFolderTelemetryLink Method for GetFolderTelemetryLink + +Returns the details for the given Telemetry Link within the folder. + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param folderId The STACKIT portal folder UUID the resource is located in. + @param regionId The STACKIT region name the resource is located in. + @return ApiGetFolderTelemetryLinkRequest +*/ +func (a *DefaultAPIService) GetFolderTelemetryLink(ctx context.Context, folderId string, regionId string) ApiGetFolderTelemetryLinkRequest { + return ApiGetFolderTelemetryLinkRequest{ + ApiService: a, + ctx: ctx, + folderId: folderId, + regionId: regionId, + } +} + +// Execute executes the request +// +// @return TelemetryLinkResponse +func (a *DefaultAPIService) GetFolderTelemetryLinkExecute(r ApiGetFolderTelemetryLinkRequest) (*TelemetryLinkResponse, error) { + var ( + localVarHTTPMethod = http.MethodGet + localVarPostBody interface{} + formFiles []formFile + localVarReturnValue *TelemetryLinkResponse + ) + + localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.GetFolderTelemetryLink") + if err != nil { + return localVarReturnValue, &oapierror.GenericOpenAPIError{ErrorMessage: err.Error()} + } + + localVarPath := localBasePath + "/v1/folders/{folderId}/regions/{regionId}/telemetry-link" localVarPath = strings.Replace(localVarPath, "{"+"folderId"+"}", url.PathEscape(parameterValueToString(r.folderId, "folderId")), -1) localVarPath = strings.Replace(localVarPath, "{"+"regionId"+"}", url.PathEscape(parameterValueToString(r.regionId, "regionId")), -1) @@ -838,7 +2039,293 @@ func (a *DefaultAPIService) DeleteFolderTelemetryLinkExecute(r ApiDeleteFolderTe } req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles) if err != nil { - return err + return localVarReturnValue, err + } + + contextHTTPRequest, ok := r.ctx.Value(config.ContextHTTPRequest).(**http.Request) + if ok { + *contextHTTPRequest = req + } + + localVarHTTPResponse, err := a.client.callAPI(req) + contextHTTPResponse, ok := r.ctx.Value(config.ContextHTTPResponse).(**http.Response) + if ok { + *contextHTTPResponse = localVarHTTPResponse + } + if err != nil || localVarHTTPResponse == nil { + return localVarReturnValue, err + } + + localVarBody, err := io.ReadAll(localVarHTTPResponse.Body) + localVarHTTPResponse.Body.Close() + localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody)) + if err != nil { + return localVarReturnValue, err + } + + if localVarHTTPResponse.StatusCode >= 300 { + newErr := &oapierror.GenericOpenAPIError{ + Body: localVarBody, + ErrorMessage: localVarHTTPResponse.Status, + StatusCode: localVarHTTPResponse.StatusCode, + } + if localVarHTTPResponse.StatusCode == 400 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return localVarReturnValue, newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return localVarReturnValue, newErr + } + if localVarHTTPResponse.StatusCode == 401 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return localVarReturnValue, newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return localVarReturnValue, newErr + } + return localVarReturnValue, newErr + } + + err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr := &oapierror.GenericOpenAPIError{ + StatusCode: localVarHTTPResponse.StatusCode, + Body: localVarBody, + ErrorMessage: err.Error(), + } + return localVarReturnValue, newErr + } + + return localVarReturnValue, nil +} + +type ApiGetOrganizationBackflushJobRequest struct { + ctx context.Context + ApiService DefaultAPI + organizationId string + regionId string + backflushJobId string +} + +func (r ApiGetOrganizationBackflushJobRequest) Execute() (*BackflushJobResponse, error) { + return r.ApiService.GetOrganizationBackflushJobExecute(r) +} + +/* +GetOrganizationBackflushJob Method for GetOrganizationBackflushJob + +Returns the details for the given Backflush Job in a organization. + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param organizationId The STACKIT portal organization UUID the resource is located in. + @param regionId The STACKIT region name the resource is located in. + @param backflushJobId The Backflush Job UUID. + @return ApiGetOrganizationBackflushJobRequest +*/ +func (a *DefaultAPIService) GetOrganizationBackflushJob(ctx context.Context, organizationId string, regionId string, backflushJobId string) ApiGetOrganizationBackflushJobRequest { + return ApiGetOrganizationBackflushJobRequest{ + ApiService: a, + ctx: ctx, + organizationId: organizationId, + regionId: regionId, + backflushJobId: backflushJobId, + } +} + +// Execute executes the request +// +// @return BackflushJobResponse +func (a *DefaultAPIService) GetOrganizationBackflushJobExecute(r ApiGetOrganizationBackflushJobRequest) (*BackflushJobResponse, error) { + var ( + localVarHTTPMethod = http.MethodGet + localVarPostBody interface{} + formFiles []formFile + localVarReturnValue *BackflushJobResponse + ) + + localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.GetOrganizationBackflushJob") + if err != nil { + return localVarReturnValue, &oapierror.GenericOpenAPIError{ErrorMessage: err.Error()} + } + + localVarPath := localBasePath + "/v1/organizations/{organizationId}/regions/{regionId}/telemetry-link/backflush-jobs/{backflushJobId}" + localVarPath = strings.Replace(localVarPath, "{"+"organizationId"+"}", url.PathEscape(parameterValueToString(r.organizationId, "organizationId")), -1) + localVarPath = strings.Replace(localVarPath, "{"+"regionId"+"}", url.PathEscape(parameterValueToString(r.regionId, "regionId")), -1) + localVarPath = strings.Replace(localVarPath, "{"+"backflushJobId"+"}", url.PathEscape(parameterValueToString(r.backflushJobId, "backflushJobId")), -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{"application/json"} + + // 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, err + } + + contextHTTPRequest, ok := r.ctx.Value(config.ContextHTTPRequest).(**http.Request) + if ok { + *contextHTTPRequest = req + } + + localVarHTTPResponse, err := a.client.callAPI(req) + contextHTTPResponse, ok := r.ctx.Value(config.ContextHTTPResponse).(**http.Response) + if ok { + *contextHTTPResponse = localVarHTTPResponse + } + if err != nil || localVarHTTPResponse == nil { + return localVarReturnValue, err + } + + localVarBody, err := io.ReadAll(localVarHTTPResponse.Body) + localVarHTTPResponse.Body.Close() + localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody)) + if err != nil { + return localVarReturnValue, err + } + + if localVarHTTPResponse.StatusCode >= 300 { + newErr := &oapierror.GenericOpenAPIError{ + Body: localVarBody, + ErrorMessage: localVarHTTPResponse.Status, + StatusCode: localVarHTTPResponse.StatusCode, + } + if localVarHTTPResponse.StatusCode == 400 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return localVarReturnValue, newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return localVarReturnValue, newErr + } + if localVarHTTPResponse.StatusCode == 401 { + var v Response4xx + err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr.ErrorMessage = err.Error() + return localVarReturnValue, newErr + } + newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) + newErr.Model = v + return localVarReturnValue, newErr + } + return localVarReturnValue, newErr + } + + err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr := &oapierror.GenericOpenAPIError{ + StatusCode: localVarHTTPResponse.StatusCode, + Body: localVarBody, + ErrorMessage: err.Error(), + } + return localVarReturnValue, newErr + } + + return localVarReturnValue, nil +} + +type ApiGetOrganizationTelemetryLinkRequest struct { + ctx context.Context + ApiService DefaultAPI + organizationId string + regionId string +} + +func (r ApiGetOrganizationTelemetryLinkRequest) Execute() (*TelemetryLinkResponse, error) { + return r.ApiService.GetOrganizationTelemetryLinkExecute(r) +} + +/* +GetOrganizationTelemetryLink Method for GetOrganizationTelemetryLink + +Returns the details for the given Telemetry Link within the organization. + + @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). + @param organizationId The STACKIT portal organization UUID the resource is located in. + @param regionId The STACKIT region name the resource is located in. + @return ApiGetOrganizationTelemetryLinkRequest +*/ +func (a *DefaultAPIService) GetOrganizationTelemetryLink(ctx context.Context, organizationId string, regionId string) ApiGetOrganizationTelemetryLinkRequest { + return ApiGetOrganizationTelemetryLinkRequest{ + ApiService: a, + ctx: ctx, + organizationId: organizationId, + regionId: regionId, + } +} + +// Execute executes the request +// +// @return TelemetryLinkResponse +func (a *DefaultAPIService) GetOrganizationTelemetryLinkExecute(r ApiGetOrganizationTelemetryLinkRequest) (*TelemetryLinkResponse, error) { + var ( + localVarHTTPMethod = http.MethodGet + localVarPostBody interface{} + formFiles []formFile + localVarReturnValue *TelemetryLinkResponse + ) + + localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.GetOrganizationTelemetryLink") + if err != nil { + return localVarReturnValue, &oapierror.GenericOpenAPIError{ErrorMessage: err.Error()} + } + + localVarPath := localBasePath + "/v1/organizations/{organizationId}/regions/{regionId}/telemetry-link" + localVarPath = strings.Replace(localVarPath, "{"+"organizationId"+"}", url.PathEscape(parameterValueToString(r.organizationId, "organizationId")), -1) + localVarPath = strings.Replace(localVarPath, "{"+"regionId"+"}", url.PathEscape(parameterValueToString(r.regionId, "regionId")), -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{"application/json"} + + // 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, err } contextHTTPRequest, ok := r.ctx.Value(config.ContextHTTPRequest).(**http.Request) @@ -852,14 +2339,14 @@ func (a *DefaultAPIService) DeleteFolderTelemetryLinkExecute(r ApiDeleteFolderTe *contextHTTPResponse = localVarHTTPResponse } if err != nil || localVarHTTPResponse == nil { - return err + return localVarReturnValue, err } localVarBody, err := io.ReadAll(localVarHTTPResponse.Body) localVarHTTPResponse.Body.Close() localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody)) if err != nil { - return err + return localVarReturnValue, err } if localVarHTTPResponse.StatusCode >= 300 { @@ -873,86 +2360,92 @@ func (a *DefaultAPIService) DeleteFolderTelemetryLinkExecute(r ApiDeleteFolderTe err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) if err != nil { newErr.ErrorMessage = err.Error() - return newErr + return localVarReturnValue, newErr } newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) newErr.Model = v - return newErr + return localVarReturnValue, newErr } if localVarHTTPResponse.StatusCode == 401 { var v Response4xx err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) if err != nil { newErr.ErrorMessage = err.Error() - return newErr + return localVarReturnValue, newErr } newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) newErr.Model = v - return newErr + return localVarReturnValue, newErr } - if localVarHTTPResponse.StatusCode == 409 { - var v Response4xx - err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) - if err != nil { - newErr.ErrorMessage = err.Error() - return newErr - } - newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) - newErr.Model = v - return newErr + return localVarReturnValue, newErr + } + + err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr := &oapierror.GenericOpenAPIError{ + StatusCode: localVarHTTPResponse.StatusCode, + Body: localVarBody, + ErrorMessage: err.Error(), } - return newErr + return localVarReturnValue, newErr } - return nil + return localVarReturnValue, nil } -type ApiDeleteOrganizationTelemetryLinkRequest struct { +type ApiGetProjectBackflushJobRequest struct { ctx context.Context ApiService DefaultAPI - organizationId string + projectId string regionId string + backflushJobId string } -func (r ApiDeleteOrganizationTelemetryLinkRequest) Execute() error { - return r.ApiService.DeleteOrganizationTelemetryLinkExecute(r) +func (r ApiGetProjectBackflushJobRequest) Execute() (*BackflushJobResponse, error) { + return r.ApiService.GetProjectBackflushJobExecute(r) } /* -DeleteOrganizationTelemetryLink Method for DeleteOrganizationTelemetryLink +GetProjectBackflushJob Method for GetProjectBackflushJob -Deletes the given Telemetry Link within the organization. +Returns the details for the given Backflush Job in a project. @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). - @param organizationId The STACKIT portal organization UUID the resource is located in. + @param projectId The STACKIT portal project UUID the resource is located in. @param regionId The STACKIT region name the resource is located in. - @return ApiDeleteOrganizationTelemetryLinkRequest + @param backflushJobId The Backflush Job UUID. + @return ApiGetProjectBackflushJobRequest */ -func (a *DefaultAPIService) DeleteOrganizationTelemetryLink(ctx context.Context, organizationId string, regionId string) ApiDeleteOrganizationTelemetryLinkRequest { - return ApiDeleteOrganizationTelemetryLinkRequest{ +func (a *DefaultAPIService) GetProjectBackflushJob(ctx context.Context, projectId string, regionId string, backflushJobId string) ApiGetProjectBackflushJobRequest { + return ApiGetProjectBackflushJobRequest{ ApiService: a, ctx: ctx, - organizationId: organizationId, + projectId: projectId, regionId: regionId, + backflushJobId: backflushJobId, } } // Execute executes the request -func (a *DefaultAPIService) DeleteOrganizationTelemetryLinkExecute(r ApiDeleteOrganizationTelemetryLinkRequest) error { +// +// @return BackflushJobResponse +func (a *DefaultAPIService) GetProjectBackflushJobExecute(r ApiGetProjectBackflushJobRequest) (*BackflushJobResponse, error) { var ( - localVarHTTPMethod = http.MethodDelete - localVarPostBody interface{} - formFiles []formFile + localVarHTTPMethod = http.MethodGet + localVarPostBody interface{} + formFiles []formFile + localVarReturnValue *BackflushJobResponse ) - localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.DeleteOrganizationTelemetryLink") + localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.GetProjectBackflushJob") if err != nil { - return &oapierror.GenericOpenAPIError{ErrorMessage: err.Error()} + return localVarReturnValue, &oapierror.GenericOpenAPIError{ErrorMessage: err.Error()} } - localVarPath := localBasePath + "/v1/organizations/{organizationId}/regions/{regionId}/telemetry-link" - localVarPath = strings.Replace(localVarPath, "{"+"organizationId"+"}", url.PathEscape(parameterValueToString(r.organizationId, "organizationId")), -1) + localVarPath := localBasePath + "/v1/projects/{projectId}/regions/{regionId}/telemetry-link/backflush-jobs/{backflushJobId}" + localVarPath = strings.Replace(localVarPath, "{"+"projectId"+"}", url.PathEscape(parameterValueToString(r.projectId, "projectId")), -1) localVarPath = strings.Replace(localVarPath, "{"+"regionId"+"}", url.PathEscape(parameterValueToString(r.regionId, "regionId")), -1) + localVarPath = strings.Replace(localVarPath, "{"+"backflushJobId"+"}", url.PathEscape(parameterValueToString(r.backflushJobId, "backflushJobId")), -1) localVarHeaderParams := make(map[string]string) localVarQueryParams := url.Values{} @@ -977,7 +2470,7 @@ func (a *DefaultAPIService) DeleteOrganizationTelemetryLinkExecute(r ApiDeleteOr } req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles) if err != nil { - return err + return localVarReturnValue, err } contextHTTPRequest, ok := r.ctx.Value(config.ContextHTTPRequest).(**http.Request) @@ -991,14 +2484,14 @@ func (a *DefaultAPIService) DeleteOrganizationTelemetryLinkExecute(r ApiDeleteOr *contextHTTPResponse = localVarHTTPResponse } if err != nil || localVarHTTPResponse == nil { - return err + return localVarReturnValue, err } localVarBody, err := io.ReadAll(localVarHTTPResponse.Body) localVarHTTPResponse.Body.Close() localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody)) if err != nil { - return err + return localVarReturnValue, err } if localVarHTTPResponse.StatusCode >= 300 { @@ -1012,63 +2505,62 @@ func (a *DefaultAPIService) DeleteOrganizationTelemetryLinkExecute(r ApiDeleteOr err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) if err != nil { newErr.ErrorMessage = err.Error() - return newErr + return localVarReturnValue, newErr } newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) newErr.Model = v - return newErr + return localVarReturnValue, newErr } if localVarHTTPResponse.StatusCode == 401 { var v Response4xx err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) if err != nil { newErr.ErrorMessage = err.Error() - return newErr + return localVarReturnValue, newErr } newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) newErr.Model = v - return newErr + return localVarReturnValue, newErr } - if localVarHTTPResponse.StatusCode == 409 { - var v Response4xx - err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) - if err != nil { - newErr.ErrorMessage = err.Error() - return newErr - } - newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) - newErr.Model = v - return newErr + return localVarReturnValue, newErr + } + + err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr := &oapierror.GenericOpenAPIError{ + StatusCode: localVarHTTPResponse.StatusCode, + Body: localVarBody, + ErrorMessage: err.Error(), } - return newErr + return localVarReturnValue, newErr } - return nil + return localVarReturnValue, nil } -type ApiDeleteProjectTelemetryLinkRequest struct { +type ApiGetProjectTelemetryLinkRequest struct { ctx context.Context ApiService DefaultAPI projectId string regionId string } -func (r ApiDeleteProjectTelemetryLinkRequest) Execute() error { - return r.ApiService.DeleteProjectTelemetryLinkExecute(r) +func (r ApiGetProjectTelemetryLinkRequest) Execute() (*TelemetryLinkResponse, error) { + return r.ApiService.GetProjectTelemetryLinkExecute(r) } /* -DeleteProjectTelemetryLink Method for DeleteProjectTelemetryLink +GetProjectTelemetryLink Method for GetProjectTelemetryLink -Deletes the given Telemetry Link within the project. +Returns the details for the given Telemetry Link within the project. @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). @param projectId The STACKIT portal project UUID the resource is located in. @param regionId The STACKIT region name the resource is located in. - @return ApiDeleteProjectTelemetryLinkRequest + @return ApiGetProjectTelemetryLinkRequest */ -func (a *DefaultAPIService) DeleteProjectTelemetryLink(ctx context.Context, projectId string, regionId string) ApiDeleteProjectTelemetryLinkRequest { - return ApiDeleteProjectTelemetryLinkRequest{ +func (a *DefaultAPIService) GetProjectTelemetryLink(ctx context.Context, projectId string, regionId string) ApiGetProjectTelemetryLinkRequest { + return ApiGetProjectTelemetryLinkRequest{ ApiService: a, ctx: ctx, projectId: projectId, @@ -1077,16 +2569,19 @@ func (a *DefaultAPIService) DeleteProjectTelemetryLink(ctx context.Context, proj } // Execute executes the request -func (a *DefaultAPIService) DeleteProjectTelemetryLinkExecute(r ApiDeleteProjectTelemetryLinkRequest) error { +// +// @return TelemetryLinkResponse +func (a *DefaultAPIService) GetProjectTelemetryLinkExecute(r ApiGetProjectTelemetryLinkRequest) (*TelemetryLinkResponse, error) { var ( - localVarHTTPMethod = http.MethodDelete - localVarPostBody interface{} - formFiles []formFile + localVarHTTPMethod = http.MethodGet + localVarPostBody interface{} + formFiles []formFile + localVarReturnValue *TelemetryLinkResponse ) - localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.DeleteProjectTelemetryLink") + localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.GetProjectTelemetryLink") if err != nil { - return &oapierror.GenericOpenAPIError{ErrorMessage: err.Error()} + return localVarReturnValue, &oapierror.GenericOpenAPIError{ErrorMessage: err.Error()} } localVarPath := localBasePath + "/v1/projects/{projectId}/regions/{regionId}/telemetry-link" @@ -1116,7 +2611,7 @@ func (a *DefaultAPIService) DeleteProjectTelemetryLinkExecute(r ApiDeleteProject } req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles) if err != nil { - return err + return localVarReturnValue, err } contextHTTPRequest, ok := r.ctx.Value(config.ContextHTTPRequest).(**http.Request) @@ -1130,14 +2625,14 @@ func (a *DefaultAPIService) DeleteProjectTelemetryLinkExecute(r ApiDeleteProject *contextHTTPResponse = localVarHTTPResponse } if err != nil || localVarHTTPResponse == nil { - return err + return localVarReturnValue, err } localVarBody, err := io.ReadAll(localVarHTTPResponse.Body) localVarHTTPResponse.Body.Close() localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody)) if err != nil { - return err + return localVarReturnValue, err } if localVarHTTPResponse.StatusCode >= 300 { @@ -1151,63 +2646,76 @@ func (a *DefaultAPIService) DeleteProjectTelemetryLinkExecute(r ApiDeleteProject err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) if err != nil { newErr.ErrorMessage = err.Error() - return newErr + return localVarReturnValue, newErr } newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) newErr.Model = v - return newErr + return localVarReturnValue, newErr } if localVarHTTPResponse.StatusCode == 401 { var v Response4xx err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) if err != nil { newErr.ErrorMessage = err.Error() - return newErr + return localVarReturnValue, newErr } newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) newErr.Model = v - return newErr + return localVarReturnValue, newErr } - if localVarHTTPResponse.StatusCode == 409 { - var v Response4xx - err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) - if err != nil { - newErr.ErrorMessage = err.Error() - return newErr - } - newErr.ErrorMessage = oapierror.FormatErrorMessage(localVarHTTPResponse.Status, &v) - newErr.Model = v - return newErr + return localVarReturnValue, newErr + } + + err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type")) + if err != nil { + newErr := &oapierror.GenericOpenAPIError{ + StatusCode: localVarHTTPResponse.StatusCode, + Body: localVarBody, + ErrorMessage: err.Error(), } - return newErr + return localVarReturnValue, newErr } - return nil + return localVarReturnValue, nil } -type ApiGetFolderTelemetryLinkRequest struct { +type ApiListFolderBackflushJobsRequest struct { ctx context.Context ApiService DefaultAPI folderId string regionId string + pageToken *string + pageSize *int32 } -func (r ApiGetFolderTelemetryLinkRequest) Execute() (*TelemetryLinkResponse, error) { - return r.ApiService.GetFolderTelemetryLinkExecute(r) +// A token to retrieve the next page of results. +func (r ApiListFolderBackflushJobsRequest) PageToken(pageToken string) ApiListFolderBackflushJobsRequest { + r.pageToken = &pageToken + return r +} + +// Maximum number of items to return +func (r ApiListFolderBackflushJobsRequest) PageSize(pageSize int32) ApiListFolderBackflushJobsRequest { + r.pageSize = &pageSize + return r +} + +func (r ApiListFolderBackflushJobsRequest) Execute() (*ListBackflushJobsResponse, error) { + return r.ApiService.ListFolderBackflushJobsExecute(r) } /* -GetFolderTelemetryLink Method for GetFolderTelemetryLink +ListFolderBackflushJobs Method for ListFolderBackflushJobs -Returns the details for the given Telemetry Link within the folder. +Returns a list of all Backflush Jobs for the folder. @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). @param folderId The STACKIT portal folder UUID the resource is located in. @param regionId The STACKIT region name the resource is located in. - @return ApiGetFolderTelemetryLinkRequest + @return ApiListFolderBackflushJobsRequest */ -func (a *DefaultAPIService) GetFolderTelemetryLink(ctx context.Context, folderId string, regionId string) ApiGetFolderTelemetryLinkRequest { - return ApiGetFolderTelemetryLinkRequest{ +func (a *DefaultAPIService) ListFolderBackflushJobs(ctx context.Context, folderId string, regionId string) ApiListFolderBackflushJobsRequest { + return ApiListFolderBackflushJobsRequest{ ApiService: a, ctx: ctx, folderId: folderId, @@ -1217,21 +2725,21 @@ func (a *DefaultAPIService) GetFolderTelemetryLink(ctx context.Context, folderId // Execute executes the request // -// @return TelemetryLinkResponse -func (a *DefaultAPIService) GetFolderTelemetryLinkExecute(r ApiGetFolderTelemetryLinkRequest) (*TelemetryLinkResponse, error) { +// @return ListBackflushJobsResponse +func (a *DefaultAPIService) ListFolderBackflushJobsExecute(r ApiListFolderBackflushJobsRequest) (*ListBackflushJobsResponse, error) { var ( localVarHTTPMethod = http.MethodGet localVarPostBody interface{} formFiles []formFile - localVarReturnValue *TelemetryLinkResponse + localVarReturnValue *ListBackflushJobsResponse ) - localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.GetFolderTelemetryLink") + localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.ListFolderBackflushJobs") if err != nil { return localVarReturnValue, &oapierror.GenericOpenAPIError{ErrorMessage: err.Error()} } - localVarPath := localBasePath + "/v1/folders/{folderId}/regions/{regionId}/telemetry-link" + localVarPath := localBasePath + "/v1/folders/{folderId}/regions/{regionId}/telemetry-link/backflush-jobs" localVarPath = strings.Replace(localVarPath, "{"+"folderId"+"}", url.PathEscape(parameterValueToString(r.folderId, "folderId")), -1) localVarPath = strings.Replace(localVarPath, "{"+"regionId"+"}", url.PathEscape(parameterValueToString(r.regionId, "regionId")), -1) @@ -1239,6 +2747,16 @@ func (a *DefaultAPIService) GetFolderTelemetryLinkExecute(r ApiGetFolderTelemetr localVarQueryParams := url.Values{} localVarFormParams := url.Values{} + if r.pageToken != nil { + parameterAddToHeaderOrQuery(localVarQueryParams, "pageToken", r.pageToken, "form", "") + } + if r.pageSize != nil { + parameterAddToHeaderOrQuery(localVarQueryParams, "pageSize", r.pageSize, "form", "") + } else { + var defaultValue int32 = 10 + parameterAddToHeaderOrQuery(localVarQueryParams, "pageSize", defaultValue, "form", "") + r.pageSize = &defaultValue + } // to determine the Content-Type header localVarHTTPContentTypes := []string{} @@ -1326,29 +2844,43 @@ func (a *DefaultAPIService) GetFolderTelemetryLinkExecute(r ApiGetFolderTelemetr return localVarReturnValue, nil } -type ApiGetOrganizationTelemetryLinkRequest struct { +type ApiListOrganizationBackflushJobsRequest struct { ctx context.Context ApiService DefaultAPI organizationId string regionId string + pageToken *string + pageSize *int32 } -func (r ApiGetOrganizationTelemetryLinkRequest) Execute() (*TelemetryLinkResponse, error) { - return r.ApiService.GetOrganizationTelemetryLinkExecute(r) +// A token to retrieve the next page of results. +func (r ApiListOrganizationBackflushJobsRequest) PageToken(pageToken string) ApiListOrganizationBackflushJobsRequest { + r.pageToken = &pageToken + return r +} + +// Maximum number of items to return +func (r ApiListOrganizationBackflushJobsRequest) PageSize(pageSize int32) ApiListOrganizationBackflushJobsRequest { + r.pageSize = &pageSize + return r +} + +func (r ApiListOrganizationBackflushJobsRequest) Execute() (*ListBackflushJobsResponse, error) { + return r.ApiService.ListOrganizationBackflushJobsExecute(r) } /* -GetOrganizationTelemetryLink Method for GetOrganizationTelemetryLink +ListOrganizationBackflushJobs Method for ListOrganizationBackflushJobs -Returns the details for the given Telemetry Link within the organization. +Returns a list of all Backflush Jobs for the organization. @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). @param organizationId The STACKIT portal organization UUID the resource is located in. @param regionId The STACKIT region name the resource is located in. - @return ApiGetOrganizationTelemetryLinkRequest + @return ApiListOrganizationBackflushJobsRequest */ -func (a *DefaultAPIService) GetOrganizationTelemetryLink(ctx context.Context, organizationId string, regionId string) ApiGetOrganizationTelemetryLinkRequest { - return ApiGetOrganizationTelemetryLinkRequest{ +func (a *DefaultAPIService) ListOrganizationBackflushJobs(ctx context.Context, organizationId string, regionId string) ApiListOrganizationBackflushJobsRequest { + return ApiListOrganizationBackflushJobsRequest{ ApiService: a, ctx: ctx, organizationId: organizationId, @@ -1358,21 +2890,21 @@ func (a *DefaultAPIService) GetOrganizationTelemetryLink(ctx context.Context, or // Execute executes the request // -// @return TelemetryLinkResponse -func (a *DefaultAPIService) GetOrganizationTelemetryLinkExecute(r ApiGetOrganizationTelemetryLinkRequest) (*TelemetryLinkResponse, error) { +// @return ListBackflushJobsResponse +func (a *DefaultAPIService) ListOrganizationBackflushJobsExecute(r ApiListOrganizationBackflushJobsRequest) (*ListBackflushJobsResponse, error) { var ( localVarHTTPMethod = http.MethodGet localVarPostBody interface{} formFiles []formFile - localVarReturnValue *TelemetryLinkResponse + localVarReturnValue *ListBackflushJobsResponse ) - localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.GetOrganizationTelemetryLink") + localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.ListOrganizationBackflushJobs") if err != nil { return localVarReturnValue, &oapierror.GenericOpenAPIError{ErrorMessage: err.Error()} } - localVarPath := localBasePath + "/v1/organizations/{organizationId}/regions/{regionId}/telemetry-link" + localVarPath := localBasePath + "/v1/organizations/{organizationId}/regions/{regionId}/telemetry-link/backflush-jobs" localVarPath = strings.Replace(localVarPath, "{"+"organizationId"+"}", url.PathEscape(parameterValueToString(r.organizationId, "organizationId")), -1) localVarPath = strings.Replace(localVarPath, "{"+"regionId"+"}", url.PathEscape(parameterValueToString(r.regionId, "regionId")), -1) @@ -1380,6 +2912,16 @@ func (a *DefaultAPIService) GetOrganizationTelemetryLinkExecute(r ApiGetOrganiza localVarQueryParams := url.Values{} localVarFormParams := url.Values{} + if r.pageToken != nil { + parameterAddToHeaderOrQuery(localVarQueryParams, "pageToken", r.pageToken, "form", "") + } + if r.pageSize != nil { + parameterAddToHeaderOrQuery(localVarQueryParams, "pageSize", r.pageSize, "form", "") + } else { + var defaultValue int32 = 10 + parameterAddToHeaderOrQuery(localVarQueryParams, "pageSize", defaultValue, "form", "") + r.pageSize = &defaultValue + } // to determine the Content-Type header localVarHTTPContentTypes := []string{} @@ -1467,29 +3009,43 @@ func (a *DefaultAPIService) GetOrganizationTelemetryLinkExecute(r ApiGetOrganiza return localVarReturnValue, nil } -type ApiGetProjectTelemetryLinkRequest struct { +type ApiListProjectBackflushJobsRequest struct { ctx context.Context ApiService DefaultAPI projectId string regionId string + pageToken *string + pageSize *int32 } -func (r ApiGetProjectTelemetryLinkRequest) Execute() (*TelemetryLinkResponse, error) { - return r.ApiService.GetProjectTelemetryLinkExecute(r) +// A token to retrieve the next page of results. +func (r ApiListProjectBackflushJobsRequest) PageToken(pageToken string) ApiListProjectBackflushJobsRequest { + r.pageToken = &pageToken + return r +} + +// Maximum number of items to return +func (r ApiListProjectBackflushJobsRequest) PageSize(pageSize int32) ApiListProjectBackflushJobsRequest { + r.pageSize = &pageSize + return r +} + +func (r ApiListProjectBackflushJobsRequest) Execute() (*ListBackflushJobsResponse, error) { + return r.ApiService.ListProjectBackflushJobsExecute(r) } /* -GetProjectTelemetryLink Method for GetProjectTelemetryLink +ListProjectBackflushJobs Method for ListProjectBackflushJobs -Returns the details for the given Telemetry Link within the project. +Returns a list of all Backflush Jobs for the project. @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). @param projectId The STACKIT portal project UUID the resource is located in. @param regionId The STACKIT region name the resource is located in. - @return ApiGetProjectTelemetryLinkRequest + @return ApiListProjectBackflushJobsRequest */ -func (a *DefaultAPIService) GetProjectTelemetryLink(ctx context.Context, projectId string, regionId string) ApiGetProjectTelemetryLinkRequest { - return ApiGetProjectTelemetryLinkRequest{ +func (a *DefaultAPIService) ListProjectBackflushJobs(ctx context.Context, projectId string, regionId string) ApiListProjectBackflushJobsRequest { + return ApiListProjectBackflushJobsRequest{ ApiService: a, ctx: ctx, projectId: projectId, @@ -1499,21 +3055,21 @@ func (a *DefaultAPIService) GetProjectTelemetryLink(ctx context.Context, project // Execute executes the request // -// @return TelemetryLinkResponse -func (a *DefaultAPIService) GetProjectTelemetryLinkExecute(r ApiGetProjectTelemetryLinkRequest) (*TelemetryLinkResponse, error) { +// @return ListBackflushJobsResponse +func (a *DefaultAPIService) ListProjectBackflushJobsExecute(r ApiListProjectBackflushJobsRequest) (*ListBackflushJobsResponse, error) { var ( localVarHTTPMethod = http.MethodGet localVarPostBody interface{} formFiles []formFile - localVarReturnValue *TelemetryLinkResponse + localVarReturnValue *ListBackflushJobsResponse ) - localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.GetProjectTelemetryLink") + localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "DefaultAPIService.ListProjectBackflushJobs") if err != nil { return localVarReturnValue, &oapierror.GenericOpenAPIError{ErrorMessage: err.Error()} } - localVarPath := localBasePath + "/v1/projects/{projectId}/regions/{regionId}/telemetry-link" + localVarPath := localBasePath + "/v1/projects/{projectId}/regions/{regionId}/telemetry-link/backflush-jobs" localVarPath = strings.Replace(localVarPath, "{"+"projectId"+"}", url.PathEscape(parameterValueToString(r.projectId, "projectId")), -1) localVarPath = strings.Replace(localVarPath, "{"+"regionId"+"}", url.PathEscape(parameterValueToString(r.regionId, "regionId")), -1) @@ -1521,6 +3077,16 @@ func (a *DefaultAPIService) GetProjectTelemetryLinkExecute(r ApiGetProjectTeleme localVarQueryParams := url.Values{} localVarFormParams := url.Values{} + if r.pageToken != nil { + parameterAddToHeaderOrQuery(localVarQueryParams, "pageToken", r.pageToken, "form", "") + } + if r.pageSize != nil { + parameterAddToHeaderOrQuery(localVarQueryParams, "pageSize", r.pageSize, "form", "") + } else { + var defaultValue int32 = 10 + parameterAddToHeaderOrQuery(localVarQueryParams, "pageSize", defaultValue, "form", "") + r.pageSize = &defaultValue + } // to determine the Content-Type header localVarHTTPContentTypes := []string{} diff --git a/services/telemetrylink/v1api/api_default_mock.go b/services/telemetrylink/v1api/api_default_mock.go index 26e8d53a6c..b95ec59091 100644 --- a/services/telemetrylink/v1api/api_default_mock.go +++ b/services/telemetrylink/v1api/api_default_mock.go @@ -20,24 +20,42 @@ var _ DefaultAPI = &DefaultAPIServiceMock{} // DefaultAPIServiceMock is meant to be used for testing only as a replacement for DefaultAPIService. // By default all FooExecute() implementations are a no-op. Behavior of the mock can be customized by populating the callbacks in this struct. type DefaultAPIServiceMock struct { + // CreateFolderBackflushJobExecuteMock can be populated to implement the behavior of the CreateFolderBackflushJobExecute function of this mock + CreateFolderBackflushJobExecuteMock *func(r ApiCreateFolderBackflushJobRequest) (*BackflushJobResponse, error) // CreateOrUpdateFolderTelemetryLinkExecuteMock can be populated to implement the behavior of the CreateOrUpdateFolderTelemetryLinkExecute function of this mock CreateOrUpdateFolderTelemetryLinkExecuteMock *func(r ApiCreateOrUpdateFolderTelemetryLinkRequest) (*TelemetryLinkResponse, error) // CreateOrUpdateOrganizationTelemetryLinkExecuteMock can be populated to implement the behavior of the CreateOrUpdateOrganizationTelemetryLinkExecute function of this mock CreateOrUpdateOrganizationTelemetryLinkExecuteMock *func(r ApiCreateOrUpdateOrganizationTelemetryLinkRequest) (*TelemetryLinkResponse, error) // CreateOrUpdateProjectTelemetryLinkExecuteMock can be populated to implement the behavior of the CreateOrUpdateProjectTelemetryLinkExecute function of this mock CreateOrUpdateProjectTelemetryLinkExecuteMock *func(r ApiCreateOrUpdateProjectTelemetryLinkRequest) (*TelemetryLinkResponse, error) + // CreateOrganizationBackflushJobExecuteMock can be populated to implement the behavior of the CreateOrganizationBackflushJobExecute function of this mock + CreateOrganizationBackflushJobExecuteMock *func(r ApiCreateOrganizationBackflushJobRequest) (*BackflushJobResponse, error) + // CreateProjectBackflushJobExecuteMock can be populated to implement the behavior of the CreateProjectBackflushJobExecute function of this mock + CreateProjectBackflushJobExecuteMock *func(r ApiCreateProjectBackflushJobRequest) (*BackflushJobResponse, error) // DeleteFolderTelemetryLinkExecuteMock can be populated to implement the behavior of the DeleteFolderTelemetryLinkExecute function of this mock DeleteFolderTelemetryLinkExecuteMock *func(r ApiDeleteFolderTelemetryLinkRequest) error // DeleteOrganizationTelemetryLinkExecuteMock can be populated to implement the behavior of the DeleteOrganizationTelemetryLinkExecute function of this mock DeleteOrganizationTelemetryLinkExecuteMock *func(r ApiDeleteOrganizationTelemetryLinkRequest) error // DeleteProjectTelemetryLinkExecuteMock can be populated to implement the behavior of the DeleteProjectTelemetryLinkExecute function of this mock DeleteProjectTelemetryLinkExecuteMock *func(r ApiDeleteProjectTelemetryLinkRequest) error + // GetFolderBackflushJobExecuteMock can be populated to implement the behavior of the GetFolderBackflushJobExecute function of this mock + GetFolderBackflushJobExecuteMock *func(r ApiGetFolderBackflushJobRequest) (*BackflushJobResponse, error) // GetFolderTelemetryLinkExecuteMock can be populated to implement the behavior of the GetFolderTelemetryLinkExecute function of this mock GetFolderTelemetryLinkExecuteMock *func(r ApiGetFolderTelemetryLinkRequest) (*TelemetryLinkResponse, error) + // GetOrganizationBackflushJobExecuteMock can be populated to implement the behavior of the GetOrganizationBackflushJobExecute function of this mock + GetOrganizationBackflushJobExecuteMock *func(r ApiGetOrganizationBackflushJobRequest) (*BackflushJobResponse, error) // GetOrganizationTelemetryLinkExecuteMock can be populated to implement the behavior of the GetOrganizationTelemetryLinkExecute function of this mock GetOrganizationTelemetryLinkExecuteMock *func(r ApiGetOrganizationTelemetryLinkRequest) (*TelemetryLinkResponse, error) + // GetProjectBackflushJobExecuteMock can be populated to implement the behavior of the GetProjectBackflushJobExecute function of this mock + GetProjectBackflushJobExecuteMock *func(r ApiGetProjectBackflushJobRequest) (*BackflushJobResponse, error) // GetProjectTelemetryLinkExecuteMock can be populated to implement the behavior of the GetProjectTelemetryLinkExecute function of this mock GetProjectTelemetryLinkExecuteMock *func(r ApiGetProjectTelemetryLinkRequest) (*TelemetryLinkResponse, error) + // ListFolderBackflushJobsExecuteMock can be populated to implement the behavior of the ListFolderBackflushJobsExecute function of this mock + ListFolderBackflushJobsExecuteMock *func(r ApiListFolderBackflushJobsRequest) (*ListBackflushJobsResponse, error) + // ListOrganizationBackflushJobsExecuteMock can be populated to implement the behavior of the ListOrganizationBackflushJobsExecute function of this mock + ListOrganizationBackflushJobsExecuteMock *func(r ApiListOrganizationBackflushJobsRequest) (*ListBackflushJobsResponse, error) + // ListProjectBackflushJobsExecuteMock can be populated to implement the behavior of the ListProjectBackflushJobsExecute function of this mock + ListProjectBackflushJobsExecuteMock *func(r ApiListProjectBackflushJobsRequest) (*ListBackflushJobsResponse, error) // PartialUpdateFolderTelemetryLinkExecuteMock can be populated to implement the behavior of the PartialUpdateFolderTelemetryLinkExecute function of this mock PartialUpdateFolderTelemetryLinkExecuteMock *func(r ApiPartialUpdateFolderTelemetryLinkRequest) (*TelemetryLinkResponse, error) // PartialUpdateOrganizationTelemetryLinkExecuteMock can be populated to implement the behavior of the PartialUpdateOrganizationTelemetryLinkExecute function of this mock @@ -46,6 +64,25 @@ type DefaultAPIServiceMock struct { PartialUpdateProjectTelemetryLinkExecuteMock *func(r ApiPartialUpdateProjectTelemetryLinkRequest) (*TelemetryLinkResponse, error) } +func (a DefaultAPIServiceMock) CreateFolderBackflushJob(ctx context.Context, folderId string, regionId string) ApiCreateFolderBackflushJobRequest { + return ApiCreateFolderBackflushJobRequest{ + ApiService: a, + ctx: ctx, + folderId: folderId, + regionId: regionId, + } +} + +// CreateFolderBackflushJobExecute is a no-op by default and will return only return nil values. Behavior can be controlled by populating the CreateFolderBackflushJobExecuteMock field in the DefaultAPIServiceMock struct. +func (a DefaultAPIServiceMock) CreateFolderBackflushJobExecute(r ApiCreateFolderBackflushJobRequest) (*BackflushJobResponse, error) { + if a.CreateFolderBackflushJobExecuteMock == nil { + var localVarReturnValue *BackflushJobResponse + return localVarReturnValue, nil + } + + return (*a.CreateFolderBackflushJobExecuteMock)(r) +} + func (a DefaultAPIServiceMock) CreateOrUpdateFolderTelemetryLink(ctx context.Context, folderId string, regionId string) ApiCreateOrUpdateFolderTelemetryLinkRequest { return ApiCreateOrUpdateFolderTelemetryLinkRequest{ ApiService: a, @@ -103,6 +140,44 @@ func (a DefaultAPIServiceMock) CreateOrUpdateProjectTelemetryLinkExecute(r ApiCr return (*a.CreateOrUpdateProjectTelemetryLinkExecuteMock)(r) } +func (a DefaultAPIServiceMock) CreateOrganizationBackflushJob(ctx context.Context, organizationId string, regionId string) ApiCreateOrganizationBackflushJobRequest { + return ApiCreateOrganizationBackflushJobRequest{ + ApiService: a, + ctx: ctx, + organizationId: organizationId, + regionId: regionId, + } +} + +// CreateOrganizationBackflushJobExecute is a no-op by default and will return only return nil values. Behavior can be controlled by populating the CreateOrganizationBackflushJobExecuteMock field in the DefaultAPIServiceMock struct. +func (a DefaultAPIServiceMock) CreateOrganizationBackflushJobExecute(r ApiCreateOrganizationBackflushJobRequest) (*BackflushJobResponse, error) { + if a.CreateOrganizationBackflushJobExecuteMock == nil { + var localVarReturnValue *BackflushJobResponse + return localVarReturnValue, nil + } + + return (*a.CreateOrganizationBackflushJobExecuteMock)(r) +} + +func (a DefaultAPIServiceMock) CreateProjectBackflushJob(ctx context.Context, projectId string, regionId string) ApiCreateProjectBackflushJobRequest { + return ApiCreateProjectBackflushJobRequest{ + ApiService: a, + ctx: ctx, + projectId: projectId, + regionId: regionId, + } +} + +// CreateProjectBackflushJobExecute is a no-op by default and will return only return nil values. Behavior can be controlled by populating the CreateProjectBackflushJobExecuteMock field in the DefaultAPIServiceMock struct. +func (a DefaultAPIServiceMock) CreateProjectBackflushJobExecute(r ApiCreateProjectBackflushJobRequest) (*BackflushJobResponse, error) { + if a.CreateProjectBackflushJobExecuteMock == nil { + var localVarReturnValue *BackflushJobResponse + return localVarReturnValue, nil + } + + return (*a.CreateProjectBackflushJobExecuteMock)(r) +} + func (a DefaultAPIServiceMock) DeleteFolderTelemetryLink(ctx context.Context, folderId string, regionId string) ApiDeleteFolderTelemetryLinkRequest { return ApiDeleteFolderTelemetryLinkRequest{ ApiService: a, @@ -157,6 +232,26 @@ func (a DefaultAPIServiceMock) DeleteProjectTelemetryLinkExecute(r ApiDeleteProj return (*a.DeleteProjectTelemetryLinkExecuteMock)(r) } +func (a DefaultAPIServiceMock) GetFolderBackflushJob(ctx context.Context, folderId string, regionId string, backflushJobId string) ApiGetFolderBackflushJobRequest { + return ApiGetFolderBackflushJobRequest{ + ApiService: a, + ctx: ctx, + folderId: folderId, + regionId: regionId, + backflushJobId: backflushJobId, + } +} + +// GetFolderBackflushJobExecute is a no-op by default and will return only return nil values. Behavior can be controlled by populating the GetFolderBackflushJobExecuteMock field in the DefaultAPIServiceMock struct. +func (a DefaultAPIServiceMock) GetFolderBackflushJobExecute(r ApiGetFolderBackflushJobRequest) (*BackflushJobResponse, error) { + if a.GetFolderBackflushJobExecuteMock == nil { + var localVarReturnValue *BackflushJobResponse + return localVarReturnValue, nil + } + + return (*a.GetFolderBackflushJobExecuteMock)(r) +} + func (a DefaultAPIServiceMock) GetFolderTelemetryLink(ctx context.Context, folderId string, regionId string) ApiGetFolderTelemetryLinkRequest { return ApiGetFolderTelemetryLinkRequest{ ApiService: a, @@ -176,6 +271,26 @@ func (a DefaultAPIServiceMock) GetFolderTelemetryLinkExecute(r ApiGetFolderTelem return (*a.GetFolderTelemetryLinkExecuteMock)(r) } +func (a DefaultAPIServiceMock) GetOrganizationBackflushJob(ctx context.Context, organizationId string, regionId string, backflushJobId string) ApiGetOrganizationBackflushJobRequest { + return ApiGetOrganizationBackflushJobRequest{ + ApiService: a, + ctx: ctx, + organizationId: organizationId, + regionId: regionId, + backflushJobId: backflushJobId, + } +} + +// GetOrganizationBackflushJobExecute is a no-op by default and will return only return nil values. Behavior can be controlled by populating the GetOrganizationBackflushJobExecuteMock field in the DefaultAPIServiceMock struct. +func (a DefaultAPIServiceMock) GetOrganizationBackflushJobExecute(r ApiGetOrganizationBackflushJobRequest) (*BackflushJobResponse, error) { + if a.GetOrganizationBackflushJobExecuteMock == nil { + var localVarReturnValue *BackflushJobResponse + return localVarReturnValue, nil + } + + return (*a.GetOrganizationBackflushJobExecuteMock)(r) +} + func (a DefaultAPIServiceMock) GetOrganizationTelemetryLink(ctx context.Context, organizationId string, regionId string) ApiGetOrganizationTelemetryLinkRequest { return ApiGetOrganizationTelemetryLinkRequest{ ApiService: a, @@ -195,6 +310,26 @@ func (a DefaultAPIServiceMock) GetOrganizationTelemetryLinkExecute(r ApiGetOrgan return (*a.GetOrganizationTelemetryLinkExecuteMock)(r) } +func (a DefaultAPIServiceMock) GetProjectBackflushJob(ctx context.Context, projectId string, regionId string, backflushJobId string) ApiGetProjectBackflushJobRequest { + return ApiGetProjectBackflushJobRequest{ + ApiService: a, + ctx: ctx, + projectId: projectId, + regionId: regionId, + backflushJobId: backflushJobId, + } +} + +// GetProjectBackflushJobExecute is a no-op by default and will return only return nil values. Behavior can be controlled by populating the GetProjectBackflushJobExecuteMock field in the DefaultAPIServiceMock struct. +func (a DefaultAPIServiceMock) GetProjectBackflushJobExecute(r ApiGetProjectBackflushJobRequest) (*BackflushJobResponse, error) { + if a.GetProjectBackflushJobExecuteMock == nil { + var localVarReturnValue *BackflushJobResponse + return localVarReturnValue, nil + } + + return (*a.GetProjectBackflushJobExecuteMock)(r) +} + func (a DefaultAPIServiceMock) GetProjectTelemetryLink(ctx context.Context, projectId string, regionId string) ApiGetProjectTelemetryLinkRequest { return ApiGetProjectTelemetryLinkRequest{ ApiService: a, @@ -214,6 +349,63 @@ func (a DefaultAPIServiceMock) GetProjectTelemetryLinkExecute(r ApiGetProjectTel return (*a.GetProjectTelemetryLinkExecuteMock)(r) } +func (a DefaultAPIServiceMock) ListFolderBackflushJobs(ctx context.Context, folderId string, regionId string) ApiListFolderBackflushJobsRequest { + return ApiListFolderBackflushJobsRequest{ + ApiService: a, + ctx: ctx, + folderId: folderId, + regionId: regionId, + } +} + +// ListFolderBackflushJobsExecute is a no-op by default and will return only return nil values. Behavior can be controlled by populating the ListFolderBackflushJobsExecuteMock field in the DefaultAPIServiceMock struct. +func (a DefaultAPIServiceMock) ListFolderBackflushJobsExecute(r ApiListFolderBackflushJobsRequest) (*ListBackflushJobsResponse, error) { + if a.ListFolderBackflushJobsExecuteMock == nil { + var localVarReturnValue *ListBackflushJobsResponse + return localVarReturnValue, nil + } + + return (*a.ListFolderBackflushJobsExecuteMock)(r) +} + +func (a DefaultAPIServiceMock) ListOrganizationBackflushJobs(ctx context.Context, organizationId string, regionId string) ApiListOrganizationBackflushJobsRequest { + return ApiListOrganizationBackflushJobsRequest{ + ApiService: a, + ctx: ctx, + organizationId: organizationId, + regionId: regionId, + } +} + +// ListOrganizationBackflushJobsExecute is a no-op by default and will return only return nil values. Behavior can be controlled by populating the ListOrganizationBackflushJobsExecuteMock field in the DefaultAPIServiceMock struct. +func (a DefaultAPIServiceMock) ListOrganizationBackflushJobsExecute(r ApiListOrganizationBackflushJobsRequest) (*ListBackflushJobsResponse, error) { + if a.ListOrganizationBackflushJobsExecuteMock == nil { + var localVarReturnValue *ListBackflushJobsResponse + return localVarReturnValue, nil + } + + return (*a.ListOrganizationBackflushJobsExecuteMock)(r) +} + +func (a DefaultAPIServiceMock) ListProjectBackflushJobs(ctx context.Context, projectId string, regionId string) ApiListProjectBackflushJobsRequest { + return ApiListProjectBackflushJobsRequest{ + ApiService: a, + ctx: ctx, + projectId: projectId, + regionId: regionId, + } +} + +// ListProjectBackflushJobsExecute is a no-op by default and will return only return nil values. Behavior can be controlled by populating the ListProjectBackflushJobsExecuteMock field in the DefaultAPIServiceMock struct. +func (a DefaultAPIServiceMock) ListProjectBackflushJobsExecute(r ApiListProjectBackflushJobsRequest) (*ListBackflushJobsResponse, error) { + if a.ListProjectBackflushJobsExecuteMock == nil { + var localVarReturnValue *ListBackflushJobsResponse + return localVarReturnValue, nil + } + + return (*a.ListProjectBackflushJobsExecuteMock)(r) +} + func (a DefaultAPIServiceMock) PartialUpdateFolderTelemetryLink(ctx context.Context, folderId string, regionId string) ApiPartialUpdateFolderTelemetryLinkRequest { return ApiPartialUpdateFolderTelemetryLinkRequest{ ApiService: a, diff --git a/services/telemetrylink/v1api/model_backflush_job_response.go b/services/telemetrylink/v1api/model_backflush_job_response.go new file mode 100644 index 0000000000..f24b89360d --- /dev/null +++ b/services/telemetrylink/v1api/model_backflush_job_response.go @@ -0,0 +1,324 @@ +/* +STACKIT Telemetry Link API + +This API provides endpoints for managing Telemetry Links. The Telemetry Link enables Log Routing towards a defined Telemetry Router. + +API version: 1.0 +*/ + +// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT. + +package v1api + +import ( + "encoding/json" + "fmt" + "time" +) + +// checks if the BackflushJobResponse type satisfies the MappedNullable interface at compile time +var _ MappedNullable = &BackflushJobResponse{} + +// BackflushJobResponse struct for BackflushJobResponse +type BackflushJobResponse struct { + // The point in time the resource was created. + CreateTime time.Time `json:"createTime"` + // The description is a longer text chosen by the user to provide more context for the resource. + Description *string `json:"description,omitempty" validate:"regexp=^([a-zA-Z0-9][a-zA-Z0-9 \\-]*)?$"` + // The display name is a short name chosen by the user to identify the resource. + DisplayName string `json:"displayName"` + // A auto generated unique id which identifies the resource. + Id string `json:"id"` + RegionId string `json:"regionId"` + Status BackflushJobResponseStatus `json:"status"` + AdditionalProperties map[string]interface{} +} + +type _BackflushJobResponse BackflushJobResponse + +// NewBackflushJobResponse instantiates a new BackflushJobResponse 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 NewBackflushJobResponse(createTime time.Time, displayName string, id string, regionId string, status BackflushJobResponseStatus) *BackflushJobResponse { + this := BackflushJobResponse{} + this.CreateTime = createTime + this.DisplayName = displayName + this.Id = id + this.RegionId = regionId + this.Status = status + return &this +} + +// NewBackflushJobResponseWithDefaults instantiates a new BackflushJobResponse 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 NewBackflushJobResponseWithDefaults() *BackflushJobResponse { + this := BackflushJobResponse{} + return &this +} + +// GetCreateTime returns the CreateTime field value +func (o *BackflushJobResponse) GetCreateTime() time.Time { + if o == nil { + var ret time.Time + return ret + } + + return o.CreateTime +} + +// GetCreateTimeOk returns a tuple with the CreateTime field value +// and a boolean to check if the value has been set. +func (o *BackflushJobResponse) GetCreateTimeOk() (*time.Time, bool) { + if o == nil { + return nil, false + } + return &o.CreateTime, true +} + +// SetCreateTime sets field value +func (o *BackflushJobResponse) SetCreateTime(v time.Time) { + o.CreateTime = v +} + +// GetDescription returns the Description field value if set, zero value otherwise. +func (o *BackflushJobResponse) GetDescription() string { + if o == nil || IsNil(o.Description) { + var ret string + return ret + } + return *o.Description +} + +// GetDescriptionOk returns a tuple with the Description field value if set, nil otherwise +// and a boolean to check if the value has been set. +func (o *BackflushJobResponse) GetDescriptionOk() (*string, bool) { + if o == nil || IsNil(o.Description) { + return nil, false + } + return o.Description, true +} + +// HasDescription returns a boolean if a field has been set. +func (o *BackflushJobResponse) HasDescription() bool { + if o != nil && !IsNil(o.Description) { + return true + } + + return false +} + +// SetDescription gets a reference to the given string and assigns it to the Description field. +func (o *BackflushJobResponse) SetDescription(v string) { + o.Description = &v +} + +// GetDisplayName returns the DisplayName field value +func (o *BackflushJobResponse) GetDisplayName() string { + if o == nil { + var ret string + return ret + } + + return o.DisplayName +} + +// GetDisplayNameOk returns a tuple with the DisplayName field value +// and a boolean to check if the value has been set. +func (o *BackflushJobResponse) GetDisplayNameOk() (*string, bool) { + if o == nil { + return nil, false + } + return &o.DisplayName, true +} + +// SetDisplayName sets field value +func (o *BackflushJobResponse) SetDisplayName(v string) { + o.DisplayName = v +} + +// GetId returns the Id field value +func (o *BackflushJobResponse) GetId() string { + if o == nil { + var ret string + return ret + } + + return o.Id +} + +// GetIdOk returns a tuple with the Id field value +// and a boolean to check if the value has been set. +func (o *BackflushJobResponse) GetIdOk() (*string, bool) { + if o == nil { + return nil, false + } + return &o.Id, true +} + +// SetId sets field value +func (o *BackflushJobResponse) SetId(v string) { + o.Id = v +} + +// GetRegionId returns the RegionId field value +func (o *BackflushJobResponse) GetRegionId() string { + if o == nil { + var ret string + return ret + } + + return o.RegionId +} + +// GetRegionIdOk returns a tuple with the RegionId field value +// and a boolean to check if the value has been set. +func (o *BackflushJobResponse) GetRegionIdOk() (*string, bool) { + if o == nil { + return nil, false + } + return &o.RegionId, true +} + +// SetRegionId sets field value +func (o *BackflushJobResponse) SetRegionId(v string) { + o.RegionId = v +} + +// GetStatus returns the Status field value +func (o *BackflushJobResponse) GetStatus() BackflushJobResponseStatus { + if o == nil { + var ret BackflushJobResponseStatus + return ret + } + + return o.Status +} + +// GetStatusOk returns a tuple with the Status field value +// and a boolean to check if the value has been set. +func (o *BackflushJobResponse) GetStatusOk() (*BackflushJobResponseStatus, bool) { + if o == nil { + return nil, false + } + return &o.Status, true +} + +// SetStatus sets field value +func (o *BackflushJobResponse) SetStatus(v BackflushJobResponseStatus) { + o.Status = v +} + +func (o BackflushJobResponse) MarshalJSON() ([]byte, error) { + toSerialize, err := o.ToMap() + if err != nil { + return []byte{}, err + } + return json.Marshal(toSerialize) +} + +func (o BackflushJobResponse) ToMap() (map[string]interface{}, error) { + toSerialize := map[string]interface{}{} + toSerialize["createTime"] = o.CreateTime + if !IsNil(o.Description) { + toSerialize["description"] = o.Description + } + toSerialize["displayName"] = o.DisplayName + toSerialize["id"] = o.Id + toSerialize["regionId"] = o.RegionId + toSerialize["status"] = o.Status + + for key, value := range o.AdditionalProperties { + toSerialize[key] = value + } + + return toSerialize, nil +} + +func (o *BackflushJobResponse) 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{ + "createTime", + "displayName", + "id", + "regionId", + "status", + } + + 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) + } + } + + varBackflushJobResponse := _BackflushJobResponse{} + + err = json.Unmarshal(data, &varBackflushJobResponse) + + if err != nil { + return err + } + + *o = BackflushJobResponse(varBackflushJobResponse) + + additionalProperties := make(map[string]interface{}) + + if err = json.Unmarshal(data, &additionalProperties); err == nil { + delete(additionalProperties, "createTime") + delete(additionalProperties, "description") + delete(additionalProperties, "displayName") + delete(additionalProperties, "id") + delete(additionalProperties, "regionId") + delete(additionalProperties, "status") + o.AdditionalProperties = additionalProperties + } + + return err +} + +type NullableBackflushJobResponse struct { + value *BackflushJobResponse + isSet bool +} + +func (v NullableBackflushJobResponse) Get() *BackflushJobResponse { + return v.value +} + +func (v *NullableBackflushJobResponse) Set(val *BackflushJobResponse) { + v.value = val + v.isSet = true +} + +func (v NullableBackflushJobResponse) IsSet() bool { + return v.isSet +} + +func (v *NullableBackflushJobResponse) Unset() { + v.value = nil + v.isSet = false +} + +func NewNullableBackflushJobResponse(val *BackflushJobResponse) *NullableBackflushJobResponse { + return &NullableBackflushJobResponse{value: val, isSet: true} +} + +func (v NullableBackflushJobResponse) MarshalJSON() ([]byte, error) { + return json.Marshal(v.value) +} + +func (v *NullableBackflushJobResponse) UnmarshalJSON(src []byte) error { + v.isSet = true + return json.Unmarshal(src, &v.value) +} diff --git a/services/telemetrylink/v1api/model_backflush_job_response_region_id.go b/services/telemetrylink/v1api/model_backflush_job_response_region_id.go new file mode 100644 index 0000000000..c082c38af8 --- /dev/null +++ b/services/telemetrylink/v1api/model_backflush_job_response_region_id.go @@ -0,0 +1,113 @@ +/* +STACKIT Telemetry Link API + +This API provides endpoints for managing Telemetry Links. The Telemetry Link enables Log Routing towards a defined Telemetry Router. + +API version: 1.0 +*/ + +// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT. + +package v1api + +import ( + "encoding/json" + "fmt" +) + +// BackflushJobResponseRegionId The STACKIT region name the resource is located in. +type BackflushJobResponseRegionId string + +// List of backflushJobResponse_regionId +const ( + BACKFLUSHJOBRESPONSEREGIONID_EU01 BackflushJobResponseRegionId = "eu01" + BACKFLUSHJOBRESPONSEREGIONID_EU02 BackflushJobResponseRegionId = "eu02" + BACKFLUSHJOBRESPONSEREGIONID_UNKNOWN_DEFAULT_OPEN_API BackflushJobResponseRegionId = "unknown_default_open_api" +) + +// All allowed values of BackflushJobResponseRegionId enum +var AllowedBackflushJobResponseRegionIdEnumValues = []BackflushJobResponseRegionId{ + "eu01", + "eu02", + "unknown_default_open_api", +} + +func (v *BackflushJobResponseRegionId) UnmarshalJSON(src []byte) error { + var value string + err := json.Unmarshal(src, &value) + if err != nil { + return err + } + enumTypeValue := BackflushJobResponseRegionId(value) + for _, existing := range AllowedBackflushJobResponseRegionIdEnumValues { + if existing == enumTypeValue { + *v = enumTypeValue + return nil + } + } + + *v = BACKFLUSHJOBRESPONSEREGIONID_UNKNOWN_DEFAULT_OPEN_API + return nil +} + +// NewBackflushJobResponseRegionIdFromValue returns a pointer to a valid BackflushJobResponseRegionId +// for the value passed as argument, or an error if the value passed is not allowed by the enum +func NewBackflushJobResponseRegionIdFromValue(v string) (*BackflushJobResponseRegionId, error) { + ev := BackflushJobResponseRegionId(v) + if ev.IsValid() { + return &ev, nil + } else { + return nil, fmt.Errorf("invalid value '%v' for BackflushJobResponseRegionId: valid values are %v", v, AllowedBackflushJobResponseRegionIdEnumValues) + } +} + +// IsValid return true if the value is valid for the enum, false otherwise +func (v BackflushJobResponseRegionId) IsValid() bool { + for _, existing := range AllowedBackflushJobResponseRegionIdEnumValues { + if existing == v { + return true + } + } + return false +} + +// Ptr returns reference to backflushJobResponse_regionId value +func (v BackflushJobResponseRegionId) Ptr() *BackflushJobResponseRegionId { + return &v +} + +type NullableBackflushJobResponseRegionId struct { + value *BackflushJobResponseRegionId + isSet bool +} + +func (v NullableBackflushJobResponseRegionId) Get() *BackflushJobResponseRegionId { + return v.value +} + +func (v *NullableBackflushJobResponseRegionId) Set(val *BackflushJobResponseRegionId) { + v.value = val + v.isSet = true +} + +func (v NullableBackflushJobResponseRegionId) IsSet() bool { + return v.isSet +} + +func (v *NullableBackflushJobResponseRegionId) Unset() { + v.value = nil + v.isSet = false +} + +func NewNullableBackflushJobResponseRegionId(val *BackflushJobResponseRegionId) *NullableBackflushJobResponseRegionId { + return &NullableBackflushJobResponseRegionId{value: val, isSet: true} +} + +func (v NullableBackflushJobResponseRegionId) MarshalJSON() ([]byte, error) { + return json.Marshal(v.value) +} + +func (v *NullableBackflushJobResponseRegionId) UnmarshalJSON(src []byte) error { + v.isSet = true + return json.Unmarshal(src, &v.value) +} diff --git a/services/telemetrylink/v1api/model_backflush_job_response_status.go b/services/telemetrylink/v1api/model_backflush_job_response_status.go new file mode 100644 index 0000000000..314270b3ab --- /dev/null +++ b/services/telemetrylink/v1api/model_backflush_job_response_status.go @@ -0,0 +1,119 @@ +/* +STACKIT Telemetry Link API + +This API provides endpoints for managing Telemetry Links. The Telemetry Link enables Log Routing towards a defined Telemetry Router. + +API version: 1.0 +*/ + +// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT. + +package v1api + +import ( + "encoding/json" + "fmt" +) + +// BackflushJobResponseStatus The current state of the link. +type BackflushJobResponseStatus string + +// List of backflushJobResponse_status +const ( + BACKFLUSHJOBRESPONSESTATUS_ACTIVE BackflushJobResponseStatus = "active" + BACKFLUSHJOBRESPONSESTATUS_COMPLETE BackflushJobResponseStatus = "complete" + BACKFLUSHJOBRESPONSESTATUS_FAILED BackflushJobResponseStatus = "failed" + BACKFLUSHJOBRESPONSESTATUS_RECONCILING BackflushJobResponseStatus = "reconciling" + BACKFLUSHJOBRESPONSESTATUS_DELETING BackflushJobResponseStatus = "deleting" + BACKFLUSHJOBRESPONSESTATUS_UNKNOWN_DEFAULT_OPEN_API BackflushJobResponseStatus = "unknown_default_open_api" +) + +// All allowed values of BackflushJobResponseStatus enum +var AllowedBackflushJobResponseStatusEnumValues = []BackflushJobResponseStatus{ + "active", + "complete", + "failed", + "reconciling", + "deleting", + "unknown_default_open_api", +} + +func (v *BackflushJobResponseStatus) UnmarshalJSON(src []byte) error { + var value string + err := json.Unmarshal(src, &value) + if err != nil { + return err + } + enumTypeValue := BackflushJobResponseStatus(value) + for _, existing := range AllowedBackflushJobResponseStatusEnumValues { + if existing == enumTypeValue { + *v = enumTypeValue + return nil + } + } + + *v = BACKFLUSHJOBRESPONSESTATUS_UNKNOWN_DEFAULT_OPEN_API + return nil +} + +// NewBackflushJobResponseStatusFromValue returns a pointer to a valid BackflushJobResponseStatus +// for the value passed as argument, or an error if the value passed is not allowed by the enum +func NewBackflushJobResponseStatusFromValue(v string) (*BackflushJobResponseStatus, error) { + ev := BackflushJobResponseStatus(v) + if ev.IsValid() { + return &ev, nil + } else { + return nil, fmt.Errorf("invalid value '%v' for BackflushJobResponseStatus: valid values are %v", v, AllowedBackflushJobResponseStatusEnumValues) + } +} + +// IsValid return true if the value is valid for the enum, false otherwise +func (v BackflushJobResponseStatus) IsValid() bool { + for _, existing := range AllowedBackflushJobResponseStatusEnumValues { + if existing == v { + return true + } + } + return false +} + +// Ptr returns reference to backflushJobResponse_status value +func (v BackflushJobResponseStatus) Ptr() *BackflushJobResponseStatus { + return &v +} + +type NullableBackflushJobResponseStatus struct { + value *BackflushJobResponseStatus + isSet bool +} + +func (v NullableBackflushJobResponseStatus) Get() *BackflushJobResponseStatus { + return v.value +} + +func (v *NullableBackflushJobResponseStatus) Set(val *BackflushJobResponseStatus) { + v.value = val + v.isSet = true +} + +func (v NullableBackflushJobResponseStatus) IsSet() bool { + return v.isSet +} + +func (v *NullableBackflushJobResponseStatus) Unset() { + v.value = nil + v.isSet = false +} + +func NewNullableBackflushJobResponseStatus(val *BackflushJobResponseStatus) *NullableBackflushJobResponseStatus { + return &NullableBackflushJobResponseStatus{value: val, isSet: true} +} + +func (v NullableBackflushJobResponseStatus) MarshalJSON() ([]byte, error) { + return json.Marshal(v.value) +} + +func (v *NullableBackflushJobResponseStatus) UnmarshalJSON(src []byte) error { + v.isSet = true + return json.Unmarshal(src, &v.value) +} diff --git a/services/telemetrylink/v1api/model_create_folder_backflush_job_payload.go b/services/telemetrylink/v1api/model_create_folder_backflush_job_payload.go new file mode 100644 index 0000000000..a842c8839a --- /dev/null +++ b/services/telemetrylink/v1api/model_create_folder_backflush_job_payload.go @@ -0,0 +1,205 @@ +/* +STACKIT Telemetry Link API + +This API provides endpoints for managing Telemetry Links. The Telemetry Link enables Log Routing towards a defined Telemetry Router. + +API version: 1.0 +*/ + +// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT. + +package v1api + +import ( + "encoding/json" + "fmt" +) + +// checks if the CreateFolderBackflushJobPayload type satisfies the MappedNullable interface at compile time +var _ MappedNullable = &CreateFolderBackflushJobPayload{} + +// CreateFolderBackflushJobPayload struct for CreateFolderBackflushJobPayload +type CreateFolderBackflushJobPayload struct { + // The description is a longer text chosen by the user to provide more context for the resource. + Description *string `json:"description,omitempty" validate:"regexp=^([a-zA-Z0-9][a-zA-Z0-9 \\-]*)?$"` + // The display name is a short name chosen by the user to identify the resource. + DisplayName string `json:"displayName" validate:"regexp=^[a-zA-Z0-9][a-zA-Z0-9 \\-]*$"` + AdditionalProperties map[string]interface{} +} + +type _CreateFolderBackflushJobPayload CreateFolderBackflushJobPayload + +// NewCreateFolderBackflushJobPayload instantiates a new CreateFolderBackflushJobPayload 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 NewCreateFolderBackflushJobPayload(displayName string) *CreateFolderBackflushJobPayload { + this := CreateFolderBackflushJobPayload{} + this.DisplayName = displayName + return &this +} + +// NewCreateFolderBackflushJobPayloadWithDefaults instantiates a new CreateFolderBackflushJobPayload 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 NewCreateFolderBackflushJobPayloadWithDefaults() *CreateFolderBackflushJobPayload { + this := CreateFolderBackflushJobPayload{} + return &this +} + +// GetDescription returns the Description field value if set, zero value otherwise. +func (o *CreateFolderBackflushJobPayload) GetDescription() string { + if o == nil || IsNil(o.Description) { + var ret string + return ret + } + return *o.Description +} + +// GetDescriptionOk returns a tuple with the Description field value if set, nil otherwise +// and a boolean to check if the value has been set. +func (o *CreateFolderBackflushJobPayload) GetDescriptionOk() (*string, bool) { + if o == nil || IsNil(o.Description) { + return nil, false + } + return o.Description, true +} + +// HasDescription returns a boolean if a field has been set. +func (o *CreateFolderBackflushJobPayload) HasDescription() bool { + if o != nil && !IsNil(o.Description) { + return true + } + + return false +} + +// SetDescription gets a reference to the given string and assigns it to the Description field. +func (o *CreateFolderBackflushJobPayload) SetDescription(v string) { + o.Description = &v +} + +// GetDisplayName returns the DisplayName field value +func (o *CreateFolderBackflushJobPayload) GetDisplayName() string { + if o == nil { + var ret string + return ret + } + + return o.DisplayName +} + +// GetDisplayNameOk returns a tuple with the DisplayName field value +// and a boolean to check if the value has been set. +func (o *CreateFolderBackflushJobPayload) GetDisplayNameOk() (*string, bool) { + if o == nil { + return nil, false + } + return &o.DisplayName, true +} + +// SetDisplayName sets field value +func (o *CreateFolderBackflushJobPayload) SetDisplayName(v string) { + o.DisplayName = v +} + +func (o CreateFolderBackflushJobPayload) MarshalJSON() ([]byte, error) { + toSerialize, err := o.ToMap() + if err != nil { + return []byte{}, err + } + return json.Marshal(toSerialize) +} + +func (o CreateFolderBackflushJobPayload) ToMap() (map[string]interface{}, error) { + toSerialize := map[string]interface{}{} + if !IsNil(o.Description) { + toSerialize["description"] = o.Description + } + toSerialize["displayName"] = o.DisplayName + + for key, value := range o.AdditionalProperties { + toSerialize[key] = value + } + + return toSerialize, nil +} + +func (o *CreateFolderBackflushJobPayload) 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{ + "displayName", + } + + 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) + } + } + + varCreateFolderBackflushJobPayload := _CreateFolderBackflushJobPayload{} + + err = json.Unmarshal(data, &varCreateFolderBackflushJobPayload) + + if err != nil { + return err + } + + *o = CreateFolderBackflushJobPayload(varCreateFolderBackflushJobPayload) + + additionalProperties := make(map[string]interface{}) + + if err = json.Unmarshal(data, &additionalProperties); err == nil { + delete(additionalProperties, "description") + delete(additionalProperties, "displayName") + o.AdditionalProperties = additionalProperties + } + + return err +} + +type NullableCreateFolderBackflushJobPayload struct { + value *CreateFolderBackflushJobPayload + isSet bool +} + +func (v NullableCreateFolderBackflushJobPayload) Get() *CreateFolderBackflushJobPayload { + return v.value +} + +func (v *NullableCreateFolderBackflushJobPayload) Set(val *CreateFolderBackflushJobPayload) { + v.value = val + v.isSet = true +} + +func (v NullableCreateFolderBackflushJobPayload) IsSet() bool { + return v.isSet +} + +func (v *NullableCreateFolderBackflushJobPayload) Unset() { + v.value = nil + v.isSet = false +} + +func NewNullableCreateFolderBackflushJobPayload(val *CreateFolderBackflushJobPayload) *NullableCreateFolderBackflushJobPayload { + return &NullableCreateFolderBackflushJobPayload{value: val, isSet: true} +} + +func (v NullableCreateFolderBackflushJobPayload) MarshalJSON() ([]byte, error) { + return json.Marshal(v.value) +} + +func (v *NullableCreateFolderBackflushJobPayload) UnmarshalJSON(src []byte) error { + v.isSet = true + return json.Unmarshal(src, &v.value) +} diff --git a/services/telemetrylink/v1api/model_create_organization_backflush_job_payload.go b/services/telemetrylink/v1api/model_create_organization_backflush_job_payload.go new file mode 100644 index 0000000000..1f63c43d01 --- /dev/null +++ b/services/telemetrylink/v1api/model_create_organization_backflush_job_payload.go @@ -0,0 +1,205 @@ +/* +STACKIT Telemetry Link API + +This API provides endpoints for managing Telemetry Links. The Telemetry Link enables Log Routing towards a defined Telemetry Router. + +API version: 1.0 +*/ + +// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT. + +package v1api + +import ( + "encoding/json" + "fmt" +) + +// checks if the CreateOrganizationBackflushJobPayload type satisfies the MappedNullable interface at compile time +var _ MappedNullable = &CreateOrganizationBackflushJobPayload{} + +// CreateOrganizationBackflushJobPayload struct for CreateOrganizationBackflushJobPayload +type CreateOrganizationBackflushJobPayload struct { + // The description is a longer text chosen by the user to provide more context for the resource. + Description *string `json:"description,omitempty" validate:"regexp=^([a-zA-Z0-9][a-zA-Z0-9 \\-]*)?$"` + // The display name is a short name chosen by the user to identify the resource. + DisplayName string `json:"displayName" validate:"regexp=^[a-zA-Z0-9][a-zA-Z0-9 \\-]*$"` + AdditionalProperties map[string]interface{} +} + +type _CreateOrganizationBackflushJobPayload CreateOrganizationBackflushJobPayload + +// NewCreateOrganizationBackflushJobPayload instantiates a new CreateOrganizationBackflushJobPayload 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 NewCreateOrganizationBackflushJobPayload(displayName string) *CreateOrganizationBackflushJobPayload { + this := CreateOrganizationBackflushJobPayload{} + this.DisplayName = displayName + return &this +} + +// NewCreateOrganizationBackflushJobPayloadWithDefaults instantiates a new CreateOrganizationBackflushJobPayload 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 NewCreateOrganizationBackflushJobPayloadWithDefaults() *CreateOrganizationBackflushJobPayload { + this := CreateOrganizationBackflushJobPayload{} + return &this +} + +// GetDescription returns the Description field value if set, zero value otherwise. +func (o *CreateOrganizationBackflushJobPayload) GetDescription() string { + if o == nil || IsNil(o.Description) { + var ret string + return ret + } + return *o.Description +} + +// GetDescriptionOk returns a tuple with the Description field value if set, nil otherwise +// and a boolean to check if the value has been set. +func (o *CreateOrganizationBackflushJobPayload) GetDescriptionOk() (*string, bool) { + if o == nil || IsNil(o.Description) { + return nil, false + } + return o.Description, true +} + +// HasDescription returns a boolean if a field has been set. +func (o *CreateOrganizationBackflushJobPayload) HasDescription() bool { + if o != nil && !IsNil(o.Description) { + return true + } + + return false +} + +// SetDescription gets a reference to the given string and assigns it to the Description field. +func (o *CreateOrganizationBackflushJobPayload) SetDescription(v string) { + o.Description = &v +} + +// GetDisplayName returns the DisplayName field value +func (o *CreateOrganizationBackflushJobPayload) GetDisplayName() string { + if o == nil { + var ret string + return ret + } + + return o.DisplayName +} + +// GetDisplayNameOk returns a tuple with the DisplayName field value +// and a boolean to check if the value has been set. +func (o *CreateOrganizationBackflushJobPayload) GetDisplayNameOk() (*string, bool) { + if o == nil { + return nil, false + } + return &o.DisplayName, true +} + +// SetDisplayName sets field value +func (o *CreateOrganizationBackflushJobPayload) SetDisplayName(v string) { + o.DisplayName = v +} + +func (o CreateOrganizationBackflushJobPayload) MarshalJSON() ([]byte, error) { + toSerialize, err := o.ToMap() + if err != nil { + return []byte{}, err + } + return json.Marshal(toSerialize) +} + +func (o CreateOrganizationBackflushJobPayload) ToMap() (map[string]interface{}, error) { + toSerialize := map[string]interface{}{} + if !IsNil(o.Description) { + toSerialize["description"] = o.Description + } + toSerialize["displayName"] = o.DisplayName + + for key, value := range o.AdditionalProperties { + toSerialize[key] = value + } + + return toSerialize, nil +} + +func (o *CreateOrganizationBackflushJobPayload) 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{ + "displayName", + } + + 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) + } + } + + varCreateOrganizationBackflushJobPayload := _CreateOrganizationBackflushJobPayload{} + + err = json.Unmarshal(data, &varCreateOrganizationBackflushJobPayload) + + if err != nil { + return err + } + + *o = CreateOrganizationBackflushJobPayload(varCreateOrganizationBackflushJobPayload) + + additionalProperties := make(map[string]interface{}) + + if err = json.Unmarshal(data, &additionalProperties); err == nil { + delete(additionalProperties, "description") + delete(additionalProperties, "displayName") + o.AdditionalProperties = additionalProperties + } + + return err +} + +type NullableCreateOrganizationBackflushJobPayload struct { + value *CreateOrganizationBackflushJobPayload + isSet bool +} + +func (v NullableCreateOrganizationBackflushJobPayload) Get() *CreateOrganizationBackflushJobPayload { + return v.value +} + +func (v *NullableCreateOrganizationBackflushJobPayload) Set(val *CreateOrganizationBackflushJobPayload) { + v.value = val + v.isSet = true +} + +func (v NullableCreateOrganizationBackflushJobPayload) IsSet() bool { + return v.isSet +} + +func (v *NullableCreateOrganizationBackflushJobPayload) Unset() { + v.value = nil + v.isSet = false +} + +func NewNullableCreateOrganizationBackflushJobPayload(val *CreateOrganizationBackflushJobPayload) *NullableCreateOrganizationBackflushJobPayload { + return &NullableCreateOrganizationBackflushJobPayload{value: val, isSet: true} +} + +func (v NullableCreateOrganizationBackflushJobPayload) MarshalJSON() ([]byte, error) { + return json.Marshal(v.value) +} + +func (v *NullableCreateOrganizationBackflushJobPayload) UnmarshalJSON(src []byte) error { + v.isSet = true + return json.Unmarshal(src, &v.value) +} diff --git a/services/telemetrylink/v1api/model_create_project_backflush_job_payload.go b/services/telemetrylink/v1api/model_create_project_backflush_job_payload.go new file mode 100644 index 0000000000..e9ab912cfa --- /dev/null +++ b/services/telemetrylink/v1api/model_create_project_backflush_job_payload.go @@ -0,0 +1,205 @@ +/* +STACKIT Telemetry Link API + +This API provides endpoints for managing Telemetry Links. The Telemetry Link enables Log Routing towards a defined Telemetry Router. + +API version: 1.0 +*/ + +// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT. + +package v1api + +import ( + "encoding/json" + "fmt" +) + +// checks if the CreateProjectBackflushJobPayload type satisfies the MappedNullable interface at compile time +var _ MappedNullable = &CreateProjectBackflushJobPayload{} + +// CreateProjectBackflushJobPayload struct for CreateProjectBackflushJobPayload +type CreateProjectBackflushJobPayload struct { + // The description is a longer text chosen by the user to provide more context for the resource. + Description *string `json:"description,omitempty" validate:"regexp=^([a-zA-Z0-9][a-zA-Z0-9 \\-]*)?$"` + // The display name is a short name chosen by the user to identify the resource. + DisplayName string `json:"displayName" validate:"regexp=^[a-zA-Z0-9][a-zA-Z0-9 \\-]*$"` + AdditionalProperties map[string]interface{} +} + +type _CreateProjectBackflushJobPayload CreateProjectBackflushJobPayload + +// NewCreateProjectBackflushJobPayload instantiates a new CreateProjectBackflushJobPayload 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 NewCreateProjectBackflushJobPayload(displayName string) *CreateProjectBackflushJobPayload { + this := CreateProjectBackflushJobPayload{} + this.DisplayName = displayName + return &this +} + +// NewCreateProjectBackflushJobPayloadWithDefaults instantiates a new CreateProjectBackflushJobPayload 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 NewCreateProjectBackflushJobPayloadWithDefaults() *CreateProjectBackflushJobPayload { + this := CreateProjectBackflushJobPayload{} + return &this +} + +// GetDescription returns the Description field value if set, zero value otherwise. +func (o *CreateProjectBackflushJobPayload) GetDescription() string { + if o == nil || IsNil(o.Description) { + var ret string + return ret + } + return *o.Description +} + +// GetDescriptionOk returns a tuple with the Description field value if set, nil otherwise +// and a boolean to check if the value has been set. +func (o *CreateProjectBackflushJobPayload) GetDescriptionOk() (*string, bool) { + if o == nil || IsNil(o.Description) { + return nil, false + } + return o.Description, true +} + +// HasDescription returns a boolean if a field has been set. +func (o *CreateProjectBackflushJobPayload) HasDescription() bool { + if o != nil && !IsNil(o.Description) { + return true + } + + return false +} + +// SetDescription gets a reference to the given string and assigns it to the Description field. +func (o *CreateProjectBackflushJobPayload) SetDescription(v string) { + o.Description = &v +} + +// GetDisplayName returns the DisplayName field value +func (o *CreateProjectBackflushJobPayload) GetDisplayName() string { + if o == nil { + var ret string + return ret + } + + return o.DisplayName +} + +// GetDisplayNameOk returns a tuple with the DisplayName field value +// and a boolean to check if the value has been set. +func (o *CreateProjectBackflushJobPayload) GetDisplayNameOk() (*string, bool) { + if o == nil { + return nil, false + } + return &o.DisplayName, true +} + +// SetDisplayName sets field value +func (o *CreateProjectBackflushJobPayload) SetDisplayName(v string) { + o.DisplayName = v +} + +func (o CreateProjectBackflushJobPayload) MarshalJSON() ([]byte, error) { + toSerialize, err := o.ToMap() + if err != nil { + return []byte{}, err + } + return json.Marshal(toSerialize) +} + +func (o CreateProjectBackflushJobPayload) ToMap() (map[string]interface{}, error) { + toSerialize := map[string]interface{}{} + if !IsNil(o.Description) { + toSerialize["description"] = o.Description + } + toSerialize["displayName"] = o.DisplayName + + for key, value := range o.AdditionalProperties { + toSerialize[key] = value + } + + return toSerialize, nil +} + +func (o *CreateProjectBackflushJobPayload) 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{ + "displayName", + } + + 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) + } + } + + varCreateProjectBackflushJobPayload := _CreateProjectBackflushJobPayload{} + + err = json.Unmarshal(data, &varCreateProjectBackflushJobPayload) + + if err != nil { + return err + } + + *o = CreateProjectBackflushJobPayload(varCreateProjectBackflushJobPayload) + + additionalProperties := make(map[string]interface{}) + + if err = json.Unmarshal(data, &additionalProperties); err == nil { + delete(additionalProperties, "description") + delete(additionalProperties, "displayName") + o.AdditionalProperties = additionalProperties + } + + return err +} + +type NullableCreateProjectBackflushJobPayload struct { + value *CreateProjectBackflushJobPayload + isSet bool +} + +func (v NullableCreateProjectBackflushJobPayload) Get() *CreateProjectBackflushJobPayload { + return v.value +} + +func (v *NullableCreateProjectBackflushJobPayload) Set(val *CreateProjectBackflushJobPayload) { + v.value = val + v.isSet = true +} + +func (v NullableCreateProjectBackflushJobPayload) IsSet() bool { + return v.isSet +} + +func (v *NullableCreateProjectBackflushJobPayload) Unset() { + v.value = nil + v.isSet = false +} + +func NewNullableCreateProjectBackflushJobPayload(val *CreateProjectBackflushJobPayload) *NullableCreateProjectBackflushJobPayload { + return &NullableCreateProjectBackflushJobPayload{value: val, isSet: true} +} + +func (v NullableCreateProjectBackflushJobPayload) MarshalJSON() ([]byte, error) { + return json.Marshal(v.value) +} + +func (v *NullableCreateProjectBackflushJobPayload) UnmarshalJSON(src []byte) error { + v.isSet = true + return json.Unmarshal(src, &v.value) +} diff --git a/services/telemetrylink/v1api/model_list_backflush_jobs_response.go b/services/telemetrylink/v1api/model_list_backflush_jobs_response.go new file mode 100644 index 0000000000..fe84c405a1 --- /dev/null +++ b/services/telemetrylink/v1api/model_list_backflush_jobs_response.go @@ -0,0 +1,204 @@ +/* +STACKIT Telemetry Link API + +This API provides endpoints for managing Telemetry Links. The Telemetry Link enables Log Routing towards a defined Telemetry Router. + +API version: 1.0 +*/ + +// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT. + +package v1api + +import ( + "encoding/json" + "fmt" +) + +// checks if the ListBackflushJobsResponse type satisfies the MappedNullable interface at compile time +var _ MappedNullable = &ListBackflushJobsResponse{} + +// ListBackflushJobsResponse struct for ListBackflushJobsResponse +type ListBackflushJobsResponse struct { + BackflushJobs []BackflushJobResponse `json:"backflushJobs"` + // A token to retrieve the next page of results. + NextPageToken *string `json:"nextPageToken,omitempty"` + AdditionalProperties map[string]interface{} +} + +type _ListBackflushJobsResponse ListBackflushJobsResponse + +// NewListBackflushJobsResponse instantiates a new ListBackflushJobsResponse 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 NewListBackflushJobsResponse(backflushJobs []BackflushJobResponse) *ListBackflushJobsResponse { + this := ListBackflushJobsResponse{} + this.BackflushJobs = backflushJobs + return &this +} + +// NewListBackflushJobsResponseWithDefaults instantiates a new ListBackflushJobsResponse 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 NewListBackflushJobsResponseWithDefaults() *ListBackflushJobsResponse { + this := ListBackflushJobsResponse{} + return &this +} + +// GetBackflushJobs returns the BackflushJobs field value +func (o *ListBackflushJobsResponse) GetBackflushJobs() []BackflushJobResponse { + if o == nil { + var ret []BackflushJobResponse + return ret + } + + return o.BackflushJobs +} + +// GetBackflushJobsOk returns a tuple with the BackflushJobs field value +// and a boolean to check if the value has been set. +func (o *ListBackflushJobsResponse) GetBackflushJobsOk() ([]BackflushJobResponse, bool) { + if o == nil { + return nil, false + } + return o.BackflushJobs, true +} + +// SetBackflushJobs sets field value +func (o *ListBackflushJobsResponse) SetBackflushJobs(v []BackflushJobResponse) { + o.BackflushJobs = v +} + +// GetNextPageToken returns the NextPageToken field value if set, zero value otherwise. +func (o *ListBackflushJobsResponse) GetNextPageToken() string { + if o == nil || IsNil(o.NextPageToken) { + var ret string + return ret + } + return *o.NextPageToken +} + +// GetNextPageTokenOk returns a tuple with the NextPageToken field value if set, nil otherwise +// and a boolean to check if the value has been set. +func (o *ListBackflushJobsResponse) GetNextPageTokenOk() (*string, bool) { + if o == nil || IsNil(o.NextPageToken) { + return nil, false + } + return o.NextPageToken, true +} + +// HasNextPageToken returns a boolean if a field has been set. +func (o *ListBackflushJobsResponse) HasNextPageToken() bool { + if o != nil && !IsNil(o.NextPageToken) { + return true + } + + return false +} + +// SetNextPageToken gets a reference to the given string and assigns it to the NextPageToken field. +func (o *ListBackflushJobsResponse) SetNextPageToken(v string) { + o.NextPageToken = &v +} + +func (o ListBackflushJobsResponse) MarshalJSON() ([]byte, error) { + toSerialize, err := o.ToMap() + if err != nil { + return []byte{}, err + } + return json.Marshal(toSerialize) +} + +func (o ListBackflushJobsResponse) ToMap() (map[string]interface{}, error) { + toSerialize := map[string]interface{}{} + toSerialize["backflushJobs"] = o.BackflushJobs + if !IsNil(o.NextPageToken) { + toSerialize["nextPageToken"] = o.NextPageToken + } + + for key, value := range o.AdditionalProperties { + toSerialize[key] = value + } + + return toSerialize, nil +} + +func (o *ListBackflushJobsResponse) 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{ + "backflushJobs", + } + + 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) + } + } + + varListBackflushJobsResponse := _ListBackflushJobsResponse{} + + err = json.Unmarshal(data, &varListBackflushJobsResponse) + + if err != nil { + return err + } + + *o = ListBackflushJobsResponse(varListBackflushJobsResponse) + + additionalProperties := make(map[string]interface{}) + + if err = json.Unmarshal(data, &additionalProperties); err == nil { + delete(additionalProperties, "backflushJobs") + delete(additionalProperties, "nextPageToken") + o.AdditionalProperties = additionalProperties + } + + return err +} + +type NullableListBackflushJobsResponse struct { + value *ListBackflushJobsResponse + isSet bool +} + +func (v NullableListBackflushJobsResponse) Get() *ListBackflushJobsResponse { + return v.value +} + +func (v *NullableListBackflushJobsResponse) Set(val *ListBackflushJobsResponse) { + v.value = val + v.isSet = true +} + +func (v NullableListBackflushJobsResponse) IsSet() bool { + return v.isSet +} + +func (v *NullableListBackflushJobsResponse) Unset() { + v.value = nil + v.isSet = false +} + +func NewNullableListBackflushJobsResponse(val *ListBackflushJobsResponse) *NullableListBackflushJobsResponse { + return &NullableListBackflushJobsResponse{value: val, isSet: true} +} + +func (v NullableListBackflushJobsResponse) MarshalJSON() ([]byte, error) { + return json.Marshal(v.value) +} + +func (v *NullableListBackflushJobsResponse) UnmarshalJSON(src []byte) error { + v.isSet = true + return json.Unmarshal(src, &v.value) +}