p2p

package
v0.1.107 Latest Latest
Warning

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

 Go to latest Published: Mar 4, 2026 License: AGPL-3.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var SensorMsgCounter = promauto.NewCounterVec(prometheus.CounterOpts{
	Namespace: "sensor",
	Name:      "messages",
	Help:      "The number and type of messages the sensor has sent and received",
}, []string{"message", "direction"})

SensorMsgCounter is a global Prometheus counter for tracking message counts. It only uses "message" and "direction" labels to maintain O(1) cardinality instead of tracking per-peer metrics which causes high cardinality issues.

Functions

func Dial 

func Dial(n *enode.Node, opts DialOpts) (*rlpxConn, error)

Dial attempts to Dial the given node and perform a handshake, returning the created Conn if successful.

func Listen 

func Listen(ln *enode.LocalNode) (*net.UDPConn, error)

func NewEthProtocol 

func NewEthProtocol(version uint, opts EthProtocolOptions) ethp2p.Protocol

NewEthProtocol creates the new eth protocol. This will handle writing the status exchange, message handling, and writing blocks/txs to the database.

func ParseBootnodes 

func ParseBootnodes(bootnodes string) ([]*enode.Node, error)

ParseBootnodes parses the bootnodes string and returns a node slice.

func ParseNode 

func ParseNode(source string) (*enode.Node, error)

ParseNode parses a node record and verifies its signature.

func ParsePrivateKey added in v0.1.90 

func ParsePrivateKey(file string, key string) (*ecdsa.PrivateKey, error)

ParsePrivateKey loads a private key from a file path or hex string. If file is provided, it attempts to load from the file path first. If the file doesn't exist, it generates a new key and saves it to the file. If key is provided instead, it parses the hex-encoded private key string. If neither file nor key is provided, it generates and returns a new private key.

func ReadNodeSet 

func ReadNodeSet(file string) ([]*enode.Node, error)

ReadNodeSet parses a list of discovery node URLs loaded from a JSON file.

func WriteDNSTreeNodes added in v0.1.61 

func WriteDNSTreeNodes(file string, tree *dnsdisc.Tree) error

func WriteNodeSet 

func WriteNodeSet(file string, ns NodeSet, writeErrors bool) error

func WritePeers 

func WritePeers(file string, urls []string) error

func WriteURLs 

func WriteURLs(file string, ns NodeSet) error

Types

type AccountRange 

type AccountRange snap.AccountRangePacket

func (AccountRange) Code 

func (msg AccountRange) Code() int

func (AccountRange) ReqID 

func (msg AccountRange) ReqID() uint64

type BlockBodies 

type BlockBodies eth.BlockBodiesPacket

BlockBodies is the network packet for block content distribution.

func (BlockBodies) Code 

func (msg BlockBodies) Code() int

func (BlockBodies) ReqID 

func (msg BlockBodies) ReqID() uint64

type BlockCache added in v0.1.94 

type BlockCache struct {
	Header *types.Header
	Body   *eth.BlockBody
	TD     *big.Int
}

BlockCache stores the actual block data to avoid duplicate fetches and database queries.

type BlockHeaders 

type BlockHeaders eth.BlockHeadersPacket

func (BlockHeaders) Code 

func (msg BlockHeaders) Code() int

func (BlockHeaders) ReqID 

func (msg BlockHeaders) ReqID() uint64

type BlockMetrics added in v0.1.97 

type BlockMetrics struct {
	HeadBlockNumber    prometheus.Gauge
	HeadBlockTimestamp prometheus.Gauge
	HeadBlockAge       prometheus.Gauge
	OldestBlockNumber  prometheus.Gauge
	BlockRange         prometheus.Gauge
}

BlockMetrics contains Prometheus metrics for tracking head and oldest blocks.

func NewBlockMetrics added in v0.1.97 

func NewBlockMetrics(block *types.Block) *BlockMetrics

NewBlockMetrics creates and registers all block-related Prometheus metrics.

func (*BlockMetrics) Update added in v0.1.97 

func (m *BlockMetrics) Update(block *types.Block, oldest *types.Header)

Update updates all block metrics.

type BorStatusPacket69 added in v0.1.107 

