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/roles/transport"
	pb "git.perx.ru/perxis/perxis-go/proto/roles"
	grpc "github.com/go-kit/kit/transport/grpc"
	empty "github.com/golang/protobuf/ptypes/empty"
	context "golang.org/x/net/context"
)

type rolesServer struct {
	create grpc.Handler
	get    grpc.Handler
	list   grpc.Handler
	update grpc.Handler
	delete grpc.Handler

	pb.UnimplementedRolesServer
}

func NewGRPCServer(endpoints *transport.EndpointsSet, opts ...grpc.ServerOption) pb.RolesServer {
	return &rolesServer{
		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...,
		),
		update: grpc.NewServer(
			endpoints.UpdateEndpoint,
			_Decode_Update_Request,
			_Encode_Update_Response,
			opts...,
		),
	}
}

func (S *rolesServer) 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 *rolesServer) 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 *rolesServer) 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 *rolesServer) 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 *rolesServer) 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
}