direct

package
v0.0.0-...-ff78b6e Latest Latest
Warning

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

 Go to latest Published: Dec 6, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ETH65 = 65
	ETH66 = 66
	ETH67 = 67
	ETH68 = 68
)

Variables

View Source 
var ProtoIds = map[uint]map[sentry.MessageId]struct{}{
	ETH65: {
		sentry.MessageId_GET_BLOCK_HEADERS_65:             struct{}{},
		sentry.MessageId_BLOCK_HEADERS_65:                 struct{}{},
		sentry.MessageId_GET_BLOCK_BODIES_65:              struct{}{},
		sentry.MessageId_BLOCK_BODIES_65:                  struct{}{},
		sentry.MessageId_GET_NODE_DATA_65:                 struct{}{},
		sentry.MessageId_NODE_DATA_65:                     struct{}{},
		sentry.MessageId_GET_RECEIPTS_65:                  struct{}{},
		sentry.MessageId_RECEIPTS_65:                      struct{}{},
		sentry.MessageId_NEW_BLOCK_HASHES_65:              struct{}{},
		sentry.MessageId_NEW_BLOCK_65:                     struct{}{},
		sentry.MessageId_TRANSACTIONS_65:                  struct{}{},
		sentry.MessageId_NEW_POOLED_TRANSACTION_HASHES_65: struct{}{},
		sentry.MessageId_GET_POOLED_TRANSACTIONS_65:       struct{}{},
		sentry.MessageId_POOLED_TRANSACTIONS_65:           struct{}{},
	},
	ETH66: {
		sentry.MessageId_GET_BLOCK_HEADERS_66:             struct{}{},
		sentry.MessageId_BLOCK_HEADERS_66:                 struct{}{},
		sentry.MessageId_GET_BLOCK_BODIES_66:              struct{}{},
		sentry.MessageId_BLOCK_BODIES_66:                  struct{}{},
		sentry.MessageId_GET_NODE_DATA_66:                 struct{}{},
		sentry.MessageId_NODE_DATA_66:                     struct{}{},
		sentry.MessageId_GET_RECEIPTS_66:                  struct{}{},
		sentry.MessageId_RECEIPTS_66:                      struct{}{},
		sentry.MessageId_NEW_BLOCK_HASHES_66:              struct{}{},
		sentry.MessageId_NEW_BLOCK_66:                     struct{}{},
		sentry.MessageId_TRANSACTIONS_66:                  struct{}{},
		sentry.MessageId_NEW_POOLED_TRANSACTION_HASHES_66: struct{}{},
		sentry.MessageId_GET_POOLED_TRANSACTIONS_66:       struct{}{},
		sentry.MessageId_POOLED_TRANSACTIONS_66:           struct{}{},
	},
	ETH67: {
		sentry.MessageId_GET_BLOCK_HEADERS_66:             struct{}{},
		sentry.MessageId_BLOCK_HEADERS_66:                 struct{}{},
		sentry.MessageId_GET_BLOCK_BODIES_66:              struct{}{},
		sentry.MessageId_BLOCK_BODIES_66:                  struct{}{},
		sentry.MessageId_GET_RECEIPTS_66:                  struct{}{},
		sentry.MessageId_RECEIPTS_66:                      struct{}{},
		sentry.MessageId_NEW_BLOCK_HASHES_66:              struct{}{},
		sentry.MessageId_NEW_BLOCK_66:                     struct{}{},
		sentry.MessageId_TRANSACTIONS_66:                  struct{}{},
		sentry.MessageId_NEW_POOLED_TRANSACTION_HASHES_66: struct{}{},
		sentry.MessageId_GET_POOLED_TRANSACTIONS_66:       struct{}{},
		sentry.MessageId_POOLED_TRANSACTIONS_66:           struct{}{},
	},
	ETH68: {
		sentry.MessageId_GET_BLOCK_HEADERS_66:             struct{}{},
		sentry.MessageId_BLOCK_HEADERS_66:                 struct{}{},
		sentry.MessageId_GET_BLOCK_BODIES_66:              struct{}{},
		sentry.MessageId_BLOCK_BODIES_66:                  struct{}{},
		sentry.MessageId_GET_RECEIPTS_66:                  struct{}{},
		sentry.MessageId_RECEIPTS_66:                      struct{}{},
		sentry.MessageId_NEW_BLOCK_HASHES_66:              struct{}{},
		sentry.MessageId_NEW_BLOCK_66:                     struct{}{},
		sentry.MessageId_TRANSACTIONS_66:                  struct{}{},
		sentry.MessageId_NEW_POOLED_TRANSACTION_HASHES_68: struct{}{},
		sentry.MessageId_GET_POOLED_TRANSACTIONS_66:       struct{}{},
		sentry.MessageId_POOLED_TRANSACTIONS_66:           struct{}{},
	},
}

