server_generated.go

// Code generated by csi-proxy-api-gen. DO NOT EDIT.

package v1alpha1

import (
	"context"

	"github.com/kubernetes-csi/csi-proxy/client/api/system/v1alpha1"
	"github.com/kubernetes-csi/csi-proxy/client/apiversion"
	"github.com/kubernetes-csi/csi-proxy/pkg/server/system/impl"
	"google.golang.org/grpc"
)

var version = apiversion.NewVersionOrPanic("v1alpha1")

type versionedAPI struct {
	apiGroupServer impl.ServerInterface
}

func NewVersionedServer(apiGroupServer impl.ServerInterface) impl.VersionedAPI {
	return &versionedAPI{
		apiGroupServer: apiGroupServer,
	}
}

func (s *versionedAPI) Register(grpcServer *grpc.Server) {
	v1alpha1.RegisterSystemServer(grpcServer, s)
}

func (s *versionedAPI) GetBIOSSerialNumber(context context.Context, versionedRequest *v1alpha1.GetBIOSSerialNumberRequest) (*v1alpha1.GetBIOSSerialNumberResponse, error) {
	request := &impl.GetBIOSSerialNumberRequest{}
	if err := Convert_v1alpha1_GetBIOSSerialNumberRequest_To_impl_GetBIOSSerialNumberRequest(versionedRequest, request); err != nil {
		return nil, err
	}

	response, err := s.apiGroupServer.GetBIOSSerialNumber(context, request, version)
	if err != nil {
		return nil, err
	}

	versionedResponse := &v1alpha1.GetBIOSSerialNumberResponse{}
	if err := Convert_impl_GetBIOSSerialNumberResponse_To_v1alpha1_GetBIOSSerialNumberResponse(response, versionedResponse); err != nil {
		return nil, err
	}

	return versionedResponse, err
}

func (s *versionedAPI) GetService(context context.Context, versionedRequest *v1alpha1.GetServiceRequest) (*v1alpha1.GetServiceResponse, error) {
	request := &impl.GetServiceRequest{}
	if err := Convert_v1alpha1_GetServiceRequest_To_impl_GetServiceRequest(versionedRequest, request); err != nil {
		return nil, err
	}

	response, err := s.apiGroupServer.GetService(context, request, version)
	if err != nil {
		return nil, err
	}

	versionedResponse := &v1alpha1.GetServiceResponse{}
	if err := Convert_impl_GetServiceResponse_To_v1alpha1_GetServiceResponse(response, versionedResponse); err != nil {
		return nil, err
	}

	return versionedResponse, err
}

func (s *versionedAPI) StartService(context context.Context, versionedRequest *v1alpha1.StartServiceRequest) (*v1alpha1.StartServiceResponse, error) {
	request := &impl.StartServiceRequest{}
	if err := Convert_v1alpha1_StartServiceRequest_To_impl_StartServiceRequest(versionedRequest, request); err != nil {
		return nil, err
	}

	response, err := s.apiGroupServer.StartService(context, request, version)
	if err != nil {
		return nil, err
	}

	versionedResponse := &v1alpha1.StartServiceResponse{}
	if err := Convert_impl_StartServiceResponse_To_v1alpha1_StartServiceResponse(response, versionedResponse); err != nil {
		return nil, err
	}

	return versionedResponse, err
}

func (s *versionedAPI) StopService(context context.Context, versionedRequest *v1alpha1.StopServiceRequest) (*v1alpha1.StopServiceResponse, error) {
	request := &impl.StopServiceRequest{}
	if err := Convert_v1alpha1_StopServiceRequest_To_impl_StopServiceRequest(versionedRequest, request); err != nil {
		return nil, err
	}

	response, err := s.apiGroupServer.StopService(context, request, version)
	if err != nil {
		return nil, err
	}

	versionedResponse := &v1alpha1.StopServiceResponse{}
	if err := Convert_impl_StopServiceResponse_To_v1alpha1_StopServiceResponse(response, versionedResponse); err != nil {
		return nil, err
	}

	return versionedResponse, err
}