source

Documentation

Index

• type BaseSource
  • func New(sigil rune, sourceURL event.SourceURL) BaseSource
  • func (b BaseSource) Sigil() rune
  • func (b BaseSource) Start(_ *sync.WaitGroup, _ func() bool, _ chan Event, _ chan event.SinkEvent, ...) error
  • func (b BaseSource) URL() event.SourceURL
• type Creator
  • func Single(f func(since *time.Time, sourceURL event.SourceURL) (*Source, error)) Creator
• type Error
• type Event
• type Metadata
• type Source

Types

type BaseSource

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

BaseSource ...

func New

func New(sigil rune, sourceURL event.SourceURL) BaseSource

New base Source.

func (BaseSource) Sigil

func (b BaseSource) Sigil() rune

Sigil ...

func (BaseSource) Start

func (b BaseSource) Start(_ *sync.WaitGroup, _ func() bool, _ chan Event, _ chan event.SinkEvent, _ chan Error) error

Start ...

func (BaseSource) URL

func (b BaseSource) URL() event.SourceURL

URL ...

type Creator

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

Source ...

func Single

func Single(f func(since *time.Time, sourceURL event.SourceURL) (*Source, error)) Creator

type Error

type Error struct {
	SourceURL event.SourceURL
	Error     error
}

Error ...

type Event

type Event struct {
	Source Source
	Event  string
}

Event ...

type Metadata

type Metadata struct {
	Name        string
	Type        reflect.Type
	CanHandle   func(url event.SourceURL) bool
	Creator     Creator
	ExampleURLs []string
}

Metadata ...

type Source

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
}

Source of events. Responsible for ingest and conversion to the standard format.