fetcher

type Callback ¶

type Callback struct {
	PushEvent      PushEventFn
	OnlyInterested FilterInterestedFn
	DropPeer       DropPeerFn

	HeavyCheck *heavycheck.Checker
	FirstCheck func(*inter.Event) error
}

type DropPeerFn ¶

type DropPeerFn func(peer string)

DropPeerFn is a callback type for dropping a peer detected as malicious.

type EventsRequesterFn ¶

type EventsRequesterFn func(hash.Events) error

EventsRequesterFn is a callback type for sending a event retrieval request.

type Fetcher ¶

type Fetcher struct {
	logger.Periodic
	// contains filtered or unexported fields
}

Fetcher is responsible for accumulating event announcements from various peers and scheduling them for retrieval.

func New(callback Callback) *Fetcher

func (f *Fetcher) Enqueue(peer string, inEvents inter.Events, t time.Time, fetchEvents EventsRequesterFn) error

func (f *Fetcher) Notify(peer string, hashes hash.Events, time time.Time, fetchEvents EventsRequesterFn) error

func (f *Fetcher) Overloaded() bool

func (f *Fetcher) OverloadedPeer(peer string) bool

func (f *Fetcher) Start()

func (f *Fetcher) Stop()

type FilterInterestedFn ¶

type FilterInterestedFn func(ids hash.Events) hash.Events

FilterInterestedFn returns only event which may be requested.

type PushEventFn ¶

type PushEventFn func(e *inter.Event, peer string)

PushEventFn is a callback type to connect a received event