bootstrap

Documentation

Index

• type Bootstrapper
  • func (b *Bootstrapper) Connected(nodeID ids.ShortID, nodeVersion version.Application) error
  • func (b *Bootstrapper) CurrentAcceptedFrontier() ([]ids.ID, error)
  • func (b *Bootstrapper) Disconnected(nodeID ids.ShortID) error
  • func (b *Bootstrapper) FilterAccepted(containerIDs []ids.ID) []ids.ID
  • func (b *Bootstrapper) ForceAccepted(acceptedContainerIDs []ids.ID) error
  • func (b *Bootstrapper) GetAncestorsFailed(vdr ids.ShortID, requestID uint32) error
  • func (b *Bootstrapper) Initialize(config Config, onFinished func() error, namespace string, ...) error
  • func (b *Bootstrapper) MultiPut(vdr ids.ShortID, requestID uint32, blks [][]byte) error
  • func (b *Bootstrapper) Timeout() error
• type Config

Types

type Bootstrapper

type Bootstrapper struct {
	common.Bootstrapper
	common.Fetcher

	// Blocked tracks operations that are blocked on blocks
	Blocked *queue.JobsWithMissing

	VM block.ChainVM

	Bootstrapped func()
	// contains filtered or unexported fields
}

func (*Bootstrapper) Connected

func (b *Bootstrapper) Connected(nodeID ids.ShortID, nodeVersion version.Application) error

Connected implements the Engine interface.

func (*Bootstrapper) CurrentAcceptedFrontier

func (b *Bootstrapper) CurrentAcceptedFrontier() ([]ids.ID, error)

CurrentAcceptedFrontier returns the last accepted block

func (*Bootstrapper) Disconnected

func (b *Bootstrapper) Disconnected(nodeID ids.ShortID) error

Disconnected implements the Engine interface.

func (*Bootstrapper) FilterAccepted

func (b *Bootstrapper) FilterAccepted(containerIDs []ids.ID) []ids.ID

FilterAccepted returns the blocks in [containerIDs] that we have accepted

func (*Bootstrapper) ForceAccepted

func (b *Bootstrapper) ForceAccepted(acceptedContainerIDs []ids.ID) error

func (*Bootstrapper) GetAncestorsFailed

func (b *Bootstrapper) GetAncestorsFailed(vdr ids.ShortID, requestID uint32) error

GetAncestorsFailed is called when a GetAncestors message we sent fails

func (*Bootstrapper) Initialize

func (b *Bootstrapper) Initialize(
	config Config,
	onFinished func() error,
	namespace string,
	registerer prometheus.Registerer,
) error

Initialize this engine.

func (*Bootstrapper) MultiPut

func (b *Bootstrapper) MultiPut(vdr ids.ShortID, requestID uint32, blks [][]byte) error

MultiPut handles the receipt of multiple containers. Should be received in response to a GetAncestors message to [vdr] with request ID [requestID]

func (*Bootstrapper) Timeout

func (b *Bootstrapper) Timeout() error

type Config

type Config struct {
	common.Config

	// Blocked tracks operations that are blocked on blocks
	Blocked *queue.JobsWithMissing

	VM block.ChainVM

	Bootstrapped func()
}