storage

Documentation

Index

• type CreatePrParams
• type DBTX
• type DbStorage
  • func NewStorage(logger *slog.Logger) *DbStorage
  • func (s *DbStorage) Bury(prUrl string) error
  • func (s *DbStorage) GetPr(prUrl string) (Pr, error)
  • func (s *DbStorage) Prs() StoredState
  • func (s *DbStorage) StoreRepoPrs(orderedPrs []types.ViewPr) error
  • func (s *DbStorage) Unbury(prUrl string) error
• type Meta
• type Pr
• type Queries
  • func New(db DBTX) *Queries
  • func (q *Queries) BuriedPrs(ctx context.Context) ([]string, error)
  • func (q *Queries) Bury(ctx context.Context, url string) error
  • func (q *Queries) CreatePr(ctx context.Context, arg CreatePrParams) (Pr, error)
  • func (q *Queries) DeletePrs(ctx context.Context) error
  • func (q *Queries) GetLastFetched(ctx context.Context) (string, error)
  • func (q *Queries) GetPr(ctx context.Context, url string) (Pr, error)
  • func (q *Queries) ListPrs(ctx context.Context) ([]Pr, error)
  • func (q *Queries) StoreLastFetched(ctx context.Context, value string) error
  • func (q *Queries) Unbury(ctx context.Context, url string) error
  • func (q *Queries) WithTx(tx *sql.Tx) *Queries
• type Storage
• type StorageDemo
  • func NewStorageDemo() *StorageDemo
  • func (s *StorageDemo) Bury(prUrl string) error
  • func (s *StorageDemo) GetPr(prUrl string) (Pr, error)
  • func (s *StorageDemo) Prs() StoredState
  • func (s *StorageDemo) StoreRepoPrs(orderedPrs []types.ViewPr) error
  • func (s *StorageDemo) Unbury(prUrl string) error
• type StoredState

Types

type CreatePrParams

type CreatePrParams struct {
	Url                      string
	ReviewStatus             string
	Title                    string
	Author                   string
	RepoName                 string
	RepoOwner                string
	RepoUrl                  string
	IsDraft                  bool
	LastUpdated              string
	LastPrCommenter          string
	ThreadsActionable        int64
	ThreadsWaiting           int64
	Additions                int64
	Deletions                int64
	ReviewRequestedFromUsers string
	Buried                   bool
}

type DBTX

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type DbStorage

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

func NewStorage

func NewStorage(logger *slog.Logger) *DbStorage

func (*DbStorage) Bury

func (s *DbStorage) Bury(prUrl string) error

func (*DbStorage) GetPr

func (s *DbStorage) GetPr(prUrl string) (Pr, error)

func (*DbStorage) Prs

func (s *DbStorage) Prs() StoredState

func (*DbStorage) StoreRepoPrs

func (s *DbStorage) StoreRepoPrs(orderedPrs []types.ViewPr) error

func (*DbStorage) Unbury

func (s *DbStorage) Unbury(prUrl string) error

type Meta

type Meta struct {
	Key   string
	Value string
}

type Pr

type Pr struct {
	Url                      string
	ReviewStatus             string
	Title                    string
	Author                   string
	RepoName                 string
	RepoOwner                string
	RepoUrl                  string
	IsDraft                  bool
	LastUpdated              string
	LastPrCommenter          string
	ThreadsActionable        int64
	ThreadsWaiting           int64
	Additions                int64
	Deletions                int64
	ReviewRequestedFromUsers string
	Buried                   bool
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) BuriedPrs

func (q *Queries) BuriedPrs(ctx context.Context) ([]string, error)

func (*Queries) Bury

func (q *Queries) Bury(ctx context.Context, url string) error

func (*Queries) CreatePr

func (q *Queries) CreatePr(ctx context.Context, arg CreatePrParams) (Pr, error)

func (*Queries) DeletePrs

func (q *Queries) DeletePrs(ctx context.Context) error

func (*Queries) GetLastFetched

func (q *Queries) GetLastFetched(ctx context.Context) (string, error)

func (*Queries) GetPr

func (q *Queries) GetPr(ctx context.Context, url string) (Pr, error)

func (*Queries) ListPrs

func (q *Queries) ListPrs(ctx context.Context) ([]Pr, error)

func (*Queries) StoreLastFetched

func (q *Queries) StoreLastFetched(ctx context.Context, value string) error

func (*Queries) Unbury

func (q *Queries) Unbury(ctx context.Context, url string) error

func (*Queries) WithTx

func (q *Queries) WithTx(tx *sql.Tx) *Queries

type Storage

type Storage interface {
	Prs() StoredState
	StoreRepoPrs(orderedPrs []types.ViewPr) error
	Bury(prUrl string) error
	Unbury(prUrl string) error
	GetPr(prUrl string) (Pr, error)
}

type StorageDemo

type StorageDemo struct{}

func NewStorageDemo

func NewStorageDemo() *StorageDemo

func (*StorageDemo) Bury

func (s *StorageDemo) Bury(prUrl string) error

func (*StorageDemo) GetPr

func (s *StorageDemo) GetPr(prUrl string) (Pr, error)

func (*StorageDemo) Prs

func (s *StorageDemo) Prs() StoredState

func (*StorageDemo) StoreRepoPrs

func (s *StorageDemo) StoreRepoPrs(orderedPrs []types.ViewPr) error

func (*StorageDemo) Unbury

func (s *StorageDemo) Unbury(prUrl string) error

type StoredState

type StoredState struct {
	Prs         []types.ViewPr
	LastFetched time.Time
}