postgres

package

v0.0.0-...-06a3cf6 Latest Latest Go to latest Published: Oct 31, 2025 License: AGPL-3.0 Imports: 25 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/defeedco/defeed

Links

Open Source Insights

Documentation ¶

Index ¶

type ActivityRepository
- func NewActivityRepository(db *DB, logger *zerolog.Logger) *ActivityRepository
- func (r *ActivityRepository) Search(ctx context.Context, req types.SearchRequest) (*types.SearchResult, error)
- func (r *ActivityRepository) Upsert(ctx context.Context, activity *types.DecoratedActivity) error
type Config
- func (c Config) DSN() string
type DB
- func NewDB(cfg *Config) *DB
- func (d *DB) Client() *ent.Client
- func (d *DB) Connect(ctx context.Context) error
type FeedRepository
- func NewFeedRepository(db *DB) *FeedRepository
type SourceRepository
- func NewSourceRepository(db *DB) *SourceRepository

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ActivityRepository ¶

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

func NewActivityRepository ¶

func NewActivityRepository(db *DB, logger *zerolog.Logger) *ActivityRepository

func (*ActivityRepository) Search ¶

func (r *ActivityRepository) Search(ctx context.Context, req types.SearchRequest) (*types.SearchResult, error)

func (*ActivityRepository) Upsert ¶

func (r *ActivityRepository) Upsert(ctx context.Context, activity *types.DecoratedActivity) error

type Config ¶

type Config struct {
	Host        string `env:"DB_HOST,required"`
	User        string `env:"DB_USER,required"`
	Password    string `env:"DB_PASSWORD,required"`
	Name        string `env:"DB_NAME,required"`
	Port        int    `env:"DB_PORT,required"`
	AutoMigrate bool   `env:"DB_AUTO_MIGRATE,default=false"`
}

func (Config) DSN ¶

func (c Config) DSN() string

type DB ¶

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

func NewDB ¶

func NewDB(cfg *Config) *DB

func (*DB) Client ¶

func (d *DB) Client() *ent.Client

func (*DB) Connect ¶

func (d *DB) Connect(ctx context.Context) error

Connect connects to Postgres and optionally creates the schema.

type FeedRepository ¶

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

func NewFeedRepository ¶

func NewFeedRepository(db *DB) *FeedRepository

func (*FeedRepository) FindBySourceUIDs ¶

func (r *FeedRepository) FindBySourceUIDs(ctx context.Context, sourceUIDs []types.TypedUID) ([]*feeds.Feed, error)

func (*FeedRepository) GetByID ¶

func (r *FeedRepository) GetByID(ctx context.Context, uid string) (*feeds.Feed, error)

func (*FeedRepository) List ¶

func (r *FeedRepository) List(ctx context.Context) ([]*feeds.Feed, error)

func (*FeedRepository) Remove ¶

func (r *FeedRepository) Remove(ctx context.Context, uid string) error

func (*FeedRepository) Upsert ¶

func (r *FeedRepository) Upsert(ctx context.Context, f feeds.Feed) error

type SourceRepository ¶

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

func NewSourceRepository ¶

func NewSourceRepository(db *DB) *SourceRepository

func (*SourceRepository) Add ¶

func (r *SourceRepository) Add(s types.Source) error

func (*SourceRepository) GetByID ¶

func (r *SourceRepository) GetByID(uid string) (types.Source, error)

func (*SourceRepository) List ¶

func (r *SourceRepository) List() ([]types.Source, error)

func (*SourceRepository) Remove ¶

func (r *SourceRepository) Remove(uid string) error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
ent
activity
enttest
feed
hook
migrate
predicate
runtime
schema
source

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL