mysql

Documentation

Index

• type Cron
• type Driver
  • func NewDriver(host, port, username, password, database string) (*Driver, error)
• type Repository
  • func NewRepository(driver *Driver) *Repository
  • func (r *Repository) Delete(ctx context.Context, id uint) error
  • func (r *Repository) GetForUser(ctx context.Context, userID int) ([]cron.Cron, error)
  • func (r *Repository) Insert(ctx context.Context, c *cron.Cron) error
  • func (r *Repository) List(ctx context.Context) ([]cron.Cron, error)
• type ResultsRepository
  • func NewResultsRepository(driver *Driver) *ResultsRepository
  • func (r *ResultsRepository) GetLastResult(ctx context.Context, cronID uint, source string) (cron.Paper, error)
  • func (r *ResultsRepository) Insert(ctx context.Context, cronID uint, paper cron.Paper) error
• type SearchResult

Types

type Cron

type Cron struct {
	ID uint

	UserID  int
	Query   string
	Sources string

	CreatedAt time.Time
	UpdatedAt time.Time
}

type Driver

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

func NewDriver

func NewDriver(host, port, username, password, database string) (*Driver, error)

type Repository

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

func NewRepository

func NewRepository(driver *Driver) *Repository

func (*Repository) Delete

func (r *Repository) Delete(ctx context.Context, id uint) error

func (*Repository) GetForUser

func (r *Repository) GetForUser(ctx context.Context, userID int) ([]cron.Cron, error)

func (*Repository) Insert

func (r *Repository) Insert(ctx context.Context, c *cron.Cron) error

func (*Repository) List

func (r *Repository) List(ctx context.Context) ([]cron.Cron, error)

type ResultsRepository

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

func NewResultsRepository

func NewResultsRepository(driver *Driver) *ResultsRepository

func (*ResultsRepository) GetLastResult

func (r *ResultsRepository) GetLastResult(ctx context.Context, cronID uint, source string) (cron.Paper, error)

func (*ResultsRepository) Insert

func (r *ResultsRepository) Insert(ctx context.Context, cronID uint, paper cron.Paper) error

type SearchResult

type SearchResult struct {
	ID uint

	CronID uint
	Source string

	Result *dbPaper

	CreatedAt time.Time
}