Functions

func NewExecutionClientDirect 

func NewExecutionClientDirect(server execution.ExecutionServer) execution.ExecutionClient

func NewSentinelClientDirect 

func NewSentinelClientDirect(sentinel sentinel.SentinelServer) sentinel.SentinelClient

Types

type DownloaderClient 

type DownloaderClient struct {
	// contains filtered or unexported fields
}

func NewDownloaderClient 

func NewDownloaderClient(server proto_downloader.DownloaderServer) *DownloaderClient

func (*DownloaderClient) Delete 

func (c *DownloaderClient) Delete(ctx context.Context, in *proto_downloader.DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*DownloaderClient) Download 

func (c *DownloaderClient) Download(ctx context.Context, in *proto_downloader.DownloadRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*DownloaderClient) Stats 

func (c *DownloaderClient) Stats(ctx context.Context, in *proto_downloader.StatsRequest, opts ...grpc.CallOption) (*proto_downloader.StatsReply, error)

func (*DownloaderClient) Verify 

func (c *DownloaderClient) Verify(ctx context.Context, in *proto_downloader.VerifyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

type EthBackendClientDirect 

type EthBackendClientDirect struct {
	// contains filtered or unexported fields
}

func NewEthBackendClientDirect 

func NewEthBackendClientDirect(server remote.ETHBACKENDServer) *EthBackendClientDirect

func (*EthBackendClientDirect) AddPeer 

func (s *EthBackendClientDirect) AddPeer(ctx context.Context, in *remote.AddPeerRequest, opts ...grpc.CallOption) (*remote.AddPeerReply, error)

func (*EthBackendClientDirect) Block 

func (s *EthBackendClientDirect) Block(ctx context.Context, in *remote.BlockRequest, opts ...grpc.CallOption) (*remote.BlockReply, error)

func (*EthBackendClientDirect) BorEvent 

func (s *EthBackendClientDirect) BorEvent(ctx context.Context, in *remote.BorEventRequest, opts ...grpc.CallOption) (*remote.BorEventReply, error)

func (*EthBackendClientDirect) ClientVersion 

func (s *EthBackendClientDirect) ClientVersion(ctx context.Context, in *remote.ClientVersionRequest, opts ...grpc.CallOption) (*remote.ClientVersionReply, error)

func (*EthBackendClientDirect) Etherbase 

func (s *EthBackendClientDirect) Etherbase(ctx context.Context, in *remote.EtherbaseRequest, opts ...grpc.CallOption) (*remote.EtherbaseReply, error)

func (*EthBackendClientDirect) NetPeerCount 

func (s *EthBackendClientDirect) NetPeerCount(ctx context.Context, in *remote.NetPeerCountRequest, opts ...grpc.CallOption) (*remote.NetPeerCountReply, error)

func (*EthBackendClientDirect) NetVersion 

func (s *EthBackendClientDirect) NetVersion(ctx context.Context, in *remote.NetVersionRequest, opts ...grpc.CallOption) (*remote.NetVersionReply, error)

func (*EthBackendClientDirect) NodeInfo 

func (s *EthBackendClientDirect) NodeInfo(ctx context.Context, in *remote.NodesInfoRequest, opts ...grpc.CallOption) (*remote.NodesInfoReply, error)

func (*EthBackendClientDirect) Peers 

func (s *EthBackendClientDirect) Peers(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*remote.PeersReply, error)

func (*EthBackendClientDirect) PendingBlock 

func (s *EthBackendClientDirect) PendingBlock(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*remote.PendingBlockReply, error)

func (*EthBackendClientDirect) ProtocolVersion 

func (s *EthBackendClientDirect) ProtocolVersion(ctx context.Context, in *remote.ProtocolVersionRequest, opts ...grpc.CallOption) (*remote.ProtocolVersionReply, error)

func (*EthBackendClientDirect) Subscribe 

func (s *EthBackendClientDirect) Subscribe(ctx context.Context, in *remote.SubscribeRequest, opts ...grpc.CallOption) (remote.ETHBACKEND_SubscribeClient, error)

func (*EthBackendClientDirect) SubscribeLogs 

func (s *EthBackendClientDirect) SubscribeLogs(ctx context.Context, opts ...grpc.CallOption) (remote.ETHBACKEND_SubscribeLogsClient, error)

func (*EthBackendClientDirect) TxnLookup 

func (s *EthBackendClientDirect) TxnLookup(ctx context.Context, in *remote.TxnLookupRequest, opts ...grpc.CallOption) (*remote.TxnLookupReply, error)

func (*EthBackendClientDirect) Version 

func (s *EthBackendClientDirect) Version(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.VersionReply, error)

type ExecutionClientDirect 

type ExecutionClientDirect struct {
	// contains filtered or unexported fields
}

func (*ExecutionClientDirect) AssembleBlock 

func (s *ExecutionClientDirect) AssembleBlock(ctx context.Context, in *execution.AssembleBlockRequest, opts ...grpc.CallOption) (*execution.AssembleBlockResponse, error)

func (*ExecutionClientDirect) CurrentHeader 

func (s *ExecutionClientDirect) CurrentHeader(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*execution.GetHeaderResponse, error)

func (*ExecutionClientDirect) FrozenBlocks 

func (s *ExecutionClientDirect) FrozenBlocks(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*execution.FrozenBlocksResponse, error)

func (*ExecutionClientDirect) GetAssembledBlock 

func (s *ExecutionClientDirect) GetAssembledBlock(ctx context.Context, in *execution.GetAssembledBlockRequest, opts ...grpc.CallOption) (*execution.GetAssembledBlockResponse, error)

func (*ExecutionClientDirect) GetBodiesByHashes 

func (s *ExecutionClientDirect) GetBodiesByHashes(ctx context.Context, in *execution.GetBodiesByHashesRequest, opts ...grpc.CallOption) (*execution.GetBodiesBatchResponse, error)

func (*ExecutionClientDirect) GetBodiesByRange 

func (s *ExecutionClientDirect) GetBodiesByRange(ctx context.Context, in *execution.GetBodiesByRangeRequest, opts ...grpc.CallOption) (*execution.GetBodiesBatchResponse, error)

func (*ExecutionClientDirect) GetBody 

func (s *ExecutionClientDirect) GetBody(ctx context.Context, in *execution.GetSegmentRequest, opts ...grpc.CallOption) (*execution.GetBodyResponse, error)

func (*ExecutionClientDirect) GetForkChoice 

func (s *ExecutionClientDirect) GetForkChoice(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*execution.ForkChoice, error)

func (*ExecutionClientDirect) GetHeader 

func (s *ExecutionClientDirect) GetHeader(ctx context.Context, in *execution.GetSegmentRequest, opts ...grpc.CallOption) (*execution.GetHeaderResponse, error)

Chain Getters.

func (*ExecutionClientDirect) GetHeaderHashNumber 

func (s *ExecutionClientDirect) GetHeaderHashNumber(ctx context.Context, in *types.H256, opts ...grpc.CallOption) (*execution.GetHeaderHashNumberResponse, error)

func (*ExecutionClientDirect) GetTD 

func (s *ExecutionClientDirect) GetTD(ctx context.Context, in *execution.GetSegmentRequest, opts ...grpc.CallOption) (*execution.GetTDResponse, error)

func (*ExecutionClientDirect) InsertBlocks 

func (s *ExecutionClientDirect) InsertBlocks(ctx context.Context, in *execution.InsertBlocksRequest, opts ...grpc.CallOption) (*execution.InsertionResult, error)

Chain Putters.

func (*ExecutionClientDirect) IsCanonicalHash 

func (s *ExecutionClientDirect) IsCanonicalHash(ctx context.Context, in *types.H256, opts ...grpc.CallOption) (*execution.IsCanonicalResponse, error)

func (*ExecutionClientDirect) Ready 

func (s *ExecutionClientDirect) Ready(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*execution.ReadyResponse, error)

func (*ExecutionClientDirect) UpdateForkChoice 

func (s *ExecutionClientDirect) UpdateForkChoice(ctx context.Context, in *execution.ForkChoice, opts ...grpc.CallOption) (*execution.ForkChoiceReceipt, error)

func (*ExecutionClientDirect) ValidateChain 

func (s *ExecutionClientDirect) ValidateChain(ctx context.Context, in *execution.ValidationRequest, opts ...grpc.CallOption) (*execution.ValidationReceipt, error)

Chain Validation and ForkChoice.

type MiningClient 

type MiningClient struct {
	// contains filtered or unexported fields
}

func NewMiningClient 

func NewMiningClient(server txpool_proto.MiningServer) *MiningClient

func (*MiningClient) GetWork 

func (s *MiningClient) GetWork(ctx context.Context, in *txpool_proto.GetWorkRequest, opts ...grpc.CallOption) (*txpool_proto.GetWorkReply, error)

func (*MiningClient) HashRate 

func (s *MiningClient) HashRate(ctx context.Context, in *txpool_proto.HashRateRequest, opts ...grpc.CallOption) (*txpool_proto.HashRateReply, error)

func (*MiningClient) Mining 

func (s *MiningClient) Mining(ctx context.Context, in *txpool_proto.MiningRequest, opts ...grpc.CallOption) (*txpool_proto.MiningReply, error)

func (*MiningClient) OnMinedBlock 

func (s *MiningClient) OnMinedBlock(ctx context.Context, in *txpool_proto.OnMinedBlockRequest, opts ...grpc.CallOption) (txpool_proto.Mining_OnMinedBlockClient, error)

func (*MiningClient) OnPendingBlock 

func (s *MiningClient) OnPendingBlock(ctx context.Context, in *txpool_proto.OnPendingBlockRequest, opts ...grpc.CallOption) (txpool_proto.Mining_OnPendingBlockClient, error)

func (*MiningClient) OnPendingLogs 

func (s *MiningClient) OnPendingLogs(ctx context.Context, in *txpool_proto.OnPendingLogsRequest, opts ...grpc.CallOption) (txpool_proto.Mining_OnPendingLogsClient, error)

func (*MiningClient) SubmitHashRate 

func (s *MiningClient) SubmitHashRate(ctx context.Context, in *txpool_proto.SubmitHashRateRequest, opts ...grpc.CallOption) (*txpool_proto.SubmitHashRateReply, error)

func (*MiningClient) SubmitWork 

func (s *MiningClient) SubmitWork(ctx context.Context, in *txpool_proto.SubmitWorkRequest, opts ...grpc.CallOption) (*txpool_proto.SubmitWorkReply, error)

func (*MiningClient) Version 

func (s *MiningClient) Version(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.VersionReply, error)

type MiningOnMinedBlockC 

type MiningOnMinedBlockC struct {
	grpc.ClientStream
	// contains filtered or unexported fields
}

func (*MiningOnMinedBlockC) Context 

func (c *MiningOnMinedBlockC) Context() context.Context

func (*MiningOnMinedBlockC) Recv 

func (c *MiningOnMinedBlockC) Recv() (*txpool_proto.OnMinedBlockReply, error)

type MiningOnMinedBlockS 

type MiningOnMinedBlockS struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

func (*MiningOnMinedBlockS) Context 

func (s *MiningOnMinedBlockS) Context() context.Context

func (*MiningOnMinedBlockS) Err 

func (s *MiningOnMinedBlockS) Err(err error)

func (*MiningOnMinedBlockS) Send 

func (s *MiningOnMinedBlockS) Send(m *txpool_proto.OnMinedBlockReply) error

type MiningOnPendingBlockC 

type MiningOnPendingBlockC struct {
	grpc.ClientStream
	// contains filtered or unexported fields
}

func (*MiningOnPendingBlockC) Context 

func (c *MiningOnPendingBlockC) Context() context.Context

func (*MiningOnPendingBlockC) Recv 

func (c *MiningOnPendingBlockC) Recv() (*txpool_proto.OnPendingBlockReply, error)

type MiningOnPendingBlockS 

type MiningOnPendingBlockS struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

func (*MiningOnPendingBlockS) Context 

func (s *MiningOnPendingBlockS) Context() context.Context

func (*MiningOnPendingBlockS) Err 

func (s *MiningOnPendingBlockS) Err(err error)

func (*MiningOnPendingBlockS) Send 

func (s *MiningOnPendingBlockS) Send(m *txpool_proto.OnPendingBlockReply) error

type MiningOnPendingLogsC 

type MiningOnPendingLogsC struct {
	grpc.ClientStream
	// contains filtered or unexported fields
}

func (*MiningOnPendingLogsC) Context 

func (c *MiningOnPendingLogsC) Context() context.Context

func (*MiningOnPendingLogsC) Recv 

func (c *MiningOnPendingLogsC) Recv() (*txpool_proto.OnPendingLogsReply, error)

type MiningOnPendingLogsS 

type MiningOnPendingLogsS struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

func (*MiningOnPendingLogsS) Context 

func (s *MiningOnPendingLogsS) Context() context.Context

func (*MiningOnPendingLogsS) Err 

func (s *MiningOnPendingLogsS) Err(err error)

func (*MiningOnPendingLogsS) Send 

func (s *MiningOnPendingLogsS) Send(m *txpool_proto.OnPendingLogsReply) error

type SentinelClientDirect 

type SentinelClientDirect struct {
	// contains filtered or unexported fields
}

func (*SentinelClientDirect) BanPeer 

func (s *SentinelClientDirect) BanPeer(ctx context.Context, p *sentinel.Peer, opts ...grpc.CallOption) (*sentinel.EmptyMessage, error)

func (*SentinelClientDirect) GetPeers 

func (s *SentinelClientDirect) GetPeers(ctx context.Context, in *sentinel.EmptyMessage, opts ...grpc.CallOption) (*sentinel.PeerCount, error)

func (*SentinelClientDirect) GetPeersStatistics 

func (s *SentinelClientDirect) GetPeersStatistics() map[string]*diagnostics.PeerStatistics

func (*SentinelClientDirect) PenalizePeer 

func (s *SentinelClientDirect) PenalizePeer(ctx context.Context, p *sentinel.Peer, opts ...grpc.CallOption) (*sentinel.EmptyMessage, error)

func (*SentinelClientDirect) PublishGossip 

func (s *SentinelClientDirect) PublishGossip(ctx context.Context, in *sentinel.GossipData, opts ...grpc.CallOption) (*sentinel.EmptyMessage, error)

func (*SentinelClientDirect) RewardPeer 

func (s *SentinelClientDirect) RewardPeer(ctx context.Context, p *sentinel.Peer, opts ...grpc.CallOption) (*sentinel.EmptyMessage, error)

func (*SentinelClientDirect) SendRequest 

func (s *SentinelClientDirect) SendRequest(ctx context.Context, in *sentinel.RequestData, opts ...grpc.CallOption) (*sentinel.ResponseData, error)

func (*SentinelClientDirect) SetStatus 

func (s *SentinelClientDirect) SetStatus(ctx context.Context, in *sentinel.Status, opts ...grpc.CallOption) (*sentinel.EmptyMessage, error)

func (*SentinelClientDirect) SubscribeGossip 

func (s *SentinelClientDirect) SubscribeGossip(ctx context.Context, in *sentinel.EmptyMessage, opts ...grpc.CallOption) (sentinel.Sentinel_SubscribeGossipClient, error)

func (*SentinelClientDirect) UnbanPeer 

func (s *SentinelClientDirect) UnbanPeer(ctx context.Context, p *sentinel.Peer, opts ...grpc.CallOption) (*sentinel.EmptyMessage, error)

type SentinelSubscribeGossipC 

type SentinelSubscribeGossipC struct {
	grpc.ClientStream
	// contains filtered or unexported fields
}

func (*SentinelSubscribeGossipC) Context 

func (c *SentinelSubscribeGossipC) Context() context.Context

func (*SentinelSubscribeGossipC) Recv 

func (c *SentinelSubscribeGossipC) Recv() (*sentinel.GossipData, error)

type SentinelSubscribeGossipS 

type SentinelSubscribeGossipS struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

func (*SentinelSubscribeGossipS) Context 

func (s *SentinelSubscribeGossipS) Context() context.Context

func (*SentinelSubscribeGossipS) Err 

func (s *SentinelSubscribeGossipS) Err(err error)

func (*SentinelSubscribeGossipS) Send 

func (s *SentinelSubscribeGossipS) Send(m *sentinel.GossipData) error

type SentryClient 

type SentryClient interface {
	sentry.SentryClient
	Protocol() uint
	Ready() bool
	MarkDisconnected()
}

type SentryClientDirect 

type SentryClientDirect struct {
	// contains filtered or unexported fields
}

SentryClientDirect implements SentryClient interface by connecting the instance of the client directly with the corresponding instance of SentryServer

func NewSentryClientDirect 

func NewSentryClientDirect(protocol uint, sentryServer sentry.SentryServer) *SentryClientDirect

func (*SentryClientDirect) AddPeer 

func (c *SentryClientDirect) AddPeer(ctx context.Context, in *sentry.AddPeerRequest, opts ...grpc.CallOption) (*sentry.AddPeerReply, error)

func (*SentryClientDirect) HandShake 

func (c *SentryClientDirect) HandShake(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*sentry.HandShakeReply, error)

func (*SentryClientDirect) MarkDisconnected 

func (c *SentryClientDirect) MarkDisconnected()

func (*SentryClientDirect) Messages 

func (c *SentryClientDirect) Messages(ctx context.Context, in *sentry.MessagesRequest, opts ...grpc.CallOption) (sentry.Sentry_MessagesClient, error)

func (*SentryClientDirect) NodeInfo 

func (c *SentryClientDirect) NodeInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.NodeInfoReply, error)

