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

type organizationsServer struct {
	create grpc.Handler
	get    grpc.Handler
	update grpc.Handler
	delete grpc.Handler
	find   grpc.Handler

	pb.UnimplementedOrganizationsServer
}

func NewGRPCServer(endpoints *transport.EndpointsSet, opts ...grpc.ServerOption) pb.OrganizationsServer {
	return &organizationsServer{
		create: grpc.NewServer(
			endpoints.CreateEndpoint,
			_Decode_Create_Request,
			_Encode_Create_Response,
			opts...,
		),
		delete: grpc.NewServer(
			endpoints.DeleteEndpoint,
			_Decode_Delete_Request,
			_Encode_Delete_Response,
			opts...,
		),
		find: grpc.NewServer(
			endpoints.FindEndpoint,
			_Decode_Find_Request,
			_Encode_Find_Response,
			opts...,
		),
		get: grpc.NewServer(
			endpoints.GetEndpoint,
			_Decode_Get_Request,
			_Encode_Get_Response,
			opts...,
		),
		update: grpc.NewServer(
			endpoints.UpdateEndpoint,
			_Decode_Update_Request,
			_Encode_Update_Response,
			opts...,
		),
	}
}

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

func (S *organizationsServer) Find(ctx context.Context, req *pb.FindRequest) (*pb.FindResponse, error) {
	_, resp, err := S.find.ServeGRPC(ctx, req)
	if err != nil {
		return nil, err
	}
	return resp.(*pb.FindResponse), nil
}