realloc/frostfs-api-go
1
0
Fork 0
forked from TrueCloudLab/frostfs-api-go
Code Issues Pull requests Projects Releases Packages Wiki Activity

[#176] Re-compile protobuf file from NeoFS API source

Browse source 
Signed-off-by: Leonard Lyubich <leonard@nspcc.ru>
This commit is contained in:
Leonard Lyubich 2021-09-28 18:11:33 +03:00 • committed by Alex Vanin
parent 3c5c589e63
commit 0117e90e9a
25 changed files with 1459 additions and 1459 deletions
Download patch file Download diff file Expand all files Collapse all files

135
v2/reputation/grpc/service.pb.go generated
View file

@ -1,18 +1,13 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.23.0
// protoc v3.14.0
// protoc-gen-go v1.27.1
// protoc v3.18.0
// source: v2/reputation/grpc/service.proto
package reputation
import (
context "context"
proto "github.com/golang/protobuf/proto"
grpc "github.com/nspcc-dev/neofs-api-go/v2/session/grpc"
grpc1 "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
reflect "reflect"
@ -26,10 +21,6 @@ const (
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
// This is a compile-time assertion that a sufficiently up-to-date version
// of the legacy proto package is being used.
const _ = proto.ProtoPackageIsVersion4
// Announce node's local trust information.
type AnnounceLocalTrustRequest struct {
state protoimpl.MessageState
@ -815,125 +806,3 @@ func file_v2_reputation_grpc_service_proto_init() {
file_v2_reputation_grpc_service_proto_goTypes = nil
file_v2_reputation_grpc_service_proto_depIdxs = nil
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc1.ClientConnInterface
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc1.SupportPackageIsVersion6
// ReputationServiceClient is the client API for ReputationService service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type ReputationServiceClient interface {
// Announce local client trust information to any node in NeoFS network.
AnnounceLocalTrust(ctx context.Context, in *AnnounceLocalTrustRequest, opts ...grpc1.CallOption) (*AnnounceLocalTrustResponse, error)
// Announces the intermediate result of the iterative algorithm for
// calculating the global reputation of the node in NeoFS network.
AnnounceIntermediateResult(ctx context.Context, in *AnnounceIntermediateResultRequest, opts ...grpc1.CallOption) (*AnnounceIntermediateResultResponse, error)
}
type reputationServiceClient struct {
cc grpc1.ClientConnInterface
}
func NewReputationServiceClient(cc grpc1.ClientConnInterface) ReputationServiceClient {
return &reputationServiceClient{cc}
}
func (c *reputationServiceClient) AnnounceLocalTrust(ctx context.Context, in *AnnounceLocalTrustRequest, opts ...grpc1.CallOption) (*AnnounceLocalTrustResponse, error) {
out := new(AnnounceLocalTrustResponse)
err := c.cc.Invoke(ctx, "/neo.fs.v2.reputation.ReputationService/AnnounceLocalTrust", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *reputationServiceClient) AnnounceIntermediateResult(ctx context.Context, in *AnnounceIntermediateResultRequest, opts ...grpc1.CallOption) (*AnnounceIntermediateResultResponse, error) {
out := new(AnnounceIntermediateResultResponse)
err := c.cc.Invoke(ctx, "/neo.fs.v2.reputation.ReputationService/AnnounceIntermediateResult", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// ReputationServiceServer is the server API for ReputationService service.
type ReputationServiceServer interface {
// Announce local client trust information to any node in NeoFS network.
AnnounceLocalTrust(context.Context, *AnnounceLocalTrustRequest) (*AnnounceLocalTrustResponse, error)
// Announces the intermediate result of the iterative algorithm for
// calculating the global reputation of the node in NeoFS network.
AnnounceIntermediateResult(context.Context, *AnnounceIntermediateResultRequest) (*AnnounceIntermediateResultResponse, error)
}
// UnimplementedReputationServiceServer can be embedded to have forward compatible implementations.
type UnimplementedReputationServiceServer struct {
}
func (*UnimplementedReputationServiceServer) AnnounceLocalTrust(context.Context, *AnnounceLocalTrustRequest) (*AnnounceLocalTrustResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method AnnounceLocalTrust not implemented")
}
func (*UnimplementedReputationServiceServer) AnnounceIntermediateResult(context.Context, *AnnounceIntermediateResultRequest) (*AnnounceIntermediateResultResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method AnnounceIntermediateResult not implemented")
}
func RegisterReputationServiceServer(s *grpc1.Server, srv ReputationServiceServer) {
s.RegisterService(&_ReputationService_serviceDesc, srv)
}
func _ReputationService_AnnounceLocalTrust_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc1.UnaryServerInterceptor) (interface{}, error) {
in := new(AnnounceLocalTrustRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ReputationServiceServer).AnnounceLocalTrust(ctx, in)
}
info := &grpc1.UnaryServerInfo{
Server: srv,
FullMethod: "/neo.fs.v2.reputation.ReputationService/AnnounceLocalTrust",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ReputationServiceServer).AnnounceLocalTrust(ctx, req.(*AnnounceLocalTrustRequest))
}
return interceptor(ctx, in, info, handler)
}
func _ReputationService_AnnounceIntermediateResult_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc1.UnaryServerInterceptor) (interface{}, error) {
in := new(AnnounceIntermediateResultRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ReputationServiceServer).AnnounceIntermediateResult(ctx, in)
}
info := &grpc1.UnaryServerInfo{
Server: srv,
FullMethod: "/neo.fs.v2.reputation.ReputationService/AnnounceIntermediateResult",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ReputationServiceServer).AnnounceIntermediateResult(ctx, req.(*AnnounceIntermediateResultRequest))
}
return interceptor(ctx, in, info, handler)
}
var _ReputationService_serviceDesc = grpc1.ServiceDesc{
ServiceName: "neo.fs.v2.reputation.ReputationService",
HandlerType: (*ReputationServiceServer)(nil),
Methods: []grpc1.MethodDesc{
{
MethodName: "AnnounceLocalTrust",
Handler: _ReputationService_AnnounceLocalTrust_Handler,
},
{
MethodName: "AnnounceIntermediateResult",
Handler: _ReputationService_AnnounceIntermediateResult_Handler,
},
},
Streams: []grpc1.StreamDesc{},
Metadata: "v2/reputation/grpc/service.proto",
}