certpg

package

v0.2.4 Latest Latest Go to latest Published: Nov 12, 2024 License: MIT Imports: 13 Imported by: 0

Details

PostgreSQL schema

View Source

const FunctionOperatorID = `` /* 503-byte string literal not displayed */

View Source

const FunctionStreamID = `` /* 494-byte string literal not displayed */

View Source

const ProcedureCreateSchema = `` /* 3864-byte string literal not displayed */

View Source

const ProcedureNewEntry = `` /* 2752-byte string literal not displayed */

View Source

const SelectGaps = `` /* 203-byte string literal not displayed */

View Source

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

View Source

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

View Source

var BulkRange = int64(4096)

This section is empty.

type CertPG struct {
	*sql.DB
	certstream.Logger
	// contains filtered or unexported fields
}

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

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 (cdb *CertPG) Backfill(ctx context.Context, ls *certstream.LogStream)

func (cdb *CertPG) Close() error

Close frees resources used.

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)