database

package

v1.0.1 Latest Latest Go to latest Published: Mar 9, 2025 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

View Source

var DB *sql.DB

DB is the database connection

func Close()

Close closes the database connection

func Connect() error

Connect establishes a connection to the PostgreSQL database

func GetLogs(filter models.LogFilter) ([]models.Log, error)

GetLogs retrieves logs from the database with optional filtering

func InsertLog(logEntry models.Log) (int, error)

InsertLog inserts a new log entry into the database

func ListenForLogs(ctx context.Context, logChan chan<- models.Log) error

ListenForLogs listens for new log notifications and sends them to the provided channel

func SetupMockDB() (*sql.DB, sqlmock.Sqlmock, error)

SetupMockDB sets up a mock database for testing

type AnyTime struct{}

AnyTime is a custom matcher for timestamp

func (a AnyTime) Match(v driver.Value) bool

Match satisfies sqlmock.Argument interface