feed source pure

 1const (
 2	// TypeStatic indicates a feed cannot be changed once the first value is committed.
 3	TypeStatic Type = iota
 4	// TypeContinuous indicates a feed can continuously ingest values and will publish
 5	// a new value on request using the values it has ingested.
 6	TypeContinuous
 7	// TypePeriodic indicates a feed can accept one or more values within a certain period
 8	// and will proceed to commit these values at the end up each period to produce an
 9	// aggregate value before starting a new period.
10	TypePeriodic
11)

1var ErrUndefined = errors.New("undefined feed")

1type Task interface {
2	MarshalJSON() ([]byte, error)
3}

1type Type int

1type Value struct {
2	String string
3	Time   time.Time
4}