direct

package
v0.0.0-...-75fb2f0 Latest Latest
Warning

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

 Go to latest Published: Oct 4, 2024 License: Apache-2.0 Imports: 12 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

This section is empty.

Types

type DownloaderClient 

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

func NewDownloaderClient 

func NewDownloaderClient(server proto_downloader.DownloaderServer) *DownloaderClient

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) Block 

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

func (*EthBackendClientDirect) ClientVersion 

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

func (*EthBackendClientDirect) EngineForkChoiceUpdated 

func (s *EthBackendClientDirect) EngineForkChoiceUpdated(ctx context.Context, in *remote.EngineForkChoiceUpdatedRequest, opts ...grpc.CallOption) (*remote.EngineForkChoiceUpdatedResponse, error)

func (*EthBackendClientDirect) EngineGetBlobsBundleV1 

func (s *EthBackendClientDirect) EngineGetBlobsBundleV1(ctx context.Context, in *remote.EngineGetBlobsBundleRequest, opts ...grpc.CallOption) (*types.BlobsBundleV1, error)

func (*EthBackendClientDirect) EngineGetPayload 

func (s *EthBackendClientDirect) EngineGetPayload(ctx context.Context, in *remote.EngineGetPayloadRequest, opts ...grpc.CallOption) (*remote.EngineGetPayloadResponse, error)

func (*EthBackendClientDirect) EngineGetPayloadBodiesByHashV1 

func (s *EthBackendClientDirect) EngineGetPayloadBodiesByHashV1(ctx context.Context, in *remote.EngineGetPayloadBodiesByHashV1Request, opts ...grpc.CallOption) (*remote.EngineGetPayloadBodiesV1Response, error)

func (*EthBackendClientDirect) EngineGetPayloadBodiesByRangeV1 

func (s *EthBackendClientDirect) EngineGetPayloadBodiesByRangeV1(ctx context.Context, in *remote.EngineGetPayloadBodiesByRangeV1Request, opts ...grpc.CallOption) (*remote.EngineGetPayloadBodiesV1Response, error)

func (*EthBackendClientDirect) EngineNewPayload 

func (s *EthBackendClientDirect) EngineNewPayload(ctx context.Context, in *types.ExecutionPayload, opts ...grpc.CallOption) (*remote.EnginePayloadStatus, 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 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 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) 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.