gdeltfetching

Documentation

Index

• func FetchGDELT(config configuration.Configuration, db *gorm.DB, rmq *rabbitmq.Client, ...) error
• type Worker
  • func NewWorker(config configuration.Configuration, db *gorm.DB, rmq *rabbitmq.Client, ...) *Worker
  • func (g *Worker) Do() error

Functions

func FetchGDELT

func FetchGDELT(
	config configuration.Configuration,
	db *gorm.DB,
	rmq *rabbitmq.Client,
	logger zerolog.Logger,
) error

FetchGDELT periodically fetches GDELT's Events, collecting each event's first news report URL, enriched with essential Event metadata.

Types

type Worker

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

func NewWorker

func NewWorker(
	config configuration.Configuration,
	db *gorm.DB,
	rmq *rabbitmq.Client,
	logger zerolog.Logger,
) *Worker

func (*Worker) Do

func (g *Worker) Do() error