postgres

Documentation

Index

• type Storage
  • func NewSubscribeStorage(db *sqlx.DB) *Storage
  • func (s *Storage) Delete(ctx context.Context, userID user.ID, wishlistID wishlist.ID) error
  • func (s *Storage) Get(ctx context.Context, userID user.ID, wishlistID wishlist.ID) (*subscribePkg.Subscribe, error)
  • func (s *Storage) GetByUser(ctx context.Context, userID user.ID) ([]*subscribePkg.Subscribe, error)
  • func (s *Storage) Upsert(ctx context.Context, subscribe *subscribePkg.Subscribe) error

Types

type Storage

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

func NewSubscribeStorage

func NewSubscribeStorage(db *sqlx.DB) *Storage

func (*Storage) Delete

func (s *Storage) Delete(ctx context.Context, userID user.ID, wishlistID wishlist.ID) error

func (*Storage) Get

func (s *Storage) Get(ctx context.Context, userID user.ID, wishlistID wishlist.ID) (*subscribePkg.Subscribe, error)

func (*Storage) GetByUser

func (s *Storage) GetByUser(ctx context.Context, userID user.ID) ([]*subscribePkg.Subscribe, error)

func (*Storage) Upsert

func (s *Storage) Upsert(ctx context.Context, subscribe *subscribePkg.Subscribe) error