func (*SentryClientDirect) PeerById 

func (c *SentryClientDirect) PeerById(ctx context.Context, in *sentry.PeerByIdRequest, opts ...grpc.CallOption) (*sentry.PeerByIdReply, error)

func (*SentryClientDirect) PeerCount 

func (c *SentryClientDirect) PeerCount(ctx context.Context, in *sentry.PeerCountRequest, opts ...grpc.CallOption) (*sentry.PeerCountReply, error)

func (*SentryClientDirect) PeerEvents 

func (c *SentryClientDirect) PeerEvents(ctx context.Context, in *sentry.PeerEventsRequest, opts ...grpc.CallOption) (sentry.Sentry_PeerEventsClient, error)

func (*SentryClientDirect) PeerMinBlock 

func (c *SentryClientDirect) PeerMinBlock(ctx context.Context, in *sentry.PeerMinBlockRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*SentryClientDirect) Peers 

func (c *SentryClientDirect) Peers(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*sentry.PeersReply, error)

func (*SentryClientDirect) PenalizePeer 

func (c *SentryClientDirect) PenalizePeer(ctx context.Context, in *sentry.PenalizePeerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*SentryClientDirect) Protocol 

func (c *SentryClientDirect) Protocol() uint

func (*SentryClientDirect) Ready 

