certstream

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) 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)