verify

type Parameters struct {
	// NReplicas is the required number of replicas (in addition to the self peer's replica) of a
	// document to consider it fully verified.
	NReplicas uint

	// ExcludeSelf indicates whether the verify will exclude a replica hosted by the verifier.
	ExcludeSelf bool

	// NClosestResponses is the required number of peers closest to the key we need to receive
	// responses from
	NClosestResponses uint

	// NMaxErrors is the maximum number of errors tolerated when querying peers during the search
	NMaxErrors uint

	// Concurrency is the number of concurrent queries to use in search
	Concurrency uint

	// Timeout for queries to individual peers
	Timeout time.Duration
}

type ResponseProcessor interface {
	// Process handles an api.VerifyResponse, adding newly discovered peers to the unqueried
	// ClosestPeers heap and adding from to the list of replicas when its MAC matches the expected
	// value.
	Process(response *api.VerifyResponse, from peer.Peer, expectedMAC []byte, verify *Verify) error
}

type Result struct {
	// Replicas gives the peers with verified replicas.
	Replicas map[string]peer.Peer

	// Closest is a heap of the responding peers without a replica found closest to the key
	Closest search.FarthestPeers

	// Unqueried is a heap of peers that were not yet queried
	Unqueried search.ClosestPeers

	// Queried is a set of all peers (keyed by peer.ID().String()) that have been queried (but
	// haven't yet necessarily responded or errored)
	Queried map[string]struct{}

	// Responded is a map of all peers that responded during verification
	Responded map[string]peer.Peer

	// Errored contains the errors received by each peer (via string representation of peer ID)
	Errored map[string]error

	// FatalErr is a fatal error that occurred during the search
	FatalErr error
}

type Verifier interface {
	// Verify executes the verification.
	Verify(verify *Verify, seeds []peer.Peer) error
}

type Verify struct {
	// Key of document to verify
	Key id.ID

	Value []byte

	ExpectedMAC []byte

	// CreateRq creates new Verify requests
	CreateRq func() *api.VerifyRequest

	// Result contains the verification result
	Result *Result

	// Params of the verification
	Params *Parameters
	// contains filtered or unexported fields
}