database

package

v0.0.0-...-dd9aec0 Latest Latest Go to latest Published: Aug 3, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cloudfoundry/silk

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type DatabaseHandler
- func NewDatabaseHandler(migrator migrateAdapter, db Db) *DatabaseHandler
type Db
type MigrateAdapter
- func (ma *MigrateAdapter) Exec(db Db, dialect string, m migrate.MigrationSource, ...) (int, error)
type Migrator
- func (m *Migrator) TryMigrations() error

Constants ¶

View Source

const MySQL = "mysql"

View Source

const Postgres = "postgres"

Variables ¶

View Source

var RecordNotAffectedError = errors.New("record not affected")

Functions ¶

This section is empty.

Types ¶

type DatabaseHandler ¶

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

func NewDatabaseHandler ¶

func NewDatabaseHandler(migrator migrateAdapter, db Db) *DatabaseHandler

func (*DatabaseHandler) AddEntry ¶

func (d *DatabaseHandler) AddEntry(lease controller.Lease) error

func (*DatabaseHandler) All ¶

func (d *DatabaseHandler) All() ([]controller.Lease, error)

func (*DatabaseHandler) AllActive ¶

func (d *DatabaseHandler) AllActive(duration int) ([]controller.Lease, error)

func (*DatabaseHandler) AllBlockSubnets ¶

func (d *DatabaseHandler) AllBlockSubnets() ([]controller.Lease, error)

func (*DatabaseHandler) AllSingleIPSubnets ¶

func (d *DatabaseHandler) AllSingleIPSubnets() ([]controller.Lease, error)

func (*DatabaseHandler) CheckDatabase ¶

func (d *DatabaseHandler) CheckDatabase() error

func (*DatabaseHandler) DeleteEntry ¶

func (d *DatabaseHandler) DeleteEntry(underlayIP string) error

func (*DatabaseHandler) LastRenewedAtForUnderlayIP ¶

func (d *DatabaseHandler) LastRenewedAtForUnderlayIP(underlayIP string) (int64, error)

func (*DatabaseHandler) LeaseForUnderlayIP ¶

func (d *DatabaseHandler) LeaseForUnderlayIP(underlayIP string) (*controller.Lease, error)

func (*DatabaseHandler) Migrate ¶

func (d *DatabaseHandler) Migrate() (int, error)

func (*DatabaseHandler) OldestExpiredBlockSubnet ¶

func (d *DatabaseHandler) OldestExpiredBlockSubnet(expirationTime int) (*controller.Lease, error)

func (*DatabaseHandler) OldestExpiredSingleIP ¶

func (d *DatabaseHandler) OldestExpiredSingleIP(expirationTime int) (*controller.Lease, error)

func (*DatabaseHandler) RenewLeaseForUnderlayIP ¶

func (d *DatabaseHandler) RenewLeaseForUnderlayIP(underlayIP string) error

type Db ¶

type Db interface {
	Exec(query string, args ...interface{}) (sql.Result, error)
	Rebind(query string) string
	Query(query string, args ...interface{}) (*sql.Rows, error)
	QueryRow(query string, args ...interface{}) *sql.Row
	DriverName() string
	RawConnection() *sqlx.DB
}

type MigrateAdapter ¶

type MigrateAdapter struct {
}

func (*MigrateAdapter) Exec ¶

func (ma *MigrateAdapter) Exec(db Db, dialect string, m migrate.MigrationSource, dir migrate.MigrationDirection) (int, error)

type Migrator ¶

type Migrator struct {
	DatabaseMigrator              databaseMigrator
	MaxMigrationAttempts          int
	MigrationAttemptSleepDuration time.Duration
	Logger                        lager.Logger
}

func (*Migrator) TryMigrations ¶

func (m *Migrator) TryMigrations() error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
fakes Code generated by counterfeiter.	Code generated by counterfeiter.

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