candidate

Documentation

Index

• func Validate(m message.Message) error
• func ValidateCandidate(cm block.Block) error
• type Requestor
  • func NewRequestor(publisher eventbus.Publisher) *Requestor
  • func (r *Requestor) ProcessCandidate(srcPeerID string, msg message.Message) ([]bytes.Buffer, error)
  • func (r *Requestor) RequestCandidate(ctx context.Context, hash []byte) (block.Block, error)

Functions

func Validate

func Validate(m message.Message) error

Validate an incoming Candidate message.

func ValidateCandidate

func ValidateCandidate(cm block.Block) error

ValidateCandidate makes sure the hash and root are correct, to avoid malicious nodes from overwriting the candidate block for a specific hash.

Types

type Requestor

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

Requestor serves to retrieve certain Candidate messages from peers in the network.

func NewRequestor

func NewRequestor(publisher eventbus.Publisher) *Requestor

NewRequestor returns an initialized Requestor struct.

func (*Requestor) ProcessCandidate

func (r *Requestor) ProcessCandidate(srcPeerID string, msg message.Message) ([]bytes.Buffer, error)

ProcessCandidate will process a received Candidate message. Invalid and non-matching Candidate messages are discarded.

func (*Requestor) RequestCandidate

func (r *Requestor) RequestCandidate(ctx context.Context, hash []byte) (block.Block, error)

RequestCandidate will attempt to fetch a Candidate message for a given hash from the network.