metadata

type DBIndex interface {
	Databases() ([]string, error)
	Tables(database string) ([]string, error)
	Paths(database string, table string) ([]string, error)
}

type IndexEntry struct {
	Layer     string         `json:"layer"`
	Database  string         `json:"database"`
	Table     string         `json:"table"`
	Path      string         `json:"path"`
	SizeBytes int64          `json:"size_bytes"`
	RowCount  int64          `json:"row_count"`
	ChunkTime int64          `json:"chunk_time"`
	Min       map[string]any `json:"min"`
	Max       map[string]any `json:"max"`
	MinTime   int64          `json:"min_time"`
	MaxTime   int64          `json:"max_time"`
}

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

type MergeConfigurationsConf [][3]int64

type MergePlan struct {
	ID        string
	Layer     string
	Database  string
	Table     string
	From      []string
	To        string
	Iteration int
}

type Promise[T any] interface {
	Get() (T, error)
	Peek() (int32, T, error)
	Done(res T, err error)
}

type QEntry struct {
	Path  string `json:"path"`
	TimeS int32  `json:"time"`
}

type QueryOptions struct {
	Folder    string
	After     time.Time
	Before    time.Time
	Iteration int
}

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

type SinglePromise[T any] struct {
	// contains filtered or unexported fields
}

type TableIndex interface {
	Batch(add []*IndexEntry, rm []*IndexEntry) Promise[int32]
	Get(path string) *IndexEntry
	Run()
	Stop()
	RmFromDropQueue(files []string) Promise[int32]
	GetDropQueue() []string
	GetMergePlanner() TableMergePlanner
	GetQuerier() TableQuerier
}

type TableMergePlanner interface {
	GetMergePlan(layer string, iteration int) (*MergePlan, error)
	EndMerge(plan *MergePlan) error
}

type TableQuerier interface {
	Query(options QueryOptions) ([]*IndexEntry, error)
}

type WaitForAllPromise[T any] struct {
	// contains filtered or unexported fields
}