postgres

package

v0.0.0-...-bbdcbae Latest Latest Go to latest Published: Apr 2, 2025 License: AGPL-3.0 Imports: 18 Imported by: 0

Details

This section is empty.

This section is empty.

func MigrateDown(ctx context.Context, sqlDB *sql.DB) error

func MigrateUp(ctx context.Context, sqlDB *sql.DB) error

func NewDB(ctx context.Context, dbDSN string) (*sql.DB, func() error, error)

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

func NewFileRepo(db *sql.DB) *FileRepo

func (repo *FileRepo) Delete(ctx context.Context, filename string) error

func (repo *FileRepo) Get(ctx context.Context, filename string) (*filemanager.File, error)

func (repo *FileRepo) Insert(ctx context.Context, file *filemanager.File) error

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

func NewListingItemRepo(db *sql.DB) *ListingItemRepo

func (repo *ListingItemRepo) Get(ctx context.Context, itemID string) (*listing.Item, error)

func (repo *ListingItemRepo) Insert(ctx context.Context, item *listing.Item) error

func (repo *ListingItemRepo) List(ctx context.Context, req *listing.ListItemsRequest) ([]*listing.Item, error)

func (repo *ListingItemRepo) Replace(ctx context.Context, itemID string, item *listing.Item) error

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

func NewListingLocationRepo(db *sql.DB) *ListingLocationRepo

func (repo *ListingLocationRepo) Get(ctx context.Context, locationID string) (*listing.Location, error)

func (repo *ListingLocationRepo) Insert(ctx context.Context, location *listing.Location) error

func (repo *ListingLocationRepo) List(ctx context.Context) ([]*listing.Location, error)

func (repo *ListingLocationRepo) Replace(ctx context.Context, locationID string, location *listing.Location) error