type BorStatusPacket69 struct {
	ProtocolVersion uint32
	NetworkID       uint64
	TD              *big.Int
	Genesis         common.Hash
	ForkID          forkid.ID
	EarliestBlock   uint64
	LatestBlock     uint64
	LatestBlockHash common.Hash
}

BorStatusPacket69 is the Bor-compatible status packet for ETH69. Bor's implementation includes the TD field which upstream go-ethereum removed.

func (*BorStatusPacket69) Kind added in v0.1.107 

func (*BorStatusPacket69) Kind() byte

func (*BorStatusPacket69) Name added in v0.1.107 

func (*BorStatusPacket69) Name() string

type ByteCodes 

type ByteCodes snap.ByteCodesPacket

func (ByteCodes) Code 

func (msg ByteCodes) Code() int

func (ByteCodes) ReqID 

func (msg ByteCodes) ReqID() uint64

type Conns added in v0.1.89 

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

Conns manages a collection of active peer connections for transaction broadcasting. It also maintains a global cache of blocks written to the database.

func NewConns added in v0.1.89 

func NewConns(opts ConnsOptions) *Conns

NewConns creates a new connection manager with a blocks cache.

func (*Conns) Add added in v0.1.89 

func (c *Conns) Add(cn *conn)

Add adds a connection to the manager.

func (*Conns) AddTxs added in v0.1.107 

func (c *Conns) AddTxs(txs []*types.Transaction) []common.Hash

AddTxs adds multiple transactions to the shared cache in a single lock operation. Returns the computed hashes for reuse by the caller.

func (*Conns) Blocks added in v0.1.94 

func (c *Conns) Blocks() *ds.LRU[common.Hash, BlockCache]

Blocks returns the global blocks cache.

func (*Conns) BroadcastBlock added in v0.1.107 

func (c *Conns) BroadcastBlock(block *types.Block, td *big.Int) int

BroadcastBlock broadcasts a full block to peers that don't already know about it and returns the number of peers the block was successfully sent to. If broadcast flags are disabled, this is a no-op.

func (*Conns) BroadcastBlockHashes added in v0.1.107 

func (c *Conns) BroadcastBlockHashes(hashes []common.Hash, numbers []uint64) int

BroadcastBlockHashes enqueues block hashes to per-peer broadcast queues. Each peer has a dedicated goroutine that drains the queue and sends. Returns the number of peers the hashes were enqueued to. If broadcast flags are disabled, this is a no-op.

func (*Conns) BroadcastTx added in v0.1.89 

func (c *Conns) BroadcastTx(tx *types.Transaction) int

BroadcastTx broadcasts a single transaction to all connected peers. Returns the number of peers the transaction was successfully sent to.

func (*Conns) BroadcastTxHashes added in v0.1.107 

func (c *Conns) BroadcastTxHashes(hashes []common.Hash) int

BroadcastTxHashes enqueues transaction hashes to per-peer broadcast queues. Each peer has a dedicated goroutine that drains the queue and batches sends. Returns the number of peers the hashes were enqueued to. If broadcast flags are disabled, this is a no-op.

func (*Conns) BroadcastTxs added in v0.1.89 

func (c *Conns) BroadcastTxs(txs types.Transactions) int

BroadcastTxs broadcasts multiple transactions to all connected peers, filtering out transactions that each peer already knows about. Returns the number of peers the transactions were successfully sent to. If broadcast flags are disabled, this is a no-op.

func (*Conns) GetPeerMessages added in v0.1.104 

func (c *Conns) GetPeerMessages(peerID string) *PeerMessages

GetPeerMessages returns a snapshot of message counts for a specific peer. Returns nil if the peer is not found.

func (*Conns) GetPeerName added in v0.1.104 

func (c *Conns) GetPeerName(peerID string) string

GetPeerName returns the fullname (client identifier) for a specific peer. Returns empty string if the peer is not found.

func (*Conns) GetPeerVersion added in v0.1.107 

func (c *Conns) GetPeerVersion(peerID string) uint

GetPeerVersion returns the negotiated eth protocol version for a specific peer. Returns 0 if the peer is not found.

func (*Conns) HeadBlock added in v0.1.97 

func (c *Conns) HeadBlock() eth.NewBlockPacket

HeadBlock returns the current head block packet.

func (*Conns) KnownBlocksMax added in v0.1.107 

func (c *Conns) KnownBlocksMax() int

KnownBlocksMax returns the maximum size for per-peer known block caches.

