server.microgen.go

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

// DO NOT EDIT.
package transportgrpc

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

type membersServer struct {
	set               grpc.Handler
	get               grpc.Handler
	remove            grpc.Handler
	listMembers       grpc.Handler
	listOrganizations grpc.Handler

	pb.UnimplementedMembersServer
}

func NewGRPCServer(endpoints *transport.EndpointsSet, opts ...grpc.ServerOption) pb.MembersServer {
	return &membersServer{
		get: grpc.NewServer(
			endpoints.GetEndpoint,
			_Decode_Get_Request,
			_Encode_Get_Response,
			opts...,
		),
		listMembers: grpc.NewServer(
			endpoints.ListMembersEndpoint,
			_Decode_ListMembers_Request,
			_Encode_ListMembers_Response,
			opts...,
		),
		listOrganizations: grpc.NewServer(
			endpoints.ListOrganizationsEndpoint,
			_Decode_ListOrganizations_Request,
			_Encode_ListOrganizations_Response,
			opts...,
		),
		remove: grpc.NewServer(
			endpoints.RemoveEndpoint,
			_Decode_Remove_Request,
			_Encode_Remove_Response,
			opts...,
		),
		set: grpc.NewServer(
			endpoints.SetEndpoint,
			_Decode_Set_Request,
			_Encode_Set_Response,
			opts...,
		),
	}
}

func (S *membersServer) Set(ctx context.Context, req *pb.SetRequest) (*empty.Empty, error) {
	_, resp, err := S.set.ServeGRPC(ctx, req)
	if err != nil {
		return nil, err
	}
	return resp.(*empty.Empty), nil
}

func (S *membersServer) 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 *membersServer) Remove(ctx context.Context, req *pb.RemoveRequest) (*empty.Empty, error) {
	_, resp, err := S.remove.ServeGRPC(ctx, req)
	if err != nil {
		return nil, err
	}
	return resp.(*empty.Empty), nil
}

func (S *membersServer) ListMembers(ctx context.Context, req *pb.ListMembersRequest) (*pb.ListMembersResponse, error) {
	_, resp, err := S.listMembers.ServeGRPC(ctx, req)
	if err != nil {
		return nil, err
	}
	return resp.(*pb.ListMembersResponse), nil
}

func (S *membersServer) ListOrganizations(ctx context.Context, req *pb.ListOrganizationsRequest) (*pb.ListOrganizationsResponse, error) {
	_, resp, err := S.listOrganizations.ServeGRPC(ctx, req)
	if err != nil {
		return nil, err
	}
	return resp.(*pb.ListOrganizationsResponse), nil
}