Versions in this module Expand all Collapse all v0 v0.4.3 Nov 9, 2026 v0.4.2 Nov 4, 2026 Changes in this version type Traffic + func (t *Traffic) SetPoolUpstream(fn func(host string) *url.URL) v0.4.1 Nov 4, 2026 v0.4.0 Nov 4, 2026 Changes in this version + const TrafficSearchDescription + func SeedToolMetas() []actool.CoreTool + func ValidateProxyURL(raw string) (*url.URL, error) + type ArchiveExchange struct + ContentType string + Host string + ID string + Method string + ReqBlob string + ReqBody []byte + ReqHead string + ReqLen int + RespBlob string + RespBody []byte + RespHead string + RespLen int + Status int + TS int64 + URL string + URLTemplate string + type ArchiveSnapshot struct + Blobs []string + Exchanges []ArchiveExchange + Version int + type EvidenceExchange struct + ContentType string + ID string + Method string + ReqHash string + ReqHead string + ReqLen int64 + Request io.Reader + RespHash string + RespHead string + RespLen int64 + Response io.Reader + Status int + TS int64 + URL string + type ExchangeMeta struct + ContentType string + Host string + ID string + Method string + Path string + RespLen int + Status int + TS int64 + URL string + URLTemplate string + type HostCount struct + Count int + Host string + type HostDeleteStage struct + func (s *HostDeleteStage) Commit() error + func (s *HostDeleteStage) Deleted() int64 + func (s *HostDeleteStage) Rollback() error + type PageQuery struct + Body string + Host string + Method string + Order string + Path string + Query string + RespMax int64 + RespMin int64 + Sort string + Status string + type Traffic struct + func Open(dir, addr string) (*Traffic, error) + func (t *Traffic) Blob(hash string) (*os.File, int64, error) + func (t *Traffic) BlobRange(hash string, offset, length int64) (data []byte, total int64, err error) + func (t *Traffic) CACertPath() string + func (t *Traffic) Close() error + func (t *Traffic) Count() (int, error) + func (t *Traffic) DB() *sql.DB + func (t *Traffic) DeleteAll() (deleted int64, reclaimed int64, err error) + func (t *Traffic) DeleteHost(host string) (int64, error) + func (t *Traffic) DeleteHostsExact(hosts []string) (int64, error) + func (t *Traffic) ExportHosts(hosts []string, dir string) (int64, error) + func (t *Traffic) Get(id string) (req, resp string, err error) + func (t *Traffic) Hosts() ([]HostCount, error) + func (t *Traffic) ImportArchive(dir string) (int64, error) + func (t *Traffic) Page(f PageQuery, page, size int) (rows []ExchangeMeta, total int, err error) + func (t *Traffic) ProxyAddr() string + func (t *Traffic) ReadEvidence(ctx context.Context, ids []string, consume func(EvidenceExchange) error) error + func (t *Traffic) RecoverHostDeleteStages(archiveCommitted func(int64, int64) (bool, error)) error + func (t *Traffic) Search(host string, page, size int) ([]ExchangeMeta, error) + func (t *Traffic) SetUpstreamProxy(raw string) error + func (t *Traffic) StageDeleteHostsExact(hosts []string) (*HostDeleteStage, error) + func (t *Traffic) StageDeleteHostsExactForArchive(hosts []string, archiveID, taskID int64) (*HostDeleteStage, error) + func (t *Traffic) Start() error + func (t *Traffic) Tools() []actool.CoreTool
Go to main page