postgres

package

v0.0.0-...-4993f2c Latest Latest Go to latest Published: Oct 27, 2025 License: MIT Imports: 6 Imported by: 0

Details

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

Repository

github.com/movetokube/postgres-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func GetConnection(user, password, host, database, uri_args string, logger logr.Logger) (*sql.DB, error)
type AzureType
type PG
- func NewPG(cfg *config.Cfg, logger logr.Logger) (PG, error)
type PostgresSchemaPrivileges

Constants ¶

View Source

const (
	CREATE_DB            = `CREATE DATABASE "%s"`
	CREATE_SCHEMA        = `CREATE SCHEMA IF NOT EXISTS "%s" AUTHORIZATION "%s"`
	CREATE_EXTENSION     = `CREATE EXTENSION IF NOT EXISTS "%s"`
	ALTER_DB_OWNER       = `ALTER DATABASE "%s" OWNER TO "%s"`
	DROP_DATABASE        = `DROP DATABASE "%s"`
	GRANT_USAGE_SCHEMA   = `GRANT USAGE ON SCHEMA "%s" TO "%s"`
	GRANT_CREATE_TABLE   = `GRANT CREATE ON SCHEMA "%s" TO "%s"`
	GRANT_ALL_TABLES     = `GRANT %s ON ALL TABLES IN SCHEMA "%s" TO "%s"`
	DEFAULT_PRIVS_SCHEMA = `ALTER DEFAULT PRIVILEGES IN SCHEMA "%s" GRANT %s ON TABLES TO "%s"`
	REVOKE_CONNECT       = `REVOKE CONNECT ON DATABASE "%s" FROM public`
	TERMINATE_BACKEND    = `` /* 137-byte string literal not displayed */
	GET_DB_OWNER         = `SELECT pg_catalog.pg_get_userbyid(d.datdba) FROM pg_catalog.pg_database d WHERE d.datname = '%s'`
	GRANT_CREATE_SCHEMA  = `GRANT CREATE ON DATABASE "%s" TO "%s"`
)

View Source

const (
	CREATE_GROUP_ROLE   = `CREATE ROLE "%s"`
	CREATE_USER_ROLE    = `CREATE ROLE "%s" WITH LOGIN PASSWORD '%s'`
	GRANT_ROLE          = `GRANT "%s" TO "%s"`
	ALTER_USER_SET_ROLE = `ALTER USER "%s" SET ROLE "%s"`
	REVOKE_ROLE         = `REVOKE "%s" FROM "%s"`
	UPDATE_PASSWORD     = `ALTER ROLE "%s" WITH PASSWORD '%s'`
	DROP_ROLE           = `DROP ROLE "%s"`
	DROP_OWNED_BY       = `DROP OWNED BY "%s"`
	REASIGN_OBJECTS     = `REASSIGN OWNED BY "%s" TO "%s"`
)

Variables ¶

This section is empty.

Functions ¶

func GetConnection ¶

func GetConnection(user, password, host, database, uri_args string, logger logr.Logger) (*sql.DB, error)

Types ¶

type AzureType ¶

type AzureType string

type PG ¶

type PG interface {
	CreateDB(dbname, username string) error
	CreateSchema(db, role, schema string, logger logr.Logger) error
	CreateExtension(db, extension string, logger logr.Logger) error
	CreateGroupRole(role string) error
	CreateUserRole(role, password string) (string, error)
	UpdatePassword(role, password string) error
	GrantRole(role, grantee string) error
	SetSchemaPrivileges(schemaPrivileges PostgresSchemaPrivileges, logger logr.Logger) error
	RevokeRole(role, revoked string) error
	AlterDefaultLoginRole(role, setRole string) error
	DropDatabase(db string, logger logr.Logger) error
	DropRole(role, newOwner, database string, logger logr.Logger) error
	GetUser() string
	GetDefaultDatabase() string
}

func NewPG ¶

func NewPG(cfg *config.Cfg, logger logr.Logger) (PG, error)

type PostgresSchemaPrivileges ¶

type PostgresSchemaPrivileges struct {
	DB           string
	Role         string
	Schema       string
	Privs        string
	CreateSchema bool
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
mock Package mock_postgres is a generated GoMock package.	Package mock_postgres is a generated GoMock package.

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