repository

Documentation

Index

• Variables
• type ArticleRepository
  • func NewArticleRepository(db *pgxpool.Pool) *ArticleRepository
  • func (a *ArticleRepository) AllNotPosted(ctx context.Context, since time.Time, limit uint64) ([]*models.Article, error)
  • func (a *ArticleRepository) MarkPosted(ctx context.Context, id int64) error
  • func (a *ArticleRepository) Store(ctx context.Context, article models.Article) error
• type SourceRepository
  • func NewSourceRepository(db *pgxpool.Pool) *SourceRepository
  • func (s *SourceRepository) Add(ctx context.Context, source models.Source) (int64, error)
  • func (s *SourceRepository) Delete(ctx context.Context, id int64) error
  • func (s *SourceRepository) SourceByID(ctx context.Context, id int64) (*models.Source, error)
  • func (s *SourceRepository) Sources(ctx context.Context) ([]*models.Source, error)

Variables

var (
	ErrorSourceNotFound = errors.New("source not found")
)

Types

type ArticleRepository

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

func NewArticleRepository

func NewArticleRepository(db *pgxpool.Pool) *ArticleRepository

func (*ArticleRepository) AllNotPosted

func (a *ArticleRepository) AllNotPosted(ctx context.Context, since time.Time, limit uint64) ([]*models.Article, error)

func (*ArticleRepository) MarkPosted

func (a *ArticleRepository) MarkPosted(ctx context.Context, id int64) error

func (*ArticleRepository) Store

func (a *ArticleRepository) Store(ctx context.Context, article models.Article) error

type SourceRepository

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

func NewSourceRepository

func NewSourceRepository(db *pgxpool.Pool) *SourceRepository

func (*SourceRepository) Add

func (s *SourceRepository) Add(ctx context.Context, source models.Source) (int64, error)

func (*SourceRepository) Delete

func (s *SourceRepository) Delete(ctx context.Context, id int64) error

func (*SourceRepository) SourceByID

func (s *SourceRepository) SourceByID(ctx context.Context, id int64) (*models.Source, error)

func (*SourceRepository) Sources

func (s *SourceRepository) Sources(ctx context.Context) ([]*models.Source, error)