db

Documentation

Overview

Package db provides SQL implementations of dex's storage interfaces.

Index

• Variables
• func DropMigrationsTable(dbMap *gorp.DbMap) error
• func GetPlannedMigrations(dbMap *gorp.DbMap) ([]*migrate.PlannedMigration, error)
• func MigrateMaxMigrations(dbMap *gorp.DbMap, max int) (int, error)
• func MigrateToLatest(dbMap *gorp.DbMap) (int, error)
• func NewClientRepo(dbm *gorp.DbMap) client.ClientRepo
• func NewClientRepoFromClients(dbm *gorp.DbMap, cs []client.LoadableClient) (client.ClientRepo, error)
• func NewConnection(cfg Config) (*gorp.DbMap, error)
• func NewHealthChecker(dbm *gorp.DbMap) *healthChecker
• func NewMemDB() *gorp.DbMap
• func NewPasswordInfoRepo(dbm *gorp.DbMap) user.PasswordInfoRepo
• func NewPasswordInfoRepoFromPasswordInfos(dbm *gorp.DbMap, infos []user.PasswordInfo) (user.PasswordInfoRepo, error)
• func NewRefreshTokenRepo(dbm *gorp.DbMap) refresh.RefreshTokenRepo
• func NewRefreshTokenRepoWithGenerator(dbm *gorp.DbMap, gen refresh.RefreshTokenGenerator) refresh.RefreshTokenRepo
• func NewUserRepo(dbm *gorp.DbMap) user.UserRepo
• func NewUserRepoFromUsers(dbm *gorp.DbMap, us []user.UserWithRemoteIdentities) (user.UserRepo, error)
• func TransactionFactory(conn *gorp.DbMap) repo.TransactionFactory
• type Config
• type ConnectorConfigRepo
  • func NewConnectorConfigRepo(dbm *gorp.DbMap) *ConnectorConfigRepo
  • func (r *ConnectorConfigRepo) All() ([]connector.ConnectorConfig, error)
  • func (r *ConnectorConfigRepo) GetConnectorByID(tx repo.Transaction, id string) (connector.ConnectorConfig, error)
  • func (r *ConnectorConfigRepo) Set(cfgs []connector.ConnectorConfig) error
• type GarbageCollector
  • func NewGarbageCollector(dbm *gorp.DbMap, ival time.Duration) *GarbageCollector
  • func (gc *GarbageCollector) Run() chan struct{}
• type PrivateKeySetRepo
  • func NewPrivateKeySetRepo(dbm *gorp.DbMap, useOldFormat bool, secrets ...[]byte) (*PrivateKeySetRepo, error)
  • func (r *PrivateKeySetRepo) Get() (key.KeySet, error)
  • func (r *PrivateKeySetRepo) Set(ks key.KeySet) error
• type SessionKeyRepo
  • func NewSessionKeyRepo(dbm *gorp.DbMap) *SessionKeyRepo
  • func NewSessionKeyRepoWithClock(dbm *gorp.DbMap, clock clockwork.Clock) *SessionKeyRepo
  • func (r *SessionKeyRepo) Pop(key string) (string, error)
  • func (r *SessionKeyRepo) Push(sk session.SessionKey, exp time.Duration) error
• type SessionRepo
  • func NewSessionRepo(dbm *gorp.DbMap) *SessionRepo
  • func NewSessionRepoWithClock(dbm *gorp.DbMap, clock clockwork.Clock) *SessionRepo
  • func (r *SessionRepo) Create(s session.Session) error
  • func (r *SessionRepo) Get(sessionID string) (*session.Session, error)
  • func (r *SessionRepo) Update(s session.Session) error

Variables

var (
	ErrorCannotDecryptKeys = errors.New("Cannot Decrypt Keys")
)

Functions

func DropMigrationsTable

func DropMigrationsTable(dbMap *gorp.DbMap) error

func GetPlannedMigrations

func GetPlannedMigrations(dbMap *gorp.DbMap) ([]*migrate.PlannedMigration, error)

func MigrateMaxMigrations

func MigrateMaxMigrations(dbMap *gorp.DbMap, max int) (int, error)

func MigrateToLatest

func MigrateToLatest(dbMap *gorp.DbMap) (int, error)

func NewClientRepo

func NewClientRepo(dbm *gorp.DbMap) client.ClientRepo

func NewClientRepoFromClients

func NewClientRepoFromClients(dbm *gorp.DbMap, cs []client.LoadableClient) (client.ClientRepo, error)

