Versions in this module Expand all Collapse all v1 v1.1.2 Mar 3, 2020 Changes in this version + type FetchOptions struct + BatchSize int + FlushInterval time.Duration + ParallelFetch int + Reporter incident.Reporter + State ScanStateManager + type FileStateManager struct + func NewFileStateManager(filename string) (*FileStateManager, error) + func (f *FileStateManager) Flush(ctx context.Context) error + type Goshawk struct + func NewBoundaryGoshawk(_ context.Context, cfg *configpb.GoshawkConfig, hcLog, hcHub *http.Client, ...) (*Goshawk, error) + func NewBoundaryGoshawkFromFile(ctx context.Context, filename string, hcLog, hcHub *http.Client, ...) (*Goshawk, error) + func NewGoshawk(ctx context.Context, cfg *configpb.GoshawkConfig, hc *http.Client, ...) (*Goshawk, error) + func NewGoshawkFromFile(ctx context.Context, filename string, hc *http.Client, fetchOpts FetchOptions) (*Goshawk, error) + func (hawk *Goshawk) Fly(ctx context.Context) + type Gossiper struct + func NewBoundaryGossiper(ctx context.Context, cfg *configpb.GossipConfig, hcLog, hcHub *http.Client, ...) (*Gossiper, error) + func NewBoundaryGossiperFromFile(ctx context.Context, filename string, hcLog, hcHub *http.Client, ...) (*Gossiper, error) + func NewGossiper(ctx context.Context, cfg *configpb.GossipConfig, hc *http.Client, ...) (*Gossiper, error) + func NewGossiperFromFile(ctx context.Context, filename string, hc *http.Client, ...) (*Gossiper, error) + func (g *Gossiper) CertForSTH(name, url string, sth *ct.SignedTreeHead) (*ct.ASN1Cert, error) + func (g *Gossiper) CheckCanSubmit(ctx context.Context) error + func (g *Gossiper) Run(ctx context.Context) + func (g *Gossiper) Submitter(ctx context.Context, s <-chan sthInfo) + type ScanState struct + Mu sync.Mutex + Next map[string]int64 + func (s *ScanState) GetHubIndex(hubURL string) int64 + func (s *ScanState) UpdateHubIndex(hubURL string, nextIndex int64) + type ScanStateManager interface + Flush func(ctx context.Context) error + GetHubIndex func(hubURL string) int64 + UpdateHubIndex func(hubURL string, nextIndex int64)