Вынесена Version

pkg/account/version/transport/grpc/client.microgen.go

-// Code generated by microgen 0.9.1. DO NOT EDIT.
-
-package transportgrpc
-
-import (
-	transport "git.perx.ru/perxis/perxis-go/pkg/account/version/transport"
-	pb "git.perx.ru/perxis/perxis-go/proto/versions/account"
-	grpckit "github.com/go-kit/kit/transport/grpc"
-	grpc "google.golang.org/grpc"
-)
-
-func NewGRPCClient(conn *grpc.ClientConn, addr string, opts ...grpckit.ClientOption) transport.EndpointsSet {
-	if addr == "" {
-		addr = "account.Versions"
-	}
-	return transport.EndpointsSet{GetEndpoint: grpckit.NewClient(
-		conn, addr, "Get",
-		_Encode_Get_Request,
-		_Decode_Get_Response,
-		pb.GetResponse{},
-		opts...,
-	).Endpoint()}
-}

pkg/account/version/transport/grpc/protobuf_endpoint_converters.microgen.go

-// Code generated by microgen 0.9.1. DO NOT EDIT.
-
-// Please, do not change functions names!
-package transportgrpc
-
-import (
-	"context"
-	"errors"
-
-	transport2 "git.perx.ru/perxis/perxis-go/pkg/account/version/transport"
-	pb "git.perx.ru/perxis/perxis-go/proto/versions/account"
-	empty "github.com/golang/protobuf/ptypes/empty"
-)
-
-func _Encode_Get_Request(ctx context.Context, request interface{}) (interface{}, error) {
-	return &empty.Empty{}, nil
-}
-
-func _Encode_Get_Response(ctx context.Context, response interface{}) (interface{}, error) {
-	if response == nil {
-		return nil, errors.New("nil GetResponse")
-	}
-	resp := response.(*transport2.GetResponse)
-	respVersion, err := PtrVersionsVersionToProto(resp.Version)
-	if err != nil {
-		return nil, err
-	}
-	return &pb.GetResponse{Version: respVersion}, nil
-}
-
-func _Decode_Get_Request(ctx context.Context, request interface{}) (interface{}, error) {
-	return &empty.Empty{}, nil
-}
-
-func _Decode_Get_Response(ctx context.Context, response interface{}) (interface{}, error) {
-	if response == nil {
-		return nil, errors.New("nil GetResponse")
-	}
-	resp := response.(*pb.GetResponse)
-	respVersion, err := ProtoToPtrVersionsVersion(resp.Version)
-	if err != nil {
-		return nil, err
-	}
-	return &transport2.GetResponse{Version: respVersion}, nil
-}

pkg/account/version/transport/grpc/protobuf_type_converters.microgen.go

-// Code generated by microgen 0.9.1. DO NOT EDIT.
-
-// It is better for you if you do not change functions names!
-// This file will never be overwritten.
-package transportgrpc
-
-import (
-	"git.perx.ru/perxis/perxis-go/pkg/version"
-	"git.perx.ru/perxis/perxis-go/proto/common"
-)
-
-func PtrVersionsVersionToProto(version *version.Version) (*common.Version, error) {
-	pVersion := &common.Version{
-		ApiVersion:    version.APIVersion,
-		ServerVersion: version.ServerVersion,
-		Commit:        version.Commit,
-		BuildTime:     version.BuildTime,
-		BuildNumber:   int32(version.BuildNumber),
-	}
-	return pVersion, nil
-}
-
-func ProtoToPtrVersionsVersion(protoVersion *common.Version) (*version.Version, error) {
-	version := &version.Version{
-		APIVersion:    protoVersion.ApiVersion,
-		ServerVersion: protoVersion.ServerVersion,
-		Commit:        protoVersion.Commit,
-		BuildTime:     protoVersion.BuildTime,
-		BuildNumber:   int(protoVersion.BuildNumber),
-	}
-	return version, nil
-}
-
-func PtrVersionVersionToProto(version *version.Version) (*common.Version, error) {
-	panic("function not provided") // TODO: provide converter
-}
-
-func ProtoToPtrVersionVersion(protoVersion *common.Version) (*version.Version, error) {
-	panic("function not provided") // TODO: provide converter
-}

pkg/account/version/transport/grpc/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/account/version/transport"
-	pb "git.perx.ru/perxis/perxis-go/proto/versions/account"
-	grpc "github.com/go-kit/kit/transport/grpc"
-	empty "github.com/golang/protobuf/ptypes/empty"
-	context "golang.org/x/net/context"
-)
-
-type versionsServer struct {
-	get grpc.Handler
-
-	pb.UnimplementedVersionsServer
-}
-
-func NewGRPCServer(endpoints *transport.EndpointsSet, opts ...grpc.ServerOption) pb.VersionsServer {
-	return &versionsServer{get: grpc.NewServer(
-		endpoints.GetEndpoint,
-		_Decode_Get_Request,
-		_Encode_Get_Response,
-		opts...,
-	)}
-}
-
-func (S *versionsServer) Get(ctx context.Context, req *empty.Empty) (*pb.GetResponse, error) {
-	_, resp, err := S.get.ServeGRPC(ctx, req)
-	if err != nil {
-		return nil, err
-	}
-	return resp.(*pb.GetResponse), nil
-}

