diff options
| author | elee <eddy@gfxlabs.io> | 2022-03-17 05:09:13 -0500 |
|---|---|---|
| committer | elee <eddy@gfxlabs.io> | 2022-03-17 05:09:13 -0500 |
| commit | f3ab6769e991554969fde3f29fe170a38d34a996 (patch) | |
| tree | d04093fc06ab2499f886bd228e43d5acde194333 /weed/filer/arangodb | |
| parent | 31571dd96e9c3b299dc72d0afac2859098248fc9 (diff) | |
| download | seaweedfs-f3ab6769e991554969fde3f29fe170a38d34a996.tar.xz seaweedfs-f3ab6769e991554969fde3f29fe170a38d34a996.zip | |
make start from indexing work
Diffstat (limited to 'weed/filer/arangodb')
| -rw-r--r-- | weed/filer/arangodb/arangodb_store.go | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/weed/filer/arangodb/arangodb_store.go b/weed/filer/arangodb/arangodb_store.go index dc4fbad84..f10576105 100644 --- a/weed/filer/arangodb/arangodb_store.go +++ b/weed/filer/arangodb/arangodb_store.go @@ -263,16 +263,18 @@ remove d in files`, map[string]interface{}{"dir": dir}) return nil } +//TODO: use fulltext index func (store *ArangodbStore) ListDirectoryPrefixedEntries(ctx context.Context, dirPath util.FullPath, startFileName string, includeStartFile bool, limit int64, prefix string, eachEntryFunc filer.ListEachEntryFunc) (lastFileName string, err error) { return lastFileName, filer.ErrUnsupportedListDirectoryPrefixed } func (store *ArangodbStore) ListDirectoryEntries(ctx context.Context, dirPath util.FullPath, startFileName string, includeStartFile bool, limit int64, eachEntryFunc filer.ListEachEntryFunc) (lastFileName string, err error) { eq := "" - if !includeStartFile { - eq = "filter d.name != \"" + startFileName + "\"" + if includeStartFile { + eq = "filter d.name >= \"" + startFileName + "\"" + } else { + eq = "filter d.name > \"" + startFileName + "\"" } - fmt.Println(dirPath, startFileName, includeStartFile) query := fmt.Sprintf(` for d in files filter d.directory == "%s" |