database

Documentation

Index

• type DB
  • func NewDB(config customconfig.PostgreSQL) (DB, error)
• type QuerierExtended
• type QueriesExtended
  • func (e *QueriesExtended) RefreshMaterializedViewAggregatedAnime(ctx context.Context) error
  • func (e *QueriesExtended) RefreshMaterializedViewConcurrentAggregatedAnimeRelation(ctx context.Context) error
  • func (e *QueriesExtended) RefreshMaterializedViewConcurrentAggregatedTitle(ctx context.Context) error

Types

type DB

type DB interface {
	Q() QuerierExtended
	Pool() *pgxpool.Pool
	Close()
}

func NewDB

func NewDB(config customconfig.PostgreSQL) (DB, error)

type QuerierExtended

type QuerierExtended interface {
	sqlc.Querier

	RefreshMaterializedViewAggregatedAnime(ctx context.Context) (err error)
	RefreshMaterializedViewConcurrentAggregatedTitle(ctx context.Context) (err error)
	RefreshMaterializedViewConcurrentAggregatedAnimeRelation(ctx context.Context) (err error)
}

type QueriesExtended

type QueriesExtended struct {
	*sqlc.Queries
	// contains filtered or unexported fields
}

func (*QueriesExtended) RefreshMaterializedViewAggregatedAnime

func (e *QueriesExtended) RefreshMaterializedViewAggregatedAnime(ctx context.Context) error

RefreshMaterializedViewAggregatedAnime simply triggers a manual refresh on the materialized view.

func (*QueriesExtended) RefreshMaterializedViewConcurrentAggregatedAnimeRelation

func (e *QueriesExtended) RefreshMaterializedViewConcurrentAggregatedAnimeRelation(ctx context.Context) error

RefreshMaterializedViewConcurrentAggregatedAnimeRelation simply triggers a manual refresh on the materialized view in a concurrent manner.

func (*QueriesExtended) RefreshMaterializedViewConcurrentAggregatedTitle

func (e *QueriesExtended) RefreshMaterializedViewConcurrentAggregatedTitle(ctx context.Context) error

RefreshMaterializedViewConcurrentAggregatedTitle simply triggers a manual refresh on the materialized view in a concurrent manner.