Documentation
¶
Index ¶
- func GetLogOperators() map[string][]string
- func GetProcessedCerts() int64
- func GetProcessedPrecerts() int64
- func ParseCertstreamEntry(rawEntry *ct.RawLogEntry, operatorName, logname, ctURL string) (models.Entry, error)
- type CTCertIndex
- type CTMetrics
- type LogMetrics
- func (m *LogMetrics) Get(operator, url string) int64
- func (m *LogMetrics) GetAllCTIndexes() CTCertIndex
- func (m *LogMetrics) GetCTIndex(url string) uint64
- func (m *LogMetrics) GetCTMetrics() CTMetrics
- func (m *LogMetrics) Inc(operator, url string, index uint64)
- func (m *LogMetrics) Init(operator, url string)
- func (m *LogMetrics) LoadCTIndex(ctIndexFilePath string)
- func (m *LogMetrics) OperatorLogMapping() OperatorLogs
- func (m *LogMetrics) SaveCertIndexes(ctIndexFilePath string)
- func (m *LogMetrics) SaveCertIndexesAtInterval(interval time.Duration, ctIndexFilePath string)
- func (m *LogMetrics) Set(operator, url string, value int64)
- func (m *LogMetrics) SetCTIndex(url string, index uint64)
- type OperatorLogs
- type OperatorMetric
- type Watcher
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetLogOperators ¶
func GetProcessedCerts ¶
func GetProcessedCerts() int64
GetProcessedCerts returns the total number of processed certificates.
func GetProcessedPrecerts ¶
func GetProcessedPrecerts() int64
GetProcessedPrecerts returns the total number of processed precertificates.
func ParseCertstreamEntry ¶ added in v1.8.0
func ParseCertstreamEntry(rawEntry *ct.RawLogEntry, operatorName, logname, ctURL string) (models.Entry, error)
ParseCertstreamEntry creates an Entry from a ct.RawLogEntry.
Types ¶
type CTCertIndex ¶
CTCertIndex is a map of CT log urls to the last processed certficate index on the said log.
type CTMetrics ¶
type CTMetrics map[string]OperatorMetric
CTMetrics is a map of operator names to a map of CT log urls to the number of certs processed by said log.
func GetCertMetrics ¶
func GetCertMetrics() CTMetrics
type LogMetrics ¶
type LogMetrics struct {
// contains filtered or unexported fields
}
LogMetrics is a struct that holds a map of metrics for each CT log grouped by operator. Metrics can be accessed and written concurrently through the Get, Set and Inc methods.
func (*LogMetrics) Get ¶
func (m *LogMetrics) Get(operator, url string) int64
Get the metric for a given operator and ct url.
func (*LogMetrics) GetAllCTIndexes ¶
func (m *LogMetrics) GetAllCTIndexes() CTCertIndex
GetAllCTIndexes returns a copy of the internal CT index map.
func (*LogMetrics) GetCTIndex ¶
func (m *LogMetrics) GetCTIndex(url string) uint64
GetCTIndex returns the last cert index processed for a given CT url.
func (*LogMetrics) GetCTMetrics ¶
func (m *LogMetrics) GetCTMetrics() CTMetrics
GetCTMetrics returns a copy of the internal metrics map.
func (*LogMetrics) Inc ¶
func (m *LogMetrics) Inc(operator, url string, index uint64)
Inc the metric for a given operator and ct url.
func (*LogMetrics) Init ¶ added in v1.7.0
func (m *LogMetrics) Init(operator, url string)
Init initializes the internal metrics map with the given operator names and CT log urls if it doesn't exist yet.
func (*LogMetrics) LoadCTIndex ¶
func (m *LogMetrics) LoadCTIndex(ctIndexFilePath string)
LoadCTIndex loads the last cert index processed for each CT url if it exists.
func (*LogMetrics) OperatorLogMapping ¶
func (m *LogMetrics) OperatorLogMapping() OperatorLogs
OperatorLogMapping returns a map of operator names to a list of CT logs.
func (*LogMetrics) SaveCertIndexes ¶
func (m *LogMetrics) SaveCertIndexes(ctIndexFilePath string)
SaveCertIndexes saves the index of CTLogs to a file.
func (*LogMetrics) SaveCertIndexesAtInterval ¶
func (m *LogMetrics) SaveCertIndexesAtInterval(interval time.Duration, ctIndexFilePath string)
SaveCertIndexesAtInterval saves the index of CTLogs at given intervals. We first create a temp file and write the index data to it. Only then do we move the temp file to the actual permanent index file. This prevents the last good index file from being clobbered if the program was shutdown/killed in-between the write operation.
func (*LogMetrics) Set ¶
func (m *LogMetrics) Set(operator, url string, value int64)
Set the metric for a given operator and ct url.
func (*LogMetrics) SetCTIndex ¶
func (m *LogMetrics) SetCTIndex(url string, index uint64)
SetCTIndex sets the index for a given CT url.
type OperatorLogs ¶
OperatorLogs is a map of operator names to a list of CT log urls, operated by said operator.
type OperatorMetric ¶
OperatorMetric is a map of CT log urls to the number of certs processed by said log.
type Watcher ¶
type Watcher struct {
// contains filtered or unexported fields
}
Watcher describes a component that watches for new certificates in a CT log.
func NewWatcher ¶ added in v1.5.0
NewWatcher creates a new Watcher.
func (*Watcher) CreateIndexFile ¶
CreateIndexFile creates a ct_index.json file based on the current STHs of all availble logs.
Source Files