func NewConnection

func NewConnection(cfg Config) (*gorp.DbMap, error)

func NewHealthChecker

func NewHealthChecker(dbm *gorp.DbMap) *healthChecker

func NewMemDB

func NewMemDB() *gorp.DbMap

NewMemDB creates a new in memory sqlite3 database.

func NewPasswordInfoRepo

func NewPasswordInfoRepo(dbm *gorp.DbMap) user.PasswordInfoRepo

func NewPasswordInfoRepoFromPasswordInfos

func NewPasswordInfoRepoFromPasswordInfos(dbm *gorp.DbMap, infos []user.PasswordInfo) (user.PasswordInfoRepo, error)

func NewRefreshTokenRepo

func NewRefreshTokenRepo(dbm *gorp.DbMap) refresh.RefreshTokenRepo

func NewRefreshTokenRepoWithGenerator

func NewRefreshTokenRepoWithGenerator(dbm *gorp.DbMap, gen refresh.RefreshTokenGenerator) refresh.RefreshTokenRepo

func NewUserRepo

func NewUserRepo(dbm *gorp.DbMap) user.UserRepo

func NewUserRepoFromUsers

func NewUserRepoFromUsers(dbm *gorp.DbMap, us []user.UserWithRemoteIdentities) (user.UserRepo, error)

func TransactionFactory

func TransactionFactory(conn *gorp.DbMap) repo.TransactionFactory

Types

type Config

type Config struct {
	// Connection string in the format: <driver>://<username>:<password>@<host>:<port>/<database>
	DSN string
	// The maximum number of open connections to the database. The default is 0 (unlimited).
	// For more details see: http://golang.org/pkg/database/sql/#DB.SetMaxOpenConns
	MaxOpenConnections int
	// The maximum number of connections in the idle connection pool. The default is 0 (unlimited).
	// For more details see: http://golang.org/pkg/database/sql/#DB.SetMaxIdleConns
	MaxIdleConnections int
}

type ConnectorConfigRepo

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

func NewConnectorConfigRepo

func NewConnectorConfigRepo(dbm *gorp.DbMap) *ConnectorConfigRepo

func (*ConnectorConfigRepo) All

func (r *ConnectorConfigRepo) All() ([]connector.ConnectorConfig, error)

func (*ConnectorConfigRepo) GetConnectorByID

func (r *ConnectorConfigRepo) GetConnectorByID(tx repo.Transaction, id string) (connector.ConnectorConfig, error)

func (*ConnectorConfigRepo) Set

func (r *ConnectorConfigRepo) Set(cfgs []connector.ConnectorConfig) error

type GarbageCollector

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

func NewGarbageCollector

func NewGarbageCollector(dbm *gorp.DbMap, ival time.Duration) *GarbageCollector

func (*GarbageCollector) Run

func (gc *GarbageCollector) Run() chan struct{}

type PrivateKeySetRepo

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

func NewPrivateKeySetRepo

func NewPrivateKeySetRepo(dbm *gorp.DbMap, useOldFormat bool, secrets ...[]byte) (*PrivateKeySetRepo, error)

func (*PrivateKeySetRepo) Get

func (r *PrivateKeySetRepo) Get() (key.KeySet, error)

func (*PrivateKeySetRepo) Set

func (r *PrivateKeySetRepo) Set(ks key.KeySet) error

type SessionKeyRepo

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

func NewSessionKeyRepo

func NewSessionKeyRepo(dbm *gorp.DbMap) *SessionKeyRepo

func NewSessionKeyRepoWithClock

func NewSessionKeyRepoWithClock(dbm *gorp.DbMap, clock clockwork.Clock) *SessionKeyRepo

func (*SessionKeyRepo) Pop

func (r *SessionKeyRepo) Pop(key string) (string, error)

func (*SessionKeyRepo) Push

func (r *SessionKeyRepo) Push(sk session.SessionKey, exp time.Duration) error

type SessionRepo

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

func NewSessionRepo

func NewSessionRepo(dbm *gorp.DbMap) *SessionRepo

func NewSessionRepoWithClock

func NewSessionRepoWithClock(dbm *gorp.DbMap, clock clockwork.Clock) *SessionRepo

func (*SessionRepo) Create

func (r *SessionRepo) Create(s session.Session) error

func (*SessionRepo) Get

func (r *SessionRepo) Get(sessionID string) (*session.Session, error)

func (*SessionRepo) Update

func (r *SessionRepo) Update(s session.Session) error