repository

Documentation

Index

• func NewAPIKeyRepo(db *sqlc.Queries) domain.APIKeyRepo
• func NewDocAPIKeyRepo(queries *sqlc.Queries) domain.DocAPIKeyRepo
• func NewIdempotencyKeyRepo(queries *sqlc.Queries) domain.IdempotencyKeyRepo
• func NewLeaseRepo(queries *sqlc.Queries) lease.Repo
• func NewOutboxEnqueuerRepo(dbPool *sql.DB, queries *sqlc.Queries) messaging.OutboxEnqueuerRepo
• func NewOutboxRepo(queries *sqlc.Queries) messaging.OutboxRepo
• func NewRefreshTokenRepo(db *sqlc.Queries) domain.RefreshTokenRepo
• func NewRegistrationQueueRepo(db *sqlc.Queries) domain.RegistrationQueueRepo
• func NewRegistrationSessionRepo(queries *sqlc.Queries) domain.RegistrationSessionRepo
• func NewRepoFactory(queries *sqlc.Queries) domain.RepoFactory
• func NewUserRepo(db *sqlc.Queries) domain.UserRepo

Functions

func NewAPIKeyRepo

func NewAPIKeyRepo(db *sqlc.Queries) domain.APIKeyRepo

func NewDocAPIKeyRepo

func NewDocAPIKeyRepo(queries *sqlc.Queries) domain.DocAPIKeyRepo

func NewIdempotencyKeyRepo

func NewIdempotencyKeyRepo(queries *sqlc.Queries) domain.IdempotencyKeyRepo

func NewLeaseRepo

func NewLeaseRepo(queries *sqlc.Queries) lease.Repo

NewLeaseRepo creates a lease repository backed by the service's MySQL connection.

func NewOutboxEnqueuerRepo

func NewOutboxEnqueuerRepo(dbPool *sql.DB, queries *sqlc.Queries) messaging.OutboxEnqueuerRepo

NewOutboxEnqueuerRepo creates a new outbox repository for the enqueuer. It requires both the db pool (for transactions) and queries (for non-transactional operations).

func NewOutboxRepo

func NewOutboxRepo(queries *sqlc.Queries) messaging.OutboxRepo

NewOutboxRepo creates a new outbox repository.

func NewRefreshTokenRepo

func NewRefreshTokenRepo(db *sqlc.Queries) domain.RefreshTokenRepo

func NewRegistrationQueueRepo

func NewRegistrationQueueRepo(db *sqlc.Queries) domain.RegistrationQueueRepo

func NewRegistrationSessionRepo

func NewRegistrationSessionRepo(queries *sqlc.Queries) domain.RegistrationSessionRepo

func NewRepoFactory

func NewRepoFactory(queries *sqlc.Queries) domain.RepoFactory

NewRepoFactory creates a factory that instantiates repositories backed by the provided sqlc query executor (raw DB or transactional).

func NewUserRepo

func NewUserRepo(db *sqlc.Queries) domain.UserRepo