db

Documentation

Index

• Variables
• func AddRecord(ctx context.Context, r model.Record) error
• func ClosePostgres()
• func EnsureTables(ctx context.Context) error
• func FetchAllRecords(ctx context.Context) ([]model.Record, error)
• func FetchRecords(ctx context.Context, domain, qtype string) ([]model.Record, error)
• func GetDomainHits(ctx context.Context, domain, qtype string) (int64, error)
• func IncrementMetric(ctx context.Context, domain, qtype string) error
• func InitPostgres(ctx context.Context) error

Variables

var PgPool *pgxpool.Pool

Functions

func AddRecord

func AddRecord(ctx context.Context, r model.Record) error

func ClosePostgres

func ClosePostgres()

func EnsureTables

func EnsureTables(ctx context.Context) error

Creates tables if not exist

func FetchAllRecords

func FetchAllRecords(ctx context.Context) ([]model.Record, error)

func FetchRecords

func FetchRecords(ctx context.Context, domain, qtype string) ([]model.Record, error)

func GetDomainHits

func GetDomainHits(ctx context.Context, domain, qtype string) (int64, error)

func IncrementMetric

func IncrementMetric(ctx context.Context, domain, qtype string) error

func InitPostgres

func InitPostgres(ctx context.Context) error