certstreamui

Documentation

Index

• type CertStreamUI
  • func New(cfg *webserv.Config, mux *http.ServeMux, jw *jaws.Jaws, cdb *certpg.CertPG) (csui *CertStreamUI, err error)
  • func (csui *CertStreamUI) AddRoutes(mux *http.ServeMux)
  • func (csui *CertStreamUI) CertStream() (cs *certstream.CertStream)
  • func (csui *CertStreamUI) Close() (err error)
  • func (csui *CertStreamUI) Run(ctx context.Context)
  • func (csui *CertStreamUI) SettingsLoad() (err error)
  • func (csui *CertStreamUI) SettingsSave() (err error)
  • func (csui *CertStreamUI) Stats() *Stats
  • func (csui *CertStreamUI) UiBackfillLimit() jaws.HtmlGetter
  • func (csui *CertStreamUI) UiClock() jaws.HtmlGetter
  • func (csui *CertStreamUI) UiDomainCount() jaws.HtmlGetter
  • func (csui *CertStreamUI) UiLogEntries() jaws.Container
  • func (csui *CertStreamUI) UiLogOperator(lo *certstream.LogOperator) *uiLogOperator
  • func (csui *CertStreamUI) UiNavLink(rq *http.Request, url, title string) template.HTML
• type Settings
  • func (s *Settings) Load() (err error)
  • func (s *Settings) Save() (err error)
• type Stats
  • func (s *Stats) UiBwBackfill() fmt.Stringer
  • func (s *Stats) UiBwTotal() fmt.Stringer
  • func (s *Stats) UiDbConns() jaws.HtmlGetter
  • func (s *Stats) UiDbLoad() fmt.Stringer
  • func (s *Stats) UiInsideGaps() fmt.Stringer

Types

type CertStreamUI

type CertStreamUI struct {
	Config      *webserv.Config
	Jaws        *jaws.Jaws
	FaviconURI  string
	PkgName     string
	PkgVersion  string
	Settings    Settings
	DomainCount uint64           // atomic
	Limiter     *bwlimit.Limiter // overall bandwidth limiter
	// contains filtered or unexported fields
}

func New

func New(cfg *webserv.Config, mux *http.ServeMux, jw *jaws.Jaws, cdb *certpg.CertPG) (csui *CertStreamUI, err error)

func (*CertStreamUI) AddRoutes

func (csui *CertStreamUI) AddRoutes(mux *http.ServeMux)

func (*CertStreamUI) CertStream

func (csui *CertStreamUI) CertStream() (cs *certstream.CertStream)

func (*CertStreamUI) Close

func (csui *CertStreamUI) Close() (err error)

func (*CertStreamUI) Run

func (csui *CertStreamUI) Run(ctx context.Context)

func (*CertStreamUI) SettingsLoad

func (csui *CertStreamUI) SettingsLoad() (err error)

func (*CertStreamUI) SettingsSave

func (csui *CertStreamUI) SettingsSave() (err error)

func (*CertStreamUI) Stats

func (csui *CertStreamUI) Stats() *Stats

func (*CertStreamUI) UiBackfillLimit

func (csui *CertStreamUI) UiBackfillLimit() jaws.HtmlGetter

func (*CertStreamUI) UiClock

func (csui *CertStreamUI) UiClock() jaws.HtmlGetter

func (*CertStreamUI) UiDomainCount

func (csui *CertStreamUI) UiDomainCount() jaws.HtmlGetter

func (*CertStreamUI) UiLogEntries

func (csui *CertStreamUI) UiLogEntries() jaws.Container

func (*CertStreamUI) UiLogOperator

func (csui *CertStreamUI) UiLogOperator(lo *certstream.LogOperator) *uiLogOperator

func (*CertStreamUI) UiNavLink

func (csui *CertStreamUI) UiNavLink(rq *http.Request, url, title string) template.HTML

type Settings

type Settings struct {
	CertStreamURL string
	MaxBandwidth  int64 // atomic: max allowed bandwidth overall
	FillBandwidth int64 // atomic: max allowed bandwidth for database backfill
	// contains filtered or unexported fields
}

func (*Settings) Load

func (s *Settings) Load() (err error)

func (*Settings) Save

func (s *Settings) Save() (err error)

type Stats

type Stats struct {
	sql.DBStats
	DbLoadPct  int
	InsideGaps int64
	BwTotal    bytecount.Value
	BwBackfill bytecount.Value
	// contains filtered or unexported fields
}

func (*Stats) UiBwBackfill

func (s *Stats) UiBwBackfill() fmt.Stringer

func (*Stats) UiBwTotal

func (s *Stats) UiBwTotal() fmt.Stringer

func (*Stats) UiDbConns

func (s *Stats) UiDbConns() jaws.HtmlGetter

func (*Stats) UiDbLoad

func (s *Stats) UiDbLoad() fmt.Stringer

func (*Stats) UiInsideGaps

func (s *Stats) UiInsideGaps() fmt.Stringer