func (*Conns) KnownTxsOpts added in v0.1.107 

func (c *Conns) KnownTxsOpts() ds.BloomSetOptions

KnownTxsOpts returns the bloom filter options for per-peer known tx tracking.

func (*Conns) Nodes added in v0.1.89 

func (c *Conns) Nodes() []*enode.Node

Nodes returns all currently connected peer nodes.

func (*Conns) OldestBlock added in v0.1.97 

func (c *Conns) OldestBlock() *types.Header

OldestBlock returns the oldest block the sensor will fetch parents for. This is set once at initialization to the head block and acts as a floor to prevent the sensor from crawling backwards indefinitely.

func (*Conns) PeekTxs added in v0.1.107 

func (c *Conns) PeekTxs(hashes []common.Hash) []*types.Transaction

PeekTxs retrieves multiple transactions from the shared cache without updating LRU ordering. Uses a single read lock for better concurrency when LRU ordering is not needed.

func (*Conns) PeekTxsWithHashes added in v0.1.107 

func (c *Conns) PeekTxsWithHashes(hashes []common.Hash) ([]common.Hash, []*types.Transaction)

PeekTxsWithHashes retrieves multiple transactions with their hashes from the cache. Returns parallel slices of found hashes and transactions. Uses a single read lock.

func (*Conns) PeerConnectedAt added in v0.1.97 

func (c *Conns) PeerConnectedAt(peerID string) time.Time

PeerConnectedAt returns the connection time for a peer by their ID. Returns zero time if the peer is not found.

func (*Conns) Remove added in v0.1.89 

func (c *Conns) Remove(cn *conn)

Remove removes a connection from the manager when a peer disconnects.

func (*Conns) ShouldBroadcastBlockHashes added in v0.1.107 

func (c *Conns) ShouldBroadcastBlockHashes() bool

ShouldBroadcastBlockHashes returns whether block hash broadcasting is enabled.

func (*Conns) ShouldBroadcastBlocks added in v0.1.107 

func (c *Conns) ShouldBroadcastBlocks() bool

ShouldBroadcastBlocks returns whether full block broadcasting is enabled.

func (*Conns) ShouldBroadcastTx added in v0.1.107 

func (c *Conns) ShouldBroadcastTx() bool

ShouldBroadcastTx returns whether full transaction broadcasting is enabled.

func (*Conns) ShouldBroadcastTxHashes added in v0.1.107 

func (c *Conns) ShouldBroadcastTxHashes() bool

ShouldBroadcastTxHashes returns whether transaction hash broadcasting is enabled.

func (*Conns) UpdateHeadBlock added in v0.1.97 

func (c *Conns) UpdateHeadBlock(packet eth.NewBlockPacket) bool

UpdateHeadBlock updates the head block if the provided block is newer. Returns true if the head block was updated, false otherwise.

type ConnsOptions added in v0.1.94 

type ConnsOptions struct {
	BlocksCache                ds.LRUOptions
	TxsCache                   ds.LRUOptions
	KnownTxsBloom              ds.BloomSetOptions
	KnownBlocksMax             int
	Head                       eth.NewBlockPacket
	ShouldBroadcastTx          bool
	ShouldBroadcastTxHashes    bool
	ShouldBroadcastBlocks      bool
	ShouldBroadcastBlockHashes bool
}

ConnsOptions contains configuration options for creating a new Conns manager.

type DialOpts added in v0.1.90 

type DialOpts struct {
	EnableWit  bool
	Port       int
	Addr       net.IP
	PrivateKey *ecdsa.PrivateKey
}

func NewDialOpts added in v0.1.90 

func NewDialOpts() DialOpts

type Direction added in v0.1.91 

type Direction string

Direction represents the direction of a message (sent or received). 

const (
	// MsgReceived represents messages received from peers.
	MsgReceived Direction = "received"
	// MsgSent represents messages sent to peers.
	MsgSent Direction = "sent"

	// PacketSuffix is appended to message names to create packet count metrics.
	PacketSuffix = "Packet"
)

type Disconnect 

type Disconnect struct {
	Reason p2p.DiscReason
}

Disconnect is the RLP structure for a disconnect message.

func (Disconnect) Code 

func (msg Disconnect) Code() int

func (Disconnect) ReqID 

