diff --git a/CHANGELOG.md b/CHANGELOG.md index 8f7a84e..27506b4 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -7,6 +7,9 @@ ### Fixed ### Changed +### Removed +- Reputation system (#21) + ### Updated ## 2.15.0 - 2023-04-11 diff --git a/accounting/grpc/service.pb.go b/accounting/grpc/service.pb.go index 196c7ab..9699622 100644 Binary files a/accounting/grpc/service.pb.go and b/accounting/grpc/service.pb.go differ diff --git a/accounting/grpc/service_grpc.pb.go b/accounting/grpc/service_grpc.pb.go index f1cfeb5..1e1b17e 100644 Binary files a/accounting/grpc/service_grpc.pb.go and b/accounting/grpc/service_grpc.pb.go differ diff --git a/accounting/grpc/types.pb.go b/accounting/grpc/types.pb.go index 322a56c..b8dff21 100644 Binary files a/accounting/grpc/types.pb.go and b/accounting/grpc/types.pb.go differ diff --git a/acl/grpc/types.pb.go b/acl/grpc/types.pb.go index 583f89a..94a8e47 100644 Binary files a/acl/grpc/types.pb.go and b/acl/grpc/types.pb.go differ diff --git a/audit/grpc/types.pb.go b/audit/grpc/types.pb.go index b542ec2..a2cac43 100644 Binary files a/audit/grpc/types.pb.go and b/audit/grpc/types.pb.go differ diff --git a/container/grpc/service.pb.go b/container/grpc/service.pb.go index 6786337..e3bdaf0 100644 Binary files a/container/grpc/service.pb.go and b/container/grpc/service.pb.go differ diff --git a/container/grpc/service_grpc.pb.go b/container/grpc/service_grpc.pb.go index 1de8b5f..c70bce7 100644 Binary files a/container/grpc/service_grpc.pb.go and b/container/grpc/service_grpc.pb.go differ diff --git a/container/grpc/types.pb.go b/container/grpc/types.pb.go index 1044617..7f0cc1b 100644 Binary files a/container/grpc/types.pb.go and b/container/grpc/types.pb.go differ diff --git a/lock/grpc/types.pb.go b/lock/grpc/types.pb.go index 22758c1..958476c 100644 Binary files a/lock/grpc/types.pb.go and b/lock/grpc/types.pb.go differ diff --git a/netmap/grpc/service.pb.go b/netmap/grpc/service.pb.go index d74d7c3..acfe43c 100644 Binary files a/netmap/grpc/service.pb.go and b/netmap/grpc/service.pb.go differ diff --git a/netmap/grpc/service_grpc.pb.go b/netmap/grpc/service_grpc.pb.go index 9ac25db..3834c3d 100644 Binary files a/netmap/grpc/service_grpc.pb.go and b/netmap/grpc/service_grpc.pb.go differ diff --git a/netmap/grpc/types.pb.go b/netmap/grpc/types.pb.go index 0f017da..276e648 100644 Binary files a/netmap/grpc/types.pb.go and b/netmap/grpc/types.pb.go differ diff --git a/object/grpc/service.pb.go b/object/grpc/service.pb.go index 6ba4090..ddda473 100644 Binary files a/object/grpc/service.pb.go and b/object/grpc/service.pb.go differ diff --git a/object/grpc/service_grpc.pb.go b/object/grpc/service_grpc.pb.go index 6b1c32a..10f33b8 100644 Binary files a/object/grpc/service_grpc.pb.go and b/object/grpc/service_grpc.pb.go differ diff --git a/object/grpc/types.pb.go b/object/grpc/types.pb.go index 506adda..11cb63e 100644 Binary files a/object/grpc/types.pb.go and b/object/grpc/types.pb.go differ diff --git a/refs/grpc/types.pb.go b/refs/grpc/types.pb.go index 5e9bfb5..0d6b671 100644 Binary files a/refs/grpc/types.pb.go and b/refs/grpc/types.pb.go differ diff --git a/reputation/convert.go b/reputation/convert.go deleted file mode 100644 index ca54261..0000000 --- a/reputation/convert.go +++ /dev/null @@ -1,604 +0,0 @@ -package reputation - -import ( - "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/refs" - refsGRPC "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/refs/grpc" - reputation "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/reputation/grpc" - "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/rpc/grpc" - "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/rpc/message" -) - -// ToGRPCMessage converts PeerID to gRPC-generated -// reputation.PeerID message. -func (x *PeerID) ToGRPCMessage() grpc.Message { - var m *reputation.PeerID - - if x != nil { - m = new(reputation.PeerID) - - m.SetPublicKey(x.publicKey) - } - - return m -} - -// FromGRPCMessage tries to restore PeerID from grpc.Message. -// -// Returns message.ErrUnexpectedMessageType if m is not -// a gRPC-generated reputation.PeerID message. -func (x *PeerID) FromGRPCMessage(m grpc.Message) error { - v, ok := m.(*reputation.PeerID) - if !ok { - return message.NewUnexpectedMessageType(m, v) - } - - x.publicKey = v.GetPublicKey() - - return nil -} - -// ToGRPCMessage converts Trust to gRPC-generated -// reputation.Trust message. -func (x *Trust) ToGRPCMessage() grpc.Message { - var m *reputation.Trust - - if x != nil { - m = new(reputation.Trust) - - m.SetValue(x.val) - m.SetPeer(x.peer.ToGRPCMessage().(*reputation.PeerID)) - } - - return m -} - -// FromGRPCMessage tries to restore Trust from grpc.Message. -// -// Returns message.ErrUnexpectedMessageType if m is not -// a gRPC-generated reputation.Trust message. -func (x *Trust) FromGRPCMessage(m grpc.Message) error { - v, ok := m.(*reputation.Trust) - if !ok { - return message.NewUnexpectedMessageType(m, v) - } - - peer := v.GetPeer() - if peer == nil { - x.peer = nil - } else { - if x.peer == nil { - x.peer = new(PeerID) - } - - err := x.peer.FromGRPCMessage(peer) - if err != nil { - return err - } - } - - x.val = v.GetValue() - - return nil -} - -// ToGRPCMessage converts PeerToPeerTrust to gRPC-generated -// reputation.PeerToPeerTrust message. -func (x *PeerToPeerTrust) ToGRPCMessage() grpc.Message { - var m *reputation.PeerToPeerTrust - - if x != nil { - m = new(reputation.PeerToPeerTrust) - - m.SetTrustingPeer(x.trusting.ToGRPCMessage().(*reputation.PeerID)) - m.SetTrust(x.trust.ToGRPCMessage().(*reputation.Trust)) - } - - return m -} - -// FromGRPCMessage tries to restore PeerToPeerTrust from grpc.Message. -// -// Returns message.ErrUnexpectedMessageType if m is not -// a gRPC-generated reputation.PeerToPeerTrust message. -func (x *PeerToPeerTrust) FromGRPCMessage(m grpc.Message) error { - v, ok := m.(*reputation.PeerToPeerTrust) - if !ok { - return message.NewUnexpectedMessageType(m, v) - } - - var err error - - trusting := v.GetTrustingPeer() - if trusting == nil { - x.trusting = nil - } else { - if x.trusting == nil { - x.trusting = new(PeerID) - } - - err = x.trusting.FromGRPCMessage(trusting) - if err != nil { - return err - } - } - - trust := v.GetTrust() - if trust == nil { - x.trust = nil - } else { - if x.trust == nil { - x.trust = new(Trust) - } - - err = x.trust.FromGRPCMessage(trust) - } - - return err -} - -// TrustsToGRPC converts slice of Trust structures -// to slice of gRPC-generated Trust messages. -func TrustsToGRPC(xs []Trust) (res []*reputation.Trust) { - if xs != nil { - res = make([]*reputation.Trust, 0, len(xs)) - - for i := range xs { - res = append(res, xs[i].ToGRPCMessage().(*reputation.Trust)) - } - } - - return -} - -// TrustsFromGRPC tries to restore slice of Trust structures from -// slice of gRPC-generated reputation.Trust messages. -func TrustsFromGRPC(xs []*reputation.Trust) (res []Trust, err error) { - if xs != nil { - res = make([]Trust, len(xs)) - - for i := range xs { - if xs[i] != nil { - err = res[i].FromGRPCMessage(xs[i]) - if err != nil { - return - } - } - } - } - - return -} - -// ToGRPCMessage converts GlobalTrustBody to gRPC-generated -// reputation.GlobalTrust_Body message. -func (x *GlobalTrustBody) ToGRPCMessage() grpc.Message { - var m *reputation.GlobalTrust_Body - - if x != nil { - m = new(reputation.GlobalTrust_Body) - - m.SetManager(x.manager.ToGRPCMessage().(*reputation.PeerID)) - m.SetTrust(x.trust.ToGRPCMessage().(*reputation.Trust)) - } - - return m -} - -// FromGRPCMessage tries to restore GlobalTrustBody from grpc.Message. -// -// Returns message.ErrUnexpectedMessageType if m is not -// a gRPC-generated reputation.GlobalTrust_Body message. -func (x *GlobalTrustBody) FromGRPCMessage(m grpc.Message) error { - v, ok := m.(*reputation.GlobalTrust_Body) - if !ok { - return message.NewUnexpectedMessageType(m, v) - } - - var err error - - manager := v.GetManager() - if manager == nil { - x.manager = nil - } else { - if x.manager == nil { - x.manager = new(PeerID) - } - - err = x.manager.FromGRPCMessage(manager) - if err != nil { - return err - } - } - - trust := v.GetTrust() - if trust == nil { - x.trust = nil - } else { - if x.trust == nil { - x.trust = new(Trust) - } - - err = x.trust.FromGRPCMessage(trust) - } - - return err -} - -// ToGRPCMessage converts GlobalTrust to gRPC-generated -// reputation.GlobalTrust message. -func (x *GlobalTrust) ToGRPCMessage() grpc.Message { - var m *reputation.GlobalTrust - - if x != nil { - m = new(reputation.GlobalTrust) - - m.SetVersion(x.version.ToGRPCMessage().(*refsGRPC.Version)) - m.SetBody(x.body.ToGRPCMessage().(*reputation.GlobalTrust_Body)) - m.SetSignature(x.sig.ToGRPCMessage().(*refsGRPC.Signature)) - } - - return m -} - -// FromGRPCMessage tries to restore GlobalTrust from grpc.Message. -// -// Returns message.ErrUnexpectedMessageType if m is not -// a gRPC-generated reputation.GlobalTrust message. -func (x *GlobalTrust) FromGRPCMessage(m grpc.Message) error { - v, ok := m.(*reputation.GlobalTrust) - if !ok { - return message.NewUnexpectedMessageType(m, v) - } - - var err error - - version := v.GetVersion() - if version == nil { - x.version = nil - } else { - if x.version == nil { - x.version = new(refs.Version) - } - - err = x.version.FromGRPCMessage(version) - if err != nil { - return err - } - } - - body := v.GetBody() - if body == nil { - x.body = nil - } else { - if x.body == nil { - x.body = new(GlobalTrustBody) - } - - err = x.body.FromGRPCMessage(body) - if err != nil { - return err - } - } - - sig := v.GetSignature() - if sig == nil { - x.sig = nil - } else { - if x.sig == nil { - x.sig = new(refs.Signature) - } - - err = x.sig.FromGRPCMessage(sig) - } - - return err -} - -// ToGRPCMessage converts AnnounceLocalTrustRequestBody to gRPC-generated -// reputation.AnnounceLocalTrustRequest_Body message. -func (x *AnnounceLocalTrustRequestBody) ToGRPCMessage() grpc.Message { - var m *reputation.AnnounceLocalTrustRequest_Body - - if x != nil { - m = new(reputation.AnnounceLocalTrustRequest_Body) - - m.SetEpoch(x.epoch) - m.SetTrusts(TrustsToGRPC(x.trusts)) - } - - return m -} - -// FromGRPCMessage tries to restore AnnounceLocalTrustRequestBody from grpc.Message. -// -// Returns message.ErrUnexpectedMessageType if m is not -// a gRPC-generated reputation.AnnounceLocalTrustRequest_Body message. -func (x *AnnounceLocalTrustRequestBody) FromGRPCMessage(m grpc.Message) error { - v, ok := m.(*reputation.AnnounceLocalTrustRequest_Body) - if !ok { - return message.NewUnexpectedMessageType(m, v) - } - - var err error - - x.trusts, err = TrustsFromGRPC(v.GetTrusts()) - if err != nil { - return err - } - - x.epoch = v.GetEpoch() - - return nil -} - -// ToGRPCMessage converts AnnounceLocalTrustRequest to gRPC-generated -// reputation.AnnounceLocalTrustRequest message. -func (x *AnnounceLocalTrustRequest) ToGRPCMessage() grpc.Message { - var m *reputation.AnnounceLocalTrustRequest - - if x != nil { - m = new(reputation.AnnounceLocalTrustRequest) - - m.SetBody(x.body.ToGRPCMessage().(*reputation.AnnounceLocalTrustRequest_Body)) - x.RequestHeaders.ToMessage(m) - } - - return m -} - -// FromGRPCMessage tries to restore AnnounceLocalTrustRequest from grpc.Message. -// -// Returns message.ErrUnexpectedMessageType if m is not -// a gRPC-generated reputation.AnnounceLocalTrustRequest message. -func (x *AnnounceLocalTrustRequest) FromGRPCMessage(m grpc.Message) error { - v, ok := m.(*reputation.AnnounceLocalTrustRequest) - if !ok { - return message.NewUnexpectedMessageType(m, v) - } - - var err error - - body := v.GetBody() - if body == nil { - x.body = nil - } else { - if x.body == nil { - x.body = new(AnnounceLocalTrustRequestBody) - } - - err = x.body.FromGRPCMessage(body) - if err != nil { - return err - } - } - - return x.RequestHeaders.FromMessage(v) -} - -// ToGRPCMessage converts AnnounceLocalTrustResponseBody to gRPC-generated -// reputation.AnnounceLocalTrustResponse_Body message. -func (x *AnnounceLocalTrustResponseBody) ToGRPCMessage() grpc.Message { - var m *reputation.AnnounceLocalTrustResponse_Body - - if x != nil { - m = new(reputation.AnnounceLocalTrustResponse_Body) - } - - return m -} - -// FromGRPCMessage tries to restore AnnounceLocalTrustResponseBody from grpc.Message. -// -// Returns message.ErrUnexpectedMessageType if m is not -// a gRPC-generated reputation.AnnounceLocalTrustResponse_Body message. -func (x *AnnounceLocalTrustResponseBody) FromGRPCMessage(m grpc.Message) error { - v, ok := m.(*reputation.AnnounceLocalTrustResponse_Body) - if !ok { - return message.NewUnexpectedMessageType(m, v) - } - - return nil -} - -// ToGRPCMessage converts AnnounceLocalTrustResponse to gRPC-generated -// reputation.AnnounceLocalTrustResponse message. -func (x *AnnounceLocalTrustResponse) ToGRPCMessage() grpc.Message { - var m *reputation.AnnounceLocalTrustResponse - - if x != nil { - m = new(reputation.AnnounceLocalTrustResponse) - - m.SetBody(x.body.ToGRPCMessage().(*reputation.AnnounceLocalTrustResponse_Body)) - x.ResponseHeaders.ToMessage(m) - } - - return m -} - -// FromGRPCMessage tries to restore AnnounceLocalTrustResponse from grpc.Message. -// -// Returns message.ErrUnexpectedMessageType if m is not -// a gRPC-generated reputation.AnnounceLocalTrustResponse message. -func (x *AnnounceLocalTrustResponse) FromGRPCMessage(m grpc.Message) error { - v, ok := m.(*reputation.AnnounceLocalTrustResponse) - if !ok { - return message.NewUnexpectedMessageType(m, v) - } - - var err error - - body := v.GetBody() - if body == nil { - x.body = nil - } else { - if x.body == nil { - x.body = new(AnnounceLocalTrustResponseBody) - } - - err = x.body.FromGRPCMessage(body) - if err != nil { - return err - } - } - - return x.ResponseHeaders.FromMessage(v) -} - -// ToGRPCMessage converts AnnounceIntermediateResultRequestBody to gRPC-generated -// reputation.AnnounceIntermediateResultRequest_Body message. -func (x *AnnounceIntermediateResultRequestBody) ToGRPCMessage() grpc.Message { - var m *reputation.AnnounceIntermediateResultRequest_Body - - if x != nil { - m = new(reputation.AnnounceIntermediateResultRequest_Body) - - m.SetEpoch(x.epoch) - m.SetIteration(x.iter) - m.SetTrust(x.trust.ToGRPCMessage().(*reputation.PeerToPeerTrust)) - } - - return m -} - -// FromGRPCMessage tries to restore AnnounceIntermediateResultRequestBody from grpc.Message. -// -// Returns message.ErrUnexpectedMessageType if m is not -// a gRPC-generated reputation.AnnounceIntermediateResultRequest_Body message. -func (x *AnnounceIntermediateResultRequestBody) FromGRPCMessage(m grpc.Message) error { - v, ok := m.(*reputation.AnnounceIntermediateResultRequest_Body) - if !ok { - return message.NewUnexpectedMessageType(m, v) - } - - trust := v.GetTrust() - if trust == nil { - x.trust = nil - } else { - if x.trust == nil { - x.trust = new(PeerToPeerTrust) - } - - err := x.trust.FromGRPCMessage(trust) - if err != nil { - return err - } - } - - x.epoch = v.GetEpoch() - x.iter = v.GetIteration() - - return nil -} - -// ToGRPCMessage converts AnnounceIntermediateResultRequest to gRPC-generated -// reputation.AnnounceIntermediateResultRequest message. -func (x *AnnounceIntermediateResultRequest) ToGRPCMessage() grpc.Message { - var m *reputation.AnnounceIntermediateResultRequest - - if x != nil { - m = new(reputation.AnnounceIntermediateResultRequest) - - m.SetBody(x.body.ToGRPCMessage().(*reputation.AnnounceIntermediateResultRequest_Body)) - x.RequestHeaders.ToMessage(m) - } - - return m -} - -// FromGRPCMessage tries to restore AnnounceIntermediateResultRequest from grpc.Message. -// -// Returns message.ErrUnexpectedMessageType if m is not -// a gRPC-generated reputation.AnnounceIntermediateResultRequest message. -func (x *AnnounceIntermediateResultRequest) FromGRPCMessage(m grpc.Message) error { - v, ok := m.(*reputation.AnnounceIntermediateResultRequest) - if !ok { - return message.NewUnexpectedMessageType(m, v) - } - - var err error - - body := v.GetBody() - if body == nil { - x.body = nil - } else { - if x.body == nil { - x.body = new(AnnounceIntermediateResultRequestBody) - } - - err = x.body.FromGRPCMessage(body) - if err != nil { - return err - } - } - - return x.RequestHeaders.FromMessage(v) -} - -// ToGRPCMessage converts AnnounceIntermediateResultResponseBody to gRPC-generated -// reputation.AnnounceIntermediateResultResponse_Body message. -func (x *AnnounceIntermediateResultResponseBody) ToGRPCMessage() grpc.Message { - var m *reputation.AnnounceIntermediateResultResponse_Body - - if x != nil { - m = new(reputation.AnnounceIntermediateResultResponse_Body) - } - - return m -} - -// FromGRPCMessage tries to restore AnnounceIntermediateResultResponseBody from grpc.Message. -// -// Returns message.ErrUnexpectedMessageType if m is not -// a gRPC-generated reputation.AnnounceIntermediateResultResponse_Body message. -func (x *AnnounceIntermediateResultResponseBody) FromGRPCMessage(m grpc.Message) error { - v, ok := m.(*reputation.AnnounceIntermediateResultResponse_Body) - if !ok { - return message.NewUnexpectedMessageType(m, v) - } - - return nil -} - -// ToGRPCMessage converts AnnounceIntermediateResultResponse to gRPC-generated -// reputation.AnnounceIntermediateResultResponse message. -func (x *AnnounceIntermediateResultResponse) ToGRPCMessage() grpc.Message { - var m *reputation.AnnounceIntermediateResultResponse - - if x != nil { - m = new(reputation.AnnounceIntermediateResultResponse) - - m.SetBody(x.body.ToGRPCMessage().(*reputation.AnnounceIntermediateResultResponse_Body)) - x.ResponseHeaders.ToMessage(m) - } - - return m -} - -// FromGRPCMessage tries to restore AnnounceIntermediateResultResponse from grpc.Message. -// -// Returns message.ErrUnexpectedMessageType if m is not -// a gRPC-generated reputation.AnnounceIntermediateResultResponse message. -func (x *AnnounceIntermediateResultResponse) FromGRPCMessage(m grpc.Message) error { - v, ok := m.(*reputation.AnnounceIntermediateResultResponse) - if !ok { - return message.NewUnexpectedMessageType(m, v) - } - - var err error - - body := v.GetBody() - if body == nil { - x.body = nil - } else { - if x.body == nil { - x.body = new(AnnounceIntermediateResultResponseBody) - } - - err = x.body.FromGRPCMessage(body) - if err != nil { - return err - } - } - - return x.ResponseHeaders.FromMessage(v) -} diff --git a/reputation/grpc/service.go b/reputation/grpc/service.go deleted file mode 100644 index 81ed890..0000000 --- a/reputation/grpc/service.go +++ /dev/null @@ -1,90 +0,0 @@ -package reputation - -import ( - session "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/session/grpc" -) - -// SetEpoch sets epoch in which the trust was assessed. -func (x *AnnounceLocalTrustRequest_Body) SetEpoch(v uint64) { - x.Epoch = v -} - -// SetTrusts sets list of normalized trust values. -func (x *AnnounceLocalTrustRequest_Body) SetTrusts(v []*Trust) { - x.Trusts = v -} - -// SetBody sets body of the request. -func (x *AnnounceLocalTrustRequest) SetBody(v *AnnounceLocalTrustRequest_Body) { - x.Body = v -} - -// SetMetaHeader sets meta header of the request. -func (x *AnnounceLocalTrustRequest) SetMetaHeader(v *session.RequestMetaHeader) { - x.MetaHeader = v -} - -// SetVerifyHeader sets verification header of the request. -func (x *AnnounceLocalTrustRequest) SetVerifyHeader(v *session.RequestVerificationHeader) { - x.VerifyHeader = v -} - -// SetBody sets body of the response. -func (x *AnnounceLocalTrustResponse) SetBody(v *AnnounceLocalTrustResponse_Body) { - x.Body = v -} - -// SetMetaHeader sets meta header of the response. -func (x *AnnounceLocalTrustResponse) SetMetaHeader(v *session.ResponseMetaHeader) { - x.MetaHeader = v -} - -// SetVerifyHeader sets verification header of the response. -func (x *AnnounceLocalTrustResponse) SetVerifyHeader(v *session.ResponseVerificationHeader) { - x.VerifyHeader = v -} - -// SetEpoch sets epoch in which the intermediate trust was assessed. -func (x *AnnounceIntermediateResultRequest_Body) SetEpoch(v uint64) { - x.Epoch = v -} - -// SetIteration sets sequence number of the iteration. -func (x *AnnounceIntermediateResultRequest_Body) SetIteration(v uint32) { - x.Iteration = v -} - -// SetTrust sets current global trust value. -func (x *AnnounceIntermediateResultRequest_Body) SetTrust(v *PeerToPeerTrust) { - x.Trust = v -} - -// SetBody sets body of the request. -func (x *AnnounceIntermediateResultRequest) SetBody(v *AnnounceIntermediateResultRequest_Body) { - x.Body = v -} - -// SetMetaHeader sets meta header of the request. -func (x *AnnounceIntermediateResultRequest) SetMetaHeader(v *session.RequestMetaHeader) { - x.MetaHeader = v -} - -// SetVerifyHeader sets verification header of the request. -func (x *AnnounceIntermediateResultRequest) SetVerifyHeader(v *session.RequestVerificationHeader) { - x.VerifyHeader = v -} - -// SetBody sets body of the response. -func (x *AnnounceIntermediateResultResponse) SetBody(v *AnnounceIntermediateResultResponse_Body) { - x.Body = v -} - -// SetMetaHeader sets meta header of the response. -func (x *AnnounceIntermediateResultResponse) SetMetaHeader(v *session.ResponseMetaHeader) { - x.MetaHeader = v -} - -// SetVerifyHeader sets verification header of the response. -func (x *AnnounceIntermediateResultResponse) SetVerifyHeader(v *session.ResponseVerificationHeader) { - x.VerifyHeader = v -} diff --git a/reputation/grpc/service.pb.go b/reputation/grpc/service.pb.go deleted file mode 100644 index 2d0f61f..0000000 Binary files a/reputation/grpc/service.pb.go and /dev/null differ diff --git a/reputation/grpc/service_grpc.pb.go b/reputation/grpc/service_grpc.pb.go deleted file mode 100644 index 582a8cd..0000000 Binary files a/reputation/grpc/service_grpc.pb.go and /dev/null differ diff --git a/reputation/grpc/types.go b/reputation/grpc/types.go deleted file mode 100644 index 63f2d34..0000000 --- a/reputation/grpc/types.go +++ /dev/null @@ -1,55 +0,0 @@ -package reputation - -import ( - refs "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/refs/grpc" -) - -// SetPublicKey sets binary public key of ID. -func (x *PeerID) SetPublicKey(v []byte) { - x.PublicKey = v -} - -// SetPeer sets trusted peer's ID. -func (x *Trust) SetPeer(v *PeerID) { - x.Peer = v -} - -// SetValue sets trust value. -func (x *Trust) SetValue(v float64) { - x.Value = v -} - -// SetTrustingPeer sets trusting peer ID. -func (x *PeerToPeerTrust) SetTrustingPeer(v *PeerID) { - x.TrustingPeer = v -} - -// SetTrust sets trust value of trusting peer to the trusted one. -func (x *PeerToPeerTrust) SetTrust(v *Trust) { - x.Trust = v -} - -// SetManager sets manager ID. -func (x *GlobalTrust_Body) SetManager(v *PeerID) { - x.Manager = v -} - -// SetTrust sets global trust value. -func (x *GlobalTrust_Body) SetTrust(v *Trust) { - x.Trust = v -} - -// SetVersion sets message format version. -func (x *GlobalTrust) SetVersion(v *refs.Version) { - x.Version = v -} - -// SetBody sets message body. -func (x *GlobalTrust) SetBody(v *GlobalTrust_Body) { - x.Body = v -} - -// SetSignature sets body signature. -func (x *GlobalTrust) SetSignature(v *refs.Signature) { - x.Signature = v -} diff --git a/reputation/grpc/types.pb.go b/reputation/grpc/types.pb.go deleted file mode 100644 index b95b240..0000000 Binary files a/reputation/grpc/types.pb.go and /dev/null differ diff --git a/reputation/json.go b/reputation/json.go deleted file mode 100644 index 3976462..0000000 --- a/reputation/json.go +++ /dev/null @@ -1,38 +0,0 @@ -package reputation - -import ( - reputation "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/reputation/grpc" - "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/rpc/message" -) - -func (x *PeerID) MarshalJSON() ([]byte, error) { - return message.MarshalJSON(x) -} - -func (x *PeerID) UnmarshalJSON(data []byte) error { - return message.UnmarshalJSON(x, data, new(reputation.PeerID)) -} - -func (x *Trust) MarshalJSON() ([]byte, error) { - return message.MarshalJSON(x) -} - -func (x *Trust) UnmarshalJSON(data []byte) error { - return message.UnmarshalJSON(x, data, new(reputation.Trust)) -} - -func (x *PeerToPeerTrust) MarshalJSON() ([]byte, error) { - return message.MarshalJSON(x) -} - -func (x *PeerToPeerTrust) UnmarshalJSON(data []byte) error { - return message.UnmarshalJSON(x, data, new(reputation.PeerToPeerTrust)) -} - -func (x *GlobalTrust) MarshalJSON() ([]byte, error) { - return message.MarshalJSON(x) -} - -func (x *GlobalTrust) UnmarshalJSON(data []byte) error { - return message.UnmarshalJSON(x, data, new(reputation.GlobalTrust)) -} diff --git a/reputation/marshal.go b/reputation/marshal.go deleted file mode 100644 index a64e822..0000000 --- a/reputation/marshal.go +++ /dev/null @@ -1,276 +0,0 @@ -package reputation - -import ( - reputation "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/reputation/grpc" - "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/rpc/message" - protoutil "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/util/proto" -) - -const ( - _ = iota - peerIDPubKeyFNum -) - -func (x *PeerID) StableMarshal(buf []byte) []byte { - if x == nil { - return []byte{} - } - - if buf == nil { - buf = make([]byte, x.StableSize()) - } - - protoutil.BytesMarshal(peerIDPubKeyFNum, buf, x.publicKey) - - return buf -} - -func (x *PeerID) StableSize() (size int) { - size += protoutil.BytesSize(peerIDPubKeyFNum, x.publicKey) - - return -} - -func (x *PeerID) Unmarshal(data []byte) error { - return message.Unmarshal(x, data, new(reputation.PeerID)) -} - -const ( - _ = iota - trustPeerFNum - trustValueFNum -) - -func (x *Trust) StableMarshal(buf []byte) []byte { - if x == nil { - return []byte{} - } - - if buf == nil { - buf = make([]byte, x.StableSize()) - } - - var offset int - - offset += protoutil.NestedStructureMarshal(trustPeerFNum, buf[offset:], x.peer) - protoutil.Float64Marshal(trustValueFNum, buf[offset:], x.val) - - return buf -} - -func (x *Trust) StableSize() (size int) { - size += protoutil.NestedStructureSize(trustPeerFNum, x.peer) - size += protoutil.Float64Size(trustValueFNum, x.val) - - return -} - -func (x *Trust) Unmarshal(data []byte) error { - return message.Unmarshal(x, data, new(reputation.Trust)) -} - -const ( - _ = iota - p2pTrustTrustingFNum - p2pTrustValueFNum -) - -func (x *PeerToPeerTrust) StableMarshal(buf []byte) []byte { - if x == nil { - return []byte{} - } - - if buf == nil { - buf = make([]byte, x.StableSize()) - } - - var offset int - - offset += protoutil.NestedStructureMarshal(p2pTrustTrustingFNum, buf, x.trusting) - protoutil.NestedStructureMarshal(p2pTrustValueFNum, buf[offset:], x.trust) - - return buf -} - -func (x *PeerToPeerTrust) StableSize() (size int) { - size += protoutil.NestedStructureSize(p2pTrustTrustingFNum, x.trusting) - size += protoutil.NestedStructureSize(p2pTrustValueFNum, x.trust) - - return -} - -func (x *PeerToPeerTrust) Unmarshal(data []byte) error { - return message.Unmarshal(x, data, new(reputation.PeerToPeerTrust)) -} - -const ( - _ = iota - globalTrustBodyManagerFNum - globalTrustBodyValueFNum -) - -func (x *GlobalTrustBody) StableMarshal(buf []byte) []byte { - if x == nil { - return []byte{} - } - - if buf == nil { - buf = make([]byte, x.StableSize()) - } - - var offset int - - offset += protoutil.NestedStructureMarshal(globalTrustBodyManagerFNum, buf, x.manager) - protoutil.NestedStructureMarshal(globalTrustBodyValueFNum, buf[offset:], x.trust) - - return buf -} - -func (x *GlobalTrustBody) StableSize() (size int) { - size += protoutil.NestedStructureSize(globalTrustBodyManagerFNum, x.manager) - size += protoutil.NestedStructureSize(globalTrustBodyValueFNum, x.trust) - - return -} - -func (x *GlobalTrustBody) Unmarshal(data []byte) error { - return message.Unmarshal(x, data, new(reputation.GlobalTrust_Body)) -} - -const ( - _ = iota - globalTrustVersionFNum - globalTrustBodyFNum - globalTrustSigFNum -) - -func (x *GlobalTrust) StableMarshal(buf []byte) []byte { - if x == nil { - return []byte{} - } - - if buf == nil { - buf = make([]byte, x.StableSize()) - } - - var offset int - - offset += protoutil.NestedStructureMarshal(globalTrustVersionFNum, buf, x.version) - offset += protoutil.NestedStructureMarshal(globalTrustBodyFNum, buf[offset:], x.body) - protoutil.NestedStructureMarshal(globalTrustSigFNum, buf[offset:], x.sig) - - return buf -} - -func (x *GlobalTrust) StableSize() (size int) { - size += protoutil.NestedStructureSize(globalTrustVersionFNum, x.version) - size += protoutil.NestedStructureSize(globalTrustBodyFNum, x.body) - size += protoutil.NestedStructureSize(globalTrustSigFNum, x.sig) - - return -} - -func (x *GlobalTrust) Unmarshal(data []byte) error { - return message.Unmarshal(x, data, new(reputation.GlobalTrust)) -} - -const ( - _ = iota - announceLocalTrustBodyEpochFNum - announceLocalTrustBodyTrustsFNum -) - -func (x *AnnounceLocalTrustRequestBody) StableMarshal(buf []byte) []byte { - if x == nil { - return []byte{} - } - - if buf == nil { - buf = make([]byte, x.StableSize()) - } - - var offset int - - offset += protoutil.UInt64Marshal(announceLocalTrustBodyEpochFNum, buf[offset:], x.epoch) - - for i := range x.trusts { - offset += protoutil.NestedStructureMarshal(announceLocalTrustBodyTrustsFNum, buf[offset:], &x.trusts[i]) - } - - return buf -} - -func (x *AnnounceLocalTrustRequestBody) StableSize() (size int) { - size += protoutil.UInt64Size(announceLocalTrustBodyEpochFNum, x.epoch) - - for i := range x.trusts { - size += protoutil.NestedStructureSize(announceLocalTrustBodyTrustsFNum, &x.trusts[i]) - } - - return -} - -func (x *AnnounceLocalTrustRequestBody) Unmarshal(data []byte) error { - return message.Unmarshal(x, data, new(reputation.AnnounceLocalTrustRequest_Body)) -} - -func (x *AnnounceLocalTrustResponseBody) StableMarshal(buf []byte) []byte { - return buf -} - -func (x *AnnounceLocalTrustResponseBody) StableSize() int { - return 0 -} - -func (x *AnnounceLocalTrustResponseBody) Unmarshal(data []byte) error { - return message.Unmarshal(x, data, new(reputation.AnnounceLocalTrustResponse_Body)) -} - -const ( - _ = iota - announceInterResBodyEpochFNum - announceInterResBodyIterFNum - announceInterResBodyTrustFNum -) - -func (x *AnnounceIntermediateResultRequestBody) StableMarshal(buf []byte) []byte { - if x == nil { - return []byte{} - } - - if buf == nil { - buf = make([]byte, x.StableSize()) - } - - var offset int - - offset += protoutil.UInt64Marshal(announceInterResBodyEpochFNum, buf, x.epoch) - offset += protoutil.UInt32Marshal(announceInterResBodyIterFNum, buf[offset:], x.iter) - protoutil.NestedStructureMarshal(announceInterResBodyTrustFNum, buf[offset:], x.trust) - - return buf -} - -func (x *AnnounceIntermediateResultRequestBody) StableSize() (size int) { - size += protoutil.UInt64Size(announceInterResBodyEpochFNum, x.epoch) - size += protoutil.UInt32Size(announceInterResBodyIterFNum, x.iter) - size += protoutil.NestedStructureSize(announceInterResBodyTrustFNum, x.trust) - - return -} - -func (x *AnnounceIntermediateResultRequestBody) Unmarshal(data []byte) error { - return message.Unmarshal(x, data, new(reputation.AnnounceIntermediateResultRequest_Body)) -} - -func (x *AnnounceIntermediateResultResponseBody) StableMarshal(buf []byte) []byte { - return buf -} - -func (x *AnnounceIntermediateResultResponseBody) StableSize() int { - return 0 -} - -func (x *AnnounceIntermediateResultResponseBody) Unmarshal(data []byte) error { - return message.Unmarshal(x, data, new(reputation.AnnounceIntermediateResultResponse_Body)) -} diff --git a/reputation/message_test.go b/reputation/message_test.go deleted file mode 100644 index 891c2e4..0000000 --- a/reputation/message_test.go +++ /dev/null @@ -1,34 +0,0 @@ -package reputation_test - -import ( - "testing" - - reputationtest "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/reputation/test" - "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/rpc/message" - messagetest "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/rpc/message/test" -) - -func TestMessageConvert(t *testing.T) { - messagetest.TestRPCMessage(t, - func(empty bool) message.Message { return reputationtest.GenerateTrust(empty) }, - func(empty bool) message.Message { return reputationtest.GenerateAnnounceLocalTrustRequestBody(empty) }, - func(empty bool) message.Message { return reputationtest.GenerateAnnounceLocalTrustRequest(empty) }, - func(empty bool) message.Message { return reputationtest.GenerateAnnounceLocalTrustResponseBody(empty) }, - func(empty bool) message.Message { return reputationtest.GenerateAnnounceLocalTrustResponse(empty) }, - func(empty bool) message.Message { - return reputationtest.GenerateAnnounceIntermediateResultRequestBody(empty) - }, - func(empty bool) message.Message { - return reputationtest.GenerateAnnounceIntermediateResultRequest(empty) - }, - func(empty bool) message.Message { - return reputationtest.GenerateAnnounceIntermediateResultResponseBody(empty) - }, - func(empty bool) message.Message { - return reputationtest.GenerateAnnounceIntermediateResultResponse(empty) - }, - func(empty bool) message.Message { return reputationtest.GenerateGlobalTrustBody(empty) }, - func(empty bool) message.Message { return reputationtest.GenerateGlobalTrust(empty) }, - func(empty bool) message.Message { return reputationtest.GeneratePeerToPeerTrust(empty) }, - ) -} diff --git a/reputation/test/generate.go b/reputation/test/generate.go deleted file mode 100644 index 7731ad9..0000000 --- a/reputation/test/generate.go +++ /dev/null @@ -1,160 +0,0 @@ -package reputationtest - -import ( - refstest "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/refs/test" - "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/reputation" - sessiontest "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/session/test" -) - -func GeneratePeerID(empty bool) *reputation.PeerID { - m := new(reputation.PeerID) - - if !empty { - m.SetPublicKey([]byte{1, 2, 3}) - } - - return m -} - -func GenerateTrust(empty bool) *reputation.Trust { - m := new(reputation.Trust) - - if !empty { - m.SetValue(1) - m.SetPeer(GeneratePeerID(false)) - } - - return m -} - -func GeneratePeerToPeerTrust(empty bool) *reputation.PeerToPeerTrust { - m := new(reputation.PeerToPeerTrust) - - if !empty { - m.SetTrustingPeer(GeneratePeerID(false)) - m.SetTrust(GenerateTrust(false)) - } - - return m -} - -func GenerateGlobalTrustBody(empty bool) *reputation.GlobalTrustBody { - m := new(reputation.GlobalTrustBody) - - if !empty { - m.SetManager(GeneratePeerID(false)) - m.SetTrust(GenerateTrust(false)) - } - - return m -} - -func GenerateGlobalTrust(empty bool) *reputation.GlobalTrust { - m := new(reputation.GlobalTrust) - - if !empty { - m.SetVersion(refstest.GenerateVersion(false)) - m.SetBody(GenerateGlobalTrustBody(false)) - m.SetSignature(refstest.GenerateSignature(empty)) - } - - return m -} - -func GenerateTrusts(empty bool) []reputation.Trust { - var res []reputation.Trust - - if !empty { - res = append(res, - *GenerateTrust(false), - *GenerateTrust(false), - ) - } - - return res -} - -func GenerateAnnounceLocalTrustRequestBody(empty bool) *reputation.AnnounceLocalTrustRequestBody { - m := new(reputation.AnnounceLocalTrustRequestBody) - - if !empty { - m.SetEpoch(13) - m.SetTrusts(GenerateTrusts(false)) - } - - return m -} - -func GenerateAnnounceLocalTrustRequest(empty bool) *reputation.AnnounceLocalTrustRequest { - m := new(reputation.AnnounceLocalTrustRequest) - - if !empty { - m.SetBody(GenerateAnnounceLocalTrustRequestBody(false)) - m.SetMetaHeader(sessiontest.GenerateRequestMetaHeader(empty)) - m.SetVerificationHeader(sessiontest.GenerateRequestVerificationHeader(empty)) - } - - return m -} - -func GenerateAnnounceLocalTrustResponseBody(empty bool) *reputation.AnnounceLocalTrustResponseBody { - m := new(reputation.AnnounceLocalTrustResponseBody) - - return m -} - -func GenerateAnnounceLocalTrustResponse(empty bool) *reputation.AnnounceLocalTrustResponse { - m := new(reputation.AnnounceLocalTrustResponse) - - if !empty { - m.SetBody(GenerateAnnounceLocalTrustResponseBody(false)) - m.SetMetaHeader(sessiontest.GenerateResponseMetaHeader(empty)) - m.SetVerificationHeader(sessiontest.GenerateResponseVerificationHeader(empty)) - } - - return m -} - -func GenerateAnnounceIntermediateResultRequestBody(empty bool) *reputation.AnnounceIntermediateResultRequestBody { - m := new(reputation.AnnounceIntermediateResultRequestBody) - - if !empty { - m.SetEpoch(123) - m.SetIteration(564) - m.SetTrust(GeneratePeerToPeerTrust(false)) - } - - return m -} - -func GenerateAnnounceIntermediateResultRequest(empty bool) *reputation.AnnounceIntermediateResultRequest { - m := new(reputation.AnnounceIntermediateResultRequest) - - if !empty { - m.SetBody(GenerateAnnounceIntermediateResultRequestBody(false)) - } - - m.SetMetaHeader(sessiontest.GenerateRequestMetaHeader(empty)) - m.SetVerificationHeader(sessiontest.GenerateRequestVerificationHeader(empty)) - - return m -} - -func GenerateAnnounceIntermediateResultResponseBody(empty bool) *reputation.AnnounceIntermediateResultResponseBody { - m := new(reputation.AnnounceIntermediateResultResponseBody) - - return m -} - -func GenerateAnnounceIntermediateResultResponse(empty bool) *reputation.AnnounceIntermediateResultResponse { - m := new(reputation.AnnounceIntermediateResultResponse) - - if !empty { - m.SetBody(GenerateAnnounceIntermediateResultResponseBody(false)) - } - - m.SetMetaHeader(sessiontest.GenerateResponseMetaHeader(empty)) - m.SetVerificationHeader(sessiontest.GenerateResponseVerificationHeader(empty)) - - return m -} diff --git a/reputation/types.go b/reputation/types.go deleted file mode 100644 index a339183..0000000 --- a/reputation/types.go +++ /dev/null @@ -1,366 +0,0 @@ -package reputation - -import ( - "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/refs" - "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/session" -) - -// PeerID represents reputation.PeerID message -// from NeoFS API v2. -type PeerID struct { - publicKey []byte -} - -// GetPublicKey returns peer's binary public key of ID. -func (x *PeerID) GetPublicKey() []byte { - if x != nil { - return x.publicKey - } - - return nil -} - -// SetPublicKey sets peer's binary public key of ID. -func (x *PeerID) SetPublicKey(v []byte) { - x.publicKey = v -} - -// Trust represents reputation.Trust message -// from NeoFS API v2. -type Trust struct { - val float64 - - peer *PeerID -} - -// GetPeer returns trusted peer's ID. -func (x *Trust) GetPeer() *PeerID { - if x != nil { - return x.peer - } - - return nil -} - -// SetPeer sets trusted peer's ID. -func (x *Trust) SetPeer(v *PeerID) { - x.peer = v -} - -// GetValue returns trust value. -func (x *Trust) GetValue() float64 { - if x != nil { - return x.val - } - - return 0 -} - -// SetValue sets trust value. -func (x *Trust) SetValue(v float64) { - x.val = v -} - -// PeerToPeerTrust represents reputation.PeerToPeerTrust message -// from NeoFS API v2. -type PeerToPeerTrust struct { - trusting *PeerID - - trust *Trust -} - -// GetTrustingPeer returns trusting peer ID. -func (x *PeerToPeerTrust) GetTrustingPeer() *PeerID { - if x != nil { - return x.trusting - } - - return nil -} - -// SetTrustingPeer sets trusting peer ID. -func (x *PeerToPeerTrust) SetTrustingPeer(v *PeerID) { - x.trusting = v -} - -// GetTrust returns trust value of trusting peer to the trusted one. -func (x *PeerToPeerTrust) GetTrust() *Trust { - if x != nil { - return x.trust - } - - return nil -} - -// SetTrust sets trust value of trusting peer to the trusted one. -func (x *PeerToPeerTrust) SetTrust(v *Trust) { - x.trust = v -} - -// GlobalTrustBody represents reputation.GlobalTrust.Body message -// from NeoFS API v2. -type GlobalTrustBody struct { - manager *PeerID - - trust *Trust -} - -// GetManager returns node manager ID. -func (x *GlobalTrustBody) GetManager() *PeerID { - if x != nil { - return x.manager - } - - return nil -} - -// SetManager sets node manager ID. -func (x *GlobalTrustBody) SetManager(v *PeerID) { - x.manager = v -} - -// GetTrust returns global trust value. -func (x *GlobalTrustBody) GetTrust() *Trust { - if x != nil { - return x.trust - } - - return nil -} - -// SetTrust sets global trust value. -func (x *GlobalTrustBody) SetTrust(v *Trust) { - x.trust = v -} - -// GlobalTrust represents reputation.GlobalTrust message -// from NeoFS API v2. -type GlobalTrust struct { - version *refs.Version - - body *GlobalTrustBody - - sig *refs.Signature -} - -// GetVersion returns message format version. -func (x *GlobalTrust) GetVersion() *refs.Version { - if x != nil { - return x.version - } - - return nil -} - -// SetVersion sets message format version. -func (x *GlobalTrust) SetVersion(v *refs.Version) { - x.version = v -} - -// GetBody returns message body. -func (x *GlobalTrust) GetBody() *GlobalTrustBody { - if x != nil { - return x.body - } - - return nil -} - -// SetBody sets message body. -func (x *GlobalTrust) SetBody(v *GlobalTrustBody) { - x.body = v -} - -// GetSignature returns body signature. -func (x *GlobalTrust) GetSignature() *refs.Signature { - if x != nil { - return x.sig - } - - return nil -} - -// SetSignature sets body signature. -func (x *GlobalTrust) SetSignature(v *refs.Signature) { - x.sig = v -} - -// AnnounceLocalTrustRequestBody is a structure of AnnounceLocalTrust request body. -type AnnounceLocalTrustRequestBody struct { - epoch uint64 - - trusts []Trust -} - -// GetEpoch returns epoch in which the trust was assessed. -func (x *AnnounceLocalTrustRequestBody) GetEpoch() uint64 { - if x != nil { - return x.epoch - } - - return 0 -} - -// SetEpoch sets epoch in which the trust was assessed. -func (x *AnnounceLocalTrustRequestBody) SetEpoch(v uint64) { - x.epoch = v -} - -// GetTrusts returns list of normalized trust values. -func (x *AnnounceLocalTrustRequestBody) GetTrusts() []Trust { - if x != nil { - return x.trusts - } - - return nil -} - -// SetTrusts sets list of normalized trust values. -func (x *AnnounceLocalTrustRequestBody) SetTrusts(v []Trust) { - x.trusts = v -} - -// AnnounceLocalTrustResponseBody is a structure of AnnounceLocalTrust response body. -type AnnounceLocalTrustResponseBody struct{} - -// AnnounceLocalTrustRequest represents reputation.AnnounceLocalTrustRequest -// message from NeoFS API v2. -type AnnounceLocalTrustRequest struct { - body *AnnounceLocalTrustRequestBody - - session.RequestHeaders -} - -// GetBody returns request body. -func (x *AnnounceLocalTrustRequest) GetBody() *AnnounceLocalTrustRequestBody { - if x != nil { - return x.body - } - - return nil -} - -// SetBody sets request body. -func (x *AnnounceLocalTrustRequest) SetBody(v *AnnounceLocalTrustRequestBody) { - x.body = v -} - -// AnnounceLocalTrustResponse represents reputation.AnnounceLocalTrustResponse -// message from NeoFS API v2. -type AnnounceLocalTrustResponse struct { - body *AnnounceLocalTrustResponseBody - - session.ResponseHeaders -} - -// GetBody returns response body. -func (x *AnnounceLocalTrustResponse) GetBody() *AnnounceLocalTrustResponseBody { - if x != nil { - return x.body - } - - return nil -} - -// SetBody sets response body. -func (x *AnnounceLocalTrustResponse) SetBody(v *AnnounceLocalTrustResponseBody) { - x.body = v -} - -// AnnounceIntermediateResultRequestBody is a structure of AnnounceIntermediateResult request body. -type AnnounceIntermediateResultRequestBody struct { - epoch uint64 - - iter uint32 - - trust *PeerToPeerTrust -} - -// GetEpoch returns epoch number in which the intermediate trust was assessed. -func (x *AnnounceIntermediateResultRequestBody) GetEpoch() uint64 { - if x != nil { - return x.epoch - } - - return 0 -} - -// SetEpoch sets epoch number in which the intermediate trust was assessed. -func (x *AnnounceIntermediateResultRequestBody) SetEpoch(v uint64) { - x.epoch = v -} - -// GetIteration returns sequence number of the iteration. -func (x *AnnounceIntermediateResultRequestBody) GetIteration() uint32 { - if x != nil { - return x.iter - } - - return 0 -} - -// SetIteration sets sequence number of the iteration. -func (x *AnnounceIntermediateResultRequestBody) SetIteration(v uint32) { - x.iter = v -} - -// GetTrust returns current global trust value. -func (x *AnnounceIntermediateResultRequestBody) GetTrust() *PeerToPeerTrust { - if x != nil { - return x.trust - } - - return nil -} - -// SetTrust sets current global trust value. -func (x *AnnounceIntermediateResultRequestBody) SetTrust(v *PeerToPeerTrust) { - x.trust = v -} - -// AnnounceIntermediateResultResponseBody is a structure of AnnounceIntermediateResult response body. -type AnnounceIntermediateResultResponseBody struct{} - -// AnnounceIntermediateResultRequest represents reputation.AnnounceIntermediateResult -// message from NeoFS API v2. -type AnnounceIntermediateResultRequest struct { - body *AnnounceIntermediateResultRequestBody - - session.RequestHeaders -} - -// GetBody returns request body. -func (x *AnnounceIntermediateResultRequest) GetBody() *AnnounceIntermediateResultRequestBody { - if x != nil { - return x.body - } - - return nil -} - -// SetBody sets request body. -func (x *AnnounceIntermediateResultRequest) SetBody(v *AnnounceIntermediateResultRequestBody) { - x.body = v -} - -// AnnounceIntermediateResultResponse represents reputation.AnnounceIntermediateResultResponse -// message from NeoFS API v2. -type AnnounceIntermediateResultResponse struct { - body *AnnounceIntermediateResultResponseBody - - session.ResponseHeaders -} - -// GetBody returns response body. -func (x *AnnounceIntermediateResultResponse) GetBody() *AnnounceIntermediateResultResponseBody { - if x != nil { - return x.body - } - - return nil -} - -// SetBody sets response body. -func (x *AnnounceIntermediateResultResponse) SetBody(v *AnnounceIntermediateResultResponseBody) { - x.body = v -} diff --git a/rpc/reputation.go b/rpc/reputation.go deleted file mode 100644 index 3d036b2..0000000 --- a/rpc/reputation.go +++ /dev/null @@ -1,46 +0,0 @@ -package rpc - -import ( - "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/reputation" - "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/rpc/client" - "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/rpc/common" -) - -const serviceReputation = serviceNamePrefix + "reputation.ReputationService" - -const ( - rpcReputationAnnounceLocalTrust = "AnnounceLocalTrust" - rpcReputationAnnounceIntermediateResult = "AnnounceIntermediateResult" -) - -// AnnounceLocalTrust executes ReputationService.AnnounceLocalTrust RPC. -func AnnounceLocalTrust( - cli *client.Client, - req *reputation.AnnounceLocalTrustRequest, - opts ...client.CallOption, -) (*reputation.AnnounceLocalTrustResponse, error) { - resp := new(reputation.AnnounceLocalTrustResponse) - - err := client.SendUnary(cli, common.CallMethodInfoUnary(serviceReputation, rpcReputationAnnounceLocalTrust), req, resp, opts...) - if err != nil { - return nil, err - } - - return resp, nil -} - -// AnnounceIntermediateResult executes ReputationService.AnnounceIntermediateResult RPC. -func AnnounceIntermediateResult( - cli *client.Client, - req *reputation.AnnounceIntermediateResultRequest, - opts ...client.CallOption, -) (*reputation.AnnounceIntermediateResultResponse, error) { - resp := new(reputation.AnnounceIntermediateResultResponse) - - err := client.SendUnary(cli, common.CallMethodInfoUnary(serviceReputation, rpcReputationAnnounceIntermediateResult), req, resp, opts...) - if err != nil { - return nil, err - } - - return resp, nil -} diff --git a/session/grpc/service.pb.go b/session/grpc/service.pb.go index 23d6913..5ba114d 100644 Binary files a/session/grpc/service.pb.go and b/session/grpc/service.pb.go differ diff --git a/session/grpc/service_grpc.pb.go b/session/grpc/service_grpc.pb.go index a056280..32793fe 100644 Binary files a/session/grpc/service_grpc.pb.go and b/session/grpc/service_grpc.pb.go differ diff --git a/session/grpc/types.pb.go b/session/grpc/types.pb.go index ed76725..25e0715 100644 Binary files a/session/grpc/types.pb.go and b/session/grpc/types.pb.go differ diff --git a/signature/body.go b/signature/body.go index bf3ab6c..a160ed3 100644 --- a/signature/body.go +++ b/signature/body.go @@ -7,7 +7,6 @@ import ( "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/container" "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/netmap" "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/object" - "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/reputation" "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/session" ) @@ -101,15 +100,5 @@ func serviceMessageBody(req interface{}) stableMarshaler { return v.GetBody() case *netmap.SnapshotResponse: return v.GetBody() - - /* Reputation */ - case *reputation.AnnounceLocalTrustRequest: - return v.GetBody() - case *reputation.AnnounceLocalTrustResponse: - return v.GetBody() - case *reputation.AnnounceIntermediateResultRequest: - return v.GetBody() - case *reputation.AnnounceIntermediateResultResponse: - return v.GetBody() } } diff --git a/status/grpc/types.pb.go b/status/grpc/types.pb.go index f6fd81c..a30533f 100644 Binary files a/status/grpc/types.pb.go and b/status/grpc/types.pb.go differ diff --git a/storagegroup/grpc/types.pb.go b/storagegroup/grpc/types.pb.go index 6629364..75f5b46 100644 Binary files a/storagegroup/grpc/types.pb.go and b/storagegroup/grpc/types.pb.go differ diff --git a/subnet/grpc/types.pb.go b/subnet/grpc/types.pb.go index c2d7529..032ba6c 100644 Binary files a/subnet/grpc/types.pb.go and b/subnet/grpc/types.pb.go differ diff --git a/tombstone/grpc/types.pb.go b/tombstone/grpc/types.pb.go index 3365912..d1065ba 100644 Binary files a/tombstone/grpc/types.pb.go and b/tombstone/grpc/types.pb.go differ diff --git a/util/proto/test/test.pb.go b/util/proto/test/test.pb.go index de6f380..0dfa4dc 100644 Binary files a/util/proto/test/test.pb.go and b/util/proto/test/test.pb.go differ