certpg

README

PostgreSQL schema

Documentation

Index

• Constants
• Variables
• type CertPG
  • func New(ctx context.Context, 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) LogError(err error, msg string, args ...any) error
  • func (cdb *CertPG) Operator(ctx context.Context, lo *certstream.LogOperator) (err error)
  • func (cdb *CertPG) Stream(ctx context.Context, ls *certstream.LogStream) (err error)

Constants

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 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.Limiter      // limiter used when backfilling
	// 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, 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) 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) Stream

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