Documentation
¶
Overview ¶
Package database provides CRUD operations with database.
Package database provides CRUD operations with database.
Package database provides CRUD operations with database.
Package database provides CRUD operations with database.
Index ¶
- type FeedItemsRepository
- func (repo *FeedItemsRepository) Create(ctx context.Context, in *entity.FeedItem) (*entity.FeedItem, error)
- func (repo *FeedItemsRepository) Delete(ctx context.Context, feedID string, toDate time.Time) error
- func (repo *FeedItemsRepository) GetByFeedID(ctx context.Context, id string) ([]*entity.FeedItem, error)
- type FeedsRepository
- func (repo *FeedsRepository) Create(ctx context.Context, in *entity.Feed) (*entity.Feed, error)
- func (repo *FeedsRepository) Delete(ctx context.Context, id string) error
- func (repo *FeedsRepository) Get(ctx context.Context, filter *entity.FeedFilter) ([]*entity.Feed, error)
- func (repo *FeedsRepository) GetByID(ctx context.Context, id string) (*entity.Feed, error)
- func (repo *FeedsRepository) GetForUpdate(ctx context.Context, delay int64) ([]*entity.Feed, error)
- func (repo *FeedsRepository) Update(ctx context.Context, in *entity.Feed) (*entity.Feed, error)
- type SubscriptionsRepository
- func (repo *SubscriptionsRepository) Create(ctx context.Context, in *entity.Subscription) (*entity.Subscription, error)
- func (repo *SubscriptionsRepository) Delete(ctx context.Context, id string) error
- func (repo *SubscriptionsRepository) GetByFeedID(ctx context.Context, id string) ([]*entity.Subscription, error)
- func (repo *SubscriptionsRepository) GetByID(ctx context.Context, id string) (*entity.Subscription, error)
- func (repo *SubscriptionsRepository) GetByUserID(ctx context.Context, id int64) ([]*entity.Subscription, error)
- type UsersRepository
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FeedItemsRepository ¶
type FeedItemsRepository struct {
// contains filtered or unexported fields
}
FeedItemsRepository object capable of interacting with FeedItemsRepository
func NewFeedItemsRepository ¶
func NewFeedItemsRepository(db *database.Database, log *logger.Zerolog) *FeedItemsRepository
NewFeedItemsRepository creates a new FeedItemsRepository
func (*FeedItemsRepository) Create ¶
func (repo *FeedItemsRepository) Create(ctx context.Context, in *entity.FeedItem) (*entity.FeedItem, error)
Create creates new feed item
func (*FeedItemsRepository) GetByFeedID ¶
func (repo *FeedItemsRepository) GetByFeedID(ctx context.Context, id string) ([]*entity.FeedItem, error)
GetByFeedID returns feed items by feed_id
type FeedsRepository ¶
type FeedsRepository struct {
// contains filtered or unexported fields
}
FeedsRepository object capable of interacting with FeedsRepository
func NewFeedsRepository ¶
func NewFeedsRepository(db *database.Database, log *logger.Zerolog) *FeedsRepository
NewFeedsRepository creates a new FeedsRepository
func (*FeedsRepository) Delete ¶
func (repo *FeedsRepository) Delete(ctx context.Context, id string) error
Delete deletes feed item
func (*FeedsRepository) Get ¶
func (repo *FeedsRepository) Get(ctx context.Context, filter *entity.FeedFilter) ([]*entity.Feed, error)
Get returns feeds
func (*FeedsRepository) GetForUpdate ¶
GetForUpdate returns feeds that need to be updated
type SubscriptionsRepository ¶
type SubscriptionsRepository struct {
// contains filtered or unexported fields
}
SubscriptionsRepository object capable of interacting with SubscriptionsRepository
func NewSubscriptionsRepository ¶
func NewSubscriptionsRepository(db *database.Database, log *logger.Zerolog) *SubscriptionsRepository
NewSubscriptionsRepository creates a new SubscriptionsRepository
func (*SubscriptionsRepository) Create ¶
func (repo *SubscriptionsRepository) Create(ctx context.Context, in *entity.Subscription) (*entity.Subscription, error)
Create creates new subscription
func (*SubscriptionsRepository) Delete ¶
func (repo *SubscriptionsRepository) Delete(ctx context.Context, id string) error
Delete deletes user subscription
func (*SubscriptionsRepository) GetByFeedID ¶
func (repo *SubscriptionsRepository) GetByFeedID(ctx context.Context, id string) ([]*entity.Subscription, error)
GetByFeedID returns subscriptions by feed id
func (*SubscriptionsRepository) GetByID ¶
func (repo *SubscriptionsRepository) GetByID(ctx context.Context, id string) (*entity.Subscription, error)
GetByID returns subscriptions by id
func (*SubscriptionsRepository) GetByUserID ¶
func (repo *SubscriptionsRepository) GetByUserID(ctx context.Context, id int64) ([]*entity.Subscription, error)
GetByUserID returns subscriptions by user id
type UsersRepository ¶
type UsersRepository struct {
// contains filtered or unexported fields
}
UsersRepository object capable of interacting with UsersRepository
func NewUsersRepository ¶
func NewUsersRepository(db *database.Database, log *logger.Zerolog) *UsersRepository
NewUsersRepository creates a new UsersRepository
func (*UsersRepository) Get ¶
func (repo *UsersRepository) Get(ctx context.Context, filter *entity.UsersFilter) ([]*entity.User, error)
Get returns users
Source Files