func (msg Disconnect) ReqID() uint64

type Disconnects 

type Disconnects []p2p.DiscReason

Disconnects is the RLP structure for disconnect messages.

func (Disconnects) Code 

func (msg Disconnects) Code() int

func (Disconnects) ReqID 

func (msg Disconnects) ReqID() uint64

type Error 

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

func (*Error) Code 

func (e *Error) Code() int

func (*Error) Error 

func (e *Error) Error() string

func (*Error) ReqID 

func (e *Error) ReqID() uint64

func (*Error) String 

func (e *Error) String() string

func (*Error) Unwrap 

func (e *Error) Unwrap() error

type EthProtocolOptions 

type EthProtocolOptions struct {
	Context     context.Context
	Database    database.Database
	GenesisHash common.Hash
	RPC         string
	SensorID    string
	NetworkID   uint64
	Conns       *Conns
	ForkID      forkid.ID

	// Cache configurations
	RequestsCache ds.LRUOptions
	ParentsCache  ds.LRUOptions

	// Broadcast flags control what gets rebroadcasted to other peers
	ShouldBroadcastTx          bool
	ShouldBroadcastTxHashes    bool
	ShouldBroadcastBlocks      bool
	ShouldBroadcastBlockHashes bool
}

EthProtocolOptions is the options used when creating a new eth protocol.

type GetAccountRange 

type GetAccountRange snap.GetAccountRangePacket

GetAccountRange represents an account range query.

func (GetAccountRange) Code 

func (msg GetAccountRange) Code() int

func (GetAccountRange) ReqID 

func (msg GetAccountRange) ReqID() uint64

type GetBlockBodies 

type GetBlockBodies eth.GetBlockBodiesPacket

GetBlockBodies represents a GetBlockBodies request

func (GetBlockBodies) Code 

func (msg GetBlockBodies) Code() int

func (GetBlockBodies) ReqID 

func (msg GetBlockBodies) ReqID() uint64

type GetBlockHeaders 

type GetBlockHeaders eth.GetBlockHeadersPacket

GetBlockHeaders represents a block header query.

func (GetBlockHeaders) Code 

func (msg GetBlockHeaders) Code() int

func (GetBlockHeaders) ReqID 

func (msg GetBlockHeaders) ReqID() uint64

type GetByteCodes 

type GetByteCodes snap.GetByteCodesPacket

func (GetByteCodes) Code 

func (msg GetByteCodes) Code() int

func (GetByteCodes) ReqID 

func (msg GetByteCodes) ReqID() uint64

type GetPooledTransactions 

type GetPooledTransactions eth.GetPooledTransactionsPacket

func (GetPooledTransactions) Code 

func (msg GetPooledTransactions) Code() int

func (GetPooledTransactions) ReqID 

func (msg GetPooledTransactions) ReqID() uint64

type GetStorageRanges 

type GetStorageRanges snap.GetStorageRangesPacket

func (GetStorageRanges) Code 

func (msg GetStorageRanges) Code() int

func (GetStorageRanges) ReqID 

func (msg GetStorageRanges) ReqID() uint64

type GetTrieNodes 

type GetTrieNodes snap.GetTrieNodesPacket

func (GetTrieNodes) Code 

func (msg GetTrieNodes) Code() int

func (GetTrieNodes) ReqID 

func (msg GetTrieNodes) ReqID() uint64

type GetWitnessPacket added in v0.1.90 

type GetWitnessPacket struct {
	RequestId uint64
	*GetWitnessRequest
}

GetWitnessPacket represents a witness query with request ID wrapping.

func (GetWitnessPacket) Code added in v0.1.90 

func (msg GetWitnessPacket) Code() int

func (GetWitnessPacket) ReqID added in v0.1.90 

func (msg GetWitnessPacket) ReqID() uint64

type GetWitnessRequest added in v0.1.90 

type GetWitnessRequest struct {
	WitnessPages []WitnessPageRequest // Request by list of witness pages
}

GetWitnessRequest represents a list of witnesses query by witness pages.

type Hello 

type Hello struct {
	Version    uint64
	Name       string
	Caps       []p2p.Cap
	ListenPort uint64
	ID         []byte // secp256k1 public key

	// Ignore additional fields (for forward compatibility).
	Rest []rlp.RawValue `rlp:"tail"`
}

