stream

type Engine struct {
	// contains filtered or unexported fields
}

type HealthTrace struct {
	Warm    time.Duration `json:"warm"`
	Parse   time.Duration `json:"parse"`
	Plan    time.Duration `json:"plan"`
	STAT    time.Duration `json:"stat"`
	Samples int           `json:"samples"`
	// BODY probe results: the mid-file segments verified with a real
	// BODY (yEnc header) read, since STAT 223 does not prove a BODY
	// would not be taken down (451).
	Body       time.Duration `json:"body"`
	BodyProbes int           `json:"bodyProbes"`
	BodyOK     int           `json:"bodyOk"`
	// FailFast is set when the check bailed out on the first confirmed
	// missing article instead of waiting for every sample; FailReason
	// says which probe decided it.
	FailFast   bool   `json:"failFast"`
	FailReason string `json:"failReason,omitempty"`
}

type Options struct {
	Repair config.Repair
	// HotBufferBytes bounds decoded segments kept in memory across all
	// sources (default 256 MiB).
	HotBufferBytes int64
	// ReadAheadMin is the initial read-ahead window of a sequential reader
	// (default 4 MiB); it grows with the bytes read up to ReadAheadMax
	// (default 64 MiB).
	ReadAheadMin int64
	ReadAheadMax int64
	// ReadAheadParallel caps concurrent read-ahead fetches per source
	// (default 8).
	ReadAheadParallel int
	// ReadParallel caps concurrent fetches serving one ReadAt (default 16).
	ReadParallel int
	// PrefetchParallel caps concurrent fetches of one Prefetch call
	// (default 4).
	PrefetchParallel int
	// HealthSamples is how many articles Check STATs (default 12, from
	// config Resolver.HealthSamples).
	HealthSamples int
	// HealthParallel caps concurrent STATs of one Check (default 16).
	HealthParallel int
	// OpenParallel caps concurrent header fetches while opening (default 16).
	OpenParallel int
	// ReadTimeout bounds one ReadAt (default 90 s); ReadAt has no context.
	ReadTimeout time.Duration
	// MaxReleases is how many parsed release indexes are kept for reuse
	// (default 32). Releases with open sources are never dropped.
	MaxReleases int
	// Retries is how often a failed article fetch (other than missing or
	// cancelled) is retried (default 2).
	Retries int
	// MaxProbes bounds articles fetched to identify obfuscated files
	// (default 64).
	MaxProbes int
}

type Stats struct {
	RepairLastReason   string
	RepairAttempts     int64
	RepairSuccesses    int64
	RepairFailures     int64
	RepairInputBytes   int64
	RepairSummaryBytes int64
	Fetches            int64 // articles fetched from Usenet
	FetchedBytes       int64 // decoded bytes fetched from Usenet
	HotHits            int64 // segments served from memory
	CacheHits          int64 // segments served from the disk cache
	Missing            int64 // articles missing on every provider
	Coalesced          int64 // requests that joined an in-flight fetch
	HotBytes           int64 // bytes currently in the hot buffer
	OpenReleases       int   // release indexes held
	ActiveSources      int64

	// PAR2 (see par2.go): index files parsed, unusable (fetched but not
	// parseable) and skipped as oversize; obfuscated files named from PAR2;
	// head probes of obfuscated files avoided thanks to it; first volumes
	// verified against it and found not matching.
	Par2Loaded      int64
	Par2Failed      int64
	Par2Skipped     int64
	Par2Named       int64
	Par2ProbesSaved int64
	Par2Verified    int64
	Par2Mismatches  int64
}