sync_internal

Documentation

Index

• Variables
• type BlockApplied
• type Blocks
• type ChangePeerNeeded
• type Eof
• type Internal
  • func InternalFromLastSignatures(p extension.PeerExtension, signatures *signatures.ReverseOrdering) Internal
  • func NewInternal(orderedBlocks *ordered_blocks.OrderedBlocks, ...) Internal
  • func (a Internal) AvailableCount() int
  • func (a Internal) Block(block *proto.Block) (Internal, error)
  • func (a Internal) BlockIDs(p PeerExtension, ids []proto.BlockID) (Internal, error)
  • func (a Internal) Blocks(p peerExtension, needToChangePeerSyncWithFunc func() bool) (Internal, Blocks, Eof, ChangePeerNeeded)
  • func (a Internal) RequestedCount() int
  • func (a Internal) WaitingForSignatures() bool
• type PeerExtension

Variables

var NoSignaturesExpectedErr = proto.NewInfoMsg(errors.New("no signatures expected"))

var UnexpectedBlockErr = proto.NewInfoMsg(errors.New("unexpected block"))

Types

type BlockApplied

type BlockApplied bool

type Blocks

type Blocks []*proto.Block

type ChangePeerNeeded

type ChangePeerNeeded = bool

type Eof

type Eof = bool

type Internal

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

func InternalFromLastSignatures

func InternalFromLastSignatures(p extension.PeerExtension, signatures *signatures.ReverseOrdering) Internal

func NewInternal

func NewInternal(orderedBlocks *ordered_blocks.OrderedBlocks, respondedSignatures *signatures.ReverseOrdering, waitingForSignatures bool) Internal

func (Internal) AvailableCount

func (a Internal) AvailableCount() int

func (Internal) Block

func (a Internal) Block(block *proto.Block) (Internal, error)

func (Internal) BlockIDs

func (a Internal) BlockIDs(p PeerExtension, ids []proto.BlockID) (Internal, error)

func (Internal) Blocks

func (a Internal) Blocks(p peerExtension, needToChangePeerSyncWithFunc func() bool) (Internal, Blocks, Eof, ChangePeerNeeded)

func (Internal) RequestedCount

func (a Internal) RequestedCount() int

func (Internal) WaitingForSignatures

func (a Internal) WaitingForSignatures() bool

type PeerExtension

type PeerExtension interface {
	AskBlocksIDs(id []proto.BlockID)
	AskBlock(id proto.BlockID)
}