Hello is the RLP structure of the protocol handshake.

func (Hello) Code 

func (msg Hello) Code() int

func (Hello) ReqID 

func (msg Hello) ReqID() uint64

type Message 

type Message interface {
	Code() int
	ReqID() uint64
}

type MessageCount 

type MessageCount struct {
	BlockHeaders        int64 `json:"block_headers,omitempty"`
	BlockBodies         int64 `json:"block_bodies,omitempty"`
	Blocks              int64 `json:"blocks,omitempty"`
	BlockHashes         int64 `json:"block_hashes,omitempty"`
	BlockHeaderRequests int64 `json:"block_header_requests,omitempty"`
	BlockBodiesRequests int64 `json:"block_bodies_requests,omitempty"`
	Transactions        int64 `json:"transactions,omitempty"`
	TransactionHashes   int64 `json:"transaction_hashes,omitempty"`
	TransactionRequests int64 `json:"transaction_requests,omitempty"`
	Pings               int64 `json:"pings,omitempty"`
	Errors              int64 `json:"errors,omitempty"`
	Disconnects         int64 `json:"disconnects,omitempty"`
	NewWitness          int64 `json:"new_witness,omitempty"`
	NewWitnessHashes    int64 `json:"new_witness_hashes,omitempty"`
	GetWitnessRequest   int64 `json:"get_witness_request,omitempty"`
	Witness             int64 `json:"witness,omitempty"`
}

MessageCount is used to help the outer goroutine to receive summary of the number and type of messages that were sent. This is used for distributed logging. It can be used to count the different types of messages received across all peer connections to provide a summary.

func (*MessageCount) Clear 

func (mc *MessageCount) Clear()

Clear clears all of the counts from the message counter.

func (*MessageCount) IncrementByName added in v0.1.104 

func (mc *MessageCount) IncrementByName(name string, count int64)

IncrementByName increments the appropriate field based on message name.

func (*MessageCount) IsEmpty 

func (c *MessageCount) IsEmpty() bool

IsEmpty checks whether the sum of all the counts is empty. Make sure to call Load before this method to get an accurate count.

func (*MessageCount) Load 

func (mc *MessageCount) Load() MessageCount

Load takes a snapshot of all the counts in a thread-safe manner. Make sure you call this and read from the returned object.

type NewBlock 

type NewBlock eth.NewBlockPacket

NewBlock is the network packet for the block propagation message.

func (NewBlock) Code 

func (msg NewBlock) Code() int

func (NewBlock) ReqID 

func (msg NewBlock) ReqID() uint64

type NewBlockHashes 

type NewBlockHashes eth.NewBlockHashesPacket

NewBlockHashes is the network packet for the block announcements.

func (NewBlockHashes) Code 

func (msg NewBlockHashes) Code() int

func (NewBlockHashes) ReqID 

func (msg NewBlockHashes) ReqID() uint64

type NewPooledTransactionHashes 

type NewPooledTransactionHashes struct {
	Types  []byte
	Sizes  []uint32
	Hashes []common.Hash
}

NewPooledTransactionHashes is the network packet for the tx hash propagation message.

func (NewPooledTransactionHashes) Code 

func (msg NewPooledTransactionHashes) Code() int

func (NewPooledTransactionHashes) ReqID 

func (msg NewPooledTransactionHashes) ReqID() uint64

type NewPooledTransactionHashes66 

type NewPooledTransactionHashes66 []common.Hash

NewPooledTransactionHashes66 is the network packet for the tx hash propagation message.

func (NewPooledTransactionHashes66) Code 

func (msg NewPooledTransactionHashes66) Code() int

func (NewPooledTransactionHashes66) ReqID 

func (msg NewPooledTransactionHashes66) ReqID() uint64

type NewWitnessHashesPacket added in v0.1.90 

type NewWitnessHashesPacket struct {
	Hashes  []common.Hash
	Numbers []uint64
}

func (NewWitnessHashesPacket) Code added in v0.1.90 

func (msg NewWitnessHashesPacket) Code() int

func (NewWitnessHashesPacket) ReqID added in v0.1.90 

func (msg NewWitnessHashesPacket) ReqID() uint64

type NewWitnessPacket added in v0.1.90 

type NewWitnessPacket struct {
	Witness *stateless.Witness
}

func (NewWitnessPacket) Code added in v0.1.90 

