aggregator

Documentation

Index

• type Aggregator
  • func NewInstagramAggregator(db *buntdb.DB, api instagram.InstagramAPI, imagesFolder string, ...) Aggregator
• type HTTPClient
• type InstagramAggregator
  • func (a *InstagramAggregator) Start(interval time.Duration) error
  • func (a *InstagramAggregator) Stop()

Types

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

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

NewInstagramAggregator returns a new initialized instagram aggregator.

type HTTPClient

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

HTTPClient defines the primitive needed to perform HTTP queries

type InstagramAggregator

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

InstagramAggregator implements an aggregator that fetches Instagram posts.

- implements aggregator.Aggregator

func (*InstagramAggregator) Start

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

Start implements aggregator.Aggregator. It should be called only if the aggregator is not already running.

func (*InstagramAggregator) Stop

func (a *InstagramAggregator) Stop()

Stop implements aggregator.Aggregator. It should be called only if the Aggregator is started.