source

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

type Error struct {
	SourceURL model.SourceURL
	Error     error
}

type Event struct {
	Source Source
	Event  string
}

type Metadata struct {
	Name        string
	Type        reflect.Type
	CanHandle   func(url model.SourceURL) bool
	Creator     func(since *time.Time, sourceURL model.SourceURL) (*Source, error)
	ExampleURLs []string
}

type Source interface {
	// Sigil represents the type of source in a single character.
	Sigil() rune
	// URL is the URL from which the events come.
	URL() model.SourceURL
	// Start collecting events.
	Start(wg *sync.WaitGroup, running func() bool, srcChan chan Event, snkChan chan model.SinkEvent, errChan chan Error) error
}