Versions in this module Expand all Collapse all v0 v0.3.0 Dec 22, 2020 Changes in this version + type Submitter interface + Submit func(ctx context.Context, src interface{}) (err error) v0.2.7 Dec 15, 2020 Changes in this version + func GetKREIngestorName() string + type Loader struct + func NewLoader(hist history.Reader, committer ingestion.Committer, ...) *Loader + func (l *Loader) Process(ctx context.Context, interval time.Duration) error