func (c *SentryClientDirect) Ready() bool

func (*SentryClientDirect) SendMessageById 

func (c *SentryClientDirect) SendMessageById(ctx context.Context, in *sentry.SendMessageByIdRequest, opts ...grpc.CallOption) (*sentry.SentPeers, error)

func (*SentryClientDirect) SendMessageByMinBlock 

func (c *SentryClientDirect) SendMessageByMinBlock(ctx context.Context, in *sentry.SendMessageByMinBlockRequest, opts ...grpc.CallOption) (*sentry.SentPeers, error)

func (*SentryClientDirect) SendMessageToAll 

func (c *SentryClientDirect) SendMessageToAll(ctx context.Context, in *sentry.OutboundMessageData, opts ...grpc.CallOption) (*sentry.SentPeers, error)

func (*SentryClientDirect) SendMessageToRandomPeers 

func (c *SentryClientDirect) SendMessageToRandomPeers(ctx context.Context, in *sentry.SendMessageToRandomPeersRequest, opts ...grpc.CallOption) (*sentry.SentPeers, error)

func (*SentryClientDirect) SetStatus 

func (c *SentryClientDirect) SetStatus(ctx context.Context, in *sentry.StatusData, opts ...grpc.CallOption) (*sentry.SetStatusReply, error)

