indexwrapper

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

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

type CompressType uint8

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

type Index interface {
	io.Closer
	Destroy() error

	// Dedup returns wether the specified key is existed
	// If key is existed, return ErrDuplicate
	// If any other unknown error happens, return error
	// If key is not found, return nil
	Dedup(key any) error

	BatchDedup(keys containers.Vector, rowmask *roaring.Bitmap) (keyselects *roaring.Bitmap, err error)

	// BatchUpsert batch insert the specific keys
	// If any deduplication, it will fetch the old value first, fill the active map with new value, insert the old value into delete map
	// If any other unknown error hanppens, return error
	BatchUpsert(keysCtx *index.KeysCtx, offset int, ts uint64) (*index.BatchResp, error)

	// Delete delete the specific key
	// If the specified key not found in active map, return ErrNotFound
	// If any other error happens, return error
	// Delete the specific key from active map and then insert it into delete map
	Delete(key any, ts uint64) error
	GetActiveRow(key any) (row uint32, err error)
	// Check deletes map for specified key @ts
	// If deleted is true, the specified key was deleted @ts
	// If existed is false, the specified key was not found in deletes map
	IsKeyDeleted(key any, ts uint64) (deleted bool, existed bool)
	HasDeleteFrom(key any, fromTs uint64) bool
	GetMaxDeleteTS() uint64

	String() string

	ReadFrom(data.Block) error
	WriteTo(data.Block) error
}

type IndexMeta struct {
	IdxType     IndexType
	CompType    CompressType
	ColIdx      uint16
	InternalIdx uint16
	Size        uint32
	RawSize     uint32
}

type IndexType uint8

type IndicesMeta struct {
	Metas []IndexMeta
}

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

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