refresher

package

v0.0.0-...-bcb87c1 Latest Latest Go to latest Published: Sep 3, 2025 License: MIT Imports: 16 Imported by: 0

Details

This section is empty.

This section is empty.

func StartScheduler(ctx context.Context, r *Refresher)

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

func New(ag *appglobals.AppGlobals) *Refresher

func (r *Refresher) CountRowsAwaitingRefresh(ctx context.Context) (int64, error)

func (r *Refresher) ExplainSelectQuery(ctx context.Context) (string, error)

func (r *Refresher) Run(ctx context.Context) error

func (r *Refresher) SelectRowsToProcess(ctx context.Context, tx pgx.Tx) ([]RowToProcess, error)

type RowToProcess struct {
	Url          string
	MD5          types.MD5Hash
	FetchStatus  int
	FetchHeaders feed.HeaderMap
}