postgres

package
v0.0.0-...-ec7b898 Latest Latest
Warning

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

 Go to latest Published: Oct 9, 2023 License: Apache-2.0, MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DATABASE_NAME     = "DATABASE_NAME"
	DATABASE_HOSTNAME = "DATABASE_HOSTNAME"
	DATABASE_PORT     = "DATABASE_PORT"
	DATABASE_USER     = "DATABASE_USER"
	DATABASE_PASSWORD = "DATABASE_PASSWORD"
)

Env variables

View Source 
const (
	DbConnectionFailedMsg = "db connection failed"
)

Variables

View Source 
var DefaultConfig = Config{
	Hostname:     "localhost",
	Port:         8077,
	DatabaseName: "filecoin_testing",
	Username:     "fil",
	Password:     "password",
}

DefaultConfig are default parameters for connecting to a Postgres sql

Functions

func ConnectPGX 

func ConnectPGX(ctx context.Context, config *Config) (*pgxpool.Pool, error)

ConnectPGX initializes and returns a PGX connection pool

func ConnectSQLX 

func ConnectSQLX(ctx context.Context, config *Config) (*sqlx.DB, error)

ConnectSQLX initializes and returns a SQLX connection pool for postgres

func ErrDBConnectionFailed 

func ErrDBConnectionFailed(connectErr error) error

func MakeConfig 

func MakeConfig(config Config) (*pgxpool.Config, error)

MakeConfig creates a pgxpool.Config from the provided Config

func SetupPGXDB 

func SetupPGXDB(config *Config) (sql.Database, error)

SetupPGXDB is used to setup a pgx db

func SetupSQLXDB 

func SetupSQLXDB(config *Config) (sql.Database, error)

SetupSQLXDB is used to setup a sqlx db

Types

type Config 

type Config struct {
	// conn string params
	Hostname     string
	Port         int
	DatabaseName string
	Username     string
	Password     string

	// conn settings
	MaxConns        int
	MaxIdle         int
	MinConns        int
	MaxConnIdleTime time.Duration
	MaxConnLifetime time.Duration
	ConnTimeout     time.Duration
	LogStatements   bool

	// driver type
	Driver DriverType

	// toggle on/off upserts
	Upsert bool

	// toggle on/off CopyFrom
	CopyFrom bool
}

Config holds params for a Postgres db

func (Config) DbConnectionString 

func (c Config) DbConnectionString() string

DbConnectionString constructs and returns the connection string from the config

func (Config) Type 

func (c Config) Type() shared.DBType

Type satisfies interfaces.Config

func (Config) WithEnv 

func (c Config) WithEnv() (Config, error)

type DB 

type DB struct {
	sql.Driver
	// contains filtered or unexported fields
}

DB implements sql.Database using a configured driver and Postgres statement syntax

func NewPostgresDB 

func NewPostgresDB(driver sql.Driver, upsert bool) *DB

NewPostgresDB returns a postgres.DB using the provided driver

func (*DB) AccountActorAddressColumnNames 

func (db *DB) AccountActorAddressColumnNames() []string

func (*DB) AccountActorAddressesTableName 

func (db *DB) AccountActorAddressesTableName() []string

func (*DB) ActorEventsColumnNames 

func (db *DB) ActorEventsColumnNames() []string

func (*DB) ActorEventsTableName 

func (db *DB) ActorEventsTableName() []string

func (*DB) ActorStateColumnNames 

func (db *DB) ActorStateColumnNames() []string

func (*DB) ActorStateTableName 

func (db *DB) ActorStateTableName() []string

func (*DB) ActorsColumnNames 

func (db *DB) ActorsColumnNames() []string

func (*DB) ActorsTableName 

func (db *DB) ActorsTableName() []string

func (*DB) BlockHeadersColumnNames 

func (db *DB) BlockHeadersColumnNames() []string

func (*DB) BlockHeadersTableName 

func (db *DB) BlockHeadersTableName() []string

func (*DB) BlockMessagesColumnNames 

func (db *DB) BlockMessagesColumnNames() []string

func (*DB) BlockMessagesTableName 

func (db *DB) BlockMessagesTableName() []string

func (*DB) BlockParentsColumnNames 

func (db *DB) BlockParentsColumnNames() []string

func (*DB) BlockParentsTableName 

func (db *DB) BlockParentsTableName() []string

func (*DB) CIDsColumnNames 

func (db *DB) CIDsColumnNames() []string

func (*DB) CIDsTableName 

func (db *DB) CIDsTableName() []string

func (*DB) CronActorMethodReceiversColumnNames 

func (db *DB) CronActorMethodReceiversColumnNames() []string

func (*DB) CronActorMethodReceiversTableName 

func (db *DB) CronActorMethodReceiversTableName() []string

func (*DB) DRandsColumnNames 

func (db *DB) DRandsColumnNames() []string

func (*DB) DRandsTableName 

func (db *DB) DRandsTableName() []string

func (*DB) FEVMActorStateColumnNames 

func (db *DB) FEVMActorStateColumnNames() []string

func (*DB) FEVMActorStateTableNames 

func (db *DB) FEVMActorStateTableNames() []string

func (*DB) FEVMActorStorageColumnNames 

func (db *DB) FEVMActorStorageColumnNames() []string

func (*DB) FEVMActorStorageTableNames 

func (db *DB) FEVMActorStorageTableNames() []string

func (*DB) IPLDsColumnNames 

func (db *DB) IPLDsColumnNames() []string

func (*DB) IPLDsTableName 

func (db *DB) IPLDsTableName() []string

func (*DB) InitActorIdAddressesColumnNames 

func (db *DB) InitActorIdAddressesColumnNames() []string

func (*DB) InitActorIdAddressesTableName 

func (db *DB) InitActorIdAddressesTableName() []string

func (*DB) InsertAccountActorAddressesStm 

func (db *DB) InsertAccountActorAddressesStm() string

func (*DB) InsertActorEventsStm 

func (db *DB) InsertActorEventsStm() string

func (*DB) InsertActorStateStm 

func (db *DB) InsertActorStateStm() string

func (*DB) InsertActorsStm 

func (db *DB) InsertActorsStm() string

func (*DB) InsertBlockHeadersStm 

func (db *DB) InsertBlockHeadersStm() string

func (*DB) InsertBlockMessagesStm 

func (db *DB) InsertBlockMessagesStm() string

func (*DB) InsertBlockParentsStm 

func (db *DB) InsertBlockParentsStm() string

func (*DB) InsertCIDsStm 

func (db *DB) InsertCIDsStm() string

func (*DB) InsertCronActorMethodReceiversStm 

func (db *DB) InsertCronActorMethodReceiversStm() string

func (*DB) InsertDRandsStm 

func (db *DB) InsertDRandsStm() string

func (*DB) InsertFEVMActorStateStm 

func (db *DB) InsertFEVMActorStateStm() string

func (*DB) InsertFEVMActorStorageStm 

func (db *DB) InsertFEVMActorStorageStm() string

func (*DB) InsertIPLDsStm 

func (db *DB) InsertIPLDsStm() string

func (*DB) InsertInitActorIdAddressesStm 

func (db *DB) InsertInitActorIdAddressesStm() string

func (*DB) InsertInternalMessagesStm 

func (db *DB) InsertInternalMessagesStm() string

func (*DB) InsertInternalParsedMessagesStm 

func (db *DB) InsertInternalParsedMessagesStm() string

func (*DB) InsertMessagesStm 

func (db *DB) InsertMessagesStm() string

func (*DB) InsertMinerActorStateStm 

func (db *DB) InsertMinerActorStateStm() string

func (*DB) InsertMinerDeadlinesStm 

func (db *DB) InsertMinerDeadlinesStm() string

func (*DB) InsertMinerInfosStm 

func (db *DB) InsertMinerInfosStm() string

func (*DB) InsertMinerPartitionExpirationsStm 

func (db *DB) InsertMinerPartitionExpirationsStm() string

func (*DB) InsertMinerPartitionsStm 

func (db *DB) InsertMinerPartitionsStm() string

func (*DB) InsertMinerPreCommittedSectorInfosStm 

func (db *DB) InsertMinerPreCommittedSectorInfosStm() string

func (*DB) InsertMinerSectorInfosStm 

func (db *DB) InsertMinerSectorInfosStm() string

func (*DB) InsertMinerVestingFundsStm 

func (db *DB) InsertMinerVestingFundsStm() string

func (*DB) InsertMultisigActorPendingTxsStm 

func (db *DB) InsertMultisigActorPendingTxsStm() string

func (*DB) InsertMultisigActorStateStm 

func (db *DB) InsertMultisigActorStateStm() string

func (*DB) InsertParsedMessagesStm 

func (db *DB) InsertParsedMessagesStm() string

func (*DB) InsertPaymentChannelActorStateStm 

func (db *DB) InsertPaymentChannelActorStateStm() string

func (*DB) InsertPaymentChannelLaneStateStm 

func (db *DB) InsertPaymentChannelLaneStateStm() string

func (*DB) InsertReceiptsStm 

func (db *DB) InsertReceiptsStm() string

func (*DB) InsertRewardActorStateStm 

func (db *DB) InsertRewardActorStateStm() string

func (*DB) InsertStorageActorDealOpsAtEpochStm 

func (db *DB) InsertStorageActorDealOpsAtEpochStm() string

func (*DB) InsertStorageActorDealOpsBucketsStm 

func (db *DB) InsertStorageActorDealOpsBucketsStm() string

func (*DB) InsertStorageActorDealProposalsStm 

func (db *DB) InsertStorageActorDealProposalsStm() string

func (*DB) InsertStorageActorDealStateStm 

func (db *DB) InsertStorageActorDealStateStm() string

func (*DB) InsertStorageActorEscrowsStm 

func (db *DB) InsertStorageActorEscrowsStm() string

func (*DB) InsertStorageActorLockedFundsStm 

func (db *DB) InsertStorageActorLockedFundsStm() string

func (*DB) InsertStorageActorPendingProposalsStm 

func (db *DB) InsertStorageActorPendingProposalsStm() string

func (*DB) InsertStorageActorStateStm 

func (db *DB) InsertStorageActorStateStm() string

func (*DB) InsertStoragePowerActorStateStm 

func (db *DB) InsertStoragePowerActorStateStm() string

func (*DB) InsertStoragePowerClaimsStm 

func (db *DB) InsertStoragePowerClaimsStm() string

func (*DB) InsertStoragePowerCronBucketsStm 

func (db *DB) InsertStoragePowerCronBucketsStm() string

func (*DB) InsertStoragePowerCronEventsStm 

func (db *DB) InsertStoragePowerCronEventsStm() string

func (*DB) InsertStoragePowerProofSealVerifyInfosStm 

func (db *DB) InsertStoragePowerProofSealVerifyInfosStm() string

func (*DB) InsertStoragePowerProofValidationBucketsStm 

func (db *DB) InsertStoragePowerProofValidationBucketsStm() string

func (*DB) InsertTipSetMembersStm 

func (db *DB) InsertTipSetMembersStm() string

func (*DB) InsertTipSetsStm 

func (db *DB) InsertTipSetsStm() string

func (*DB) InsertVMMessagesStm 

func (db *DB) InsertVMMessagesStm() string

func (*DB) InsertVerifiedRegistryActorStateStm 

func (db *DB) InsertVerifiedRegistryActorStateStm() string

func (*DB) InsertVerifiedRegistryClientsStm 

func (db *DB) InsertVerifiedRegistryClientsStm() string

func (*DB) InsertVerifiedRegistryVerifiersStm 

func (db *DB) InsertVerifiedRegistryVerifiersStm() string

func (*DB) InternalMessagesColumnNames 

func (db *DB) InternalMessagesColumnNames() []string

func (*DB) InternalMessagesTableName 

func (db *DB) InternalMessagesTableName() []string

func (*DB) InternalParsedMessagesColumnNames 

func (db *DB) InternalParsedMessagesColumnNames() []string

func (*DB) InternalParsedMessagesTableName 

func (db *DB) InternalParsedMessagesTableName() []string

func (*DB) MessagesColumnNames 

func (db *DB) MessagesColumnNames() []string

func (*DB) MessagesTableName 

func (db *DB) MessagesTableName() []string

func (*DB) MinerActorStateColumnNames 

func (db *DB) MinerActorStateColumnNames() []string

func (*DB) MinerActorStateTableName 

func (db *DB) MinerActorStateTableName() []string

func (*DB) MinerDeadlinesColumnNames 

func (db *DB) MinerDeadlinesColumnNames() []string

func (*DB) MinerDeadlinesTableName 

func (db *DB) MinerDeadlinesTableName() []string

func (*DB) MinerInfosColumnNames 

func (db *DB) MinerInfosColumnNames() []string

func (*DB) MinerInfosTableName 

func (db *DB) MinerInfosTableName() []string

func (*DB) MinerPartitionExpirationsColumnNames 

func (db *DB) MinerPartitionExpirationsColumnNames() []string

func (*DB) MinerPartitionExpirationsTableName 

func (db *DB) MinerPartitionExpirationsTableName() []string

func (*DB) MinerPartitionsColumnNames 

func (db *DB) MinerPartitionsColumnNames() []string

func (*DB) MinerPartitionsTableName 

func (db *DB) MinerPartitionsTableName() []string

func (*DB) MinerPreCommittedSectorInfosColumnNames 

func (db *DB) MinerPreCommittedSectorInfosColumnNames() []string

func (*DB) MinerPreCommittedSectorInfosTableName 

func (db *DB) MinerPreCommittedSectorInfosTableName() []string

func (*DB) MinerSectorInfosColumnNames 

func (db *DB) MinerSectorInfosColumnNames() []string

func (*DB) MinerSectorInfosTableName 

func (db *DB) MinerSectorInfosTableName() []string

func (*DB) MinerVestingFundsColumnNames 

func (db *DB) MinerVestingFundsColumnNames() []string

func (*DB) MinerVestingFundsTableName 

func (db *DB) MinerVestingFundsTableName() []string

func (*DB) MultisigActorStateColumnNames 

func (db *DB) MultisigActorStateColumnNames() []string

func (*DB) MultisigActorStateTableName 

func (db *DB) MultisigActorStateTableName() []string

func (*DB) MultisigPendingTxsColumnNames 

func (db *DB) MultisigPendingTxsColumnNames() []string

func (*DB) MultisigPendingTxsTableName 

func (db *DB) MultisigPendingTxsTableName() []string

func (*DB) ParsedMessagesColumnNames 

func (db *DB) ParsedMessagesColumnNames() []string

func (*DB) ParsedMessagesTableName 

func (db *DB) ParsedMessagesTableName() []string

func (*DB) PaymentChannelActorStateColumnNames 

func (db *DB) PaymentChannelActorStateColumnNames() []string

func (*DB) PaymentChannelActorStateTableName 

func (db *DB) PaymentChannelActorStateTableName() []string

func (*DB) PaymentChannelLaneStateColumnNames 

func (db *DB) PaymentChannelLaneStateColumnNames() []string

func (*DB) PaymentChannelLaneStateTableName 

func (db *DB) PaymentChannelLaneStateTableName() []string

func (*DB) ReceiptsColumnNames 

func (db *DB) ReceiptsColumnNames() []string

func (*DB) ReceiptsTableName 

func (db *DB) ReceiptsTableName() []string

func (*DB) RewardActorStateColumnNames 

func (db *DB) RewardActorStateColumnNames() []string

func (*DB) RewardActorStateTableName 

func (db *DB) RewardActorStateTableName() []string

func (*DB) StorageActorDealOpsAtEpochColumnNames 

func (db *DB) StorageActorDealOpsAtEpochColumnNames() []string

func (*DB) StorageActorDealOpsAtEpochTableName 

func (db *DB) StorageActorDealOpsAtEpochTableName() []string

func (*DB) StorageActorDealOpsBucketsColumnNames 

func (db *DB) StorageActorDealOpsBucketsColumnNames() []string

func (*DB) StorageActorDealOpsBucketsTableName 

func (db *DB) StorageActorDealOpsBucketsTableName() []string

func (*DB) StorageActorDealProposalsColumnNames 

func (db *DB) StorageActorDealProposalsColumnNames() []string

func (*DB) StorageActorDealProposalsTableName 

func (db *DB) StorageActorDealProposalsTableName() []string

func (*DB) StorageActorDealStateColumnNames 

func (db *DB) StorageActorDealStateColumnNames() []string

func (*DB) StorageActorDealStateTableName 

func (db *DB) StorageActorDealStateTableName() []string

func (*DB) StorageActorEscrowsColumnNames 

func (db *DB) StorageActorEscrowsColumnNames() []string

func (*DB) StorageActorEscrowsTableName 

func (db *DB) StorageActorEscrowsTableName() []string

func (*DB) StorageActorLockedTokensColumnNames 

func (db *DB) StorageActorLockedTokensColumnNames() []string

func (*DB) StorageActorLockedTokensTableName 

func (db *DB) StorageActorLockedTokensTableName() []string

func (*DB) StorageActorPendingProposalsColumnNames 

func (db *DB) StorageActorPendingProposalsColumnNames() []string

func (*DB) StorageActorPendingProposalsTableName 

func (db *DB) StorageActorPendingProposalsTableName() []string

func (*DB) StorageActorStateColumnNames 

func (db *DB) StorageActorStateColumnNames() []string

func (*DB) StorageActorStateTableName 

func (db *DB) StorageActorStateTableName() []string

func (*DB) StoragePowerActorStateColumnNames 

func (db *DB) StoragePowerActorStateColumnNames() []string

func (*DB) StoragePowerActorStateTableName 

func (db *DB) StoragePowerActorStateTableName() []string

func (*DB) StoragePowerClaimsColumnNames 

func (db *DB) StoragePowerClaimsColumnNames() []string

func (*DB) StoragePowerClaimsTableName 

func (db *DB) StoragePowerClaimsTableName() []string

func (*DB) StoragePowerCronEventBucketsColumnNames 

func (db *DB) StoragePowerCronEventBucketsColumnNames() []string

func (*DB) StoragePowerCronEventBucketsTableName 

func (db *DB) StoragePowerCronEventBucketsTableName() []string

func (*DB) StoragePowerCronEventsColumnNames 

func (db *DB) StoragePowerCronEventsColumnNames() []string

func (*DB) StoragePowerCronEventsTableName 

func (db *DB) StoragePowerCronEventsTableName() []string

func (*DB) StoragePowerProofSealVerifyInfosColumnNames 

func (db *DB) StoragePowerProofSealVerifyInfosColumnNames() []string

func (*DB) StoragePowerProofSealVerifyInfosTableName 

func (db *DB) StoragePowerProofSealVerifyInfosTableName() []string

func (*DB) StoragePowerProofValidationBucketsColumnNames 

func (db *DB) StoragePowerProofValidationBucketsColumnNames() []string

func (*DB) StoragePowerProofValidationBucketsTableName 

func (db *DB) StoragePowerProofValidationBucketsTableName() []string

func (*DB) TipSetMembersColumnNames 

func (db *DB) TipSetMembersColumnNames() []string

func (*DB) TipSetMembersTableName 

func (db *DB) TipSetMembersTableName() []string

func (*DB) TipSetsColumnNames 

func (db *DB) TipSetsColumnNames() []string

func (*DB) TipSetsTableName 

func (db *DB) TipSetsTableName() []string

func (*DB) VMMessagesColumnNames 

func (db *DB) VMMessagesColumnNames() []string

func (*DB) VMMessagesTableName 

func (db *DB) VMMessagesTableName() []string

func (*DB) VerifiedRegistryActorStateTableName 

func (db *DB) VerifiedRegistryActorStateTableName() []string

func (*DB) VerifiedRegistryClientsColumnNames 

func (db *DB) VerifiedRegistryClientsColumnNames() []string

func (*DB) VerifiedRegistryClientsTableName 

func (db *DB) VerifiedRegistryClientsTableName() []string

func (*DB) VerifiedRegistryVerifiersColumnNames 

func (db *DB) VerifiedRegistryVerifiersColumnNames() []string

func (*DB) VerifiedRegistryVerifiersTableName 

func (db *DB) VerifiedRegistryVerifiersTableName() []string

type DriverType 

type DriverType string

DriverType to explicitly type the kind of sql driver we are using 

const (
	PGX     DriverType = "PGX"
	SQLX    DriverType = "SQLX"
	Unknown DriverType = "Unknown"
)

func ResolveDriverType 

func ResolveDriverType(str string) (DriverType, error)

ResolveDriverType resolves a DriverType from a provided string

type LogAdapter 

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

func NewLogAdapter 

func NewLogAdapter(l *log.Logger) *LogAdapter

func (*LogAdapter) Log 

func (l *LogAdapter) Log(ctx context.Context, level pgx.LogLevel, msg string, data map[string]interface{})

type PGXDriver 

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

PGXDriver driver, implements sql.Driver

func NewPGXDriver 

func NewPGXDriver(ctx context.Context, config *Config) (*PGXDriver, error)

NewPGXDriver returns a new pgx driver it initializes the connection pool and creates the node info table

func (*PGXDriver) Begin 

func (pgx *PGXDriver) Begin(ctx context.Context) (sql.Tx, error)

Begin satisfies sql.Database

func (*PGXDriver) Close 

func (pgx *PGXDriver) Close() error

Close satisfies sql.Database/io.Closer

func (*PGXDriver) Context 

func (pgx *PGXDriver) Context() context.Context

Context satisfies sql.Database

func (*PGXDriver) Exec 

func (pgx *PGXDriver) Exec(ctx context.Context, sql string, args ...interface{}) (sql.Result, error)

Exec satisfies sql.Database

func (*PGXDriver) Get 

func (pgx *PGXDriver) Get(ctx context.Context, dest interface{}, query string, args ...interface{}) error

Get satisfies sql.Database

func (*PGXDriver) QueryRow 

func (pgx *PGXDriver) QueryRow(ctx context.Context, sql string, args ...interface{}) sql.ScannableRow

QueryRow satisfies sql.Database

func (*PGXDriver) Select 

func (pgx *PGXDriver) Select(ctx context.Context, dest interface{}, query string, args ...interface{}) error

Select satisfies sql.Database

func (*PGXDriver) Stats 

func (pgx *PGXDriver) Stats() metrics.DbStats

func (*PGXDriver) UseCopyFrom 

func (pgx *PGXDriver) UseCopyFrom() bool

UseCopyFrom satisfies sql.Database

type SQLXDriver 

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

SQLXDriver driver, implements sql.Driver

func NewSQLXDriver 

func NewSQLXDriver(ctx context.Context, config *Config) (*SQLXDriver, error)

NewSQLXDriver returns a new sqlx driver for Postgres it initializes the connection pool and creates the node info table

func (*SQLXDriver) Begin 

func (driver *SQLXDriver) Begin(_ context.Context) (sql.Tx, error)

Begin satisfies sql.Database

func (*SQLXDriver) Close 

func (driver *SQLXDriver) Close() error

Close satisfies sql.Database/io.Closer

func (*SQLXDriver) Context 

func (driver *SQLXDriver) Context() context.Context

Context satisfies sql.Database

func (*SQLXDriver) Exec 

func (driver *SQLXDriver) Exec(_ context.Context, sql string, args ...interface{}) (sql.Result, error)

Exec satisfies sql.Database

func (*SQLXDriver) Get 

func (driver *SQLXDriver) Get(_ context.Context, dest interface{}, query string, args ...interface{}) error

Get satisfies sql.Database

func (*SQLXDriver) QueryRow 

func (driver *SQLXDriver) QueryRow(_ context.Context, sql string, args ...interface{}) sql.ScannableRow

QueryRow satisfies sql.Database

func (*SQLXDriver) Select 

func (driver *SQLXDriver) Select(_ context.Context, dest interface{}, query string, args ...interface{}) error

Select satisfies sql.Database

func (*SQLXDriver) Stats 

func (driver *SQLXDriver) Stats() metrics.DbStats

func (*SQLXDriver) UseCopyFrom 

func (driver *SQLXDriver) UseCopyFrom() bool

UseCopyFrom satisfies sql.Database

Source Files

View all Source files

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.