monitor

type Dialer ¶

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

Dialer encapsulates a libp2p host that dials peers.

func NewDialer(h host.Host, conf *config.Monitor) (*Dialer, error)

func (d *Dialer) StartDialing(ctx context.Context, dialQueue *queue.FIFO[peer.AddrInfo], resultsQueue *queue.FIFO[Result])

type Result ¶

type Result struct {
	DialerID string

	// The dialed peer
	Peer peer.AddrInfo

	// If error is set the peer was not dialable
	Error error

	// The above error transferred to a known error
	DialError string

	// When was the dial started
	DialStartTime time.Time

	// When did this crawl end
	DialEndTime time.Time
}

Result captures data that is gathered from pinging a single peer.

func (r *Result) DialDuration() time.Duration

type Scheduler ¶

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

The Scheduler handles the scheduling and managing of

a) dialers - They consume a queue of peer address information, visit them and publish their results
             on a separate results queue. This results queue is consumed by this scheduler and further
             processed

func NewScheduler(conf *config.Monitor, dbc *db.DBClient) (*Scheduler, error)

func (s *Scheduler) StartMonitoring(ctx context.Context) error