collector.go

package core

import (
	"fmt"
)

// A Collector schedules the execution of various Jobs.
type Collector struct {
	// The Importer we forward the ULO/RDF bytes to.
	im Importer

	// Collection of all ever sumbmitted jobs. Aquire
	// mu before accessing this collection.
	jobs JobMap
}

func (c *Collector) Submit(j *Job) error {
	id := j.Id()

	if _, loaded := c.jobs.LoadOrStore(id, j); loaded {
		return fmt.Errorf("Id=%v already submitted", id)
	}

	go j.Collect(c)
	return nil
}