source

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

type Creator func(since *time.Time, sourceURL event.SourceURL) ([]Source, error)

type Error struct {
	SourceURL event.SourceURL
	Error     error
}

type Event struct {
	Source Source
	Event  string
}

type Metadata struct {
	Name        string
	Type        reflect.Type
	CanHandle   func(url event.SourceURL) bool
	Creator     Creator
	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() event.SourceURL
	// Start collecting events.
	Start(wg *sync.WaitGroup, running func() bool, srcChan chan Event, snkChan chan event.SinkEvent, errChan chan Error) error
}