postgres

Documentation

Index

• type DBConn
• type LinkStorage
  • func NewLinkStorage(db DBConn) *LinkStorage
  • func (store *LinkStorage) GetLink(ctx context.Context, token string) (*model.Link, error)
  • func (store *LinkStorage) StartRecalculation(interval time.Duration, deleted chan []string)
  • func (store *LinkStorage) StoreLink(ctx context.Context, link *model.Link) error

Types

type DBConn

type DBConn interface {
	// Conn() *pgx.Conn
	Acquire(ctx context.Context) (*pgxpool.Conn, error)
	Begin(ctx context.Context) (pgx.Tx, error)
	BeginFunc(ctx context.Context, f func(pgx.Tx) error) error
	BeginTx(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error)
	BeginTxFunc(ctx context.Context, txOptions pgx.TxOptions, f func(pgx.Tx) error) error
	Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)
	Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)
	QueryFunc(ctx context.Context, sql string, args []interface{}, scans []interface{}, f func(pgx.QueryFuncRow) error) (pgconn.CommandTag, error)
	QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row
}

type LinkStorage

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

func NewLinkStorage

func NewLinkStorage(db DBConn) *LinkStorage

func (*LinkStorage) GetLink

func (store *LinkStorage) GetLink(ctx context.Context, token string) (*model.Link, error)

func (*LinkStorage) StartRecalculation

func (store *LinkStorage) StartRecalculation(interval time.Duration, deleted chan []string)

func (*LinkStorage) StoreLink

func (store *LinkStorage) StoreLink(ctx context.Context, link *model.Link) error