certpg

README

PostgreSQL schema

Documentation

Index

• Constants
• Variables
• type CertPG
  • func New(ctx context.Context, cd bwlimit.ContextDialer, db *sql.DB, prefix string) (cdb *CertPG, err error)
  • func (cdb *CertPG) BackfillStream(ctx context.Context, ls *certstream.LogStream)
  • func (cdb *CertPG) Close() error
  • func (cdb *CertPG) Entry(ctx context.Context, le *certstream.LogEntry) (err error)
  • func (cdb *CertPG) Estimate(table string) (estimate float64, err error)
  • func (cdb *CertPG) LogError(err error, msg string, args ...any) error
  • func (cdb *CertPG) Operator(ctx context.Context, lo *certstream.LogOperator) (err error)
  • func (cdb *CertPG) ScanDnsname(rows *sql.Rows, dnsname *Dnsname) (err error)
  • func (cdb *CertPG) Stream(ctx context.Context, ls *certstream.LogStream) (err error)
• type Dnsname

Constants

const SelectDnsnameLike = `SELECT * FROM CERTDB_dnsnames WHERE dnsname LIKE $1;`

const SelectEstimate = `SELECT reltuples AS estimate FROM pg_class WHERE relname = $1;`

const SelectMaxIndex = `SELECT MAX(logindex) AS logindex FROM CERTDB_entry WHERE stream = $1;`

const SelectMinIndex = `SELECT MIN(logindex) AS logindex FROM CERTDB_entry WHERE stream = $1;`

Variables

var BulkRange = int64(4096)

var FunctionName string

var FunctionOperatorID string

var FunctionStreamID string

var ProcedureCreateSchema string

var ProcedureNewEntry string

var SelectGaps string

Types

type CertPG

type CertPG struct {
	*sql.DB
	certstream.Logger
	Backfill              bool                // if true, fill in missing entries in database
	bwlimit.ContextDialer                     // if not nil, ContextDialer used for backfilling
	Pfx                   func(string) string // prefix replacer
	// contains filtered or unexported fields
}

CertPG integrates with sql.DB to manage certificate stream data for a PostgreSQL database

func New

func New(ctx context.Context, cd bwlimit.ContextDialer, db *sql.DB, prefix string) (cdb *CertPG, err error)

New creates a CertPG and creates the needed tables and indices if they don't exist.

func (*CertPG) BackfillStream

func (cdb *CertPG) BackfillStream(ctx context.Context, ls *certstream.LogStream)

func (*CertPG) Close

func (cdb *CertPG) Close() error

Close frees resources used.

func (*CertPG) Entry

func (cdb *CertPG) Entry(ctx context.Context, le *certstream.LogEntry) (err error)

func (*CertPG) Estimate

func (cdb *CertPG) Estimate(table string) (estimate float64, err error)

func (*CertPG) LogError

func (cdb *CertPG) LogError(err error, msg string, args ...any) error

func (*CertPG) Operator

func (cdb *CertPG) Operator(ctx context.Context, lo *certstream.LogOperator) (err error)

func (*CertPG) ScanDnsname

func (cdb *CertPG) ScanDnsname(rows *sql.Rows, dnsname *Dnsname) (err error)

func (*CertPG) Stream

func (cdb *CertPG) Stream(ctx context.Context, ls *certstream.LogStream) (err error)

type Dnsname

type Dnsname struct {
	CertID    int64
	DNSName   string
	NotBefore time.Time
	Idna      bool
	Valid     bool
	PreCert   bool
	Issuer    string
	Subject   string
	Crtsh     string
}