get all index entries for the local json metadata

Author: akvlad

json_index.go

@@ -79,6 +79,20 @@ func (J *JSONIndex) GetQuerier() TableQuerier {
 	return J
 }
 
+func (J *JSONIndex) GetAll() ([]*IndexEntry, error) {
+	var res []*IndexEntry
+	for _, l := range J.parts {
+		for _, parts := range l {
+			_res, err := parts.GetAll()
+			if err != nil {
+				return nil, err
+			}
+			res = append(res, _res...)
+		}
+	}
+	return res, nil
+}
+
 func (J *JSONIndex) Batch(add []*IndexEntry, rm []*IndexEntry) Promise[int32] {
 	J.lock.Lock()
 	defer J.lock.Unlock()

json_part_index.go

@@ -79,6 +79,15 @@ func newJsonPartIndex(opts jsonPartIdxOpts) (*jsonPartIndex, error) {
 	return res, err
 }
 
+func (J *jsonPartIndex) GetAll() ([]*IndexEntry, error) {
+	var res []*IndexEntry
+	J.entries.Range(func(key, value interface{}) bool {
+		res = append(res, J.jEntry2Entry(value.(*jsonIndexEntry)))
+		return true
+	})
+	return res, nil
+}
+
 func (J *jsonPartIndex) getLayer(name string) int {
 	for i, layer := range J.layers {
 		if layer.Name == name {

redis_index.go

@@ -154,6 +154,10 @@ func (r *RedisIndex) initFuncs() error {
 	return err
 }
 
+func (r *RedisIndex) GetAll() ([]*IndexEntry, error) {
+	return nil, fmt.Errorf("not implemented")
+}
+
 func (r *RedisIndex) Batch(add []*IndexEntry, rm []*IndexEntry) Promise[int32] {
 	var cmds []any
 	for _, entry := range add {

types.go

@@ -122,6 +122,7 @@ type TableIndex interface {
 	GetQuerier() TableQuerier
 	GetMovePlanner() TableMovePlanner
 	GetDropPlanner() TableDropPlanner
+	GetAll() ([]*IndexEntry, error)
 }
 
 type TableDropPlanner interface {