Skip to content

feat: add querier json #1288

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 42 commits into from
Apr 16, 2025
Merged
Changes from 1 commit
Commits
Show all changes
42 commits
Select commit Hold shift + click to select a range
2d1aa22
generic metadata for ingestor and indexer
nikhilsinhaparseable Apr 7, 2025
b8243a2
add querier metadata
nikhilsinhaparseable Apr 7, 2025
59b9867
remove writing query metadata to storage
nikhilsinhaparseable Apr 7, 2025
dcd9b1b
remove unused
nikhilsinhaparseable Apr 7, 2025
a718691
clone from
nikhilsinhaparseable Apr 7, 2025
358af90
split into smaller functions
nikhilsinhaparseable Apr 7, 2025
1c1fb33
clippy suggestions
nikhilsinhaparseable Apr 7, 2025
d39fb47
helper function
nikhilsinhaparseable Apr 7, 2025
bef7984
add Prism mode
nikhilsinhaparseable Apr 7, 2025
4145db2
prism mode to option
nikhilsinhaparseable Apr 8, 2025
8ba0f90
add serde error to QueryError
nikhilsinhaparseable Apr 8, 2025
f5c2088
add custom error
nikhilsinhaparseable Apr 8, 2025
4e4c38f
overwrite remote for Prism mode
nikhilsinhaparseable Apr 8, 2025
2599aa8
make public
nikhilsinhaparseable Apr 8, 2025
166b2cb
make mod store_metadata public
nikhilsinhaparseable Apr 8, 2025
303b7c0
active/inactive indexers and queriers in analytics
nikhilsinhaparseable Apr 8, 2025
64ce915
add error to query error
nikhilsinhaparseable Apr 8, 2025
074b44c
add prism check for various methods
nikhilsinhaparseable Apr 8, 2025
8c164ff
update logic for check or load stream
nikhilsinhaparseable Apr 9, 2025
143e3f2
update logic for load stream
nikhilsinhaparseable Apr 9, 2025
30165c3
revert restriction for enterprise to oss
nikhilsinhaparseable Apr 10, 2025
c6159ff
add comment for check or load stream
nikhilsinhaparseable Apr 10, 2025
7a3a662
self in cluster info
nikhilsinhaparseable Apr 12, 2025
22f763e
add scheme to cluster info
nikhilsinhaparseable Apr 12, 2025
1429877
self metadata for cluster info and metrics
nikhilsinhaparseable Apr 14, 2025
2232af8
update url fetch
nikhilsinhaparseable Apr 14, 2025
1e4728f
add prism metadata for node info
nikhilsinhaparseable Apr 14, 2025
48b121c
refactor url parsing
nikhilsinhaparseable Apr 14, 2025
6f0b623
correct logic to delete node from cluster
nikhilsinhaparseable Apr 14, 2025
7bd0a38
add comments, remove hard coded values for node types
nikhilsinhaparseable Apr 14, 2025
c66fb74
delete from staging for ingestor
nikhilsinhaparseable Apr 14, 2025
264ccf3
replaced to get_stream
nikhilsinhaparseable Apr 14, 2025
70c0342
remove node metadata from parseable struct, add as OnceCell
nikhilsinhaparseable Apr 15, 2025
0049e1b
ingestor_id mapping
nikhilsinhaparseable Apr 15, 2025
87f9803
prism mode in cluster info and metrics
nikhilsinhaparseable Apr 15, 2025
ccf5ef2
convert node metadata to Arc
nikhilsinhaparseable Apr 15, 2025
a717313
coderabbitai suggestions
nikhilsinhaparseable Apr 15, 2025
b043a75
ingestor analytics response check
nikhilsinhaparseable Apr 15, 2025
8af3a4c
remove redundant code
nikhilsinhaparseable Apr 15, 2025
1841a68
process live ingestors in paralllel
nikhilsinhaparseable Apr 15, 2025
04aade9
Update src/handlers/http/cluster/mod.rs
nikhilsinhaparseable Apr 15, 2025
891e38c
rename queries to queriers
nikhilsinhaparseable Apr 16, 2025
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Update src/handlers/http/cluster/mod.rs
Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>
Signed-off-by: Nikhil Sinha <131262146+nikhilsinhaparseable@users.noreply.github.com>
  • Loading branch information
nikhilsinhaparseable and coderabbitai[bot] authored Apr 15, 2025
commit 04aade9b467b2d8d6b4237918400ea183659f33c
10 changes: 9 additions & 1 deletion src/handlers/http/cluster/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -736,7 +736,15 @@ pub async fn get_node_info<T: Metadata + DeserializeOwned>(
)
.await?
.iter()
.filter_map(|x| serde_json::from_slice::<T>(x).ok())
.filter_map(|x| {
match serde_json::from_slice::<T>(x) {
Ok(val) => Some(val),
Err(e) => {
error!("Failed to parse node metadata: {:?}", e);
None
}
}
})
.collect();

Ok(metadata)
Expand Down
Loading