ctstream

Aug 30, 2024

Changes in this version

+ var MaxThread = 100

type CTClient

+ func (ctstream *CTClient) SleepToAdjustThreadNum()

Aug 29, 2024

Changes in this version

+ var FetchingThread = 0

Aug 7, 2024

Changes in this version

type CTsStream

+ func SemiDefaultCTsStream(streams []*CTStream, sleep time.Duration) (*CTsStream, error)

Aug 7, 2024

Changes in this version

type CTStream

+ func (stream *CTStream) Start(callback Callback)

Aug 7, 2024

Changes in this version

+ var DefaultSleep = 1 * time.Second

type CTStream

+ Ctx context.Context

+ Wg sync.WaitGroup

+ func (stream *CTStream) Await()

Aug 6, 2024

Changes in this version

type CTsStream

+ Streams []*CTStream

Aug 6, 2024

Changes in this version

type CTsStream

+ func (stream *CTsStream) Await()

+ func (stream *CTsStream) Start(callback Callback, sleep time.Duration)

Aug 6, 2024

Changes in this version

+ var DefaultMaxEntries int64 = 256

Aug 6, 2024

Changes in this version

+ type CTClient struct

+ Sleep time.Duration

+ Url string

+ func DefaultCTClient(url string) (*CTClient, error)

+ func NewCTClient(url string, maxEntrySize int64, ops jsonclient.Options) (*CTClient, error)

+ func (stream *CTClient) Init() error

+ func (stream *CTClient) Next() ([]ct.LogEntry, error)

type CTStream

+ Client *CTClient

+ func DefaultCTStream(url string) (*CTStream, error)

+ func NewCTStream(client *CTClient) (*CTStream, error)

+ type CTsStream struct

+ Sleep time.Duration

+ func DefaultCTsStream(urls []string) (*CTsStream, error)

+ func NewCTsStream(streams []*CTStream) (*CTsStream, error)

+ func (stream *CTsStream) Init() error

+ func (stream *CTsStream) Next(callback Callback)

+ func (stream *CTsStream) Run(callback Callback, sleep time.Duration)

+ func (stream *CTsStream) Stop()

Jul 7, 2024

Changes in this version

+ const DEFAULT_MAX_ENTRIES

type CTStream

+ MaxEntrySize int

+ func Default(urls []string, sleep time.Duration) (*CTStream, error)

Jul 7, 2024

Changes in this version

type CTStream

+ func (stream *CTStream) Stop()

Jun 12, 2024

Changes in this version

+ const ERROR_FAILED_TO_FETCH_STH

+ const ERROR_FAILED_TO_GET_CERT

+ const ERROR_FAILED_TO_NEW

+ const ERROR_FAILED_TO_PARSE_CERT

+ const ERROR_NEW_LOGS_NOT_FOUND

+ const NO_CERT_AND_PRECERT_LEAF

+ func ExtractCertFromEntry(entry *ct.LogEntry) (*ctx509.Certificate, error)

+ type CTStream struct

+ Sleep time.Duration

+ func New(urls []string, sleep time.Duration) (*CTStream, error)

+ func (stream *CTStream) Init() error

+ func (stream *CTStream) Next(callback Callback)

+ func (stream *CTStream) Run(callback Callback)

+ type Callback func(*ctx509.Certificate, LogID, *client.LogClient, error)

+ type LogID = int64