sync

package

Go to main page

Versions in this module

v0

v0.9.0

Mar 1, 2024

Changes in this version

type Network

+ BlockAnnounceHandshake func(*types.Header) error

v0.8.0

Dec 11, 2023

Changes in this version

+ var ErrStopTimeout = errors.New("stop timeout")

type BlockState

+ Range func(startHash, endHash common.Hash) (hashes []common.Hash, err error)

+ RangeInMemory func(start, end common.Hash) ([]common.Hash, error)

+ type BuildBlockRuntime interface

+ ApplyExtrinsic func(data types.Extrinsic) ([]byte, error)

+ FinalizeBlock func() (*types.Header, error)

+ InherentExtrinsics func(data []byte) ([]byte, error)

+ InitializeBlock func(header *types.Header) error

+ ValidateTransaction func(e types.Extrinsic) (*transaction.Validity, error)

type Config

+ BadBlocks []string

+ RequestMaker network.RequestMaker

+ type MockRequestMaker struct

+ func NewMockRequestMaker(ctrl *gomock.Controller) *MockRequestMaker

+ func (m *MockRequestMaker) Do(arg0 peer.ID, arg1 network.Message, arg2 network.ResponseMessage) error

+ func (m *MockRequestMaker) EXPECT() *MockRequestMakerMockRecorder

+ type MockRequestMakerMockRecorder struct

+ func (mr *MockRequestMakerMockRecorder) Do(arg0, arg1, arg2 any) *gomock.Call

type Network

+ AllConnectedPeersIDs func() []peer.ID

+ type Telemetry interface

+ SendMessage func(msg json.Marshaler)

v0.7.0

Nov 23, 2022

Changes in this version

+ func BuildBlock(t *testing.T, instance runtime.Instance, parent *types.Header, ...) *types.Block

+ type BabeVerifier interface

+ VerifyBlock func(header *types.Header) error

+ type BlockImportHandler interface

+ HandleBlockImport func(block *types.Block, state *rtstorage.TrieState, announce bool) error

type BlockState

+ GetAllBlocksAtNumber func(num uint) ([]common.Hash, error)

+ GetBlockByHash func(common.Hash) (*types.Block, error)

+ GetFinalisedNotifierChannel func() chan *types.FinalisationInfo

+ GetHashByNumber func(blockNumber uint) (common.Hash, error)

+ GetHeaderByNumber func(num uint) (*types.Header, error)

+ GetHighestFinalisedHeader func() (*types.Header, error)

+ GetRuntime func(blockHash common.Hash) (instance runtime.Instance, err error)

+ IsDescendantOf func(parent, child common.Hash) (bool, error)

+ SetFinalisedHash func(hash common.Hash, round, setID uint64) error

+ StoreRuntime func(common.Hash, runtime.Instance)

+ type ChainProcessor interface

+ type ChainSync interface

+ type CodeSubstitutedState interface

+ LoadCodeSubstitutedBlockHash func() common.Hash

+ StoreCodeSubstitutedBlockHash func(hash common.Hash) error

type Config

+ BabeVerifier BabeVerifier

+ BlockImportHandler BlockImportHandler

+ FinalityGadget FinalityGadget

+ MaxPeers int

+ MinPeers int

+ Network Network

+ SlotDuration time.Duration

+ Telemetry telemetry.Client

+ type DisjointBlockSet interface

+ type FinalityGadget interface

+ VerifyBlockJustification func(common.Hash, []byte) ([]byte, error)

+ type Network interface

+ DoBlockRequest func(to peer.ID, req *network.BlockRequestMessage) (*network.BlockResponseMessage, error)

+ Peers func() []common.PeerInfo

+ ReportPeer func(change peerset.ReputationChange, p peer.ID)

+ type RuntimeInstance interface

+ ApplyExtrinsic func(data types.Extrinsic) ([]byte, error)

+ BabeConfiguration func() (*types.BabeConfiguration, error)

+ CheckInherents func()

+ DecodeSessionKeys func(enc []byte) ([]byte, error)

+ Exec func(function string, data []byte) ([]byte, error)

+ ExecuteBlock func(block *types.Block) ([]byte, error)

+ FinalizeBlock func() (*types.Header, error)

+ GenerateSessionKeys func()

+ GetCodeHash func() common.Hash

+ GrandpaAuthorities func() ([]types.Authority, error)

+ InherentExtrinsics func(data []byte) ([]byte, error)

+ InitializeBlock func(header *types.Header) error

+ Keystore func() *keystore.GlobalKeystore

+ Metadata func() ([]byte, error)

+ NetworkService func() runtime.BasicNetwork

+ NodeStorage func() runtime.NodeStorage

+ OffchainWorker func()

+ PaymentQueryInfo func(ext []byte) (*types.RuntimeDispatchInfo, error)

