loading

Documentation

Index

• type BlockPackage
• type IDsPackage
• type Loader
  • func NewLoader(registry *peers.Registry, linkage *chains.Linkage, idsCh <-chan IDsPackage, ...) *Loader
  • func (l *Loader) Fail()
  • func (l *Loader) OK()
  • func (l *Loader) Run(ctx context.Context)
  • func (l *Loader) Shutdown()
• type Reporter

Types

type BlockPackage

type BlockPackage struct {
	Peer  netip.Addr
	Block *proto.Block
}

type IDsPackage

type IDsPackage struct {
	Peer netip.Addr
	IDs  []proto.BlockID
}

type Loader

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

func NewLoader

func NewLoader(
	registry *peers.Registry, linkage *chains.Linkage, idsCh <-chan IDsPackage, blockCh <-chan BlockPackage,
) *Loader

func (*Loader) Fail

func (l *Loader) Fail()

func (*Loader) OK

func (l *Loader) OK()

func (*Loader) Run

func (l *Loader) Run(ctx context.Context)

func (*Loader) Shutdown

func (l *Loader) Shutdown()

type Reporter

type Reporter interface {
	OK()
	Fail()
}