aggregator

type Aggregator ¶

type Aggregator interface {
	// Start should start a goroutine that periodically fetches content from
	// Instagram and updates the local database accordingly.
	Start(interval time.Duration) error

	// Stop should stop the periodical update and free resources.
	Stop()
}

Aggregator defines the primitives required for an Aggregator. An aggregator's job is to periodically fetch new entries and store them on a database.

func NewInstagramAggregator(db *buntdb.DB, api instagram.InstagramAPI,
	imagesFolder string, client HTTPClient, logger zerolog.Logger) Aggregator

type HTTPClient ¶ added in v1.0.1

type HTTPClient interface {
	Get(url string) (resp *http.Response, err error)
}

HTTPClient defines the primitive needed to perform HTTP queries

type InstagramAggregator ¶ added in v1.0.2

type InstagramAggregator struct {
	sync.Mutex
	// contains filtered or unexported fields
}

InstagramAggregator implements an aggregator that fetches Instagram posts.

- implements aggregator.Aggregator

func (a *InstagramAggregator) Start(interval time.Duration) error

func (a *InstagramAggregator) Stop()