sync_internal

Documentation

Index

• Variables
• type BlockApplied
• type Blocks
• 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) (Internal, Blocks, Eof)
  • 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 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) (Internal, Blocks, Eof)

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)
}