reputation

package
v2.13.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 1, 2022 License: Apache-2.0 Imports: 10 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_reputation_grpc_service_proto protoreflect.FileDescriptor
View Source 
var File_reputation_grpc_types_proto protoreflect.FileDescriptor
View Source 
var ReputationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "neo.fs.v2.reputation.ReputationService",
	HandlerType: (*ReputationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AnnounceLocalTrust",
			Handler:    _ReputationService_AnnounceLocalTrust_Handler,
		},
		{
			MethodName: "AnnounceIntermediateResult",
			Handler:    _ReputationService_AnnounceIntermediateResult_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "reputation/grpc/service.proto",
}

ReputationService_ServiceDesc is the grpc.ServiceDesc for ReputationService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterReputationServiceServer 

func RegisterReputationServiceServer(s grpc.ServiceRegistrar, 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 announcement 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 announcement has an empty body because the trust exchange operation is asynchronous. If Trust information does 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 [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 announcement 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 announcement has an empty body because the trust exchange operation is asynchronous. If Trust information does 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 a 33 byte long compressed public key of the node, the same as the one stored in the network map.

String presentation is a [base58](https://tools.ietf.org/html/draft-msporny-base58-02) encoded string.

JSON value will be 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) Descriptor() ([]byte, []int)

Deprecated: Use PeerID.ProtoReflect.Descriptor instead.

func (*PeerID) GetPublicKey 

func (x *PeerID) GetPublicKey() []byte

func (*PeerID) ProtoMessage 

func (*PeerID) ProtoMessage()

func (*PeerID) ProtoReflect 

func (x *PeerID) ProtoReflect() protoreflect.Message

func (*PeerID) Reset 

func (x *PeerID) Reset()

func (*PeerID) SetPublicKey 

func (x *PeerID) SetPublicKey(v []byte)

SetPublicKey sets binary public key of ID.

func (*PeerID) String 

func (x *PeerID) String() string

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.
	//
	// Statuses:
	// - **OK** (0, SECTION_SUCCESS):
	// local trust has been successfully announced;
	// - Common failures (SECTION_FAILURE_COMMON).
	AnnounceLocalTrust(ctx context.Context, in *AnnounceLocalTrustRequest, opts ...grpc.CallOption) (*AnnounceLocalTrustResponse, error)
	// Announce the intermediate result of the iterative algorithm for
	// calculating the global reputation of the node in NeoFS network.
	//
	// Statuses:
	// - **OK** (0, SECTION_SUCCESS):
	// intermediate trust estimation has been successfully announced;
	// - Common failures (SECTION_FAILURE_COMMON).
	AnnounceIntermediateResult(ctx context.Context, in *AnnounceIntermediateResultRequest, opts ...grpc.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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewReputationServiceClient 

func NewReputationServiceClient(cc grpc.ClientConnInterface) ReputationServiceClient

type ReputationServiceServer 

type ReputationServiceServer interface {
	// Announce local client trust information to any node in NeoFS network.
	//
	// Statuses:
	// - **OK** (0, SECTION_SUCCESS):
	// local trust has been successfully announced;
	// - Common failures (SECTION_FAILURE_COMMON).
	AnnounceLocalTrust(context.Context, *AnnounceLocalTrustRequest) (*AnnounceLocalTrustResponse, error)
	// Announce the intermediate result of the iterative algorithm for
	// calculating the global reputation of the node in NeoFS network.
	//
	// Statuses:
	// - **OK** (0, SECTION_SUCCESS):
	// intermediate trust estimation has been successfully announced;
	// - Common failures (SECTION_FAILURE_COMMON).
	AnnounceIntermediateResult(context.Context, *AnnounceIntermediateResultRequest) (*AnnounceIntermediateResultResponse, error)
}

ReputationServiceServer is the server API for ReputationService service. All implementations should embed UnimplementedReputationServiceServer for forward compatibility

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) Descriptor() ([]byte, []int)

Deprecated: Use Trust.ProtoReflect.Descriptor instead.

func (*Trust) GetPeer 

func (x *Trust) GetPeer() *PeerID

func (*Trust) GetValue 

func (x *Trust) GetValue() float64

func (*Trust) ProtoMessage 

func (*Trust) ProtoMessage()

func (*Trust) ProtoReflect 

func (x *Trust) ProtoReflect() protoreflect.Message

func (*Trust) Reset 

func (x *Trust) Reset()

func (*Trust) SetPeer 

func (x *Trust) SetPeer(v *PeerID)

SetPeer sets trusted peer's ID.

func (*Trust) SetValue 

func (x *Trust) SetValue(v float64)

SetValue sets trust value.

func (*Trust) String 

func (x *Trust) String() string

type UnimplementedReputationServiceServer 

type UnimplementedReputationServiceServer struct {
}

UnimplementedReputationServiceServer should 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)

type UnsafeReputationServiceServer 

type UnsafeReputationServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeReputationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReputationServiceServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.