type SentryClientRemote 

type SentryClientRemote struct {
	sentry.SentryClient
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewSentryClientRemote 

func NewSentryClientRemote(client sentry.SentryClient) *SentryClientRemote

NewSentryClientRemote - app code must use this class to avoid concurrency - it accepts protocol (which received async by SetStatus) in constructor, means app can't use client which protocol unknown yet

func (*SentryClientRemote) HandShake 

func (c *SentryClientRemote) HandShake(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*sentry.HandShakeReply, error)

func (*SentryClientRemote) MarkDisconnected 

func (c *SentryClientRemote) MarkDisconnected()

func (*SentryClientRemote) Messages 

func (c *SentryClientRemote) Messages(ctx context.Context, in *sentry.MessagesRequest, opts ...grpc.CallOption) (sentry.Sentry_MessagesClient, error)

func (*SentryClientRemote) PeerCount 

func (c *SentryClientRemote) PeerCount(ctx context.Context, in *sentry.PeerCountRequest, opts ...grpc.CallOption) (*sentry.PeerCountReply, error)

func (*SentryClientRemote) Protocol 

func (c *SentryClientRemote) Protocol() uint

func (*SentryClientRemote) Ready 

func (c *SentryClientRemote) Ready() bool

func (*SentryClientRemote) SetStatus 

func (c *SentryClientRemote) SetStatus(ctx context.Context, in *sentry.StatusData, opts ...grpc.CallOption) (*sentry.SetStatusReply, error)

type SentryMessagesStreamC 

type SentryMessagesStreamC struct {
	grpc.ClientStream
	// contains filtered or unexported fields
}

func (*SentryMessagesStreamC) Context 

func (c *SentryMessagesStreamC) Context() context.Context

func (*SentryMessagesStreamC) Recv 

func (c *SentryMessagesStreamC) Recv() (*sentry.InboundMessage, error)

func (*SentryMessagesStreamC) RecvMsg 

func (c *SentryMessagesStreamC) RecvMsg(anyMessage interface{}) error

type SentryMessagesStreamS 

type SentryMessagesStreamS struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

SentryMessagesStreamS implements proto_sentry.Sentry_ReceiveMessagesServer

func (*SentryMessagesStreamS) Context 

func (s *SentryMessagesStreamS) Context() context.Context

func (*SentryMessagesStreamS) Err 

func (s *SentryMessagesStreamS) Err(err error)

func (*SentryMessagesStreamS) Send 

func (s *SentryMessagesStreamS) Send(m *sentry.InboundMessage) error

type SentryPeersStreamC 

type SentryPeersStreamC struct {
	grpc.ClientStream
	// contains filtered or unexported fields
}

func (*SentryPeersStreamC) Context 

func (c *SentryPeersStreamC) Context() context.Context

func (*SentryPeersStreamC) Recv 

func (c *SentryPeersStreamC) Recv() (*sentry.PeerEvent, error)

func (*SentryPeersStreamC) RecvMsg 

func (c *SentryPeersStreamC) RecvMsg(anyMessage interface{}) error

type SentryPeersStreamS 

type SentryPeersStreamS struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

SentryPeersStreamS - implements proto_sentry.Sentry_ReceivePeersServer

func (*SentryPeersStreamS) Context 

func (s *SentryPeersStreamS) Context() context.Context

func (*SentryPeersStreamS) Err 

func (s *SentryPeersStreamS) Err(err error)

func (*SentryPeersStreamS) Send 

func (s *SentryPeersStreamS) Send(m *sentry.PeerEvent) error

type StateDiffClient 

type StateDiffClient interface {
	StateChanges(ctx context.Context, in *remote.StateChangeRequest, opts ...grpc.CallOption) (remote.KV_StateChangesClient, error)
	Snapshots(ctx context.Context, in *remote.SnapshotsRequest, opts ...grpc.CallOption) (*remote.SnapshotsReply, error)
}

type StateDiffClientDirect 

type StateDiffClientDirect struct {
	// contains filtered or unexported fields
}

SentryClientDirect implements SentryClient interface by connecting the instance of the client directly with the corresponding instance of SentryServer

func NewStateDiffClientDirect 

func NewStateDiffClientDirect(server remote.KVServer) *StateDiffClientDirect

func (*StateDiffClientDirect) Snapshots 

func (c *StateDiffClientDirect) Snapshots(ctx context.Context, in *remote.SnapshotsRequest, opts ...grpc.CallOption) (*remote.SnapshotsReply, error)

func (*StateDiffClientDirect) StateChanges 

func (c *StateDiffClientDirect) StateChanges(ctx context.Context, in *remote.StateChangeRequest, opts ...grpc.CallOption) (remote.KV_StateChangesClient, error)

type StateDiffStreamC 

type StateDiffStreamC struct {
	grpc.ClientStream
	// contains filtered or unexported fields
}

func (*StateDiffStreamC) Context 

func (c *StateDiffStreamC) Context() context.Context

func (*StateDiffStreamC) Recv 

func (c *StateDiffStreamC) Recv() (*remote.StateChangeBatch, error)

type StateDiffStreamS 

type StateDiffStreamS struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

StateDiffStreamS implements proto_sentry.Sentry_ReceiveMessagesServer

func (*StateDiffStreamS) Context 

func (s *StateDiffStreamS) Context() context.Context

func (*StateDiffStreamS) Err 

func (s *StateDiffStreamS) Err(err error)

func (*StateDiffStreamS) Send 

func (s *StateDiffStreamS) Send(m *remote.StateChangeBatch) error

type SubscribeLogsStreamC 

type SubscribeLogsStreamC struct {
	grpc.ClientStream
	// contains filtered or unexported fields
}

func (*SubscribeLogsStreamC) Recv 

func (c *SubscribeLogsStreamC) Recv() (*remote.SubscribeLogsReply, error)

func (*SubscribeLogsStreamC) Send 

func (c *SubscribeLogsStreamC) Send(m *remote.LogsFilterRequest) error

type SubscribeLogsStreamS 

type SubscribeLogsStreamS struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

func (*SubscribeLogsStreamS) Err 

func (s *SubscribeLogsStreamS) Err(err error)

func (*SubscribeLogsStreamS) Recv 

func (s *SubscribeLogsStreamS) Recv() (*remote.LogsFilterRequest, error)

func (*SubscribeLogsStreamS) Send 

func (s *SubscribeLogsStreamS) Send(m *remote.SubscribeLogsReply) error

type SubscribeStreamC 

type SubscribeStreamC struct {
	grpc.ClientStream
	// contains filtered or unexported fields
}

func (*SubscribeStreamC) Context 

func (c *SubscribeStreamC) Context() context.Context

func (*SubscribeStreamC) Recv 

func (c *SubscribeStreamC) Recv() (*remote.SubscribeReply, error)

type SubscribeStreamS 

type SubscribeStreamS struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

func (*SubscribeStreamS) Context 

func (s *SubscribeStreamS) Context() context.Context

func (*SubscribeStreamS) Err 

func (s *SubscribeStreamS) Err(err error)

func (*SubscribeStreamS) Send 

func (s *SubscribeStreamS) Send(m *remote.SubscribeReply) error

type TxPoolClient 

type TxPoolClient struct {
	// contains filtered or unexported fields
}

func NewTxPoolClient 

func NewTxPoolClient(server txpool_proto.TxpoolServer) *TxPoolClient

func (*TxPoolClient) Add 

func (s *TxPoolClient) Add(ctx context.Context, in *txpool_proto.AddRequest, opts ...grpc.CallOption) (*txpool_proto.AddReply, error)

func (*TxPoolClient) All 

func (s *TxPoolClient) All(ctx context.Context, in *txpool_proto.AllRequest, opts ...grpc.CallOption) (*txpool_proto.AllReply, error)

func (*TxPoolClient) FindUnknown 

func (s *TxPoolClient) FindUnknown(ctx context.Context, in *txpool_proto.TxHashes, opts ...grpc.CallOption) (*txpool_proto.TxHashes, error)

func (*TxPoolClient) Nonce 

func (s *TxPoolClient) Nonce(ctx context.Context, in *txpool_proto.NonceRequest, opts ...grpc.CallOption) (*txpool_proto.NonceReply, error)

func (*TxPoolClient) OnAdd 

func (s *TxPoolClient) OnAdd(ctx context.Context, in *txpool_proto.OnAddRequest, opts ...grpc.CallOption) (txpool_proto.Txpool_OnAddClient, error)

func (*TxPoolClient) Pending 

func (s *TxPoolClient) Pending(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*txpool_proto.PendingReply, error)

func (*TxPoolClient) Status 

func (s *TxPoolClient) Status(ctx context.Context, in *txpool_proto.StatusRequest, opts ...grpc.CallOption) (*txpool_proto.StatusReply, error)

func (*TxPoolClient) Transactions 

func (s *TxPoolClient) Transactions(ctx context.Context, in *txpool_proto.TransactionsRequest, opts ...grpc.CallOption) (*txpool_proto.TransactionsReply, error)

func (*TxPoolClient) Version 

func (s *TxPoolClient) Version(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.VersionReply, error)

type TxPoolOnAddC 

type TxPoolOnAddC struct {
	grpc.ClientStream
	// contains filtered or unexported fields
}

func (*TxPoolOnAddC) Context 

func (c *TxPoolOnAddC) Context() context.Context

func (*TxPoolOnAddC) Recv 

func (c *TxPoolOnAddC) Recv() (*txpool_proto.OnAddReply, error)

type TxPoolOnAddS 

type TxPoolOnAddS struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

func (*TxPoolOnAddS) Context 

func (s *TxPoolOnAddS) Context() context.Context

func (*TxPoolOnAddS) Err 

func (s *TxPoolOnAddS) Err(err error)

func (*TxPoolOnAddS) Send 

func (s *TxPoolOnAddS) Send(m *txpool_proto.OnAddReply) error

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.