iodb

package
v0.1.4 Latest Latest
Warning

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

Go to latest
Published: Apr 7, 2026 License: MIT Imports: 8 Imported by: 0

Documentation

Overview

Package iodb implements database operations using pgxpool. This is an impure I/O package that implements contracts defined in pkg/.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConnectionError

func ConnectionError(
	host string,
	port int,
	database string,
	user string,
	err error,
) error

ConnectionError creates an error for database connection failures.

func CreateViewError added in v0.0.3

func CreateViewError(viewName string, err error) error

CreateViewError creates an error for when creating materialized view fails.

func CreateViewIndexError added in v0.0.3

func CreateViewIndexError(viewName string, err error) error

CreateViewIndexError creates an error for when creating index on materialized view fails.

func DeleteDatasetError added in v0.1.4

func DeleteDatasetError(table string, err error) error

DeleteDatasetError creates an error for when deleting dataset records from a table fails.

func DropTableError

func DropTableError(tableName string, err error) error

DropTableError creates an error for when dropping table fails.

func DropViewError added in v0.0.3

func DropViewError(viewName string, err error) error

DropViewError creates an error for when dropping materialized view fails.

func EmptyDatabaseError

func EmptyDatabaseError(host, database string) error

EmptyDatabaseError creates an error for when database has no tables.

func NewPgxOperator

func NewPgxOperator() db.Operator

NewPgxOperator creates a new database operator (without connecting).

func NotConnectedError

func NotConnectedError() error

NotConnectedError creates an error for when operation is attempted without connection.

func QueryDataSourcesError added in v0.1.4

func QueryDataSourcesError(err error) error

QueryDataSourcesError creates an error for when querying data sources fails.

func QueryTablesError

func QueryTablesError(err error) error

QueryTablesError creates an error for when querying table list fails.

func QueryViewsError added in v0.0.3

func QueryViewsError(err error) error

QueryViewsError creates an error for when querying materialized view list fails.

func ScanTableError

func ScanTableError(err error) error

ScanTableError creates an error for when scanning table name fails.

func ScanViewError added in v0.0.3

func ScanViewError(err error) error

ScanViewError creates an error for when scanning view name fails.

func TableCheckError

func TableCheckError(err error) error

TableCheckError creates an error for when checking table existence fails.

func TableExistsCheckError

func TableExistsCheckError(tableName string, err error) error

TableExistsCheckError creates an error for when checking table existence fails.

Types

This section is empty.

Jump to

Keyboard shortcuts

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