jobs

Documentation

Index

• Constants
• func ExploreJob(in chan dht.Entry, data ...interface{}) <-chan dht.Entry
• type Job

Constants

const ExploreBufferSize = 100

const ExploreFrequency = time.Minute * 2

Functions

func ExploreJob

func ExploreJob(in chan dht.Entry, data ...interface{}) <-chan dht.Entry

This job runs every two minutes, and tries to build the netdb with as many entries as it possibly can

Types

type Job

type Job func(<-chan interface{}, ...interface{}) <-chan interface{}

Takes in data, returns a stream of data