database

package
v0.0.0-...-d398788 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 22, 2026 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Instance

type Instance struct {
	DB *bun.DB
	// contains filtered or unexported fields
}

func InitDB

func InitDB(connType, connStr string) (*Instance, error)

func (*Instance) CheckUserIdentityExists

func (db *Instance) CheckUserIdentityExists(userid string) bool

func (*Instance) Close

func (db *Instance) Close() error

func (*Instance) ConfirmEmailByUserID

func (db *Instance) ConfirmEmailByUserID(userID string) error

func (*Instance) CreateClient

func (db *Instance) CreateClient(ci *models.Client) error

func (*Instance) CreateUser

func (db *Instance) CreateUser(user *models.User) error

func (*Instance) CreateUserIdentity

func (db *Instance) CreateUserIdentity(identity *models.UserIdentity) error

func (*Instance) DeleteClient

func (db *Instance) DeleteClient(id string) error

func (*Instance) DeleteTokenByAccess

func (db *Instance) DeleteTokenByAccess(token string) error

func (*Instance) DeleteTokenByAccessOrRefresh

func (db *Instance) DeleteTokenByAccessOrRefresh(access, refresh string) error

func (*Instance) DeleteTokenByID

func (db *Instance) DeleteTokenByID(id string) error

func (*Instance) DeleteTokenByRefresh

func (db *Instance) DeleteTokenByRefresh(token string) error

func (*Instance) DeleteTokensByUserID

func (db *Instance) DeleteTokensByUserID(userID string) error

func (*Instance) DeleteUser

func (db *Instance) DeleteUser(userID string) error

func (*Instance) EnqueueDirectWrite

func (db *Instance) EnqueueDirectWrite(job WriteJob) error

func (*Instance) EnqueueWrite

func (db *Instance) EnqueueWrite(job WriteJob) error

func (*Instance) GetClientByID

func (db *Instance) GetClientByID(id string) (*models.Client, error)

func (*Instance) GetClientByUserID

func (db *Instance) GetClientByUserID(userID string) (*models.Client, error)

func (*Instance) GetCorrespondingUser

func (db *Instance) GetCorrespondingUser(identity_id string) (*models.User, error)

func (*Instance) GetIdentityByUserID

func (db *Instance) GetIdentityByUserID(userID string) (*models.UserIdentity, error)

func (*Instance) GetOrCreateUser

func (db *Instance) GetOrCreateUser(pbuser *pb.User, provider string) (*pb.User, error)

func (*Instance) GetTokenByAccess

func (db *Instance) GetTokenByAccess(token string) (*models.DBToken, error)

func (*Instance) GetTokenByRefresh

func (db *Instance) GetTokenByRefresh(token string) (*models.DBToken, error)

func (*Instance) GetUserByEmail

func (db *Instance) GetUserByEmail(email string) (*models.User, error)

func (*Instance) GetUserByID

func (db *Instance) GetUserByID(id string) (*models.User, error)

func (*Instance) GetUserByName

func (db *Instance) GetUserByName(name string) (*models.User, error)

func (*Instance) LatestPasswordReset

func (db *Instance) LatestPasswordReset(email string) (*models.PasswordReset, error)

func (*Instance) MarkPasswordResetUsed

func (db *Instance) MarkPasswordResetUsed(id string) error

func (*Instance) SavePasswordReset

func (db *Instance) SavePasswordReset(pr *models.PasswordReset) error

func (*Instance) SaveToken

func (db *Instance) SaveToken(t *models.DBToken) error

func (*Instance) UpdateClient

func (db *Instance) UpdateClient(ci *models.Client) error

func (*Instance) UpdateUserPassword

func (db *Instance) UpdateUserPassword(userID, passwordHash string) error

type WriteJob

type WriteJob func(bun.Tx) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL