certstream

Jan 16, 2026

Changes in this version

type PgDB

+ func (cdb *PgDB) GetHistoricalCertificates(ctx context.Context, expiresAfter time.Time, ...) (err error)

Jan 13, 2026

Changes in this version

type PgDB

+ func (cdb *PgDB) DeleteCertificates(ctx context.Context, cutoff time.Time, batchSize int) (rowsDeleted int64, err error)

+ func (cdb *PgDB) DeleteStream(ctx context.Context, streamId int32, batchSize int) (rowsDeleted int64, err error)

Jan 8, 2026

Changes in this version

+ var ErrSunlightClientMissing = errors.New("sunlight client missing")

+ var FuncDeleteDomainDuplicates string

type LogEntry

+ Certificate *x509.Certificate

+ LogIndex int64

+ PreCert bool

+ Seen time.Time

+ Signature []byte

type LogOperator

+ func (lo *LogOperator) Email() []string

+ func (lo *LogOperator) Name() string

type LogStream

+ func (ls *LogStream) URL() string

Oct 31, 2025

Changes in this version

+ var SelectAllGaps string

type CertStream

+ func (cs *CertStream) GetLogStreamByID(id int32) (ls *LogStream)

type LogOperator

+ func (lo *LogOperator) GetStreamByID(id int32) (ls *LogStream)

Oct 29, 2025

Changes in this version

type Config

+ PgWorkerBits int

Oct 29, 2025

Changes in this version

type Config

+ GetEntriesParallelism int

Oct 29, 2025

Changes in this version

+ var DbBatchSize = 1000

+ var LogBatchSize = int64(1000)

Oct 29, 2025

Changes in this version

+ var FuncAttachMetadata string

+ var FuncEnsureCert string

+ var FuncIngestBatch string

Oct 15, 2025

Changes in this version

+ func RenderSQL(query string, args ...any) string

Aug 22, 2025

Changes in this version

type Config

+ PgNoSSL bool

May 27, 2025

Changes in this version

type Certificate

+ func (c *Certificate) GetCommonName() (s string)

type JsonCertificate

+ func (js *JsonCertificate) SetCommonName()

May 26, 2025

Changes in this version

+ var SelectIDSince string

type PgDB

+ func (cdb *PgDB) GetCertificateSince(ctx context.Context, cert *JsonCertificate) (since time.Time, err error)

May 26, 2025

Changes in this version

type JsonCertificate

+ Since time.Time

type PgCertificate

+ Since time.Time

May 22, 2025

Changes in this version

type JsonIdentity

+ ID int

May 22, 2025

Changes in this version

+ var FunctionFindSince string

type PgDB

+ func (cdb *PgDB) GetLatestCertificateSince(ctx context.Context, commonname string, subject, issuer int64) (since time.Time, err error)

May 22, 2025

Changes in this version

type PgDB

+ func (cdb *PgDB) GetCertificatesByCommonName(ctx context.Context, commonname string) (certs []*JsonCertificate, err error)

May 22, 2025

Changes in this version

type JsonCertificate

+ CommonName string

May 8, 2025

Changes in this version

type PgDB

+ func (cdb *PgDB) GetCertificatesByCommmonName(ctx context.Context, commonname string) (certs []*JsonCertificate, err error)

Feb 4, 2025

Changes in this version

+ var ErrLogIdle errLogIdle

+ var IdleCloseTime = time.Hour

type LogStream

+ Activity atomic.Int64

Feb 3, 2025

Changes in this version

type PgDnsnamesView

+ Tld string

Jan 29, 2025

Changes in this version

type LogOperator

+ func (lo *LogOperator) ErrorCount() (n int)

+ func (lo *LogOperator) Errors() (errs []StreamError)

+ type StreamError struct

+ Err error

+ When time.Time

+ func (ewt StreamError) Error() string

+ func (ewt StreamError) Unwrap() error

Jan 29, 2025

Changes in this version

type PgDnsnamesView

+ Domain string

+ FQDN string

Jan 24, 2025

Changes in this version

+ var MaxErrors = 25

type LogStream

+ func (ls *LogStream) Errors() (errs []error)

Jan 24, 2025

Changes in this version

type CertStream

+ func (cs *CertStream) Close()

type PgDB

+ Workers atomic.Int32

Jan 23, 2025

Changes in this version

type LogOperator

+ func (lo *LogOperator) StreamCount() (n int)

Jan 23, 2025

Changes in this version

+ var DnsnameIndex string

Jan 22, 2025

Changes in this version

type Config

+ PgMaxAge int

Jan 20, 2025

Changes in this version

type PgDB

+ func (cdb *PgDB) DbError() (err error)

+ func (cdb *PgDB) QueueUsage() (pct int)

Jan 17, 2025

Changes in this version

+ var CreateSchema string

+ var ProcAddNewEntry string

type PgDB

+ func (cdb *PgDB) AverageNewEntryTime() (d time.Duration)

Jan 15, 2025

Changes in this version

type LogStream

+ HeadClient *client.LogClient

+ TailClient *client.LogClient

type PgDB

+ func (cdb *PgDB) Close()

+ func (cdb *PgDB) Load() (pct int)

+ func (cdb *PgDB) Send(ctx context.Context, le *LogEntry)

Jan 14, 2025

Changes in this version

+ const SelectDnsnameLike

+ const SelectEstimate

+ const SelectMaxIndex

+ const SelectMinIndex

+ var BulkRange = int64(4096)

+ var DefaultTransport = &http.Transport

+ var FunctionName string

+ var FunctionOperatorID string

+ var FunctionStreamID string

+ var ProcedureCreateSchema string

+ var ProcedureNewEntry string

+ var SelectGaps string

+ func ScanCertificate(row Scanner, cert *PgCertificate) (err error)

+ func ScanDnsname(row Scanner, p *PgDnsname) error

+ func ScanDnsnamesView(row Scanner, dnsname *PgDnsnamesView) (err error)

+ func ScanIdent(row Scanner, ident *PgIdent) error

+ func ScanLogEntry(row Scanner, entry *PgLogEntry) (err error)

type CertStream

+ C <-chan *LogEntry

+ DB *PgDB

+ HeadClient *http.Client

+ TailClient *http.Client

+ func Start(ctx context.Context, cfg *Config) (cs *CertStream, err error)

+ func (cs *CertStream) LogInfo(msg string, args ...any)

+ type Config struct

+ HeadDialer proxy.ContextDialer

+ Logger Logger

+ PgAddr string

+ PgConns int

+ PgName string

+ PgPass string

+ PgPrefix string

+ PgUser string

+ TailDialer proxy.ContextDialer

+ func NewConfig() *Config

+ type JsonCertificate struct

+ DNSNames []string

+ EmailAddresses []string

+ IPAddresses []string

+ Issuer JsonIdentity

+ NotAfter time.Time

+ NotBefore time.Time

+ PreCert bool

+ Seen time.Time

+ Signature []byte

+ Subject JsonIdentity

+ URIs []string

+ func NewJSONCertificate(cert *Certificate) (jsoncert *JsonCertificate)

+ type JsonIdentity struct

+ CommonName string

+ Country string

+ Organization string

+ Province string

+ func (id *JsonIdentity) Fill(name *pkix.Name)

+ type PgCertificate struct

+ CommonName string

+ Id int64

+ IssuerID int

+ NotAfter time.Time

+ NotBefore time.Time

+ PreCert bool

+ Sha256 []byte

+ SubjectID int

+ type PgDB struct

+ Pfx func(string) string

+ func NewPgDB(ctx context.Context, cs *CertStream) (cdb *PgDB, err error)

+ func (cdb *PgDB) Entry(ctx context.Context, le *LogEntry) (err error)

+ func (cdb *PgDB) Estimate(ctx context.Context, table string) (estimate float64, err error)

+ func (cdb *PgDB) GetCertificateByHash(ctx context.Context, hash []byte) (cert *JsonCertificate, err error)

+ func (cdb *PgDB) GetCertificateByID(ctx context.Context, id int64) (cert *JsonCertificate, err error)

+ func (cdb *PgDB) GetCertificateByLogEntry(ctx context.Context, entry *PgLogEntry) (cert *JsonCertificate, err error)

+ func (cdb *PgDB) Operator(ctx context.Context, lo *LogOperator) (err error)

+ func (cdb *PgDB) Stream(ctx context.Context, ls *LogStream) (err error)

+ type PgDnsname struct

+ CertID int64

+ Dnsname string

+ type PgDnsnamesView struct

+ CertID int64

+ Crtsh string

+ DNSName string

+ Idna bool

+ Issuer string

+ NotBefore time.Time

+ PreCert bool

+ Subject string

+ Valid bool

+ type PgIdent struct

+ Country string

+ Id int

+ Organization string

+ Province string

+ type PgLogEntry struct

+ CertID int64

+ LogIndex int64

+ Seen time.Time

+ StreamID int

+ type Scanner interface

+ Scan func(dest ...any) error

Dec 12, 2024

Changes in this version

type LogEntry

+ Historical bool

Dec 11, 2024

Changes in this version

+ type Certificate struct

+ PreCert bool

+ Seen time.Time

+ Signature []byte

Nov 25, 2024

Changes in this version

type LogStream

+ InsideGaps int64

Nov 20, 2024

Changes in this version

+ var BatchSize = 1024

type LogStream

+ HttpClient *http.Client

Nov 12, 2024

Changes in this version

type LogStream

+ MaxIndex int64

+ MinIndex int64

Nov 12, 2024

Changes in this version

type Logger

+ Info func(msg string, args ...any)

Nov 11, 2024

Changes in this version

type CertStream

+ func (cs *CertStream) LogError(err error, msg string, args ...any)

type LogEntry

+ Id int64

type LogOperator

+ Id int32

type LogStream

+ Backfilled int32

+ Id int32

+ LastIndex int64

+ func (ls *LogStream) GetRawEntries(ctx context.Context, start, end int64, ...)

+ func (ls *LogStream) MakeLogEntry(logindex int64, entry ct.LeafEntry) *LogEntry

+ func (ls *LogStream) NewLastIndex(ctx context.Context) (lastIndex int64, err error)

+ func (ls *LogStream) SendEntry(entryCh chan<- *LogEntry, logindex int64, entry ct.LeafEntry)

+ type Logger interface

+ Error func(msg string, args ...any)

Oct 21, 2024

Changes in this version

type LogOperator

+ Count int64

type LogStream

+ Count int64

+ EndIndex int64

+ Index int64

Oct 18, 2024

Changes in this version

type CertStream

+ func (cs *CertStream) CountStreams() (running, stopped int)

+ type LogOperator struct

+ Domain string

+ Streams []*LogStream

type LogStream

+ Err error

+ func (ls *LogStream) Stopped() bool

Oct 17, 2024

Changes in this version

type CertStream

+ Operators []string

Oct 17, 2024

Changes in this version

+ const PkgName

+ const PkgVersion

+ var DefaultHttpClient = &http.Client

+ func DefaultLogStreamInit(op *loglist3.Operator, log *loglist3.Log) (httpClient *http.Client, startIndex int64)

+ func GetLogList(ctx context.Context, httpClient *http.Client, listUrl string) (logList *loglist3.LogList, err error)

+ func OperatorDomain(urlString string) string

+ type CertStream struct

+ BatchSize int

+ LogStreamInit LogStreamInitFn

+ ParallelFetch int

+ func New() *CertStream

+ func (cs *CertStream) Start(ctx context.Context, logList *loglist3.LogList) (entryCh <-chan *LogEntry, err error)

+ type LogEntry struct

+ Err error

+ RawLogEntry *ct.RawLogEntry

+ func (le *LogEntry) Cert() (cert *x509.Certificate)

+ func (le *LogEntry) DNSNames() (names []string)

+ func (le *LogEntry) Index() (index int64)

+ func (le *LogEntry) String() (s string)

+ type LogStream struct

+ OperatorDomain string

+ func NewLogStream(cs *CertStream, httpClient *http.Client, startIndex int64, ...) (ls *LogStream, err error)

+ func (ls *LogStream) Run(ctx context.Context, entryCh chan<- *LogEntry)

+ func (ls *LogStream) String() string

+ type LogStreamInitFn func(op *loglist3.Operator, log *loglist3.Log) (httpClient *http.Client, startIndex int64)