frac

type Active struct {
	Config *Config

	BaseFileName string

	MIDs *UInt64s
	RIDs *UInt64s

	DocBlocks *UInt64s

	TokenList *TokenList

	DocsPositions *DocsPositions
	// contains filtered or unexported fields
}

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

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

type AggLimits struct {
	MaxFieldTokens     int // MaxFieldTokens max AggQuery.Field uniq values to parse.
	MaxGroupTokens     int // MaxGroupTokens max AggQuery.GroupBy unique values.
	MaxTIDsPerFraction int // MaxTIDsPerFraction max number of tokens per fraction.
}

type BlockInfo struct {
	Info *Info
}

type BlockOffsets struct {
	IDsTotal uint32 // todo: the best place for this field is Info block
	Offsets  []uint64
}

type Config struct {
	Search SearchConfig

	SkipSortDocs bool
	KeepMetaFile bool
}

type DataProvider interface {
	Fetch([]seq.ID) ([][]byte, error)
	Search(processor.SearchParams) (*seq.QPR, error)
}

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

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

type DocProvider struct {
	DocCount int
	Docs     []byte
	Metas    []byte
	// contains filtered or unexported fields
}

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

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

type EmptyDataProvider struct{}

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

type Fraction interface {
	Info() *Info
	IsIntersecting(from seq.MID, to seq.MID) bool
	Contains(mid seq.MID) bool
	DataProvider(context.Context) (DataProvider, func())
	Offload(ctx context.Context, u storage.Uploader) (bool, error)
	Suicide()
}

type IndexCache struct {
	Registry   *cache.Cache[[]byte]
	MIDs       *cache.Cache[[]byte]
	RIDs       *cache.Cache[[]byte]
	Params     *cache.Cache[seqids.BlockParams]
	Tokens     *cache.Cache[*token.Block]
	TokenTable *cache.Cache[token.Table]
	LIDs       *cache.Cache[*lids.Block]
}

type Info struct {
	Path          string                   `json:"name"`
	Ver           string                   `json:"ver"`
	BinaryDataVer config.BinaryDataVersion `json:"binary_data_ver"`
	DocsTotal     uint32                   `json:"docs_total"`
	DocsOnDisk    uint64                   `json:"docs_on_disk"`  // how much compressed docs data is stored on disk
	DocsRaw       uint64                   `json:"docs_raw"`      // how much raw docs data is appended
	MetaOnDisk    uint64                   `json:"meta_on_disk"`  // how much compressed metadata is stored on disk
	IndexOnDisk   uint64                   `json:"index_on_disk"` // how much compressed index data is stored on disk

	ConstRegularBlockSize int `json:"const_regular_block_size"`
	ConstIDsPerBlock      int `json:"const_ids_per_block"`
	ConstLIDBlockCap      int `json:"const_lid_block_cap"`

	From         seq.MID               `json:"from"`
	To           seq.MID               `json:"to"`
	CreationTime uint64                `json:"creation_time"`
	SealingTime  uint64                `json:"sealing_time"`
	Distribution *seq.MIDsDistribution `json:"distribution"`
}

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

type MetaData struct {
	ID seq.ID
	// Size of an uncompressed document in bytes.
	Size   uint32
	Tokens []MetaToken
}

type MetaToken struct {
	Key   []byte
	Value []byte
}

type PSD int // emulates hard shutdown on different stages of fraction deletion, used for tests

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

type Remote struct {
	Config *Config

	BaseFileName string
	// contains filtered or unexported fields
}

type SealParams struct {
	IDsZstdLevel           int
	LIDsZstdLevel          int
	TokenListZstdLevel     int
	DocsPositionsZstdLevel int
	TokenTableZstdLevel    int

	DocBlocksZstdLevel int // DocBlocksZstdLevel is the zstd compress level of each document block.
	DocBlockSize       int // DocBlockSize is decompressed payload size of document block.
}

type Sealed struct {
	Config *Config

	BaseFileName string

	// shit for testing
	PartialSuicideMode PSD
	// contains filtered or unexported fields
}

type SearchConfig struct {
	AggLimits AggLimits
}

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

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

type TokenList struct {
	FieldTIDs map[string][]uint32
	// contains filtered or unexported fields
}

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