server.microgen.go

// Code generated by microgen 0.9.1. DO NOT EDIT.

// DO NOT EDIT.
package transportgrpc

import (
	transport "git.perx.ru/perxis/perxis-go/pkg/collections/transport"
	pb "git.perx.ru/perxis/perxis-go/proto/collections"
	grpc "github.com/go-kit/kit/transport/grpc"
	empty "github.com/golang/protobuf/ptypes/empty"
	context "golang.org/x/net/context"
)

type collectionsServer struct {
	create    grpc.Handler
	get       grpc.Handler
	list      grpc.Handler
	update    grpc.Handler
	setSchema grpc.Handler
	delete    grpc.Handler

	pb.UnimplementedCollectionsServer
}

func NewGRPCServer(endpoints *transport.EndpointsSet, opts ...grpc.ServerOption) pb.CollectionsServer {
	return &collectionsServer{
		create: grpc.NewServer(
			endpoints.CreateEndpoint,
			_Decode_Create_Request,
			_Encode_Create_Response,
			opts...,
		),
		delete: grpc.NewServer(
			endpoints.DeleteEndpoint,
			_Decode_Delete_Request,
			_Encode_Delete_Response,
			opts...,
		),
		get: grpc.NewServer(
			endpoints.GetEndpoint,
			_Decode_Get_Request,
			_Encode_Get_Response,
			opts...,
		),
		list: grpc.NewServer(
			endpoints.ListEndpoint,
			_Decode_List_Request,
			_Encode_List_Response,
			opts...,
		),
		setSchema: grpc.NewServer(
			endpoints.SetSchemaEndpoint,
			_Decode_SetSchema_Request,
			_Encode_SetSchema_Response,
			opts...,
		),
		update: grpc.NewServer(
			endpoints.UpdateEndpoint,
			_Decode_Update_Request,
			_Encode_Update_Response,
			opts...,
		),
	}
}

func (S *collectionsServer) Create(ctx context.Context, req *pb.CreateRequest) (*pb.CreateResponse, error) {
	_, resp, err := S.create.ServeGRPC(ctx, req)
	if err != nil {
		return nil, err
	}
	return resp.(*pb.CreateResponse), nil
}

func (S *collectionsServer) Get(ctx context.Context, req *pb.GetRequest) (*pb.GetResponse, error) {
	_, resp, err := S.get.ServeGRPC(ctx, req)
	if err != nil {
		return nil, err
	}
	return resp.(*pb.GetResponse), nil
}

func (S *collectionsServer) List(ctx context.Context, req *pb.ListRequest) (*pb.ListResponse, error) {
	_, resp, err := S.list.ServeGRPC(ctx, req)
	if err != nil {
		return nil, err
	}
	return resp.(*pb.ListResponse), nil
}

func (S *collectionsServer) Update(ctx context.Context, req *pb.UpdateRequest) (*empty.Empty, error) {
	_, resp, err := S.update.ServeGRPC(ctx, req)
	if err != nil {
		return nil, err
	}
	return resp.(*empty.Empty), nil
}

func (S *collectionsServer) SetSchema(ctx context.Context, req *pb.SetSchemaRequest) (*empty.Empty, error) {
	_, resp, err := S.setSchema.ServeGRPC(ctx, req)
	if err != nil {
		return nil, err
	}
	return resp.(*empty.Empty), nil
}

func (S *collectionsServer) Delete(ctx context.Context, req *pb.DeleteRequest) (*empty.Empty, error) {
	_, resp, err := S.delete.ServeGRPC(ctx, req)
	if err != nil {
		return nil, err
	}
	return resp.(*empty.Empty), nil
}