Documentation
¶
Index ¶
- type NotificationRepository
- func (r *NotificationRepository) DeleteByIDs(ctx context.Context, ids []uuid.UUID) error
- func (r *NotificationRepository) InsertOne(ctx context.Context, not *entity.Notification) error
- func (r *NotificationRepository) ListByTypeForUpdate(ctx context.Context, notificationType entity.NotificationType, batchSize int) ([]*entity.Notification, error)
- type Queryer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NotificationRepository ¶
type NotificationRepository struct {
// contains filtered or unexported fields
}
func NewNotificationRepository ¶
func NewNotificationRepository(queryer Queryer) *NotificationRepository
func (*NotificationRepository) DeleteByIDs ¶
func (*NotificationRepository) InsertOne ¶
func (r *NotificationRepository) InsertOne(ctx context.Context, not *entity.Notification) error
func (*NotificationRepository) ListByTypeForUpdate ¶
func (r *NotificationRepository) ListByTypeForUpdate( ctx context.Context, notificationType entity.NotificationType, batchSize int, ) ([]*entity.Notification, error)
type Queryer ¶
type Queryer interface {
QueryxContext(ctx context.Context, query string, args ...any) (*sqlx.Rows, error)
NamedExecContext(ctx context.Context, query string, arg interface{}) (sql.Result, error)
SelectContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error
ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
Rebind(query string) string
}
Source Files
Click to show internal directories.
Click to hide internal directories.