dbmanager

package

v0.1.14 Latest Latest Go to latest Published: Jul 30, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/SUSE/telemetry-server

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type DbManager
type DbType
type PgxPoolManager
type PostgresManager
- func (m *PostgresManager) Connect() (err error)
type SqlDbManager
type Sqlite3Manager

Constants ¶

View Source

const (
	POSTGRES_CONN_SCALE int32 = 4
	POSTGRES_CONN_MAX   int32 = 30
	POSTGRES_CONN_IDLE  int32 = 2
	POSTGRES_CONN_MIN   int32 = 2
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DbManager ¶

type DbManager interface {
	String() string
	Init(dbType DbType, dataSource string, manager string)
	Type() DbType
	DB() *sql.DB
	Connect() error
	Ping() error
	Close() error
}

Interface for managing DB specific resouces

func New ¶

func New(driver, dataSource string) (dbMgr DbManager, err error)

func NewPgxPoolManager ¶

func NewPgxPoolManager(dbType DbType, dataSource string) DbManager

func NewPostgresManager ¶

func NewPostgresManager(dbType DbType, dataSource string) DbManager

func NewSqlDbManager ¶

func NewSqlDbManager(dbType DbType, dataSource string, manager string) DbManager

func NewSqlite3Manager ¶

func NewSqlite3Manager(dbType DbType, dataSource string) DbManager

type DbType ¶

type DbType int

Supported DB Types

const (
	DB_TYPE_UNKNOWN DbType = iota

	// valid DB types
	DB_TYPE_PGX
	DB_TYPE_POSTGRES
	DB_TYPE_SQLITE3
)

func (DbType) DbDriver ¶

func (t DbType) DbDriver() (dbDriver string, err error)

func (DbType) IsPostgres ¶

func (t DbType) IsPostgres() (isPostgres bool)

DB Type flavour checks

func (DbType) IsSqlite3 ¶

func (t DbType) IsSqlite3() (isSqlite3 bool)

func (DbType) String ¶

func (t DbType) String() string

type PgxPoolManager ¶

type PgxPoolManager struct {
	SqlDbManager
	// contains filtered or unexported fields
}

pgxpool specific variant of SqlDbManager

func (*PgxPoolManager) Close ¶

func (m *PgxPoolManager) Close() (err error)

func (*PgxPoolManager) Connect ¶

func (m *PgxPoolManager) Connect() (err error)

func (*PgxPoolManager) Type ¶

func (m *PgxPoolManager) Type() DbType

type PostgresManager ¶

type PostgresManager struct {
	SqlDbManager
}

Postgres specific variant of SqlDbManager

func (*PostgresManager) Connect ¶

func (m *PostgresManager) Connect() (err error)

type SqlDbManager ¶

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

general database/sql DB Manager

func (*SqlDbManager) Close ¶

func (m *SqlDbManager) Close() (err error)

func (*SqlDbManager) Connect ¶

func (m *SqlDbManager) Connect() (err error)

func (*SqlDbManager) DB ¶

func (m *SqlDbManager) DB() *sql.DB

func (*SqlDbManager) Init ¶

func (m *SqlDbManager) Init(dbType DbType, dataSource string, manager string)

func (*SqlDbManager) Ping ¶

func (m *SqlDbManager) Ping() (err error)

func (*SqlDbManager) String ¶

func (m *SqlDbManager) String() string

func (*SqlDbManager) Type ¶

func (m *SqlDbManager) Type() DbType

type Sqlite3Manager ¶

type Sqlite3Manager struct {
	SqlDbManager
}

Sqlite3 specific variant of SqlDbManager

Source Files ¶

View all Source files

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