MCPcopy Create free account

hub / github.com/Devanshusharma2005/distributed-search / functions

Functions44 in github.com/Devanshusharma2005/distributed-search

↓ 15 callersMethodClose
()
internal/index/indexer.go:171
↓ 8 callersFunctionwriteError
(w http.ResponseWriter, msg string, code int)
cmd/coordinator/main.go:161
↓ 3 callersMethodGetEmbedding
(ctx context.Context, text string)
internal/embed/client.go:38
↓ 2 callersFunctionCosineSimilarity
(a, b []float64)
internal/hybrid/search.go:503
↓ 2 callersMethodGetEmbedding
(ctx context.Context, text string)
internal/hybrid/search.go:21
↓ 2 callersFunctionNewIndexer
(indexPath string)
internal/index/indexer.go:23
↓ 2 callersFunctionNewIndexerWithVectors
(indexPath string, embedClient *embed.OllamaClient)
internal/index/indexer.go:27
↓ 2 callersFunctionNewOllamaClient
(baseURL, model string)
internal/embed/client.go:28
↓ 2 callersMethodSearch
(ctx context.Context, query string, limit int, alpha float64)
internal/hybrid/search.go:71
↓ 2 callersMethodSearchWithFusion
(ctx context.Context, query string, limit int, alpha float64, fusionMethod string)
internal/hybrid/search.go:75
↓ 2 callersFunctioncacheKey
(endpoint, query string, limit int)
cmd/coordinator/main.go:132
↓ 2 callersFunctiongetFromCache
(ctx context.Context, rdb *redis.Client, key string)
cmd/coordinator/main.go:136
↓ 2 callersFunctiongetShardStats
(counters []int)
cmd/ingester/main.go:97
↓ 2 callersFunctionsetCache
(ctx context.Context, rdb *redis.Client, key string, data []byte)
cmd/coordinator/main.go:147
↓ 2 callersFunctionwriteJSON
(w http.ResponseWriter, v interface{})
cmd/coordinator/main.go:154
↓ 1 callersMethodIndexJSONL
(ctx context.Context, jsonlPath string, batchSize int, maxDocs int)
internal/index/indexer.go:63
↓ 1 callersFunctionNewHybridSearcher
(embedClient EmbeddingClient, etcdEps string)
internal/hybrid/search.go:62
↓ 1 callersFunctioncleanWikiText
(raw string)
cmd/ingester/main.go:41
↓ 1 callersMethoddiscoverShards
(parent context.Context)
internal/hybrid/search.go:330
↓ 1 callersMethodfanoutQueryParallel
(ctx context.Context, shards []string, q string, perShardLimit int)
internal/hybrid/search.go:399
↓ 1 callersMethodfuseWithRRF
(hits []ShardHit, queryVector []float64, limit int)
internal/hybrid/search.go:164
↓ 1 callersMethodfuseWithWeights
(hits []ShardHit, queryVector []float64, alpha float64, limit int)
internal/hybrid/search.go:295
↓ 1 callersMethodgetHotTermShards
(parent context.Context, term string)
internal/hybrid/search.go:364
↓ 1 callersFunctiongetString
(v interface{})
internal/hybrid/search.go:496
↓ 1 callersFunctionhotTermsHandler
(etcdEps string)
cmd/coordinator/main.go:321
↓ 1 callersFunctionhybridHandler
(searcher *hybrid.HybridSearcher, rdb *redis.Client)
cmd/coordinator/main.go:218
↓ 1 callersFunctionparseVector
(field interface{})
internal/hybrid/search.go:479
↓ 1 callersMethodqueryShard
(ctx context.Context, shardAddr, q string, limit int)
internal/hybrid/search.go:427
↓ 1 callersFunctionregisterShard
(ctx context.Context, shardID, port int, hostname, etcdEps string)
cmd/searcher/main.go:115
↓ 1 callersFunctionsearchHandler
(idx bleve.Index, shardID int)
cmd/searcher/main.go:169
↓ 1 callersFunctionsearchHandler
(searcher *hybrid.HybridSearcher, rdb *redis.Client)
cmd/coordinator/main.go:168
↓ 1 callersFunctionshardsHandler
(etcdEps string)
cmd/coordinator/main.go:280
↓ 1 callersFunctiontruncate
(s string, maxLen int)
internal/index/indexer.go:175
↓ 1 callersFunctionworker
(ctx context.Context, id int, in <-chan page, out chan<- model.Doc, counter *atomic.Int64)
cmd/ingester/main.go:69
FunctionFormatHit
(hit *search.DocumentMatch)
internal/search/search.go:7
MethodGetBatchEmbeddings
(ctx context.Context, texts []string)
internal/embed/client.go:84
FunctionhealthHandler
(w http.ResponseWriter, r *http.Request)
cmd/coordinator/main.go:364
Functioninit
()
cmd/searcher/main.go:39
Functioninit
()
cmd/coordinator/main.go:48
Functionmain
()
cmd/etcd-test/main.go:12
Functionmain
()
cmd/indexer/main.go:17
Functionmain
()
cmd/ingester/main.go:111
Functionmain
()
cmd/searcher/main.go:52
Functionmain
()
cmd/coordinator/main.go:65