Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Devanshusharma2005/distributed-search
/ functions
Functions
44 in github.com/Devanshusharma2005/distributed-search
⨍
Functions
44
◇
Types & classes
16
↓ 15 callers
Method
Close
()
internal/index/indexer.go:171
↓ 8 callers
Function
writeError
(w http.ResponseWriter, msg string, code int)
cmd/coordinator/main.go:161
↓ 3 callers
Method
GetEmbedding
(ctx context.Context, text string)
internal/embed/client.go:38
↓ 2 callers
Function
CosineSimilarity
(a, b []float64)
internal/hybrid/search.go:503
↓ 2 callers
Method
GetEmbedding
(ctx context.Context, text string)
internal/hybrid/search.go:21
↓ 2 callers
Function
NewIndexer
(indexPath string)
internal/index/indexer.go:23
↓ 2 callers
Function
NewIndexerWithVectors
(indexPath string, embedClient *embed.OllamaClient)
internal/index/indexer.go:27
↓ 2 callers
Function
NewOllamaClient
(baseURL, model string)
internal/embed/client.go:28
↓ 2 callers
Method
Search
(ctx context.Context, query string, limit int, alpha float64)
internal/hybrid/search.go:71
↓ 2 callers
Method
SearchWithFusion
(ctx context.Context, query string, limit int, alpha float64, fusionMethod string)
internal/hybrid/search.go:75
↓ 2 callers
Function
cacheKey
(endpoint, query string, limit int)
cmd/coordinator/main.go:132
↓ 2 callers
Function
getFromCache
(ctx context.Context, rdb *redis.Client, key string)
cmd/coordinator/main.go:136
↓ 2 callers
Function
getShardStats
(counters []int)
cmd/ingester/main.go:97
↓ 2 callers
Function
setCache
(ctx context.Context, rdb *redis.Client, key string, data []byte)
cmd/coordinator/main.go:147
↓ 2 callers
Function
writeJSON
(w http.ResponseWriter, v interface{})
cmd/coordinator/main.go:154
↓ 1 callers
Method
IndexJSONL
(ctx context.Context, jsonlPath string, batchSize int, maxDocs int)
internal/index/indexer.go:63
↓ 1 callers
Function
NewHybridSearcher
(embedClient EmbeddingClient, etcdEps string)
internal/hybrid/search.go:62
↓ 1 callers
Function
cleanWikiText
(raw string)
cmd/ingester/main.go:41
↓ 1 callers
Method
discoverShards
(parent context.Context)
internal/hybrid/search.go:330
↓ 1 callers
Method
fanoutQueryParallel
(ctx context.Context, shards []string, q string, perShardLimit int)
internal/hybrid/search.go:399
↓ 1 callers
Method
fuseWithRRF
(hits []ShardHit, queryVector []float64, limit int)
internal/hybrid/search.go:164
↓ 1 callers
Method
fuseWithWeights
(hits []ShardHit, queryVector []float64, alpha float64, limit int)
internal/hybrid/search.go:295
↓ 1 callers
Method
getHotTermShards
(parent context.Context, term string)
internal/hybrid/search.go:364
↓ 1 callers
Function
getString
(v interface{})
internal/hybrid/search.go:496
↓ 1 callers
Function
hotTermsHandler
(etcdEps string)
cmd/coordinator/main.go:321
↓ 1 callers
Function
hybridHandler
(searcher *hybrid.HybridSearcher, rdb *redis.Client)
cmd/coordinator/main.go:218
↓ 1 callers
Function
parseVector
(field interface{})
internal/hybrid/search.go:479
↓ 1 callers
Method
queryShard
(ctx context.Context, shardAddr, q string, limit int)
internal/hybrid/search.go:427
↓ 1 callers
Function
registerShard
(ctx context.Context, shardID, port int, hostname, etcdEps string)
cmd/searcher/main.go:115
↓ 1 callers
Function
searchHandler
(idx bleve.Index, shardID int)
cmd/searcher/main.go:169
↓ 1 callers
Function
searchHandler
(searcher *hybrid.HybridSearcher, rdb *redis.Client)
cmd/coordinator/main.go:168
↓ 1 callers
Function
shardsHandler
(etcdEps string)
cmd/coordinator/main.go:280
↓ 1 callers
Function
truncate
(s string, maxLen int)
internal/index/indexer.go:175
↓ 1 callers
Function
worker
(ctx context.Context, id int, in <-chan page, out chan<- model.Doc, counter *atomic.Int64)
cmd/ingester/main.go:69
Function
FormatHit
(hit *search.DocumentMatch)
internal/search/search.go:7
Method
GetBatchEmbeddings
(ctx context.Context, texts []string)
internal/embed/client.go:84
Function
healthHandler
(w http.ResponseWriter, r *http.Request)
cmd/coordinator/main.go:364
Function
init
()
cmd/searcher/main.go:39
Function
init
()
cmd/coordinator/main.go:48
Function
main
()
cmd/etcd-test/main.go:12
Function
main
()
cmd/indexer/main.go:17
Function
main
()
cmd/ingester/main.go:111
Function
main
()
cmd/searcher/main.go:52
Function
main
()
cmd/coordinator/main.go:65