candidate

Documentation

Index

• func SanityCheckCandidate(cm block.Block) error
• func Validate(m message.Message) 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 SanityCheckCandidate

func SanityCheckCandidate(cm block.Block) error

SanityCheckCandidate makes sure the hash is correct, to avoid malicious nodes from overwriting the candidate block for a specific hash.

func Validate

func Validate(m message.Message) error

Validate an incoming Candidate message.

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.