Documentation
¶
Overview ¶
Package sync TODO(3147): Add details on how sync works.
Index ¶
- func ReadChunkedBlock(stream libp2pcore.Stream, p2p p2p.P2P) (*eth.BeaconBlock, error)
- func ReadStatusCode(stream io.Reader, encoding encoder.NetworkEncoding) (uint8, string, error)
- func WriteChunk(stream libp2pcore.Stream, encoding encoder.NetworkEncoding, msg interface{}) error
- type Checker
- type Config
- type RegularSync
- type StatusTracker
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ReadChunkedBlock ¶
func ReadChunkedBlock(stream libp2pcore.Stream, p2p p2p.P2P) (*eth.BeaconBlock, error)
ReadChunkedBlock handles each response chunk that is sent by the peer and converts it into a beacon block.
func ReadStatusCode ¶
ReadStatusCode response from a RPC stream.
func WriteChunk ¶
func WriteChunk(stream libp2pcore.Stream, encoding encoder.NetworkEncoding, msg interface{}) error
WriteChunk object to stream. response_chunk ::= | <result> | <encoding-dependent-header> | <encoded-payload>
Types ¶
type Checker ¶
Checker defines a struct which can verify whether a node is currently synchronizing a chain with the rest of peers in the network.
type Config ¶
type Config struct {
P2P p2p.P2P
DB db.Database
Operations *operations.Service
Chain blockchainService
InitialSync Checker
}
Config to set up the regular sync service.
type RegularSync ¶
type RegularSync struct {
// contains filtered or unexported fields
}
RegularSync service is responsible for handling all run time p2p related operations as the main entry point for network messages.
func (*RegularSync) Status ¶
func (r *RegularSync) Status() error
Status of the currently running regular sync service.
Source Files
¶
- deadlines.go
- doc.go
- error.go
- log.go
- metrics.go
- pending_blocks_queue.go
- rpc.go
- rpc_beacon_blocks_by_range.go
- rpc_beacon_blocks_by_root.go
- rpc_chunked_response.go
- rpc_goodbye.go
- rpc_status.go
- service.go
- subscriber.go
- subscriber_beacon_attestation.go
- subscriber_beacon_blocks.go
- subscriber_handlers.go
- validate_attester_slashing.go
- validate_beacon_attestation.go
- validate_beacon_blocks.go
- validate_proposer_slashing.go
- validate_voluntary_exit.go
Directories
¶
| Path | Synopsis |
|---|---|
|
Package peerstatus is a threadsafe global cache to store recent peer status messages for access across multiple services.
|
Package peerstatus is a threadsafe global cache to store recent peer status messages for access across multiple services. |
Click to show internal directories.
Click to hide internal directories.