Documentation ¶
Index ¶
- Variables
- func RegisterReputationServiceServer(s *grpc1.Server, srv ReputationServiceServer)
- type AnnounceIntermediateResultRequest
- func (*AnnounceIntermediateResultRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AnnounceIntermediateResultRequest) GetBody() *AnnounceIntermediateResultRequest_Body
- func (x *AnnounceIntermediateResultRequest) GetMetaHeader() *grpc.RequestMetaHeader
- func (x *AnnounceIntermediateResultRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
- func (*AnnounceIntermediateResultRequest) ProtoMessage()
- func (x *AnnounceIntermediateResultRequest) ProtoReflect() protoreflect.Message
- func (x *AnnounceIntermediateResultRequest) Reset()
- func (x *AnnounceIntermediateResultRequest) SetBody(v *AnnounceIntermediateResultRequest_Body)
- func (x *AnnounceIntermediateResultRequest) SetMetaHeader(v *session.RequestMetaHeader)
- func (x *AnnounceIntermediateResultRequest) SetVerifyHeader(v *session.RequestVerificationHeader)
- func (x *AnnounceIntermediateResultRequest) String() string
- type AnnounceIntermediateResultRequest_Body
- func (*AnnounceIntermediateResultRequest_Body) Descriptor() ([]byte, []int)deprecated
- func (x *AnnounceIntermediateResultRequest_Body) GetEpoch() uint64
- func (x *AnnounceIntermediateResultRequest_Body) GetIteration() uint32
- func (x *AnnounceIntermediateResultRequest_Body) GetTrust() *PeerToPeerTrust
- func (*AnnounceIntermediateResultRequest_Body) ProtoMessage()
- func (x *AnnounceIntermediateResultRequest_Body) ProtoReflect() protoreflect.Message
- func (x *AnnounceIntermediateResultRequest_Body) Reset()
- func (x *AnnounceIntermediateResultRequest_Body) SetEpoch(v uint64)
- func (x *AnnounceIntermediateResultRequest_Body) SetIteration(v uint32)
- func (x *AnnounceIntermediateResultRequest_Body) SetTrust(v *PeerToPeerTrust)
- func (x *AnnounceIntermediateResultRequest_Body) String() string
- type AnnounceIntermediateResultResponse
- func (*AnnounceIntermediateResultResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AnnounceIntermediateResultResponse) GetBody() *AnnounceIntermediateResultResponse_Body
- func (x *AnnounceIntermediateResultResponse) GetMetaHeader() *grpc.ResponseMetaHeader
- func (x *AnnounceIntermediateResultResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
- func (*AnnounceIntermediateResultResponse) ProtoMessage()
- func (x *AnnounceIntermediateResultResponse) ProtoReflect() protoreflect.Message
- func (x *AnnounceIntermediateResultResponse) Reset()
- func (x *AnnounceIntermediateResultResponse) SetBody(v *AnnounceIntermediateResultResponse_Body)
- func (x *AnnounceIntermediateResultResponse) SetMetaHeader(v *session.ResponseMetaHeader)
- func (x *AnnounceIntermediateResultResponse) SetVerifyHeader(v *session.ResponseVerificationHeader)
- func (x *AnnounceIntermediateResultResponse) String() string
- type AnnounceIntermediateResultResponse_Body
- func (*AnnounceIntermediateResultResponse_Body) Descriptor() ([]byte, []int)deprecated
- func (*AnnounceIntermediateResultResponse_Body) ProtoMessage()
- func (x *AnnounceIntermediateResultResponse_Body) ProtoReflect() protoreflect.Message
- func (x *AnnounceIntermediateResultResponse_Body) Reset()
- func (x *AnnounceIntermediateResultResponse_Body) String() string
- type AnnounceLocalTrustRequest
- func (*AnnounceLocalTrustRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AnnounceLocalTrustRequest) GetBody() *AnnounceLocalTrustRequest_Body
- func (x *AnnounceLocalTrustRequest) GetMetaHeader() *grpc.RequestMetaHeader
- func (x *AnnounceLocalTrustRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
- func (*AnnounceLocalTrustRequest) ProtoMessage()
- func (x *AnnounceLocalTrustRequest) ProtoReflect() protoreflect.Message
- func (x *AnnounceLocalTrustRequest) Reset()
- func (x *AnnounceLocalTrustRequest) SetBody(v *AnnounceLocalTrustRequest_Body)
- func (x *AnnounceLocalTrustRequest) SetMetaHeader(v *session.RequestMetaHeader)
- func (x *AnnounceLocalTrustRequest) SetVerifyHeader(v *session.RequestVerificationHeader)
- func (x *AnnounceLocalTrustRequest) String() string
- type AnnounceLocalTrustRequest_Body
- func (*AnnounceLocalTrustRequest_Body) Descriptor() ([]byte, []int)deprecated
- func (x *AnnounceLocalTrustRequest_Body) GetEpoch() uint64
- func (x *AnnounceLocalTrustRequest_Body) GetTrusts() []*Trust
- func (*AnnounceLocalTrustRequest_Body) ProtoMessage()
- func (x *AnnounceLocalTrustRequest_Body) ProtoReflect() protoreflect.Message
- func (x *AnnounceLocalTrustRequest_Body) Reset()
- func (x *AnnounceLocalTrustRequest_Body) SetEpoch(v uint64)
- func (x *AnnounceLocalTrustRequest_Body) SetTrusts(v []*Trust)
- func (x *AnnounceLocalTrustRequest_Body) String() string
- type AnnounceLocalTrustResponse
- func (*AnnounceLocalTrustResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AnnounceLocalTrustResponse) GetBody() *AnnounceLocalTrustResponse_Body
- func (x *AnnounceLocalTrustResponse) GetMetaHeader() *grpc.ResponseMetaHeader
- func (x *AnnounceLocalTrustResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
- func (*AnnounceLocalTrustResponse) ProtoMessage()
- func (x *AnnounceLocalTrustResponse) ProtoReflect() protoreflect.Message
- func (x *AnnounceLocalTrustResponse) Reset()
- func (x *AnnounceLocalTrustResponse) SetBody(v *AnnounceLocalTrustResponse_Body)
- func (x *AnnounceLocalTrustResponse) SetMetaHeader(v *session.ResponseMetaHeader)
- func (x *AnnounceLocalTrustResponse) SetVerifyHeader(v *session.ResponseVerificationHeader)
- func (x *AnnounceLocalTrustResponse) String() string
- type AnnounceLocalTrustResponse_Body
- func (*AnnounceLocalTrustResponse_Body) Descriptor() ([]byte, []int)deprecated
- func (*AnnounceLocalTrustResponse_Body) ProtoMessage()
- func (x *AnnounceLocalTrustResponse_Body) ProtoReflect() protoreflect.Message
- func (x *AnnounceLocalTrustResponse_Body) Reset()
- func (x *AnnounceLocalTrustResponse_Body) String() string
- type GlobalTrust
- func (*GlobalTrust) Descriptor() ([]byte, []int)deprecated
- func (x *GlobalTrust) GetBody() *GlobalTrust_Body
- func (x *GlobalTrust) GetSignature() *grpc.Signature
- func (x *GlobalTrust) GetVersion() *grpc.Version
- func (*GlobalTrust) ProtoMessage()
- func (x *GlobalTrust) ProtoReflect() protoreflect.Message
- func (x *GlobalTrust) Reset()
- func (x *GlobalTrust) SetBody(v *GlobalTrust_Body)
- func (x *GlobalTrust) SetSignature(v *refs.Signature)
- func (x *GlobalTrust) SetVersion(v *refs.Version)
- func (x *GlobalTrust) String() string
- type GlobalTrust_Body
- func (*GlobalTrust_Body) Descriptor() ([]byte, []int)deprecated
- func (x *GlobalTrust_Body) GetManager() *PeerID
- func (x *GlobalTrust_Body) GetTrust() *Trust
- func (*GlobalTrust_Body) ProtoMessage()
- func (x *GlobalTrust_Body) ProtoReflect() protoreflect.Message
- func (x *GlobalTrust_Body) Reset()
- func (x *GlobalTrust_Body) SetManager(v *PeerID)
- func (x *GlobalTrust_Body) SetTrust(v *Trust)
- func (x *GlobalTrust_Body) String() string
- type PeerID
- type PeerToPeerTrust
- func (*PeerToPeerTrust) Descriptor() ([]byte, []int)deprecated
- func (x *PeerToPeerTrust) GetTrust() *Trust
- func (x *PeerToPeerTrust) GetTrustingPeer() *PeerID
- func (*PeerToPeerTrust) ProtoMessage()
- func (x *PeerToPeerTrust) ProtoReflect() protoreflect.Message
- func (x *PeerToPeerTrust) Reset()
- func (x *PeerToPeerTrust) SetTrust(v *Trust)
- func (x *PeerToPeerTrust) SetTrustingPeer(v *PeerID)
- func (x *PeerToPeerTrust) String() string
- type ReputationServiceClient
- type ReputationServiceServer
- type Trust
- func (*Trust) Descriptor() ([]byte, []int)deprecated
- func (x *Trust) GetPeer() *PeerID
- func (x *Trust) GetValue() float64
- func (*Trust) ProtoMessage()
- func (x *Trust) ProtoReflect() protoreflect.Message
- func (x *Trust) Reset()
- func (x *Trust) SetPeer(v *PeerID)
- func (x *Trust) SetValue(v float64)
- func (x *Trust) String() string
- type UnimplementedReputationServiceServer
- func (*UnimplementedReputationServiceServer) AnnounceIntermediateResult(context.Context, *AnnounceIntermediateResultRequest) (*AnnounceIntermediateResultResponse, error)
- func (*UnimplementedReputationServiceServer) AnnounceLocalTrust(context.Context, *AnnounceLocalTrustRequest) (*AnnounceLocalTrustResponse, error)
Constants ¶
This section is empty.
Variables ¶
var File_v2_reputation_grpc_service_proto protoreflect.FileDescriptor
var File_v2_reputation_grpc_types_proto protoreflect.FileDescriptor
Functions ¶
func RegisterReputationServiceServer ¶
func RegisterReputationServiceServer(s *grpc1.Server, srv ReputationServiceServer)
Types ¶
type AnnounceIntermediateResultRequest ¶
type AnnounceIntermediateResultRequest struct { // Body of the request message. Body *AnnounceIntermediateResultRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader,proto3" json:"meta_header,omitempty"` // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader,proto3" json:"verify_header,omitempty"` // contains filtered or unexported fields }
Announce intermediate global trust information.
func (*AnnounceIntermediateResultRequest) Descriptor
deprecated
func (*AnnounceIntermediateResultRequest) Descriptor() ([]byte, []int)
Deprecated: Use AnnounceIntermediateResultRequest.ProtoReflect.Descriptor instead.
func (*AnnounceIntermediateResultRequest) GetBody ¶
func (x *AnnounceIntermediateResultRequest) GetBody() *AnnounceIntermediateResultRequest_Body
func (*AnnounceIntermediateResultRequest) GetMetaHeader ¶
func (x *AnnounceIntermediateResultRequest) GetMetaHeader() *grpc.RequestMetaHeader
func (*AnnounceIntermediateResultRequest) GetVerifyHeader ¶
func (x *AnnounceIntermediateResultRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
func (*AnnounceIntermediateResultRequest) ProtoMessage ¶
func (*AnnounceIntermediateResultRequest) ProtoMessage()
func (*AnnounceIntermediateResultRequest) ProtoReflect ¶
func (x *AnnounceIntermediateResultRequest) ProtoReflect() protoreflect.Message
func (*AnnounceIntermediateResultRequest) Reset ¶
func (x *AnnounceIntermediateResultRequest) Reset()
func (*AnnounceIntermediateResultRequest) SetBody ¶
func (x *AnnounceIntermediateResultRequest) SetBody(v *AnnounceIntermediateResultRequest_Body)
SetBody sets body of the request.
func (*AnnounceIntermediateResultRequest) SetMetaHeader ¶
func (x *AnnounceIntermediateResultRequest) SetMetaHeader(v *session.RequestMetaHeader)
SetMetaHeader sets meta header of the request.
func (*AnnounceIntermediateResultRequest) SetVerifyHeader ¶
func (x *AnnounceIntermediateResultRequest) SetVerifyHeader(v *session.RequestVerificationHeader)
SetVerifyHeader sets verification header of the request.
func (*AnnounceIntermediateResultRequest) String ¶
func (x *AnnounceIntermediateResultRequest) String() string
type AnnounceIntermediateResultRequest_Body ¶
type AnnounceIntermediateResultRequest_Body struct { // Iteration execution Epoch number Epoch uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"` // Iteration sequence number Iteration uint32 `protobuf:"varint,2,opt,name=iteration,proto3" json:"iteration,omitempty"` // Current global trust value calculated at the specified iteration Trust *PeerToPeerTrust `protobuf:"bytes,3,opt,name=trust,proto3" json:"trust,omitempty"` // contains filtered or unexported fields }
Announce intermediate global trust information.
func (*AnnounceIntermediateResultRequest_Body) Descriptor
deprecated
func (*AnnounceIntermediateResultRequest_Body) Descriptor() ([]byte, []int)
Deprecated: Use AnnounceIntermediateResultRequest_Body.ProtoReflect.Descriptor instead.
func (*AnnounceIntermediateResultRequest_Body) GetEpoch ¶
func (x *AnnounceIntermediateResultRequest_Body) GetEpoch() uint64
func (*AnnounceIntermediateResultRequest_Body) GetIteration ¶
func (x *AnnounceIntermediateResultRequest_Body) GetIteration() uint32
func (*AnnounceIntermediateResultRequest_Body) GetTrust ¶
func (x *AnnounceIntermediateResultRequest_Body) GetTrust() *PeerToPeerTrust
func (*AnnounceIntermediateResultRequest_Body) ProtoMessage ¶
func (*AnnounceIntermediateResultRequest_Body) ProtoMessage()
func (*AnnounceIntermediateResultRequest_Body) ProtoReflect ¶
func (x *AnnounceIntermediateResultRequest_Body) ProtoReflect() protoreflect.Message
func (*AnnounceIntermediateResultRequest_Body) Reset ¶
func (x *AnnounceIntermediateResultRequest_Body) Reset()
func (*AnnounceIntermediateResultRequest_Body) SetEpoch ¶
func (x *AnnounceIntermediateResultRequest_Body) SetEpoch(v uint64)
SetEpoch sets epoch in which the intermediate trust was assessed.
func (*AnnounceIntermediateResultRequest_Body) SetIteration ¶
func (x *AnnounceIntermediateResultRequest_Body) SetIteration(v uint32)
SetIteration sets sequence number of the iteration.
func (*AnnounceIntermediateResultRequest_Body) SetTrust ¶
func (x *AnnounceIntermediateResultRequest_Body) SetTrust(v *PeerToPeerTrust)
SetTrust sets current global trust value.
func (*AnnounceIntermediateResultRequest_Body) String ¶
func (x *AnnounceIntermediateResultRequest_Body) String() string
type AnnounceIntermediateResultResponse ¶
type AnnounceIntermediateResultResponse struct { // Body of the response message. Body *AnnounceIntermediateResultResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader,proto3" json:"meta_header,omitempty"` // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader,proto3" json:"verify_header,omitempty"` // contains filtered or unexported fields }
Intermediate global trust information announce response.
func (*AnnounceIntermediateResultResponse) Descriptor
deprecated
func (*AnnounceIntermediateResultResponse) Descriptor() ([]byte, []int)
Deprecated: Use AnnounceIntermediateResultResponse.ProtoReflect.Descriptor instead.
func (*AnnounceIntermediateResultResponse) GetBody ¶
func (x *AnnounceIntermediateResultResponse) GetBody() *AnnounceIntermediateResultResponse_Body
func (*AnnounceIntermediateResultResponse) GetMetaHeader ¶
func (x *AnnounceIntermediateResultResponse) GetMetaHeader() *grpc.ResponseMetaHeader
func (*AnnounceIntermediateResultResponse) GetVerifyHeader ¶
func (x *AnnounceIntermediateResultResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
func (*AnnounceIntermediateResultResponse) ProtoMessage ¶
func (*AnnounceIntermediateResultResponse) ProtoMessage()
func (*AnnounceIntermediateResultResponse) ProtoReflect ¶
func (x *AnnounceIntermediateResultResponse) ProtoReflect() protoreflect.Message
func (*AnnounceIntermediateResultResponse) Reset ¶
func (x *AnnounceIntermediateResultResponse) Reset()
func (*AnnounceIntermediateResultResponse) SetBody ¶
func (x *AnnounceIntermediateResultResponse) SetBody(v *AnnounceIntermediateResultResponse_Body)
SetBody sets body of the response.
func (*AnnounceIntermediateResultResponse) SetMetaHeader ¶
func (x *AnnounceIntermediateResultResponse) SetMetaHeader(v *session.ResponseMetaHeader)
SetMetaHeader sets meta header of the response.
func (*AnnounceIntermediateResultResponse) SetVerifyHeader ¶
func (x *AnnounceIntermediateResultResponse) SetVerifyHeader(v *session.ResponseVerificationHeader)
SetVerifyHeader sets verification header of the response.
func (*AnnounceIntermediateResultResponse) String ¶
func (x *AnnounceIntermediateResultResponse) String() string
type AnnounceIntermediateResultResponse_Body ¶
type AnnounceIntermediateResultResponse_Body struct {
// contains filtered or unexported fields
}
Response to the node's intermediate global trust information announce has an empty body because the trust exchange operation is asynchronous. If Trust information will not pass sanity checks it is silently ignored.
func (*AnnounceIntermediateResultResponse_Body) Descriptor
deprecated
func (*AnnounceIntermediateResultResponse_Body) Descriptor() ([]byte, []int)
Deprecated: Use AnnounceIntermediateResultResponse_Body.ProtoReflect.Descriptor instead.
func (*AnnounceIntermediateResultResponse_Body) ProtoMessage ¶
func (*AnnounceIntermediateResultResponse_Body) ProtoMessage()
func (*AnnounceIntermediateResultResponse_Body) ProtoReflect ¶
func (x *AnnounceIntermediateResultResponse_Body) ProtoReflect() protoreflect.Message
func (*AnnounceIntermediateResultResponse_Body) Reset ¶
func (x *AnnounceIntermediateResultResponse_Body) Reset()
func (*AnnounceIntermediateResultResponse_Body) String ¶
func (x *AnnounceIntermediateResultResponse_Body) String() string
type AnnounceLocalTrustRequest ¶
type AnnounceLocalTrustRequest struct { // Body of the request message. Body *AnnounceLocalTrustRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader,proto3" json:"meta_header,omitempty"` // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader,proto3" json:"verify_header,omitempty"` // contains filtered or unexported fields }
Announce node's local trust information.
func (*AnnounceLocalTrustRequest) Descriptor
deprecated
func (*AnnounceLocalTrustRequest) Descriptor() ([]byte, []int)
Deprecated: Use AnnounceLocalTrustRequest.ProtoReflect.Descriptor instead.
func (*AnnounceLocalTrustRequest) GetBody ¶
func (x *AnnounceLocalTrustRequest) GetBody() *AnnounceLocalTrustRequest_Body
func (*AnnounceLocalTrustRequest) GetMetaHeader ¶
func (x *AnnounceLocalTrustRequest) GetMetaHeader() *grpc.RequestMetaHeader
func (*AnnounceLocalTrustRequest) GetVerifyHeader ¶
func (x *AnnounceLocalTrustRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
func (*AnnounceLocalTrustRequest) ProtoMessage ¶
func (*AnnounceLocalTrustRequest) ProtoMessage()
func (*AnnounceLocalTrustRequest) ProtoReflect ¶
func (x *AnnounceLocalTrustRequest) ProtoReflect() protoreflect.Message
func (*AnnounceLocalTrustRequest) Reset ¶
func (x *AnnounceLocalTrustRequest) Reset()
func (*AnnounceLocalTrustRequest) SetBody ¶
func (x *AnnounceLocalTrustRequest) SetBody(v *AnnounceLocalTrustRequest_Body)
SetBody sets body of the request.
func (*AnnounceLocalTrustRequest) SetMetaHeader ¶
func (x *AnnounceLocalTrustRequest) SetMetaHeader(v *session.RequestMetaHeader)
SetMetaHeader sets meta header of the request.
func (*AnnounceLocalTrustRequest) SetVerifyHeader ¶
func (x *AnnounceLocalTrustRequest) SetVerifyHeader(v *session.RequestVerificationHeader)
SetVerifyHeader sets verification header of the request.
func (*AnnounceLocalTrustRequest) String ¶
func (x *AnnounceLocalTrustRequest) String() string
type AnnounceLocalTrustRequest_Body ¶
type AnnounceLocalTrustRequest_Body struct { // Trust assessment Epoch number Epoch uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"` // List of normalized local trust values to other NeoFS nodes. The value // is calculated according to EigenTrust++ algorithm and must be a // floating point number in the [0;1] range. Trusts []*Trust `protobuf:"bytes,2,rep,name=trusts,proto3" json:"trusts,omitempty"` // contains filtered or unexported fields }
Announce node's local trust information.
func (*AnnounceLocalTrustRequest_Body) Descriptor
deprecated
func (*AnnounceLocalTrustRequest_Body) Descriptor() ([]byte, []int)
Deprecated: Use AnnounceLocalTrustRequest_Body.ProtoReflect.Descriptor instead.
func (*AnnounceLocalTrustRequest_Body) GetEpoch ¶
func (x *AnnounceLocalTrustRequest_Body) GetEpoch() uint64
func (*AnnounceLocalTrustRequest_Body) GetTrusts ¶
func (x *AnnounceLocalTrustRequest_Body) GetTrusts() []*Trust
func (*AnnounceLocalTrustRequest_Body) ProtoMessage ¶
func (*AnnounceLocalTrustRequest_Body) ProtoMessage()
func (*AnnounceLocalTrustRequest_Body) ProtoReflect ¶
func (x *AnnounceLocalTrustRequest_Body) ProtoReflect() protoreflect.Message
func (*AnnounceLocalTrustRequest_Body) Reset ¶
func (x *AnnounceLocalTrustRequest_Body) Reset()
func (*AnnounceLocalTrustRequest_Body) SetEpoch ¶
func (x *AnnounceLocalTrustRequest_Body) SetEpoch(v uint64)
SetEpoch sets epoch in which the trust was assessed.
func (*AnnounceLocalTrustRequest_Body) SetTrusts ¶
func (x *AnnounceLocalTrustRequest_Body) SetTrusts(v []*Trust)
SetTrusts sets list of normalized trust values.
func (*AnnounceLocalTrustRequest_Body) String ¶
func (x *AnnounceLocalTrustRequest_Body) String() string
type AnnounceLocalTrustResponse ¶
type AnnounceLocalTrustResponse struct { // Body of the response message. Body *AnnounceLocalTrustResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader,proto3" json:"meta_header,omitempty"` // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader,proto3" json:"verify_header,omitempty"` // contains filtered or unexported fields }
Node's local trust information announce response.
func (*AnnounceLocalTrustResponse) Descriptor
deprecated
func (*AnnounceLocalTrustResponse) Descriptor() ([]byte, []int)
Deprecated: Use AnnounceLocalTrustResponse.ProtoReflect.Descriptor instead.
func (*AnnounceLocalTrustResponse) GetBody ¶
func (x *AnnounceLocalTrustResponse) GetBody() *AnnounceLocalTrustResponse_Body
func (*AnnounceLocalTrustResponse) GetMetaHeader ¶
func (x *AnnounceLocalTrustResponse) GetMetaHeader() *grpc.ResponseMetaHeader
func (*AnnounceLocalTrustResponse) GetVerifyHeader ¶
func (x *AnnounceLocalTrustResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
func (*AnnounceLocalTrustResponse) ProtoMessage ¶
func (*AnnounceLocalTrustResponse) ProtoMessage()
func (*AnnounceLocalTrustResponse) ProtoReflect ¶
func (x *AnnounceLocalTrustResponse) ProtoReflect() protoreflect.Message
func (*AnnounceLocalTrustResponse) Reset ¶
func (x *AnnounceLocalTrustResponse) Reset()
func (*AnnounceLocalTrustResponse) SetBody ¶
func (x *AnnounceLocalTrustResponse) SetBody(v *AnnounceLocalTrustResponse_Body)
SetBody sets body of the response.
func (*AnnounceLocalTrustResponse) SetMetaHeader ¶
func (x *AnnounceLocalTrustResponse) SetMetaHeader(v *session.ResponseMetaHeader)
SetMetaHeader sets meta header of the response.
func (*AnnounceLocalTrustResponse) SetVerifyHeader ¶
func (x *AnnounceLocalTrustResponse) SetVerifyHeader(v *session.ResponseVerificationHeader)
SetVerifyHeader sets verification header of the response.
func (*AnnounceLocalTrustResponse) String ¶
func (x *AnnounceLocalTrustResponse) String() string
type AnnounceLocalTrustResponse_Body ¶
type AnnounceLocalTrustResponse_Body struct {
// contains filtered or unexported fields
}
Response to the node's local trust information announce has an empty body because the trust exchange operation is asynchronous. If Trust information will not pass sanity checks it is silently ignored.
func (*AnnounceLocalTrustResponse_Body) Descriptor
deprecated
func (*AnnounceLocalTrustResponse_Body) Descriptor() ([]byte, []int)
Deprecated: Use AnnounceLocalTrustResponse_Body.ProtoReflect.Descriptor instead.
func (*AnnounceLocalTrustResponse_Body) ProtoMessage ¶
func (*AnnounceLocalTrustResponse_Body) ProtoMessage()
func (*AnnounceLocalTrustResponse_Body) ProtoReflect ¶
func (x *AnnounceLocalTrustResponse_Body) ProtoReflect() protoreflect.Message
func (*AnnounceLocalTrustResponse_Body) Reset ¶
func (x *AnnounceLocalTrustResponse_Body) Reset()
func (*AnnounceLocalTrustResponse_Body) String ¶
func (x *AnnounceLocalTrustResponse_Body) String() string
type GlobalTrust ¶
type GlobalTrust struct { // Message format version. Effectively the version of API library used to create // the message. Version *grpc.Version `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` // Message body Body *GlobalTrust_Body `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"` // Signature of the binary `body` field by the manager. Signature *grpc.Signature `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
Global trust level to NeoFS node.
func (*GlobalTrust) Descriptor
deprecated
func (*GlobalTrust) Descriptor() ([]byte, []int)
Deprecated: Use GlobalTrust.ProtoReflect.Descriptor instead.
func (*GlobalTrust) GetBody ¶
func (x *GlobalTrust) GetBody() *GlobalTrust_Body
func (*GlobalTrust) GetSignature ¶
func (x *GlobalTrust) GetSignature() *grpc.Signature
func (*GlobalTrust) GetVersion ¶
func (x *GlobalTrust) GetVersion() *grpc.Version
func (*GlobalTrust) ProtoMessage ¶
func (*GlobalTrust) ProtoMessage()
func (*GlobalTrust) ProtoReflect ¶
func (x *GlobalTrust) ProtoReflect() protoreflect.Message
func (*GlobalTrust) Reset ¶
func (x *GlobalTrust) Reset()
func (*GlobalTrust) SetBody ¶
func (x *GlobalTrust) SetBody(v *GlobalTrust_Body)
SetBody sets message body.
func (*GlobalTrust) SetSignature ¶
func (x *GlobalTrust) SetSignature(v *refs.Signature)
SetSignature sets body signature.
func (*GlobalTrust) SetVersion ¶
func (x *GlobalTrust) SetVersion(v *refs.Version)
SetVersion sets message format version.
func (*GlobalTrust) String ¶
func (x *GlobalTrust) String() string
type GlobalTrust_Body ¶
type GlobalTrust_Body struct { // Node manager ID Manager *PeerID `protobuf:"bytes,1,opt,name=manager,proto3" json:"manager,omitempty"` // Global trust level Trust *Trust `protobuf:"bytes,2,opt,name=trust,proto3" json:"trust,omitempty"` // contains filtered or unexported fields }
Message body structure.
func (*GlobalTrust_Body) Descriptor
deprecated
func (*GlobalTrust_Body) Descriptor() ([]byte, []int)
Deprecated: Use GlobalTrust_Body.ProtoReflect.Descriptor instead.
func (*GlobalTrust_Body) GetManager ¶
func (x *GlobalTrust_Body) GetManager() *PeerID
func (*GlobalTrust_Body) GetTrust ¶
func (x *GlobalTrust_Body) GetTrust() *Trust
func (*GlobalTrust_Body) ProtoMessage ¶
func (*GlobalTrust_Body) ProtoMessage()
func (*GlobalTrust_Body) ProtoReflect ¶
func (x *GlobalTrust_Body) ProtoReflect() protoreflect.Message
func (*GlobalTrust_Body) Reset ¶
func (x *GlobalTrust_Body) Reset()
func (*GlobalTrust_Body) SetManager ¶
func (x *GlobalTrust_Body) SetManager(v *PeerID)
SetManager sets manager ID.
func (*GlobalTrust_Body) SetTrust ¶
func (x *GlobalTrust_Body) SetTrust(v *Trust)
SetTrust sets global trust value.
func (*GlobalTrust_Body) String ¶
func (x *GlobalTrust_Body) String() string
type PeerID ¶
type PeerID struct { // Peer node's public key PublicKey []byte `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"` // contains filtered or unexported fields }
NeoFS unique peer identifier is 33 byte long compressed public key of the node, the same as the one stored in the network map.
String presentation is [base58](https://tools.ietf.org/html/draft-msporny-base58-02) encoded string.
JSON value will be the data encoded as a string using standard base64 encoding with paddings. Either [standard](https://tools.ietf.org/html/rfc4648#section-4) or [URL-safe](https://tools.ietf.org/html/rfc4648#section-5) base64 encoding with/without paddings are accepted.
func (*PeerID) Descriptor
deprecated
func (*PeerID) GetPublicKey ¶
func (*PeerID) ProtoMessage ¶
func (*PeerID) ProtoMessage()
func (*PeerID) ProtoReflect ¶
func (x *PeerID) ProtoReflect() protoreflect.Message
func (*PeerID) SetPublicKey ¶
SetPublicKey sets binary public key of ID.
type PeerToPeerTrust ¶
type PeerToPeerTrust struct { // Identifier of the trusting peer TrustingPeer *PeerID `protobuf:"bytes,1,opt,name=trusting_peer,json=trustingPeer,proto3" json:"trusting_peer,omitempty"` // Trust level Trust *Trust `protobuf:"bytes,2,opt,name=trust,proto3" json:"trust,omitempty"` // contains filtered or unexported fields }
Trust level of a peer to a peer.
func (*PeerToPeerTrust) Descriptor
deprecated
func (*PeerToPeerTrust) Descriptor() ([]byte, []int)
Deprecated: Use PeerToPeerTrust.ProtoReflect.Descriptor instead.
func (*PeerToPeerTrust) GetTrust ¶
func (x *PeerToPeerTrust) GetTrust() *Trust
func (*PeerToPeerTrust) GetTrustingPeer ¶
func (x *PeerToPeerTrust) GetTrustingPeer() *PeerID
func (*PeerToPeerTrust) ProtoMessage ¶
func (*PeerToPeerTrust) ProtoMessage()
func (*PeerToPeerTrust) ProtoReflect ¶
func (x *PeerToPeerTrust) ProtoReflect() protoreflect.Message
func (*PeerToPeerTrust) Reset ¶
func (x *PeerToPeerTrust) Reset()
func (*PeerToPeerTrust) SetTrust ¶
func (x *PeerToPeerTrust) SetTrust(v *Trust)
SetTrust sets trust value of trusting peer to the trusted one.
func (*PeerToPeerTrust) SetTrustingPeer ¶
func (x *PeerToPeerTrust) SetTrustingPeer(v *PeerID)
SetTrustingPeer sets trusting peer ID.
func (*PeerToPeerTrust) String ¶
func (x *PeerToPeerTrust) String() string
type ReputationServiceClient ¶
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) }
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.
func NewReputationServiceClient ¶
func NewReputationServiceClient(cc grpc1.ClientConnInterface) ReputationServiceClient
type ReputationServiceServer ¶
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) }
ReputationServiceServer is the server API for ReputationService service.
type Trust ¶
type Trust struct { // Identifier of the trusted peer Peer *PeerID `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer,omitempty"` // Trust level in [0:1] range Value float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
Trust level to a NeoFS network peer.
func (*Trust) Descriptor
deprecated
func (*Trust) ProtoMessage ¶
func (*Trust) ProtoMessage()
func (*Trust) ProtoReflect ¶
func (x *Trust) ProtoReflect() protoreflect.Message
type UnimplementedReputationServiceServer ¶
type UnimplementedReputationServiceServer struct { }
UnimplementedReputationServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedReputationServiceServer) AnnounceIntermediateResult ¶
func (*UnimplementedReputationServiceServer) AnnounceIntermediateResult(context.Context, *AnnounceIntermediateResultRequest) (*AnnounceIntermediateResultResponse, error)
func (*UnimplementedReputationServiceServer) AnnounceLocalTrust ¶
func (*UnimplementedReputationServiceServer) AnnounceLocalTrust(context.Context, *AnnounceLocalTrustRequest) (*AnnounceLocalTrustResponse, error)