layerfetcher

Documentation

Overview

Package layerfetcher fetches layers from remote peers

Index

• Variables
• type Config
  • func DefaultConfig() Config
• type Future
  • func (f *Future) Result() fetch.HashDataPromiseResult
• type LayerPromiseResult
• type Logic
  • func NewLogic(ctx context.Context, cfg Config, blocks blockHandler, atxs atxHandler, ...) *Logic
  • func (l *Logic) AddDBs(blockDB, AtxDB, TxDB, poetDB database.Getter)
  • func (l *Logic) Close()
  • func (l *Logic) FetchAtx(ctx context.Context, id types.ATXID) error
  • func (l *Logic) FetchBlock(ctx context.Context, id types.BlockID) error
  • func (l *Logic) GetAtxs(ctx context.Context, IDs []types.ATXID) error
  • func (l *Logic) GetBallots(context.Context, []types.BallotID) error
  • func (l *Logic) GetBlocks(ctx context.Context, IDs []types.BlockID) error
  • func (l *Logic) GetEpochATXs(ctx context.Context, id types.EpochID) error
  • func (l *Logic) GetPoetProof(ctx context.Context, id types.Hash32) error
  • func (l *Logic) GetTxs(ctx context.Context, IDs []types.TransactionID) error
  • func (l *Logic) IsSynced(context.Context) bool
  • func (l *Logic) ListenToGossip() bool
  • func (l *Logic) PollLayerContent(ctx context.Context, layerID types.LayerID) chan LayerPromiseResult
  • func (l *Logic) Start()
• type TxProcessor

Variables

var (
	// ErrNoPeers is returned when node has no peers.
	ErrNoPeers = errors.New("no peers")
	// ErrInternal is returned from the peer when the peer encounters an internal error.
	ErrInternal = errors.New("unspecified error returned by peer")
	// ErrBlockNotFetched is returned when at least one block is not fetched successfully.
	ErrBlockNotFetched = errors.New("block not fetched")
)

Types

type Config

type Config struct {
	RequestTimeout int
	GoldenATXID    types.ATXID
}

Config defines configuration for layer fetching logic.

func DefaultConfig

func DefaultConfig() Config

DefaultConfig returns default configuration for layer fetching logic.

type Future

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

Future is a preparation for using actual futures in the code, this will allow to truly execute asynchronous reads and receive result only when needed.

func (*Future) Result

func (f *Future) Result() fetch.HashDataPromiseResult

Result actually evaluates the result of the fetch task.

type LayerPromiseResult

type LayerPromiseResult struct {
	Err   error
	Layer types.LayerID
}

LayerPromiseResult is the result of trying to fetch data for an entire layer.

type Logic

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

Logic is the struct containing components needed to follow layer fetching logic.

func NewLogic

func NewLogic(ctx context.Context, cfg Config, blocks blockHandler, atxs atxHandler, poet poetDB, atxIDs atxIDsDB, txs TxProcessor,
	host network, fetcher fetch.Fetcher, layers layerDB, log log.Log) *Logic

NewLogic creates a new instance of layer fetching logic.

func (*Logic) AddDBs

func (l *Logic) AddDBs(blockDB, AtxDB, TxDB, poetDB database.Getter)

AddDBs adds dbs that will be queried when sync requests are received. these databases will be exposed to external callers.

func (*Logic) Close

func (l *Logic) Close()

Close closes all running workers.

func (*Logic) FetchAtx

func (l *Logic) FetchAtx(ctx context.Context, id types.ATXID) error

FetchAtx returns error if ATX was not found.

func (*Logic) FetchBlock

func (l *Logic) FetchBlock(ctx context.Context, id types.BlockID) error

FetchBlock gets data for a single block id and validates it.

func (*Logic) GetAtxs

func (l *Logic) GetAtxs(ctx context.Context, IDs []types.ATXID) error

GetAtxs gets the data for given atx ids IDs and validates them. returns an error if at least one ATX cannot be fetched.

func (*Logic) GetBallots

func (l *Logic) GetBallots(context.Context, []types.BallotID) error

GetBallots gets data for the specified BallotIDs and validates them.

func (*Logic) GetBlocks

func (l *Logic) GetBlocks(ctx context.Context, IDs []types.BlockID) error

GetBlocks gets the data for given block ids and validates the blocks. returns an error if a single atx failed to be fetched or validated.

func (*Logic) GetEpochATXs

func (l *Logic) GetEpochATXs(ctx context.Context, id types.EpochID) error

GetEpochATXs fetches all atxs received by peer for given layer.

func (*Logic) GetPoetProof

func (l *Logic) GetPoetProof(ctx context.Context, id types.Hash32) error

GetPoetProof gets poet proof from remote peer.

func (*Logic) GetTxs

func (l *Logic) GetTxs(ctx context.Context, IDs []types.TransactionID) error

GetTxs fetches the txs provided as IDs and validates them, returns an error if one TX failed to be fetched.

func (*Logic) IsSynced

func (l *Logic) IsSynced(context.Context) bool

IsSynced indicates if this node is synced.

func (*Logic) ListenToGossip

func (l *Logic) ListenToGossip() bool

ListenToGossip indicates if node is currently accepting packets from gossip.

func (*Logic) PollLayerContent

func (l *Logic) PollLayerContent(ctx context.Context, layerID types.LayerID) chan LayerPromiseResult

PollLayerContent polls peers for the content of a given layer ID. it returns a channel for the caller to be notified when responses are received from all peers.

func (*Logic) Start

func (l *Logic) Start()

Start starts layerFetcher logic and fetch component.

type TxProcessor

type TxProcessor interface {
	HandleSyncTransaction(data []byte) error
}

TxProcessor is an interface for handling TX data received in sync.