Versions in this module Expand all Collapse all v1 v1.0.0 Sep 20, 2023 Changes in this version + const Sentry_AddPeer_FullMethodName + const Sentry_HandShake_FullMethodName + const Sentry_Messages_FullMethodName + const Sentry_NodeInfo_FullMethodName + const Sentry_PeerById_FullMethodName + const Sentry_PeerCount_FullMethodName + const Sentry_PeerEvents_FullMethodName + const Sentry_PeerMinBlock_FullMethodName + const Sentry_Peers_FullMethodName + const Sentry_PenalizePeer_FullMethodName + const Sentry_SendMessageById_FullMethodName + const Sentry_SendMessageByMinBlock_FullMethodName + const Sentry_SendMessageToAll_FullMethodName + const Sentry_SendMessageToRandomPeers_FullMethodName + const Sentry_SetStatus_FullMethodName + var File_p2psentry_sentry_proto protoreflect.FileDescriptor + var MessageId_name = map[int32]string + var MessageId_value = map[string]int32 + var PeerEvent_PeerEventId_name = map[int32]string + var PeerEvent_PeerEventId_value = map[string]int32 + var PenaltyKind_name = map[int32]string + var PenaltyKind_value = map[string]int32 + var Protocol_name = map[int32]string + var Protocol_value = map[string]int32 + var Sentry_ServiceDesc = grpc.ServiceDesc + func RegisterSentryServer(s grpc.ServiceRegistrar, srv SentryServer) + type AddPeerReply struct + Success bool + func (*AddPeerReply) Descriptor() ([]byte, []int) + func (*AddPeerReply) ProtoMessage() + func (x *AddPeerReply) GetSuccess() bool + func (x *AddPeerReply) ProtoReflect() protoreflect.Message + func (x *AddPeerReply) Reset() + func (x *AddPeerReply) String() string + type AddPeerRequest struct + Url string + func (*AddPeerRequest) Descriptor() ([]byte, []int) + func (*AddPeerRequest) ProtoMessage() + func (x *AddPeerRequest) GetUrl() string + func (x *AddPeerRequest) ProtoReflect() protoreflect.Message + func (x *AddPeerRequest) Reset() + func (x *AddPeerRequest) String() string + type Forks struct + Genesis *types.H256 + HeightForks []uint64 + TimeForks []uint64 + func (*Forks) Descriptor() ([]byte, []int) + func (*Forks) ProtoMessage() + func (x *Forks) GetGenesis() *types.H256 + func (x *Forks) GetHeightForks() []uint64 + func (x *Forks) GetTimeForks() []uint64 + func (x *Forks) ProtoReflect() protoreflect.Message + func (x *Forks) Reset() + func (x *Forks) String() string + type HandShakeReply struct + Protocol Protocol + func (*HandShakeReply) Descriptor() ([]byte, []int) + func (*HandShakeReply) ProtoMessage() + func (x *HandShakeReply) GetProtocol() Protocol + func (x *HandShakeReply) ProtoReflect() protoreflect.Message + func (x *HandShakeReply) Reset() + func (x *HandShakeReply) String() string + type InboundMessage struct + Data []byte + Id MessageId + PeerId *types.H512 + func (*InboundMessage) Descriptor() ([]byte, []int) + func (*InboundMessage) ProtoMessage() + func (x *InboundMessage) GetData() []byte + func (x *InboundMessage) GetId() MessageId + func (x *InboundMessage) GetPeerId() *types.H512 + func (x *InboundMessage) ProtoReflect() protoreflect.Message + func (x *InboundMessage) Reset() + func (x *InboundMessage) String() string + type MessageId int32 + const MessageId_BLOCK_BODIES_65 + const MessageId_BLOCK_BODIES_66 + const MessageId_BLOCK_HASHES_65 + const MessageId_BLOCK_HEADERS_65 + const MessageId_BLOCK_HEADERS_66 + const MessageId_GET_BLOCK_BODIES_65 + const MessageId_GET_BLOCK_BODIES_66 + const MessageId_GET_BLOCK_HEADERS_65 + const MessageId_GET_BLOCK_HEADERS_66 + const MessageId_GET_NODE_DATA_65 + const MessageId_GET_NODE_DATA_66 + const MessageId_GET_POOLED_TRANSACTIONS_65 + const MessageId_GET_POOLED_TRANSACTIONS_66 + const MessageId_GET_RECEIPTS_65 + const MessageId_GET_RECEIPTS_66 + const MessageId_NEW_BLOCK_65 + const MessageId_NEW_BLOCK_66 + const MessageId_NEW_BLOCK_HASHES_65 + const MessageId_NEW_BLOCK_HASHES_66 + const MessageId_NEW_POOLED_TRANSACTION_HASHES_65 + const MessageId_NEW_POOLED_TRANSACTION_HASHES_66 + const MessageId_NEW_POOLED_TRANSACTION_HASHES_68 + const MessageId_NODE_DATA_65 + const MessageId_NODE_DATA_66 + const MessageId_POOLED_TRANSACTIONS_65 + const MessageId_POOLED_TRANSACTIONS_66 + const MessageId_RECEIPTS_65 + const MessageId_RECEIPTS_66 + const MessageId_STATUS_65 + const MessageId_STATUS_66 + const MessageId_TRANSACTIONS_65 + const MessageId_TRANSACTIONS_66 + func (MessageId) Descriptor() protoreflect.EnumDescriptor + func (MessageId) EnumDescriptor() ([]byte, []int) + func (MessageId) Type() protoreflect.EnumType + func (x MessageId) Enum() *MessageId + func (x MessageId) Number() protoreflect.EnumNumber + func (x MessageId) String() string + type MessagesRequest struct + Ids []MessageId + func (*MessagesRequest) Descriptor() ([]byte, []int) + func (*MessagesRequest) ProtoMessage() + func (x *MessagesRequest) GetIds() []MessageId + func (x *MessagesRequest) ProtoReflect() protoreflect.Message + func (x *MessagesRequest) Reset() + func (x *MessagesRequest) String() string + type OutboundMessageData struct + Data []byte + Id MessageId + func (*OutboundMessageData) Descriptor() ([]byte, []int) + func (*OutboundMessageData) ProtoMessage() + func (x *OutboundMessageData) GetData() []byte + func (x *OutboundMessageData) GetId() MessageId + func (x *OutboundMessageData) ProtoReflect() protoreflect.Message + func (x *OutboundMessageData) Reset() + func (x *OutboundMessageData) String() string + type PeerByIdReply struct + Peer *types.PeerInfo + func (*PeerByIdReply) Descriptor() ([]byte, []int) + func (*PeerByIdReply) ProtoMessage() + func (x *PeerByIdReply) GetPeer() *types.PeerInfo + func (x *PeerByIdReply) ProtoReflect() protoreflect.Message + func (x *PeerByIdReply) Reset() + func (x *PeerByIdReply) String() string + type PeerByIdRequest struct + PeerId *types.H512 + func (*PeerByIdRequest) Descriptor() ([]byte, []int) + func (*PeerByIdRequest) ProtoMessage() + func (x *PeerByIdRequest) GetPeerId() *types.H512 + func (x *PeerByIdRequest) ProtoReflect() protoreflect.Message + func (x *PeerByIdRequest) Reset() + func (x *PeerByIdRequest) String() string + type PeerCountPerProtocol struct + Count uint64 + Protocol Protocol + func (*PeerCountPerProtocol) Descriptor() ([]byte, []int) + func (*PeerCountPerProtocol) ProtoMessage() + func (x *PeerCountPerProtocol) GetCount() uint64 + func (x *PeerCountPerProtocol) GetProtocol() Protocol + func (x *PeerCountPerProtocol) ProtoReflect() protoreflect.Message + func (x *PeerCountPerProtocol) Reset() + func (x *PeerCountPerProtocol) String() string + type PeerCountReply struct + Count uint64 + CountsPerProtocol []*PeerCountPerProtocol + func (*PeerCountReply) Descriptor() ([]byte, []int) + func (*PeerCountReply) ProtoMessage() + func (x *PeerCountReply) GetCount() uint64 + func (x *PeerCountReply) GetCountsPerProtocol() []*PeerCountPerProtocol + func (x *PeerCountReply) ProtoReflect() protoreflect.Message + func (x *PeerCountReply) Reset() + func (x *PeerCountReply) String() string + type PeerCountRequest struct + func (*PeerCountRequest) Descriptor() ([]byte, []int) + func (*PeerCountRequest) ProtoMessage() + func (x *PeerCountRequest) ProtoReflect() protoreflect.Message + func (x *PeerCountRequest) Reset() + func (x *PeerCountRequest) String() string + type PeerEvent struct + EventId PeerEvent_PeerEventId + PeerId *types.H512 + func (*PeerEvent) Descriptor() ([]byte, []int) + func (*PeerEvent) ProtoMessage() + func (x *PeerEvent) GetEventId() PeerEvent_PeerEventId + func (x *PeerEvent) GetPeerId() *types.H512 + func (x *PeerEvent) ProtoReflect() protoreflect.Message + func (x *PeerEvent) Reset() + func (x *PeerEvent) String() string + type PeerEvent_PeerEventId int32 + const PeerEvent_Connect + const PeerEvent_Disconnect + func (PeerEvent_PeerEventId) Descriptor() protoreflect.EnumDescriptor + func (PeerEvent_PeerEventId) EnumDescriptor() ([]byte, []int) + func (PeerEvent_PeerEventId) Type() protoreflect.EnumType + func (x PeerEvent_PeerEventId) Enum() *PeerEvent_PeerEventId + func (x PeerEvent_PeerEventId) Number() protoreflect.EnumNumber + func (x PeerEvent_PeerEventId) String() string + type PeerEventsRequest struct + func (*PeerEventsRequest) Descriptor() ([]byte, []int) + func (*PeerEventsRequest) ProtoMessage() + func (x *PeerEventsRequest) ProtoReflect() protoreflect.Message + func (x *PeerEventsRequest) Reset() + func (x *PeerEventsRequest) String() string + type PeerMinBlockRequest struct + MinBlock uint64 + PeerId *types.H512 + func (*PeerMinBlockRequest) Descriptor() ([]byte, []int) + func (*PeerMinBlockRequest) ProtoMessage() + func (x *PeerMinBlockRequest) GetMinBlock() uint64 + func (x *PeerMinBlockRequest) GetPeerId() *types.H512 + func (x *PeerMinBlockRequest) ProtoReflect() protoreflect.Message + func (x *PeerMinBlockRequest) Reset() + func (x *PeerMinBlockRequest) String() string + type PeersReply struct + Peers []*types.PeerInfo + func (*PeersReply) Descriptor() ([]byte, []int) + func (*PeersReply) ProtoMessage() + func (x *PeersReply) GetPeers() []*types.PeerInfo + func (x *PeersReply) ProtoReflect() protoreflect.Message + func (x *PeersReply) Reset() + func (x *PeersReply) String() string + type PenalizePeerRequest struct + PeerId *types.H512 + Penalty PenaltyKind + func (*PenalizePeerRequest) Descriptor() ([]byte, []int) + func (*PenalizePeerRequest) ProtoMessage() + func (x *PenalizePeerRequest) GetPeerId() *types.H512 + func (x *PenalizePeerRequest) GetPenalty() PenaltyKind + func (x *PenalizePeerRequest) ProtoReflect() protoreflect.Message + func (x *PenalizePeerRequest) Reset() + func (x *PenalizePeerRequest) String() string + type PenaltyKind int32 + const PenaltyKind_Kick + func (PenaltyKind) Descriptor() protoreflect.EnumDescriptor + func (PenaltyKind) EnumDescriptor() ([]byte, []int) + func (PenaltyKind) Type() protoreflect.EnumType + func (x PenaltyKind) Enum() *PenaltyKind + func (x PenaltyKind) Number() protoreflect.EnumNumber + func (x PenaltyKind) String() string + type Protocol int32 + const Protocol_ETH65 + const Protocol_ETH66 + const Protocol_ETH67 + const Protocol_ETH68 + func (Protocol) Descriptor() protoreflect.EnumDescriptor + func (Protocol) EnumDescriptor() ([]byte, []int) + func (Protocol) Type() protoreflect.EnumType + func (x Protocol) Enum() *Protocol + func (x Protocol) Number() protoreflect.EnumNumber + func (x Protocol) String() string + type SendMessageByIdRequest struct + Data *OutboundMessageData + PeerId *types.H512 + func (*SendMessageByIdRequest) Descriptor() ([]byte, []int) + func (*SendMessageByIdRequest) ProtoMessage() + func (x *SendMessageByIdRequest) GetData() *OutboundMessageData + func (x *SendMessageByIdRequest) GetPeerId() *types.H512 + func (x *SendMessageByIdRequest) ProtoReflect() protoreflect.Message + func (x *SendMessageByIdRequest) Reset() + func (x *SendMessageByIdRequest) String() string + type SendMessageByMinBlockRequest struct + Data *OutboundMessageData + MaxPeers uint64 + MinBlock uint64 + func (*SendMessageByMinBlockRequest) Descriptor() ([]byte, []int) + func (*SendMessageByMinBlockRequest) ProtoMessage() + func (x *SendMessageByMinBlockRequest) GetData() *OutboundMessageData + func (x *SendMessageByMinBlockRequest) GetMaxPeers() uint64 + func (x *SendMessageByMinBlockRequest) GetMinBlock() uint64 + func (x *SendMessageByMinBlockRequest) ProtoReflect() protoreflect.Message + func (x *SendMessageByMinBlockRequest) Reset() + func (x *SendMessageByMinBlockRequest) String() string + type SendMessageToRandomPeersRequest struct + Data *OutboundMessageData + MaxPeers uint64 + func (*SendMessageToRandomPeersRequest) Descriptor() ([]byte, []int) + func (*SendMessageToRandomPeersRequest) ProtoMessage() + func (x *SendMessageToRandomPeersRequest) GetData() *OutboundMessageData + func (x *SendMessageToRandomPeersRequest) GetMaxPeers() uint64 + func (x *SendMessageToRandomPeersRequest) ProtoReflect() protoreflect.Message + func (x *SendMessageToRandomPeersRequest) Reset() + func (x *SendMessageToRandomPeersRequest) String() string + type SentPeers struct + Peers []*types.H512 + func (*SentPeers) Descriptor() ([]byte, []int) + func (*SentPeers) ProtoMessage() + func (x *SentPeers) GetPeers() []*types.H512 + func (x *SentPeers) ProtoReflect() protoreflect.Message + func (x *SentPeers) Reset() + func (x *SentPeers) String() string + type SentryClient interface + AddPeer func(ctx context.Context, in *AddPeerRequest, opts ...grpc.CallOption) (*AddPeerReply, error) + HandShake func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HandShakeReply, error) + Messages func(ctx context.Context, in *MessagesRequest, opts ...grpc.CallOption) (Sentry_MessagesClient, error) + NodeInfo func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.NodeInfoReply, error) + PeerById func(ctx context.Context, in *PeerByIdRequest, opts ...grpc.CallOption) (*PeerByIdReply, error) + PeerCount func(ctx context.Context, in *PeerCountRequest, opts ...grpc.CallOption) (*PeerCountReply, error) + PeerEvents func(ctx context.Context, in *PeerEventsRequest, opts ...grpc.CallOption) (Sentry_PeerEventsClient, error) + PeerMinBlock func(ctx context.Context, in *PeerMinBlockRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + Peers func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PeersReply, error) + PenalizePeer func(ctx context.Context, in *PenalizePeerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + SendMessageById func(ctx context.Context, in *SendMessageByIdRequest, opts ...grpc.CallOption) (*SentPeers, error) + SendMessageByMinBlock func(ctx context.Context, in *SendMessageByMinBlockRequest, opts ...grpc.CallOption) (*SentPeers, error) + SendMessageToAll func(ctx context.Context, in *OutboundMessageData, opts ...grpc.CallOption) (*SentPeers, error) + SendMessageToRandomPeers func(ctx context.Context, in *SendMessageToRandomPeersRequest, ...) (*SentPeers, error) + SetStatus func(ctx context.Context, in *StatusData, opts ...grpc.CallOption) (*SetStatusReply, error) + func NewSentryClient(cc grpc.ClientConnInterface) SentryClient + type SentryClientMock struct + AddPeerFunc func(ctx context.Context, in *AddPeerRequest, opts ...grpc.CallOption) (*AddPeerReply, error) + HandShakeFunc func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HandShakeReply, error) + MessagesFunc func(ctx context.Context, in *MessagesRequest, opts ...grpc.CallOption) (Sentry_MessagesClient, error) + NodeInfoFunc func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.NodeInfoReply, error) + PeerByIdFunc func(ctx context.Context, in *PeerByIdRequest, opts ...grpc.CallOption) (*PeerByIdReply, error) + PeerCountFunc func(ctx context.Context, in *PeerCountRequest, opts ...grpc.CallOption) (*PeerCountReply, error) + PeerEventsFunc func(ctx context.Context, in *PeerEventsRequest, opts ...grpc.CallOption) (Sentry_PeerEventsClient, error) + PeerMinBlockFunc func(ctx context.Context, in *PeerMinBlockRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + PeersFunc func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PeersReply, error) + PenalizePeerFunc func(ctx context.Context, in *PenalizePeerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + SendMessageByIdFunc func(ctx context.Context, in *SendMessageByIdRequest, opts ...grpc.CallOption) (*SentPeers, error) + SendMessageByMinBlockFunc func(ctx context.Context, in *SendMessageByMinBlockRequest, opts ...grpc.CallOption) (*SentPeers, error) + SendMessageToAllFunc func(ctx context.Context, in *OutboundMessageData, opts ...grpc.CallOption) (*SentPeers, error) + SendMessageToRandomPeersFunc func(ctx context.Context, in *SendMessageToRandomPeersRequest, ...) (*SentPeers, error) + SetStatusFunc func(ctx context.Context, in *StatusData, opts ...grpc.CallOption) (*SetStatusReply, error) + func (mock *SentryClientMock) AddPeer(ctx context.Context, in *AddPeerRequest, opts ...grpc.CallOption) (*AddPeerReply, error) + func (mock *SentryClientMock) AddPeerCalls() []struct{ ... } + func (mock *SentryClientMock) HandShake(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HandShakeReply, error) + func (mock *SentryClientMock) HandShakeCalls() []struct{ ... } + func (mock *SentryClientMock) Messages(ctx context.Context, in *MessagesRequest, opts ...grpc.CallOption) (Sentry_MessagesClient, error) + func (mock *SentryClientMock) MessagesCalls() []struct{ ... } + func (mock *SentryClientMock) NodeInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.NodeInfoReply, error) + func (mock *SentryClientMock) NodeInfoCalls() []struct{ ... } + func (mock *SentryClientMock) PeerById(ctx context.Context, in *PeerByIdRequest, opts ...grpc.CallOption) (*PeerByIdReply, error) + func (mock *SentryClientMock) PeerByIdCalls() []struct{ ... } + func (mock *SentryClientMock) PeerCount(ctx context.Context, in *PeerCountRequest, opts ...grpc.CallOption) (*PeerCountReply, error) + func (mock *SentryClientMock) PeerCountCalls() []struct{ ... } + func (mock *SentryClientMock) PeerEvents(ctx context.Context, in *PeerEventsRequest, opts ...grpc.CallOption) (Sentry_PeerEventsClient, error) + func (mock *SentryClientMock) PeerEventsCalls() []struct{ ... } + func (mock *SentryClientMock) PeerMinBlock(ctx context.Context, in *PeerMinBlockRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + func (mock *SentryClientMock) PeerMinBlockCalls() []struct{ ... } + func (mock *SentryClientMock) Peers(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PeersReply, error) + func (mock *SentryClientMock) PeersCalls() []struct{ ... } + func (mock *SentryClientMock) PenalizePeer(ctx context.Context, in *PenalizePeerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + func (mock *SentryClientMock) PenalizePeerCalls() []struct{ ... } + func (mock *SentryClientMock) SendMessageById(ctx context.Context, in *SendMessageByIdRequest, opts ...grpc.CallOption) (*SentPeers, error) + func (mock *SentryClientMock) SendMessageByIdCalls() []struct{ ... } + func (mock *SentryClientMock) SendMessageByMinBlock(ctx context.Context, in *SendMessageByMinBlockRequest, opts ...grpc.CallOption) (*SentPeers, error) + func (mock *SentryClientMock) SendMessageByMinBlockCalls() []struct{ ... } + func (mock *SentryClientMock) SendMessageToAll(ctx context.Context, in *OutboundMessageData, opts ...grpc.CallOption) (*SentPeers, error) + func (mock *SentryClientMock) SendMessageToAllCalls() []struct{ ... } + func (mock *SentryClientMock) SendMessageToRandomPeers(ctx context.Context, in *SendMessageToRandomPeersRequest, ...) (*SentPeers, error) + func (mock *SentryClientMock) SendMessageToRandomPeersCalls() []struct{ ... } + func (mock *SentryClientMock) SetStatus(ctx context.Context, in *StatusData, opts ...grpc.CallOption) (*SetStatusReply, error) + func (mock *SentryClientMock) SetStatusCalls() []struct{ ... } + type SentryServer interface + AddPeer func(context.Context, *AddPeerRequest) (*AddPeerReply, error) + HandShake func(context.Context, *emptypb.Empty) (*HandShakeReply, error) + Messages func(*MessagesRequest, Sentry_MessagesServer) error + NodeInfo func(context.Context, *emptypb.Empty) (*types.NodeInfoReply, error) + PeerById func(context.Context, *PeerByIdRequest) (*PeerByIdReply, error) + PeerCount func(context.Context, *PeerCountRequest) (*PeerCountReply, error) + PeerEvents func(*PeerEventsRequest, Sentry_PeerEventsServer) error + PeerMinBlock func(context.Context, *PeerMinBlockRequest) (*emptypb.Empty, error) + Peers func(context.Context, *emptypb.Empty) (*PeersReply, error) + PenalizePeer func(context.Context, *PenalizePeerRequest) (*emptypb.Empty, error) + SendMessageById func(context.Context, *SendMessageByIdRequest) (*SentPeers, error) + SendMessageByMinBlock func(context.Context, *SendMessageByMinBlockRequest) (*SentPeers, error) + SendMessageToAll func(context.Context, *OutboundMessageData) (*SentPeers, error) + SendMessageToRandomPeers func(context.Context, *SendMessageToRandomPeersRequest) (*SentPeers, error) + SetStatus func(context.Context, *StatusData) (*SetStatusReply, error) + type SentryServerMock struct + AddPeerFunc func(contextMoqParam context.Context, addPeerRequest *AddPeerRequest) (*AddPeerReply, error) + HandShakeFunc func(contextMoqParam context.Context, empty *emptypb.Empty) (*HandShakeReply, error) + MessagesFunc func(messagesRequest *MessagesRequest, sentry_MessagesServer Sentry_MessagesServer) error + NodeInfoFunc func(contextMoqParam context.Context, empty *emptypb.Empty) (*types.NodeInfoReply, error) + PeerByIdFunc func(contextMoqParam context.Context, peerByIdRequest *PeerByIdRequest) (*PeerByIdReply, error) + PeerCountFunc func(contextMoqParam context.Context, peerCountRequest *PeerCountRequest) (*PeerCountReply, error) + PeerEventsFunc func(peerEventsRequest *PeerEventsRequest, ...) error + PeerMinBlockFunc func(contextMoqParam context.Context, peerMinBlockRequest *PeerMinBlockRequest) (*emptypb.Empty, error) + PeersFunc func(contextMoqParam context.Context, empty *emptypb.Empty) (*PeersReply, error) + PenalizePeerFunc func(contextMoqParam context.Context, penalizePeerRequest *PenalizePeerRequest) (*emptypb.Empty, error) + SendMessageByIdFunc func(contextMoqParam context.Context, ...) (*SentPeers, error) + SendMessageByMinBlockFunc func(contextMoqParam context.Context, ...) (*SentPeers, error) + SendMessageToAllFunc func(contextMoqParam context.Context, outboundMessageData *OutboundMessageData) (*SentPeers, error) + SendMessageToRandomPeersFunc func(contextMoqParam context.Context, ...) (*SentPeers, error) + SetStatusFunc func(contextMoqParam context.Context, statusData *StatusData) (*SetStatusReply, error) + func (mock *SentryServerMock) AddPeer(contextMoqParam context.Context, addPeerRequest *AddPeerRequest) (*AddPeerReply, error) + func (mock *SentryServerMock) AddPeerCalls() []struct{ ... } + func (mock *SentryServerMock) HandShake(contextMoqParam context.Context, empty *emptypb.Empty) (*HandShakeReply, error) + func (mock *SentryServerMock) HandShakeCalls() []struct{ ... } + func (mock *SentryServerMock) Messages(messagesRequest *MessagesRequest, sentry_MessagesServer Sentry_MessagesServer) error + func (mock *SentryServerMock) MessagesCalls() []struct{ ... } + func (mock *SentryServerMock) NodeInfo(contextMoqParam context.Context, empty *emptypb.Empty) (*types.NodeInfoReply, error) + func (mock *SentryServerMock) NodeInfoCalls() []struct{ ... } + func (mock *SentryServerMock) PeerById(contextMoqParam context.Context, peerByIdRequest *PeerByIdRequest) (*PeerByIdReply, error) + func (mock *SentryServerMock) PeerByIdCalls() []struct{ ... } + func (mock *SentryServerMock) PeerCount(contextMoqParam context.Context, peerCountRequest *PeerCountRequest) (*PeerCountReply, error) + func (mock *SentryServerMock) PeerCountCalls() []struct{ ... } + func (mock *SentryServerMock) PeerEvents(peerEventsRequest *PeerEventsRequest, ...) error + func (mock *SentryServerMock) PeerEventsCalls() []struct{ ... } + func (mock *SentryServerMock) PeerMinBlock(contextMoqParam context.Context, peerMinBlockRequest *PeerMinBlockRequest) (*emptypb.Empty, error) + func (mock *SentryServerMock) PeerMinBlockCalls() []struct{ ... } + func (mock *SentryServerMock) Peers(contextMoqParam context.Context, empty *emptypb.Empty) (*PeersReply, error) + func (mock *SentryServerMock) PeersCalls() []struct{ ... } + func (mock *SentryServerMock) PenalizePeer(contextMoqParam context.Context, penalizePeerRequest *PenalizePeerRequest) (*emptypb.Empty, error) + func (mock *SentryServerMock) PenalizePeerCalls() []struct{ ... } + func (mock *SentryServerMock) SendMessageById(contextMoqParam context.Context, ...) (*SentPeers, error) + func (mock *SentryServerMock) SendMessageByIdCalls() []struct{ ... } + func (mock *SentryServerMock) SendMessageByMinBlock(contextMoqParam context.Context, ...) (*SentPeers, error) + func (mock *SentryServerMock) SendMessageByMinBlockCalls() []struct{ ... } + func (mock *SentryServerMock) SendMessageToAll(contextMoqParam context.Context, outboundMessageData *OutboundMessageData) (*SentPeers, error) + func (mock *SentryServerMock) SendMessageToAllCalls() []struct{ ... } + func (mock *SentryServerMock) SendMessageToRandomPeers(contextMoqParam context.Context, ...) (*SentPeers, error) + func (mock *SentryServerMock) SendMessageToRandomPeersCalls() []struct{ ... } + func (mock *SentryServerMock) SetStatus(contextMoqParam context.Context, statusData *StatusData) (*SetStatusReply, error) + func (mock *SentryServerMock) SetStatusCalls() []struct{ ... } + type Sentry_MessagesClient interface + Recv func() (*InboundMessage, error) + type Sentry_MessagesServer interface + Send func(*InboundMessage) error + type Sentry_PeerEventsClient interface + Recv func() (*PeerEvent, error) + type Sentry_PeerEventsServer interface + Send func(*PeerEvent) error + type SetStatusReply struct + func (*SetStatusReply) Descriptor() ([]byte, []int) + func (*SetStatusReply) ProtoMessage() + func (x *SetStatusReply) ProtoReflect() protoreflect.Message + func (x *SetStatusReply) Reset() + func (x *SetStatusReply) String() string + type StatusData struct + BestHash *types.H256 + ForkData *Forks + MaxBlockHeight uint64 + MaxBlockTime uint64 + NetworkId uint64 + TotalDifficulty *types.H256 + func (*StatusData) Descriptor() ([]byte, []int) + func (*StatusData) ProtoMessage() + func (x *StatusData) GetBestHash() *types.H256 + func (x *StatusData) GetForkData() *Forks + func (x *StatusData) GetMaxBlockHeight() uint64 + func (x *StatusData) GetMaxBlockTime() uint64 + func (x *StatusData) GetNetworkId() uint64 + func (x *StatusData) GetTotalDifficulty() *types.H256 + func (x *StatusData) ProtoReflect() protoreflect.Message + func (x *StatusData) Reset() + func (x *StatusData) String() string + type UnimplementedSentryServer struct + func (UnimplementedSentryServer) AddPeer(context.Context, *AddPeerRequest) (*AddPeerReply, error) + func (UnimplementedSentryServer) HandShake(context.Context, *emptypb.Empty) (*HandShakeReply, error) + func (UnimplementedSentryServer) Messages(*MessagesRequest, Sentry_MessagesServer) error + func (UnimplementedSentryServer) NodeInfo(context.Context, *emptypb.Empty) (*types.NodeInfoReply, error) + func (UnimplementedSentryServer) PeerById(context.Context, *PeerByIdRequest) (*PeerByIdReply, error) + func (UnimplementedSentryServer) PeerCount(context.Context, *PeerCountRequest) (*PeerCountReply, error) + func (UnimplementedSentryServer) PeerEvents(*PeerEventsRequest, Sentry_PeerEventsServer) error + func (UnimplementedSentryServer) PeerMinBlock(context.Context, *PeerMinBlockRequest) (*emptypb.Empty, error) + func (UnimplementedSentryServer) Peers(context.Context, *emptypb.Empty) (*PeersReply, error) + func (UnimplementedSentryServer) PenalizePeer(context.Context, *PenalizePeerRequest) (*emptypb.Empty, error) + func (UnimplementedSentryServer) SendMessageById(context.Context, *SendMessageByIdRequest) (*SentPeers, error) + func (UnimplementedSentryServer) SendMessageByMinBlock(context.Context, *SendMessageByMinBlockRequest) (*SentPeers, error) + func (UnimplementedSentryServer) SendMessageToAll(context.Context, *OutboundMessageData) (*SentPeers, error) + func (UnimplementedSentryServer) SendMessageToRandomPeers(context.Context, *SendMessageToRandomPeersRequest) (*SentPeers, error) + func (UnimplementedSentryServer) SetStatus(context.Context, *StatusData) (*SetStatusReply, error) + type UnsafeSentryServer interface