pkg/content/version/transport/client.microgen.go

-// Code generated by microgen 0.9.1. DO NOT EDIT.
-
-package transport
-
-import (
-	"context"
-	"errors"
-
-	version "git.perx.ru/perxis/perxis-go/pkg/version"
-	codes "google.golang.org/grpc/codes"
-	status "google.golang.org/grpc/status"
-)
-
-func (set EndpointsSet) Get(arg0 context.Context) (res0 *version.Version, res1 error) {
-	request := GetRequest{}
-	response, res1 := set.GetEndpoint(arg0, &request)
-	if res1 != nil {
-		if e, ok := status.FromError(res1); ok || e.Code() == codes.Internal || e.Code() == codes.Unknown {
-			res1 = errors.New(e.Message())
-		}
-		return
-	}
-	return response.(*GetResponse).Version, res1
-}

pkg/content/version/transport/endpoints.microgen.go

-// Code generated by microgen 0.9.1. DO NOT EDIT.
-
-package transport
-
-import endpoint "github.com/go-kit/kit/endpoint"
-
-// EndpointsSet implements Versions API and used for transport purposes.
-type EndpointsSet struct {
-	GetEndpoint endpoint.Endpoint
-}

pkg/content/version/transport/exchanges.microgen.go

-// Code generated by microgen 0.9.1. DO NOT EDIT.
-
-package transport
-
-import version "git.perx.ru/perxis/perxis-go/pkg/version"
-
-type (
-	// Formal exchange type, please do not delete.
-	GetRequest  struct{}
-	GetResponse struct {
-		Version *version.Version `json:"version"`
-	}
-)

pkg/content/version/transport/server.microgen.go

-// Code generated by microgen 0.9.1. DO NOT EDIT.
-
-package transport
-
-import (
-	"context"
-
-	versions "git.perx.ru/perxis/perxis-go/pkg/version"
-	endpoint "github.com/go-kit/kit/endpoint"
-)
-
-func Endpoints(svc versions.Versions) EndpointsSet {
-	return EndpointsSet{GetEndpoint: GetEndpoint(svc)}
-}
-
-func GetEndpoint(svc versions.Versions) endpoint.Endpoint {
-	return func(arg0 context.Context, request interface{}) (interface{}, error) {
-		res0, res1 := svc.Get(arg0)
-		return &GetResponse{Version: res0}, res1
-	}
-}

pkg/content/version/transport/grpc/client.microgen.go → pkg/version/transport/grpc/client.microgen.go

@@ -3,16 +3,13 @@
 package transportgrpc
 
 import (
-	transport "git.perx.ru/perxis/perxis-go/pkg/content/version/transport"
+	transport "git.perx.ru/perxis/perxis-go/pkg/version/transport"
 	pb "git.perx.ru/perxis/perxis-go/proto/versions/content"
 	grpckit "github.com/go-kit/kit/transport/grpc"
 	grpc "google.golang.org/grpc"
 )
 
 func NewGRPCClient(conn *grpc.ClientConn, addr string, opts ...grpckit.ClientOption) transport.EndpointsSet {
-	if addr == "" {
-		addr = "content.Versions"
-	}
 	return transport.EndpointsSet{GetEndpoint: grpckit.NewClient(
 		conn, addr, "Get",
 		_Encode_Get_Request,

pkg/content/version/transport/grpc/protobuf_endpoint_converters.microgen.go → pkg/version/transport/grpc/protobuf_endpoint_converters.microgen.go

@@ -7,7 +7,7 @@ import (
 	"context"
 	"errors"
 
-	transport "git.perx.ru/perxis/perxis-go/pkg/content/version/transport"
+	transport "git.perx.ru/perxis/perxis-go/pkg/version/transport"
 	pb "git.perx.ru/perxis/perxis-go/proto/versions/content"
 	empty "github.com/golang/protobuf/ptypes/empty"
 )

pkg/content/version/transport/grpc/server.microgen.go → pkg/version/transport/grpc/server.microgen.go

@@ -4,7 +4,7 @@
 package transportgrpc
 
 import (
-	transport "git.perx.ru/perxis/perxis-go/pkg/content/version/transport"
+	transport "git.perx.ru/perxis/perxis-go/pkg/version/transport"
 	pb "git.perx.ru/perxis/perxis-go/proto/versions/content"
 	grpc "github.com/go-kit/kit/transport/grpc"
 	empty "github.com/golang/protobuf/ptypes/empty"