api_apache_kafka_connect_mirror_v2_service.go

/*
 * Instaclustr API Documentation
 *
 *
 *
 * API version: Current
 * Generated by: OpenAPI Generator (https://openapi-generator.tech)
 */

package openapi

import (
	"context"
	"errors"
	"net/http"
)

// ApacheKafkaConnectMirrorV2APIService is a service that implements the logic for the ApacheKafkaConnectMirrorV2APIServicer
// This service should implement the business logic for every endpoint for the ApacheKafkaConnectMirrorV2API API.
// Include any external packages or services that will be required by this service.
type ApacheKafkaConnectMirrorV2APIService struct {
	MockKafkaMirror *KafkaConnectMirrorV2
}

// NewApacheKafkaConnectMirrorV2APIService creates a default api service
func NewApacheKafkaConnectMirrorV2APIService() ApacheKafkaConnectMirrorV2APIServicer {
	return &ApacheKafkaConnectMirrorV2APIService{}
}

// ClusterManagementV2DataSourcesKafkaConnectClusterClusterIdMirrorsV2Get - List all Kafka connect mirrors.
func (s *ApacheKafkaConnectMirrorV2APIService) ClusterManagementV2DataSourcesKafkaConnectClusterClusterIdMirrorsV2Get(ctx context.Context, clusterId string) (ImplResponse, error) {
	// TODO - update ClusterManagementV2DataSourcesKafkaConnectClusterClusterIdMirrorsV2Get with the required logic for this service method.
	// Add api_apache_kafka_connect_mirror_v2_service.go to the .openapi-generator-ignore to avoid overwriting this service implementation when updating open api generation.

	// TODO: Uncomment the next line to return response Response(200, []KafkaConnectMirrorSummariesV2{}) or use other options such as http.Ok ...
	// return Response(200, []KafkaConnectMirrorSummariesV2{}), nil

	return Response(http.StatusNotImplemented, nil), errors.New("ClusterManagementV2DataSourcesKafkaConnectClusterClusterIdMirrorsV2Get method not implemented")
}

// ClusterManagementV2ResourcesApplicationsKafkaConnectMirrorsV2MirrorIdDelete - Delete a Kafka Connect Mirror
func (s *ApacheKafkaConnectMirrorV2APIService) ClusterManagementV2ResourcesApplicationsKafkaConnectMirrorsV2MirrorIdDelete(ctx context.Context, mirrorId string) (ImplResponse, error) {
	// TODO - update ClusterManagementV2ResourcesApplicationsKafkaConnectMirrorsV2MirrorIdDelete with the required logic for this service method.
	// Add api_apache_kafka_connect_mirror_v2_service.go to the .openapi-generator-ignore to avoid overwriting this service implementation when updating open api generation.

	s.MockKafkaMirror = nil
	return Response(204, nil), nil
}

// ClusterManagementV2ResourcesApplicationsKafkaConnectMirrorsV2MirrorIdGet - Get the details of a kafka connect mirror
func (s *ApacheKafkaConnectMirrorV2APIService) ClusterManagementV2ResourcesApplicationsKafkaConnectMirrorsV2MirrorIdGet(ctx context.Context, mirrorId string) (ImplResponse, error) {
	// TODO - update ClusterManagementV2ResourcesApplicationsKafkaConnectMirrorsV2MirrorIdGet with the required logic for this service method.
	// Add api_apache_kafka_connect_mirror_v2_service.go to the .openapi-generator-ignore to avoid overwriting this service implementation when updating open api generation.

	if s.MockKafkaMirror != nil {
		s.MockKafkaMirror.Status = RUNNING
	} else {
		return Response(404, nil), nil
	}

	return Response(200, s.MockKafkaMirror), nil
}

// ClusterManagementV2ResourcesApplicationsKafkaConnectMirrorsV2MirrorIdPut - Update a Kafka Connect mirror.
func (s *ApacheKafkaConnectMirrorV2APIService) ClusterManagementV2ResourcesApplicationsKafkaConnectMirrorsV2MirrorIdPut(ctx context.Context, mirrorId string, kafkaConnectMirrorUpdateV2 KafkaConnectMirrorUpdateV2) (ImplResponse, error) {
	// TODO - update ClusterManagementV2ResourcesApplicationsKafkaConnectMirrorsV2MirrorIdPut with the required logic for this service method.
	// Add api_apache_kafka_connect_mirror_v2_service.go to the .openapi-generator-ignore to avoid overwriting this service implementation when updating open api generation.

	s.MockKafkaMirror.TargetLatency = kafkaConnectMirrorUpdateV2.TargetLatency

	return Response(202, s.MockKafkaMirror), nil
}

// ClusterManagementV2ResourcesApplicationsKafkaConnectMirrorsV2Post - Create a Kafka Connect mirror
func (s *ApacheKafkaConnectMirrorV2APIService) ClusterManagementV2ResourcesApplicationsKafkaConnectMirrorsV2Post(ctx context.Context, kafkaConnectMirrorV2 KafkaConnectMirrorV2) (ImplResponse, error) {
	// TODO - update ClusterManagementV2ResourcesApplicationsKafkaConnectMirrorsV2Post with the required logic for this service method.
	// Add api_apache_kafka_connect_mirror_v2_service.go to the .openapi-generator-ignore to avoid overwriting this service implementation when updating open api generation.

	s.MockKafkaMirror = &kafkaConnectMirrorV2
	s.MockKafkaMirror.Id = CreatedID
	return Response(202, s.MockKafkaMirror), nil
}