+ RandomSeed func()

+ SetContextStorage func(s runtime.Storage)

+ Stop func()

+ UpdateRuntimeCode func([]byte) error

+ ValidateTransaction func(e types.Extrinsic) (*transaction.Validity, error)

+ Validator func() bool

+ Version func() runtime.Version

type Service

+ func (s *Service) HandleBlockAnnounceHandshake(from peer.ID, msg *network.BlockAnnounceHandshake) error

+ func (s *Service) HighestBlock() uint

+ func (s *Service) Start() error

+ func (s *Service) Stop() error

v0.6.0

Apr 8, 2021

v0.5.2

Apr 7, 2021

v0.5.1

Apr 7, 2021

v0.5.0

Apr 7, 2021

v0.4.1

Apr 14, 2021

v0.4.0

Apr 6, 2021

Changes in this version

type Service

+ func (s *Service) SetSyncing(syncing bool)

type StorageState

+ SetSyncing func(bool)

v0.3.2

Mar 22, 2021

Changes in this version

type BlockState

+ AddBlockToBlockTree func(header *types.Header) error

v0.3.1

Mar 8, 2021

Changes in this version

type BlockState

+ SetFinalizedHash func(hash common.Hash, round, setID uint64) error

+ SetJustification func(hash common.Hash, data []byte) error

v0.3.0

Feb 25, 2021

Changes in this version

+ var ErrEmptyRuntimeCode = errors.New("new :code is empty")

+ var ErrInvalidBlockRequest = errors.New("invalid block request")

+ var ErrNilBlockData = errors.New("got nil BlockData")

type BlockProducer

+ SetRuntime func(rt runtime.Instance)

type BlockState

+ BestBlockHeader func() (*types.Header, error)

+ HasBlockBody func(hash common.Hash) (bool, error)

type Service

+ func (s *Service) IsSynced() bool

+ func (s *Service) ProcessBlockData(data []*types.BlockData) error

type StorageState

+ LoadCodeHash func(*common.Hash) (common.Hash, error)

v0.2.0

Nov 10, 2020

Changes in this version

+ var ErrInvalidBlock = errors.New("could not verify block")

+ var ErrNilBlockState = errors.New("cannot have nil BlockState")

+ var ErrNilRuntime = errors.New("cannot have nil runtime")

+ var ErrNilStorageState = errors.New("cannot have nil StorageState")

+ var ErrNilVerifier = errors.New("cannot have nil Verifier")

+ var ErrServiceStopped = errors.New("service has been stopped")

+ func ErrNilChannel(s string) error

+ type BlockProducer interface

+ Pause func() error

+ Resume func() error

+ type BlockState interface

+ AddBlock func(*types.Block) error

+ BestBlockHash func() common.Hash

+ BestBlockNumber func() (*big.Int, error)

+ CompareAndSetBlockData func(bd *types.BlockData) error

+ GetBlockBody func(common.Hash) (*types.Body, error)

+ GetBlockByNumber func(*big.Int) (*types.Block, error)

+ GetHeader func(common.Hash) (*types.Header, error)

+ GetJustification func(common.Hash) ([]byte, error)

+ GetMessageQueue func(common.Hash) ([]byte, error)

+ GetReceipt func(common.Hash) ([]byte, error)

+ HasHeader func(hash common.Hash) (bool, error)

+ SetHeader func(*types.Header) error

+ SubChain func(start, end common.Hash) ([]common.Hash, error)

+ type Config struct

+ BlockProducer BlockProducer

+ BlockState BlockState

+ DigestHandler DigestHandler

+ LogLvl log.Lvl

+ Runtime runtime.LegacyInstance

+ StorageState StorageState

+ TransactionState TransactionState

+ Verifier Verifier

+ type DigestHandler interface

+ HandleConsensusDigest func(*types.ConsensusDigest) error

+ Start func()

+ Stop func()

+ type Service struct

+ func NewService(cfg *Config) (*Service, error)

+ func (s *Service) CreateBlockResponse(blockRequest *network.BlockRequestMessage) (*network.BlockResponseMessage, error)

+ func (s *Service) HandleBlockAnnounce(msg *network.BlockAnnounceMessage) *network.BlockRequestMessage

+ func (s *Service) HandleBlockResponse(msg *network.BlockResponseMessage) *network.BlockRequestMessage

+ func (s *Service) HandleSeenBlocks(blockNum *big.Int) *network.BlockRequestMessage

+ type StorageState interface

+ StoreTrie func(root common.Hash, ts *state.TrieState) error

+ TrieState func(root *common.Hash) (*state.TrieState, error)

+ type TransactionState interface

+ RemoveExtrinsic func(ext types.Extrinsic)

+ type Verifier interface

+ VerifyBlock func(header *types.Header) (bool, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL