postgres

Documentation

Index

• Constants
• func ErrBeginTransactionFailed(beginErr error) error
• func ErrDBConnectionFailed(connectErr error) error
• func ErrDBDeleteFailed(deleteErr error) error
• func ErrDBInsertFailed(insertErr error) error
• func ErrUnableToSetNode(setErr error) error
• type DB
  • func NewDB(databaseConfig config.Database, node core.Node) (*DB, error)
  • func (db *DB) CreateNode(node *core.Node) error

Constants

const (
	BeginTransactionFailedMsg = "failed to begin transaction"
	DbConnectionFailedMsg     = "db connection failed"
	DeleteQueryFailedMsg      = "delete query failed"
	InsertQueryFailedMsg      = "insert query failed"
	SettingNodeFailedMsg      = "unable to set db node"
)

Functions

func ErrBeginTransactionFailed

func ErrBeginTransactionFailed(beginErr error) error

func ErrDBConnectionFailed

func ErrDBConnectionFailed(connectErr error) error

func ErrDBDeleteFailed

func ErrDBDeleteFailed(deleteErr error) error

func ErrDBInsertFailed

func ErrDBInsertFailed(insertErr error) error

func ErrUnableToSetNode

func ErrUnableToSetNode(setErr error) error

Types

type DB

type DB struct {
	*sqlx.DB
	Node   core.Node
	NodeID int64
}

func NewDB

func NewDB(databaseConfig config.Database, node core.Node) (*DB, error)

func (*DB) CreateNode

func (db *DB) CreateNode(node *core.Node) error