network

type API ¶

type API interface {
	minerprotocols.API
	peeragents.API
}

type Surveyer ¶

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

An Surveyer observes features of the filecoin network

func NewSurveyer(api API, storage model.Storage, interval time.Duration, name string, tasks []string) (*Surveyer, error)

func (s *Surveyer) Details() (string, map[string]interface{})

func (s *Surveyer) Done() <-chan struct{}

func (s *Surveyer) Run(ctx context.Context) error

func (s *Surveyer) Tick(ctx context.Context) error

type Task ¶

type Task interface {
	Process(ctx context.Context) (model.Persistable, error)
	Close() error
}

type TaskResult ¶

type TaskResult struct {
	Task        string
	Error       error
	Data        model.Persistable
	StartedAt   time.Time
	CompletedAt time.Time
}

A TaskResult is either some data to persist or an error which indicates that the task did not complete. Partial completions are possible provided the Data contains a persistable log of the results.