fracmanager

type AsyncSearchRequest struct {
	ID        string
	Params    processor.SearchParams
	Query     string
	Retention time.Duration
}

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

type AsyncSearcherConfig struct {
	DataDir     string
	Parallelism int
}

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

type CacheMaintainerMetrics struct {
	HitsTotal       *prometheus.CounterVec
	MissTotal       *prometheus.CounterVec
	PanicsTotal     *prometheus.CounterVec
	LockWaitsTotal  *prometheus.CounterVec
	WaitsTotal      *prometheus.CounterVec
	ReattemptsTotal *prometheus.CounterVec
	SizeRead        *prometheus.CounterVec
	SizeOccupied    *prometheus.CounterVec
	SizeReleased    *prometheus.CounterVec
	MapsRecreated   *prometheus.CounterVec
	MissLatency     *prometheus.CounterVec

	Oldest            *prometheus.GaugeVec
	AddBuckets        *prometheus.CounterVec
	DelBuckets        *prometheus.CounterVec
	CleanGenerations  *prometheus.CounterVec
	ChangeGenerations *prometheus.CounterVec
}

type Config struct {
	DataDir string

	FracSize  uint64
	TotalSize uint64
	CacheSize uint64

	FracLoadLimit     uint64 // how many sealed fractions should fracmanager load, if 0 then loads all
	ShouldReplay      bool
	MaintenanceDelay  time.Duration
	CacheCleanupDelay time.Duration
	CacheGCDelay      time.Duration
	SealParams        frac.SealParams
	SortCacheSize     uint64 // size for docs cache for active fraction
	Fraction          frac.Config
}

type FetchSearchResultRequest struct {
	ID string
}

type FetchSearchResultResponse struct {
	QPR        seq.QPR
	Expiration time.Time
	Done       bool

	// Stuff that needed seq-db proxy to complete async search response.
	AggQueries   []processor.AggQuery
	HistInterval uint64
	Order        seq.DocsOrder
}

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

type FracManager struct {
	OldestCT atomic.Uint64
	// contains filtered or unexported fields
}

type List []frac.Fraction

type MappingProvider interface {
	GetMapping() seq.Mapping
}

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

type SearcherCfg struct {
	MaxFractionHits       int // the maximum number of fractions used in the search
	FractionsPerIteration int
}