postgresstore

package

v0.0.0-...-b28803a Latest Latest Go to latest Published: Aug 15, 2024 License: MIT Imports: 9 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

func NewPostgresMigration(db *DB, migrationPath string) (*rf.Migration, error)

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

func NewAuthStore(db *DB) *AuthStore

func (as *AuthStore) CreateAuthAndUser(ctx context.Context, auth *rf.Auth) error

func (as *AuthStore) FindByEmail(ctx context.Context, email string) (*rf.Auth, error)

type DB struct {
	DBURL string
	Now   func() time.Time
	// contains filtered or unexported fields
}

func NewDB(dbURL string) *DB

func (db *DB) BeginTx(ctx context.Context, opts pgx.TxOptions) (*Tx, error)

func (db *DB) Close() error

func (db *DB) Open() (err error)

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

func NewFeedStore(db *DB) *FeedStore

func (fs *FeedStore) CreateFeed(ctx context.Context, feed *rf.Feed) error

func (fs *FeedStore) CreateUserFeed(ctx context.Context, feed *rf.Feed) error

func (fs *FeedStore) DeleteFeed(ctx context.Context, userID, feedID int64) error

func (fs *FeedStore) FindByURL(ctx context.Context, url string) (*rf.Feed, error)

func (fs *FeedStore) FindUserFeedByID(ctx context.Context, userID, feedID int64) (*rf.Feed, error)

func (fs *FeedStore) ListUserFeeds(ctx context.Context, userID int64) ([]rf.Feed, error)

type Tx struct {
	pgx.Tx
	// contains filtered or unexported fields
}

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

func NewUserStore(db *DB) *UserStore