Versions in this module Expand all Collapse all v1 v1.0.1 Apr 12, 2022 Changes in this version + func WithClient(c *db.Client) func(*Database) + func WithHasher(h func() hash.Hash) func(*Database) + func WithTxIsolationLevel(level sql.IsolationLevel) func(*Database) + type Database struct + func NewDatabase(opts ...func(*Database)) *Database + func (d *Database) BeginTx(ctx context.Context) (*db.Tx, error) + func (d *Database) Close() error + func (d *Database) CreateAuthCode(code storage.AuthCode) error + func (d *Database) CreateAuthRequest(authRequest storage.AuthRequest) error + func (d *Database) CreateClient(client storage.Client) error + func (d *Database) CreateConnector(connector storage.Connector) error + func (d *Database) CreateDeviceRequest(request storage.DeviceRequest) error + func (d *Database) CreateDeviceToken(token storage.DeviceToken) error + func (d *Database) CreateOfflineSessions(session storage.OfflineSessions) error + func (d *Database) CreatePassword(password storage.Password) error + func (d *Database) CreateRefresh(refresh storage.RefreshToken) error + func (d *Database) DeleteAuthCode(id string) error + func (d *Database) DeleteAuthRequest(id string) error + func (d *Database) DeleteClient(id string) error + func (d *Database) DeleteConnector(id string) error + func (d *Database) DeleteOfflineSessions(userID, connID string) error + func (d *Database) DeletePassword(email string) error + func (d *Database) DeleteRefresh(id string) error + func (d *Database) GarbageCollect(now time.Time) (storage.GCResult, error) + func (d *Database) GetAuthCode(id string) (storage.AuthCode, error) + func (d *Database) GetAuthRequest(id string) (storage.AuthRequest, error) + func (d *Database) GetClient(id string) (storage.Client, error) + func (d *Database) GetConnector(id string) (storage.Connector, error) + func (d *Database) GetDeviceRequest(userCode string) (storage.DeviceRequest, error) + func (d *Database) GetDeviceToken(deviceCode string) (storage.DeviceToken, error) + func (d *Database) GetKeys() (storage.Keys, error) + func (d *Database) GetOfflineSessions(userID, connID string) (storage.OfflineSessions, error) + func (d *Database) GetPassword(email string) (storage.Password, error) + func (d *Database) GetRefresh(id string) (storage.RefreshToken, error) + func (d *Database) ListClients() ([]storage.Client, error) + func (d *Database) ListConnectors() ([]storage.Connector, error) + func (d *Database) ListPasswords() ([]storage.Password, error) + func (d *Database) ListRefreshTokens() ([]storage.RefreshToken, error) + func (d *Database) Schema() *migrate.Schema + func (d *Database) UpdateAuthRequest(id string, updater func(old storage.AuthRequest) (storage.AuthRequest, error)) error + func (d *Database) UpdateClient(id string, updater func(old storage.Client) (storage.Client, error)) error + func (d *Database) UpdateConnector(id string, updater func(old storage.Connector) (storage.Connector, error)) error + func (d *Database) UpdateDeviceToken(deviceCode string, ...) error + func (d *Database) UpdateKeys(updater func(old storage.Keys) (storage.Keys, error)) error + func (d *Database) UpdateOfflineSessions(userID string, connID string, ...) error + func (d *Database) UpdatePassword(email string, updater func(old storage.Password) (storage.Password, error)) error + func (d *Database) UpdateRefreshToken(id string, ...) error