db

Documentation

Overview

Package db contains db connection logic, data accessor functions and model

Index

• type DBConnection
  • func NewDBConnection(dbPool *sql.DB, c *DBConnectionParams, logger *logr.Logger) *DBConnection
  • func (d *DBConnection) Close()
  • func (d *DBConnection) InitConnection() error
  • func (d *DBConnection) IsIPBlacklisted(ctx *context.Context, blockIP string) (bool, error)
  • func (d *DBConnection) UpsertBlacklistRecord(ctx *context.Context, blockIP string, t time.Time) error
• type DBConnectionParams

Types

type DBConnection

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

DBConnection object which keeps database connection handler and provides data accessor functions

func NewDBConnection

func NewDBConnection(dbPool *sql.DB, c *DBConnectionParams, logger *logr.Logger) *DBConnection

NewDBConnection creates a new database connection

func (*DBConnection) Close

func (d *DBConnection) Close()

Close database connection

func (*DBConnection) InitConnection

func (d *DBConnection) InitConnection() error

InitConnection initializes a connection to the database

func (*DBConnection) IsIPBlacklisted

func (d *DBConnection) IsIPBlacklisted(ctx *context.Context, blockIP string) (bool, error)

IsIPBlacklisted checks if the provided IP address is present in the blacklisted database

func (*DBConnection) UpsertBlacklistRecord

func (d *DBConnection) UpsertBlacklistRecord(ctx *context.Context, blockIP string, t time.Time) error

UpsertBlacklistRecord adds or updates a Blacklisted record in the database

type DBConnectionParams

type DBConnectionParams struct {
	Host     *string
	Port     *int
	Password *string
	User     *string
	DBName   *string
	SSLMode  *string
}

DBConnectionParams are parameters for a database connection