func (msg NewWitnessPacket) Code() int

func (NewWitnessPacket) ReqID added in v0.1.90 

func (msg NewWitnessPacket) ReqID() uint64

type NodeJSON 

type NodeJSON struct {
	URL    string  `json:"url"`
	Hello  *Hello  `json:"hello,omitempty"`
	Status *Status `json:"status,omitempty"`
	Error  string  `json:"error,omitempty"`
	Time   int64   `json:"time,omitempty"`
	Nodes  int     `json:"nodes,omitempty"`
}

type NodeSet 

type NodeSet map[enode.ID][]NodeJSON

type PeerMessages added in v0.1.104 

type PeerMessages struct {
	Received        MessageCount
	Sent            MessageCount
	PacketsReceived MessageCount
	PacketsSent     MessageCount
}

PeerMessages tracks message counts for a single peer connection. This is used to provide per-peer visibility via the API without creating high-cardinality Prometheus metrics.

func NewPeerMessages added in v0.1.104 

func NewPeerMessages() *PeerMessages

NewPeerMessages creates a new PeerMessages instance.

func (*PeerMessages) IncrementReceived added in v0.1.104 

func (pm *PeerMessages) IncrementReceived(name string, count int64)

IncrementReceived increments the received message count.

func (*PeerMessages) IncrementSent added in v0.1.104 

func (pm *PeerMessages) IncrementSent(name string, count int64)

IncrementSent increments the sent message count.

func (*PeerMessages) Load added in v0.1.104 

func (pm *PeerMessages) Load() PeerMessages

Load returns a snapshot of all message counts.

type Ping 

type Ping struct{}

func (Ping) Code 

func (msg Ping) Code() int

func (Ping) ReqID 

func (msg Ping) ReqID() uint64

type Pong 

type Pong struct{}

func (Pong) Code 

func (msg Pong) Code() int

func (Pong) ReqID 

func (msg Pong) ReqID() uint64

type PooledTransactions 

type PooledTransactions eth.PooledTransactionsPacket

func (PooledTransactions) Code 

func (msg PooledTransactions) Code() int

func (PooledTransactions) ReqID 

func (msg PooledTransactions) ReqID() uint64

type Status 

type Status eth.StatusPacket68

Status is the network packet for the status message for eth/64 and later.

func (Status) Code 

func (msg Status) Code() int

func (Status) ReqID 

func (msg Status) ReqID() uint64

type StorageRanges 

type StorageRanges snap.StorageRangesPacket

func (StorageRanges) Code 

func (msg StorageRanges) Code() int

func (StorageRanges) ReqID 

func (msg StorageRanges) ReqID() uint64

type Transactions 

type Transactions eth.TransactionsPacket

func (Transactions) Code 

func (msg Transactions) Code() int

func (Transactions) ReqID 

func (msg Transactions) ReqID() uint64

type TrieNodes 

type TrieNodes snap.TrieNodesPacket

func (TrieNodes) Code 

func (msg TrieNodes) Code() int

func (TrieNodes) ReqID 

func (msg TrieNodes) ReqID() uint64

type WitnessPacketRLPPacket added in v0.1.90 

type WitnessPacketRLPPacket struct {
	RequestId uint64
	WitnessPacketResponse
}

WitnessPacketRLPPacket represents a witness response with request ID wrapping.

func (WitnessPacketRLPPacket) Code added in v0.1.90 

func (msg WitnessPacketRLPPacket) Code() int

func (WitnessPacketRLPPacket) ReqID added in v0.1.90 

func (msg WitnessPacketRLPPacket) ReqID() uint64

type WitnessPacketResponse added in v0.1.90 

type WitnessPacketResponse []WitnessPageResponse

WitnessPacketResponse represents a witness response, to use when we already have the witness rlp encoded.

type WitnessPageRequest added in v0.1.90 

type WitnessPageRequest struct {
	Hash common.Hash // BlockHash
	Page uint64      // Starts on 0
}

type WitnessPageResponse added in v0.1.90 

type WitnessPageResponse struct {
	Data       []byte
	Hash       common.Hash
	Page       uint64 // Starts on 0; If Page >= TotalPages means the request was invalid and the response is an empty data array
	TotalPages uint64 // Length of pages
}

Source Files

View all Source files

Directories

Path Synopsis

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.