db

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: May 4, 2016 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

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

Functions

func DefaultSecretGenerator added in v0.4.0 

func DefaultSecretGenerator() ([]byte, error)

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 added in v0.4.0 

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

func NewClientRepoFromClients added in v0.4.0 

func NewClientRepoFromClients(dbm *gorp.DbMap, clients []client.Client) (client.ClientRepo, error)

func NewClientRepoWithSecretGenerator added in v0.4.0 

func NewClientRepoWithSecretGenerator(dbm *gorp.DbMap, secGen SecretGenerator) client.ClientRepo

func NewConnection 

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

func NewHealthChecker 

func NewHealthChecker(dbm *gorp.DbMap) *healthChecker

func NewMemDB added in v0.3.0 

func NewMemDB() *gorp.DbMap

NewMemDB creates a new in memory sqlite3 database.

func NewPasswordInfoRepo 

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

func NewPasswordInfoRepoFromPasswordInfos added in v0.3.0 

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

func NewRefreshTokenRepo 

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

func NewRefreshTokenRepoWithGenerator added in v0.3.0 

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 added in v0.2.0 

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 SecretGenerator added in v0.4.0 

type SecretGenerator func() ([]byte, 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

Source Files

View all Source files

Directories

Path Synopsis
Package translate implements translation of driver specific SQL queries.
 Package translate implements translation of driver specific SQL queries.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.